org.apache.ignite.internal.processors.hadoop.impl.igfs

Class HadoopIgfsIpcIo

java.lang.Object

org.apache.ignite.internal.processors.hadoop.impl.igfs.HadoopIgfsIpcIo

All Implemented Interfaces:

HadoopIgfsIo

public class HadoopIgfsIpcIo
extends Object
implements HadoopIgfsIo

IO layer implementation based on blocking IPC streams.

Constructor Summary

Constructors

Constructor and Description
HadoopIgfsIpcIo(String endpointAddr, IgfsMarshaller marsh, org.apache.commons.logging.Log log)

Method Summary

Modifier and Type	Method and Description
void	addEventListener(HadoopIgfsIpcIoListener lsnr) Adds event listener that will be invoked when connection with server is lost or remote error has occurred.
void	forceClose() Closes this IO instance, removing it from cache.
static HadoopIgfsIpcIo	get(org.apache.commons.logging.Log log, String endpoint) Returns a started and valid instance of this class for a given endpoint.
void	release() Releases this instance, decrementing usage count.
void	removeEventListener(HadoopIgfsIpcIoListener lsnr) Removes event listener that will be invoked when connection with server is lost or remote error has occurred.
IgniteInternalFuture<IgfsMessage>	send(IgfsMessage msg) Sends given IGFS client message and asynchronously awaits for response.
<T> IgniteInternalFuture<T>	send(IgfsMessage msg, byte[] outBuf, int outOff, int outLen) Sends given IGFS client message and asynchronously awaits for response.
void	sendPlain(IgfsMessage msg) Sends given message and does not wait for response.
String	toString()

Methods inherited from class java.lang.Object

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

Constructor Detail

HadoopIgfsIpcIo

public HadoopIgfsIpcIo(String endpointAddr,
                       IgfsMarshaller marsh,
                       org.apache.commons.logging.Log log)

Parameters:

endpointAddr - Endpoint.

marsh - Protocol.

log - Logger to use.

Method Detail

get

public static HadoopIgfsIpcIo get(org.apache.commons.logging.Log log,
                                  String endpoint)
                           throws IOException

Returns a started and valid instance of this class for a given endpoint.

Parameters:

log - Logger to use for new instance.

endpoint - Endpoint string.

Returns:

New or existing cached instance, which is started and operational.

Throws:

IOException - If new instance was created but failed to start.

release

public void release()

Releases this instance, decrementing usage count.

If usage count becomes zero, the instance is stopped and removed from cache.

forceClose

public void forceClose()

Closes this IO instance, removing it from cache.

addEventListener

public void addEventListener(HadoopIgfsIpcIoListener lsnr)

Adds event listener that will be invoked when connection with server is lost or remote error has occurred. If connection is closed already, callback will be invoked synchronously inside this method.

Specified by:

addEventListener in interface HadoopIgfsIo

Parameters:

lsnr - Event listener.

removeEventListener

public void removeEventListener(HadoopIgfsIpcIoListener lsnr)

Removes event listener that will be invoked when connection with server is lost or remote error has occurred.

Specified by:

removeEventListener in interface HadoopIgfsIo

Parameters:

lsnr - Event listener.

send

public IgniteInternalFuture<IgfsMessage> send(IgfsMessage msg)
                                       throws IgniteCheckedException

Sends given IGFS client message and asynchronously awaits for response.

Specified by:

send in interface HadoopIgfsIo

Parameters:

msg - Message to send.

Returns:

Future that will be completed.

Throws:

IgniteCheckedException - If a message cannot be sent (connection is broken or client was closed).

send

public <T> IgniteInternalFuture<T> send(IgfsMessage msg,
                                        @Nullable
                                        byte[] outBuf,
                                        int outOff,
                                        int outLen)
                                 throws IgniteCheckedException

Sends given IGFS client message and asynchronously awaits for response. When IO detects response beginning for given message it stops reading data and passes input stream to closure which can read response in a specific way.

Specified by:

send in interface HadoopIgfsIo

Parameters:

msg - Message to send.

outBuf - Output buffer. If null, the output buffer is not used.

outOff - Output buffer offset.

outLen - Output buffer length.

Returns:

Future that will be completed when response is returned from closure.

Throws:

IgniteCheckedException - If a message cannot be sent (connection is broken or client was closed).

sendPlain

public void sendPlain(IgfsMessage msg)
               throws IgniteCheckedException

Sends given message and does not wait for response.

Specified by:

sendPlain in interface HadoopIgfsIo

Parameters:

msg - Message to send.

Throws:

IgniteCheckedException - If send failed.

toString

public String toString()

Overrides:

toString in class Object