Package org.jgroups.tests.perf

Class MPerfRpc

java.lang.Object

org.jgroups.tests.perf.MPerfRpc

All Implemented Interfaces:

Receiver

public class MPerfRpc
extends java.lang.Object
implements Receiver

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

Initially copied from MPerf.

Since:

3.3

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
protected static class	MPerfRpc.ConfigChange
protected static class	MPerfRpc.Configuration
protected static class	MPerfRpc.Result
protected class	MPerfRpc.Sender
protected class	MPerfRpc.Stats

Field Summary

Fields

Modifier and Type	Field	Description
protected JChannel	channel
protected static short	clearResults
protected static short	configChange
protected static short	configReq
protected static short	configRsp
protected RpcDispatcher	disp
protected static short	exit
protected static java.text.NumberFormat	format
protected static short	handleData
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 static java.lang.reflect.Method[]	METHODS
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,MPerfRpc.Stats>	received_msgs	Maintains stats per sender, will be sent to perf originator when all messages have been received
protected static short	result
protected Address	result_collector
protected ResponseCollector<MPerfRpc.Result>	results
protected RequestOptions	send_options
protected static short	sendingDone
protected static short	startSending
protected boolean	sync
protected java.util.concurrent.atomic.AtomicLong	total_received_msgs

Constructor Summary

Constructors

Constructor	Description
MPerfRpc()

Method Summary

Modifier and Type	Method	Description
void	clearResults()
protected static java.lang.String	computeStats(long time, long msgs, int size)
protected void	configChange(java.lang.String name)
void	configChange(MPerfRpc.ConfigChange config_change)
void	configReq(Address sender)
void	configRsp(MPerfRpc.Configuration cfg)
protected void	displayResults()
void	exit()
protected java.util.List<Address>	getSenders()	Returns all members if num_senders <= 0, or the members with rank <= num_senders
void	handleData(Address src, byte[] payload, long seqno, boolean check_order)
protected java.lang.Object	invokeRpc(short method_id, Address dest, RequestOptions options, java.lang.Object... args)
protected RspList<?>	invokeRpc(short method_id, RequestOptions options, java.lang.Object... args)
protected void	loop()
static void	main(java.lang.String[] args)
void	result(Address sender, MPerfRpc.Result res)	Called when a result from a node is received
void	sendingDone(Address sender)
protected void	sendMessages()
void	start(java.lang.String props, java.lang.String name)
void	startSending(Address initiator)
void	stop()
void	viewAccepted(View view)	Called when a change in membership has occurred.

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.jgroups.Receiver

block, getState, receive, receive, setState, unblock

Field Detail

props

protected java.lang.String props

channel

protected JChannel channel

disp

protected RpcDispatcher disp

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

sync

protected boolean sync

oob

protected boolean oob

received_msgs

protected final java.util.concurrent.ConcurrentMap<Address,MPerfRpc.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<MPerfRpc.Result> results

result_collector

protected volatile Address result_collector

initiator

protected volatile boolean initiator

send_options

protected RequestOptions send_options

format

protected static final java.text.NumberFormat format

handleData

protected static final short handleData

See Also:

Constant Field Values

startSending

protected static final short startSending

See Also:

Constant Field Values

sendingDone

protected static final short sendingDone

See Also:

Constant Field Values

result

protected static final short result

See Also:

Constant Field Values

clearResults

protected static final short clearResults

See Also:

Constant Field Values

configChange

protected static final short configChange

See Also:

Constant Field Values

configReq

protected static final short configReq

See Also:

Constant Field Values

configRsp

protected static final short configRsp

See Also:

Constant Field Values

exit

protected static final short exit

See Also:

Constant Field Values

METHODS

protected static final java.lang.reflect.Method[] METHODS

Constructor Detail

MPerfRpc

public MPerfRpc()

Method Detail

start

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

Throws:

java.lang.Exception

loop

protected void loop()

displayResults

protected void displayResults()

configChange

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

Throws:

java.lang.Exception

invokeRpc

protected RspList<?> invokeRpc(short method_id,
                               RequestOptions options,
                               java.lang.Object... args)
                        throws java.lang.Exception

Throws:

java.lang.Exception

invokeRpc

protected java.lang.Object invokeRpc(short method_id,
                                     Address dest,
                                     RequestOptions options,
                                     java.lang.Object... args)
                              throws java.lang.Exception

Throws:

java.lang.Exception

stop

public void stop()

handleData

public void handleData(Address src,
                       byte[] payload,
                       long seqno,
                       boolean check_order)

startSending

public void startSending(Address initiator)

sendingDone

public void sendingDone(Address sender)

result

public void result(Address sender,
                   MPerfRpc.Result res)

Called when a result from a node is received

clearResults

public void clearResults()

configChange

public void configChange(MPerfRpc.ConfigChange config_change)

configReq

public void configReq(Address sender)
               throws java.lang.Exception

Throws:

java.lang.Exception

configRsp

public void configRsp(MPerfRpc.Configuration cfg)

exit

public void exit()

getSenders

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

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

viewAccepted

public void viewAccepted(View view)

Description copied from interface: Receiver

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 JChannel.connect(String) returns.

Specified by:

viewAccepted in interface Receiver

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)