org.jgroups.blocks.cs

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 and Description
protected class	NioConnection.Reader
protected static class	NioConnection.State

Field Summary

Fields

Modifier and Type	Field and Description
protected SocketChannel	channel
protected boolean	copy_on_partial_write
protected SelectionKey	key
protected int	partial_writes
protected NioConnection.Reader	reader
protected long	reader_idle_time
protected Buffers	recv_buf
protected Buffers	send_buf
protected Lock	send_lock
protected NioBaseServer	server
protected boolean	write_interest_set

Fields inherited from class org.jgroups.blocks.cs.Connection

cookie, last_access, peer_addr

Constructor Summary

Constructors

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

Method Summary

Modifier and Type	Method and Description
protected boolean	_receive(boolean update)
void	clearSelectionKey(int interest_ops)
void	close()
void	connect(Address dest)
protected void	connect(Address dest, boolean send_local_addr)
boolean	copyOnPartialWrite()
NioConnection	copyOnPartialWrite(boolean b)
protected static byte[]	getBuffer(ByteBuffer buf)
protected long	getTimestamp()
boolean	isConnected()
boolean	isExpired(long now)
boolean	isOpen()
SelectionKey	key()
NioConnection	key(SelectionKey k)
Address	localAddress()
protected static ByteBuffer	makeLengthBuffer(ByteBuffer buf)
int	numPartialWrites()
Address	peerAddress()
long	readerIdleTime()
NioConnection	readerIdleTime(long t)
boolean	readerRunning()
protected Address	readPeerAddress()
void	receive() Read the length first, then the actual data.
void	registerSelectionKey(int interest_ops)
void	send()
void	send(byte[] buf, int offset, int length)
void	send(ByteBuffer buf) Sends a message.
protected void	send(ByteBuffer buf, boolean send_length)
protected void	sendLocalAddress(Address local_addr)
protected void	setSocketParameters(Socket client_sock)
void	start()
protected String	status()
String	toString()
protected void	updateLastAccessed()
protected void	writeInterest(boolean register)

Methods inherited from class java.lang.Object

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

Field Detail

channel

protected SocketChannel channel

key

protected SelectionKey key

server

protected final NioBaseServer server

send_buf

protected final Buffers send_buf

write_interest_set

protected boolean write_interest_set

copy_on_partial_write

protected boolean copy_on_partial_write

partial_writes

protected int partial_writes

send_lock

protected final Lock send_lock

recv_buf

protected Buffers recv_buf

reader

protected NioConnection.Reader reader

reader_idle_time

protected long reader_idle_time

Constructor Detail

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 Detail

isOpen

public boolean isOpen()

Specified by:

isOpen in class Connection

isConnected

public boolean isConnected()

Specified by:

isConnected in class Connection

isExpired

public boolean isExpired(long now)

Specified by:

isExpired in class Connection

updateLastAccessed

protected void updateLastAccessed()

localAddress

public Address localAddress()

Specified by:

localAddress in class Connection

peerAddress

public Address peerAddress()

Specified by:

peerAddress 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()

readerIdleTime

public long readerIdleTime()

readerIdleTime

public NioConnection readerIdleTime(long t)

readerRunning

public boolean readerRunning()

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

Parameters:

buf -

Throws:

Exception

send

public void send()
          throws Exception

Throws:

Exception

receive

public void receive()
             throws Exception

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

Throws:

Exception

send

protected void send(ByteBuffer buf,
                    boolean send_length)
             throws Exception

Throws:

Exception

_receive

protected boolean _receive(boolean update)
                    throws Exception

Throws:

Exception

close

public void close()
           throws IOException

Throws:

IOException

toString

public String toString()

Overrides:

toString in class Object

status

protected String status()

getTimestamp

protected long getTimestamp()

writeInterest

protected void writeInterest(boolean register)

setSocketParameters

protected void setSocketParameters(Socket client_sock)
                            throws SocketException

Throws:

SocketException

sendLocalAddress

protected void sendLocalAddress(Address local_addr)
                         throws Exception

Throws:

Exception

readPeerAddress

protected Address readPeerAddress()
                           throws Exception

Throws:

Exception

getBuffer

protected static byte[] getBuffer(ByteBuffer buf)

makeLengthBuffer

protected static ByteBuffer makeLengthBuffer(ByteBuffer buf)