com.facebook.buck.io.unixsocket

Class UnixDomainSocket

java.lang.Object

java.net.Socket

com.facebook.buck.io.unixsocket.UnixDomainSocket

All Implemented Interfaces:

Transport, Closeable, AutoCloseable

public class UnixDomainSocket
extends Socket
implements Transport

Implements a Socket backed by a native Unix domain socket.

Instances of this class always return null for Socket.getInetAddress(), Socket.getLocalAddress(), Socket.getLocalSocketAddress(), Socket.getRemoteSocketAddress().

If not explicitly closed, will close the file descriptor when finalized.

Caller is responsible for closing the streams returned from getInputStream() and getOutputStream().

Method Summary

Modifier and Type	Method and Description
void	close()
static UnixDomainSocket	createSocketWithPath(Path path) Creates a Unix domain socket bound to a path.
protected void	finalize()
InputStream	getInputStream() Returns an input stream for reading messages
OutputStream	getOutputStream() Returns an input stream for writing messages.
boolean	isConnected()
void	shutdownInput()
void	shutdownOutput()

Methods inherited from class java.net.Socket

bind, connect, connect, getChannel, getInetAddress, getKeepAlive, getLocalAddress, getLocalPort, getLocalSocketAddress, getOOBInline, getPort, getReceiveBufferSize, getRemoteSocketAddress, getReuseAddress, getSendBufferSize, getSoLinger, getSoTimeout, getTcpNoDelay, getTrafficClass, isBound, isClosed, isInputShutdown, isOutputShutdown, sendUrgentData, setKeepAlive, setOOBInline, setPerformancePreferences, setReceiveBufferSize, setReuseAddress, setSendBufferSize, setSocketImplFactory, setSoLinger, setSoTimeout, setTcpNoDelay, setTrafficClass, toString

Methods inherited from class java.lang.Object

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

Method Detail

createSocketWithPath

public static UnixDomainSocket createSocketWithPath(Path path)
                                             throws IOException

Creates a Unix domain socket bound to a path.

Throws:

IOException

isConnected

public boolean isConnected()

Overrides:

isConnected in class Socket

getInputStream

public InputStream getInputStream()

Description copied from interface: Transport

Returns an input stream for reading messages

Specified by:

getInputStream in interface Transport

Overrides:

getInputStream in class Socket

Returns:

an input stream for reading messages in this IPC

getOutputStream

public OutputStream getOutputStream()

Description copied from interface: Transport

Returns an input stream for writing messages.

Specified by:

getOutputStream in interface Transport

Overrides:

getOutputStream in class Socket

Returns:

an input stream for writing messages in this IPC

shutdownInput

public void shutdownInput()
                   throws IOException

Overrides:

shutdownInput in class Socket

Throws:

IOException

shutdownOutput

public void shutdownOutput()
                    throws IOException

Overrides:

shutdownOutput in class Socket

Throws:

IOException

close

public void close()
           throws IOException

Specified by:

close in interface Closeable

Specified by:

close in interface AutoCloseable

Overrides:

close in class Socket

Throws:

IOException

finalize

protected void finalize()
                 throws IOException

Overrides:

finalize in class Object

Throws:

IOException