org.apache.hadoop.hdfs.net

Class DomainPeerServer

java.lang.Object

org.apache.hadoop.hdfs.net.DomainPeerServer

All Implemented Interfaces:

Closeable, AutoCloseable, PeerServer

@InterfaceAudience.Private
public class DomainPeerServer
extends Object
implements PeerServer

Constructor Summary

Constructors

Constructor and Description
DomainPeerServer(String path, int port)

Method Summary

Methods

Modifier and Type	Method and Description
Peer	accept() Listens for a connection to be made to this server and accepts it.
void	close() Free the resources associated with this peer server.
String	getBindPath()
String	getListeningString()
void	setReceiveBufferSize(int size) Set the receive buffer size of the PeerServer.
String	toString()

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

Constructor Detail

DomainPeerServer

public DomainPeerServer(String path,
                int port)
                 throws IOException

Throws:

IOException

Method Detail

getBindPath

public String getBindPath()

setReceiveBufferSize

public void setReceiveBufferSize(int size)
                          throws IOException

Description copied from interface: PeerServer

Set the receive buffer size of the PeerServer.

Specified by:

setReceiveBufferSize in interface PeerServer

Parameters:

size - The receive buffer size.

Throws:

IOException

accept

public Peer accept()
            throws IOException,
                   SocketTimeoutException

Description copied from interface: PeerServer

Listens for a connection to be made to this server and accepts it. The method blocks until a connection is made.

Specified by:

accept in interface PeerServer

Throws:

IOException - if an I/O error occurs when waiting for a connection.

SocketTimeoutException - if a timeout was previously set and the timeout has been reached.

getListeningString

public String getListeningString()

Specified by:

getListeningString in interface PeerServer

Returns:

A string representation of the address we're listening on.

close

public void close()
           throws IOException

Description copied from interface: PeerServer

Free the resources associated with this peer server. This normally includes sockets, etc.

Specified by:

close in interface Closeable

Specified by:

close in interface AutoCloseable

Specified by:

close in interface PeerServer

Throws:

IOException - If there is an error closing the PeerServer

toString

public String toString()

Overrides:

toString in class Object