Class SimpleP2PClient

java.lang.Object
  SimpleP2PClient

public class SimpleP2PClient
extends java.lang.Object

Nested Class Summary

(package private) class	SimpleP2PClient.MessageSendEvent
(package private) class	SimpleP2PClient.MessageTimer

Field Summary

private static int	BUCKETSIZE
private ATcpClientSocket	clisock
private QueueIF	compQ
private ATcpConnection	conn
private static boolean	CONSTANT_RATE
private int	cur_seqNum
private static boolean	DEBUG
protected static java.lang.String	HOSTNAME
private static int	MIN_DELAY
private long	MS_WAIT
private int	MSGS_PER_SEND
private java.util.Hashtable	msgTbl
protected static int	NUM_MSGS
protected static double	RATE
protected static StatsGatherer	respStats
private long	send_last
private java.util.Vector	sendEvents
private static int	SKIP_SAMPLES
private ssTimer	timer
private int	total_rcv
private static boolean	VERBOSE

Constructor Summary

SimpleP2PClient()

Method Summary

void	doIt()
private void	doSender()
static void	main(java.lang.String[] args)
private void	startSender()
private static void	usage()

Methods inherited from class java.lang.Object

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

Field Detail

DEBUG

private static final boolean DEBUG

See Also:

Constant Field Values

VERBOSE

private static final boolean VERBOSE

See Also:

Constant Field Values

CONSTANT_RATE

private static final boolean CONSTANT_RATE

See Also:

Constant Field Values

BUCKETSIZE

private static final int BUCKETSIZE

See Also:

Constant Field Values

SKIP_SAMPLES

private static final int SKIP_SAMPLES

See Also:

Constant Field Values

MIN_DELAY

private static final int MIN_DELAY

See Also:

Constant Field Values

HOSTNAME

protected static java.lang.String HOSTNAME

RATE

protected static double RATE

NUM_MSGS

protected static int NUM_MSGS

respStats

protected static StatsGatherer respStats

compQ

private QueueIF compQ

conn

private ATcpConnection conn

clisock

private ATcpClientSocket clisock

total_rcv

private int total_rcv

msgTbl

private java.util.Hashtable msgTbl

cur_seqNum

private int cur_seqNum

timer

private ssTimer timer

MS_WAIT

private long MS_WAIT

MSGS_PER_SEND

private int MSGS_PER_SEND

sendEvents

private java.util.Vector sendEvents

send_last

private long send_last

Constructor Detail

SimpleP2PClient

public SimpleP2PClient()
                throws java.lang.Exception

Throws:

java.lang.Exception

Method Detail

startSender

private void startSender()

doSender

private void doSender()

doIt

public void doIt()
          throws SinkClosedException,
                 java.io.IOException

Throws:

SinkClosedException

java.io.IOException

usage

private static void usage()

main

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