Class MessageReader

java.lang.Object

org.jgroups.nio.MessageReader

public class MessageReader
extends Object

Class for reading length prefix messages from a channel. We have an internal buffer which is compacted and grown as needed. We have a separate reader index, and buffer.position() is used as the writer index; this is similar to Netty ByteBuf. The limit is not used and always same as capacity.

Since:

5.5.3

Author:

Christian Fredriksson

Field Summary

Fields

Modifier and Type	Field	Description
protected final NioConnection	conn
protected int	max_length

Constructor Summary

Constructors

Constructor	Description
MessageReader(SocketChannel channel)
MessageReader(NioConnection c, SocketChannel channel)
MessageReader(NioConnection c, SocketChannel channel, int initial_buf_size, boolean use_direct_buffers)

Method Summary

Modifier and Type	Method	Description
MessageReader	maxLength(int max_length)
ByteBuffer	readMessage()	Reads length prefixed messages from a channel.
String	toString()

Methods inherited from class Object

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

Field Details

max_length

protected int max_length

conn

protected final NioConnection conn

Constructor Details

MessageReader

public MessageReader(SocketChannel channel)

MessageReader

public MessageReader(NioConnection c,
 SocketChannel channel)

MessageReader

public MessageReader(NioConnection c,
 SocketChannel channel,
 int initial_buf_size,
 boolean use_direct_buffers)

Method Details

readMessage

public ByteBuffer readMessage()
                       throws IOException

Reads length prefixed messages from a channel.

Returns:

The buffer (position is 0 and limit is length), or null if not all data could be read.

Throws:

IOException

maxLength

public MessageReader maxLength(int max_length)

toString

public String toString()

Overrides:

toString in class Object