com.fr.third.jgroups.tests

类 UnicastTestTcpSlow

java.lang.Object

com.fr.third.jgroups.tests.UnicastTestTcpSlow

public class UnicastTestTcpSlow
extends java.lang.Object

Same as UnicastTest, but uses pure TCP instead of JGroups

作者:

Bela Ban

嵌套类概要

嵌套类

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

字段概要

字段

限定符和类型	字段和说明
protected UnicastTestTcpSlow.Acceptor	acceptor
protected java.util.concurrent.atomic.AtomicLong	current_value
protected static byte	DATA
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

构造器概要

构造器

构造器和说明
UnicastTestTcpSlow()

方法概要

方法

限定符和类型	方法和说明
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(byte[] buf, int offset, int length)
void	receive(Message msg)

从类继承的方法 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

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

另请参阅:

常量字段值

构造器详细资料

UnicastTestTcpSlow

public UnicastTestTcpSlow()

方法详细资料

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)

readMessage

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

抛出:

java.lang.Exception