TROSCServerWorker

Overview

Location


 

constructor Create (TROBaseSuperTcpConnection)    (declared in TROBaseSuperChannelWorker)

constructor Create(ABaseSuperConnection: TROBaseSuperTcpConnection)

Parameters:

  • ABaseSuperConnection:

Creates a new instance.

constructor Create(aOwner: TROBaseSuperTCPServer; ABaseSuperConnection: TROBaseSuperTcpConnection)

Parameters:

  • aOwner:
  • ABaseSuperConnection:

BaseSuperConnection  protected    (declared in TROBaseSuperChannelWorker)

property BaseSuperConnection: TROBaseSuperTcpConnection read

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 (Boolean)  protected virtual    (declared in TROBaseSuperChannelWorker)

procedure Disconnected(var aRestartLoop: Boolean)

Parameters:

  • aRestartLoop:

Disconnected (Boolean)  protected override

procedure Disconnected(var RestartLoop: Boolean)

Parameters:

  • RestartLoop:

DoExecute    (declared in TROBaseSuperChannelWorker)

procedure DoExecute

EndWriteLock    (declared in TROBaseSuperChannelWorker)

procedure EndWriteLock

GenerateId    (declared in TROBaseSuperChannelWorker)

function GenerateId: Integer

GetDefaultResponse  protected override

function GetDefaultResponse: string

Idle  protected virtual    (declared in TROBaseSuperChannelWorker)

procedure Idle

IncomingData (Integer, TStream)  protected virtual abstract    (declared in TROBaseSuperChannelWorker)

procedure IncomingData(aId: Integer; aData: TStream)

Parameters:

  • aId:
  • aData:

IncomingData (Integer, TStream)  protected override

procedure IncomingData(Id: Integer; aData: TStream)

Parameters:

  • Id:
  • aData:

IntSendData  protected    (declared in TROBaseSuperChannelWorker)

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

Parameters:

  • aId:
  • 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

MaxPackageSize    (declared in TROBaseSuperChannelWorker)

property MaxPackageSize: Integer read write

OnProgress    (declared in TROBaseSuperChannelWorker)

property OnProgress: TProgressEvent read write
delegate: procedure OnProgress(aSender: TObject; aType: TProgressType; aDirection: TProgressDirection; aTransferred: Integer; aTotal: Integer)

Owner

property Owner: TROBaseSuperTCPServer read

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(aData: TStream)

Parameters:

  • aData:

ReadStream  protected    (declared in TROBaseSuperChannelWorker)

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

Parameters:

  • aDest:
  • aLen:

SendError    (declared in TROBaseSuperChannelWorker)

procedure SendError(aId: Integer; aError: Byte)

Parameters:

  • aId:
  • aError:

SendOptions  protected    (declared in TROBaseSuperChannelWorker)

procedure SendOptions(aData: ROUTF8String)

Parameters:

  • aData:

SendPackage    (declared in TROBaseSuperChannelWorker)

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

Parameters:

  • aData:
  • aId:

SetAckDetails  protected virtual    (declared in TROBaseSuperChannelWorker)

procedure SetAckDetails(aId: Integer; aOk: Boolean; aErrorNo: Integer)

Parameters:

  • aId:
  • aOk:
  • aErrorNo:

SkipAck    (declared in TROBaseSuperChannelWorker)

property SkipAck: Boolean read write

SupportsOptions  protected    (declared in TROBaseSuperChannelWorker)

procedure SupportsOptions

WaitForAck    (declared in TROBaseSuperChannelWorker)

class procedure WaitForAck(aPackage: IROPackageAck; aTimeout: Integer)

Parameters:

  • aPackage:
  • aTimeout:

 

BaseSuperConnection  protected    (declared in TROBaseSuperChannelWorker)

property BaseSuperConnection: TROBaseSuperTcpConnection read

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

MaxPackageSize    (declared in TROBaseSuperChannelWorker)

property MaxPackageSize: Integer read write

Owner

property Owner: TROBaseSuperTCPServer read

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(aPackage: IROPackageAck; aTimeout: Integer)

Parameters:

  • aPackage:
  • aTimeout:

 

constructor Create (TROBaseSuperTcpConnection)    (declared in TROBaseSuperChannelWorker)

constructor Create(ABaseSuperConnection: TROBaseSuperTcpConnection)

Parameters:

  • ABaseSuperConnection:

Creates a new instance.

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 (Boolean)  protected virtual    (declared in TROBaseSuperChannelWorker)

procedure Disconnected(var aRestartLoop: Boolean)

Parameters:

  • aRestartLoop:

Disconnected (Boolean)  protected override

procedure Disconnected(var RestartLoop: Boolean)

Parameters:

  • RestartLoop:

DoExecute    (declared in TROBaseSuperChannelWorker)

procedure DoExecute

EndWriteLock    (declared in TROBaseSuperChannelWorker)

procedure EndWriteLock

GenerateId    (declared in TROBaseSuperChannelWorker)

function GenerateId: Integer

GetDefaultResponse  protected override

function GetDefaultResponse: string

Idle  protected virtual    (declared in TROBaseSuperChannelWorker)

procedure Idle

IncomingData (Integer, TStream)  protected virtual abstract    (declared in TROBaseSuperChannelWorker)

procedure IncomingData(aId: Integer; aData: TStream)

Parameters:

  • aId:
  • aData:

IncomingData (Integer, TStream)  protected override

procedure IncomingData(Id: Integer; aData: TStream)

Parameters:

  • Id:
  • aData:

IntSendData  protected    (declared in TROBaseSuperChannelWorker)

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

Parameters:

  • aId:
  • aData:

ProcessOption  protected    (declared in TROBaseSuperChannelWorker)

procedure ProcessOption(aData: TStream)

Parameters:

  • aData:

ReadStream  protected    (declared in TROBaseSuperChannelWorker)

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

Parameters:

  • aDest:
  • aLen:

SendError    (declared in TROBaseSuperChannelWorker)

procedure SendError(aId: Integer; aError: Byte)

Parameters:

  • aId:
  • aError:

SendOptions  protected    (declared in TROBaseSuperChannelWorker)

procedure SendOptions(aData: ROUTF8String)

Parameters:

  • aData:

SendPackage    (declared in TROBaseSuperChannelWorker)

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

Parameters:

  • aData:
  • aId:

SetAckDetails  protected virtual    (declared in TROBaseSuperChannelWorker)

procedure SetAckDetails(aId: Integer; aOk: Boolean; aErrorNo: Integer)

Parameters:

  • aId:
  • aOk:
  • aErrorNo:

SupportsOptions  protected    (declared in TROBaseSuperChannelWorker)

procedure SupportsOptions

 

OnProgress    (declared in TROBaseSuperChannelWorker)

property OnProgress: TProgressEvent read write
delegate: procedure OnProgress(aSender: TObject; aType: TProgressType; aDirection: TProgressDirection; aTransferred: Integer; aTotal: Integer)