Searched refs:mTasks (Results 1 – 10 of 10) sorted by relevance
| /hardware/interfaces/broadcastradio/common/utils/ |
| D | WorkerThread.cpp | 58 mTasks.push(Task({when, std::move(task), std::move(cancelTask)})); in schedule()
64 while (!mTasks.empty()) { in cancelAll()
65 auto task = mTasks.top(); in cancelAll()
67 mTasks.pop(); in cancelAll()
77 if (mTasks.empty()) { in threadLoop()
82 auto task = mTasks.top(); in threadLoop()
88 mTasks.pop(); in threadLoop()
|
| /hardware/google/pixel/power-libperfmgr/aidl/ |
| D | SessionTaskMap.cpp | 44 mTasks[taskId].push_back(sessValPtr); in add()
84 auto taskItr = mTasks.find(taskId); in getTaskVoteRange()
85 if (taskItr == mTasks.end()) { in getTaskVoteRange()
116 auto itr = mTasks.find(taskId); in getSessionIds()
117 if (itr == mTasks.end()) { in getSessionIds()
163 auto taskItr = mTasks.find(taskId); in remove()
164 if (taskItr == mTasks.end()) { in remove()
180 mTasks.erase(taskItr); in remove()
196 auto taskItr = mTasks.find(taskId); in removeDeadTaskSessionMap()
197 if (taskItr == mTasks.end()) { in removeDeadTaskSessionMap()
[all …]
|
| D | SessionTaskMap.h | 88 auto taskSessItr = mTasks.find(taskId); in forEachSessionInTask()
89 if (taskSessItr == mTasks.end()) { in forEachSessionInTask()
128 std::unordered_map<pid_t, std::vector<std::shared_ptr<SessionValueEntry>>> mTasks; variable
|
| /hardware/interfaces/automotive/remoteaccess/test_grpc_server/impl/src/ |
| D | TestWakeupClientServiceImpl.cpp | 75 if (mTasks.size() == 0) { in maybePopOne()
78 TaskInfo response = std::move(mTasks.top()); in maybePopOne()
79 mTasks.pop(); in maybePopOne()
90 mTasks.push(TaskInfo{ in add()
104 return mTasks.size() > 0 || mStopped; in waitForTask()
122 return mTasks.size() == 0 || mStopped; in isEmpty()
131 while (mTasks.size() > 0) { in handleTaskTimeout()
132 const TaskInfo& taskInfo = mTasks.top(); in handleTaskTimeout()
139 mTasks.pop(); in handleTaskTimeout()
|
| /hardware/interfaces/broadcastradio/common/utils/include/broadcastradio-utils/ |
| D | WorkerThread.h | 49 std::priority_queue<Task> mTasks GUARDED_BY(mMut);
|
| /hardware/google/pixel/power-libperfmgr/aidl/tests/ |
| D | PowerHintSessionTest.cpp | 223 ASSERT_EQ(sessManager->mSessionTaskMap.mTasks[deadThreadID].size(), 2); in TEST_F()
231 ASSERT_EQ(sessManager->mSessionTaskMap.mTasks[deadThreadID].size(), 1); in TEST_F()
233 ASSERT_EQ(sessManager->mSessionTaskMap.mTasks.count(deadThreadID), 0); in TEST_F()
|
| /hardware/interfaces/automotive/remoteaccess/hal/default/src/ |
| D | RemoteAccessService.cpp | 677 mTasks.push_back({ in onRemoteTaskRequested()
686 std::string s = StringPrintf("Received %zu tasks in %f seconds", mTasks.size(), in printTasks()
688 for (size_t i = 0; i < mTasks.size(); i++) { in printTasks()
689 StringAppendF(&s, "Client Id: %s, Data: %s\n", mTasks[i].clientId.c_str(), in printTasks()
690 printBytes(mTasks[i].data).c_str()); in printTasks()
|
| /hardware/interfaces/automotive/remoteaccess/hal/default/include/ |
| D | RemoteAccessService.h | 56 std::vector<TaskData> mTasks; variable
|
| /hardware/google/gfxstream/guest/platform/rutabaga/ |
| D | RutabagaLayer.cpp | 239 std::queue<VirtioGpuTaskWithWaitable> mTasks; member in gfxstream::EmulatedVirtioGpu::EmulatedVirtioGpuImpl
760 mTasks.push(VirtioGpuTaskWithWaitable{ in EnqueueVirtioGpuTask()
1008 if (!mTasks.empty()) { in RunVirtioGpuTaskProcessingLoop()
1009 task = std::move(mTasks.front()); in RunVirtioGpuTaskProcessingLoop()
1010 mTasks.pop(); in RunVirtioGpuTaskProcessingLoop()
|
| /hardware/interfaces/automotive/remoteaccess/test_grpc_server/impl/include/ |
| D | TestWakeupClientServiceImpl.h | 92 std::priority_queue<TaskInfo, std::vector<TaskInfo>, TaskInfoComparator> mTasks
|