public class MPerf extends ReceiverAdapter
Modifier and Type | Class and Description |
---|---|
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 |
Modifier and Type | Field and Description |
---|---|
protected AckCollector |
ack_collector |
protected boolean |
cancelled |
protected JChannel |
channel |
protected static 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 List<Address> |
members |
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,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 AtomicLong |
total_received_msgs |
Constructor and Description |
---|
MPerf() |
Modifier and Type | Method and Description |
---|---|
protected void |
applyNewConfig(byte[] buffer) |
protected static String |
computeStats(long time,
long msgs,
int size) |
protected void |
configChange(String name) |
protected void |
displayResults() |
protected static InputStream |
findFile(String filename) |
protected 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(String[] args) |
protected void |
newConfig() |
protected static String |
printProperties() |
void |
receive(Message msg)
Called when a message is received.
|
protected void |
send(Address target,
Object payload,
byte header,
Message.Flag... flags) |
protected void |
sendMessages() |
void |
start(String props,
String name) |
void |
stop() |
void |
viewAccepted(View view)
Called when a change in membership has occurred.
|
protected String props
protected JChannel channel
protected final AckCollector ack_collector
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 oob
protected boolean cancelled
protected final ConcurrentMap<Address,MPerf.Stats> received_msgs
protected final AtomicLong total_received_msgs
protected final Log log
protected boolean looping
protected long last_interval
protected final ResponseCollector<MPerf.Result> results
protected volatile Address result_collector
protected volatile boolean initiator
protected static final NumberFormat format
protected static final short ID
protected void loop()
protected void displayResults()
protected void send(Address target, Object payload, byte header, Message.Flag... flags) throws Exception
Exception
protected static String printProperties()
protected static InputStream findFile(String filename)
public void stop()
public void receive(Message msg)
ReceiverAdapter
receive
in interface MessageListener
receive
in class ReceiverAdapter
protected void handleData(Address src, long seqno, boolean check_order)
protected List<Address> getSenders()
protected void applyNewConfig(byte[] buffer)
protected void handleConfigChange(MPerf.ConfigChange config_change)
protected void handleConfigRequest(Address sender) throws Exception
Exception
protected void handleConfigResponse(MPerf.Configuration cfg)
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 © 2019 JBoss, a division of Red Hat. All rights reserved.