Package zmq.io.coder
Class EncoderBase
- java.lang.Object
-
- zmq.io.coder.EncoderBase
-
-
Field Summary
Fields Modifier and Type Field Description private java.nio.ByteBuffer
buffer
private int
bufferSize
private Errno
errno
private boolean
error
protected Msg
inProgress
private boolean
newMsgFlag
private java.lang.Runnable
next
private int
toWrite
private java.nio.ByteBuffer
writeBuf
-
Constructor Summary
Constructors Modifier Constructor Description protected
EncoderBase(Errno errno, int bufferSize)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description void
destroy()
int
encode(ValueReference<java.nio.ByteBuffer> data, int size)
void
encoded()
protected void
encodingError()
int
errno()
void
errno(int err)
protected void
initStep(java.lang.Runnable next, boolean newMsgFlag)
boolean
isError()
void
loadMsg(Msg msg)
protected void
next()
private void
nextStep(byte[] buf, int toWrite, java.lang.Runnable next, boolean newMsgFlag)
protected void
nextStep(java.nio.ByteBuffer buf, int toWrite, java.lang.Runnable next, boolean newMsgFlag)
private void
nextStep(java.nio.ByteBuffer buf, java.lang.Runnable next, boolean newMsgFlag)
protected void
nextStep(Msg msg, java.lang.Runnable state, boolean beginning)
-
-
-
Field Detail
-
writeBuf
private java.nio.ByteBuffer writeBuf
-
next
private java.lang.Runnable next
-
newMsgFlag
private boolean newMsgFlag
-
toWrite
private int toWrite
-
buffer
private final java.nio.ByteBuffer buffer
-
bufferSize
private final int bufferSize
-
error
private boolean error
-
inProgress
protected Msg inProgress
-
errno
private final Errno errno
-
-
Constructor Detail
-
EncoderBase
protected EncoderBase(Errno errno, int bufferSize)
-
-
Method Detail
-
encode
public final int encode(ValueReference<java.nio.ByteBuffer> data, int size)
-
encodingError
protected void encodingError()
-
isError
public final boolean isError()
-
next
protected void next()
-
nextStep
protected void nextStep(Msg msg, java.lang.Runnable state, boolean beginning)
-
nextStep
private void nextStep(byte[] buf, int toWrite, java.lang.Runnable next, boolean newMsgFlag)
-
initStep
protected void initStep(java.lang.Runnable next, boolean newMsgFlag)
-
nextStep
private void nextStep(java.nio.ByteBuffer buf, java.lang.Runnable next, boolean newMsgFlag)
-
nextStep
protected void nextStep(java.nio.ByteBuffer buf, int toWrite, java.lang.Runnable next, boolean newMsgFlag)
-
errno
public int errno()
-
errno
public void errno(int err)
-
-