public T take(){
  T element=pending.poll();
  if (hadoop_ipc_class_checker_hack.isHadoopIPCCall(element))   hadoop_ipc_class_checker_hack.setCallEnqueue(element,avail);
  if (hadoop_ipc_class_checker_hack.isHBaseCallRunner(element))   hadoop_ipc_class_checker_hack.setCallRunnerEnqueue(element,avail);
  int new_count=count.decrementAndGet();
  if (new_count != 0) {
    enqueue();
  }
  taggregator.throttled(tenantId,0L);
  return element;
}

public T take ( ) { T element = pending . poll ( ) ; if ( hadoop_ipc_class_checker_hack . isHadoopIPCCall ( element ) ) hadoop_ipc_class_checker_hack . setCallEnqueue ( element , avail ) ; if ( hadoop_ipc_class_checker_hack . isHBaseCallRunner ( element ) ) hadoop_ipc_class_checker_hack . setCallRunnerEnqueue ( element , avail ) ; int new_count = count . decrementAndGet ( ) ; if ( new_count != 0 ) { enqueue ( ) ; } taggregator . throttled ( tenantId , 0L ) ; return element ; }
this method can only be called when we know that there are pending elements . it is an error if this method is called but there are no pending elements
