MPerfRpc

java.lang.Object
- com.fr.third.jgroups.ReceiverAdapter
- - com.fr.third.jgroups.tests.perf.MPerfRpc

所有已实现的接口:

MembershipListener, MessageListener, Receiver
```
public class MPerfRpc
extends ReceiverAdapter
```
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.

从以下版本开始:

3.3

作者:

Bela Ban (belaban@yahoo.com)

嵌套类概要

嵌套类
限定符和类型	类和说明
`protected static class`	`MPerfRpc.ConfigChange`
`protected static class`	`MPerfRpc.Configuration`
`protected class`	`MPerfRpc.MperfMarshaller`
`protected static class`	`MPerfRpc.Result`
`protected class`	`MPerfRpc.Sender`
`protected class`	`MPerfRpc.Stats`

字段概要

字段
限定符和类型	字段和说明
`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`

构造器概要

构造器
构造器和说明

MPerfRpc()

构造器
构造器和说明
`MPerfRpc()`

方法概要

方法
限定符和类型	方法和说明
`void`	`clearResults()`
`protected static java.lang.String`	`computeStats(long time, long msgs, int size)`
`void`	`configChange(MPerfRpc.ConfigChange config_change)`
`protected void`	`configChange(java.lang.String name)`
`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.

从类继承的方法 com.fr.third.jgroups.ReceiverAdapter
block, getState, receive, 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
```

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

另请参阅:: 常量字段值

startSending

protected static final short startSending

另请参阅:: 常量字段值

sendingDone

protected static final short sendingDone

另请参阅:: 常量字段值

result
```
protected static final short result
```
另请参阅:
常量字段值

clearResults

protected static final short clearResults

另请参阅:: 常量字段值

configChange

protected static final short configChange

另请参阅:: 常量字段值

configReq
```
protected static final short configReq
```
另请参阅:
常量字段值

configRsp
```
protected static final short configRsp
```
另请参阅:
常量字段值

exit
```
protected static final short exit
```
另请参阅:
常量字段值

METHODS

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

构造器详细资料
- MPerfRpc
```
public MPerfRpc()
```

方法详细资料

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

invokeRpc

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

抛出:: java.lang.Exception

invokeRpc

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

抛出:: 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

抛出:: 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)
```
从类复制的说明: 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)

类 MPerfRpc

嵌套类概要

字段概要

构造器概要

方法概要

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

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

字段详细资料

props

channel

disp

local_addr

name

num_msgs

msg_size

num_threads

log_interval

receive_log_interval

num_senders

sync

oob

received_msgs

total_received_msgs

members

log

looping

last_interval

results

result_collector

initiator

send_options

format

handleData

startSending

sendingDone

result

clearResults

configChange

configReq

configRsp

exit

METHODS

构造器详细资料

MPerfRpc

方法详细资料

start

loop

displayResults

configChange

invokeRpc

invokeRpc

stop

handleData

startSending

sendingDone

result

clearResults

configChange

configReq

configRsp

exit

getSenders

viewAccepted

sendMessages

computeStats

main