Home
last modified time | relevance | path

Searched refs:getRemoteAddressString (Results 1 – 10 of 10) sorted by relevance

/dports/devel/hadoop2/hadoop-2.7.2-src/hadoop-hdfs-project/hadoop-hdfs/src/main/java/org/apache/hadoop/hdfs/net/
H A DDomainPeer.java83 public String getRemoteAddressString() { in getRemoteAddressString() method in DomainPeer
110 return "DomainPeer(" + getRemoteAddressString() + ")"; in toString()
H A DEncryptedPeer.java104 public String getRemoteAddressString() { in getRemoteAddressString() method in EncryptedPeer
105 return enclosedPeer.getRemoteAddressString(); in getRemoteAddressString()
H A DPeer.java82 public String getRemoteAddressString(); in getRemoteAddressString() method
H A DBasicInetPeer.java95 public String getRemoteAddressString() { in getRemoteAddressString() method in BasicInetPeer
H A DNioInetPeer.java98 public String getRemoteAddressString() { in getRemoteAddressString() method in NioInetPeer
/dports/devel/hadoop2/hadoop-2.7.2-src/hadoop-hdfs-project/hadoop-hdfs/src/main/java/org/apache/hadoop/hdfs/server/datanode/
H A DDataXceiver.java137 remoteAddress = peer.getRemoteAddressString(); in DataXceiver()
202 "at " + peer.getRemoteAddressString() + ". Perhaps the client " + in run()
207 "handshake from client at " + peer.getRemoteAddressString() + in run()
561 LOG.warn("Client " + peer.getRemoteAddressString() + in readBlock()
675 peer.getRemoteAddressString(), in writeBlock()
987 "to " + peer.getRemoteAddressString() + " because it's pinned ";
994 "to " + peer.getRemoteAddressString() + " because threads " +
1023 LOG.info("Copied " + block + " to " + peer.getRemoteAddressString());
1059 " from " + peer.getRemoteAddressString() + " because threads " +
1142 LOG.info("Moved " + block + " from " + peer.getRemoteAddressString()
[all …]
/dports/devel/hadoop2/hadoop-2.7.2-src/hadoop-hdfs-project/hadoop-hdfs/src/main/java/org/apache/hadoop/hdfs/
H A DRemoteBlockReader2.java347 peer.getRemoteAddressString() + ": " + e.getMessage()); in sendReadResult()
452 + ", remote=" + peer.getRemoteAddressString() in checkSuccess()
H A DRemoteBlockReader.java486 peer.getRemoteAddressString() + ": " + e.getMessage()); in sendReadResult()
/dports/devel/hadoop2/hadoop-2.7.2-src/hadoop-hdfs-project/hadoop-hdfs/src/test/java/org/apache/hadoop/hdfs/
H A DTestPeerCache.java91 public String getRemoteAddressString() { in getRemoteAddressString() method in TestPeerCache.FakePeer
/dports/devel/hadoop2/hadoop-2.7.2-src/hadoop-hdfs-project/hadoop-hdfs/src/main/java/org/apache/hadoop/hdfs/protocol/datatransfer/sasl/
H A DDataTransferSaslUtil.java160 String remoteAddr = peer.getRemoteAddressString().split(":")[0]; in getPeerAddress()