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 int |
anycast_count |
protected List<Address> |
members |
protected boolean |
msg_bundling |
protected int |
msg_size |
protected int |
num_msgs |
protected int |
num_threads |
protected boolean |
oob |
protected double |
read_percentage |
protected List<Address> |
site_masters |
protected boolean |
sync |
protected boolean |
use_anycast_addrs |
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) |
static void |
main(String[] args) |
void |
put(long key,
byte[] val) |
void |
set(String field_name,
Object value) |
UPerf.Results |
startTest() |
void |
viewAccepted(View new_view)
Called when a change in membership has occurred.
|
protected boolean sync
protected boolean oob
protected int num_threads
protected int num_msgs
protected int msg_size
protected int anycast_count
protected boolean use_anycast_addrs
protected boolean msg_bundling
protected double read_percentage
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 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
public static void main(String[] args)
Copyright © 2015 JBoss, a division of Red Hat. All rights reserved.