com.mysql.cj.protocol.x

Class SyncMessageReader

java.lang.Object

com.mysql.cj.protocol.x.SyncMessageReader

All Implemented Interfaces:

MessageReader<XMessageHeader,XMessage>

public class SyncMessageReader
extends java.lang.Object
implements MessageReader<XMessageHeader,XMessage>

Synchronous-only implementation of MessageReader. This implementation wraps a InputStream.

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
private class	SyncMessageReader.ListenersDispatcher

Field Summary

Fields

Modifier and Type	Field and Description
(package private) java.lang.Thread	dispatchingThread
(package private) java.lang.Object	dispatchingThreadMonitor Lock to protect the pending message.
(package private) java.util.LinkedList<XMessageHeader>	headersQueue
private FullReadInputStream	inputStream Stream as a source of messages.
(package private) java.util.concurrent.BlockingQueue<MessageListener<XMessage>>	messageListenerQueue Queue of MessageListeners waiting to process messages.
(package private) java.util.LinkedList<com.google.protobuf.GeneratedMessageV3>	messagesQueue
private Protocol.ProtocolEventHandler	protocolEventHandler
(package private) java.lang.Object	waitingSyncOperationMonitor Lock to protect async reads from sync ones.

Constructor Summary

Constructors

Constructor and Description
SyncMessageReader(FullReadInputStream inputStream, Protocol.ProtocolEventHandler protocolEventHandler)

Method Summary

Modifier and Type	Method and Description
int	getNextNonNoticeMessageType()
void	pushMessageListener(MessageListener<XMessage> listener) Queue a MessageListener to receive messages delivered asynchronously.
XMessageHeader	readHeader() Read the next message header from server, possibly blocking indefinitely until the message is received.
private XMessageHeader	readHeaderLocal()
XMessage	readMessage(java.util.Optional<XMessage> reuse, int expectedType) Read message from server into to the given Message instance or into the new one if not present.
XMessage	readMessage(java.util.Optional<XMessage> reuse, XMessageHeader hdr) Read message from server into to the given Message instance or into the new one if not present.
private <T extends com.google.protobuf.GeneratedMessageV3> T	readMessageLocal(java.lang.Class<T> messageClass, boolean fromQueue)

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

getMessageSequence, probeHeader, probeMessage, resetMessageSequence, skipPacket, start, stopAfterNextMessage, undecorate, undecorateAll

Field Detail

inputStream

private FullReadInputStream inputStream

Stream as a source of messages.

headersQueue

java.util.LinkedList<XMessageHeader> headersQueue

messagesQueue

java.util.LinkedList<com.google.protobuf.GeneratedMessageV3> messagesQueue

messageListenerQueue

java.util.concurrent.BlockingQueue<MessageListener<XMessage>> messageListenerQueue

Queue of MessageListeners waiting to process messages.

dispatchingThreadMonitor

java.lang.Object dispatchingThreadMonitor

Lock to protect the pending message.

waitingSyncOperationMonitor

java.lang.Object waitingSyncOperationMonitor

Lock to protect async reads from sync ones.

dispatchingThread

java.lang.Thread dispatchingThread

protocolEventHandler

private Protocol.ProtocolEventHandler protocolEventHandler

Constructor Detail

SyncMessageReader

public SyncMessageReader(FullReadInputStream inputStream,
                         Protocol.ProtocolEventHandler protocolEventHandler)

Method Detail

readHeader

public XMessageHeader readHeader()
                          throws java.io.IOException

Description copied from interface: MessageReader

Read the next message header from server, possibly blocking indefinitely until the message is received.

Specified by:

readHeader in interface MessageReader<XMessageHeader,XMessage>

Returns:

MessageHeader of the next message

Throws:

java.io.IOException - if an error occurs

getNextNonNoticeMessageType

public int getNextNonNoticeMessageType()
                                throws java.io.IOException

Throws:

java.io.IOException

readHeaderLocal

private XMessageHeader readHeaderLocal()
                                throws java.io.IOException

Throws:

java.io.IOException

readMessageLocal

private <T extends com.google.protobuf.GeneratedMessageV3> T readMessageLocal(java.lang.Class<T> messageClass,
                                                                              boolean fromQueue)

readMessage

public XMessage readMessage(java.util.Optional<XMessage> reuse,
                            XMessageHeader hdr)
                     throws java.io.IOException

Description copied from interface: MessageReader

Read message from server into to the given Message instance or into the new one if not present. For asynchronous channel it synchronously reads the next message in the stream, blocking until the message is read fully. Could throw CJCommunicationsException wrapping an IOException during read or parse

Specified by:

readMessage in interface MessageReader<XMessageHeader,XMessage>

Parameters:

reuse - Message object to reuse. May be ignored by implementation.

hdr - MessageHeader instance

Returns:

Message instance

Throws:

java.io.IOException - if an error occurs

readMessage

public XMessage readMessage(java.util.Optional<XMessage> reuse,
                            int expectedType)
                     throws java.io.IOException

Description copied from interface: MessageReader

Read message from server into to the given Message instance or into the new one if not present. For asynchronous channel it synchronously reads the next message in the stream, blocking until the message is read fully. Could throw WrongArgumentException if the expected message type is not the next message (exception will be thrown in *caller* context).

Specified by:

readMessage in interface MessageReader<XMessageHeader,XMessage>

Parameters:

reuse - Message object to reuse. May be ignored by implementation.

expectedType - Expected type of message.

Returns:

Message instance

Throws:

java.io.IOException - if an error occurs

pushMessageListener

public void pushMessageListener(MessageListener<XMessage> listener)

Description copied from interface: MessageReader

Queue a MessageListener to receive messages delivered asynchronously.

Specified by:

pushMessageListener in interface MessageReader<XMessageHeader,XMessage>

Parameters:

listener - MessageListener