edu.iu.dsc.tws.common.net.tcp

Class Client

java.lang.Object

edu.iu.dsc.tws.common.net.tcp.Client

All Implemented Interfaces:

SelectHandler

public class Client
extends java.lang.Object
implements SelectHandler

Constructor Summary

Constructors

Constructor and Description
Client(java.lang.String host, int port, Config cfg, Progress looper, ChannelHandler handler)
Client(java.lang.String host, int port, Config cfg, Progress looper, ChannelHandler handler, boolean fixBuffers)

Method Summary

Modifier and Type	Method and Description
boolean	connect()
void	disconnect()
void	disconnectGraceFully(long waitTime) Stop the client while trying to process any queued requests and responses
void	handleAccept(java.nio.channels.SelectableChannel ch) Handle accept availability of channel
void	handleConnect(java.nio.channels.SelectableChannel selectableChannel) Handle a connection ready for channel
void	handleError(java.nio.channels.SelectableChannel ch) Handle error of channel
void	handleRead(java.nio.channels.SelectableChannel ch) Handle read availability of channel
void	handleWrite(java.nio.channels.SelectableChannel ch) Handle write availability of channel
boolean	isConnected()
TCPMessage	receive(java.nio.channels.SocketChannel sc, java.nio.ByteBuffer buffer, int size, int edge)
TCPMessage	send(java.nio.channels.SocketChannel sc, java.nio.ByteBuffer buffer, int size, int edge)
void	setHostAndPort(java.lang.String host, int port) this method must be called when the client is disconnected
void	tryConnecting() this method may be called when the target machine may not be up yet this method may be called repeatedly, until it connects connection exceptions are ignored, they are not propagated to connection handler connection attempt fails silently

Methods inherited from class java.lang.Object

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

Constructor Detail

Client

public Client(java.lang.String host,
              int port,
              Config cfg,
              Progress looper,
              ChannelHandler handler)

Client

public Client(java.lang.String host,
              int port,
              Config cfg,
              Progress looper,
              ChannelHandler handler,
              boolean fixBuffers)

Method Detail

setHostAndPort

public void setHostAndPort(java.lang.String host,
                           int port)

this method must be called when the client is disconnected

connect

public boolean connect()

tryConnecting

public void tryConnecting()

this method may be called when the target machine may not be up yet this method may be called repeatedly, until it connects connection exceptions are ignored, they are not propagated to connection handler connection attempt fails silently

isConnected

public boolean isConnected()

send

public TCPMessage send(java.nio.channels.SocketChannel sc,
                       java.nio.ByteBuffer buffer,
                       int size,
                       int edge)

receive

public TCPMessage receive(java.nio.channels.SocketChannel sc,
                          java.nio.ByteBuffer buffer,
                          int size,
                          int edge)

disconnect

public void disconnect()

disconnectGraceFully

public void disconnectGraceFully(long waitTime)

Stop the client while trying to process any queued requests and responses

handleRead

public void handleRead(java.nio.channels.SelectableChannel ch)

Description copied from interface: SelectHandler

Handle read availability of channel

Specified by:

handleRead in interface SelectHandler

Parameters:

ch - socket channel

handleWrite

public void handleWrite(java.nio.channels.SelectableChannel ch)

Description copied from interface: SelectHandler

Handle write availability of channel

Specified by:

handleWrite in interface SelectHandler

Parameters:

ch - socket channel

handleAccept

public void handleAccept(java.nio.channels.SelectableChannel ch)

Description copied from interface: SelectHandler

Handle accept availability of channel

Specified by:

handleAccept in interface SelectHandler

Parameters:

ch - socket channel

handleConnect

public void handleConnect(java.nio.channels.SelectableChannel selectableChannel)

Description copied from interface: SelectHandler

Handle a connection ready for channel

Specified by:

handleConnect in interface SelectHandler

Parameters:

selectableChannel - socket channel

handleError

public void handleError(java.nio.channels.SelectableChannel ch)

Description copied from interface: SelectHandler

Handle error of channel

Specified by:

handleError in interface SelectHandler

Parameters:

ch - socket channel