public class UPerf extends ReceiverAdapter
Modifier and Type | Class and Description |
---|---|
static class |
UPerf.Config |
static class |
UPerf.Results |
Modifier and Type | Field and Description |
---|---|
protected boolean |
allow_local_gets |
protected int |
anycast_count |
protected Thread |
event_loop_thread |
protected static String |
format |
protected boolean |
looping |
protected List<Address> |
members |
protected boolean |
msg_bundling |
protected int |
msg_size |
protected int |
num_msgs |
protected int |
num_threads |
protected boolean |
oob |
protected boolean |
print_details |
protected boolean |
print_invokers |
protected double |
read_percentage |
protected List<Address> |
site_masters |
protected boolean |
sync |
protected View |
view |
Constructor and Description |
---|
UPerf() |
Modifier and Type | Method and Description |
---|---|
protected void |
addSiteMastersToMembers() |
protected void |
applyConfig(UPerf.Config config) |
protected void |
changeFieldAcrossCluster(String field_name,
Object value) |
void |
eventLoop() |
byte[] |
get(long key) |
UPerf.Config |
getConfig() |
protected static List<String> |
getSites(JChannel channel) |
void |
init(String props,
String name,
boolean xsite,
AddressGenerator generator,
int bind_port) |
static void |
main(String[] args) |
protected static String |
print(AverageMinMax avg,
boolean details) |
protected void |
printView() |
void |
put(long key,
byte[] val) |
void |
quitAll() |
void |
set(String field_name,
Object value) |
protected void |
startEventThread() |
UPerf.Results |
startTest() |
protected void |
stopEventThread() |
void |
viewAccepted(View new_view)
Called when a change in membership has occurred.
|
protected volatile View view
protected volatile boolean looping
protected Thread event_loop_thread
protected boolean sync
protected boolean oob
protected int num_threads
protected int num_msgs
protected int msg_size
protected int anycast_count
protected boolean msg_bundling
protected double read_percentage
protected boolean allow_local_gets
protected boolean print_invokers
protected boolean print_details
protected static final String format
public void init(String props, String name, boolean xsite, AddressGenerator generator, int bind_port) throws Throwable
Throwable
protected void startEventThread()
protected void stopEventThread()
public void viewAccepted(View new_view)
ReceiverAdapter
Channel.connect(String)
returns.viewAccepted
in interface MembershipListener
viewAccepted
in class ReceiverAdapter
protected void addSiteMastersToMembers()
public UPerf.Results startTest() throws Throwable
Throwable
public void quitAll()
public byte[] get(long key)
public void put(long key, byte[] val)
public UPerf.Config getConfig()
protected void applyConfig(UPerf.Config config)
protected void changeFieldAcrossCluster(String field_name, Object value) throws Exception
Exception
protected void printView()
protected static String print(AverageMinMax avg, boolean details)
public static void main(String[] args)
Copyright © 2023 JBoss, a division of Red Hat. All rights reserved.