Class NioConnection.PeerAddressReader

java.lang.Object

org.jgroups.blocks.cs.NioConnection.PeerAddressReader

Enclosing class:

NioConnection

public static class NioConnection.PeerAddressReader
extends Object

Reads a peer address from a SocketChannel. Note that method readPeerAddress(SocketChannel) is not reentrant

Since:

3.6.5

Author:

Bela Ban

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
protected static enum	NioConnection.PeerAddressReader.State

Field Summary

Fields

Modifier and Type	Field	Description
protected final ByteBuffer	buffer
protected final byte[]	cookie_buf
protected static final int	IPV4_SIZE
protected static final int	IPv6_SIZE
protected static final int	METADATA_SIZE
protected NioConnection.PeerAddressReader.State	state

Constructor Summary

Constructors

Constructor	Description
PeerAddressReader()
PeerAddressReader(boolean use_direct_memory)

Method Summary

Modifier and Type	Method	Description
protected int	parseMetadata(SocketAddress local, SocketAddress remote)
Address	readPeerAddress(SocketChannel ch)
NioConnection.PeerAddressReader	reset()

Methods inherited from class Object

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

Field Details

METADATA_SIZE

protected static final int METADATA_SIZE

See Also:

• Constant Field Values

IPV4_SIZE

protected static final int IPV4_SIZE

See Also:

• Constant Field Values

IPv6_SIZE

protected static final int IPv6_SIZE

See Also:

• Constant Field Values

buffer

protected final ByteBuffer buffer

state

protected NioConnection.PeerAddressReader.State state

cookie_buf

protected final byte[] cookie_buf

Constructor Details

PeerAddressReader

public PeerAddressReader()

PeerAddressReader

public PeerAddressReader(boolean use_direct_memory)

Method Details

readPeerAddress

public Address readPeerAddress(SocketChannel ch)
                        throws IOException

Throws:

IOException

reset

public NioConnection.PeerAddressReader reset()

parseMetadata

protected int parseMetadata(SocketAddress local,
 SocketAddress remote)
                     throws IOException

Throws:

IOException