edu.umass.cs.reconfiguration

Class ReconfigurationConfig

java.lang.Object

edu.umass.cs.reconfiguration.ReconfigurationConfig

public class ReconfigurationConfig
extends java.lang.Object

Author:

arun Reconfiguration configuration parameters. These parameters are expected to be statically set at JVM initiation time and should not be changed subsequently. A static code block can be used to read parameters from a file and set them using methods here. Reconfiguration parameters that can be dynamically changed after initiation are generally supported using get/set methods in their respective classes.

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	ReconfigurationConfig.CommandArgs Command-line options
static class	ReconfigurationConfig.RC Reconfiguration config parameters.
static class	ReconfigurationConfig.ReconfigureUponActivesChange This enum specifies the reconfiguration behavior when active replicas are added or removed.

Field Summary

Fields

Modifier and Type	Field and Description
static java.lang.Class<?>	application
protected static java.lang.String	DEFAULT_RECONFIGURATOR_PREFIX

Constructor Summary

Constructors

Constructor and Description
ReconfigurationConfig()

Method Summary

Modifier and Type	Method and Description
static boolean	aggressiveDeletionsAllowed()
static boolean	aggressiveReconfigurationsAllowed()
protected static Replicable	createApp(java.lang.String[] args)
static int	getClientFacingClearPort(int port)
static int	getClientFacingPort(int port)
static int	getClientFacingSSLPort(int port)
static int	getClientPortClearOffset()
static int	getClientPortOffset()
static int	getClientPortSSLOffset()
static SSLDataProcessingWorker.SSL_MODES	getClientSSLMode()
static ReconfigurationConfig.ReconfigureUponActivesChange	getDefaultReconfigureUponActivesChangePolicy()
static java.lang.String	getDefaultServiceName()
static java.lang.String	getDefaultServiceNameInitialState()
static long	getDelayedDeleteWaitDuration() The time for which we must wait before finally deleting a name's reconfiguration record (i.e., all memory of that name is lost) must be at least as high as paxos' MAX_FINAL_STATE_AGE, otherwise it can cause the creation of a name or addition of a reconfigurator to stall for arbitrarily long, or worse, violate safety by using incorrect state from previous incarnations.
static java.lang.Class<?>	getDemandProfile()
static int	getHTTPPort(int port)
static int	getHTTPPortClearOffset()
static int	getHTTPPortSSLOffset()
static int	getHTTPSPort(int port)
static java.util.logging.Logger	getLogger()
static long	getMaxFinalStateAge() Necessary to ensure safety under name re-creations (see getDelayedDeleteWaitDuration() below).
static java.util.Set<java.net.InetSocketAddress>	getReconfiguratorAddresses()
static java.util.Set<java.lang.String>	getReconfiguratorIDs()
static java.util.Map<java.lang.String,java.net.InetSocketAddress>	getReconfigurators()
static SSLDataProcessingWorker.SSL_MODES	getServerSSLMode()
static java.lang.Object	getSummary(ClientRequest request)
static java.lang.Object	getSummary(ClientRequest request, boolean stringify)
static boolean	instrument(int n)
protected static boolean	isAggregatedMergeSplit() Default true now for an improved merge/split implementation.
static boolean	isTLSEnabled()
static void	load()
static void	main(java.lang.String[] args)
static CreateServiceName[]	makeCreateNameRequest(java.util.Map<java.lang.String,java.lang.String> nameStates, int batchSize)
static CreateServiceName[]	makeCreateNameRequest(java.util.Map<java.lang.String,java.lang.String> nameStates, int batchSize, java.util.Set<java.lang.String> reconfigurators)
static void	setClientSSLMode(SSLDataProcessingWorker.SSL_MODES sslMode) Deprecated.
static void	setConsoleHandler()
static void	setConsoleHandler(java.util.logging.Level level)
static java.lang.Class<?>	setDemandProfile(java.lang.Class<?> newDP)
static void	setServerSSLMode(SSLDataProcessingWorker.SSL_MODES sslMode) Deprecated.
static boolean	shouldReconfigureInPlace()
protected static CreateServiceName[]	testMakeCreateNameRequest(java.lang.String name, java.lang.String state, int numRequests, int batchSize)

Methods inherited from class java.lang.Object

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

Field Detail

application

public static final java.lang.Class<?> application

DEFAULT_RECONFIGURATOR_PREFIX

protected static java.lang.String DEFAULT_RECONFIGURATOR_PREFIX

Constructor Detail

ReconfigurationConfig

public ReconfigurationConfig()

Method Detail

load

public static void load()

getDefaultServiceName

public static final java.lang.String getDefaultServiceName()

Returns:

Default service name that is replicated at all active replicas.

getDefaultServiceNameInitialState

public static final java.lang.String getDefaultServiceNameInitialState()

Returns:

Initial state of default service name that is replicated at all active replicas.

getLogger

public static final java.util.logging.Logger getLogger()

Returns:

Logger used by all of the reconfiguration package.

isAggregatedMergeSplit

protected static final boolean isAggregatedMergeSplit()

Default true now for an improved merge/split implementation. Doing merges in the old way potentially violates RSM safety. True effectively disables the use of RCRecordRequest.RequestTypes#RECONFIGURATION_MERGE.

getMaxFinalStateAge

public static final long getMaxFinalStateAge()

Necessary to ensure safety under name re-creations (see getDelayedDeleteWaitDuration() below). We also use this timeout for garbage collecting remote checkpoints transferred using the file system.

Returns:

The value of MAX_FINAL_STATE_AGE used by paxos. This is the time after which paxos' epoch final state can be safely deleted.

getDelayedDeleteWaitDuration

public static final long getDelayedDeleteWaitDuration()

The time for which we must wait before finally deleting a name's reconfiguration record (i.e., all memory of that name is lost) must be at least as high as paxos' MAX_FINAL_STATE_AGE, otherwise it can cause the creation of a name or addition of a reconfigurator to stall for arbitrarily long, or worse, violate safety by using incorrect state from previous incarnations.

Returns:

The time for which deleted records should be left waiting so that they don't get recreated subsequently with un-garbage-collected copies of epoch final state from previous incarnations.

setDemandProfile

public static java.lang.Class<?> setDemandProfile(java.lang.Class<?> newDP)

Parameters:

newDP -

Returns:

Old DemandProfile class.

getDemandProfile

public static java.lang.Class<?> getDemandProfile()

Returns:

DemandProfile class.

shouldReconfigureInPlace

public static boolean shouldReconfigureInPlace()

Returns:

True means in-place reconfigurations will still be conducted.

getDefaultReconfigureUponActivesChangePolicy

public static ReconfigurationConfig.ReconfigureUponActivesChange getDefaultReconfigureUponActivesChangePolicy()

Returns:

Default ReconfigureUponActivesChange policy.

setClientSSLMode

@Deprecated
public static void setClientSSLMode(SSLDataProcessingWorker.SSL_MODES sslMode)

Deprecated.

Parameters:

sslMode -

getClientSSLMode

public static SSLDataProcessingWorker.SSL_MODES getClientSSLMode()

Returns:

The default SSL mode for client-server communication.

setServerSSLMode

@Deprecated
public static void setServerSSLMode(SSLDataProcessingWorker.SSL_MODES sslMode)

Deprecated.

Parameters:

sslMode -

getServerSSLMode

public static SSLDataProcessingWorker.SSL_MODES getServerSSLMode()

Returns:

The default SSL mode for server-server communication.

isTLSEnabled

public static boolean isTLSEnabled()

Returns:

True if mutual authentication between servers is enabled.

getClientPortOffset

public static int getClientPortOffset()

Returns:

The client port offset, i.e., the port number that is to be added to the standard port in order to get the client-facing port. A nonzero offset is needed to support transport layer security between servers.

getClientFacingPort

public static int getClientFacingPort(int port)

Parameters:

port -

Returns:

Translates port to corresponding client facing port.

getClientFacingClearPort

public static int getClientFacingClearPort(int port)

Parameters:

port -

Returns:

Translates port to corresponding client facing port.

getHTTPPort

public static int getHTTPPort(int port)

Parameters:

port -

Returns:

Translates port to corresponding client facing port.

getHTTPSPort

public static int getHTTPSPort(int port)

Parameters:

port -

Returns:

Translates port to corresponding client facing port.

getClientFacingSSLPort

public static int getClientFacingSSLPort(int port)

Parameters:

port -

Returns:

Translates port to corresponding client facing port.

getClientPortSSLOffset

public static int getClientPortSSLOffset()

Returns:

The client port SSL offset, i.e., the port number that is to be added to the standard port in order to get the client-facing SSL port. A nonzero offset is needed to separate client-client communication from server-server communication and to support transport layer security between servers.

getClientPortClearOffset

public static int getClientPortClearOffset()

Returns:

The client port offset, i.e., the port number that is to be added to the standard port in order to get the client-facing port. A nonzero offset is needed to separate client-client communication from server-server communication and to support transport layer security between servers.

getHTTPPortSSLOffset

public static int getHTTPPortSSLOffset()

Returns:

The client port HTTTPS offset, i.e., the port number that is to be added to the standard port in order to get the client-facing HTTPS port. A nonzero offset is needed to separate client-client communication from server-server communication and to support transport layer security between servers.

getHTTPPortClearOffset

public static int getHTTPPortClearOffset()

Returns:

The client port HTTTP offset, i.e., the port number that is to be added to the standard port in order to get the client-facing HTTP port. A nonzero offset is needed to separate client-client communication from server-server communication and to support transport layer security between servers.

aggressiveDeletionsAllowed

public static boolean aggressiveDeletionsAllowed()

Returns:

True is aggressive recreations allowed.

aggressiveReconfigurationsAllowed

public static boolean aggressiveReconfigurationsAllowed()

Returns:

True is aggressive reconfigurations are allowed.

getReconfigurators

public static java.util.Map<java.lang.String,java.net.InetSocketAddress> getReconfigurators()

Returns:

A map of names and socket addresses corresponding to servers hosting paxos replicas.

getReconfiguratorAddresses

public static java.util.Set<java.net.InetSocketAddress> getReconfiguratorAddresses()

Returns:

Returns only reconfigurator addresses.

getReconfiguratorIDs

public static java.util.Set<java.lang.String> getReconfiguratorIDs()

Returns:

Gets only reconfigurator String IDs.

createApp

protected static Replicable createApp(java.lang.String[] args)

Parameters:

args -

Returns:

Replicable app created via reflection.

makeCreateNameRequest

public static CreateServiceName[] makeCreateNameRequest(java.util.Map<java.lang.String,java.lang.String> nameStates,
                                                        int batchSize)

Parameters:

nameStates -

batchSize -

Returns:

Array of CreateServiceName objects each of which is a batch create of up to batchSize names and corresponds to the same RC group.

makeCreateNameRequest

public static CreateServiceName[] makeCreateNameRequest(java.util.Map<java.lang.String,java.lang.String> nameStates,
                                                        int batchSize,
                                                        java.util.Set<java.lang.String> reconfigurators)

Parameters:

nameStates -

batchSize -

reconfigurators -

Returns:

Array of CreateServiceName objects each of which is a batch create of up to batchSize names and corresponds to the same RC group.

setConsoleHandler

public static void setConsoleHandler(java.util.logging.Level level)

Parameters:

level -

setConsoleHandler

public static void setConsoleHandler()

testMakeCreateNameRequest

protected static CreateServiceName[] testMakeCreateNameRequest(java.lang.String name,
                                                               java.lang.String state,
                                                               int numRequests,
                                                               int batchSize)

getSummary

public static java.lang.Object getSummary(ClientRequest request,
                                          boolean stringify)

Parameters:

request -

stringify -

Returns:

Stringifiable object if stringify

instrument

public static boolean instrument(int n)

Parameters:

n -

Returns:

Used internally by reconfiguration classes.

getSummary

public static java.lang.Object getSummary(ClientRequest request)

Parameters:

request -

Returns:

Stringifiable object.

main

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

Parameters:

args -