org.gridgain.grid.util.ipc.loopback

Class GridIpcClientTcpEndpoint

java.lang.Object

org.gridgain.grid.util.ipc.loopback.GridIpcClientTcpEndpoint

All Implemented Interfaces:

Closeable, AutoCloseable, GridIpcEndpoint

public class GridIpcClientTcpEndpoint
extends Object
implements GridIpcEndpoint

Loopback IPC endpoint based on socket.

Constructor Summary

Constructors

Constructor and Description
GridIpcClientTcpEndpoint(Socket clientSock) Creates connected client IPC endpoint.
GridIpcClientTcpEndpoint(String host, int port) Creates and connects client IPC endpoint.

Method Summary

Methods

Modifier and Type	Method and Description
void	close() Closes endpoint.
InputStream	inputStream() Gets input stream associated with this IPC endpoint.
OutputStream	outputStream() Gets output stream associated with this IPC endpoint.

Methods inherited from class java.lang.Object

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

Constructor Detail

GridIpcClientTcpEndpoint

public GridIpcClientTcpEndpoint(Socket clientSock)

Creates connected client IPC endpoint.

Parameters:

clientSock - Connected client socket.

GridIpcClientTcpEndpoint

public GridIpcClientTcpEndpoint(String host,
                        int port)
                         throws GridException

Creates and connects client IPC endpoint.

Parameters:

port - Port.

host - Host.

Throws:

GridException - If connection fails.

Method Detail

inputStream

public InputStream inputStream()
                        throws GridException

Gets input stream associated with this IPC endpoint.

Specified by:

inputStream in interface GridIpcEndpoint

Returns:

IPC input stream.

Throws:

GridException - If error occurred.

outputStream

public OutputStream outputStream()
                          throws GridException

Gets output stream associated with this IPC endpoint.

Specified by:

outputStream in interface GridIpcEndpoint

Returns:

IPC output stream.

Throws:

GridException - If error occurred.

close

public void close()

Closes endpoint. Note that IPC endpoint may acquire native resources so it must be always closed once it is not needed.

Specified by:

close in interface Closeable

Specified by:

close in interface AutoCloseable

Specified by:

close in interface GridIpcEndpoint