com.mysql.cj.protocol.a

Class TracingPacketSender

java.lang.Object

com.mysql.cj.protocol.a.TracingPacketSender

All Implemented Interfaces:

MessageSender<NativePacketPayload>

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

A decorating MessageSender which traces all sent packets to the provided logger.

Field Summary

Fields

Modifier and Type	Field and Description
private java.lang.String	host
private Log	log
private MessageSender<NativePacketPayload>	packetSender
private long	serverThreadId

Constructor Summary

Constructors

Constructor and Description
TracingPacketSender(MessageSender<NativePacketPayload> packetSender, Log log, java.lang.String host, long serverThreadId)

Method Summary

Modifier and Type	Method and Description
private void	logPacket(byte[] packet, int packetLen, byte packetSequence) Log the packet details to the provided logger.
void	send(byte[] packet, int packetLen, byte packetSequence) Synchronously send the message to server.
void	setServerThreadId(long serverThreadId)
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

host

private java.lang.String host

serverThreadId

private long serverThreadId

log

private Log log

Constructor Detail

TracingPacketSender

public TracingPacketSender(MessageSender<NativePacketPayload> packetSender,
                           Log log,
                           java.lang.String host,
                           long serverThreadId)

Method Detail

setServerThreadId

public void setServerThreadId(long serverThreadId)

logPacket

private void logPacket(byte[] packet,
                       int packetLen,
                       byte packetSequence)

Log the packet details to the provided logger.

Parameters:

packet - packet as bytes

packetLen - packet length

packetSequence - sequence index

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