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

Interface HadoopIgfsIo

All Known Implementing Classes:

HadoopIgfsIpcIo

public interface HadoopIgfsIo

IO abstraction layer for IGFS client. Two kind of messages are expected to be sent: requests with response and request without response.

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	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.

Method Detail

send

IgniteInternalFuture<IgfsMessage> send(IgfsMessage msg)
                                throws IgniteCheckedException

Sends given IGFS client message and asynchronously awaits for response.

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

<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.

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

void sendPlain(IgfsMessage msg)
        throws IgniteCheckedException

Sends given message and does not wait for response.

Parameters:

msg - Message to send.

Throws:

IgniteCheckedException - If send failed.

addEventListener

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.

Parameters:

lsnr - Event listener.

removeEventListener

void removeEventListener(HadoopIgfsIpcIoListener lsnr)

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

Parameters:

lsnr - Event listener.