Lines Matching refs:mAdapter
66 BatchingAdapter& mAdapter; in readConfigCommand() member
69 mAdapter(adapter) {} in readConfigCommand()
87 mAdapter.setBatchSize(batchSize); in readConfigCommand()
88 mAdapter.setTripBatchSize(tripBatchSize); in readConfigCommand()
89 mAdapter.setBatchingTimeout(batchingTimeout); in readConfigCommand()
90 mAdapter.setBatchingAccuracy(batchingAccuracy); in readConfigCommand()
104 BatchingAdapter& mAdapter; in setConfigCommand() member
109 mAdapter(adapter), in setConfigCommand()
112 mApi.setBatchSize(mAdapter.getBatchSize()); in setConfigCommand()
113 mApi.setTripBatchSize(mAdapter.getTripBatchSize()); in setConfigCommand()
168 BatchingAdapter& mAdapter; in handleEngineUpEvent() member
173 mAdapter(adapter), in handleEngineUpEvent()
176 mAdapter.setEngineCapabilitiesKnown(true); in handleEngineUpEvent()
177 mAdapter.broadcastCapabilities(mAdapter.getCapabilities()); in handleEngineUpEvent()
178 mApi.setBatchSize(mAdapter.getBatchSize()); in handleEngineUpEvent()
179 mApi.setTripBatchSize(mAdapter.getTripBatchSize()); in handleEngineUpEvent()
180 mAdapter.restartSessions(); in handleEngineUpEvent()
181 for (auto msg: mAdapter.mPendingMsgs) { in handleEngineUpEvent()
182 mAdapter.sendMsg(msg); in handleEngineUpEvent()
184 mAdapter.mPendingMsgs.clear(); in handleEngineUpEvent()
322 BatchingAdapter& mAdapter; in startBatchingCommand() member
333 mAdapter(adapter), in startBatchingCommand()
339 if (!mAdapter.isEngineCapabilitiesKnown()) { in startBatchingCommand()
340 mAdapter.mPendingMsgs.push_back(new MsgStartBatching(*this)); in startBatchingCommand()
345 if (!mAdapter.hasBatchingCallback(mClient)) { in startBatchingCommand()
356 mAdapter.startBatching(mClient, mSessionId, mBatchingOptions); in startBatchingCommand()
358 mAdapter.startTripBatchingMultiplex(mClient, mSessionId, mBatchingOptions); in startBatchingCommand()
360 mAdapter.reportResponse(mClient, LOCATION_ERROR_INVALID_PARAMETER, mSessionId); in startBatchingCommand()
415 BatchingAdapter& mAdapter; in updateBatchingOptionsCommand() member
426 mAdapter(adapter), in updateBatchingOptionsCommand()
432 if (!mAdapter.isEngineCapabilitiesKnown()) { in updateBatchingOptionsCommand()
433 mAdapter.mPendingMsgs.push_back(new MsgUpdateBatching(*this)); in updateBatchingOptionsCommand()
437 if (!mAdapter.isBatchingSession(mClient, mSessionId)) { in updateBatchingOptionsCommand()
444 if (!mAdapter.isTripSession(mSessionId)) { in updateBatchingOptionsCommand()
445 mAdapter.stopBatching(mClient, mSessionId, true, mBatchOptions); in updateBatchingOptionsCommand()
447 mAdapter.stopTripBatchingMultiplex(mClient, mSessionId, true, mBatchOptions); in updateBatchingOptionsCommand()
462 BatchingAdapter& mAdapter; in stopBatchingCommand() member
471 mAdapter(adapter), in stopBatchingCommand()
476 if (!mAdapter.isEngineCapabilitiesKnown()) { in stopBatchingCommand()
477 mAdapter.mPendingMsgs.push_back(new MsgStopBatching(*this)); in stopBatchingCommand()
481 if (!mAdapter.isBatchingSession(mClient, mSessionId)) { in stopBatchingCommand()
485 if (mAdapter.isTripSession(mSessionId)) { in stopBatchingCommand()
486 mAdapter.stopTripBatchingMultiplex(mClient, mSessionId); in stopBatchingCommand()
488 mAdapter.stopBatching(mClient, mSessionId); in stopBatchingCommand()
542 BatchingAdapter& mAdapter; in getBatchedLocationsCommand() member
553 mAdapter(adapter), in getBatchedLocationsCommand()
559 if (!mAdapter.isEngineCapabilitiesKnown()) { in getBatchedLocationsCommand()
560 mAdapter.mPendingMsgs.push_back(new MsgGetBatchedLocations(*this)); in getBatchedLocationsCommand()
564 if (!mAdapter.hasBatchingCallback(mClient)) { in getBatchedLocationsCommand()
566 } else if (!mAdapter.isBatchingSession(mClient, mSessionId)) { in getBatchedLocationsCommand()
570 if (mAdapter.isTripSession(mSessionId)) { in getBatchedLocationsCommand()
572 new LocApiResponse(*mAdapter.getContext(), in getBatchedLocationsCommand()
573 [&mAdapter = mAdapter, mSessionId = mSessionId, in getBatchedLocationsCommand()
575 mAdapter.reportResponse(mClient, err, mSessionId); in getBatchedLocationsCommand()
578 mApi.getBatchedLocations(mCount, new LocApiResponse(*mAdapter.getContext(), in getBatchedLocationsCommand()
579 [&mAdapter = mAdapter, mSessionId = mSessionId, in getBatchedLocationsCommand()
581 mAdapter.reportResponse(mClient, err, mSessionId); in getBatchedLocationsCommand()
585 mAdapter.reportResponse(mClient, err, mSessionId); in getBatchedLocationsCommand()
600 BatchingAdapter& mAdapter; in reportLocationsEvent() member
609 mAdapter(adapter), in reportLocationsEvent()
627 mAdapter.reportLocations(mLocations, mCount, mBatchingMode); in reportLocationsEvent()
650 BatchingAdapter& mAdapter; in reportCompletedTripsEvent() member
655 mAdapter(adapter), in reportCompletedTripsEvent()
667 for(auto itt = mAdapter.mTripSessions.begin(); itt != mAdapter.mTripSessions.end();) in reportCompletedTripsEvent()
677 itt = mAdapter.mTripSessions.erase(itt); in reportCompletedTripsEvent()
679 if (tripSession.tripTBFInterval == mAdapter.mOngoingTripTBFInterval) { in reportCompletedTripsEvent()
681 mAdapter.mTripWithOngoingTBFDropped = true; in reportCompletedTripsEvent()
684 if (tripSession.tripDistance == mAdapter.mOngoingTripDistance) { in reportCompletedTripsEvent()
686 mAdapter.mTripWithOngoingTripDistanceDropped = true; in reportCompletedTripsEvent()
694 mAdapter.reportBatchStatusChange(BATCHING_STATUS_TRIP_COMPLETED, in reportCompletedTripsEvent()
696 mAdapter.restartTripBatching(false, mAccumulatedDistance, 0); in reportCompletedTripsEvent()
698 mAdapter.printTripReport(); in reportCompletedTripsEvent()
727 BatchingAdapter& mAdapter; in reportBatchStatusChangeEvent() member
732 mAdapter(adapter), in reportBatchStatusChangeEvent()
741 mAdapter.reportBatchStatusChange(mBatchStatus, tempList); in reportBatchStatusChangeEvent()