Package org.jgroups.tests

Class UnicastTestTcp

java.lang.Object

org.jgroups.tests.UnicastTestTcp

public class UnicastTestTcp
extends java.lang.Object

Same as UnicastTest, but uses pure TCP instead of JGroups

Nested Class Summary

Nested Classes

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

Field Summary

Fields

Modifier and Type	Field	Description
protected UnicastTestTcp.Acceptor	acceptor
protected java.util.concurrent.atomic.AtomicLong	current_value
protected static byte	DATA
protected PhysicalAddress	destination
protected boolean	dont_bundle
protected java.net.InetSocketAddress	local
protected int	msg_size
protected long	msgs_per_sec
protected int	num_msgs
protected int	num_threads
protected boolean	oob
protected java.io.DataOutputStream	output
protected java.util.concurrent.locks.Lock	output_lock
protected long	print
protected java.net.InetSocketAddress	remote
protected java.net.Socket	sock
protected static int	SOCK_RECV_BUF_SIZE
protected static int	SOCK_SEND_BUF_SIZE
protected java.net.ServerSocket	srv_sock
protected long	start
protected static byte	START
protected long	stop
protected static boolean	TCP_NODELAY
protected java.util.concurrent.atomic.AtomicLong	total_bytes
protected long	total_time

Constructor Summary

Constructors

Constructor	Description
UnicastTestTcp()

Method Summary

Modifier and Type	Method	Description
void	eventLoop()
(package private) static void	help()
void	init(java.lang.String local_addr, java.lang.String remote_addr, int local_port, int remote_port)
static void	main(java.lang.String[] args)
protected static Message	readMessage(java.io.DataInput in)
void	receive(Message msg)
(package private) void	sendMessages()
(package private) void	setMessageSize()
(package private) void	setNumMessages()
(package private) void	setSenderThreads()
protected static void	writeMessage(Message msg, java.io.DataOutputStream out)

Methods inherited from class java.lang.Object

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

Field Detail

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 java.net.InetSocketAddress local

remote

protected java.net.InetSocketAddress remote

destination

protected PhysicalAddress destination

sock

protected java.net.Socket sock

output

protected java.io.DataOutputStream output

output_lock

protected final java.util.concurrent.locks.Lock output_lock

srv_sock

protected java.net.ServerSocket srv_sock

acceptor

protected UnicastTestTcp.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 java.util.concurrent.atomic.AtomicLong current_value

total_bytes

protected java.util.concurrent.atomic.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 Detail

UnicastTestTcp

public UnicastTestTcp()

Method Detail

init

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

Throws:

java.lang.Exception

eventLoop

public void eventLoop()
               throws java.lang.Exception

Throws:

java.lang.Exception

sendMessages

void sendMessages()
           throws java.lang.Exception

Throws:

java.lang.Exception

setSenderThreads

void setSenderThreads()
               throws java.lang.Exception

Throws:

java.lang.Exception

setNumMessages

void setNumMessages()
             throws java.lang.Exception

Throws:

java.lang.Exception

setMessageSize

void setMessageSize()
             throws java.lang.Exception

Throws:

java.lang.Exception

main

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

help

static void help()

receive

public void receive(Message msg)

writeMessage

protected static final void writeMessage(Message msg,
                                         java.io.DataOutputStream out)
                                  throws java.lang.Exception

Throws:

java.lang.Exception

readMessage

protected static final Message readMessage(java.io.DataInput in)
                                    throws java.lang.Exception

Throws:

java.lang.Exception