TROSCServerWorker

Overview

Location

Implements

 

constructor Create (TROBaseSuperTcpConnection)    (declared in TROBaseSuperChannelWorker)

constructor Create(ABaseSuperConnection: TROBaseSuperTcpConnection)

Parameters:

  • ABaseSuperConnection:

constructor Create(aOwner: TROBaseSuperTCPServer; ABaseSuperConnection: TROBaseSuperTcpConnection)

Parameters:

  • aOwner:
  • ABaseSuperConnection:

BaseSuperConnection  protected    (declared in TROBaseSuperChannelWorker)

property BaseSuperConnection: TROBaseSuperTcpConnection read write

BeginWriteLock    (declared in TROBaseSuperChannelWorker)

procedure BeginWriteLock

ClientID    (declared in TROBaseSuperChannelWorker)

property ClientID: TGuid read write

Connected  protected override

procedure Connected

Disconnect    (declared in TROBaseSuperChannelWorker)

procedure Disconnect

Disconnected  protected override

procedure Disconnected(var RestartLoop: Boolean)

Parameters:

  • RestartLoop:

DispatchEvent  protected

This method is called by the event manager to notify the server about a new event.

procedure DispatchEvent(anEventDataItem: TROEventData; aSessionReference: TGUID; aSender: TObject)

Parameters:

  • anEventDataItem: Represents an event that fires.
  • aSessionReference: Unique identifier that represents the session.
  • aSender: Indicates the object that receives the event.

DoExecute    (declared in TROBaseSuperChannelWorker)

procedure DoExecute

EndWriteLock    (declared in TROBaseSuperChannelWorker)

procedure EndWriteLock

EventsRegistered  protected

This method is called whenever the event manager registers for the specified client.

procedure EventsRegistered(aSender: TObject; aClient: TGUID)

Parameters:

  • aSender: Object that will receive the event.
  • aClient: GUID that specifies the client.

GenerateId    (declared in TROBaseSuperChannelWorker)

function GenerateId: Integer

GetDefaultResponse  protected override

function GetDefaultResponse: string

GetTransportObject  protected

Returns itself.

function GetTransportObject: TObject

Idle  protected virtual    (declared in TROBaseSuperChannelWorker)

procedure Idle

IncomingData  protected override

procedure IncomingData(Id: Integer; aData: TStream)

Parameters:

  • Id:
  • aData:

IntSendData  protected    (declared in TROBaseSuperChannelWorker)

function IntSendData(Id: Integer; aData: TStream): IROPackageAck

Parameters:

  • Id:
  • aData:

IsConnected    (declared in TROBaseSuperChannelWorker)

property IsConnected: Boolean read write

IsServer  protected    (declared in TROBaseSuperChannelWorker)

property IsServer: Boolean read write

LastData  protected    (declared in TROBaseSuperChannelWorker)

property LastData: TDateTime read write

MaxPackageSize    (declared in TROBaseSuperChannelWorker)

property MaxPackageSize: Integer read write

OnProgress    (declared in TROBaseSuperChannelWorker)

property OnProgress: TProgressEvent read write
delegate: procedure OnProgress(iSender: TObject; iType: TProgressType; iDirection: TProgressDirection; iTransferred: integer; iTotal: integer)

Owner

property Owner: TROBaseSuperTCPServer read write

PingFrequency  protected    (declared in TROBaseSuperChannelWorker)

property PingFrequency: Integer read write

PingTimeout  protected    (declared in TROBaseSuperChannelWorker)

property PingTimeout: Integer read write

ProcessOption  protected    (declared in TROBaseSuperChannelWorker)

procedure ProcessOption(Data: TStream)

Parameters:

  • Data:

ReadStream  protected    (declared in TROBaseSuperChannelWorker)

function ReadStream(aDest: TStream; aLen: Integer): Boolean

Parameters:

  • aDest:
  • aLen:

SendError    (declared in TROBaseSuperChannelWorker)

procedure SendError(Id: Integer; Error: Byte)

Parameters:

  • Id:
  • Error:

SendOptions  protected    (declared in TROBaseSuperChannelWorker)

procedure SendOptions(aData: ROUTF8String)

Parameters:

  • aData:

SendPackage    (declared in TROBaseSuperChannelWorker)

function SendPackage(aData: TStream; Id: Integer): IROPackageAck

Parameters:

  • aData:
  • Id:

SetAckDetails  protected virtual    (declared in TROBaseSuperChannelWorker)

procedure SetAckDetails(Id: Integer; Oke: Boolean; ErrorNo: Integer)

Parameters:

  • Id:
  • Oke:
  • ErrorNo:

SkipAck    (declared in TROBaseSuperChannelWorker)

property SkipAck: Boolean read write

SupportsOptions  protected    (declared in TROBaseSuperChannelWorker)

procedure SupportsOptions

WaitForAck    (declared in TROBaseSuperChannelWorker)

class procedure WaitForAck(pkg: IROPackageAck; Timeout: Integer)

Parameters:

  • pkg:
  • Timeout:

 

BaseSuperConnection  protected    (declared in TROBaseSuperChannelWorker)

property BaseSuperConnection: TROBaseSuperTcpConnection read write

ClientID    (declared in TROBaseSuperChannelWorker)

property ClientID: TGuid read write

IsConnected    (declared in TROBaseSuperChannelWorker)

property IsConnected: Boolean read write

IsServer  protected    (declared in TROBaseSuperChannelWorker)

property IsServer: Boolean read write

LastData  protected    (declared in TROBaseSuperChannelWorker)

property LastData: TDateTime read write

MaxPackageSize    (declared in TROBaseSuperChannelWorker)

property MaxPackageSize: Integer read write

Owner

property Owner: TROBaseSuperTCPServer read write

PingFrequency  protected    (declared in TROBaseSuperChannelWorker)

property PingFrequency: Integer read write

PingTimeout  protected    (declared in TROBaseSuperChannelWorker)

property PingTimeout: Integer read write

SkipAck    (declared in TROBaseSuperChannelWorker)

property SkipAck: Boolean read write

 

WaitForAck    (declared in TROBaseSuperChannelWorker)

class procedure WaitForAck(pkg: IROPackageAck; Timeout: Integer)

Parameters:

  • pkg:
  • Timeout:

 

constructor Create (TROBaseSuperTcpConnection)    (declared in TROBaseSuperChannelWorker)

constructor Create(ABaseSuperConnection: TROBaseSuperTcpConnection)

Parameters:

  • ABaseSuperConnection:

constructor Create(aOwner: TROBaseSuperTCPServer; ABaseSuperConnection: TROBaseSuperTcpConnection)

Parameters:

  • aOwner:
  • ABaseSuperConnection:

BeginWriteLock    (declared in TROBaseSuperChannelWorker)

procedure BeginWriteLock

Connected  protected override

procedure Connected

Disconnect    (declared in TROBaseSuperChannelWorker)

procedure Disconnect

Disconnected  protected override

procedure Disconnected(var RestartLoop: Boolean)

Parameters:

  • RestartLoop:

DispatchEvent  protected

This method is called by the event manager to notify the server about a new event.

procedure DispatchEvent(anEventDataItem: TROEventData; aSessionReference: TGUID; aSender: TObject)

Parameters:

  • anEventDataItem: Represents an event that fires.
  • aSessionReference: Unique identifier that represents the session.
  • aSender: Indicates the object that receives the event.

DoExecute    (declared in TROBaseSuperChannelWorker)

procedure DoExecute

EndWriteLock    (declared in TROBaseSuperChannelWorker)

procedure EndWriteLock

EventsRegistered  protected

This method is called whenever the event manager registers for the specified client.

procedure EventsRegistered(aSender: TObject; aClient: TGUID)

Parameters:

  • aSender: Object that will receive the event.
  • aClient: GUID that specifies the client.

GenerateId    (declared in TROBaseSuperChannelWorker)

function GenerateId: Integer

GetDefaultResponse  protected override

function GetDefaultResponse: string

GetTransportObject  protected

Returns itself.

function GetTransportObject: TObject

Idle  protected virtual    (declared in TROBaseSuperChannelWorker)

procedure Idle

IncomingData  protected override

procedure IncomingData(Id: Integer; aData: TStream)

Parameters:

  • Id:
  • aData:

IntSendData  protected    (declared in TROBaseSuperChannelWorker)

function IntSendData(Id: Integer; aData: TStream): IROPackageAck

Parameters:

  • Id:
  • aData:

ProcessOption  protected    (declared in TROBaseSuperChannelWorker)

procedure ProcessOption(Data: TStream)

Parameters:

  • Data:

ReadStream  protected    (declared in TROBaseSuperChannelWorker)

function ReadStream(aDest: TStream; aLen: Integer): Boolean

Parameters:

  • aDest:
  • aLen:

SendError    (declared in TROBaseSuperChannelWorker)

procedure SendError(Id: Integer; Error: Byte)

Parameters:

  • Id:
  • Error:

SendOptions  protected    (declared in TROBaseSuperChannelWorker)

procedure SendOptions(aData: ROUTF8String)

Parameters:

  • aData:

SendPackage    (declared in TROBaseSuperChannelWorker)

function SendPackage(aData: TStream; Id: Integer): IROPackageAck

Parameters:

  • aData:
  • Id:

SetAckDetails  protected virtual    (declared in TROBaseSuperChannelWorker)

procedure SetAckDetails(Id: Integer; Oke: Boolean; ErrorNo: Integer)

Parameters:

  • Id:
  • Oke:
  • ErrorNo:

SupportsOptions  protected    (declared in TROBaseSuperChannelWorker)

procedure SupportsOptions

 

OnProgress    (declared in TROBaseSuperChannelWorker)

property OnProgress: TProgressEvent read write
delegate: procedure OnProgress(iSender: TObject; iType: TProgressType; iDirection: TProgressDirection; iTransferred: integer; iTotal: integer)