Package org.jgroups.blocks.cs

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
static final byte[]	cookie
protected long	last_access
protected Address	peer_addr
protected BaseServer	server

Constructor Summary

Constructors

Constructor	Description
Connection()

Method Summary

Modifier and Type	Method	Description
abstract void	connect(Address dest)
abstract void	flush()
protected long	getTimestamp()
abstract boolean	isClosed()
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	start()
abstract String	status()
protected void	updateLastAccessed()

Methods inherited from class java.lang.Object

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

Methods inherited from interface java.io.Closeable

close

Field Details

cookie

public static final byte[] cookie

server

protected BaseServer server

peer_addr

protected Address peer_addr

last_access

protected long last_access

Constructor Details

Connection

public Connection()

Method Details

isConnected

public abstract boolean isConnected()

isConnectionPending

public abstract boolean isConnectionPending()

isClosed

public abstract boolean isClosed()

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

status

public abstract String status()

getTimestamp

protected long getTimestamp()

updateLastAccessed

protected void updateLastAccessed()

isExpired

public boolean isExpired(long now)