com.fr.third.jgroups.tests.perf

类 UPerf

java.lang.Object

com.fr.third.jgroups.ReceiverAdapter

com.fr.third.jgroups.tests.perf.UPerf

所有已实现的接口:

MembershipListener, MessageListener, Receiver

public class UPerf
extends ReceiverAdapter

Tests the UNICAST by invoking unicast RPCs between a sender and a receiver. Mimicks the DIST mode in Infinispan

作者:

Bela Ban

嵌套类概要

嵌套类

限定符和类型	类和说明
static class	UPerf.Config
static class	UPerf.Results

字段概要

字段

限定符和类型	字段和说明
protected int	anycast_count
protected java.lang.Thread	event_loop_thread
protected boolean	get_before_put
protected boolean	looping
protected java.util.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 java.util.List<Address>	site_masters
protected boolean	sync
protected boolean	use_anycast_addrs
protected View	view

构造器概要

构造器

构造器和说明
UPerf()

方法概要

方法

限定符和类型	方法和说明
protected void	addSiteMastersToMembers()
protected void	applyConfig(UPerf.Config config)
protected void	changeFieldAcrossCluster(java.lang.String field_name, java.lang.Object value)
void	eventLoop()
byte[]	get(long key)
UPerf.Config	getConfig()
protected static java.util.List<java.lang.String>	getSites(JChannel channel)
void	init(java.lang.String props, java.lang.String name, boolean xsite, AddressGenerator generator, int bind_port)
static void	main(java.lang.String[] args)
void	put(long key, byte[] val)
void	quitAll()
void	set(java.lang.String field_name, java.lang.Object value)
protected void	startEventThread()
UPerf.Results	startTest()
protected void	stopEventThread()
void	viewAccepted(View new_view) Called when a change in membership has occurred.

从类继承的方法 com.fr.third.jgroups.ReceiverAdapter

block, getState, receive, setState, suspect, unblock

从类继承的方法 java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

字段详细资料

members

protected final java.util.List<Address> members

view

protected volatile View view

site_masters

protected final java.util.List<Address> site_masters

looping

protected volatile boolean looping

event_loop_thread

protected java.lang.Thread event_loop_thread

sync

protected boolean sync

oob

protected boolean oob

num_threads

protected int num_threads

num_msgs

protected int num_msgs

msg_size

protected int msg_size

anycast_count

protected int anycast_count

use_anycast_addrs

protected boolean use_anycast_addrs

msg_bundling

protected boolean msg_bundling

read_percentage

protected double read_percentage

get_before_put

protected boolean get_before_put

构造器详细资料

UPerf

public UPerf()

方法详细资料

init

public void init(java.lang.String props,
        java.lang.String name,
        boolean xsite,
        AddressGenerator generator,
        int bind_port)
          throws java.lang.Throwable

抛出:

java.lang.Throwable

startEventThread

protected void startEventThread()

stopEventThread

protected void stopEventThread()

viewAccepted

public void viewAccepted(View new_view)

从类复制的说明: ReceiverAdapter

Called when a change in membership has occurred. No long running actions, sending of messages or anything that could block should be done in this callback. If some long running action needs to be performed, it should be done in a separate thread.

Note that on reception of the first view (a new member just joined), the channel will not yet be in the connected state. This only happens when Channel.connect(String) returns.

指定者:

viewAccepted 在接口中 MembershipListener

覆盖:

viewAccepted 在类中 ReceiverAdapter

addSiteMastersToMembers

protected void addSiteMastersToMembers()

startTest

public UPerf.Results startTest()
                        throws java.lang.Throwable

抛出:

java.lang.Throwable

quitAll

public void quitAll()

set

public void set(java.lang.String field_name,
       java.lang.Object value)

get

public byte[] get(long key)

put

public void put(long key,
       byte[] val)

getConfig

public UPerf.Config getConfig()

applyConfig

protected void applyConfig(UPerf.Config config)

eventLoop

public void eventLoop()
               throws java.lang.Throwable

抛出:

java.lang.Throwable

changeFieldAcrossCluster

protected void changeFieldAcrossCluster(java.lang.String field_name,
                            java.lang.Object value)
                                 throws java.lang.Exception

抛出:

java.lang.Exception

getSites

protected static java.util.List<java.lang.String> getSites(JChannel channel)

main

public static void main(java.lang.String[] args)