com.goldencode.p2j.net

Class ByteArrayHandler

java.lang.Object

com.goldencode.p2j.net.ByteArrayHandler

public abstract class ByteArrayHandler
extends java.lang.Object

This class splits input data stream into chunks. Each chunk is a sequence of bytes prepended with an integer length.

Field Summary

Fields

Modifier and Type	Field and Description
private java.io.ByteArrayOutputStream	baos Large message data holder
private java.nio.ByteBuffer	bb Work buffer.
private int	len The length of the next chunk.
private int	remaining Bytes to be read in a large message
private boolean	trace Trace operations' flag

Constructor Summary

Constructors

Constructor and Description
ByteArrayHandler(int bufsize, boolean trace) Constructor

Method Summary

Modifier and Type	Method and Description
private boolean	next() Try to extract a next chunk from the input
int	nextChunk(java.nio.ByteBuffer chunk) Process the next portion of input
protected abstract void	ready(byte[] data) Process the byte portion of the next chunk

Methods inherited from class java.lang.Object

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

Field Detail

bb

private volatile java.nio.ByteBuffer bb

Work buffer.

trace

private final boolean trace

Trace operations' flag

len

private volatile int len

The length of the next chunk.

remaining

private volatile int remaining

Bytes to be read in a large message

baos

private volatile java.io.ByteArrayOutputStream baos

Large message data holder

Constructor Detail

ByteArrayHandler

public ByteArrayHandler(int bufsize,
                        boolean trace)

Constructor

Parameters:

bufsize - max incoming portion size

trace - trace operations flag

Method Detail

nextChunk

public int nextChunk(java.nio.ByteBuffer chunk)

Process the next portion of input

Parameters:

chunk - input data

Returns:

number of chunks found since previous input

ready

protected abstract void ready(byte[] data)

Process the byte portion of the next chunk

Parameters:

data - the byte portion of the next chunk

next

private boolean next()

Try to extract a next chunk from the input

Returns:

true if a new chunk was found