com.mysql.cj.protocol.a

Class DebugBufferingPacketSender

java.lang.Object

com.mysql.cj.protocol.a.DebugBufferingPacketSender

All Implemented Interfaces:

MessageSender<NativePacketPayload>

public class DebugBufferingPacketSender
extends java.lang.Object
implements MessageSender<NativePacketPayload>

Field Summary

Fields

Modifier and Type	Field and Description
private static int	DEBUG_MSG_LEN
private int	maxPacketDumpLength
private java.util.LinkedList<java.lang.StringBuilder>	packetDebugBuffer
private RuntimeProperty<java.lang.Integer>	packetDebugBufferSize
private MessageSender<NativePacketPayload>	packetSender

Constructor Summary

Constructors

Constructor and Description
DebugBufferingPacketSender(MessageSender<NativePacketPayload> packetSender, java.util.LinkedList<java.lang.StringBuilder> packetDebugBuffer, RuntimeProperty<java.lang.Integer> packetDebugBufferSize)

Method Summary

Modifier and Type	Method and Description
private void	pushPacketToDebugBuffer(byte[] packet, int packetLen) Add a packet to the debug buffer.
void	send(byte[] packet, int packetLen, byte packetSequence) Synchronously send the message to server.
void	setMaxPacketDumpLength(int maxPacketDumpLength)
MessageSender<NativePacketPayload>	undecorate() Return the previous PacketSender instance from the decorators chain or the current PacketSender if it is the first entry in a chain.
MessageSender<NativePacketPayload>	undecorateAll() Return a PacketSender instance free of decorators.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface com.mysql.cj.protocol.MessageSender

send, send, setMaxAllowedPacket

Field Detail

packetSender

private MessageSender<NativePacketPayload> packetSender

packetDebugBuffer

private java.util.LinkedList<java.lang.StringBuilder> packetDebugBuffer

packetDebugBufferSize

private RuntimeProperty<java.lang.Integer> packetDebugBufferSize

maxPacketDumpLength

private int maxPacketDumpLength

DEBUG_MSG_LEN

private static final int DEBUG_MSG_LEN

See Also:

Constant Field Values

Constructor Detail

DebugBufferingPacketSender

public DebugBufferingPacketSender(MessageSender<NativePacketPayload> packetSender,
                                  java.util.LinkedList<java.lang.StringBuilder> packetDebugBuffer,
                                  RuntimeProperty<java.lang.Integer> packetDebugBufferSize)

Method Detail

setMaxPacketDumpLength

public void setMaxPacketDumpLength(int maxPacketDumpLength)

pushPacketToDebugBuffer

private void pushPacketToDebugBuffer(byte[] packet,
                                     int packetLen)

Add a packet to the debug buffer.

Parameters:

packet - packet as bytes

packetLen - packet length

send

public void send(byte[] packet,
                 int packetLen,
                 byte packetSequence)
          throws java.io.IOException

Description copied from interface: MessageSender

Synchronously send the message to server.

Specified by:

send in interface MessageSender<NativePacketPayload>

Parameters:

packet - byte array containing a message

packetLen - length of the message

packetSequence - message sequence index (used in a native protocol)

Throws:

java.io.IOException - if an error occurs

undecorateAll

public MessageSender<NativePacketPayload> undecorateAll()

Description copied from interface: MessageSender

Return a PacketSender instance free of decorators.

Specified by:

undecorateAll in interface MessageSender<NativePacketPayload>

Returns:

MessageSender instance

undecorate

public MessageSender<NativePacketPayload> undecorate()

Description copied from interface: MessageSender

Return the previous PacketSender instance from the decorators chain or the current PacketSender if it is the first entry in a chain.

Specified by:

undecorate in interface MessageSender<NativePacketPayload>

Returns:

MessageSender instance