Java 类org.apache.hadoop.hdfs.server.protocol.NodeRegistration 实例源码

项目：hadoop 文件：NameNodeRpcServer.java

/** 
 * Verifies the given registration.
 * 
 * @param nodeReg node registration
 * @throws UnregisteredNodeException if the registration is invalid
 */
private void verifyRequest(NodeRegistration nodeReg) throws IOException {
  // verify registration ID
  final String id = nodeReg.getRegistrationID();
  final String expectedID = namesystem.getRegistrationID();
  if (!expectedID.equals(id)) {
    LOG.warn("Registration IDs mismatched: the "
        + nodeReg.getClass().getSimpleName() + " ID is " + id
        + " but the expected ID is " + expectedID);
     throw new UnregisteredNodeException(nodeReg);
  }
}

项目：aliyun-oss-hadoop-fs 文件：NameNodeRpcServer.java

/** 
 * Verifies the given registration.
 * 
 * @param nodeReg node registration
 * @throws UnregisteredNodeException if the registration is invalid
 */
private void verifyRequest(NodeRegistration nodeReg) throws IOException {
  // verify registration ID
  final String id = nodeReg.getRegistrationID();
  final String expectedID = namesystem.getRegistrationID();
  if (!expectedID.equals(id)) {
    LOG.warn("Registration IDs mismatched: the "
        + nodeReg.getClass().getSimpleName() + " ID is " + id
        + " but the expected ID is " + expectedID);
     throw new UnregisteredNodeException(nodeReg);
  }
}

项目：big-c 文件：NameNodeRpcServer.java

/** 
 * Verifies the given registration.
 * 
 * @param nodeReg node registration
 * @throws UnregisteredNodeException if the registration is invalid
 */
private void verifyRequest(NodeRegistration nodeReg) throws IOException {
  // verify registration ID
  final String id = nodeReg.getRegistrationID();
  final String expectedID = namesystem.getRegistrationID();
  if (!expectedID.equals(id)) {
    LOG.warn("Registration IDs mismatched: the "
        + nodeReg.getClass().getSimpleName() + " ID is " + id
        + " but the expected ID is " + expectedID);
     throw new UnregisteredNodeException(nodeReg);
  }
}

项目：hadoop-2.6.0-cdh5.4.3 文件：NameNodeRpcServer.java

/** 
 * Verifies the given registration.
 * 
 * @param nodeReg node registration
 * @throws UnregisteredNodeException if the registration is invalid
 */
private void verifyRequest(NodeRegistration nodeReg) throws IOException {
  // verify registration ID
  final String id = nodeReg.getRegistrationID();
  final String expectedID = namesystem.getRegistrationID();
  if (!expectedID.equals(id)) {
    LOG.warn("Registration IDs mismatched: the "
        + nodeReg.getClass().getSimpleName() + " ID is " + id
        + " but the expected ID is " + expectedID);
     throw new UnregisteredNodeException(nodeReg);
  }
}

项目：hadoop-plus 文件：NameNodeRpcServer.java

/** 
 * Verifies the given registration.
 * 
 * @param nodeReg node registration
 * @throws UnregisteredNodeException if the registration is invalid
 */
void verifyRequest(NodeRegistration nodeReg) throws IOException {
  verifyLayoutVersion(nodeReg.getVersion());
  if (!namesystem.getRegistrationID().equals(nodeReg.getRegistrationID())) {
    LOG.warn("Invalid registrationID - expected: "
        + namesystem.getRegistrationID() + " received: "
        + nodeReg.getRegistrationID());
    throw new UnregisteredNodeException(nodeReg);
  }
}

项目：FlexMap 文件：NameNodeRpcServer.java

/** 
 * Verifies the given registration.
 * 
 * @param nodeReg node registration
 * @throws UnregisteredNodeException if the registration is invalid
 */
private void verifyRequest(NodeRegistration nodeReg) throws IOException {
  // verify registration ID
  final String id = nodeReg.getRegistrationID();
  final String expectedID = namesystem.getRegistrationID();
  if (!expectedID.equals(id)) {
    LOG.warn("Registration IDs mismatched: the "
        + nodeReg.getClass().getSimpleName() + " ID is " + id
        + " but the expected ID is " + expectedID);
     throw new UnregisteredNodeException(nodeReg);
  }
}

项目：hops 文件：NameNodeRpcServer.java

/**
 * Verifies the given registration.
 *
 * @param nodeReg
 *     node registration
 * @throws UnregisteredNodeException
 *     if the registration is invalid
 */
void verifyRequest(NodeRegistration nodeReg) throws IOException {
  verifyLayoutVersion(nodeReg.getVersion());
  if (!namesystem.getRegistrationID().equals(nodeReg.getRegistrationID())) {
    LOG.warn("Invalid registrationID - expected: " +
        namesystem.getRegistrationID() + " received: " +
        nodeReg.getRegistrationID());
    throw new UnregisteredNodeException(nodeReg);
  }
}

项目：hadoop-TCP 文件：NameNodeRpcServer.java

/** 
 * Verifies the given registration.
 * 
 * @param nodeReg node registration
 * @throws UnregisteredNodeException if the registration is invalid
 */
void verifyRequest(NodeRegistration nodeReg) throws IOException {
  verifyLayoutVersion(nodeReg.getVersion());
  if (!namesystem.getRegistrationID().equals(nodeReg.getRegistrationID())) {
    LOG.warn("Invalid registrationID - expected: "
        + namesystem.getRegistrationID() + " received: "
        + nodeReg.getRegistrationID());
    throw new UnregisteredNodeException(nodeReg);
  }
}

项目：hardfs 文件：NameNodeRpcServer.java

/** 
 * Verifies the given registration.
 * 
 * @param nodeReg node registration
 * @throws UnregisteredNodeException if the registration is invalid
 */
void verifyRequest(NodeRegistration nodeReg) throws IOException {
  verifyLayoutVersion(nodeReg.getVersion());
  if (!namesystem.getRegistrationID().equals(nodeReg.getRegistrationID())) {
    LOG.warn("Invalid registrationID - expected: "
        + namesystem.getRegistrationID() + " received: "
        + nodeReg.getRegistrationID());
    throw new UnregisteredNodeException(nodeReg);
  }
}

项目：hadoop-on-lustre2 文件：NameNodeRpcServer.java

/** 
 * Verifies the given registration.
 * 
 * @param nodeReg node registration
 * @throws UnregisteredNodeException if the registration is invalid
 */
private void verifyRequest(NodeRegistration nodeReg) throws IOException {
  // verify registration ID
  final String id = nodeReg.getRegistrationID();
  final String expectedID = namesystem.getRegistrationID();
  if (!expectedID.equals(id)) {
    LOG.warn("Registration IDs mismatched: the "
        + nodeReg.getClass().getSimpleName() + " ID is " + id
        + " but the expected ID is " + expectedID);
     throw new UnregisteredNodeException(nodeReg);
  }
}

项目：hadoop 文件：UnregisteredNodeException.java

public UnregisteredNodeException(NodeRegistration nodeReg) {
  super("Unregistered server: " + nodeReg.toString());
}

项目：aliyun-oss-hadoop-fs 文件：UnregisteredNodeException.java

public UnregisteredNodeException(NodeRegistration nodeReg) {
  super("Unregistered server: " + nodeReg.toString());
}

项目：big-c 文件：UnregisteredNodeException.java

public UnregisteredNodeException(NodeRegistration nodeReg) {
  super("Unregistered server: " + nodeReg.toString());
}

项目：hadoop-2.6.0-cdh5.4.3 文件：UnregisteredNodeException.java

public UnregisteredNodeException(NodeRegistration nodeReg) {
  super("Unregistered server: " + nodeReg.toString());
}

项目：hadoop-plus 文件：UnregisteredNodeException.java

public UnregisteredNodeException(NodeRegistration nodeReg) {
  super("Unregistered server: " + nodeReg.toString());
}

项目：FlexMap 文件：UnregisteredNodeException.java

public UnregisteredNodeException(NodeRegistration nodeReg) {
  super("Unregistered server: " + nodeReg.toString());
}

项目：hops 文件：UnregisteredNodeException.java

public UnregisteredNodeException(NodeRegistration nodeReg) {
  super("Unregistered server: " + nodeReg.toString());
}

项目：hadoop-TCP 文件：UnregisteredNodeException.java

public UnregisteredNodeException(NodeRegistration nodeReg) {
  super("Unregistered server: " + nodeReg.toString());
}

项目：hardfs 文件：UnregisteredNodeException.java

public UnregisteredNodeException(NodeRegistration nodeReg) {
  super("Unregistered server: " + nodeReg.toString());
}

项目：hadoop-on-lustre2 文件：UnregisteredNodeException.java

public UnregisteredNodeException(NodeRegistration nodeReg) {
  super("Unregistered server: " + nodeReg.toString());
}

项目：cumulus 文件：UnregisteredNodeException.java

public UnregisteredNodeException(NodeRegistration nodeReg) {
  super("Unregistered server: " + nodeReg.toString());
}

项目：cumulus 文件：NameNode.java

/** 
 * Verify request.
 * 
 * Verifies correctness of the datanode version, registration ID, and 
 * if the datanode does not need to be shutdown.
 * 
 * @param nodeReg data node registration
 * @throws IOException
 */
public void verifyRequest(NodeRegistration nodeReg) throws IOException {
  verifyVersion(nodeReg.getVersion());
  if (!namesystem.getRegistrationID().equals(nodeReg.getRegistrationID()))
    throw new UnregisteredNodeException(nodeReg);
}