Package org.jgroups.tests

Class UnicastTestTcpRpc

java.lang.Object

org.jgroups.tests.UnicastTestTcpRpc

public class UnicastTestTcpRpc
extends Object

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

Field Summary

Fields

Modifier and Type	Field	Description
private Thread	acceptor
(package private) static final byte	ACK
private InetAddress	addr
private final byte[]	buf
private boolean	busy_sleep
private 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 final byte	RECEIVE_ASYNC
(package private) static final byte	RECEIVE_SYNC
private long	sleep_time
private Socket	sock
private DataInputStream	sock_in
private DataOutputStream	sock_out
private ServerSocket	srv_sock
private long	start
(package private) static final byte	START
private boolean	started
private long	stop
private boolean	sync
private 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(DataInputStream in, DataOutputStream out)
(package private) static void	help()
void	init(long sleep_time, boolean exit_on_end, boolean busy_sleep, boolean sync, boolean oob, String addr, int local_port, int dest_port)
(package private) void	invokeRpcs()
static void	main(String[] args)
void	receiveData(long value, byte[] buffer)
(package private) static void	set(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 Details

srv_sock

private ServerSocket srv_sock

sock

private volatile Socket sock

sock_in

private DataInputStream sock_in

sock_out

private 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 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 AtomicInteger current_value

num_values

private int num_values

print

private int print

total_bytes

private AtomicLong total_bytes

acceptor

private 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 Details

UnicastTestTcpRpc

public UnicastTestTcpRpc()

Method Details

init

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

Throws:

Exception

createSocket

void createSocket()
           throws IOException

Throws:

IOException

handleRequest

boolean handleRequest(DataInputStream in,
 DataOutputStream out)
               throws IOException

Throws:

IOException

set

static void set(Socket socket)
         throws SocketException

Throws:

SocketException

stop

void stop()

startTest

public void startTest(int num_values)

receiveData

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

eventLoop

public void eventLoop()
               throws Throwable

Throws:

Throwable

invokeRpcs

void invokeRpcs()
         throws Throwable

Throws:

Throwable

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