Class NioConnection

java.lang.Object

org.jgroups.blocks.cs.Connection

org.jgroups.blocks.cs.NioConnection

All Implemented Interfaces:

Closeable, AutoCloseable

public class NioConnection
extends Connection

An NIO based impl of Connection

Since:

3.6.5

Author:

Bela Ban

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static class	NioConnection.PeerAddressReader	Reads a peer address from a SocketChannel.

Field Summary

Fields

Modifier and Type	Field	Description
protected final SocketChannel	channel
protected ByteBuffer	cookie_buffer
protected boolean	copy_on_partial_write
protected ByteBuffer	graceful_close_buf
protected SelectionKey	key
protected ByteBuffer	length_buf
protected final MessageReader	message_reader
protected int	num_drops
protected int	partial_writes
protected final NioConnection.PeerAddressReader	peer_addr_reader
protected final Buffers	send_buf

Fields inherited from class Connection

closed_gracefully, cookie, GRACEFUL_CLOSE, last_access, peer_addr, send_lock, server

Constructor Summary

Constructors

Constructor	Description
NioConnection(SocketChannel channel, NioBaseServer server)
NioConnection(Address peer_addr, NioBaseServer server)	Creates a connection stub and binds it, use connect(Address) to connect

Method Summary

Modifier and Type	Method	Description
protected boolean	_read()
protected void	addBuffer(ByteBuffer buf)
protected void	addBuffers(ByteBuffer[] bufs)
void	clearSelectionKey(int interest_ops)
void	close()
void	close(boolean graceful)
void	connect(Address dest)
protected void	connect(Address dest, boolean send_local_addr)
boolean	copyOnPartialWrite()
NioConnection	copyOnPartialWrite(boolean b)
protected ByteBuffer	createBuffer(int size)
protected void	createBuffers()
protected void	doClose()
void	flush()
boolean	isClosed()
boolean	isConnected()
boolean	isConnectionPending()
SelectionKey	key()
NioConnection	key(SelectionKey k)
Address	localAddress()
int	numDrops()
int	numPartialWrites()
void	read()	Read the length first, then the actual data.
void	registerSelectionKey(int interest_ops)
NioConnection	reset()
void	send(byte[] buf, int offset, int length)
protected void	send(Runnable add_buf)	Sends the buffers currently present in send_buf
void	send(ByteBuffer buf)	Sends a message.
void	send(ByteBuffer[] bufs)
protected void	sendLocalAddress(Address local_addr)
protected void	setSocketParameters(Socket client_sock)
void	start()
String	status()
String	toString()

Methods inherited from class Connection

getTimestamp, isClosedGracefully, isExpired, peerAddress, setClosedGracefully, updateLastAccessed

Methods inherited from class Object

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

Field Details

channel

protected final SocketChannel channel

key

protected SelectionKey key

send_buf

protected final Buffers send_buf

message_reader

protected final MessageReader message_reader

copy_on_partial_write

protected boolean copy_on_partial_write

partial_writes

protected int partial_writes

num_drops

protected int num_drops

peer_addr_reader

protected final NioConnection.PeerAddressReader peer_addr_reader

length_buf

protected ByteBuffer length_buf

graceful_close_buf

protected ByteBuffer graceful_close_buf

cookie_buffer

protected ByteBuffer cookie_buffer

Constructor Details

NioConnection

public NioConnection(Address peer_addr,
 NioBaseServer server)
              throws Exception

Creates a connection stub and binds it, use connect(Address) to connect

Throws:

Exception

NioConnection

public NioConnection(SocketChannel channel,
 NioBaseServer server)
              throws Exception

Throws:

Exception

Method Details

isConnected

public boolean isConnected()

Specified by:

isConnected in class Connection

isConnectionPending

public boolean isConnectionPending()

Specified by:

isConnectionPending in class Connection

isClosed

public boolean isClosed()

Specified by:

isClosed in class Connection

localAddress

public Address localAddress()

Specified by:

localAddress in class Connection

key

public SelectionKey key()

key

public NioConnection key(SelectionKey k)

copyOnPartialWrite

public NioConnection copyOnPartialWrite(boolean b)

copyOnPartialWrite

public boolean copyOnPartialWrite()

numPartialWrites

public int numPartialWrites()

numDrops

public int numDrops()

reset

public NioConnection reset()

registerSelectionKey

public void registerSelectionKey(int interest_ops)

clearSelectionKey

public void clearSelectionKey(int interest_ops)

connect

public void connect(Address dest)
             throws Exception

Specified by:

connect in class Connection

Throws:

Exception

connect

protected void connect(Address dest,
 boolean send_local_addr)
                throws Exception

Throws:

Exception

start

public void start()
           throws Exception

Specified by:

start in class Connection

Throws:

Exception

send

public void send(byte[] buf,
 int offset,
 int length)
          throws Exception

Specified by:

send in class Connection

Throws:

Exception

send

public void send(ByteBuffer buf)
          throws Exception

Sends a message. If the previous write didn't complete, tries to complete it. If this still doesn't complete, the message is dropped (needs to be retransmitted, e.g. by UNICAST3 or NAKACK2).

Specified by:

send in class Connection

Throws:

Exception

send

public void send(ByteBuffer[] bufs)
          throws Exception

Specified by:

send in class Connection

Throws:

Exception

read

public void read()
          throws Exception

Read the length first, then the actual data. This method is not reentrant and access must be synchronized

Throws:

Exception

close

public void close()
           throws IOException

Throws:

IOException

close

public void close(boolean graceful)
           throws IOException

Specified by:

close in class Connection

Throws:

IOException

flush

public void flush()

Specified by:

flush in class Connection

toString

public String toString()

Overrides:

toString in class Object

status

public String status()

Specified by:

status in class Connection

_read

protected boolean _read()
                 throws Exception

Throws:

Exception

send

protected void send(Runnable add_buf)
             throws Exception

Sends the buffers currently present in send_buf

Throws:

Exception - If the send failed, e.g. because the channel was closed

addBuffer

protected void addBuffer(ByteBuffer buf)

addBuffers

protected void addBuffers(ByteBuffer[] bufs)

doClose

protected void doClose()

setSocketParameters

protected void setSocketParameters(Socket client_sock)
                            throws SocketException

Throws:

SocketException

sendLocalAddress

protected void sendLocalAddress(Address local_addr)
                         throws Exception

Throws:

Exception

createBuffers

protected void createBuffers()

createBuffer

protected ByteBuffer createBuffer(int size)