zmq

Class DecoderBase

java.lang.Object

zmq.DecoderBase

All Implemented Interfaces:

IDecoder

Direct Known Subclasses:

Decoder, V1Decoder

public abstract class DecoderBase
extends java.lang.Object
implements IDecoder

Field Summary

Fields

Modifier and Type	Field and Description
private java.nio.ByteBuffer	buf
private int	bufsize
private MsgAllocator	msgAllocator
private java.nio.ByteBuffer	readBuf
private int	state
(package private) boolean	zeroCopy

Constructor Summary

Constructors

Constructor and Description
DecoderBase(int bufsize)

Method Summary

Modifier and Type	Method and Description
protected void	decodingError()
java.nio.ByteBuffer	getBuffer()
MsgAllocator	getMsgAllocator()
protected abstract boolean	next()
protected void	nextStep(byte[] buf, int toRead, int state)
protected void	nextStep(java.nio.ByteBuffer buf, int state)
protected void	nextStep(Msg msg, int state)
int	processBuffer(java.nio.ByteBuffer buf, int size)
void	setMsgAllocator(MsgAllocator msgAllocator)
boolean	stalled()
protected int	state()
protected void	state(int state)

Methods inherited from class java.lang.Object

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

Methods inherited from interface zmq.IDecoder

setMsgSink

Field Detail

readBuf

private java.nio.ByteBuffer readBuf

msgAllocator

private MsgAllocator msgAllocator

bufsize

private int bufsize

buf

private java.nio.ByteBuffer buf

state

private int state

zeroCopy

boolean zeroCopy

Constructor Detail

DecoderBase

public DecoderBase(int bufsize)

Method Detail

getBuffer

public java.nio.ByteBuffer getBuffer()

Specified by:

getBuffer in interface IDecoder

processBuffer

public int processBuffer(java.nio.ByteBuffer buf,
                         int size)

Specified by:

processBuffer in interface IDecoder

nextStep

protected void nextStep(Msg msg,
                        int state)

nextStep

protected void nextStep(byte[] buf,
                        int toRead,
                        int state)

nextStep

protected void nextStep(java.nio.ByteBuffer buf,
                        int state)

state

protected int state()

state

protected void state(int state)

decodingError

protected void decodingError()

stalled

public boolean stalled()

Specified by:

stalled in interface IDecoder

getMsgAllocator

public MsgAllocator getMsgAllocator()

setMsgAllocator

public void setMsgAllocator(MsgAllocator msgAllocator)

next

protected abstract boolean next()