org.jgroups.nio

Class NioConnection

java.lang.Object

org.jgroups.nio.NioConnection

All Implemented Interfaces:

java.io.Closeable, java.lang.AutoCloseable, Connection<Address>

public class NioConnection
extends java.lang.Object
implements Connection<Address>

An NIO based impl of Connection

Since:

3.6.5

Author:

Bela Ban

Field Summary

Fields

Modifier and Type	Field and Description
protected java.nio.channels.SocketChannel	channel
protected java.nio.channels.SelectionKey	key
protected long	last_access
protected Address	peer_addr
protected Buffers	recv_buf
protected java.util.concurrent.locks.Lock	recv_lock
protected Buffers	send_buf
protected java.util.concurrent.locks.Lock	send_lock
protected NioServer	server
protected boolean	write_interest_set

Constructor Summary

Constructors

Constructor and Description
NioConnection(Address peer_addr, NioServer server) Creates a connection stub and binds it, use connect(Address) to connect
NioConnection(java.nio.channels.SocketChannel channel, NioServer server)

Method Summary

Modifier and Type	Method and Description
void	close()
void	connect(Address dest)
protected long	getTimestamp()
boolean	isConnected()
boolean	isExpired(long now)
boolean	isOpen()
java.nio.channels.SelectionKey	key()
NioConnection	key(java.nio.channels.SelectionKey k)
Address	peerAddress()
protected Address	readPeerAddress(java.nio.ByteBuffer buf)
void	receive() Read the length first, then the actual data
void	receive(int max_num_msgs_to_receive) Tries to receive up to max_num_msgs_to_receive messages in one go
void	send()
void	send(byte[] buf, int offset, int length)
void	send(java.nio.ByteBuffer buf) Sends a message.
protected void	sendLocalAddress(Address local_addr)
protected void	setSocketParameters(java.net.Socket client_sock)
void	start()
java.lang.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 java.nio.channels.SocketChannel channel

key

protected java.nio.channels.SelectionKey key

peer_addr

protected Address peer_addr

last_access

protected long last_access

server

protected final NioServer server

send_buf

protected final Buffers send_buf

write_interest_set

protected boolean write_interest_set

send_lock

protected final java.util.concurrent.locks.Lock send_lock

recv_buf

protected Buffers recv_buf

recv_lock

protected final java.util.concurrent.locks.Lock recv_lock

Constructor Detail

NioConnection

public NioConnection(Address peer_addr,
                     NioServer server)
              throws java.lang.Exception

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

Throws:

java.lang.Exception

NioConnection

public NioConnection(java.nio.channels.SocketChannel channel,
                     NioServer server)
              throws java.lang.Exception

Throws:

java.lang.Exception

Method Detail

isOpen

public boolean isOpen()

Specified by:

isOpen in interface Connection<Address>

isConnected

public boolean isConnected()

Specified by:

isConnected in interface Connection<Address>

isExpired

public boolean isExpired(long now)

Specified by:

isExpired in interface Connection<Address>

updateLastAccessed

protected void updateLastAccessed()

peerAddress

public Address peerAddress()

key

public java.nio.channels.SelectionKey key()

key

public NioConnection key(java.nio.channels.SelectionKey k)

connect

public void connect(Address dest)
             throws java.lang.Exception

Specified by:

connect in interface Connection<Address>

Throws:

java.lang.Exception

start

public void start()
           throws java.lang.Exception

Specified by:

start in interface Connection<Address>

Throws:

java.lang.Exception

send

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

Specified by:

send in interface Connection<Address>

Throws:

java.lang.Exception

send

public void send(java.nio.ByteBuffer buf)
          throws java.lang.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 interface Connection<Address>

Parameters:

buf -

Throws:

java.lang.Exception

send

public void send()
          throws java.lang.Exception

Throws:

java.lang.Exception

receive

public void receive()
             throws java.lang.Exception

Read the length first, then the actual data

Throws:

java.lang.Exception

receive

public void receive(int max_num_msgs_to_receive)
             throws java.lang.Exception

Tries to receive up to max_num_msgs_to_receive messages in one go

Parameters:

max_num_msgs_to_receive -

Throws:

java.lang.Exception

close

public void close()
           throws java.io.IOException

Specified by:

close in interface java.io.Closeable

Specified by:

close in interface java.lang.AutoCloseable

Throws:

java.io.IOException

toString

public java.lang.String toString()

Overrides:

toString in class java.lang.Object

getTimestamp

protected long getTimestamp()

writeInterest

protected void writeInterest(boolean register)

setSocketParameters

protected void setSocketParameters(java.net.Socket client_sock)
                            throws java.net.SocketException

Throws:

java.net.SocketException

sendLocalAddress

protected void sendLocalAddress(Address local_addr)
                         throws java.lang.Exception

Throws:

java.lang.Exception

readPeerAddress

protected Address readPeerAddress(java.nio.ByteBuffer buf)
                           throws java.lang.Exception

Throws:

java.lang.Exception