Modifier and Type	Class and Description
private class	SyncMessageReader.ListenersDispatcher

Field Summary

Modifier and Type	Field and Description
pack-priv Thread	dispatchingThread
pack-priv final Lock	dispatchingThreadLock Lock to protect the pending message.
pack-priv LinkedList<XMessageHeader>	headersQueue
private FullReadInputStream	inputStream Stream as a source of messages.
pack-priv BlockingQueue<MessageListener<XMessage>>	messageListenerQueue Queue of `MessageListener`s waiting to process messages.
pack-priv LinkedList<Message>	messagesQueue
private Protocol.ProtocolEventHandler	protocolEventHandler
pack-priv final Lock	syncOperationLock Lock to protect async reads from sync ones.

Constructor Summary

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

Method Summary

Modifier and Type	Method and Description
public int	getNextNonNoticeMessageType()
public void	pushMessageListener(final MessageListener<XMessage> `MessageListener` listener) Overrides default com.mysql.cj.protocol.MessageReader.pushMessageListener. Queue a `MessageListener` to receive messages delivered asynchronously.
public XMessageHeader	readHeader() Implements com.mysql.cj.protocol.MessageReader.readHeader. Read the next message header from server, possibly blocking indefinitely until the message is received.
private XMessageHeader	readHeaderLocal()
public XMessage	readMessage(Optional<XMessage> `Message` object to reuse. May be ignored by implementation. reuse, XMessageHeader `MessageHeader` instance hdr) Implements com.mysql.cj.protocol.MessageReader.readMessage. Read message from server into to the given `Message` instance or into the new one if not present.
public XMessage	readMessage(Optional<XMessage> `Message` object to reuse. May be ignored by implementation. reuse, int Expected type of message. expectedType) Overrides default com.mysql.cj.protocol.MessageReader.readMessage. Implements com.mysql.cj.protocol.MessageReader.readMessage. Read message from server into to the given `Message` instance or into the new one if not present.
private <T extends Message> T	readMessageLocal(Class<T> messageClass, boolean fromQueue)

Inherited from java.lang.Object:: clone equals finalize getClass hashCode notify notifyAll toString wait wait wait

Field Detail

dispatchingThread	back to summary
pack-priv Thread dispatchingThread

dispatchingThreadLock	back to summary
pack-priv final Lock dispatchingThreadLock Lock to protect the pending message.

headersQueue	back to summary
pack-priv LinkedList<XMessageHeader> headersQueue

inputStream	back to summary
private FullReadInputStream inputStream Stream as a source of messages.

messageListenerQueue	back to summary
pack-priv BlockingQueue<MessageListener<XMessage>> messageListenerQueue Queue of `MessageListener`s waiting to process messages.

messagesQueue	back to summary
pack-priv LinkedList<Message> messagesQueue

protocolEventHandler	back to summary
private Protocol.ProtocolEventHandler protocolEventHandler

syncOperationLock	back to summary
pack-priv final Lock syncOperationLock Lock to protect async reads from sync ones.

Constructor Detail

SyncMessageReader	back to summary
public SyncMessageReader(FullReadInputStream inputStream, Protocol.ProtocolEventHandler protocolEventHandler)

Method Detail

getNextNonNoticeMessageType	back to summary
public int getNextNonNoticeMessageType() throws IOException

pushMessageListener back to summary

pushMessageListener	back to summary
public void pushMessageListener(final MessageListener<XMessage> listener) Overrides default com.mysql.cj.protocol.MessageReader.pushMessageListener. Doc from com.mysql.cj.protocol.MessageReader.pushMessageListener. Queue a `MessageListener` to receive messages delivered asynchronously. Parameters listener:MessageListener<XMessage> `MessageListener` Annotations @Override

public void pushMessageListener(final MessageListener<XMessage> listener)

Overrides default com.mysql.cj.protocol.MessageReader.pushMessageListener.

Doc from com.mysql.cj.protocol.MessageReader.pushMessageListener.

Queue a MessageListener to receive messages delivered asynchronously.

Parameters

listener:MessageListener<XMessage>: MessageListener

Annotations

@Override

readHeader back to summary

readHeader	back to summary
public XMessageHeader readHeader() throws IOException Implements com.mysql.cj.protocol.MessageReader.readHeader. Doc from com.mysql.cj.protocol.MessageReader.readHeader. Read the next message header from server, possibly blocking indefinitely until the message is received. Returns:XMessageHeader `MessageHeader` of the next message Annotations @Override Exceptions IOException: if an error occurs

public XMessageHeader readHeader() throws IOException

Implements com.mysql.cj.protocol.MessageReader.readHeader.

Doc from com.mysql.cj.protocol.MessageReader.readHeader.

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

Returns:XMessageHeader

MessageHeader of the next message

Annotations

@Override

Exceptions

IOException:: if an error occurs

readHeaderLocal	back to summary
private XMessageHeader readHeaderLocal() throws IOException

readMessage back to summary

readMessage	back to summary
public XMessage readMessage(Optional<XMessage> reuse, XMessageHeader hdr) throws IOException Implements com.mysql.cj.protocol.MessageReader.readMessage. Doc from com.mysql.cj.protocol.MessageReader.readMessage. 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 Parameters reuse:Optional<XMessage> `Message` object to reuse. May be ignored by implementation. hdr:XMessageHeader `MessageHeader` instance Returns:XMessage `Message` instance Annotations @Override Exceptions IOException: if an error occurs

public XMessage readMessage(Optional<XMessage> reuse, XMessageHeader hdr) throws IOException

Implements com.mysql.cj.protocol.MessageReader.readMessage.

Doc from com.mysql.cj.protocol.MessageReader.readMessage.

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

Parameters

reuse:Optional<XMessage>: Message object to reuse. May be ignored by implementation.
hdr:XMessageHeader: MessageHeader instance

Returns:XMessage

Message instance

Annotations

@Override

Exceptions

IOException:: if an error occurs

readMessage back to summary

readMessage	back to summary
public XMessage readMessage(Optional<XMessage> reuse, int expectedType) throws IOException Overrides default com.mysql.cj.protocol.MessageReader.readMessage. Implements com.mysql.cj.protocol.MessageReader.readMessage. Doc from com.mysql.cj.protocol.MessageReader.readMessage. 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). Parameters reuse:Optional<XMessage> `Message` object to reuse. May be ignored by implementation. expectedType:int Expected type of message. Returns:XMessage `Message` instance Annotations @Override Exceptions IOException: if an error occurs

public XMessage readMessage(Optional<XMessage> reuse, int expectedType) throws IOException

Overrides default com.mysql.cj.protocol.MessageReader.readMessage.

Implements com.mysql.cj.protocol.MessageReader.readMessage.

Doc from com.mysql.cj.protocol.MessageReader.readMessage.

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

Parameters

reuse:Optional<XMessage>: Message object to reuse. May be ignored by implementation.
expectedType:int: Expected type of message.

Returns:XMessage

Message instance

Annotations

@Override

Exceptions

IOException:: if an error occurs

readMessageLocal	back to summary
private <T extends Message> T readMessageLocal(Class<T> messageClass, boolean fromQueue) Annotations @SuppressWarnings:unchecked

com.mysql.cj.protocol.x back to summary

private Class SyncMessageReader.ListenersDispatcher

Class Inheritance

extends Object
implements Runnable

java.lang.Object
com.mysql.cj.protocol.x.SyncMessageReader.ListenersDispatcher

All Implemented Interfaces

java.lang.Runnable

Field Summary

Modifier and Type	Field and Description
private static final long	POLL_TIMEOUT The timeout value for queue.poll(timeout, unit) defining the time after which we close and unregister the dispatching thread.
pack-priv boolean	started

Constructor Summary

Access	Constructor and Description
public	ListenersDispatcher()

Method Summary

Modifier and Type	Method and Description
public void	run() Implements java.lang.Runnable.run. Runs this operation.

Inherited from java.lang.Object:: clone equals finalize getClass hashCode notify notifyAll toString wait wait wait

Field Detail

POLL_TIMEOUT	back to summary
private static final long POLL_TIMEOUT The timeout value for queue.poll(timeout, unit) defining the time after which we close and unregister the dispatching thread. On the other hand, a bigger timeout value allows us to keep dispatcher thread running while multiple concurrent asynchronous read operations are pending, thus avoiding the delays for new dispatching threads creation.

started	back to summary
pack-priv boolean started

Constructor Detail

ListenersDispatcher	back to summary
public ListenersDispatcher()

Method Detail

run	back to summary
public void run() Implements java.lang.Runnable.run. Doc from java.lang.Runnable.run. Runs this operation. Annotations @Override

run

back to summary

public void run()

Implements java.lang.Runnable.run.

Doc from java.lang.Runnable.run.

Runs this operation.

Annotations

@Override

public Class SyncMessageReader

Nested and Inner Type Summary

Field Summary

Constructor Summary

Method Summary

Field Detail

Constructor Detail

Method Detail

private Class SyncMessageReader.ListenersDispatcher

Field Summary

Constructor Summary

Method Summary

Field Detail

Constructor Detail

Method Detail