org.apache.hadoop.hdfs.net.EncryptedPeer的实例源码

项目：hadoop    文件：SaslDataTransferClient.java   

/**
 * Sends client SASL negotiation for a peer if required.
 *
 * @param peer connection peer
 * @param encryptionKeyFactory for creation of an encryption key
 * @param accesstoken connection block access token
 * @param datanodeId ID of destination Datanode
 * @return new pair of streams,wrapped after SASL negotiation
 * @throws IOException for any error
 */
public Peer peerSend(Peer peer,DataEncryptionKeyFactory encryptionKeyFactory,Token<BlockTokenIdentifier> accesstoken,DatanodeID datanodeId)
    throws IOException {
  IOStreamPair ios = checkTrustAndSend(getPeerAddress(peer),peer.getoutputStream(),peer.getInputStream(),encryptionKeyFactory,accesstoken,datanodeId);
  // Todo: Consider renaming EncryptedPeer to SaslPeer.
  return ios != null ? new EncryptedPeer(peer,ios) : peer;
}

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

/**
 * Sends client SASL negotiation for a peer if required.
 *
 * @param peer connection peer
 * @param encryptionKeyFactory for creation of an encryption key
 * @param accesstoken connection block access token
 * @param datanodeId ID of destination Datanode
 * @return new pair of streams,ios) : peer;
}

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

/**
 * Sends client SASL negotiation for a peer if required.
 *
 * @param peer connection peer
 * @param encryptionKeyFactory for creation of an encryption key
 * @param accesstoken connection block access token
 * @param datanodeId ID of destination Datanode
 * @return new pair of streams,ios) : peer;
}

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

/**
 * Sends client SASL negotiation for a peer if required.
 *
 * @param peer connection peer
 * @param encryptionKeyFactory for creation of an encryption key
 * @param accesstoken connection block access token
 * @param datanodeId ID of destination Datanode
 * @return new pair of streams,ios) : peer;
}

项目：FlexMap    文件：SaslDataTransferClient.java   

/**
 * Sends client SASL negotiation for a peer if required.
 *
 * @param peer connection peer
 * @param encryptionKeyFactory for creation of an encryption key
 * @param accesstoken connection block access token
 * @param datanodeId ID of destination Datanode
 * @return new pair of streams,ios) : peer;
}