public class RoundTripRpc extends Object implements MembershipListener
RpcDispatcherSpeedTest
for
RPCsModifier and Type | Class and Description |
---|---|
protected class |
RoundTripRpc.Invoker |
Modifier and Type | Field and Description |
---|---|
protected JChannel |
channel |
protected boolean |
details |
protected RpcDispatcher |
disp |
protected boolean |
dont_bundle |
protected RoundTripRpc.Invoker[] |
invokers |
protected int |
num_msgs |
protected int |
num_senders |
protected boolean |
oob |
protected static Method |
requestMethod |
Constructor and Description |
---|
RoundTripRpc() |
Modifier and Type | Method and Description |
---|---|
protected void |
invokeRequests() |
protected void |
loop() |
static void |
main(String[] args) |
protected static String |
print(AverageMinMax avg) |
static short |
request(short id) |
protected void |
start(String props,
String name) |
void |
viewAccepted(View view)
Called when a change in membership has occurred.
|
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
block, suspect, unblock
protected JChannel channel
protected RpcDispatcher disp
protected int num_msgs
protected int num_senders
protected boolean oob
protected boolean dont_bundle
protected boolean details
protected RoundTripRpc.Invoker[] invokers
protected static final Method requestMethod
public static short request(short id)
public void viewAccepted(View view)
MembershipListener
JChannel.connect(String)
returns.viewAccepted
in interface MembershipListener
protected void loop()
protected static String print(AverageMinMax avg)
Copyright © 2018 JBoss, a division of Red Hat. All rights reserved.