Lines Matching refs:sessionKey
40 String8 TranscodingSessionController::sessionToString(const SessionKeyType& sessionKey) { in sessionToString() argument
41 return String8::format("{client:%lld, session:%d}", (long long)sessionKey.first, in sessionToString()
42 sessionKey.second); in sessionToString()
179 SessionKeyType sessionKey = mSessionToWatch; in threadLoop() local
181 ALOGE("Watchdog timeout: %s", sessionToString(sessionKey).c_str()); in threadLoop()
184 mOwner->onError(sessionKey.first, sessionKey.second, in threadLoop()
406 for (auto& sessionKey : mSessionQueues[uid]) { in dumpAllSessions() local
407 auto sessionIt = mSessionMap.find(sessionKey); in dumpAllSessions()
410 sessionToString(sessionKey).c_str()); in dumpAllSessions()
573 const SessionKeyType& sessionKey) { in addUidToSession_l() argument
595 mSessionQueues[clientUid].push_back(sessionKey); in addUidToSession_l()
599 const SessionKeyType& sessionKey, Session::State finalState, in removeSession_l() argument
601 ALOGV("%s: session %s", __FUNCTION__, sessionToString(sessionKey).c_str()); in removeSession_l()
603 if (mSessionMap.count(sessionKey) == 0) { in removeSession_l()
604 ALOGE("session %s doesn't exist", sessionToString(sessionKey).c_str()); in removeSession_l()
611 for (uid_t uid : mSessionMap[sessionKey].allClientUids) { in removeSession_l()
623 auto it = std::find(sessionQueue.begin(), sessionQueue.end(), sessionKey); in removeSession_l()
626 sessionToString(sessionKey).c_str(), uid); in removeSession_l()
647 mSessionMap[sessionKey].allClientUids = remainingUids; in removeSession_l()
652 if (mCurrentSession == &mSessionMap[sessionKey]) { in removeSession_l()
656 setSessionState_l(&mSessionMap[sessionKey], finalState); in removeSession_l()
660 for (uid_t uid : mSessionMap[sessionKey].allClientUids) { in removeSession_l()
661 mPacer->onSessionCompleted(uid, mSessionMap[sessionKey].runningTime); in removeSession_l()
664 mSessionHistory.push_back(mSessionMap[sessionKey]); in removeSession_l()
670 mSessionMap.erase(sessionKey); in removeSession_l()
730 SessionKeyType sessionKey = std::make_pair(clientId, sessionId); in submit() local
732 ALOGV("%s: session %s, uid %d, prioirty %d", __FUNCTION__, sessionToString(sessionKey).c_str(), in submit()
737 if (mSessionMap.count(sessionKey) > 0) { in submit()
738 ALOGE("session %s already exists", sessionToString(sessionKey).c_str()); in submit()
754 mSessionMap[sessionKey].key = sessionKey; in submit()
755 mSessionMap[sessionKey].callingUid = callingUid; in submit()
756 mSessionMap[sessionKey].allClientUids.insert(clientUid); in submit()
757 mSessionMap[sessionKey].request = request; in submit()
758 mSessionMap[sessionKey].callback = callback; in submit()
759 setSessionState_l(&mSessionMap[sessionKey], Session::NOT_STARTED); in submit()
761 addUidToSession_l(clientUid, sessionKey); in submit()
770 SessionKeyType sessionKey = std::make_pair(clientId, sessionId); in cancel() local
772 ALOGV("%s: session %s", __FUNCTION__, sessionToString(sessionKey).c_str()); in cancel()
791 if (mSessionMap.count(sessionKey) == 0) { in cancel()
792 ALOGE("session %s doesn't exist", sessionToString(sessionKey).c_str()); in cancel()
795 sessionsToRemove.push_back(sessionKey); in cancel()
826 SessionKeyType sessionKey = std::make_pair(clientId, sessionId); in addClientUid() local
830 if (mSessionMap.count(sessionKey) == 0) { in addClientUid()
831 ALOGE("session %s doesn't exist", sessionToString(sessionKey).c_str()); in addClientUid()
835 if (mSessionMap[sessionKey].allClientUids.count(clientUid) > 0) { in addClientUid()
836 ALOGE("session %s already has uid %d", sessionToString(sessionKey).c_str(), clientUid); in addClientUid()
840 mSessionMap[sessionKey].allClientUids.insert(clientUid); in addClientUid()
841 addUidToSession_l(clientUid, sessionKey); in addClientUid()
851 SessionKeyType sessionKey = std::make_pair(clientId, sessionId); in getClientUids() local
855 if (mSessionMap.count(sessionKey) == 0) { in getClientUids()
856 ALOGE("session %s doesn't exist", sessionToString(sessionKey).c_str()); in getClientUids()
861 for (uid_t uid : mSessionMap[sessionKey].allClientUids) { in getClientUids()
871 SessionKeyType sessionKey = std::make_pair(clientId, sessionId); in getSession() local
875 if (mSessionMap.count(sessionKey) == 0) { in getSession()
876 ALOGE("session %s doesn't exist", sessionToString(sessionKey).c_str()); in getSession()
880 *(TranscodingRequest*)request = mSessionMap[sessionKey].request; in getSession()
887 SessionKeyType sessionKey = std::make_pair(clientId, sessionId); in notifyClient() local
891 if (mSessionMap.count(sessionKey) == 0) { in notifyClient()
893 sessionToString(sessionKey).c_str()); in notifyClient()
900 if (mSessionMap[sessionKey].getState() == Session::NOT_STARTED) { in notifyClient()
902 sessionToString(sessionKey).c_str()); in notifyClient()
906 ALOGV("%s: session %s %s", __FUNCTION__, sessionToString(sessionKey).c_str(), reason); in notifyClient()
907 func(sessionKey); in notifyClient()
911 notifyClient(clientId, sessionId, "started", [=](const SessionKeyType& sessionKey) { in onStarted() argument
912 auto callback = mSessionMap[sessionKey].callback.lock(); in onStarted()
920 notifyClient(clientId, sessionId, "paused", [=](const SessionKeyType& sessionKey) { in onPaused() argument
921 auto callback = mSessionMap[sessionKey].callback.lock(); in onPaused()
929 notifyClient(clientId, sessionId, "resumed", [=](const SessionKeyType& sessionKey) { in onResumed() argument
930 auto callback = mSessionMap[sessionKey].callback.lock(); in onResumed()
938 notifyClient(clientId, sessionId, "finish", [=](const SessionKeyType& sessionKey) { in onFinish() argument
940 auto clientCallback = mSessionMap[sessionKey].callback.lock(); in onFinish()
949 removeSession_l(sessionKey, Session::FINISHED); in onFinish()
960 notifyClient(clientId, sessionId, "error", [=](const SessionKeyType& sessionKey) { in onError() argument
971 auto clientCallback = mSessionMap[sessionKey].callback.lock(); in onError()
978 removeSession_l(sessionKey, Session::ERROR); in onError()
989 notifyClient(clientId, sessionId, "progress", [=](const SessionKeyType& sessionKey) { in onProgressUpdate() argument
990 auto callback = mSessionMap[sessionKey].callback.lock(); in onProgressUpdate()
994 mSessionMap[sessionKey].lastProgress = progress; in onProgressUpdate()
1006 notifyClient(clientId, sessionId, "resource_lost", [=](const SessionKeyType& sessionKey) { in onResourceLost() argument
1011 Session* resourceLostSession = &mSessionMap[sessionKey]; in onResourceLost()
1014 sessionToString(sessionKey).c_str()); in onResourceLost()
1024 clientCallback->onTranscodingPaused(sessionKey.second); in onResourceLost()
1171 for (auto& sessionKey : mSessionQueues[uid]) { in validateState_l() local
1172 LOG_ALWAYS_FATAL_IF(mSessionMap.count(sessionKey) != 1, in validateState_l()
1174 sessionToString(sessionKey).c_str()); in validateState_l()