text: public synchronized void setFlushPending(ThreadState perThread) {assert !perThread.flushPending;if (perThread.dwpt.getNumDocsInRAM() > 0) {perThread.flushPending = true; final long bytes = perThread.bytesUsed;flushBytes += bytes;activeBytes -= bytes;numPending++; assert assertMemory();} }