Searched refs:mWriteQueue (Results 1 – 3 of 3) sorted by relevance
59 private final ArrayList<WriteQueueItem> mWriteQueue = new ArrayList<>(); field in PersisterQueue109 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()[all …]
66 private final ArrayDeque<WriteQueueItem> mWriteQueue = new ArrayDeque<>(); field in TaskSnapshotPersister171 if (mWriteQueue.isEmpty() && mQueueIdling) { in waitForQueueEmpty()181 mWriteQueue.offer(item); in sendToQueueLocked()193 mWriteQueue.remove(item); in ensureStoreQueueDepthLocked()250 next = mWriteQueue.poll();261 final boolean writeQueueEmpty = mWriteQueue.isEmpty();
394 private List<WriteQueueItem> mWriteQueue = new ArrayList<>(); field in LaunchParamsPersisterTests.TestPersisterQueue399 while (!mWriteQueue.isEmpty()) { in flush()400 final WriteQueueItem item = mWriteQueue.remove(0); in flush()401 final boolean queueEmpty = mWriteQueue.isEmpty(); in flush()421 mWriteQueue.add(item); in addItem()430 for (int i = mWriteQueue.size() - 1; i >= 0; --i) { in findLastItem()431 WriteQueueItem writeQueueItem = mWriteQueue.get(i); in findLastItem()446 for (int i = mWriteQueue.size() - 1; i >= 0; --i) { in removeItems()447 WriteQueueItem writeQueueItem = mWriteQueue.get(i); in removeItems()451 mWriteQueue.remove(i); in removeItems()