public class RoundTripRpc extends ReceiverAdapter
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.
|
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)
ReceiverAdapter
Channel.connect(String)
returns.viewAccepted
in interface MembershipListener
viewAccepted
in class ReceiverAdapter
protected void loop()
protected static String print(AverageMinMax avg)
Copyright © 2023 JBoss, a division of Red Hat. All rights reserved.