private void initialDecodeTasks ( final ChannelHandlerContext ctx ) { currentRequest = sentRequestQueue . poll ( ) ; currentDecodingState = DecodingState . STARTED ; if ( currentRequest != null ) { Long st = sentRequestTimings . poll ( ) ; if ( st != null ) { currentOpTime = System . nanoTime ( ) - st ; } else { currentOpTime = - 1 ; } } if ( env ( ) . operationTracingEnabled ( ) ) { Span dispatchSpan = dispatchSpans . poll ( ) ; if ( dispatchSpan != null ) { currentDispatchSpan = dispatchSpan ; } } if ( traceEnabled ) { LOGGER . trace ( "{}Started decoding of {}" , logIdent ( ctx , endpoint ) , currentRequest ) ; } }
Helper method which performs the initial decoding process .