edu.umass.cs.nio.interfaces

Interface InterfaceNIOTransport<NodeIDType,MessageType>

Type Parameters:

NodeIDType -

MessageType -

All Superinterfaces:

AddressMessenger<MessageType>

All Known Subinterfaces:

JSONNIOTransport<NodeIDType>, Messenger<NodeIDType,MessageType>, SSLMessenger<NodeIDType,MessageType>

All Known Implementing Classes:

JSONMessenger, JSONNIOTransport, MessageNIOTransport, PaxosMessenger

public interface InterfaceNIOTransport<NodeIDType,MessageType>
extends AddressMessenger<MessageType>

Author:

arun

Method Summary

Modifier and Type	Method and Description
void	addPacketDemultiplexer(AbstractPacketDemultiplexer<?> pd)
java.net.InetSocketAddress	getListeningSocketAddress()
NodeIDType	getMyID()
NodeConfig<NodeIDType>	getNodeConfig()
SSLDataProcessingWorker.SSL_MODES	getSSLMode()
boolean	isDisconnected(NodeIDType node)
boolean	isStopped()
void	precedePacketDemultiplexer(AbstractPacketDemultiplexer<?> pd)
int	sendToAddress(java.net.InetSocketAddress isa, byte[] msg)
int	sendToAddress(java.net.InetSocketAddress isa, MessageType msg)
int	sendToID(NodeIDType id, byte[] msg)
int	sendToID(NodeIDType id, MessageType msg)
void	stop() Needs to be called to close NIO gracefully.

Method Detail

sendToID

int sendToID(NodeIDType id,
             MessageType msg)
      throws java.io.IOException

Parameters:

id - The destination node ID.

msg - The message to be sent.

Returns:

Number of characters written. The number of characters is calculated by converting MessageType to a String. If MessageType is a byte[], then ISO-8859-1 encoding is used.

Throws:

java.io.IOException

sendToAddress

int sendToAddress(java.net.InetSocketAddress isa,
                  MessageType msg)
           throws java.io.IOException

Specified by:

sendToAddress in interface AddressMessenger<MessageType>

Parameters:

isa -

msg -

Returns:

Number of characters written. The number of characters is calculated by converting MessageType to a String. If MessageType is a byte[], then ISO-8859-1 encoding is used.

Throws:

java.io.IOException

addPacketDemultiplexer

void addPacketDemultiplexer(AbstractPacketDemultiplexer<?> pd)

Parameters:

pd - The demultiplexer to be chained at the end of the existing list.

precedePacketDemultiplexer

void precedePacketDemultiplexer(AbstractPacketDemultiplexer<?> pd)

Parameters:

pd - The demultiplexer is placed at the head of the existing list.

getMyID

NodeIDType getMyID()

Returns:

My node ID.

stop

void stop()

Needs to be called to close NIO gracefully.

getNodeConfig

NodeConfig<NodeIDType> getNodeConfig()

Returns:

Node config used by this NIO transport.

getSSLMode

SSLDataProcessingWorker.SSL_MODES getSSLMode()

Returns:

SSL mode used by this NIO transport.

sendToID

int sendToID(NodeIDType id,
             byte[] msg)
      throws java.io.IOException

Parameters:

id -

msg -

Returns:

Number of bytes written.

Throws:

java.io.IOException

sendToAddress

int sendToAddress(java.net.InetSocketAddress isa,
                  byte[] msg)
           throws java.io.IOException

Specified by:

sendToAddress in interface AddressMessenger<MessageType>

Parameters:

isa -

msg -

Returns:

Number of bytes written.

Throws:

java.io.IOException

isDisconnected

boolean isDisconnected(NodeIDType node)

Parameters:

node -

Returns:

Whether node got disconnected.

getListeningSocketAddress

java.net.InetSocketAddress getListeningSocketAddress()

Returns:

Local socket address.

isStopped

boolean isStopped()

Returns:

True if stopped.