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");
  }
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 ( isRefilling ) checkAndResetRefillState ( key . getTick ( ) ) ; if ( timeout != 0L ) { 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 ; } } } 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.
@param key