|
|||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Objectorg.objectweb.tribe.channel.ChannelPerformaceTest
This class defines a ChannelPerformaceTest
Field Summary | |
private PullPushAdapter |
adapter
|
private ReliableGroupChannelWithGms |
channel
|
private UdpDiscoveryService |
discovery
|
private int |
done
|
private GroupMembershipService |
gms
|
private int |
msgSize
|
private int |
nbOfMembers
|
private int |
nbOfMessages
|
private int |
nbOfSenders
|
private int |
received
|
private boolean |
sending
|
private long |
start
|
private GroupIdentifier |
testGid
|
Constructor Summary | |
ChannelPerformaceTest(int members,
int senders,
int messages,
int size)
Creates a new ChannelPerformaceTest object |
Method Summary | |
void |
failedMember(Member failed,
GroupIdentifier gid,
Member sender)
|
void |
groupComposition(Group g,
Address sender)
|
private void |
initializeChannel()
Initializes group communication channel and adapter. |
void |
joinMember(Member m,
GroupIdentifier gid)
|
static void |
main(java.lang.String[] args)
Main method taking the following arguments: 1. number of group members 2. number of senders (first to join the group will send) 3. number of messages to send to the group 4. message msgSize in bytes |
void |
quitMember(Member m,
GroupIdentifier gid)
|
void |
receive(java.io.Serializable msg)
|
private void |
sendMessages()
Send the messages to the group as defined by the command line parameters |
Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
Field Detail |
private ReliableGroupChannelWithGms channel
private UdpDiscoveryService discovery
private GroupMembershipService gms
private final GroupIdentifier testGid
private PullPushAdapter adapter
private int received
private int msgSize
private int nbOfMessages
private int nbOfSenders
private int nbOfMembers
private int done
private long start
private boolean sending
Constructor Detail |
public ChannelPerformaceTest(int members, int senders, int messages, int size)
ChannelPerformaceTest
object
members
- senders
- messages
- size
- Method Detail |
private void initializeChannel() throws java.lang.Exception
java.lang.Exception
- if an error occursprivate void sendMessages()
public void receive(java.io.Serializable msg)
receive
in interface MessageListener
MessageListener.receive(java.io.Serializable)
public void joinMember(Member m, GroupIdentifier gid)
joinMember
in interface GroupMembershipListener
GroupMembershipListener.joinMember(org.objectweb.tribe.common.Member,
org.objectweb.tribe.common.GroupIdentifier)
public void quitMember(Member m, GroupIdentifier gid)
quitMember
in interface GroupMembershipListener
GroupMembershipListener.quitMember(org.objectweb.tribe.common.Member,
org.objectweb.tribe.common.GroupIdentifier)
public void groupComposition(Group g, Address sender)
groupComposition
in interface GroupMembershipListener
GroupMembershipListener.groupComposition(org.objectweb.tribe.common.Group,
org.objectweb.tribe.common.Address)
public void failedMember(Member failed, GroupIdentifier gid, Member sender)
failedMember
in interface GroupMembershipListener
GroupMembershipListener.failedMember(org.objectweb.tribe.common.Member,
org.objectweb.tribe.common.GroupIdentifier,
org.objectweb.tribe.common.Member)
public static void main(java.lang.String[] args)
1. number of group members 2. number of senders (first to join the group will send) 3. number of messages to send to the group 4. message msgSize in bytes
args
- command line arguments
|
|||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |