public class MPerfRpc extends ReceiverAdapter
MPerf
.Modifier and Type | Class and Description |
---|---|
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 |
Modifier and Type | Field and 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 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 List<Address> |
members |
protected static Method[] |
METHODS |
protected int |
msg_size |
protected String |
name |
protected int |
num_msgs |
protected int |
num_senders |
protected int |
num_threads |
protected boolean |
oob |
protected String |
props |
protected int |
receive_log_interval |
protected 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 AtomicLong |
total_received_msgs |
Constructor and Description |
---|
MPerfRpc() |
Modifier and Type | Method and Description |
---|---|
void |
clearResults() |
protected static String |
computeStats(long time,
long msgs,
int size) |
void |
configChange(MPerfRpc.ConfigChange config_change) |
protected void |
configChange(String name) |
void |
configReq(Address sender) |
void |
configRsp(MPerfRpc.Configuration cfg) |
protected void |
displayResults() |
void |
exit() |
protected 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 Object |
invokeRpc(short method_id,
Address dest,
RequestOptions options,
Object... args) |
protected RspList |
invokeRpc(short method_id,
RequestOptions options,
Object... args) |
protected void |
loop() |
static void |
main(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(String props,
String name) |
void |
startSending(Address initiator) |
void |
stop() |
void |
viewAccepted(View view)
Called when a change in membership has occurred.
|
protected String props
protected JChannel channel
protected RpcDispatcher disp
protected Address local_addr
protected String name
protected int num_msgs
protected int msg_size
protected int num_threads
protected int log_interval
protected int receive_log_interval
protected int num_senders
protected boolean sync
protected boolean oob
protected final ConcurrentMap<Address,MPerfRpc.Stats> received_msgs
protected final AtomicLong total_received_msgs
protected final Log log
protected boolean looping
protected long last_interval
protected final ResponseCollector<MPerfRpc.Result> results
protected volatile Address result_collector
protected volatile boolean initiator
protected RequestOptions send_options
protected static final NumberFormat format
protected static final short handleData
protected static final short startSending
protected static final short sendingDone
protected static final short result
protected static final short clearResults
protected static final short configChange
protected static final short configReq
protected static final short configRsp
protected static final short exit
protected static final Method[] METHODS
protected void loop()
protected void displayResults()
protected RspList invokeRpc(short method_id, RequestOptions options, Object... args) throws Exception
Exception
protected Object invokeRpc(short method_id, Address dest, RequestOptions options, Object... args) throws Exception
Exception
public void stop()
public void handleData(Address src, byte[] payload, long seqno, boolean check_order)
public void startSending(Address initiator)
public void sendingDone(Address sender)
public void result(Address sender, MPerfRpc.Result res)
public void clearResults()
public void configChange(MPerfRpc.ConfigChange config_change)
public void configRsp(MPerfRpc.Configuration cfg)
public void exit()
protected List<Address> getSenders()
public void viewAccepted(View view)
ReceiverAdapter
Channel.connect(String)
returns.viewAccepted
in interface MembershipListener
viewAccepted
in class ReceiverAdapter
protected void sendMessages()
protected static String computeStats(long time, long msgs, int size)
public static void main(String[] args)
Copyright © 2020 JBoss, a division of Red Hat. All rights reserved.