public class UnicastTestTcp extends Object
Modifier and Type | Class and Description |
---|---|
protected class |
UnicastTestTcp.Acceptor |
Modifier and Type | Field and Description |
---|---|
protected UnicastTestTcp.Acceptor |
acceptor |
protected AtomicLong |
current_value |
protected static byte |
DATA |
protected PhysicalAddress |
destination |
protected boolean |
dont_bundle |
protected InetSocketAddress |
local |
protected int |
msg_size |
protected long |
msgs_per_sec |
protected int |
num_msgs |
protected int |
num_threads |
protected boolean |
oob |
protected DataOutputStream |
output |
protected Lock |
output_lock |
protected long |
print |
protected InetSocketAddress |
remote |
protected Socket |
sock |
protected static int |
SOCK_RECV_BUF_SIZE |
protected static int |
SOCK_SEND_BUF_SIZE |
protected ServerSocket |
srv_sock |
protected long |
start |
protected static byte |
START |
protected long |
stop |
protected static boolean |
TCP_NODELAY |
protected AtomicLong |
total_bytes |
protected long |
total_time |
Constructor and Description |
---|
UnicastTestTcp() |
Modifier and Type | Method and Description |
---|---|
void |
eventLoop() |
void |
init(String local_addr,
String remote_addr,
int local_port,
int remote_port) |
static void |
main(String[] args) |
protected static Message |
readMessage(DataInput in) |
void |
receive(Message msg) |
protected static void |
writeMessage(Message msg,
DataOutputStream out) |
protected boolean oob
protected boolean dont_bundle
protected int num_threads
protected int num_msgs
protected int msg_size
protected InetSocketAddress local
protected InetSocketAddress remote
protected PhysicalAddress destination
protected Socket sock
protected DataOutputStream output
protected final Lock output_lock
protected ServerSocket srv_sock
protected UnicastTestTcp.Acceptor acceptor
protected long start
protected long stop
protected long total_time
protected long msgs_per_sec
protected long print
protected AtomicLong current_value
protected AtomicLong total_bytes
protected static final boolean TCP_NODELAY
protected static final int SOCK_SEND_BUF_SIZE
protected static final int SOCK_RECV_BUF_SIZE
protected static final byte START
protected static final byte DATA
public void init(String local_addr, String remote_addr, int local_port, int remote_port) throws Exception
Exception
public static void main(String[] args)
public void receive(Message msg)
protected static final void writeMessage(Message msg, DataOutputStream out) throws Exception
Exception
Copyright © 2023 JBoss, a division of Red Hat. All rights reserved.