atavism.server.network

Class ClientConnection

java.lang.Object

atavism.server.network.ClientConnection

Direct Known Subclasses:

ClientTCPConnection, ClientUDPConnection, RDPConnection

public abstract class ClientConnection
extends java.lang.Object

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static interface	ClientConnection.AcceptCallback
static interface	ClientConnection.MessageCallback

Field Summary

Fields

Modifier and Type	Field and Description
long	aggregatedReceives
long	aggregatedSends Some per-connection statistics
static int	connectionTypeRDP
static int	connectionTypeTCP
static int	connectionTypeUDP
protected java.util.concurrent.locks.Lock	lock
protected static boolean	logMessageContents Set this to true to log message contents
protected PacketAggregator	packetAggregator
long	receivedMessagesAggregated
long	sentMessagesAggregated
long	unaggregatedReceives
long	unaggregatedSends

Constructor Summary

Constructors

Constructor and Description
ClientConnection()

Method Summary

Modifier and Type	Method and Description
abstract boolean	canSend()
abstract boolean	canSendInternal()
abstract void	close()
abstract int	connectionKind()
abstract void	connectionReset()
PacketAggregator	getAggregator()
java.lang.Object	getAssociation()
java.util.concurrent.locks.Lock	getLock()
static boolean	getLogMessageContents()
abstract java.lang.String	IPAndPort()
abstract boolean	isOpen()
abstract void	open(java.lang.String hostname, int remotePort)
abstract void	registerMessageCallback(ClientConnection.MessageCallback pcallback)
abstract void	send(AOByteBuffer buf)
abstract boolean	sendIfPossible(AOByteBuffer buf)
abstract boolean	sendInternal(AOByteBuffer buf)
abstract int	sendMultibuf(java.util.List<AOByteBuffer> subMessages, int currentSize)
void	setAssociation(java.lang.Object object)
static void	setLogMessageContents(boolean logMessageContents)
java.lang.String	toString()

Methods inherited from class java.lang.Object

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

Field Detail

packetAggregator

protected PacketAggregator packetAggregator

aggregatedSends

public long aggregatedSends

Some per-connection statistics

sentMessagesAggregated

public long sentMessagesAggregated

unaggregatedSends

public long unaggregatedSends

aggregatedReceives

public long aggregatedReceives

receivedMessagesAggregated

public long receivedMessagesAggregated

unaggregatedReceives

public long unaggregatedReceives

connectionTypeRDP

public static final int connectionTypeRDP

See Also:

Constant Field Values

connectionTypeTCP

public static final int connectionTypeTCP

See Also:

Constant Field Values

connectionTypeUDP

public static final int connectionTypeUDP

See Also:

Constant Field Values

logMessageContents

protected static boolean logMessageContents

Set this to true to log message contents

lock

protected transient java.util.concurrent.locks.Lock lock

Constructor Detail

ClientConnection

public ClientConnection()

Method Detail

registerMessageCallback

public abstract void registerMessageCallback(ClientConnection.MessageCallback pcallback)

connectionReset

public abstract void connectionReset()

send

public abstract void send(AOByteBuffer buf)

sendInternal

public abstract boolean sendInternal(AOByteBuffer buf)

sendIfPossible

public abstract boolean sendIfPossible(AOByteBuffer buf)

sendMultibuf

public abstract int sendMultibuf(java.util.List<AOByteBuffer> subMessages,
                                 int currentSize)

open

public abstract void open(java.lang.String hostname,
                          int remotePort)

close

public abstract void close()

connectionKind

public abstract int connectionKind()

isOpen

public abstract boolean isOpen()

canSend

public abstract boolean canSend()

canSendInternal

public abstract boolean canSendInternal()

IPAndPort

public abstract java.lang.String IPAndPort()

getAssociation

public java.lang.Object getAssociation()

setAssociation

public void setAssociation(java.lang.Object object)

getLock

public java.util.concurrent.locks.Lock getLock()

getAggregator

public PacketAggregator getAggregator()

toString

public java.lang.String toString()

Overrides:

toString in class java.lang.Object

getLogMessageContents

public static boolean getLogMessageContents()

setLogMessageContents

public static void setLogMessageContents(boolean logMessageContents)