edu.umass.cs.reconfiguration.reconfigurationpackets

Class RequestActiveReplicas

java.lang.Object

edu.umass.cs.protocoltask.json.ProtocolPacket<NodeIDType,ReconfigurationPacket.PacketType>

edu.umass.cs.reconfiguration.reconfigurationpackets.ReconfigurationPacket<NodeIDType>

edu.umass.cs.reconfiguration.reconfigurationpackets.BasicReconfigurationPacket<java.net.InetSocketAddress>

edu.umass.cs.reconfiguration.reconfigurationpackets.ClientReconfigurationPacket

edu.umass.cs.reconfiguration.reconfigurationpackets.RequestActiveReplicas

All Implemented Interfaces:

Request, RequestIdentifier, Byteable, ProtocolEvent<ReconfigurationPacket.PacketType,java.lang.String>, ThresholdProtocolEvent<java.net.InetSocketAddress,ReconfigurationPacket.PacketType,java.lang.String>, ReconfiguratorRequest, ReplicableRequest, Keyable<java.lang.String>, Summarizable

public class RequestActiveReplicas
extends ClientReconfigurationPacket
implements ReplicableRequest

Author:

V. Arun This class has an additional field for returning the set of active replicas in addition to the fields in the generic ClientReconfigurationPacket. This class is used to both request for and return the set of active replicas for a name. If the field actives is null, it is implicitly interpreted as a request, else as a response.

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	RequestActiveReplicas.Keys

Nested classes/interfaces inherited from class edu.umass.cs.reconfiguration.reconfigurationpackets.ClientReconfigurationPacket

ClientReconfigurationPacket.ResponseCodes

Nested classes/interfaces inherited from class edu.umass.cs.reconfiguration.reconfigurationpackets.ReconfigurationPacket

ReconfigurationPacket.PacketType

Field Summary

Fields

Modifier and Type	Field and Description
static Stringifiable<java.net.InetSocketAddress>	unstringer Unstringer for InetSocketAddress of sender.

Fields inherited from class edu.umass.cs.reconfiguration.reconfigurationpackets.BasicReconfigurationPacket

epochNumber, serviceName

Fields inherited from class edu.umass.cs.reconfiguration.reconfigurationpackets.ReconfigurationPacket

clientPacketTypes, HANDLER_METHOD_PREFIX, PACKET_TYPE, serverPacketTypes

Fields inherited from class edu.umass.cs.protocoltask.json.ProtocolPacket

type

Fields inherited from interface edu.umass.cs.gigapaxos.interfaces.Request

NO_OP

Constructor Summary

Constructors

Constructor and Description
RequestActiveReplicas(java.net.InetSocketAddress initiator, java.lang.String name, int epochNumber)
RequestActiveReplicas(org.json.JSONObject json)
RequestActiveReplicas(org.json.JSONObject json, Stringifiable<?> unstringer)
RequestActiveReplicas(java.lang.String name)

Method Summary

Modifier and Type	Method and Description
java.util.Set<java.net.InetSocketAddress>	getActives()
long	getRequestID() The uniqueness of this identifier across all requests to a replica group is important for safety when PaxosConfig.PC.PREVENT_DOUBLE_EXECUTION is enabled as gigapaxos may otherwise assume that the duplicate request identifier corresponds to a retransmission and will send back the response if any corresponding to the first execution.
java.lang.String	getSummary() Implementations are encouraged to return an inline created new Object() whose toString() method will return the actual String instead of just returning the String directly.
static void	main(java.lang.String[] args)
boolean	needsCoordination()
ClientReconfigurationPacket	setActives(java.util.Set<java.net.InetSocketAddress> replicas)
RequestActiveReplicas	setNeedsCoordination()
org.json.JSONObject	toJSONObjectImpl()
RequestActiveReplicas	unsetNeedsCoordination()

Methods inherited from class edu.umass.cs.reconfiguration.reconfigurationpackets.ClientReconfigurationPacket

getCreateTime, getCreator, getForwader, getForwardee, getHashRCs, getMyReceiver, getRequestType, getResponseCode, getResponseMessage, isFailed, isForwardable, isForwarded, isRecursiveRedirectEnabled, isRedirectedResponse, isRequest, makeResponse, setFailed, setFailed, setForwader, setForwardee, setHashRCs, setRecursiveRedirect, setResponseMessage

Methods inherited from class edu.umass.cs.reconfiguration.reconfigurationpackets.BasicReconfigurationPacket

getEpochNumber, getServiceName

Methods inherited from class edu.umass.cs.reconfiguration.reconfigurationpackets.ReconfigurationPacket

assertPacketTypeChecks, assertPacketTypeChecks, assertPacketTypeChecks, assertPacketTypeChecks, concatenate, getMessage, getPacketType, getPacketTypeCanonicalClassName, getPacketTypeClass, getPacketTypeClassName, getReconfigurationPacket, getReconfigurationPacket, getReconfigurationPacketSuppressExceptions, getReconfigurationPacketSuppressExceptions, getReconfigurationPacketType, getReconfigurationPacketType, isReconfigurationPacket, putPacketType, toBytes, toString

Methods inherited from class edu.umass.cs.protocoltask.json.ProtocolPacket

flip, getInitiator, getKey, getSender, getType, setKey, setSender, setType, toJSONObject

Methods inherited from class java.lang.Object

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

Methods inherited from interface edu.umass.cs.reconfiguration.interfaces.ReplicableRequest

setNeedsCoordination

Methods inherited from interface edu.umass.cs.gigapaxos.interfaces.Request

getRequestType, getServiceName, toBytes, toString

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

getSummary

Field Detail

unstringer

public static final Stringifiable<java.net.InetSocketAddress> unstringer

Unstringer for InetSocketAddress of sender.

Constructor Detail

RequestActiveReplicas

public RequestActiveReplicas(java.lang.String name)

Parameters:

name -

RequestActiveReplicas

public RequestActiveReplicas(java.net.InetSocketAddress initiator,
                             java.lang.String name,
                             int epochNumber)

Parameters:

initiator -

name -

epochNumber -

RequestActiveReplicas

public RequestActiveReplicas(org.json.JSONObject json,
                             Stringifiable<?> unstringer)
                      throws org.json.JSONException

Parameters:

json -

unstringer -

Throws:

org.json.JSONException

RequestActiveReplicas

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

Parameters:

json -

Throws:

org.json.JSONException

Method Detail

toJSONObjectImpl

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

Overrides:

toJSONObjectImpl in class ClientReconfigurationPacket

Throws:

org.json.JSONException

setActives

public ClientReconfigurationPacket setActives(java.util.Set<java.net.InetSocketAddress> replicas)

Parameters:

replicas -

Returns:

this with active replicas set to replicas.

getActives

public java.util.Set<java.net.InetSocketAddress> getActives()

Returns:

Active replica socket addresses.

main

public static void main(java.lang.String[] args)

getRequestID

public long getRequestID()

Description copied from interface: RequestIdentifier

The uniqueness of this identifier across all requests to a replica group is important for safety when PaxosConfig.PC.PREVENT_DOUBLE_EXECUTION is enabled as gigapaxos may otherwise assume that the duplicate request identifier corresponds to a retransmission and will send back the response if any corresponding to the first execution. With PaxosConfig.PC.PREVENT_DOUBLE_EXECUTION disabled, the uniqueness is important for liveness as duplicate request identifiers may result in the client not receiving a response for the latter request; this is because gigapaxos stores request execution callbacks indexed by the request identifier, so there must be at most one outstanding request with a given identifier for a given replica group.

Specified by:

getRequestID in interface RequestIdentifier

Returns:

A unique request identifier for this request.

needsCoordination

public boolean needsCoordination()

Specified by:

needsCoordination in interface ReplicableRequest

Returns:

True if this request needs to be coordinated, false otherwise.

setNeedsCoordination

public RequestActiveReplicas setNeedsCoordination()

Returns:

this with needsCoordination=true

unsetNeedsCoordination

public RequestActiveReplicas unsetNeedsCoordination()

Returns:

this with needsCoordination=false

getSummary

public java.lang.String getSummary()

Description copied from interface: Summarizable

Implementations are encouraged to return an inline created new Object() whose toString() method will return the actual String instead of just returning the String directly. This helps loggers be more efficient as the String won't be generated until the log level demands it.

Specified by:

getSummary in interface Request

Specified by:

getSummary in interface Summarizable

Overrides:

getSummary in class ClientReconfigurationPacket

Returns:

A pretty-print summary.