Home
last modified time | relevance | path

Searched refs:getDomainSocket (Results 1 – 12 of 12) 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 DEncryptedPeer.java134 public DomainSocket getDomainSocket() { in getDomainSocket() method in EncryptedPeer
135 return enclosedPeer.getDomainSocket(); in getDomainSocket()
H A DPeer.java114 public DomainSocket getDomainSocket(); in getDomainSocket() method
H A DBasicInetPeer.java125 public DomainSocket getDomainSocket() { in getDomainSocket() method in BasicInetPeer
H A DDomainPeer.java114 public DomainSocket getDomainSocket() { in getDomainSocket() method in DomainPeer
H A DNioInetPeer.java128 public DomainSocket getDomainSocket() { in getDomainSocket() method in NioInetPeer
/dports/devel/hadoop2/hadoop-2.7.2-src/hadoop-common-project/hadoop-common/src/main/java/org/apache/hadoop/net/unix/
H A DDomainSocketWatcher.java142 DomainSocket getDomainSocket() { in getDomainSocket() method in DomainSocketWatcher.Entry
403 DomainSocket sock = entry.getDomainSocket(); in sendCallback()
473 DomainSocket sock = entry.getDomainSocket();
524 sendCallback("close", entries, fdSet, entry.getDomainSocket().fd);
/dports/devel/hadoop2/hadoop-2.7.2-src/hadoop-hdfs-project/hadoop-hdfs/src/main/java/org/apache/hadoop/hdfs/shortcircuit/
H A DDfsClientShmManager.java175 DomainSocket sock = peer.getDomainSocket(); in requestNewShm()
266 domainSocketWatcher.add(peer.getDomainSocket(), shm); in allocSlot()
379 shm.getPeer().getDomainSocket().shutdown(); in shutdown()
H A DShortCircuitCache.java192 final DomainSocket shmSock = shm.getPeer().getDomainSocket(); in run()
/dports/devel/hadoop2/hadoop-2.7.2-src/hadoop-hdfs-project/hadoop-hdfs/src/main/java/org/apache/hadoop/hdfs/
H A DBlockReaderFactory.java484 peer.getDomainSocket() + ". Allocating a new one..."); in createShortCircuitReplicaInfo()
509 "Disabling domain socket " + peer.getDomainSocket(), e); in createShortCircuitReplicaInfo()
543 DomainSocket sock = peer.getDomainSocket(); in requestFileDescriptors()
657 "domain socket " + peer.getDomainSocket(), ioe); in getRemoteBlockReaderFromDomain()
H A DPeerCache.java203 multimap.put(new Key(dnId, peer.getDomainSocket() != null), in putInternal()
/dports/devel/hadoop2/hadoop-2.7.2-src/hadoop-hdfs-project/hadoop-hdfs/src/test/java/org/apache/hadoop/hdfs/
H A DTestPeerCache.java121 public DomainSocket getDomainSocket() { in getDomainSocket() method in TestPeerCache.FakePeer
277 assertTrue(peer.getDomainSocket() != null);
/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.java310 if (peer.getDomainSocket() == null) { in requestShortCircuitFds()
348 DomainSocket sock = peer.getDomainSocket(); in requestShortCircuitFds()
441 DomainSocket sock = peer.getDomainSocket(); in requestShortCircuitShm()