protected final void completedReceivedNoPrefetch ( AIStreamKey key , boolean reissueGet ) { if ( TraceComponent . isAnyTracingEnabled ( ) && tc . isEntryEnabled ( ) ) SibTr . entry ( this , tc , "completedReceivedNoPrefetch" , new Object [ ] { key , Boolean . valueOf ( reissueGet ) } ) ; boolean initiateRefill = false ; long timeout = key . getOriginalTimeout ( ) ; synchronized ( this ) { if ( timeout == SIMPConstants . INFINITE_TIMEOUT ) { countOfOutstandingInfiniteTimeoutGets -- ; if ( TraceComponent . isAnyTracingEnabled ( ) && tc . isDebugEnabled ( ) ) SibTr . debug ( tc , "readAhead change: countOfOutstandingInfiniteTimeoutGets-- " + countOfOutstandingInfiniteTimeoutGets ) ; } // If the completed that came in was for a refill request then we can allow normal // operations to resume if ( isRefilling ) checkAndResetRefillState ( key . getTick ( ) ) ; // redrive a request that encompasses any requests that came in while we // were busy trying to refill. if ( timeout != 0L ) // no wait { if ( timeout != SIMPConstants . INFINITE_TIMEOUT ) { long currTime = System . currentTimeMillis ( ) ; long expectedResponseTime = currTime + rcd . getRoundTripTime ( ) ; long timeoutTime = key . getIssueTime ( ) + key . getOriginalTimeout ( ) ; if ( expectedResponseTime < timeoutTime ) timeout = timeoutTime - currTime ; else timeout = 0L ; } } } // end of sync // Reissue request if we have a suitable timeout (infinite or positive) if ( reissueGet && ( timeout == SIMPConstants . INFINITE_TIMEOUT || timeout > 0 ) ) { if ( initiateRefill ) initiateRefill ( ) ; waiting ( timeout , false ) ; } if ( TraceComponent . isAnyTracingEnabled ( ) && tc . isEntryEnabled ( ) ) SibTr . exit ( this , tc , "completedReceivedNoPrefetch" ) ; }
This method will never be called for messages received due to gets issued by the RemoteQPConsumerKeyGroup .