org.jgroups.nio

Class MockSocketChannel

java.lang.Object

java.nio.channels.spi.AbstractInterruptibleChannel

java.nio.channels.SelectableChannel

java.nio.channels.spi.AbstractSelectableChannel

java.nio.channels.SocketChannel

org.jgroups.nio.MockSocketChannel

All Implemented Interfaces:

Closeable, AutoCloseable, ByteChannel, Channel, GatheringByteChannel, InterruptibleChannel, NetworkChannel, ReadableByteChannel, ScatteringByteChannel, WritableByteChannel

public class MockSocketChannel
extends SocketChannel

A mock SocketChannel for testing

Since:

3.6.5

Author:

Bela Ban

Field Summary

Fields

Modifier and Type	Field and Description
protected ByteBuffer	bytes_to_read
protected int	bytes_to_write
protected boolean	closed
protected ByteBuffer	recorder

Constructor Summary

Constructors

Constructor and Description
MockSocketChannel()
MockSocketChannel(SelectorProvider provider) Initializes a new instance of this class.

Method Summary

Modifier and Type	Method and Description
SocketChannel	bind(SocketAddress local)
ByteBuffer	bytesToRead()
MockSocketChannel	bytesToRead(byte[] buf)
MockSocketChannel	bytesToRead(ByteBuffer buf)
MockSocketChannel	bytesToWrite(int num)
boolean	connect(SocketAddress remote)
void	doClose()
boolean	finishConnect()
SocketAddress	getLocalAddress()
<T> T	getOption(SocketOption<T> name)
SocketAddress	getRemoteAddress()
protected void	implCloseSelectableChannel()
protected void	implConfigureBlocking(boolean block)
boolean	isConnected()
boolean	isConnectionPending()
int	read(ByteBuffer dst)
long	read(ByteBuffer[] dsts, int offset, int length)
ByteBuffer	recorder()
MockSocketChannel	recorder(ByteBuffer buf)
<T> SocketChannel	setOption(SocketOption<T> name, T value)
SocketChannel	shutdownInput()
SocketChannel	shutdownOutput()
Socket	socket()
Set<SocketOption<?>>	supportedOptions()
int	write(ByteBuffer buf)
long	write(ByteBuffer[] srcs, int offset, int length)

Methods inherited from class java.nio.channels.SocketChannel

open, open, read, validOps, write

Methods inherited from class java.nio.channels.spi.AbstractSelectableChannel

blockingLock, configureBlocking, implCloseChannel, isBlocking, isRegistered, keyFor, provider, register

Methods inherited from class java.nio.channels.SelectableChannel

register

Methods inherited from class java.nio.channels.spi.AbstractInterruptibleChannel

begin, close, end, isOpen

Methods inherited from class java.lang.Object

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

Methods inherited from interface java.nio.channels.Channel

close, isOpen

Field Detail

bytes_to_write

protected int bytes_to_write

bytes_to_read

protected ByteBuffer bytes_to_read

closed

protected boolean closed

recorder

protected ByteBuffer recorder

Constructor Detail

MockSocketChannel

public MockSocketChannel()

MockSocketChannel

public MockSocketChannel(SelectorProvider provider)

Initializes a new instance of this class.

Parameters:

provider - The provider that created this channel

Method Detail

bytesToWrite

public MockSocketChannel bytesToWrite(int num)

bytesToRead

public MockSocketChannel bytesToRead(byte[] buf)

bytesToRead

public MockSocketChannel bytesToRead(ByteBuffer buf)

bytesToRead

public ByteBuffer bytesToRead()

recorder

public MockSocketChannel recorder(ByteBuffer buf)

recorder

public ByteBuffer recorder()

bind

public SocketChannel bind(SocketAddress local)
                   throws IOException

Specified by:

bind in interface NetworkChannel

Overrides:

bind in class SocketChannel

Throws:

IOException

doClose

public void doClose()

setOption

public <T> SocketChannel setOption(SocketOption<T> name,
                                   T value)
                            throws IOException

Specified by:

setOption in interface NetworkChannel

Specified by:

setOption in class SocketChannel

Throws:

IOException

getOption

public <T> T getOption(SocketOption<T> name)
                throws IOException

Throws:

IOException

supportedOptions

public Set<SocketOption<?>> supportedOptions()

shutdownInput

public SocketChannel shutdownInput()
                            throws IOException

Specified by:

shutdownInput in class SocketChannel

Throws:

IOException

shutdownOutput

public SocketChannel shutdownOutput()
                             throws IOException

Specified by:

shutdownOutput in class SocketChannel

Throws:

IOException

socket

public Socket socket()

Specified by:

socket in class SocketChannel

isConnected

public boolean isConnected()

Specified by:

isConnected in class SocketChannel

isConnectionPending

public boolean isConnectionPending()

Specified by:

isConnectionPending in class SocketChannel

connect

public boolean connect(SocketAddress remote)
                throws IOException

Specified by:

connect in class SocketChannel

Throws:

IOException

finishConnect

public boolean finishConnect()
                      throws IOException

Specified by:

finishConnect in class SocketChannel

Throws:

IOException

getRemoteAddress

public SocketAddress getRemoteAddress()
                               throws IOException

Specified by:

getRemoteAddress in class SocketChannel

Throws:

IOException

read

public int read(ByteBuffer dst)
         throws IOException

Specified by:

read in interface ReadableByteChannel

Specified by:

read in class SocketChannel

Throws:

IOException

read

public long read(ByteBuffer[] dsts,
                 int offset,
                 int length)
          throws IOException

Specified by:

read in interface ScatteringByteChannel

Specified by:

read in class SocketChannel

Throws:

IOException

write

public int write(ByteBuffer buf)
          throws IOException

Specified by:

write in interface WritableByteChannel

Specified by:

write in class SocketChannel

Throws:

IOException

write

public long write(ByteBuffer[] srcs,
                  int offset,
                  int length)
           throws IOException

Specified by:

write in interface GatheringByteChannel

Specified by:

write in class SocketChannel

Throws:

IOException

getLocalAddress

public SocketAddress getLocalAddress()
                              throws IOException

Specified by:

getLocalAddress in interface NetworkChannel

Specified by:

getLocalAddress in class SocketChannel

Throws:

IOException

implCloseSelectableChannel

protected void implCloseSelectableChannel()
                                   throws IOException

Specified by:

implCloseSelectableChannel in class AbstractSelectableChannel

Throws:

IOException

implConfigureBlocking

protected void implConfigureBlocking(boolean block)
                              throws IOException

Specified by:

implConfigureBlocking in class AbstractSelectableChannel

Throws:

IOException