Package org.jgroups.tests

Class UnicastTest

java.lang.Object

org.jgroups.tests.UnicastTest

public class UnicastTest
extends Object

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

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
protected class	UnicastTest.MyReceiver
protected class	UnicastTest.Sender

Field Summary

Fields

Modifier and Type	Field	Description
protected JChannel	channel
protected static final byte	DATA
protected boolean	dont_bundle
protected int	msg_size
protected int	num_msgs
protected int	num_threads
protected boolean	oob
protected final UnicastTest.MyReceiver	receiver
protected long	sleep_time
protected static final byte	START

Constructor Summary

Constructors

Constructor	Description
UnicastTest()

Method Summary

Modifier and Type	Method	Description
protected void	connect()
protected void	disconnect()
void	eventLoop()
protected Address	getReceiver()
(package private) static void	help()
void	init(String props, long sleep_time, String name)
static void	main(String[] args)
protected void	printConnections()
(package private) void	printView()
protected void	removeAllConnections()
(package private) void	sendMessages()
(package private) void	setMessageSize()
(package private) void	setNumMessages()
(package private) void	setSenderThreads()

Methods inherited from class java.lang.Object

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

Field Details

channel

protected JChannel channel

receiver

protected final UnicastTest.MyReceiver receiver

sleep_time

protected long sleep_time

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

See Also:

• Constant Field Values

DATA

protected static final byte DATA

See Also:

• Constant Field Values

Constructor Details

UnicastTest

public UnicastTest()

Method Details

init

public void init(String props,
 long sleep_time,
 String name)
          throws Exception

Throws:

Exception

connect

protected void connect()
                throws Exception

Throws:

Exception

disconnect

protected void disconnect()

eventLoop

public void eventLoop()
               throws Exception

Throws:

Exception

printConnections

protected void printConnections()

removeAllConnections

protected void removeAllConnections()

sendMessages

void sendMessages()
           throws Exception

Throws:

Exception

setSenderThreads

void setSenderThreads()
               throws Exception

Throws:

Exception

setNumMessages

void setNumMessages()
             throws Exception

Throws:

Exception

setMessageSize

void setMessageSize()
             throws Exception

Throws:

Exception

printView

void printView()

getReceiver

protected Address getReceiver()

main

public static void main(String[] args)

help

static void help()