com.mongodb.connection

Class InternalStreamConnection

java.lang.Object

com.mongodb.connection.InternalStreamConnection

All Implemented Interfaces:

BufferProvider, InternalConnection

@NotThreadSafe
class InternalStreamConnection
extends java.lang.Object
implements InternalConnection

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
private class	InternalStreamConnection.CommandEventSender
private static class	InternalStreamConnection.LazyCommandDocument
private class	InternalStreamConnection.MessageHeaderCallback

Field Summary

Fields

Modifier and Type	Field and Description
private CommandListener	commandListener
private java.util.List<MongoCompressor>	compressorList
private java.util.Map<java.lang.Byte,Compressor>	compressorMap
private InternalConnectionInitializer	connectionInitializer
private ConnectionDescription	description
private java.util.concurrent.atomic.AtomicBoolean	isClosed
private static Logger	LOGGER
private java.util.concurrent.atomic.AtomicBoolean	opened
private static java.util.Set<java.lang.String>	SECURITY_SENSITIVE_COMMANDS
private Compressor	sendCompressor
private ServerId	serverId
private Stream	stream
private StreamFactory	streamFactory

Constructor Summary

Constructors

Constructor and Description
InternalStreamConnection(ServerId serverId, StreamFactory streamFactory, java.util.List<MongoCompressor> compressorList, CommandListener commandListener, InternalConnectionInitializer connectionInitializer)

Method Summary

Modifier and Type	Method and Description
void	close() Closes the connection.
private Compressor	createCompressor(MongoCompressor mongoCompressor)
private java.util.Map<java.lang.Byte,Compressor>	createCompressorMap(java.util.List<MongoCompressor> compressorList)
private Compressor	findSendCompressor(ConnectionDescription description)
ByteBuf	getBuffer(int size) Gets a buffer with the givens capacity.
private Compressor	getCompressor(CompressedHeader compressedHeader)
ConnectionDescription	getDescription() Gets the description of this connection.
private ConnectionId	getId()
private static <T extends BsonDocument> T	getResponseDocument(ResponseBuffers responseBuffers, int messageId, Decoder<T> decoder)
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)
private <T> T	receiveCommandMessageResponse(CommandMessage message, Decoder<T> decoder, InternalStreamConnection.CommandEventSender commandEventSender, SessionContext sessionContext)
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 ResponseBuffers	receiveResponseBuffers()
<T> T	sendAndReceive(CommandMessage message, Decoder<T> decoder, SessionContext sessionContext) Send a command message to the server.
<T> void	sendAndReceiveAsync(CommandMessage message, Decoder<T> decoder, SessionContext sessionContext, SingleResultCallback<T> callback) Send a command message to the server.
private void	sendCommandMessage(CommandMessage message, InternalStreamConnection.LazyCommandDocument lazyCommandDocument, ByteBufferBsonOutput bsonOutput, SessionContext sessionContext)
private <T> void	sendCommandMessageAsync(int messageId, Decoder<T> decoder, SessionContext sessionContext, SingleResultCallback<T> callback, ByteBufferBsonOutput bsonOutput, InternalStreamConnection.CommandEventSender commandEventSender, boolean responseExpected)
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	updateSessionContext(SessionContext sessionContext, ResponseBuffers responseBuffers)
private void	writeAsync(java.util.List<ByteBuf> byteBuffers, SingleResultCallback<java.lang.Void> callback)

Methods inherited from class java.lang.Object

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

Field Detail

SECURITY_SENSITIVE_COMMANDS

private static final java.util.Set<java.lang.String> SECURITY_SENSITIVE_COMMANDS

LOGGER

private static final Logger LOGGER

serverId

private final ServerId serverId

streamFactory

private final StreamFactory streamFactory

connectionInitializer

private final InternalConnectionInitializer connectionInitializer

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

compressorList

private final java.util.List<MongoCompressor> compressorList

commandListener

private final CommandListener commandListener

sendCompressor

private volatile Compressor sendCompressor

compressorMap

private volatile java.util.Map<java.lang.Byte,Compressor> compressorMap

Constructor Detail

InternalStreamConnection

InternalStreamConnection(ServerId serverId,
                         StreamFactory streamFactory,
                         java.util.List<MongoCompressor> compressorList,
                         CommandListener commandListener,
                         InternalConnectionInitializer connectionInitializer)

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

createCompressorMap

private java.util.Map<java.lang.Byte,Compressor> createCompressorMap(java.util.List<MongoCompressor> compressorList)

findSendCompressor

private Compressor findSendCompressor(ConnectionDescription description)

createCompressor

private Compressor createCompressor(MongoCompressor mongoCompressor)

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

sendAndReceive

public <T> T sendAndReceive(CommandMessage message,
                            Decoder<T> decoder,
                            SessionContext sessionContext)

Description copied from interface: InternalConnection

Send a command message to the server.

Specified by:

sendAndReceive in interface InternalConnection

Parameters:

message - the command message to send

sessionContext - the session context

sendCommandMessage

private void sendCommandMessage(CommandMessage message,
                                InternalStreamConnection.LazyCommandDocument lazyCommandDocument,
                                ByteBufferBsonOutput bsonOutput,
                                SessionContext sessionContext)

receiveCommandMessageResponse

private <T> T receiveCommandMessageResponse(CommandMessage message,
                                            Decoder<T> decoder,
                                            InternalStreamConnection.CommandEventSender commandEventSender,
                                            SessionContext sessionContext)

sendAndReceiveAsync

public <T> void sendAndReceiveAsync(CommandMessage message,
                                    Decoder<T> decoder,
                                    SessionContext sessionContext,
                                    SingleResultCallback<T> callback)

Description copied from interface: InternalConnection

Send a command message to the server.

Specified by:

sendAndReceiveAsync in interface InternalConnection

Parameters:

message - the command message to send

sessionContext - the session context

callback - the callback

sendCommandMessageAsync

private <T> void sendCommandMessageAsync(int messageId,
                                         Decoder<T> decoder,
                                         SessionContext sessionContext,
                                         SingleResultCallback<T> callback,
                                         ByteBufferBsonOutput bsonOutput,
                                         InternalStreamConnection.CommandEventSender commandEventSender,
                                         boolean responseExpected)

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(java.util.List<ByteBuf> byteBuffers,
                        SingleResultCallback<java.lang.Void> callback)

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

readAsync

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

getId

private ConnectionId getId()

getServerAddress

private ServerAddress getServerAddress()

updateSessionContext

private void updateSessionContext(SessionContext sessionContext,
                                  ResponseBuffers responseBuffers)

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

getCompressor

private Compressor getCompressor(CompressedHeader compressedHeader)

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.

getResponseDocument

private static <T extends BsonDocument> T getResponseDocument(ResponseBuffers responseBuffers,
                                                              int messageId,
                                                              Decoder<T> decoder)