Package org.jgroups.tests

Class UnicastTestTcpSlow

java.lang.Object

org.jgroups.tests.UnicastTestTcpSlow

public class UnicastTestTcpSlow
extends Object

Same as UnicastTest, but uses pure TCP instead of JGroups

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
protected class	UnicastTestTcpSlow.Acceptor
private class	UnicastTestTcpSlow.Sender

Field Summary

Fields

Modifier and Type	Field	Description
protected UnicastTestTcpSlow.Acceptor	acceptor
protected AtomicLong	current_value
protected static final byte	DATA
protected boolean	dont_bundle
protected InetSocketAddress	local
protected int	msg_size
protected long	msgs_per_sec
protected int	num_msgs
protected int	num_threads
protected boolean	oob
protected DataOutputStream	output
protected final Lock	output_lock
protected long	print
protected InetSocketAddress	remote
protected Socket	sock
protected static final int	SOCK_RECV_BUF_SIZE
protected static final int	SOCK_SEND_BUF_SIZE
protected ServerSocket	srv_sock
protected long	start
protected static final byte	START
protected long	stop
protected static final boolean	TCP_NODELAY
protected AtomicLong	total_bytes
protected long	total_time

Constructor Summary

Constructors

Constructor	Description
UnicastTestTcpSlow()

Method Summary

Modifier and Type	Method	Description
void	eventLoop()
(package private) static void	help()
void	init(String local_addr, String remote_addr, int local_port, int remote_port)
static void	main(String[] args)
protected static Message	readMessage(byte[] buf, int offset, int length)
void	receive(Message msg)
(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

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

local

protected InetSocketAddress local

remote

protected InetSocketAddress remote

sock

protected Socket sock

output

protected DataOutputStream output

output_lock

protected final Lock output_lock

srv_sock

protected ServerSocket srv_sock

acceptor

protected UnicastTestTcpSlow.Acceptor acceptor

start

protected long start

stop

protected long stop

total_time

protected long total_time

msgs_per_sec

protected long msgs_per_sec

print

protected long print

current_value

protected AtomicLong current_value

total_bytes

protected AtomicLong total_bytes

TCP_NODELAY

protected static final boolean TCP_NODELAY

See Also:

• Constant Field Values

SOCK_SEND_BUF_SIZE

protected static final int SOCK_SEND_BUF_SIZE

See Also:

• Constant Field Values

SOCK_RECV_BUF_SIZE

protected static final int SOCK_RECV_BUF_SIZE

See Also:

• Constant Field Values

START

protected static final byte START

See Also:

• Constant Field Values

DATA

protected static final byte DATA

See Also:

• Constant Field Values

Constructor Details

UnicastTestTcpSlow

public UnicastTestTcpSlow()

Method Details

init

public void init(String local_addr,
 String remote_addr,
 int local_port,
 int remote_port)
          throws Exception

Throws:

Exception

eventLoop

public void eventLoop()
               throws Exception

Throws:

Exception

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

main

public static void main(String[] args)

help

static void help()

receive

public void receive(Message msg)

readMessage

protected static Message readMessage(byte[] buf,
 int offset,
 int length)
                              throws Exception

Throws:

Exception