com.mongodb.connection

Class InternalStreamConnection

java.lang.Object

com.mongodb.connection.InternalStreamConnection

All Implemented Interfaces:

BufferProvider, InternalConnection

class InternalStreamConnection
extends java.lang.Object
implements InternalConnection

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
private static class	InternalStreamConnection.ErrorHandlingConnectionListener
private class	InternalStreamConnection.ResponseBuffersCallback
private class	InternalStreamConnection.ResponseHeaderCallback
private static class	InternalStreamConnection.SendMessageRequest

Field Summary

Fields

Modifier and Type	Field and Description
private InternalConnectionInitializer	connectionInitializer
private ConnectionListener	connectionListener
private ConnectionDescription	description
private MongoException	exceptionThatPrecededStreamClosing
private java.util.concurrent.atomic.AtomicBoolean	isClosed
private boolean	isReading
private boolean	isWriting
(package private) static Logger	LOGGER
private java.util.Map<java.lang.Integer,ResponseBuffers>	messages
private java.util.concurrent.atomic.AtomicBoolean	opened
private java.util.concurrent.locks.Lock	readerLock
private java.util.concurrent.atomic.AtomicReference<java.util.concurrent.CountDownLatch>	readingPhase
private java.util.Map<java.lang.Integer,SingleResultCallback<ResponseBuffers>>	readQueue
private ServerId	serverId
private Stream	stream
private StreamFactory	streamFactory
private java.util.Deque<InternalStreamConnection.SendMessageRequest>	writeQueue
private java.util.concurrent.locks.Lock	writerLock

Constructor Summary

Constructors

Constructor and Description
InternalStreamConnection(ServerId serverId, StreamFactory streamFactory, InternalConnectionInitializer connectionInitializer, ConnectionListener connectionListener)

Method Summary

Modifier and Type	Method and Description
void	close() Closes the connection.
private void	executeCallbackAndReceiveResponse(SingleResultCallback<ResponseBuffers> callback, ResponseBuffers result, boolean mustRead)
private void	failAllQueuedReads(java.lang.Throwable t)
ByteBuf	getBuffer(int size) Gets a buffer with the givens capacity.
ConnectionDescription	getDescription() Gets the description of this connection.
private ConnectionId	getId()
private int	getMessageSize(java.util.List<ByteBuf> byteBuffers)
private ServerAddress	getServerAddress()
boolean	isClosed() Returns the closed state of the connection
void	open() Opens the connection so its ready for use
void	openAsync(SingleResultCallback<java.lang.Void> callback) Opens the connection so its ready for use
boolean	opened() Returns if the connection has been opened
private void	readAsync(int numBytes, SingleResultCallback<ByteBuf> callback)
ResponseBuffers	receiveMessage(int responseTo) Receive a response to a sent message from the server.
void	receiveMessageAsync(int responseTo, SingleResultCallback<ResponseBuffers> callback) Asynchronously receive a response to a sent message from the server.
private void	receiveResponseAsync()
private ResponseBuffers	receiveResponseBuffers()
void	sendMessage(java.util.List<ByteBuf> byteBuffers, int lastRequestId) Send a message to the server.
void	sendMessageAsync(java.util.List<ByteBuf> byteBuffers, int lastRequestId, SingleResultCallback<java.lang.Void> callback) Asynchronously send a message to the server.
private MongoException	translateReadException(java.lang.Throwable e)
private MongoException	translateWriteException(java.lang.Throwable e)
private void	writeAsync(InternalStreamConnection.SendMessageRequest request)

Methods inherited from class java.lang.Object

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

Field Detail

serverId

private final ServerId serverId

streamFactory

private final StreamFactory streamFactory

connectionInitializer

private final InternalConnectionInitializer connectionInitializer

connectionListener

private final ConnectionListener connectionListener

writerLock

private final java.util.concurrent.locks.Lock writerLock

readerLock

private final java.util.concurrent.locks.Lock readerLock

writeQueue

private final java.util.Deque<InternalStreamConnection.SendMessageRequest> writeQueue

readQueue

private final java.util.Map<java.lang.Integer,SingleResultCallback<ResponseBuffers>> readQueue

messages

private final java.util.Map<java.lang.Integer,ResponseBuffers> messages

isWriting

private boolean isWriting

isReading

private boolean isReading

readingPhase

private final java.util.concurrent.atomic.AtomicReference<java.util.concurrent.CountDownLatch> readingPhase

exceptionThatPrecededStreamClosing

private volatile MongoException exceptionThatPrecededStreamClosing

description

private volatile ConnectionDescription description

stream

private volatile Stream stream

isClosed

private final java.util.concurrent.atomic.AtomicBoolean isClosed

opened

private final java.util.concurrent.atomic.AtomicBoolean opened

LOGGER

static final Logger LOGGER

Constructor Detail

InternalStreamConnection

InternalStreamConnection(ServerId serverId,
                         StreamFactory streamFactory,
                         InternalConnectionInitializer connectionInitializer,
                         ConnectionListener connectionListener)

Method Detail

getDescription

public ConnectionDescription getDescription()

Description copied from interface: InternalConnection

Gets the description of this connection.

Specified by:

getDescription in interface InternalConnection

Returns:

the connection description

open

public void open()

Description copied from interface: InternalConnection

Opens the connection so its ready for use

Specified by:

open in interface InternalConnection

openAsync

public void openAsync(SingleResultCallback<java.lang.Void> callback)

Description copied from interface: InternalConnection

Opens the connection so its ready for use

Specified by:

openAsync in interface InternalConnection

Parameters:

callback - the callback to be called once the connection has been opened

close

public void close()

Description copied from interface: InternalConnection

Closes the connection.

Specified by:

close in interface InternalConnection

opened

public boolean opened()

Description copied from interface: InternalConnection

Returns if the connection has been opened

Specified by:

opened in interface InternalConnection

Returns:

true if connection has been opened

isClosed

public boolean isClosed()

Description copied from interface: InternalConnection

Returns the closed state of the connection

Specified by:

isClosed in interface InternalConnection

Returns:

true if connection is closed

sendMessage

public void sendMessage(java.util.List<ByteBuf> byteBuffers,
                        int lastRequestId)

Description copied from interface: InternalConnection

Send a message to the server. The connection may not make any attempt to validate the integrity of the message.

Specified by:

sendMessage in interface InternalConnection

Parameters:

byteBuffers - the list of byte buffers to send.

lastRequestId - the request id of the last message in byteBuffers

receiveMessage

public ResponseBuffers receiveMessage(int responseTo)

Description copied from interface: InternalConnection

Receive a response to a sent message from the server.

Specified by:

receiveMessage in interface InternalConnection

Parameters:

responseTo - the request id that this message is a response to

Returns:

the response

sendMessageAsync

public void sendMessageAsync(java.util.List<ByteBuf> byteBuffers,
                             int lastRequestId,
                             SingleResultCallback<java.lang.Void> callback)

Description copied from interface: InternalConnection

Asynchronously send a message to the server. The connection may not make any attempt to validate the integrity of the message.

Specified by:

sendMessageAsync in interface InternalConnection

Parameters:

byteBuffers - the list of byte buffers to send

lastRequestId - the request id of the last message in byteBuffers

callback - the callback to invoke on completion

writeAsync

private void writeAsync(InternalStreamConnection.SendMessageRequest request)

receiveMessageAsync

public void receiveMessageAsync(int responseTo,
                                SingleResultCallback<ResponseBuffers> callback)

Description copied from interface: InternalConnection

Asynchronously receive a response to a sent message from the server.

Specified by:

receiveMessageAsync in interface InternalConnection

Parameters:

responseTo - the request id that this message is a response to

callback - the callback to invoke on completion

executeCallbackAndReceiveResponse

private void executeCallbackAndReceiveResponse(SingleResultCallback<ResponseBuffers> callback,
                                               ResponseBuffers result,
                                               boolean mustRead)

getId

private ConnectionId getId()

getServerAddress

private ServerAddress getServerAddress()

receiveResponseAsync

private void receiveResponseAsync()

readAsync

private void readAsync(int numBytes,
                       SingleResultCallback<ByteBuf> callback)

translateWriteException

private MongoException translateWriteException(java.lang.Throwable e)

translateReadException

private MongoException translateReadException(java.lang.Throwable e)

receiveResponseBuffers

private ResponseBuffers receiveResponseBuffers()
                                        throws java.io.IOException

Throws:

java.io.IOException

getBuffer

public ByteBuf getBuffer(int size)

Description copied from interface: BufferProvider

Gets a buffer with the givens capacity.

Specified by:

getBuffer in interface BufferProvider

Parameters:

size - the size required for the buffer

Returns:

a ByteBuf with the given size, which is now owned by the caller and must be released.

getMessageSize

private int getMessageSize(java.util.List<ByteBuf> byteBuffers)

failAllQueuedReads

private void failAllQueuedReads(java.lang.Throwable t)