128     result = "session {" + std::to_string(event.clientId) + "," + std::to_string(event.sessionId) +  in toString()
139                  SessionIdType sessionId)  in CallbackImpl()  argument
140           : mOwner(owner), mClientId(clientId), mSessionId(sessionId) {}  in CallbackImpl()
204 void TranscoderWrapper::reportError(ClientIdType clientId, SessionIdType sessionId,  in reportError()  argument
212             auto it = mPausedStateMap.find(SessionKeyType(clientId, sessionId));  in reportError()
214                 mPausedStateMap.emplace(SessionKeyType(clientId, sessionId),  in reportError()
218             callback->onResourceLost(clientId, sessionId);  in reportError()
220             callback->onError(clientId, sessionId, toTranscodingError(err));  in reportError()
225 void TranscoderWrapper::start(ClientIdType clientId, SessionIdType sessionId,  in start()  argument
229     queueEvent(Event::Start, clientId, sessionId, [=] {  in start()
230         media_status_t err = handleStart(clientId, sessionId, request, callingUid, clientCb);  in start()
233             reportError(clientId, sessionId, err);  in start()
237                 callback->onStarted(clientId, sessionId);  in start()
243 void TranscoderWrapper::pause(ClientIdType clientId, SessionIdType sessionId) {  in pause()  argument
244     queueEvent(Event::Pause, clientId, sessionId, [=] {  in pause()
245         media_status_t err = handlePause(clientId, sessionId);  in pause()
250             reportError(clientId, sessionId, err);  in pause()
254                 callback->onPaused(clientId, sessionId);  in pause()
260 void TranscoderWrapper::resume(ClientIdType clientId, SessionIdType sessionId,  in resume()  argument
264     queueEvent(Event::Resume, clientId, sessionId, [=] {  in resume()
265         media_status_t err = handleResume(clientId, sessionId, request, callingUid, clientCb);  in resume()
268             reportError(clientId, sessionId, err);  in resume()
272                 callback->onResumed(clientId, sessionId);  in resume()
278 void TranscoderWrapper::stop(ClientIdType clientId, SessionIdType sessionId, bool abandon) {  in stop()  argument
279     queueEvent(Event::Stop, clientId, sessionId, [=] {  in stop()
281             sessionId == mCurrentSessionId) {  in stop()
293             mPausedStateMap.erase(SessionKeyType(clientId, sessionId));  in stop()
303 void TranscoderWrapper::onFinish(ClientIdType clientId, SessionIdType sessionId) {  in onFinish()  argument
304     queueEvent(Event::Finish, clientId, sessionId, [=] {  in onFinish()
306             sessionId == mCurrentSessionId) {  in onFinish()
313             callback->onFinish(clientId, sessionId);  in onFinish()
318 void TranscoderWrapper::onError(ClientIdType clientId, SessionIdType sessionId,  in onError()  argument
321             Event::Error, clientId, sessionId,  in onError()
324                     sessionId == mCurrentSessionId) {  in onError()
328                 reportError(clientId, sessionId, error);  in onError()
333 void TranscoderWrapper::onProgress(ClientIdType clientId, SessionIdType sessionId,  in onProgress()  argument
336             Event::Progress, clientId, sessionId,  in onProgress()
340                     callback->onProgressUpdate(clientId, sessionId, progress);  in onProgress()
346 void TranscoderWrapper::onHeartBeat(ClientIdType clientId, SessionIdType sessionId) {  in onHeartBeat()  argument
347     queueEvent(Event::HeartBeat, clientId, sessionId, [=] {  in onHeartBeat()
350             callback->onHeartBeat(clientId, sessionId);  in onHeartBeat()
356         ClientIdType clientId, SessionIdType sessionId, const TranscodingRequestParcel& request,  in setupTranscoder()  argument
389     callback->onHeartBeat(clientId, sessionId);  in setupTranscoder()
405     callback->onHeartBeat(clientId, sessionId);  in setupTranscoder()
408     mCurrentSessionId = sessionId;  in setupTranscoder()
410     mTranscoderCb = std::make_shared<CallbackImpl>(shared_from_this(), clientId, sessionId);  in setupTranscoder()
419     callback->onHeartBeat(clientId, sessionId);  in setupTranscoder()
428     callback->onHeartBeat(clientId, sessionId);  in setupTranscoder()
437     callback->onHeartBeat(clientId, sessionId);  in setupTranscoder()
458         callback->onHeartBeat(clientId, sessionId);  in setupTranscoder()
468     callback->onHeartBeat(clientId, sessionId);  in setupTranscoder()
474         ClientIdType clientId, SessionIdType sessionId, const TranscodingRequestParcel& request,  in handleStart()  argument
479             setupTranscoder(clientId, sessionId, request, callingUid, clientCb, &reason);  in handleStart()
499 media_status_t TranscoderWrapper::handlePause(ClientIdType clientId, SessionIdType sessionId) {  in handlePause()  argument
505     if (clientId != mCurrentClientId || sessionId != mCurrentSessionId) {  in handlePause()
507               (long long)clientId, sessionId, (long long)mCurrentClientId, mCurrentSessionId);  in handlePause()
519     mPausedStateMap[SessionKeyType(clientId, sessionId)] = pauseStates;  in handlePause()
526         ClientIdType clientId, SessionIdType sessionId, const TranscodingRequestParcel& request,  in handleResume()  argument
529     auto it = mPausedStateMap.find(SessionKeyType(clientId, sessionId));  in handleResume()
540     media_status_t err = setupTranscoder(clientId, sessionId, request, callingUid, clientCb,  in handleResume()
585 void TranscoderWrapper::queueEvent(Event::Type type, ClientIdType clientId, SessionIdType sessionId,  in queueEvent()  argument
598     mQueue.push_back({type, clientId, sessionId, runnable, arg});  in queueEvent()