operator/src/main/java/oracle/kubernetes/operator/calls/AsyncRequestStep.java
private void handleTimeout(RequestParams requestParams, AsyncFiber fiber, CancellableCall cc) {
      if (firstTimeResumed()) {
        try {
          cc.cancel();
        } finally {
          try (LoggingContext stack = LoggingContext.setThreadContext().namespace(requestParams.namespace)) {
            if (LOGGER.isFinerEnabled()) {
              logTimeout();
            }
            addResponseComponent(Component.createFor(RetryStrategy.class, retryStrategy));
          }
          fiber.resume(packet);
        }
      }
    }
// a callback within the timeout. So cancel the call and prepare to try again.
a callback within the timeout. So cancel the call and prepare to try again.
a callback within the timeout . So cancel the call and prepare to try again .
private void handleTimeout(RequestParams requestParams, AsyncFiber fiber, CancellableCall cc) {
      if (firstTimeResumed()) {
        try {
          cc.cancel();
        } finally {
          try (LoggingContext stack = LoggingContext.setThreadContext().namespace(requestParams.namespace)) {
            if (LOGGER.isFinerEnabled()) {
              logTimeout();
            }
            addResponseComponent(Component.createFor(RetryStrategy.class, retryStrategy));
          }
          fiber.resume(packet);
        }
      }
    }
private void handleTimeout ( RequestParams requestParams , AsyncFiber fiber , CancellableCall cc ) { if ( firstTimeResumed ( ) ) { try { cc . cancel ( ) ; } finally { try ( LoggingContext stack = LoggingContext . setThreadContext ( ) . namespace ( requestParams . namespace ) ) { if ( LOGGER . isFinerEnabled ( ) ) { logTimeout ( ) ; } addResponseComponent ( Component . createFor ( RetryStrategy . class , retryStrategy ) ) ; } fiber . resume ( packet ) ; } } }
a callback within the timeout.
a callback within the timeout .