Searched refs:mWriteQueue (Results 1 – 3 of 3) sorted by relevance
59 private final ArrayList<WriteQueueItem> mWriteQueue = new ArrayList<>(); field in PersisterQueue137 mWriteQueue.add(item); in addItem()139 if (flush || mWriteQueue.size() > MAX_WRITE_QUEUE_LENGTH) { in addItem()148 for (int i = mWriteQueue.size() - 1; i >= 0; --i) { in findLastItem()149 WriteQueueItem writeQueueItem = mWriteQueue.get(i); in findLastItem()181 for (int i = mWriteQueue.size() - 1; i >= 0; --i) { in removeItems()182 WriteQueueItem writeQueueItem = mWriteQueue.get(i); in removeItems()187 mWriteQueue.remove(i); in removeItems()243 while (mWriteQueue.isEmpty()) { in processNextItem()258 item = mWriteQueue.remove(0); in processNextItem()[all …]
63 private final ArrayDeque<WriteQueueItem> mWriteQueue = new ArrayDeque<>(); field in SnapshotPersistQueue122 return mWriteQueue.isEmpty() || mQueueIdling || mPaused; in isQueueEmpty()155 if (mWriteQueue.isEmpty() && mQueueIdling) { in waitForQueueEmpty()171 return mWriteQueue.size(); in peekQueueSize()176 mWriteQueue.removeFirstOccurrence(item); in addToQueueInternal()178 mWriteQueue.addFirst(item); in addToQueueInternal()180 mWriteQueue.addLast(item); in addToQueueInternal()205 mWriteQueue.remove(item); in ensureStoreQueueDepthLocked()235 next = mWriteQueue.poll();241 mWriteQueue.addLast(next);[all …]
529 private List<WriteQueueItem> mWriteQueue = new ArrayList<>(); field in LaunchParamsPersisterTests.TestPersisterQueue534 while (!mWriteQueue.isEmpty()) { in flush()535 final WriteQueueItem item = mWriteQueue.remove(0); in flush()536 final boolean queueEmpty = mWriteQueue.isEmpty(); in flush()556 mWriteQueue.add(item); in addItem()565 for (int i = mWriteQueue.size() - 1; i >= 0; --i) { in findLastItem()566 WriteQueueItem writeQueueItem = mWriteQueue.get(i); in findLastItem()581 for (int i = mWriteQueue.size() - 1; i >= 0; --i) { in removeItems()582 WriteQueueItem writeQueueItem = mWriteQueue.get(i); in removeItems()586 mWriteQueue.remove(i); in removeItems()