Searched refs:mWriteQueue (Results 1 – 3 of 3) sorted by relevance
109 mWriteQueue.add(item); in addItem()111 if (flush || mWriteQueue.size() > MAX_WRITE_QUEUE_LENGTH) { in addItem()120 for (int i = mWriteQueue.size() - 1; i >= 0; --i) { in findLastItem()121 WriteQueueItem writeQueueItem = mWriteQueue.get(i); in findLastItem()153 for (int i = mWriteQueue.size() - 1; i >= 0; --i) { in removeItems()154 WriteQueueItem writeQueueItem = mWriteQueue.get(i); in removeItems()159 mWriteQueue.remove(i); in removeItems()215 while (mWriteQueue.isEmpty()) { in processNextItem()230 item = mWriteQueue.remove(0); in processNextItem()235 + " mWriteQueue.size=" + mWriteQueue.size()); in processNextItem()[all …]
56 private final ArrayDeque<WriteQueueItem> mWriteQueue = new ArrayDeque<>(); field in SnapshotPersistQueue107 if (mWriteQueue.isEmpty() && mQueueIdling) { in waitForQueueEmpty()117 mWriteQueue.offer(item); in sendToQueueLocked()129 mWriteQueue.remove(item); in ensureStoreQueueDepthLocked()157 next = mWriteQueue.poll();163 mWriteQueue.addLast(next);175 final boolean writeQueueEmpty = mWriteQueue.isEmpty();
514 private List<WriteQueueItem> mWriteQueue = new ArrayList<>(); field in LaunchParamsPersisterTests.TestPersisterQueue519 while (!mWriteQueue.isEmpty()) { in flush()520 final WriteQueueItem item = mWriteQueue.remove(0); in flush()521 final boolean queueEmpty = mWriteQueue.isEmpty(); in flush()541 mWriteQueue.add(item); in addItem()550 for (int i = mWriteQueue.size() - 1; i >= 0; --i) { in findLastItem()551 WriteQueueItem writeQueueItem = mWriteQueue.get(i); in findLastItem()566 for (int i = mWriteQueue.size() - 1; i >= 0; --i) { in removeItems()567 WriteQueueItem writeQueueItem = mWriteQueue.get(i); in removeItems()571 mWriteQueue.remove(i); in removeItems()