public class StandardPacketInputStream extends java.lang.Object implements PacketInputStream
Modifier and Type | Field and Description |
---|---|
private byte[] |
header |
private java.io.BufferedInputStream |
inputStream |
private int |
lastPacketLength |
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 LruTraceCache |
traceCache |
Constructor and Description |
---|
StandardPacketInputStream(java.io.InputStream in,
int maxQuerySizeToLog) |
Modifier and Type | Method and Description |
---|---|
void |
close() |
static byte[] |
create(byte[] value)
Constructor for single Data (using text format).
|
static byte[] |
create(byte[][] rowData,
ColumnType[] columnTypes)
Create Buffer with Text protocol values.
|
java.io.BufferedInputStream |
getBufferedInputStream()
Get current Buffered input stream for creating compress input stream,
to avoid losing already read bytes in case of pipelining.
|
int |
getCompressLastPacketSeq() |
int |
getLastPacketLength() |
int |
getLastPacketSeq() |
Buffer |
getPacket(boolean reUsable) |
byte[] |
getPacketArray(boolean reUsable)
Get next packet.
|
void |
setServerThreadId(long serverThreadId,
java.lang.Boolean isMaster)
Set server thread id.
|
void |
setTraceCache(LruTraceCache traceCache) |
private static final int REUSABLE_BUFFER_LENGTH
private static final int MAX_PACKET_SIZE
private static Logger logger
private byte[] header
private byte[] reusableArray
private java.io.BufferedInputStream inputStream
private int packetSeq
private int maxQuerySizeToLog
private int lastPacketLength
private java.lang.String serverThreadLog
private LruTraceCache traceCache
public StandardPacketInputStream(java.io.InputStream in, int maxQuerySizeToLog)
public static byte[] create(byte[] value)
value
- valuepublic static byte[] create(byte[][] rowData, ColumnType[] columnTypes)
rowData
- datascolumnTypes
- column typespublic Buffer getPacket(boolean reUsable) throws java.io.IOException
getPacket
in interface PacketInputStream
java.io.IOException
public java.io.BufferedInputStream getBufferedInputStream()
public byte[] getPacketArray(boolean reUsable) throws java.io.IOException
getPacketArray
in interface PacketInputStream
reUsable
- if can use existing reusable buffer to avoid creating arrayjava.io.IOException
- if socket exception occur.public int getLastPacketLength()
getLastPacketLength
in interface PacketInputStream
public int getLastPacketSeq()
getLastPacketSeq
in interface PacketInputStream
public int getCompressLastPacketSeq()
getCompressLastPacketSeq
in interface PacketInputStream
public void close() throws java.io.IOException
close
in interface PacketInputStream
java.io.IOException
public void setServerThreadId(long serverThreadId, java.lang.Boolean isMaster)
setServerThreadId
in interface PacketInputStream
serverThreadId
- current server thread id.isMaster
- is server masterpublic void setTraceCache(LruTraceCache traceCache)
setTraceCache
in interface PacketInputStream