Modifier and Type | Field and 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 |
Modifier | Constructor and Description |
---|---|
protected |
EncoderBase(Errno errno,
int bufferSize) |
Modifier and Type | Method and 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) |
private java.nio.ByteBuffer writeBuf
private java.lang.Runnable next
private boolean newMsgFlag
private int toWrite
private final java.nio.ByteBuffer buffer
private final int bufferSize
private boolean error
protected Msg inProgress
private final Errno errno
protected EncoderBase(Errno errno, int bufferSize)
public final int encode(ValueReference<java.nio.ByteBuffer> data, int size)
protected void encodingError()
public final boolean isError()
protected void next()
protected void nextStep(Msg msg, java.lang.Runnable state, boolean beginning)
private void nextStep(byte[] buf, int toWrite, java.lang.Runnable next, boolean newMsgFlag)
protected void initStep(java.lang.Runnable next, boolean newMsgFlag)
private void nextStep(java.nio.ByteBuffer buf, java.lang.Runnable next, boolean newMsgFlag)
protected void nextStep(java.nio.ByteBuffer buf, int toWrite, java.lang.Runnable next, boolean newMsgFlag)
public int errno()
public void errno(int err)