Package | Description |
---|---|
com.mongodb.connection |
Contains classes that manage connecting to MongoDB servers.
|
com.mongodb.connection.netty |
This package contains netty specific classes
|
com.mongodb.internal.connection | |
org.bson |
Contains the base BSON classes.
|
org.bson.io |
Contains classes implementing I/O operations used by BSON objects.
|
Modifier and Type | Class and Description |
---|---|
(package private) class |
CompositeByteBuf |
Modifier and Type | Field and Description |
---|---|
private ByteBuf |
ResponseBuffers.bodyByteBuffer |
private ByteBuf |
CompositeByteBuf.Component.buffer |
private ByteBuf |
ByteBufBsonDocument.byteBuf |
private ByteBuf |
Compressor.ByteBufInputStream.source |
Modifier and Type | Field and Description |
---|---|
private java.util.List<ByteBuf> |
ByteBufferBsonOutput.bufferList |
private java.util.concurrent.atomic.AtomicReference<ByteBuf> |
AsynchronousSocketChannelStream.BasicCompletionHandler.byteBufReference |
private java.util.List<ByteBuf> |
CompressedMessage.wrappedMessageBuffers |
Modifier and Type | Method and Description |
---|---|
ByteBuf |
CompositeByteBuf.asReadOnly() |
ByteBuf |
CompositeByteBuf.clear() |
ByteBuf |
CompositeByteBuf.duplicate() |
ByteBuf |
CompositeByteBuf.flip() |
ByteBuf |
CompositeByteBuf.get(byte[] bytes) |
ByteBuf |
CompositeByteBuf.get(byte[] bytes,
int offset,
int length) |
ByteBuf |
CompositeByteBuf.get(int index,
byte[] bytes) |
ByteBuf |
CompositeByteBuf.get(int index,
byte[] bytes,
int offset,
int length) |
ByteBuf |
ResponseBuffers.getBodyByteBuffer()
Returns a read-only buffer containing the response body.
|
ByteBuf |
DefaultConnectionPool.PooledConnection.getBuffer(int capacity) |
ByteBuf |
SocketStream.getBuffer(int size) |
ByteBuf |
SocketChannelStream.getBuffer(int size) |
ByteBuf |
BufferProvider.getBuffer(int size)
Gets a buffer with the givens capacity.
|
ByteBuf |
InternalStreamConnection.getBuffer(int size) |
ByteBuf |
AsynchronousSocketChannelStream.getBuffer(int size) |
ByteBuf |
UsageTrackingInternalConnection.getBuffer(int size) |
private ByteBuf |
ByteBufferBsonOutput.getByteBufferAtIndex(int index) |
private ByteBuf |
ByteBufferBsonOutput.getCurrentByteBuffer() |
private static ByteBuf |
CompressedMessage.getFirstWrappedMessageBuffer(java.util.List<ByteBuf> wrappedMessageBuffers) |
ByteBuf |
CompositeByteBuf.limit(int newLimit) |
ByteBuf |
CompositeByteBuf.order(java.nio.ByteOrder byteOrder) |
ByteBuf |
CompositeByteBuf.position(int newPosition) |
ByteBuf |
CompositeByteBuf.put(byte b) |
ByteBuf |
CompositeByteBuf.put(byte[] src,
int offset,
int length) |
ByteBuf |
CompositeByteBuf.put(int index,
byte b) |
ByteBuf |
SocketStream.read(int numBytes) |
ByteBuf |
SocketChannelStream.read(int numBytes) |
ByteBuf |
AsynchronousSocketChannelStream.read(int numBytes) |
ByteBuf |
Stream.read(int numBytes)
Read from the stream, blocking until the requested number of bytes have been read.
|
ByteBuf |
CompositeByteBuf.retain() |
Modifier and Type | Method and Description |
---|---|
java.util.List<ByteBuf> |
ByteBufferBsonOutput.getByteBuffers() |
Modifier and Type | Method and Description |
---|---|
void |
InternalStreamConnection.MessageHeaderCallback.onResult(ByteBuf result,
java.lang.Throwable t) |
void |
InternalStreamConnection.MessageHeaderCallback.MessageCallback.onResult(ByteBuf result,
java.lang.Throwable t) |
private void |
AsynchronousSocketChannelStream.pipeOneBuffer(AsyncWritableByteChannel byteChannel,
ByteBuf byteBuffer,
AsyncCompletionHandler<java.lang.Void> outerHandler) |
(package private) void |
Compressor.uncompress(ByteBuf source,
ByteBuf target) |
Modifier and Type | Method and Description |
---|---|
(package private) void |
Compressor.compress(java.util.List<ByteBuf> source,
BsonOutput target) |
void |
SnappyCompressor.compress(java.util.List<ByteBuf> source,
BsonOutput target) |
private void |
SnappyCompressor.copy(java.util.List<ByteBuf> source,
byte[] in) |
private static ByteBuf |
CompressedMessage.getFirstWrappedMessageBuffer(java.util.List<ByteBuf> wrappedMessageBuffers) |
private int |
SnappyCompressor.getUncompressedSize(java.util.List<ByteBuf> source) |
private static int |
CompressedMessage.getWrappedMessageRequestId(java.util.List<ByteBuf> wrappedMessageBuffers) |
private static int |
CompressedMessage.getWrappedMessageSize(java.util.List<ByteBuf> wrappedMessageBuffers) |
void |
SocketStream.readAsync(int numBytes,
AsyncCompletionHandler<ByteBuf> handler) |
void |
SocketChannelStream.readAsync(int numBytes,
AsyncCompletionHandler<ByteBuf> handler) |
void |
AsynchronousSocketChannelStream.readAsync(int numBytes,
AsyncCompletionHandler<ByteBuf> handler) |
void |
Stream.readAsync(int numBytes,
AsyncCompletionHandler<ByteBuf> handler)
Read from the stream, asynchronously.
|
private void |
InternalStreamConnection.readAsync(int numBytes,
SingleResultCallback<ByteBuf> callback) |
void |
InternalConnection.sendMessage(java.util.List<ByteBuf> byteBuffers,
int lastRequestId)
Send a message to the server.
|
void |
DefaultConnectionPool.PooledConnection.sendMessage(java.util.List<ByteBuf> byteBuffers,
int lastRequestId) |
void |
InternalStreamConnection.sendMessage(java.util.List<ByteBuf> byteBuffers,
int lastRequestId) |
void |
UsageTrackingInternalConnection.sendMessage(java.util.List<ByteBuf> byteBuffers,
int lastRequestId) |
void |
InternalConnection.sendMessageAsync(java.util.List<ByteBuf> byteBuffers,
int lastRequestId,
SingleResultCallback<java.lang.Void> callback)
Asynchronously send a message to the server.
|
void |
DefaultConnectionPool.PooledConnection.sendMessageAsync(java.util.List<ByteBuf> byteBuffers,
int lastRequestId,
SingleResultCallback<java.lang.Void> callback) |
void |
InternalStreamConnection.sendMessageAsync(java.util.List<ByteBuf> byteBuffers,
int lastRequestId,
SingleResultCallback<java.lang.Void> callback) |
void |
UsageTrackingInternalConnection.sendMessageAsync(java.util.List<ByteBuf> byteBuffers,
int lastRequestId,
SingleResultCallback<java.lang.Void> callback) |
void |
SocketStream.write(java.util.List<ByteBuf> buffers) |
void |
SocketChannelStream.write(java.util.List<ByteBuf> buffers) |
void |
AsynchronousSocketChannelStream.write(java.util.List<ByteBuf> buffers) |
void |
Stream.write(java.util.List<ByteBuf> buffers)
Write each buffer in the list to the stream in order, blocking until all are completely written.
|
void |
SocketStream.writeAsync(java.util.List<ByteBuf> buffers,
AsyncCompletionHandler<java.lang.Void> handler) |
void |
SocketChannelStream.writeAsync(java.util.List<ByteBuf> buffers,
AsyncCompletionHandler<java.lang.Void> handler) |
void |
AsynchronousSocketChannelStream.writeAsync(java.util.List<ByteBuf> buffers,
AsyncCompletionHandler<java.lang.Void> handler) |
void |
Stream.writeAsync(java.util.List<ByteBuf> buffers,
AsyncCompletionHandler<java.lang.Void> handler)
Write each buffer in the list to the stream in order, asynchronously.
|
private void |
InternalStreamConnection.writeAsync(java.util.List<ByteBuf> byteBuffers,
SingleResultCallback<java.lang.Void> callback) |
Constructor and Description |
---|
BasicCompletionHandler(ByteBuf dst,
AsyncCompletionHandler<ByteBuf> handler) |
ByteBufBsonDocument(ByteBuf byteBuf) |
ByteBufInputStream(ByteBuf source) |
Component(ByteBuf buffer,
int offset) |
CompressedHeader(ByteBuf header,
MessageHeader messageHeader) |
MessageHeader(ByteBuf header,
int maxMessageLength) |
ReplyHeader(ByteBuf header,
CompressedHeader compressedHeader) |
ReplyHeader(ByteBuf header,
MessageHeader messageHeader) |
ReplyHeader(int messageLength,
int opCode,
MessageHeader messageHeader,
ByteBuf header) |
ResponseBuffers(ReplyHeader replyHeader,
ByteBuf bodyByteBuffer) |
Constructor and Description |
---|
BasicCompletionHandler(ByteBuf dst,
AsyncCompletionHandler<ByteBuf> handler) |
CompositeByteBuf(java.util.List<ByteBuf> buffers) |
CompressedMessage(OpCode wrappedOpcode,
java.util.List<ByteBuf> wrappedMessageBuffers,
Compressor compressor,
MessageSettings settings) |
Modifier and Type | Class and Description |
---|---|
(package private) class |
NettyByteBuf |
Modifier and Type | Field and Description |
---|---|
private AsyncCompletionHandler<ByteBuf> |
NettyStream.PendingReader.handler |
Modifier and Type | Method and Description |
---|---|
ByteBuf |
NettyByteBuf.asReadOnly() |
ByteBuf |
NettyByteBuf.clear() |
ByteBuf |
NettyByteBuf.duplicate() |
ByteBuf |
NettyByteBuf.flip() |
ByteBuf |
NettyByteBuf.get(byte[] bytes) |
ByteBuf |
NettyByteBuf.get(byte[] bytes,
int offset,
int length) |
ByteBuf |
NettyByteBuf.get(int index,
byte[] bytes) |
ByteBuf |
NettyByteBuf.get(int index,
byte[] bytes,
int offset,
int length) |
ByteBuf |
NettyStream.getBuffer(int size) |
ByteBuf |
NettyBufferProvider.getBuffer(int size) |
ByteBuf |
NettyByteBuf.limit(int newLimit) |
ByteBuf |
NettyByteBuf.order(java.nio.ByteOrder byteOrder) |
ByteBuf |
NettyByteBuf.position(int newPosition) |
ByteBuf |
NettyByteBuf.put(byte b) |
ByteBuf |
NettyByteBuf.put(byte[] src,
int offset,
int length) |
ByteBuf |
NettyByteBuf.put(int index,
byte b) |
ByteBuf |
NettyStream.read(int numBytes) |
ByteBuf |
NettyByteBuf.retain() |
Modifier and Type | Method and Description |
---|---|
void |
NettyStream.readAsync(int numBytes,
AsyncCompletionHandler<ByteBuf> handler) |
void |
NettyStream.write(java.util.List<ByteBuf> buffers) |
void |
NettyStream.writeAsync(java.util.List<ByteBuf> buffers,
AsyncCompletionHandler<java.lang.Void> handler) |
Constructor and Description |
---|
PendingReader(int numBytes,
AsyncCompletionHandler<ByteBuf> handler) |
Modifier and Type | Class and Description |
---|---|
private class |
PowerOfTwoBufferPool.PooledByteBufNIO |
Modifier and Type | Method and Description |
---|---|
ByteBuf |
PowerOfTwoBufferPool.getBuffer(int size) |
Modifier and Type | Class and Description |
---|---|
class |
ByteBufNIO
Implementation of
ByteBuf which simply wraps an NIO ByteBuffer and forwards all calls to it. |
Modifier and Type | Method and Description |
---|---|
ByteBuf |
ByteBuf.asReadOnly()
Creates a new, read-only byte buffer that shares this buffer's content.
|
ByteBuf |
ByteBufNIO.asReadOnly() |
ByteBuf |
ByteBuf.clear()
Clears this buffer.
|
ByteBuf |
ByteBufNIO.clear() |
ByteBuf |
ByteBuf.duplicate()
Creates a new byte buffer that shares this buffer's content.
|
ByteBuf |
ByteBufNIO.duplicate() |
ByteBuf |
ByteBuf.flip()
Flips this buffer.
|
ByteBuf |
ByteBufNIO.flip() |
ByteBuf |
ByteBuf.get(byte[] bytes)
Relative bulk
get method. |
ByteBuf |
ByteBufNIO.get(byte[] bytes) |
ByteBuf |
ByteBuf.get(byte[] bytes,
int offset,
int length)
Relative bulk get method.
|
ByteBuf |
ByteBufNIO.get(byte[] bytes,
int offset,
int length) |
ByteBuf |
ByteBuf.get(int index,
byte[] bytes)
Absolute bulk
get method. |
ByteBuf |
ByteBufNIO.get(int index,
byte[] bytes) |
ByteBuf |
ByteBuf.get(int index,
byte[] bytes,
int offset,
int length)
Absolute bulk get method.
|
ByteBuf |
ByteBufNIO.get(int index,
byte[] bytes,
int offset,
int length) |
ByteBuf |
RawBsonDocument.getByteBuffer()
Returns a
ByteBuf that wraps the byte array, with the proper byte order. |
ByteBuf |
ByteBuf.limit(int newLimit)
Sets this buffer's limit.
|
ByteBuf |
ByteBufNIO.limit(int newLimit) |
ByteBuf |
ByteBuf.order(java.nio.ByteOrder byteOrder)
Modifies this buffer's byte order.
|
ByteBuf |
ByteBufNIO.order(java.nio.ByteOrder byteOrder) |
ByteBuf |
ByteBuf.position(int newPosition)
Sets this buffer's position.
|
ByteBuf |
ByteBufNIO.position(int newPosition) |
ByteBuf |
ByteBuf.put(byte b)
Relative put method (optional operation).
|
ByteBuf |
ByteBufNIO.put(byte b) |
ByteBuf |
ByteBuf.put(byte[] src,
int offset,
int length)
Relative bulk put method (optional operation).
|
ByteBuf |
ByteBufNIO.put(byte[] src,
int offset,
int length) |
ByteBuf |
ByteBuf.put(int index,
byte b)
Absolute put method (optional operation).
|
ByteBuf |
ByteBufNIO.put(int index,
byte b) |
ByteBuf |
ByteBuf.retain()
Retain an additional reference to this object.
|
Modifier and Type | Field and Description |
---|---|
private ByteBuf |
ByteBufferBsonInput.buffer |
Modifier and Type | Method and Description |
---|---|
java.util.List<ByteBuf> |
BasicOutputBuffer.getByteBuffers() |
abstract java.util.List<ByteBuf> |
OutputBuffer.getByteBuffers()
Get a list of byte buffers that are prepared to be read from; in other words, whose position is 0 and whose limit is the number of
bytes that should read.
|
Constructor and Description |
---|
ByteBufferBsonInput(ByteBuf buffer)
Construct an instance with the given byte buffer.
|