TROBaseSuperChannelWorker

Overview

Location


 

constructor Create

constructor Create(ABaseSuperConnection: TROBaseSuperTcpConnection)

Parameters:

  • ABaseSuperConnection:

BaseSuperConnection  protected

property BaseSuperConnection: TROBaseSuperTcpConnection read write

BeginWriteLock

procedure BeginWriteLock

ClientID

property ClientID: TGuid read write

Connected  protected virtual

procedure Connected

Disconnect

procedure Disconnect

Disconnected  protected virtual

procedure Disconnected(var RestartLoop: Boolean)

Parameters:

  • RestartLoop:

DoExecute

procedure DoExecute

EndWriteLock

procedure EndWriteLock

GenerateId

function GenerateId: Integer

GetDefaultResponse  protected virtual

function GetDefaultResponse: string

Idle  protected virtual

procedure Idle

IncomingData  protected virtual abstract

procedure IncomingData(Id: Integer; aData: TStream)

Parameters:

  • Id:
  • aData:

IntSendData  protected

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

Parameters:

  • Id:
  • aData:

IsConnected

property IsConnected: Boolean read write

IsServer  protected

property IsServer: Boolean read write

LastData  protected

property LastData: TDateTime read write

MaxPackageSize

property MaxPackageSize: Integer read write

OnProgress

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

PingFrequency  protected

property PingFrequency: Integer read write

PingTimeout  protected

property PingTimeout: Integer read write

ProcessOption  protected

procedure ProcessOption(Data: TStream)

Parameters:

  • Data:

ReadStream  protected

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

Parameters:

  • aDest:
  • aLen:

SendError

procedure SendError(Id: Integer; Error: Byte)

Parameters:

  • Id:
  • Error:

SendOptions  protected

procedure SendOptions(aData: ROUTF8String)

Parameters:

  • aData:

SendPackage

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

Parameters:

  • aData:
  • Id:

SetAckDetails  protected virtual

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

Parameters:

  • Id:
  • Oke:
  • ErrorNo:

SkipAck

property SkipAck: Boolean read write

SupportsOptions  protected

procedure SupportsOptions

WaitForAck

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

Parameters:

  • pkg:
  • Timeout:

 

BaseSuperConnection  protected

property BaseSuperConnection: TROBaseSuperTcpConnection read write

ClientID

property ClientID: TGuid read write

IsConnected

property IsConnected: Boolean read write

IsServer  protected

property IsServer: Boolean read write

LastData  protected

property LastData: TDateTime read write

MaxPackageSize

property MaxPackageSize: Integer read write

PingFrequency  protected

property PingFrequency: Integer read write

PingTimeout  protected

property PingTimeout: Integer read write

SkipAck

property SkipAck: Boolean read write

 

WaitForAck

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

Parameters:

  • pkg:
  • Timeout:

 

constructor Create

constructor Create(ABaseSuperConnection: TROBaseSuperTcpConnection)

Parameters:

  • ABaseSuperConnection:

BeginWriteLock

procedure BeginWriteLock

Connected  protected virtual

procedure Connected

Disconnect

procedure Disconnect

Disconnected  protected virtual

procedure Disconnected(var RestartLoop: Boolean)

Parameters:

  • RestartLoop:

DoExecute

procedure DoExecute

EndWriteLock

procedure EndWriteLock

GenerateId

function GenerateId: Integer

GetDefaultResponse  protected virtual

function GetDefaultResponse: string

Idle  protected virtual

procedure Idle

IncomingData  protected virtual abstract

procedure IncomingData(Id: Integer; aData: TStream)

Parameters:

  • Id:
  • aData:

IntSendData  protected

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

Parameters:

  • Id:
  • aData:

ProcessOption  protected

procedure ProcessOption(Data: TStream)

Parameters:

  • Data:

ReadStream  protected

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

Parameters:

  • aDest:
  • aLen:

SendError

procedure SendError(Id: Integer; Error: Byte)

Parameters:

  • Id:
  • Error:

SendOptions  protected

procedure SendOptions(aData: ROUTF8String)

Parameters:

  • aData:

SendPackage

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

Parameters:

  • aData:
  • Id:

SetAckDetails  protected virtual

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

Parameters:

  • Id:
  • Oke:
  • ErrorNo:

SupportsOptions  protected

procedure SupportsOptions

 

OnProgress

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