Class Connection

java.lang.Object

org.jgroups.blocks.cs.Connection

All Implemented Interfaces:

Closeable, AutoCloseable

Direct Known Subclasses:

NioConnection, TcpConnection

public abstract class Connection
extends Object
implements Closeable

Represents a connection to a peer

Field Summary

Fields

Modifier and Type	Field	Description
protected boolean	closed_gracefully
static final byte[]	cookie
static final int	GRACEFUL_CLOSE
protected long	last_access
protected Address	peer_addr
protected final Lock	send_lock
protected BaseServer	server

Constructor Summary

Constructors

Constructor	Description
Connection()

Method Summary

Modifier and Type	Method	Description
abstract void	close(boolean graceful)
abstract void	connect(Address dest)
abstract void	flush()
protected long	getTimestamp()
abstract boolean	isClosed()
boolean	isClosedGracefully()
abstract boolean	isConnected()
abstract boolean	isConnectionPending()
boolean	isExpired(long now)
abstract Address	localAddress()
Address	peerAddress()
abstract void	send(byte[] buf, int offset, int length)
abstract void	send(ByteBuffer buf)
abstract void	send(ByteBuffer[] bufs)
Connection	setClosedGracefully(boolean b)
abstract void	start()
abstract String	status()
protected void	updateLastAccessed()

Methods inherited from class Object

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

Methods inherited from interface Closeable

close

Field Details

cookie

public static final byte[] cookie

GRACEFUL_CLOSE

public static final int GRACEFUL_CLOSE

See Also:

• Constant Field Values

server

protected BaseServer server

peer_addr

protected Address peer_addr

last_access

protected long last_access

closed_gracefully

protected volatile boolean closed_gracefully

send_lock

protected final Lock send_lock

Constructor Details

Connection

public Connection()

Method Details

isConnected

public abstract boolean isConnected()

isConnectionPending

public abstract boolean isConnectionPending()

isClosed

public abstract boolean isClosed()

isClosedGracefully

public boolean isClosedGracefully()

setClosedGracefully

public Connection setClosedGracefully(boolean b)

localAddress

public abstract Address localAddress()

peerAddress

public Address peerAddress()

flush

public abstract void flush()

connect

public abstract void connect(Address dest)
                      throws Exception

Throws:

Exception

start

public abstract void start()
                    throws Exception

Throws:

Exception

send

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

Throws:

Exception

send

public abstract void send(ByteBuffer buf)
                   throws Exception

Throws:

Exception

send

public abstract void send(ByteBuffer[] bufs)
                   throws Exception

Throws:

Exception

status

public abstract String status()

close

public abstract void close(boolean graceful)
                    throws IOException

Throws:

IOException

getTimestamp

protected long getTimestamp()

updateLastAccessed

protected void updateLastAccessed()

isExpired

public boolean isExpired(long now)