hadoop-hdds/server-scm/src/main/java/org/apache/hadoop/hdds/scm/container/replication/InProgressPool.java
public void handleContainerReport(
      ContainerReportsRequestProto containerReport) {
    if (status == ProgressStatus.InProgress) {
      executorService.submit(processContainerReport(containerReport));
    } else {
      LOG.debug("Cannot handle container report when the pool is in {} status.",
          status);
    }
  }
/**
   * Queues a container Report for handling. This is done in a worker thread
   * since decoding a container report might be compute intensive . We don't
   * want to block since we have asked for bunch of container reports
   * from a set of datanodes.
   *
   * @param containerReport - ContainerReport
   */
Queues a container Report for handling. This is done in a worker thread
since decoding a container report might be compute intensive . We don't
want to block since we have asked for bunch of container reports
from a set of datanodes.

@param containerReport - ContainerReport
Queues a container Report for handling . This is done in a worker thread since decoding a container report might be compute intensive . We don ' t want to block since we have asked for bunch of container reports from a set of datanodes . @param containerReport - ContainerReport
public void handleContainerReport(
      ContainerReportsRequestProto containerReport) {
    if (status == ProgressStatus.InProgress) {
      executorService.submit(processContainerReport(containerReport));
    } else {
      LOG.debug("Cannot handle container report when the pool is in {} status.",
          status);
    }
  }
public void handleContainerReport ( ContainerReportsRequestProto containerReport ) { if ( status == ProgressStatus . InProgress ) { executorService . submit ( processContainerReport ( containerReport ) ) ; } else { LOG . debug ( "Cannot handle container report when the pool is in {} status." , status ) ; } }
Queues a container Report for handling.
Queues a container Report for handling .