edu.umass.cs.nio

Class AbstractJSONPacketDemultiplexer

java.lang.Object

edu.umass.cs.nio.AbstractPacketDemultiplexer<org.json.JSONObject>

edu.umass.cs.nio.AbstractJSONPacketDemultiplexer

All Implemented Interfaces:

PacketDemultiplexer<org.json.JSONObject>

Direct Known Subclasses:

ExamplePacketDemultiplexer, PacketDemultiplexerDefault

public abstract class AbstractJSONPacketDemultiplexer
extends AbstractPacketDemultiplexer<org.json.JSONObject>
implements PacketDemultiplexer<org.json.JSONObject>

Author:

V. Arun

Nested Class Summary

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

AbstractPacketDemultiplexer.Tasker

Field Summary

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

DEFAULT_THREAD_POOL_SIZE, log

Constructor Summary

Constructors

Modifier	Constructor and Description
protected	AbstractJSONPacketDemultiplexer()
protected	AbstractJSONPacketDemultiplexer(int threadPoolSize)

Method Summary

Modifier and Type	Method and Description
protected java.lang.Integer	getPacketType(org.json.JSONObject json)
protected boolean	isCongested(NIOHeader header)
protected boolean	matchesType(java.lang.Object message)
protected org.json.JSONObject	processHeader(byte[] message, int offset, NIOHeader header, boolean cacheStringified)
protected org.json.JSONObject	processHeader(byte[] message, NIOHeader header)
protected org.json.JSONObject	processHeader(byte[] message, NIOHeader header, boolean cacheStringified)
static org.json.JSONObject	processHeaderStatic(byte[] message, int offset, NIOHeader header, boolean cacheStringified)

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

emulateDelays, getHandleMessageReport, getThreadPoolSize, handleMessageSuper, isOrderPreserving, loopback, register, register, register, register, register, register, registerOrderPreserving, setNumDemultiplexerThreads, setThreadName, setThreadPoolSize, stop, 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.PacketDemultiplexer

handleMessage

Constructor Detail

AbstractJSONPacketDemultiplexer

protected AbstractJSONPacketDemultiplexer(int threadPoolSize)

Parameters:

threadPoolSize - Refer documentation for setThreadPoolsize(int).

AbstractJSONPacketDemultiplexer

protected AbstractJSONPacketDemultiplexer()

Method Detail

getPacketType

protected java.lang.Integer getPacketType(org.json.JSONObject json)

Specified by:

getPacketType in class AbstractPacketDemultiplexer<org.json.JSONObject>

processHeader

protected org.json.JSONObject processHeader(byte[] message,
                                            NIOHeader header)

Specified by:

processHeader in class AbstractPacketDemultiplexer<org.json.JSONObject>

processHeader

protected org.json.JSONObject processHeader(byte[] message,
                                            NIOHeader header,
                                            boolean cacheStringified)

processHeader

protected org.json.JSONObject processHeader(byte[] message,
                                            int offset,
                                            NIOHeader header,
                                            boolean cacheStringified)

processHeaderStatic

public static final org.json.JSONObject processHeaderStatic(byte[] message,
                                                            int offset,
                                                            NIOHeader header,
                                                            boolean cacheStringified)

Parameters:

message -

offset -

header -

cacheStringified -

Returns:

JSONObject with sender address stamped.

matchesType

protected boolean matchesType(java.lang.Object message)

Specified by:

matchesType in class AbstractPacketDemultiplexer<org.json.JSONObject>

isCongested

protected boolean isCongested(NIOHeader header)

Overrides:

isCongested in class AbstractPacketDemultiplexer<org.json.JSONObject>

Returns:

True if congested