| java.lang.Object
 org.jgroups.tests.ContinousThroughputTest
| ContinousThroughputTest | | public class ContinousThroughputTest (Code) | | ContinousThroughputTest.java
This is a program to make Throughput tests.
The program assumes to run on a reliable network where no partitioning or failures happen (Apart for cping test).
Once you run the program it connects the channel and gives you a prompt.
Every time a new view is received you will see it printed.
Once you have launched the program on all the machine you use for the test just digit
on one machine the command for the test you desire to make, you will be asked for the necessary parameters,
then the test starts.
Depending on the chosen test you will see its results on the monitor and them ar logged
on a file on the working dir called "ContinousThroughputTest.log" .
author:
Gianluca Collot
version:
1.0 |
| Inner Class :public static class MessageLenghtObserver implements ProtocolObserver | |
| coordinator | | boolean coordinator(Code) | | |
| sendThreadreceiveThread | | Thread sendThreadreceiveThread(Code) | | |
| troughputSummeanTroughputminTroughputmaxTroughput | | float troughputSummeanTroughputminTroughputmaxTroughput(Code) | | |
| ContinousThroughputTest | | public ContinousThroughputTest()(Code) | | Creates threads, creates and connects channel opens log file
|
| checkChannel | | public void checkChannel()(Code) | | This function should be called in its own thread.
It recives messages and calculates the troughput
|
| cpingTest | | void cpingTest(int burst_lenght, boolean printoutput)(Code) | | Makes a continous test handling view changes
|
| parser | | public void parser()(Code) | | This function should be run in its own thread and sends messages on an already connected channel
|
| pingpongTest | | void pingpongTest(long n, int burst_length, boolean partialResultsPrint)(Code) | | Make a pingpong test:
For n times a message is sent and view.size() messages are received
Every 1000 messages sent the throughput is evaluated or at the end of the test
|
| resetData | | void resetData()(Code) | | Resets stored statistics and counters
|
| sendBurst | | void sendBurst(long n)(Code) | | sendBurst(int n): sends a burst of messages with small payload
|
| showStats | | void showStats(long start, long stop, long messages, int burstlength)(Code) | | showStats: Prints resulting times and troughput
|
| sweep | | void sweep(long tests, int burstlenght)(Code) | | |
|
|