Interface PacketOutputStream
-
- All Known Implementing Classes:
AbstractPacketOutputStream,CompressPacketOutputStream,StandardPacketOutputStream
public interface PacketOutputStream
-
-
Method Summary
All Methods Instance Methods Abstract Methods Modifier and Type Method Description booleanbufferIsDataAfterMark()voidcheckMaxAllowedLength(int length)booleancheckRemainingSize(int len)voidclose()booleanexceedMaxLength()voidflush()voidflushBufferStopAtMark()intgetMaxAllowedPacket()java.io.OutputStreamgetOutputStream()intinitialPacketPos()booleanisMarked()voidmark()voidpermitTrace(boolean permitTrace)byte[]resetMark()voidsetMaxAllowedPacket(int maxAllowedPacket)voidsetServerThreadId(long serverThreadId, java.lang.Boolean isMaster)voidsetTraceCache(LruTraceCache traceCache)voidstartPacket(int seqNo)voidwrite(byte[] arr)voidwrite(byte[] arr, int off, int len)voidwrite(int arr)voidwrite(java.io.InputStream is, boolean escape, boolean noBackslashEscapes)voidwrite(java.io.InputStream is, long length, boolean escape, boolean noBackslashEscapes)voidwrite(java.io.Reader reader, boolean escape, boolean noBackslashEscapes)voidwrite(java.io.Reader reader, long length, boolean escape, boolean noBackslashEscapes)voidwrite(java.lang.String str)voidwrite(java.lang.String str, boolean escape, boolean noBackslashEscapes)voidwriteBytes(byte value, int len)voidwriteBytesEscaped(byte[] bytes, int len, boolean noBackslashEscapes)voidwriteEmptyPacket()voidwriteEmptyPacket(int seqNo)voidwriteFieldLength(long length)voidwriteInt(int value)voidwriteLong(long value)voidwriteShort(short value)
-
-
-
Method Detail
-
startPacket
void startPacket(int seqNo)
-
writeEmptyPacket
void writeEmptyPacket(int seqNo) throws java.io.IOException- Throws:
java.io.IOException
-
writeEmptyPacket
void writeEmptyPacket() throws java.io.IOException- Throws:
java.io.IOException
-
write
void write(int arr) throws java.io.IOException- Throws:
java.io.IOException
-
write
void write(byte[] arr) throws java.io.IOException- Throws:
java.io.IOException
-
write
void write(byte[] arr, int off, int len) throws java.io.IOException- Throws:
java.io.IOException
-
write
void write(java.lang.String str) throws java.io.IOException- Throws:
java.io.IOException
-
write
void write(java.lang.String str, boolean escape, boolean noBackslashEscapes) throws java.io.IOException- Throws:
java.io.IOException
-
write
void write(java.io.InputStream is, boolean escape, boolean noBackslashEscapes) throws java.io.IOException- Throws:
java.io.IOException
-
write
void write(java.io.InputStream is, long length, boolean escape, boolean noBackslashEscapes) throws java.io.IOException- Throws:
java.io.IOException
-
write
void write(java.io.Reader reader, boolean escape, boolean noBackslashEscapes) throws java.io.IOException- Throws:
java.io.IOException
-
write
void write(java.io.Reader reader, long length, boolean escape, boolean noBackslashEscapes) throws java.io.IOException- Throws:
java.io.IOException
-
writeBytesEscaped
void writeBytesEscaped(byte[] bytes, int len, boolean noBackslashEscapes) throws java.io.IOException- Throws:
java.io.IOException
-
flush
void flush() throws java.io.IOException- Throws:
java.io.IOException
-
close
void close() throws java.io.IOException- Throws:
java.io.IOException
-
checkRemainingSize
boolean checkRemainingSize(int len)
-
exceedMaxLength
boolean exceedMaxLength()
-
getOutputStream
java.io.OutputStream getOutputStream()
-
writeShort
void writeShort(short value) throws java.io.IOException- Throws:
java.io.IOException
-
writeInt
void writeInt(int value) throws java.io.IOException- Throws:
java.io.IOException
-
writeLong
void writeLong(long value) throws java.io.IOException- Throws:
java.io.IOException
-
writeBytes
void writeBytes(byte value, int len) throws java.io.IOException- Throws:
java.io.IOException
-
writeFieldLength
void writeFieldLength(long length) throws java.io.IOException- Throws:
java.io.IOException
-
getMaxAllowedPacket
int getMaxAllowedPacket()
-
setMaxAllowedPacket
void setMaxAllowedPacket(int maxAllowedPacket)
-
permitTrace
void permitTrace(boolean permitTrace)
-
setServerThreadId
void setServerThreadId(long serverThreadId, java.lang.Boolean isMaster)
-
setTraceCache
void setTraceCache(LruTraceCache traceCache)
-
mark
void mark() throws MaxAllowedPacketException
- Throws:
MaxAllowedPacketException
-
isMarked
boolean isMarked()
-
flushBufferStopAtMark
void flushBufferStopAtMark() throws java.io.IOException- Throws:
java.io.IOException
-
bufferIsDataAfterMark
boolean bufferIsDataAfterMark()
-
resetMark
byte[] resetMark()
-
initialPacketPos
int initialPacketPos()
-
checkMaxAllowedLength
void checkMaxAllowedLength(int length) throws MaxAllowedPacketException- Throws:
MaxAllowedPacketException
-
-