edu.umass.cs.gigapaxos.paxosutil

Class PaxosPacketDemultiplexer

java.lang.Object

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

edu.umass.cs.gigapaxos.paxosutil.PaxosPacketDemultiplexer

All Implemented Interfaces:

PacketDemultiplexer<org.json.JSONObject>

public abstract class PaxosPacketDemultiplexer
extends AbstractPacketDemultiplexer<org.json.JSONObject>

Author:

V. Arun

Used to get NIO to send paxos packets to PaxosManager. This class has been merged into PaxosManager now and will be soon deprecated.

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

Constructor and Description
PaxosPacketDemultiplexer()

Method Summary

Modifier and Type	Method and Description
static void	throttleExcessiveLoad()
static PaxosPacket	toPaxosPacket(org.json.JSONObject json)
static PaxosPacket	toPaxosPacket(org.json.JSONObject json, Stringifiable<?> unstringer)

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

emulateDelays, getHandleMessageReport, getPacketType, getThreadPoolSize, handleMessageSuper, isCongested, isOrderPreserving, loopback, matchesType, processHeader, 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

PaxosPacketDemultiplexer

public PaxosPacketDemultiplexer()

Method Detail

toPaxosPacket

public static PaxosPacket toPaxosPacket(org.json.JSONObject json,
                                        Stringifiable<?> unstringer)
                                 throws org.json.JSONException

Parameters:

json -

unstringer -

Returns:

PaxosPacket parsed from JSON.

Throws:

org.json.JSONException

toPaxosPacket

public static PaxosPacket toPaxosPacket(org.json.JSONObject json)
                                 throws org.json.JSONException

Parameters:

json -

Returns:

PaxosPacket from json

Throws:

org.json.JSONException

throttleExcessiveLoad

public static void throttleExcessiveLoad()