Java 类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, 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;
}

项目：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, 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;
}

项目：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, 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;
}

项目：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, 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;
}