org.objectweb.tribe.channel
Class ChannelPerformaceTest

java.lang.Object
  extended byorg.objectweb.tribe.channel.ChannelPerformaceTest
All Implemented Interfaces:
GroupMembershipListener, MessageListener

public class ChannelPerformaceTest
extends java.lang.Object
implements MessageListener, GroupMembershipListener

This class defines a ChannelPerformaceTest

Version:
1.0
Author:
Emmanuel Cecchet

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

channel

private ReliableGroupChannelWithGms channel

discovery

private UdpDiscoveryService discovery

gms

private GroupMembershipService gms

testGid

private final GroupIdentifier testGid

adapter

private PullPushAdapter adapter

received

private int received

msgSize

private int msgSize

nbOfMessages

private int nbOfMessages

nbOfSenders

private int nbOfSenders

nbOfMembers

private int nbOfMembers

done

private int done

start

private long start

sending

private boolean sending
Constructor Detail

ChannelPerformaceTest

public ChannelPerformaceTest(int members,
                             int senders,
                             int messages,
                             int size)
Creates a new ChannelPerformaceTest object

Parameters:
members -
senders -
messages -
size -
Method Detail

initializeChannel

private void initializeChannel()
                        throws java.lang.Exception
Initializes group communication channel and adapter.

Throws:
java.lang.Exception - if an error occurs

sendMessages

private void sendMessages()
Send the messages to the group as defined by the command line parameters


receive

public void receive(java.io.Serializable msg)
Specified by:
receive in interface MessageListener
See Also:
MessageListener.receive(java.io.Serializable)

joinMember

public void joinMember(Member m,
                       GroupIdentifier gid)
Specified by:
joinMember in interface GroupMembershipListener
See Also:
GroupMembershipListener.joinMember(org.objectweb.tribe.common.Member, org.objectweb.tribe.common.GroupIdentifier)

quitMember

public void quitMember(Member m,
                       GroupIdentifier gid)
Specified by:
quitMember in interface GroupMembershipListener
See Also:
GroupMembershipListener.quitMember(org.objectweb.tribe.common.Member, org.objectweb.tribe.common.GroupIdentifier)

groupComposition

public void groupComposition(Group g,
                             Address sender)
Specified by:
groupComposition in interface GroupMembershipListener
See Also:
GroupMembershipListener.groupComposition(org.objectweb.tribe.common.Group, org.objectweb.tribe.common.Address)

failedMember

public void failedMember(Member failed,
                         GroupIdentifier gid,
                         Member sender)
Specified by:
failedMember in interface GroupMembershipListener
See Also:
GroupMembershipListener.failedMember(org.objectweb.tribe.common.Member, org.objectweb.tribe.common.GroupIdentifier, org.objectweb.tribe.common.Member)

main

public 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
 

Parameters:
args - command line arguments


Copyright © 2004 - ObjectWeb Consortium - All Rights Reserved.