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

Class Server

java.lang.Object

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

All Implemented Interfaces:

SelectHandler

public class Server
extends java.lang.Object
implements SelectHandler

Constructor Summary

Constructors

Constructor and Description
Server(Config cfg, java.lang.String host, int port, Progress loop, ChannelHandler channelHandler, boolean fixBuffers)
Server(Config cfg, java.lang.String host, int port, Progress loop, ChannelHandler channelHandler, boolean fixBuffers, int backLog)

Method Summary

Modifier and Type	Method and Description
void	handleAccept(java.nio.channels.SelectableChannel ch) Handle accept availability of channel
void	handleConnect(java.nio.channels.SelectableChannel ch) 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	hasPending() Stop the server while trying to process any queued responses
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)
boolean	start() Start listening on the port
void	stop() Stop the server
void	stopGraceFully(long waitTime) Stop the server while trying to process any queued responses

Methods inherited from class java.lang.Object

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

Constructor Detail

Server

public Server(Config cfg,
              java.lang.String host,
              int port,
              Progress loop,
              ChannelHandler channelHandler,
              boolean fixBuffers)

Server

public Server(Config cfg,
              java.lang.String host,
              int port,
              Progress loop,
              ChannelHandler channelHandler,
              boolean fixBuffers,
              int backLog)

Method Detail

start

public boolean start()

Start listening on the port

Returns:

true if started successfully

stop

public void stop()

Stop the server

hasPending

public boolean hasPending()

Stop the server while trying to process any queued responses

stopGraceFully

public void stopGraceFully(long waitTime)

Stop the server while trying to process any queued responses

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)

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 ch)

Description copied from interface: SelectHandler

Handle a connection ready for channel

Specified by:

handleConnect in interface SelectHandler

Parameters:

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