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 …]
57 private final ArrayDeque<WriteQueueItem> mWriteQueue = new ArrayDeque<>(); field in SnapshotPersistQueue108 if (mWriteQueue.isEmpty() && mQueueIdling) { in waitForQueueEmpty()119 return mWriteQueue.size(); in peekQueueSize()124 mWriteQueue.removeFirstOccurrence(item); in addToQueueInternal()126 mWriteQueue.addFirst(item); in addToQueueInternal()128 mWriteQueue.addLast(item); in addToQueueInternal()151 mWriteQueue.remove(item); in ensureStoreQueueDepthLocked()181 next = mWriteQueue.poll();187 mWriteQueue.addLast(next);199 final boolean writeQueueEmpty = mWriteQueue.isEmpty();[all …]
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()