Atavism Version 2018.1AGIS API

atavism.server.network
Class ClientConnection

java.lang.Object
  extended by atavism.server.network.ClientConnection
Direct Known Subclasses:
ClientTCPConnection, ClientUDPConnection, RDPConnection

public abstract class ClientConnection
extends java.lang.Object


Nested Class Summary
static interface ClientConnection.AcceptCallback
           
static interface ClientConnection.MessageCallback
           
 
Field Summary
 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
ClientConnection()
           
 
Method Summary
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)


Copyright © 2018 Dragonsan Studios Sp. z o.o.