DecompressPacketInputStream

java.lang.Object
- org.mariadb.jdbc.internal.io.input.DecompressPacketInputStream

All Implemented Interfaces:: PacketInputStream

public class DecompressPacketInputStream
extends java.lang.Object
implements PacketInputStream

Field Summary

Fields
Modifier and Type	Field and Description
`private byte[]`	`cacheData`
`private int`	`cacheEnd`
`private int`	`cachePos`
`private int`	`compressPacketSeq`
`private byte[]`	`header`
`private java.io.InputStream`	`inputStream`
`private static Logger`	`logger`
`private static int`	`MAX_PACKET_SIZE`
`private int`	`maxQuerySizeToLog`
`private int`	`packetSeq`
`private static int`	`REUSABLE_BUFFER_LENGTH`
`private byte[]`	`reusableArray`
`private java.lang.String`	`serverThreadLog`
`private long`	`threadId`
`private LruTraceCache`	`traceCache`

Constructor Summary

Constructors
Constructor and Description

DecompressPacketInputStream(java.io.InputStream in, int maxQuerySizeToLog, long threadId)

Constructors
Constructor and Description
`DecompressPacketInputStream(java.io.InputStream in, int maxQuerySizeToLog, long threadId)`

Method Summary

All Methods Instance Methods Concrete Methods
Modifier and Type	Method and Description
`private void`	`cache(byte[] rawBytes, int length)`
`void`	`close()`
`int`	`getCompressLastPacketSeq()`
`java.io.InputStream`	`getInputStream()`
`int`	`getLastPacketSeq()`
`private byte[]`	`getNextCachePacket()`
`Buffer`	`getPacket(boolean reUsable)`
`byte[]`	`getPacketArray(boolean reUsable)` Get next packet.
`private void`	`readBlocking(byte[] arr, int length)`
`private void`	`readCompressBlocking(byte[] arr, int compressedLength, int decompressedLength)`
`void`	`setServerThreadId(long serverThreadId, java.lang.Boolean isMaster)` Set server thread id.
`void`	`setTraceCache(LruTraceCache traceCache)`

Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Detail

REUSABLE_BUFFER_LENGTH
```
private static final int REUSABLE_BUFFER_LENGTH
```
See Also:

Constant Field Values

MAX_PACKET_SIZE
```
private static final int MAX_PACKET_SIZE
```
See Also:

Constant Field Values

logger
```
private static final Logger logger
```

header
```
private final byte[] header
```

reusableArray
```
private final byte[] reusableArray
```

inputStream

private final java.io.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 java.lang.String serverThreadLog

traceCache
```
private LruTraceCache traceCache
```

threadId
```
private long threadId
```

Constructor Detail

DecompressPacketInputStream

public DecompressPacketInputStream(java.io.InputStream in,
                                   int maxQuerySizeToLog,
                                   long threadId)

Method Detail
- getPacket
```
public Buffer getPacket(boolean reUsable)
                 throws java.io.IOException
```
  Specified by:
  
  getPacket in interface PacketInputStream
  
  Throws:
  
  java.io.IOException
- getPacketArray
```
public byte[] getPacketArray(boolean reUsable)
                      throws java.io.IOException
```
  Get next packet. Packet can be compressed, and if so, can contain many standard packet.
  
  Specified by:
  
  getPacketArray in interface PacketInputStream
  
  Parameters:
  
  reUsable - if can use existing reusable buffer to avoid creating array
  
  Returns:
  
  array packet.
  
  Throws:
  
  java.io.IOException - if socket exception occur.
- readCompressBlocking
```
private void readCompressBlocking(byte[] arr,
                                  int compressedLength,
                                  int decompressedLength)
                           throws java.io.IOException
```
  Throws:
  
  java.io.IOException
- readBlocking
```
private void readBlocking(byte[] arr,
                          int length)
                   throws java.io.IOException
```
  Throws:
  
  java.io.IOException
- cache
```
private void cache(byte[] rawBytes,
                   int length)
```
- getNextCachePacket
```
private byte[] getNextCachePacket()
```
- getLastPacketSeq
```
public int getLastPacketSeq()
```
  Specified by:
  
  getLastPacketSeq in interface PacketInputStream
- getCompressLastPacketSeq
```
public int getCompressLastPacketSeq()
```
  Specified by:
  
  getCompressLastPacketSeq in interface PacketInputStream
- close
```
public void close()
           throws java.io.IOException
```
  Specified by:
  
  close in interface PacketInputStream
  
  Throws:
  
  java.io.IOException
- setServerThreadId
```
public void setServerThreadId(long serverThreadId,
                              java.lang.Boolean isMaster)
```
  Set server thread id.
  
  Specified by:
  
  setServerThreadId in interface PacketInputStream
  
  Parameters:
  
  serverThreadId - current server thread id.
  
  isMaster - is server master
- setTraceCache
```
public void setTraceCache(LruTraceCache traceCache)
```
  Specified by:
  
  setTraceCache in interface PacketInputStream
- getInputStream
```
public java.io.InputStream getInputStream()
```
  Specified by:
  
  getInputStream in interface PacketInputStream

Class DecompressPacketInputStream

Field Summary

Constructor Summary

Method Summary

Methods inherited from class java.lang.Object

Field Detail

REUSABLE_BUFFER_LENGTH

MAX_PACKET_SIZE

logger

header

reusableArray

inputStream

maxQuerySizeToLog

cacheData

cachePos

cacheEnd

packetSeq

compressPacketSeq

serverThreadLog

traceCache

threadId

Constructor Detail

DecompressPacketInputStream

Method Detail

getPacket

getPacketArray

readCompressBlocking

readBlocking

cache

getNextCachePacket

getLastPacketSeq

getCompressLastPacketSeq

close

setServerThreadId

setTraceCache

getInputStream