com.mongodb.connection

Class SocketChannelStream

java.lang.Object

com.mongodb.connection.SocketChannelStream

All Implemented Interfaces:

BufferProvider, Stream

class SocketChannelStream
extends java.lang.Object
implements Stream

Field Summary

Fields

Modifier and Type	Field and Description
private ServerAddress	address
private BufferProvider	bufferProvider
private boolean	isClosed
private SocketSettings	settings
private java.nio.channels.SocketChannel	socketChannel
private SslSettings	sslSettings

Constructor Summary

Constructors

Constructor and Description
SocketChannelStream(ServerAddress address, SocketSettings settings, SslSettings sslSettings, BufferProvider bufferProvider)

Method Summary

Modifier and Type	Method and Description
void	close() Closes the connection.
ServerAddress	getAddress() The address that this stream is connected to.
ByteBuf	getBuffer(int size) Gets a buffer with the givens capacity.
(package private) SocketSettings	getSettings() Get the settings for this socket.
boolean	isClosed() Returns the closed state of the connection
void	open() Open the stream.
void	openAsync(AsyncCompletionHandler<java.lang.Void> handler) Open the stream asynchronously.
ByteBuf	read(int numBytes) Read from the stream, blocking until the requested number of bytes have been read.
void	readAsync(int numBytes, AsyncCompletionHandler<ByteBuf> handler) Read from the stream, asynchronously.
void	write(java.util.List<ByteBuf> buffers) Write each buffer in the list to the stream in order, blocking until all are completely written.
void	writeAsync(java.util.List<ByteBuf> buffers, AsyncCompletionHandler<java.lang.Void> handler) Write each buffer in the list to the stream in order, asynchronously.

Methods inherited from class java.lang.Object

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

Field Detail

address

private final ServerAddress address

settings

private final SocketSettings settings

sslSettings

private final SslSettings sslSettings

bufferProvider

private final BufferProvider bufferProvider

socketChannel

private volatile java.nio.channels.SocketChannel socketChannel

isClosed

private volatile boolean isClosed

Constructor Detail

SocketChannelStream

public SocketChannelStream(ServerAddress address,
                           SocketSettings settings,
                           SslSettings sslSettings,
                           BufferProvider bufferProvider)

Method Detail

open

public void open()
          throws java.io.IOException

Description copied from interface: Stream

Open the stream.

Specified by:

open in interface Stream

Throws:

java.io.IOException - if an I/O error occurs

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.

write

public void write(java.util.List<ByteBuf> buffers)
           throws java.io.IOException

Description copied from interface: Stream

Write each buffer in the list to the stream in order, blocking until all are completely written.

Specified by:

write in interface Stream

Parameters:

buffers - the buffers to write

Throws:

java.io.IOException - if there are problems writing to the stream

read

public ByteBuf read(int numBytes)
             throws java.io.IOException

Description copied from interface: Stream

Read from the stream, blocking until the requested number of bytes have been read.

Specified by:

read in interface Stream

Parameters:

numBytes - The number of bytes to read into the returned byte buffer

Returns:

a byte buffer filled with number of bytes requested

Throws:

java.io.IOException - if there are problems reading from the stream

openAsync

public void openAsync(AsyncCompletionHandler<java.lang.Void> handler)

Description copied from interface: Stream

Open the stream asynchronously.

Specified by:

openAsync in interface Stream

Parameters:

handler - the completion handler for opening the stream

writeAsync

public void writeAsync(java.util.List<ByteBuf> buffers,
                       AsyncCompletionHandler<java.lang.Void> handler)

Description copied from interface: Stream

Write each buffer in the list to the stream in order, asynchronously. This method should return immediately, and invoke the given callback on completion.

Specified by:

writeAsync in interface Stream

Parameters:

buffers - the buffers to write

handler - invoked when the read operation has completed

readAsync

public void readAsync(int numBytes,
                      AsyncCompletionHandler<ByteBuf> handler)

Description copied from interface: Stream

Read from the stream, asynchronously. This method should return immediately, and invoke the given callback when the number of requested bytes have been read.

Specified by:

readAsync in interface Stream

Parameters:

numBytes - the number of bytes

handler - invoked when the read operation has completed

getAddress

public ServerAddress getAddress()

Description copied from interface: Stream

The address that this stream is connected to.

Specified by:

getAddress in interface Stream

Returns:

the address

getSettings

SocketSettings getSettings()

Get the settings for this socket.

Returns:

the settings

close

public void close()

Description copied from interface: Stream

Closes the connection.

Specified by:

close in interface Stream

isClosed

public boolean isClosed()

Description copied from interface: Stream

Returns the closed state of the connection

Specified by:

isClosed in interface Stream

Returns:

true if connection is closed