org.jgroups.tests

Class NioClientTest

java.lang.Object

org.jgroups.tests.NioClientTest

public class NioClientTest
extends Object

NIO based client for measuring heap-based vs direct byte buffers. Use NioServerPerfTest as server

Since:

3.6.4

Author:

Bela Ban

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
protected class	NioClientTest.Sender

Field Summary

Fields

Modifier and Type	Field and Description
protected boolean	running
protected NioClientTest.Sender[]	senders
protected AtomicLong	total_bytes_sent
protected AtomicLong	total_msgs

Constructor Summary

Constructors

Constructor and Description
NioClientTest()

Method Summary

Modifier and Type	Method and Description
protected static ByteBuffer	create(int size, boolean direct)
static void	main(String[] args)
protected void	sendMessages(InetAddress host, boolean direct, int num_threads)
protected void	start(InetAddress host, boolean direct, int num_threads)

Methods inherited from class java.lang.Object

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

Field Detail

running

protected volatile boolean running

total_bytes_sent

protected final AtomicLong total_bytes_sent

total_msgs

protected final AtomicLong total_msgs

senders

protected NioClientTest.Sender[] senders

Constructor Detail

NioClientTest

public NioClientTest()

Method Detail

create

protected static ByteBuffer create(int size,
                                   boolean direct)

start

protected void start(InetAddress host,
                     boolean direct,
                     int num_threads)
              throws Exception

Throws:

Exception

sendMessages

protected void sendMessages(InetAddress host,
                            boolean direct,
                            int num_threads)
                     throws Exception

Throws:

Exception

main

public static void main(String[] args)
                 throws Exception

Throws:

Exception