com.fr.third.jgroups.tests.perf

类 MPerf

java.lang.Object

com.fr.third.jgroups.ReceiverAdapter

com.fr.third.jgroups.tests.perf.MPerf

所有已实现的接口:

MembershipListener, MessageListener, Receiver

public class MPerf
extends ReceiverAdapter

Dynamic tool to measure multicast performance of JGroups; every member sends N messages and we measure how long it takes for all receivers to receive them.

All messages received from a member P are checked for ordering and non duplicity.

MPerf is dynamic because it doesn't accept any configuration parameters (besides the channel config file and name); all configuration is done at runtime, and will be broadcast to all cluster members.

从以下版本开始:

3.1

作者:

Bela Ban (belaban@yahoo.com)

嵌套类概要

嵌套类

限定符和类型	类和说明
protected static class	MPerf.ConfigChange
protected static class	MPerf.Configuration
protected static class	MPerf.MPerfHeader
protected static class	MPerf.Result
protected class	MPerf.Sender
protected class	MPerf.Stats

字段概要

字段

限定符和类型	字段和说明
protected AckCollector	ack_collector
protected boolean	cancelled
protected JChannel	channel
protected static java.text.NumberFormat	format
protected static short	ID
protected boolean	initiator
protected long	last_interval
protected Address	local_addr
protected Log	log
protected int	log_interval
protected boolean	looping
protected java.util.List<Address>	members
protected int	msg_size
protected java.lang.String	name
protected int	num_msgs
protected int	num_senders
protected int	num_threads
protected boolean	oob
protected java.lang.String	props
protected int	receive_log_interval
protected java.util.concurrent.ConcurrentMap<Address,MPerf.Stats>	received_msgs Maintains stats per sender, will be sent to perf originator when all messages have been received
protected Address	result_collector
protected ResponseCollector<MPerf.Result>	results
protected java.util.concurrent.atomic.AtomicLong	total_received_msgs

构造器概要

构造器

构造器和说明
MPerf()

方法概要

方法

限定符和类型	方法和说明
protected void	applyNewConfig(byte[] buffer)
protected static java.lang.String	computeStats(long time, long msgs, int size)
protected void	configChange(java.lang.String name)
protected void	displayResults()
protected static java.io.InputStream	findFile(java.lang.String filename)
protected java.util.List<Address>	getSenders() Returns all members if num_senders <= 0, or the members with rank <= num_senders
protected void	handleConfigChange(MPerf.ConfigChange config_change)
protected void	handleConfigRequest(Address sender)
protected void	handleConfigResponse(MPerf.Configuration cfg)
protected void	handleData(Address src, long seqno, boolean check_order)
protected void	loop()
static void	main(java.lang.String[] args)
protected void	newConfig()
protected static java.lang.String	printProperties()
void	receive(Message msg) Called when a message is received.
protected void	send(Address target, java.lang.Object payload, byte header, Message.Flag... flags)
protected void	sendMessages()
void	start(java.lang.String props, java.lang.String name)
void	stop()
void	viewAccepted(View view) Called when a change in membership has occurred.

从类继承的方法 com.fr.third.jgroups.ReceiverAdapter

block, getState, setState, suspect, unblock

从类继承的方法 java.lang.Object

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

字段详细资料

props

protected java.lang.String props

channel

protected JChannel channel

ack_collector

protected final AckCollector ack_collector

local_addr

protected Address local_addr

name

protected java.lang.String name

num_msgs

protected int num_msgs

msg_size

protected int msg_size

num_threads

protected int num_threads

log_interval

protected int log_interval

receive_log_interval

protected int receive_log_interval

num_senders

protected int num_senders

oob

protected boolean oob

cancelled

protected boolean cancelled

received_msgs

protected final java.util.concurrent.ConcurrentMap<Address,MPerf.Stats> received_msgs

Maintains stats per sender, will be sent to perf originator when all messages have been received

total_received_msgs

protected final java.util.concurrent.atomic.AtomicLong total_received_msgs

members

protected final java.util.List<Address> members

log

protected final Log log

looping

protected boolean looping

last_interval

protected long last_interval

results

protected final ResponseCollector<MPerf.Result> results

result_collector

protected volatile Address result_collector

initiator

protected volatile boolean initiator

format

protected static final java.text.NumberFormat format

ID

protected static final short ID

构造器详细资料

MPerf

public MPerf()

方法详细资料

start

public void start(java.lang.String props,
         java.lang.String name)
           throws java.lang.Exception

抛出:

java.lang.Exception

loop

protected void loop()

displayResults

protected void displayResults()

configChange

protected void configChange(java.lang.String name)
                     throws java.lang.Exception

抛出:

java.lang.Exception

newConfig

protected void newConfig()
                  throws java.lang.Exception

抛出:

java.lang.Exception

send

protected void send(Address target,
        java.lang.Object payload,
        byte header,
        Message.Flag... flags)
             throws java.lang.Exception

抛出:

java.lang.Exception

printProperties

protected static java.lang.String printProperties()

findFile

protected static java.io.InputStream findFile(java.lang.String filename)

stop

public void stop()

receive

public void receive(Message msg)

从类复制的说明: ReceiverAdapter

Called when a message is received.

指定者:

receive 在接口中 MessageListener

覆盖:

receive 在类中 ReceiverAdapter

handleData

protected void handleData(Address src,
              long seqno,
              boolean check_order)

getSenders

protected java.util.List<Address> getSenders()

Returns all members if num_senders <= 0, or the members with rank <= num_senders

applyNewConfig

protected void applyNewConfig(byte[] buffer)

handleConfigChange

protected void handleConfigChange(MPerf.ConfigChange config_change)

handleConfigRequest

protected void handleConfigRequest(Address sender)
                            throws java.lang.Exception

抛出:

java.lang.Exception

handleConfigResponse

protected void handleConfigResponse(MPerf.Configuration cfg)

viewAccepted

public void viewAccepted(View view)

从类复制的说明: ReceiverAdapter

Called when a change in membership has occurred. No long running actions, sending of messages or anything that could block should be done in this callback. If some long running action needs to be performed, it should be done in a separate thread.

Note that on reception of the first view (a new member just joined), the channel will not yet be in the connected state. This only happens when Channel.connect(String) returns.

指定者:

viewAccepted 在接口中 MembershipListener

覆盖:

viewAccepted 在类中 ReceiverAdapter

sendMessages

protected void sendMessages()

computeStats

protected static java.lang.String computeStats(long time,
                            long msgs,
                            int size)

main

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