code: func (fc *DocumentsWriterFlushControl) pruneBlockedQueue(flushingQueue *DocumentsWriterDeleteQueue) {
  	for e := fc.blockedFlushes.Front(); e != nil; e = e.Next() {
  		if blockedFlush := e.Value.(*BlockedFlush); blockedFlush.dwpt.deleteQueue == flushingQueue {
  			fc.blockedFlushes.Remove(e)
  			_, ok := fc.flushingWriters[blockedFlush.dwpt]
  			assert2(!ok, "DWPT is already flushing")
  			// Record the flushing DWPT to reduce flushBytes in doAfterFlush
  			fc.flushingWriters[blockedFlush.dwpt] = blockedFlush.bytes
  			// don't decr pending here - its already done when DWPT is blocked
  			fc.flushQueue.PushBack(blockedFlush.dwpt)
  		}
  	}
  }
docs: /*
  Prunes the blockedQueue by removing all DWPT that are associated with
  the given flush queue.
  */