navigators.smart.tom.demo
Class ThroughputLatencyTestClient
java.lang.Object
navigators.smart.tom.TOMSender
navigators.smart.tom.demo.ThroughputLatencyTestClient
- All Implemented Interfaces:
- java.lang.Runnable, ReplyReceiver
public class ThroughputLatencyTestClient
- extends TOMSender
- implements java.lang.Runnable
Method Summary |
static void |
main(java.lang.String[] args)
|
void |
replyReceived(TOMMessage reply)
This is the method invoked by the client side comunication system, and where the
code to handle the reply is to be written |
void |
run()
|
Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
st
private Storage st
exec
private int exec
argSize
private int argSize
sm
private java.util.concurrent.Semaphore sm
mutex
private java.util.concurrent.Semaphore mutex
count
private int count
cs
private CommunicationSystemClientSide cs
f
private int f
n
private int n
myId
private int myId
currentId
private int currentId
last_send_instant
private long last_send_instant
num_sends
private int num_sends
interval
private int interval
initialNumOps
private long[] initialNumOps
initialTimestamp
private long[] initialTimestamp
max
private long max
measurementEpoch
private int measurementEpoch
ThroughputLatencyTestClient
public ThroughputLatencyTestClient(int id,
int exec,
int argSize,
int interval,
TOMConfiguration conf)
run
public void run()
- Specified by:
run
in interface java.lang.Runnable
replyReceived
public void replyReceived(TOMMessage reply)
- Description copied from interface:
ReplyReceiver
- This is the method invoked by the client side comunication system, and where the
code to handle the reply is to be written
- Specified by:
replyReceived
in interface ReplyReceiver
- Parameters:
reply
- The reply delivered by the client side comunication system
main
public static void main(java.lang.String[] args)