Package org.mariadb.jdbc.internal.io.input

Class DecompressPacketInputStream

java.lang.Object

org.mariadb.jdbc.internal.io.input.DecompressPacketInputStream

All Implemented Interfaces:

PacketInputStream

public class DecompressPacketInputStream
extends Object
implements PacketInputStream

Field Summary

Fields

Modifier and Type	Field	Description
private byte[]	cacheData
private int	cacheEnd
private int	cachePos
private int	compressPacketSeq
private final byte[]	header
private final InputStream	inputStream
private static final Logger	logger
private static final int	MAX_PACKET_SIZE
private final int	maxQuerySizeToLog
private int	packetSeq
private static final int	REUSABLE_BUFFER_LENGTH
private final byte[]	reusableArray
private String	serverThreadLog
private LruTraceCache	traceCache

Constructor Summary

Constructors

Constructor	Description
DecompressPacketInputStream(InputStream in, int maxQuerySizeToLog)

Method Summary

Modifier and Type	Method	Description
private void	cache(byte[] rawBytes, int length)
void	close()
int	getCompressLastPacketSeq()
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, 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 Details

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 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

Constructor Details

DecompressPacketInputStream

public DecompressPacketInputStream(InputStream in,
 int maxQuerySizeToLog)

Method Details

getPacket

public Buffer getPacket(boolean reUsable)
                 throws IOException

Specified by:

getPacket in interface PacketInputStream

Throws:

IOException

getPacketArray

public byte[] getPacketArray(boolean reUsable)
                      throws 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:

IOException - if socket exception occur.

readCompressBlocking

private void readCompressBlocking(byte[] arr,
 int compressedLength,
 int decompressedLength)
                           throws IOException

Throws:

IOException

readBlocking

private void readBlocking(byte[] arr,
 int length)
                   throws IOException

Throws:

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 IOException

Specified by:

close in interface PacketInputStream

Throws:

IOException

setServerThreadId

public void setServerThreadId(long serverThreadId,
 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