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

Field Summary

private int	argSize
private int	count
private CommunicationSystemClientSide	cs
private int	currentId
private int	exec
private int	f
private long[]	initialNumOps
private long[]	initialTimestamp
private int	interval
private long	last_send_instant
private long	max
private int	measurementEpoch
private java.util.concurrent.Semaphore	mutex
private int	myId
private int	n
private int	num_sends
private java.util.concurrent.Semaphore	sm
private Storage	st

Constructor Summary

ThroughputLatencyTestClient(int id, int exec, int argSize, int interval, TOMConfiguration conf)

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 navigators.smart.tom.TOMSender

getLastSequenceNumber, init, init, sign, TOMulticast, TOMulticast, TOMulticast

Methods inherited from class java.lang.Object

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

Field Detail

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

Constructor Detail

ThroughputLatencyTestClient

public ThroughputLatencyTestClient(int id,
                                   int exec,
                                   int argSize,
                                   int interval,
                                   TOMConfiguration conf)

Method Detail

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)