operator/src/main/java/oracle/kubernetes/operator/DomainProcessorImpl.java
public void reportSuspendedFibers() {
    if (LOGGER.isFineEnabled()) {
      BiConsumer<String, FiberGate> consumer =
          (namespace, gate) -> {
            gate.getCurrentFibers().forEach(
                (key, fiber) -> {
                  Optional.ofNullable(fiber.getSuspendedStep()).ifPresent(suspendedStep -> {
                    try (LoggingContext ignored
                             = LoggingContext.setThreadContext().namespace(namespace).domainUid(getDomainUid(fiber))) {
                      LOGGER.fine("Fiber is SUSPENDED at " + suspendedStep.getName());
                    }
                  });
                });
          };
      makeRightFiberGates.forEach(consumer);
      statusFiberGates.forEach(consumer);
    }
  }
/**
   * Report on currently suspended fibers. This is the first step toward diagnosing if we need special handling
   * to kill or kick these fibers.
   */
Report on currently suspended fibers. This is the first step toward diagnosing if we need special handling
to kill or kick these fibers.
Report on currently suspended fibers . This is the first step toward diagnosing if we need special handling to kill or kick these fibers .
public void reportSuspendedFibers() {
    if (LOGGER.isFineEnabled()) {
      BiConsumer<String, FiberGate> consumer =
          (namespace, gate) -> {
            gate.getCurrentFibers().forEach(
                (key, fiber) -> {
                  Optional.ofNullable(fiber.getSuspendedStep()).ifPresent(suspendedStep -> {
                    try (LoggingContext ignored
                             = LoggingContext.setThreadContext().namespace(namespace).domainUid(getDomainUid(fiber))) {
                      LOGGER.fine("Fiber is SUSPENDED at " + suspendedStep.getName());
                    }
                  });
                });
          };
      makeRightFiberGates.forEach(consumer);
      statusFiberGates.forEach(consumer);
    }
  }
public void reportSuspendedFibers ( ) { if ( LOGGER . isFineEnabled ( ) ) { BiConsumer < String , FiberGate > consumer = ( namespace , gate ) -> { gate . getCurrentFibers ( ) . forEach ( ( key , fiber ) -> { Optional . ofNullable ( fiber . getSuspendedStep ( ) ) . ifPresent ( suspendedStep -> { try ( LoggingContext ignored = LoggingContext . setThreadContext ( ) . namespace ( namespace ) . domainUid ( getDomainUid ( fiber ) ) ) { LOGGER . fine ( "Fiber is SUSPENDED at " + suspendedStep . getName ( ) ) ; } } ) ; } ) ; } ; makeRightFiberGates . forEach ( consumer ) ; statusFiberGates . forEach ( consumer ) ; } }
Report on currently suspended fibers.
Report on currently suspended fibers .