Class DecompressPacketInputStream

java.lang.Object
org.mariadb.jdbc.internal.io.input.DecompressPacketInputStream
All Implemented Interfaces:
PacketInputStream

public class DecompressPacketInputStream extends Object implements PacketInputStream
  • Field Details

    • REUSABLE_BUFFER_LENGTH

      private static final int REUSABLE_BUFFER_LENGTH
      See Also:
    • MAX_PACKET_SIZE

      private static final int MAX_PACKET_SIZE
      See Also:
    • logger

      private static final Logger logger
    • reusableArray

      private final byte[] reusableArray
    • inputStream

      private final InputStream inputStream
    • maxQuerySizeToLog

      private final int maxQuerySizeToLog
    • cacheData

      private byte[] cacheData
    • cachePos

      private int cachePos
    • cacheEnd

      private int cacheEnd
    • packetSeq

      private int packetSeq
    • compressPacketSeq

      private int compressPacketSeq
    • serverThreadLog

      private String serverThreadLog
    • traceCache

      private LruTraceCache traceCache
    • threadId

      private long threadId
  • Constructor Details

    • DecompressPacketInputStream

      public DecompressPacketInputStream(InputStream in, int maxQuerySizeToLog, long threadId)
  • Method Details