Package org.jgroups.tests

Class NioServerPerfTest

java.lang.Object

org.jgroups.tests.NioServerPerfTest

public class NioServerPerfTest
extends Object

NIO based server for measuring heap-based vs direct byte buffers. Use NioClientTest as client test driver

Since:

3.6.4

Field Summary

Fields

Modifier and Type	Field	Description
protected ByteBuffer	buffer
static final long	BYTES_TO_SEND
protected ServerSocketChannel	ch
protected boolean	running
protected Selector	selector
static final int	SIZE
protected final AtomicLong	start
protected final AtomicLong	total_bytes_received
protected final AtomicLong	total_msgs

Constructor Summary

Constructors

Constructor	Description
NioServerPerfTest()

Method Summary

Modifier and Type	Method	Description
protected static ByteBuffer	create(int size, boolean direct)
protected boolean	handle(SocketChannel ch, ByteBuffer buf)
static void	main(String[] args)
protected void	start(boolean direct)

Methods inherited from class java.lang.Object

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

Field Details

ch

protected ServerSocketChannel ch

selector

protected Selector selector

running

protected volatile boolean running

buffer

protected ByteBuffer buffer

total_bytes_received

protected final AtomicLong total_bytes_received

total_msgs

protected final AtomicLong total_msgs

start

protected final AtomicLong start

BYTES_TO_SEND

public static final long BYTES_TO_SEND

See Also:

• Constant Field Values

SIZE

public static final int SIZE

See Also:

• Constant Field Values

Constructor Details

NioServerPerfTest

public NioServerPerfTest()

Method Details

create

protected static ByteBuffer create(int size,
 boolean direct)

start

protected void start(boolean direct)
              throws Exception

Throws:

Exception

handle

protected boolean handle(SocketChannel ch,
 ByteBuffer buf)

main

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

Throws:

Exception