Class DecompressPacketInputStream
java.lang.Object
org.mariadb.jdbc.internal.io.input.DecompressPacketInputStream
- All Implemented Interfaces:
PacketInputStream
-
Constructor Summary
ConstructorsConstructorDescriptionDecompressPacketInputStream(InputStream in, int maxQuerySizeToLog, long threadId) -
Method Summary
Modifier and TypeMethodDescriptionvoidclose()intintgetPacket(boolean reUsable) byte[]getPacketArray(boolean reUsable) Get next packet.voidsetServerThreadId(long serverThreadId, Boolean isMaster) Set server thread id.voidsetTraceCache(LruTraceCache traceCache)
-
Constructor Details
-
DecompressPacketInputStream
-
-
Method Details
-
getPacket
- Specified by:
getPacketin interfacePacketInputStream- Throws:
IOException
-
getPacketArray
Get next packet. Packet can be compressed, and if so, can contain many standard packet.- Specified by:
getPacketArrayin interfacePacketInputStream- Parameters:
reUsable- if can use existing reusable buffer to avoid creating array- Returns:
- array packet.
- Throws:
IOException- if socket exception occur.
-
getLastPacketSeq
public int getLastPacketSeq()- Specified by:
getLastPacketSeqin interfacePacketInputStream
-
getCompressLastPacketSeq
public int getCompressLastPacketSeq()- Specified by:
getCompressLastPacketSeqin interfacePacketInputStream
-
close
- Specified by:
closein interfacePacketInputStream- Throws:
IOException
-
setServerThreadId
Set server thread id.- Specified by:
setServerThreadIdin interfacePacketInputStream- Parameters:
serverThreadId- current server thread id.isMaster- is server master
-
setTraceCache
- Specified by:
setTraceCachein interfacePacketInputStream
-
getInputStream
- Specified by:
getInputStreamin interfacePacketInputStream
-