code: func (p *FlushByRamOrCountsPolicy) markLargestWriterPending(control *DocumentsWriterFlushControl,
  	perThreadState *ThreadState, currentBytesPerThread int64) {
  	control.setFlushPending(p.findLargestNonPendingWriter(control, perThreadState))
  }
docs: /* Marks the mos tram consuming active DWPT flush pending */