edu.umass.cs.reconfiguration.testing

Class MetaRequestPacket

java.lang.Object

edu.umass.cs.nio.JSONPacket

edu.umass.cs.gigapaxos.paxospackets.PaxosPacket

edu.umass.cs.gigapaxos.paxospackets.RequestPacket

edu.umass.cs.reconfiguration.testing.MetaRequestPacket

All Implemented Interfaces:

ClientRequest, Request, RequestIdentifier, Byteable, Summarizable

public class MetaRequestPacket
extends RequestPacket

Author:

arun A request packet for testing in a manner very similar to TESTPaxosClient and RequestPacket but using TESTPaxosClient.

Nested Class Summary

Nested classes/interfaces inherited from class edu.umass.cs.gigapaxos.paxospackets.RequestPacket

RequestPacket.Keys, RequestPacket.ResponseCodes

Nested classes/interfaces inherited from class edu.umass.cs.gigapaxos.paxospackets.PaxosPacket

PaxosPacket.NodeIDKeys, PaxosPacket.PaxosPacketType

Field Summary

Fields inherited from class edu.umass.cs.gigapaxos.paxospackets.RequestPacket

digest, NO_OP, NULL_SOCKADDR, requestID, requestValue, SIZE_ESTIMATE, SIZEOF_REQUEST_FIXED, stop

Fields inherited from class edu.umass.cs.gigapaxos.paxospackets.PaxosPacket

CHARSET, packetType, paxosID, SIZEOF_PAXOSPACKET_FIXED, version

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

PACKET_TYPE, type

Constructor Summary

Constructors

Constructor and Description
MetaRequestPacket(byte[] bytes)
MetaRequestPacket(org.json.JSONObject json)
MetaRequestPacket(long id, java.lang.String val, boolean stop)
MetaRequestPacket(RequestPacket req)
MetaRequestPacket(java.lang.String name, java.lang.String val)

Method Summary

Modifier and Type	Method and Description
static MetaRequestPacket	getMetaRequestPacket(byte[] bytes)
IntegerPacketType	getRequestType()
MetaRequestPacket	getResponse()
boolean	needsCoordination()
byte[]	toBytes() The implementation of this method is tied to and must be the inverse of AppRequestParser.getRequest(byte[], edu.umass.cs.nio.nioutils.NIOHeader) , i.e., invoking getRequest(request.toBytes(), header).equals(request).
org.json.JSONObject	toJSONObjectImpl()
java.lang.String	toString() Learned the hard way that using org.json to stringify is an order of magnitude slower with large request values compared to manually inserting the string like below.

Methods inherited from class edu.umass.cs.gigapaxos.paxospackets.RequestPacket

addDebugInfo, addDebugInfo, addDebugInfo, addDebugInfoDeep, addDebugInfoDeep, batchSize, digestEquals, doubleCheckFields, equals, getACK, getBatched, getByteifiedSelf, getClientAddress, getClientID, getDebugInfo, getDigest, getEntryReplica, getEntryReplicaRequestsAsBatch, getEntryTime, getFirstOnly, getForwardCount, getForwarderID, getListenAddress, getMessageDigest, getNACK, getRandomPValue, getRequestID, getRequestPackets, getRequestValue, getRequestValues, getSamplePValue, getServiceName, getStringifiedSelf, getSummary, getSummaryString, hasRequestValue, isBroadcasted, isMetaValue, isNoop, isPingPonging, isPingPonging, isStopRequest, latchToBatch, lengthEstimate, main, makeNewRequest, makeNoop, printBatched, setBroadcasted, setByteifiedSelf, setDigest, setEntryReplica, setEntryReplicaAndReturnCount, setEntryTime, setForwarderID, setResponse, setReturnRequestValue, setStringifiedSelf, shouldBroadcast, shouldDigest, shouldReturnRequestValue, toBytes, toBytesInstrument, toJSONSmartImpl

Methods inherited from class edu.umass.cs.gigapaxos.paxospackets.PaxosPacket

getPaxosID, getPaxosIDVersion, getPaxosPacket, getPaxosPacket, getPaxosPacketType, getPaxosPacketType, getSummary, getType, getType, getVersion, isParseable, isRecovery, isRecovery, isStatic, markRecovered, putPaxosID, toBytes, toJSONObject, toJSONSmart, toSingletonArray

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

couldBeJSON, couldBeJSON, couldBeJSON, couldBeJSONArray, couldBeJSONObject, getPacketType, putPacketType, putPacketType

Methods inherited from class java.lang.Object

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

Methods inherited from interface edu.umass.cs.utils.Summarizable

getSummary

Constructor Detail

MetaRequestPacket

public MetaRequestPacket(java.lang.String name,
                         java.lang.String val)

Parameters:

name -

val -

MetaRequestPacket

public MetaRequestPacket(long id,
                         java.lang.String val,
                         boolean stop)

Parameters:

id -

val -

stop -

MetaRequestPacket

public MetaRequestPacket(byte[] bytes)
                  throws java.io.UnsupportedEncodingException,
                         java.net.UnknownHostException

Parameters:

bytes -

Throws:

java.io.UnsupportedEncodingException

java.net.UnknownHostException

MetaRequestPacket

public MetaRequestPacket(org.json.JSONObject json)
                  throws org.json.JSONException

Parameters:

json -

Throws:

org.json.JSONException

MetaRequestPacket

public MetaRequestPacket(RequestPacket req)

Parameters:

req -

Method Detail

getMetaRequestPacket

public static MetaRequestPacket getMetaRequestPacket(byte[] bytes)
                                              throws java.io.UnsupportedEncodingException,
                                                     java.net.UnknownHostException,
                                                     org.json.JSONException

Parameters:

bytes -

Returns:

MetaRequestPacket from bytes.

Throws:

java.io.UnsupportedEncodingException

java.net.UnknownHostException

org.json.JSONException

getRequestType

public IntegerPacketType getRequestType()

Specified by:

getRequestType in interface Request

Overrides:

getRequestType in class RequestPacket

Returns:

The IntegerPacketType type corresponding to this request.

toBytes

public byte[] toBytes()

Description copied from interface: Request

The implementation of this method is tied to and must be the inverse of AppRequestParser.getRequest(byte[], edu.umass.cs.nio.nioutils.NIOHeader) , i.e., invoking getRequest(request.toBytes(), header).equals(request).

Specified by:

toBytes in interface Request

Specified by:

toBytes in interface Byteable

Overrides:

toBytes in class RequestPacket

Returns:

byte[] serialized form of this request

toJSONObjectImpl

public org.json.JSONObject toJSONObjectImpl()
                                     throws org.json.JSONException

Overrides:

toJSONObjectImpl in class RequestPacket

Returns:

JSONObject corresponding to fields in classes extending this class.

Throws:

org.json.JSONException

toString

public java.lang.String toString()

Description copied from class: RequestPacket

Learned the hard way that using org.json to stringify is an order of magnitude slower with large request values compared to manually inserting the string like below. json-smart is fast enough for our purposes but still doesn't beat direct string construction like below. Note: we need to account for batching carefully here. So, we use a json array of strings as opposed to json objects for batched requests above. Otherwise, this method will only use string construction for the first request in a batch.

Specified by:

toString in interface Request

Overrides:

toString in class RequestPacket

Returns:

Returns this request serialized as a String.

needsCoordination

public boolean needsCoordination()

Returns:

False. FIXME:

getResponse

public MetaRequestPacket getResponse()

Specified by:

getResponse in interface ClientRequest

Overrides:

getResponse in class RequestPacket

Returns:

The response to be sent back to the client that issued this request. AbstractReplicaCoordinator, e.g., PaxosManager, will invoke this method immediately after Application.execute(Request) and, if the returned response is non-null, will send it back to the client that issued that request. Applications are expected to internally implement logic that sets the response at the end of Application.execute(Request) as follows:

public boolean Replicable.execute(Request request)} {
// execute request to obtain response
request.setResponse(response);
}