private RecordBuffer<R> onTakeSuccess(RecordBuffer<R> buffer,long elapsed){
  queuedRecords-=buffer.sizeRecords();
  queuedBytes-=buffer.sizeBytesWithOverhead();
  checkPendingRecords();
  totalTakenBuffers.incrementAndGet();
  notFull.signal();
  return buffer;
}

private RecordBuffer < R > onTakeSuccess ( RecordBuffer < R > buffer , long elapsed ) { queuedRecords -= buffer . sizeRecords ( ) ; queuedBytes -= buffer . sizeBytesWithOverhead ( ) ; checkPendingRecords ( ) ; totalTakenBuffers . incrementAndGet ( ) ; notFull . signal ( ) ; return buffer ; }
keep private . call only when holding lock .
