insert e into the backing queue or block until we can . if we block and the queue changes on us , we will insert while the queue is drained . concode_field_sep RpcScheduler scheduler concode_elem_sep AtomicReference<BlockingQueue<E>> putRef concode_elem_sep int CHECKPOINT_NUM concode_elem_sep boolean clientBackOffEnabled concode_elem_sep long CHECKPOINT_INTERVAL_MS concode_elem_sep AtomicReference<BlockingQueue<E>> takeRef concode_elem_sep Log LOG concode_field_sep int parseNumLevels concode_elem_sep void setClientBackoffEnabled concode_elem_sep void addResponseTime concode_elem_sep T createScheduler concode_elem_sep Class<? extends BlockingQueue<E>> convertQueueClass concode_elem_sep T createCallQueueInstance concode_elem_sep Class<? extends RpcScheduler> convertSchedulerClass concode_elem_sep boolean shouldBackOff concode_elem_sep void swapQueue concode_elem_sep boolean queueIsReallyEmpty concode_elem_sep boolean offer concode_elem_sep E take concode_elem_sep int size concode_elem_sep boolean isClientBackoffEnabled concode_elem_sep String stringRepr concode_elem_sep int getPriorityLevel
void function ( E arg0 ) { putRef . get ( ) . put ( arg0 ) ; }