edu.umass.cs.reconfiguration.testing

Class TESTPaxosClient

java.lang.Object

edu.umass.cs.reconfiguration.testing.TESTPaxosClient

public class TESTPaxosClient
extends java.lang.Object

Author:

V. Arun FIXME: Near-duplication of TESTPaxosClient. Remove redundant code by extending from TESTPaxosClient.

Constructor Summary

Constructors

Modifier	Constructor and Description
protected	TESTPaxosClient(int id, NodeConfig<java.lang.Integer> nc)

Method Summary

Modifier and Type	Method and Description
protected static java.lang.String	getAggregateOutput(long delay)
static java.lang.String	getGibberish()
protected static java.util.Set<RequestPacket>	getMissingRequests(TESTPaxosClient[] clients)
protected static int	getTotalNoopCount()
static void	main(java.lang.String[] args)
protected boolean	makeAndSendRequest(java.lang.String paxosID)
protected boolean	makeAndSendRequestCallable(java.lang.String paxosID)
protected static boolean	noOutstanding(TESTPaxosClient[] clients)
protected static void	printOutput(TESTPaxosClient[] clients)
protected static void	resetLatencyComputation(TESTPaxosClient[] clients)
protected boolean	sendRequest(int id, RequestPacket req)
protected static void	sendTestRequests(int numReqs, TESTPaxosClient[] clients, double load)
protected static TESTPaxosClient[]	setupClients(NodeConfig<java.lang.Integer> nc)
protected static void	twoPhaseTest(int numReqs, TESTPaxosClient[] clients)
protected static void	waitForResponses(TESTPaxosClient[] clients, long startTime, int numRequests)
protected static void	waitUntilRunDone()

Methods inherited from class java.lang.Object

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

Constructor Detail

TESTPaxosClient

protected TESTPaxosClient(int id,
                          NodeConfig<java.lang.Integer> nc)
                   throws java.io.IOException

Throws:

java.io.IOException

Method Detail

resetLatencyComputation

protected static void resetLatencyComputation(TESTPaxosClient[] clients)

getTotalNoopCount

protected static int getTotalNoopCount()

sendRequest

protected boolean sendRequest(int id,
                              RequestPacket req)
                       throws java.io.IOException,
                              org.json.JSONException

Throws:

java.io.IOException

org.json.JSONException

getGibberish

public static java.lang.String getGibberish()

Returns:

Literally gibberish.

makeAndSendRequest

protected boolean makeAndSendRequest(java.lang.String paxosID)
                              throws org.json.JSONException,
                                     java.io.IOException,
                                     java.lang.InterruptedException,
                                     java.util.concurrent.ExecutionException

Throws:

org.json.JSONException

java.io.IOException

java.lang.InterruptedException

java.util.concurrent.ExecutionException

makeAndSendRequestCallable

protected boolean makeAndSendRequestCallable(java.lang.String paxosID)
                                      throws org.json.JSONException,
                                             java.io.IOException,
                                             java.lang.InterruptedException,
                                             java.util.concurrent.ExecutionException

Throws:

org.json.JSONException

java.io.IOException

java.lang.InterruptedException

java.util.concurrent.ExecutionException

setupClients

protected static TESTPaxosClient[] setupClients(NodeConfig<java.lang.Integer> nc)

sendTestRequests

protected static void sendTestRequests(int numReqs,
                                       TESTPaxosClient[] clients,
                                       double load)
                                throws org.json.JSONException,
                                       java.io.IOException,
                                       java.lang.InterruptedException,
                                       java.util.concurrent.ExecutionException

Throws:

org.json.JSONException

java.io.IOException

java.lang.InterruptedException

java.util.concurrent.ExecutionException

waitForResponses

protected static void waitForResponses(TESTPaxosClient[] clients,
                                       long startTime,
                                       int numRequests)

noOutstanding

protected static boolean noOutstanding(TESTPaxosClient[] clients)

getMissingRequests

protected static java.util.Set<RequestPacket> getMissingRequests(TESTPaxosClient[] clients)

printOutput

protected static void printOutput(TESTPaxosClient[] clients)

getAggregateOutput

protected static java.lang.String getAggregateOutput(long delay)

waitUntilRunDone

protected static void waitUntilRunDone()
                                throws java.lang.InterruptedException

Throws:

java.lang.InterruptedException

twoPhaseTest

protected static void twoPhaseTest(int numReqs,
                                   TESTPaxosClient[] clients)
                            throws java.lang.InterruptedException,
                                   org.json.JSONException,
                                   java.io.IOException,
                                   java.util.concurrent.ExecutionException

Throws:

java.lang.InterruptedException

org.json.JSONException

java.io.IOException

java.util.concurrent.ExecutionException

main

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

Parameters:

args -