com.fr.third.jgroups.tests

类 UnicastTestTcp

java.lang.Object

com.fr.third.jgroups.tests.UnicastTestTcp

public class UnicastTestTcp
extends java.lang.Object

Same as UnicastTest, but uses pure TCP instead of JGroups

作者:

Bela Ban

嵌套类概要

嵌套类

限定符和类型	类和说明
protected class	UnicastTestTcp.Acceptor

字段概要

字段

限定符和类型	字段和说明
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

构造器概要

构造器

构造器和说明
UnicastTestTcp()

方法概要

方法

限定符和类型	方法和说明
void	eventLoop()
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)
protected static void	writeMessage(Message msg, java.io.DataOutputStream out)

从类继承的方法 java.lang.Object

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

字段详细资料

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

另请参阅:

常量字段值

SOCK_SEND_BUF_SIZE

protected static final int SOCK_SEND_BUF_SIZE

另请参阅:

常量字段值

SOCK_RECV_BUF_SIZE

protected static final int SOCK_RECV_BUF_SIZE

另请参阅:

常量字段值

START

protected static final byte START

另请参阅:

常量字段值

DATA

protected static final byte DATA

另请参阅:

常量字段值

构造器详细资料

UnicastTestTcp

public UnicastTestTcp()

方法详细资料

init

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

抛出:

java.lang.Exception

eventLoop

public void eventLoop()
               throws java.lang.Exception

抛出:

java.lang.Exception

main

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

receive

public void receive(Message msg)

writeMessage

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

抛出:

java.lang.Exception

readMessage

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

抛出:

java.lang.Exception