com.fr.third.jgroups.tests

类 UnicastTest

java.lang.Object

com.fr.third.jgroups.tests.UnicastTest

public class UnicastTest
extends java.lang.Object

Perf tests the UNICAST protocol by sending unicast messages between a sender and a receiver

作者:

Bela Ban

嵌套类概要

嵌套类

限定符和类型	类和说明
protected class	UnicastTest.MyReceiver
protected class	UnicastTest.Sender

字段概要

字段

限定符和类型	字段和说明
protected boolean	busy_sleep
protected JChannel	channel
protected static byte	DATA
protected boolean	dont_bundle
protected int	msg_size
protected int	num_msgs
protected int	num_threads
protected boolean	oob
protected UnicastTest.MyReceiver	receiver
protected long	sleep_time
protected static byte	START

构造器概要

构造器

构造器和说明
UnicastTest()

方法概要

方法

限定符和类型	方法和说明
protected void	_init(JChannel ch, long sleep_time, boolean busy_sleep, java.lang.String name)
void	eventLoop()
protected Address	getReceiver()
void	init(Protocol[] props, long sleep_time, boolean busy_sleep, java.lang.String name)
void	init(java.lang.String props, long sleep_time, boolean busy_sleep, java.lang.String name)
static void	main(java.lang.String[] args)
protected void	printConnections()
protected void	removeAllConnections()

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

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

字段详细资料

channel

protected JChannel channel

receiver

protected final UnicastTest.MyReceiver receiver

sleep_time

protected long sleep_time

busy_sleep

protected boolean busy_sleep

oob

protected boolean oob

dont_bundle

protected boolean dont_bundle

num_threads

protected int num_threads

num_msgs

protected int num_msgs

msg_size

protected int msg_size

START

protected static final byte START

另请参阅:

常量字段值

DATA

protected static final byte DATA

另请参阅:

常量字段值

构造器详细资料

UnicastTest

public UnicastTest()

方法详细资料

init

public void init(Protocol[] props,
        long sleep_time,
        boolean busy_sleep,
        java.lang.String name)
          throws java.lang.Exception

抛出:

java.lang.Exception

init

public void init(java.lang.String props,
        long sleep_time,
        boolean busy_sleep,
        java.lang.String name)
          throws java.lang.Exception

抛出:

java.lang.Exception

_init

protected void _init(JChannel ch,
         long sleep_time,
         boolean busy_sleep,
         java.lang.String name)
              throws java.lang.Exception

抛出:

java.lang.Exception

eventLoop

public void eventLoop()
               throws java.lang.Exception

抛出:

java.lang.Exception

printConnections

protected void printConnections()

removeAllConnections

protected void removeAllConnections()

getReceiver

protected Address getReceiver()

main

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