Package org.jgroups.tests

Class UnicastTestTcpRpc

java.lang.Object

org.jgroups.tests.UnicastTestTcpRpc

public class UnicastTestTcpRpc
extends java.lang.Object

Tests the UNICAST by invoking unicast RPCs between a sender and a receiver

Field Summary

Fields

Modifier and Type	Field	Description
private java.lang.Thread	acceptor
(package private) static byte	ACK
private java.net.InetAddress	addr
private byte[]	buf
private boolean	busy_sleep
private java.util.concurrent.atomic.AtomicInteger	current_value
private int	dest_port
(package private) long	entire_req_time
private boolean	exit_on_end
private int	local_port
private int	msg_size
(package private) long	num_entire_reqs
private int	num_msgs
(package private) int	num_reqs
(package private) int	num_rsps
private int	num_threads
private int	num_values
private boolean	oob
private int	print
(package private) static byte	RECEIVE_ASYNC
(package private) static byte	RECEIVE_SYNC
private long	sleep_time
private java.net.Socket	sock
private java.io.DataInputStream	sock_in
private java.io.DataOutputStream	sock_out
private java.net.ServerSocket	srv_sock
private long	start
(package private) static byte	START
private boolean	started
private long	stop
private boolean	sync
private java.util.concurrent.atomic.AtomicLong	total_bytes
(package private) long	total_req_time
(package private) long	total_rsp_time

Constructor Summary

Constructors

Constructor	Description
UnicastTestTcpRpc()

Method Summary

Modifier and Type	Method	Description
(package private) void	createSocket()
void	eventLoop()
(package private) boolean	handleRequest(java.io.DataInputStream in, java.io.DataOutputStream out)
(package private) static void	help()
void	init(long sleep_time, boolean exit_on_end, boolean busy_sleep, boolean sync, boolean oob, java.lang.String addr, int local_port, int dest_port)
(package private) void	invokeRpcs()
static void	main(java.lang.String[] args)
void	receiveData(long value, byte[] buffer)
(package private) static void	set(java.net.Socket socket)
(package private) void	setMessageSize()
(package private) void	setNumMessages()
(package private) void	setSenderThreads()
void	startTest(int num_values)
(package private) void	stop()

Methods inherited from class java.lang.Object

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

Field Detail

srv_sock

private java.net.ServerSocket srv_sock

sock

private volatile java.net.Socket sock

sock_in

private java.io.DataInputStream sock_in

sock_out

private java.io.DataOutputStream sock_out

sleep_time

private long sleep_time

exit_on_end

private boolean exit_on_end

busy_sleep

private boolean busy_sleep

sync

private boolean sync

oob

private boolean oob

num_threads

private int num_threads

num_msgs

private int num_msgs

msg_size

private int msg_size

addr

private java.net.InetAddress addr

local_port

private int local_port

dest_port

private int dest_port

started

private boolean started

start

private long start

stop

private long stop

current_value

private java.util.concurrent.atomic.AtomicInteger current_value

num_values

private int num_values

print

private int print

total_bytes

private java.util.concurrent.atomic.AtomicLong total_bytes

acceptor

private java.lang.Thread acceptor

buf

private final byte[] buf

total_req_time

long total_req_time

total_rsp_time

long total_rsp_time

entire_req_time

long entire_req_time

num_entire_reqs

long num_entire_reqs

num_reqs

int num_reqs

num_rsps

int num_rsps

START

static final byte START

See Also:

Constant Field Values

RECEIVE_ASYNC

static final byte RECEIVE_ASYNC

See Also:

Constant Field Values

RECEIVE_SYNC

static final byte RECEIVE_SYNC

See Also:

Constant Field Values

ACK

static final byte ACK

See Also:

Constant Field Values

Constructor Detail

UnicastTestTcpRpc

public UnicastTestTcpRpc()

Method Detail

init

public void init(long sleep_time,
                 boolean exit_on_end,
                 boolean busy_sleep,
                 boolean sync,
                 boolean oob,
                 java.lang.String addr,
                 int local_port,
                 int dest_port)
          throws java.lang.Exception

Throws:

java.lang.Exception

createSocket

void createSocket()
           throws java.io.IOException

Throws:

java.io.IOException

handleRequest

boolean handleRequest(java.io.DataInputStream in,
                      java.io.DataOutputStream out)
               throws java.io.IOException

Throws:

java.io.IOException

set

static void set(java.net.Socket socket)
         throws java.net.SocketException

Throws:

java.net.SocketException

stop

void stop()

startTest

public void startTest(int num_values)

receiveData

public void receiveData(long value,
                        byte[] buffer)

eventLoop

public void eventLoop()
               throws java.lang.Throwable

Throws:

java.lang.Throwable

invokeRpcs

void invokeRpcs()
         throws java.lang.Throwable

Throws:

java.lang.Throwable

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()