public class UPerf extends ReceiverAdapter
Modifier and Type | Class and Description |
---|---|
static class |
UPerf.Config |
static class |
UPerf.Results |
protected class |
UPerf.UPerfMarshaller |
Modifier and Type | Field and Description |
---|---|
protected boolean |
allow_local_gets |
protected static Field |
ALLOW_LOCAL_GETS |
protected int |
anycast_count |
protected static Field |
ANYCAST_COUNT |
protected Thread |
event_loop_thread |
protected static String |
format |
protected boolean |
looping |
protected List<Address> |
members |
protected int |
msg_size |
protected static Field |
MSG_SIZE |
protected LongAdder |
num_reads |
protected int |
num_threads |
protected static Field |
NUM_THREADS |
protected LongAdder |
num_writes |
protected boolean |
oob |
protected static Field |
OOB |
protected boolean |
print_details |
protected static Field |
PRINT_DETAILS |
protected boolean |
print_invokers |
protected static Field |
PRINT_INVOKERS |
protected double |
read_percentage |
protected static Field |
READ_PERCENTAGE |
protected boolean |
sync |
protected static Field |
SYNC |
protected int |
time |
protected static Field |
TIME |
protected View |
view |
Constructor and Description |
---|
UPerf() |
Modifier and Type | Method and Description |
---|---|
protected void |
applyConfig(UPerf.Config config) |
protected void |
changeFieldAcrossCluster(Field field,
Object value) |
void |
eventLoop() |
byte[] |
get(long key) |
UPerf.Config |
getConfig() |
protected static List<String> |
getSites(JChannel channel) |
void |
init(String props,
String name,
AddressGenerator generator,
int bind_port) |
static void |
main(String[] args) |
protected static String |
print(AverageMinMax avg,
boolean details) |
protected String |
printAverage(long start_time) |
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 final LongAdder num_reads
protected final LongAdder num_writes
protected boolean sync
protected boolean oob
protected int num_threads
protected int time
protected int msg_size
protected int anycast_count
protected double read_percentage
protected boolean allow_local_gets
protected boolean print_invokers
protected boolean print_details
protected static final Field SYNC
protected static final Field OOB
protected static final Field NUM_THREADS
protected static final Field TIME
protected static final Field MSG_SIZE
protected static final Field ANYCAST_COUNT
protected static final Field READ_PERCENTAGE
protected static final Field ALLOW_LOCAL_GETS
protected static final Field PRINT_INVOKERS
protected static final Field PRINT_DETAILS
protected static final String format
public void init(String props, String name, AddressGenerator generator, int bind_port) throws Throwable
Throwable
protected void startEventThread()
protected void stopEventThread()
public void viewAccepted(View new_view)
MembershipListener
JChannel.connect(String)
returns.viewAccepted
in interface MembershipListener
viewAccepted
in class ReceiverAdapter
public UPerf.Results startTest() throws Throwable
Throwable
public void quitAll()
protected String printAverage(long start_time)
public byte[] get(long key)
public void put(long key, byte[] val)
public UPerf.Config getConfig()
protected void applyConfig(UPerf.Config config)
public void eventLoop()
protected void changeFieldAcrossCluster(Field field, Object value) throws Exception
Exception
protected void printView()
protected static String print(AverageMinMax avg, boolean details)
public static void main(String[] args)
Copyright © 2018 JBoss, a division of Red Hat. All rights reserved.