Searched refs:mWriteQueue (Results 1 – 3 of 3) sorted by relevance
125 ArrayList<WriteQueueItem> mWriteQueue = new ArrayList<WriteQueueItem>(); field in TaskPersister168 for (int queueNdx = mWriteQueue.size() - 1; queueNdx >= 0; --queueNdx) { in removeThumbnails()169 final WriteQueueItem item = mWriteQueue.get(queueNdx); in removeThumbnails()177 mWriteQueue.remove(queueNdx); in removeThumbnails()257 for (queueNdx = mWriteQueue.size() - 1; queueNdx >= 0; --queueNdx) { in wakeup()258 final WriteQueueItem item = mWriteQueue.get(queueNdx); in wakeup()269 mWriteQueue.add(new TaskWriteQueueItem(task)); in wakeup()274 mWriteQueue.add(new WriteQueueItem()); in wakeup()276 if (flush || mWriteQueue.size() > MAX_WRITE_QUEUE_LENGTH) { in wakeup()282 + mNextWriteTime + " mWriteQueue.size=" + mWriteQueue.size() in wakeup()[all …]
57 private final BlockingQueue<ProtoOutputStream> mWriteQueue = new ArrayBlockingQueue<>(200); field in WindowTracing73 mWriteQueue.clear(); in startTrace()101 while (!mWriteQueue.isEmpty()) { in stopTrace()122 if (!mWriteQueue.offer(proto)) { in appendTraceEntry()137 proto = mWriteQueue.take(); in loopOnce()
62 private final ArrayDeque<WriteQueueItem> mWriteQueue = new ArrayDeque<>(); field in TaskSnapshotPersister149 if (mWriteQueue.isEmpty() && mQueueIdling) { in waitForQueueEmpty()159 mWriteQueue.offer(item); in sendToQueueLocked()171 mWriteQueue.remove(item); in ensureStoreQueueDepthLocked()228 next = mWriteQueue.poll();239 final boolean writeQueueEmpty = mWriteQueue.isEmpty();