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 boolean
bufferIsDataAfterMark()
void
checkMaxAllowedLength(int length)
boolean
checkRemainingSize(int len)
void
close()
boolean
exceedMaxLength()
void
flush()
void
flushBufferStopAtMark()
int
getMaxAllowedPacket()
java.io.OutputStream
getOutputStream()
int
initialPacketPos()
boolean
isMarked()
void
mark()
void
permitTrace(boolean permitTrace)
byte[]
resetMark()
void
setMaxAllowedPacket(int maxAllowedPacket)
void
setServerThreadId(long serverThreadId, java.lang.Boolean isMaster)
void
setTraceCache(LruTraceCache traceCache)
void
startPacket(int seqNo)
void
write(byte[] arr)
void
write(byte[] arr, int off, int len)
void
write(int arr)
void
write(java.io.InputStream is, boolean escape, boolean noBackslashEscapes)
void
write(java.io.InputStream is, long length, boolean escape, boolean noBackslashEscapes)
void
write(java.io.Reader reader, boolean escape, boolean noBackslashEscapes)
void
write(java.io.Reader reader, long length, boolean escape, boolean noBackslashEscapes)
void
write(java.lang.String str)
void
write(java.lang.String str, boolean escape, boolean noBackslashEscapes)
void
writeBytes(byte value, int len)
void
writeBytesEscaped(byte[] bytes, int len, boolean noBackslashEscapes)
void
writeEmptyPacket()
void
writeEmptyPacket(int seqNo)
void
writeFieldLength(long length)
void
writeInt(int value)
void
writeLong(long value)
void
writeShort(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
-
-