question: private boolean onQueueBufferSuccess ( RecordBuffer < R > buffer , long elapsed ) { queuedRecords += buffer . sizeRecords ( ) ; queuedBytes += buffer . sizeBytesWithOverhead ( ) ; totalQueueWaitTimeMillis . addAndGet ( elapsed ) ; notEmpty . signal ( ) ; return true ; }
target:  Keep private. Call only when holding lock.