Class MultiClientThreaded

java.lang.Object
  java.lang.Thread
      MultiClientThreaded

All Implemented Interfaces:

java.lang.Runnable

public class MultiClientThreaded
extends java.lang.Thread

Nested Class Summary

Nested classes/interfaces inherited from class java.lang.Thread

java.lang.Thread.State, java.lang.Thread.UncaughtExceptionHandler

Field Summary

private static int	BENCH_DELAY
private boolean	benchthread
private static int[]	clientNumBurstsReceived
private static int[]	clientNumBurstsSent
private static int	CONN_HIST_BUCKETSIZE
private static java.util.Hashtable	conn_time_hist
private static boolean	DEBUG
private static boolean	HISTOGRAM_REPORT
private static java.lang.Object	lock
private static long	max_connect_time
private static long	max_response_time
private static int	num_bytes
private static int	num_completions
private static int	num_connections
private static int	NUM_CONNECTIONS
private static int	numBenchRuns
private static int	NUMBER_RUNS
private static boolean	OVERALL_REPORT
private static int	PORTNUM
private static boolean	QUIET
private static int	RECV_BURST_SIZE
private static int	RECV_MESSAGE_SIZE
private static java.lang.String	REMOTE_HOST
private static int	RESP_HIST_BUCKETSIZE
private static java.util.Hashtable	resp_time_hist
private static int	SEND_BURST_SIZE
private static int	SEND_MESSAGE_SIZE
private static int	SLEEP_TIME
private java.net.Socket	sock
private int	tnum
private static long	total_connect_time
private static long	total_response_time
private static boolean	VERBOSE_REPORT

Fields inherited from class java.lang.Thread

MAX_PRIORITY, MIN_PRIORITY, NORM_PRIORITY

Constructor Summary

MultiClientThreaded()

MultiClientThreaded(int tnum)

Method Summary

private void	doBandwidth()
private void	doBenchThread()
private void	doClientThread()
static void	main(java.lang.String[] args)
private static void	printResults(java.lang.String msg, int numiters, int message_size, long t1, long t2)
void	run()

Methods inherited from class java.lang.Thread

activeCount, checkAccess, countStackFrames, currentThread, destroy, dumpStack, enumerate, getAllStackTraces, getContextClassLoader, getDefaultUncaughtExceptionHandler, getId, getName, getPriority, getStackTrace, getState, getThreadGroup, getUncaughtExceptionHandler, holdsLock, interrupt, interrupted, isAlive, isDaemon, isInterrupted, join, join, join, resume, setContextClassLoader, setDaemon, setDefaultUncaughtExceptionHandler, setName, setPriority, setUncaughtExceptionHandler, sleep, sleep, start, stop, stop, suspend, toString, yield

Methods inherited from class java.lang.Object

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

Field Detail

DEBUG

private static final boolean DEBUG

See Also:

Constant Field Values

PORTNUM

private static final int PORTNUM

See Also:

Constant Field Values

OVERALL_REPORT

private static final boolean OVERALL_REPORT

See Also:

Constant Field Values

VERBOSE_REPORT

private static final boolean VERBOSE_REPORT

See Also:

Constant Field Values

HISTOGRAM_REPORT

private static final boolean HISTOGRAM_REPORT

See Also:

Constant Field Values

REMOTE_HOST

private static java.lang.String REMOTE_HOST

NUM_CONNECTIONS

private static int NUM_CONNECTIONS

SEND_MESSAGE_SIZE

private static int SEND_MESSAGE_SIZE

RECV_MESSAGE_SIZE

private static int RECV_MESSAGE_SIZE

SEND_BURST_SIZE

private static int SEND_BURST_SIZE

RECV_BURST_SIZE

private static int RECV_BURST_SIZE

QUIET

private static boolean QUIET

BENCH_DELAY

private static final int BENCH_DELAY

See Also:

Constant Field Values

SLEEP_TIME

private static final int SLEEP_TIME

See Also:

Constant Field Values

NUMBER_RUNS

private static final int NUMBER_RUNS

See Also:

Constant Field Values

sock

private java.net.Socket sock

tnum

private int tnum

benchthread

private boolean benchthread

lock

private static java.lang.Object lock

num_connections

private static int num_connections

max_connect_time

private static long max_connect_time

total_connect_time

private static long total_connect_time

num_completions

private static int num_completions

num_bytes

private static int num_bytes

max_response_time

private static long max_response_time

total_response_time

private static long total_response_time

conn_time_hist

private static java.util.Hashtable conn_time_hist

resp_time_hist

private static java.util.Hashtable resp_time_hist

CONN_HIST_BUCKETSIZE

private static final int CONN_HIST_BUCKETSIZE

See Also:

Constant Field Values

RESP_HIST_BUCKETSIZE

private static final int RESP_HIST_BUCKETSIZE

See Also:

Constant Field Values

numBenchRuns

private static int numBenchRuns

clientNumBurstsSent

private static int[] clientNumBurstsSent

clientNumBurstsReceived

private static int[] clientNumBurstsReceived

Constructor Detail

MultiClientThreaded

public MultiClientThreaded(int tnum)

MultiClientThreaded

public MultiClientThreaded()

Method Detail

run

public void run()

Specified by:

run in interface java.lang.Runnable

Overrides:

run in class java.lang.Thread

printResults

private static void printResults(java.lang.String msg,
                                 int numiters,
                                 int message_size,
                                 long t1,
                                 long t2)

doBenchThread

private void doBenchThread()

doClientThread

private void doClientThread()

doBandwidth

private void doBandwidth()
                  throws java.io.IOException

Throws:

java.io.IOException

main

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