| java.lang.Object org.jgroups.tests.PerfTest
PerfTest | public class PerfTest implements MessageListener,MembershipListener(Code) | | Test which multicasts n messages to all members. Measures the time until all members have received
all messages from all senders. Start a number of members (e.g. 4). Wait until all of them are up and
have joined the group. Then press 's' for all senders to start multicasting messages. When you see all
--* DONE messages for all senders, press 'a' to see the total stats.
author: Bela Ban |
Inner Class :public static class MyHeader extends Header | |
Constructor Summary | |
public | PerfTest(String props, int num_bursts, int num_msgs_per_burst, int msg_size, long sleep_time, boolean sender) |
buf | byte[] buf(Code) | | The buffer to be sent (will be msg_size bytes)
|
busy_sleep | boolean busy_sleep(Code) | | Use busy sleeping ? (see #Util.sleep(long,boolean) for details)
|
data | HashMap data(Code) | | HashMap. Stores received multicasts. Keyed by sender
|
msg_size | int msg_size(Code) | | Size of a message in bytes
|
num_bursts | int num_bursts(Code) | | Number of bursts. Total number of messages is num_bursts * num_msgs_per_burst
|
num_msgs_per_burst | int num_msgs_per_burst(Code) | | Number of messages per burst. After a burst we sleep for sleep_time msecs
|
sender | boolean sender(Code) | | Am I a sender as well ?
|
sent_msgs | long sent_msgs(Code) | | Number of messages sent by us
|
sleep_time | long sleep_time(Code) | | Sleep time between bursts in milliseconds. 0 means no sleep
|
PerfTest | public PerfTest(String props, int num_bursts, int num_msgs_per_burst, int msg_size, long sleep_time, boolean sender)(Code) | | |
block | public void block()(Code) | | |
getState | public byte[] getState()(Code) | | |
sendMessages | void sendMessages()(Code) | | |
setState | public void setState(byte[] state)(Code) | | |
viewAccepted | public void viewAccepted(View new_view)(Code) | | |
|
|