Home
last modified time | relevance | path

Searched refs:mCmdQueue (Results 1 – 4 of 4) sorted by relevance

/packages/modules/StatsD/lib/libstatssocket/
Dstats_buffer_writer_queue.cpp51 return mCmdQueue.size(); in getQueueSize()
57 if (mCmdQueue.size() >= kQueueMaxSizeLimit) { in pushToQueue()
62 mCmdQueue.push(cmd); in pushToQueue()
93 while (!mCmdQueue.empty()) { in drainQueue()
94 free(mCmdQueue.front().buffer); in drainQueue()
95 mCmdQueue.pop(); in drainQueue()
105 if (mCmdQueue.empty()) { in processCommands()
106 mCondition.wait(lock, [this] { return !this->mCmdQueue.empty(); }); in processCommands()
108 cmd = mCmdQueue.front(); in processCommands()
127 mCmdQueue.pop(); in processCommands()
Dstats_buffer_writer_queue_impl.h50 std::queue<Cmd> mCmdQueue; variable
/packages/apps/Messaging/src/com/android/messaging/util/
DNotificationPlayer.java63 private final LinkedList<Command> mCmdQueue = new LinkedList<Command>(); field in NotificationPlayer
183 synchronized (mCmdQueue) { in run()
187 cmd = mCmdQueue.removeFirst(); in run()
205 synchronized (mCmdQueue) { in run()
206 if (mCmdQueue.size() == 0) { in run()
226 synchronized (mCmdQueue) { in onCompletion()
227 if (mCmdQueue.size() == 0) { in onCompletion()
286 synchronized (mCmdQueue) { in play()
303 synchronized (mCmdQueue) { in stop()
318 mCmdQueue.add(cmd); in enqueueLocked()
/packages/modules/StatsD/lib/libstatspull/
Dstats_pull_atom_callback.cpp310 std::queue<std::unique_ptr<Cmd>> mCmdQueue; member in CallbackOperationsHandler
317 mCmdQueue.push(std::move(cmd)); in pushToQueue()
343 mCmdQueue.swap(emptyQueue); in processCommands()
355 if (mCmdQueue.empty()) { in processCommands()
360 cmd = std::move(mCmdQueue.front()); in processCommands()
361 mCmdQueue.pop(); in processCommands()