boolean function ( ) { if ( currentBackoff < 0 ) { return false ; } if ( currentBackoff == 0 ) { currentBackoff = initialBackoff ; return true ; } else if ( currentBackoff < maxBackoff ) { currentBackoff = Math . min ( currentBackoff * 2 , maxBackoff ) ; return true ; } return false ; }
increases the current backoff and returns whether the operation was successful . concode_field_sep AtomicReference<Throwable> cause concode_elem_sep int initialBackoff concode_elem_sep int maxBackoff concode_elem_sep ResultPartitionID partitionId concode_elem_sep int currentBackoff concode_elem_sep SingleInputGate inputGate concode_elem_sep int channelIndex concode_field_sep void requestSubpartition concode_elem_sep void notifySubpartitionConsumed concode_elem_sep void releaseAllResources concode_elem_sep int getChannelIndex concode_elem_sep Buffer getNextBuffer concode_elem_sep void setError concode_elem_sep int getCurrentBackoff concode_elem_sep void notifyAvailableBuffer concode_elem_sep void sendTaskEvent concode_elem_sep void checkError concode_elem_sep boolean isReleased