ATAS
Loading...
Searching...
No Matches
ATAS.DataFeedsCore.SessionServer.SocketSession< TMessage > Class Template Referenceabstract
Inheritance diagram for ATAS.DataFeedsCore.SessionServer.SocketSession< TMessage >:
[legend]
Collaboration diagram for ATAS.DataFeedsCore.SessionServer.SocketSession< TMessage >:
[legend]

Public Member Functions

override void Start ()
 
override void Stop ()
 
void Send (TMessage message)
 
- Public Member Functions inherited from ATAS.DataFeedsCore.SessionServer.SessionInfo
abstract void Start ()
 
abstract void Stop ()
 
void SetLoggedIn ()
 

Protected Member Functions

 SocketSession (SessionInfoType type, Socket socket, int maxQueueSize)
 
 SocketSession (SessionInfoType type, Socket socket)
 
abstract void Process (SocketAsyncEventArgs e)
 
abstract void SetSendBuffer (ConcurrentQueue< TMessage > queue, SocketAsyncEventArgs e)
 
abstract void SetReceiveBuffer (SocketAsyncEventArgs e)
 
abstract void SendLogout (string reason=null)
 
void CloseClientSocket (string reason=null)
 
- Protected Member Functions inherited from ATAS.DataFeedsCore.SessionServer.SessionInfo
 SessionInfo (SessionInfoType type, EndPoint address)
 

Properties

int QueueLength [get]
 
int MaxQueueSize [get]
 
- Properties inherited from ATAS.DataFeedsCore.SessionServer.SessionInfo
SessionInfoType Type [get]
 
EndPoint Address [get]
 
ServerStates State [get, protected set]
 
User User [get, set]
 

Constructor & Destructor Documentation

◆ SocketSession() [1/2]

ATAS.DataFeedsCore.SessionServer.SocketSession< TMessage >.SocketSession ( SessionInfoType  type,
Socket  socket,
int  maxQueueSize 
)
protected

◆ SocketSession() [2/2]

ATAS.DataFeedsCore.SessionServer.SocketSession< TMessage >.SocketSession ( SessionInfoType  type,
Socket  socket 
)
protected

Member Function Documentation

◆ CloseClientSocket()

void ATAS.DataFeedsCore.SessionServer.SocketSession< TMessage >.CloseClientSocket ( string  reason = null)
protected

◆ Process()

abstract void ATAS.DataFeedsCore.SessionServer.SocketSession< TMessage >.Process ( SocketAsyncEventArgs  e)
protectedpure virtual

◆ Send()

void ATAS.DataFeedsCore.SessionServer.SocketSession< TMessage >.Send ( TMessage  message)

◆ SendLogout()

abstract void ATAS.DataFeedsCore.SessionServer.SocketSession< TMessage >.SendLogout ( string  reason = null)
protectedpure virtual

◆ SetReceiveBuffer()

abstract void ATAS.DataFeedsCore.SessionServer.SocketSession< TMessage >.SetReceiveBuffer ( SocketAsyncEventArgs  e)
protectedpure virtual

◆ SetSendBuffer()

abstract void ATAS.DataFeedsCore.SessionServer.SocketSession< TMessage >.SetSendBuffer ( ConcurrentQueue< TMessage >  queue,
SocketAsyncEventArgs  e 
)
protectedpure virtual

◆ Start()

◆ Stop()

Property Documentation

◆ MaxQueueSize

int ATAS.DataFeedsCore.SessionServer.SocketSession< TMessage >.MaxQueueSize
get

◆ QueueLength

int ATAS.DataFeedsCore.SessionServer.SocketSession< TMessage >.QueueLength
get

The documentation for this class was generated from the following file: