hadoop-hdds/server-scm/src/test/java/org/apache/hadoop/hdds/scm/node/TestNodeManager.java
private void heartbeatNodeSet(SCMNodeManager manager,
                                List<DatanodeDetails> list,
                                int sleepDuration) throws InterruptedException {
    while (!Thread.currentThread().isInterrupted()) {
      for (DatanodeDetails dn : list) {
        manager.sendHeartbeat(dn.getProtoBufMessage(), null, reportState);
      }
      Thread.sleep(sleepDuration);
    }
  }
/**
   * Heartbeat a given set of nodes at a specified frequency.
   *
   * @param manager       - Node Manager
   * @param list          - List of datanodeIDs
   * @param sleepDuration - Duration to sleep between heartbeats.
   * @throws InterruptedException
   */
Heartbeat a given set of nodes at a specified frequency.
@param manager       - Node Manager
@param list          - List of datanodeIDs
@param sleepDuration - Duration to sleep between heartbeats.
Heartbeat a given set of nodes at a specified frequency . @param manager - Node Manager @param list - List of datanodeIDs @param sleepDuration - Duration to sleep between heartbeats .
private void heartbeatNodeSet(SCMNodeManager manager,
                                List<DatanodeDetails> list,
                                int sleepDuration) throws InterruptedException {
    while (!Thread.currentThread().isInterrupted()) {
      for (DatanodeDetails dn : list) {
        manager.sendHeartbeat(dn.getProtoBufMessage(), null, reportState);
      }
      Thread.sleep(sleepDuration);
    }
  }
private void heartbeatNodeSet ( SCMNodeManager manager , List < DatanodeDetails > list , int sleepDuration ) throws InterruptedException { while ( ! Thread . currentThread ( ) . isInterrupted ( ) ) { for ( DatanodeDetails dn : list ) { manager . sendHeartbeat ( dn . getProtoBufMessage ( ) , null , reportState ) ; } Thread . sleep ( sleepDuration ) ; } }
Heartbeat a given set of nodes at a specified frequency.
Heartbeat a given set of nodes at a specified frequency .