edu.umass.cs.nio

Class JSONNIOTransport<NodeIDType>

java.lang.Object

edu.umass.cs.nio.NIOTransport<NodeIDType>

edu.umass.cs.nio.MessageNIOTransport<NodeIDType,org.json.JSONObject>

edu.umass.cs.nio.JSONNIOTransport<NodeIDType>

Type Parameters:

NodeIDType - Consider using JSONMessenger any place you want to use this class. The former subsumes this class and also has support for MessagingTask objects. This class exists primarily as a wrapper around NIOTransport to support JSON messages. NIOTransport is for general-purpose NIO byte stream communication between numbered nodes as specified by the NodeConfig interface and a data processing worker as specified by the DataProcessingWorker interface that handles byte arrays. This class provides the abstraction of JSON messages and a corresponding PacketDemultiplexer that handles JSON messages instead of raw bytes. Currently, there is no way to directly use NIOTransport other than with MessageNIOTransport or JSONNIOTransport.

All Implemented Interfaces:

AddressMessenger<org.json.JSONObject>, HandshakeCallback, InterfaceNIOTransport<NodeIDType,org.json.JSONObject>, java.lang.Runnable

public class JSONNIOTransport<NodeIDType>
extends MessageNIOTransport<NodeIDType,org.json.JSONObject>

Author:

V. Arun

Nested Class Summary

Nested classes/interfaces inherited from class edu.umass.cs.nio.NIOTransport

NIOTransport.AlternatingByteBuffer

Field Summary

Fields inherited from class edu.umass.cs.nio.MessageNIOTransport

NIO_CHARSET_ENCODING, RCVR_ADDRESS_FIELD, RCVR_IP_FIELD, RCVR_PORT_FIELD, SNDR_ADDRESS_FIELD, SNDR_IP_FIELD, SNDR_PORT_FIELD

Fields inherited from class edu.umass.cs.nio.NIOTransport

DEFAULT_SSL_MODE, MAX_PAYLOAD_SIZE, MAX_QUEUED_SENDS, MIN_INTER_CONNECT_TIME, myID, nodeConfig, worker, WRITE_BUFFER_SIZE

Constructor Summary

Constructors

Constructor and Description
JSONNIOTransport(NodeIDType id, NodeConfig<NodeIDType> nodeConfig) Initiates transporter with id and nodeConfig.
JSONNIOTransport(NodeIDType id, NodeConfig<NodeIDType> nodeConfig, AbstractPacketDemultiplexer<?> pd, boolean start)
JSONNIOTransport(NodeIDType id, NodeConfig<NodeIDType> nodeConfig, AbstractPacketDemultiplexer<?> pd, SSLDataProcessingWorker.SSL_MODES sslMode)
JSONNIOTransport(NodeIDType id, NodeConfig<NodeIDType> nodeConfig, SSLDataProcessingWorker.SSL_MODES sslMode)

Method Summary

Methods inherited from class edu.umass.cs.nio.MessageNIOTransport

addPacketDemultiplexer, getMyID, getNodeConfig, getReceiverAddress, getReceiverAddress, getReceiverAddressJSONSmart, getSenderAddress, getSenderAddress, getSenderAddressAsString, getSenderAddressJSONSmart, getSenderInetAddress, main, precedePacketDemultiplexer, sendToAddress, sendToAddress, sendToID, sendToID, sendToIDInternal, setName, stop

Methods inherited from class edu.umass.cs.nio.NIOTransport

cleanup, getCompression, getCompressionThreshold, getListeningAddress, getListeningPort, getListeningSocketAddress, getLogger, getNodeAddress, getNodePort, getPayloadLength, getPendingSize, getSSLMode, handshakeComplete, isDisconnected, isStarted, isStopped, outOfRange, run, send, send, send, setCompression, setCompressionThreshold, setMaxQueuedSends, setMinInterConnectTime, setUseSenderTask, toString

Methods inherited from class java.lang.Object

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

Methods inherited from interface edu.umass.cs.nio.interfaces.InterfaceNIOTransport

getListeningSocketAddress, getSSLMode, isDisconnected, isStopped

Constructor Detail

JSONNIOTransport

public JSONNIOTransport(NodeIDType id,
                        NodeConfig<NodeIDType> nodeConfig)
                 throws java.io.IOException

Initiates transporter with id and nodeConfig.

Parameters:

id - My node ID.

nodeConfig - A map from all nodes' IDs to their respective socket addresses.

Throws:

java.io.IOException

JSONNIOTransport

public JSONNIOTransport(NodeIDType id,
                        NodeConfig<NodeIDType> nodeConfig,
                        SSLDataProcessingWorker.SSL_MODES sslMode)
                 throws java.io.IOException

Parameters:

id -

nodeConfig -

sslMode -

Throws:

java.io.IOException

JSONNIOTransport

public JSONNIOTransport(NodeIDType id,
                        NodeConfig<NodeIDType> nodeConfig,
                        AbstractPacketDemultiplexer<?> pd,
                        boolean start)
                 throws java.io.IOException

Parameters:

id - My node ID.

nodeConfig - A map from all nodes' IDs to their respective socket addresses.

pd - The packet demultiplexer to handle received messages.

start - If a server thread must be automatically started upon construction. If false, the caller must explicitly invoke (new Thread(JSONNIOTransport)).start() to start the server.

Throws:

java.io.IOException

JSONNIOTransport

public JSONNIOTransport(NodeIDType id,
                        NodeConfig<NodeIDType> nodeConfig,
                        AbstractPacketDemultiplexer<?> pd,
                        SSLDataProcessingWorker.SSL_MODES sslMode)
                 throws java.io.IOException

Parameters:

id -

nodeConfig -

pd -

sslMode -

Throws:

java.io.IOException