Package zmq.io.coder

Class EncoderBase

java.lang.Object

zmq.io.coder.EncoderBase

All Implemented Interfaces:

IEncoder

Direct Known Subclasses:

Encoder

public abstract class EncoderBase
extends Object
implements IEncoder

Field Summary

Fields

Modifier and Type	Field	Description
private final ByteBuffer	buffer
private final int	bufferSize
private final Errno	errno
private boolean	error
protected Msg	inProgress
private boolean	newMsgFlag
private Runnable	next
private int	toWrite
private ByteBuffer	writeBuf

Constructor Summary

Constructors

Modifier	Constructor	Description
protected	EncoderBase(Errno errno, int bufferSize)

Method Summary

Modifier and Type	Method	Description
void	destroy()
final int	encode(ValueReference<ByteBuffer> data, int size)
void	encoded()
protected void	encodingError()
int	errno()
void	errno(int err)
protected void	initStep(Runnable next, boolean newMsgFlag)
final boolean	isError()
final void	loadMsg(Msg msg)
protected void	next()
private void	nextStep(byte[] buf, int toWrite, Runnable next, boolean newMsgFlag)
protected void	nextStep(ByteBuffer buf, int toWrite, Runnable next, boolean newMsgFlag)
private void	nextStep(ByteBuffer buf, Runnable next, boolean newMsgFlag)
protected void	nextStep(Msg msg, Runnable state, boolean beginning)

Methods inherited from class java.lang.Object

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

Field Details

writeBuf

private ByteBuffer writeBuf

next

private Runnable next

newMsgFlag

private boolean newMsgFlag

toWrite

private int toWrite

buffer

private final ByteBuffer buffer

bufferSize

private final int bufferSize

error

private boolean error

inProgress

protected Msg inProgress

errno

private final Errno errno

Constructor Details

EncoderBase

protected EncoderBase(Errno errno,
 int bufferSize)

Method Details

loadMsg

public final void loadMsg(Msg msg)

Specified by:

loadMsg in interface IEncoder

encode

public final int encode(ValueReference<ByteBuffer> data,
 int size)

Specified by:

encode in interface IEncoder

encoded

public void encoded()

Specified by:

encoded in interface IEncoder

encodingError

protected void encodingError()

isError

public final boolean isError()

next

protected void next()

nextStep

protected void nextStep(Msg msg,
 Runnable state,
 boolean beginning)

nextStep

private void nextStep(byte[] buf,
 int toWrite,
 Runnable next,
 boolean newMsgFlag)

initStep

protected void initStep(Runnable next,
 boolean newMsgFlag)

nextStep

private void nextStep(ByteBuffer buf,
 Runnable next,
 boolean newMsgFlag)

nextStep

protected void nextStep(ByteBuffer buf,
 int toWrite,
 Runnable next,
 boolean newMsgFlag)

errno

public int errno()

errno

public void errno(int err)

destroy

public void destroy()

Specified by:

destroy in interface IEncoder