TROBaseSuperChannelWorker

Overview

Location


 

constructor Create

constructor Create(ABaseSuperConnection: TROBaseSuperTcpConnection)

Parameters:

  • ABaseSuperConnection:

BaseSuperConnection  protected

property BaseSuperConnection: TROBaseSuperTcpConnection read

BeginWriteLock

procedure BeginWriteLock

ClientID

property ClientID: TGuid read write

Connected  protected virtual

procedure Connected

Disconnect

procedure Disconnect

Disconnected  protected virtual

procedure Disconnected(var aRestartLoop: Boolean)

Parameters:

  • aRestartLoop:

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

Parameters:

  • aId:
  • aData:

IntSendData  protected

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

Parameters:

  • aId:
  • aData:

IsConnected

property IsConnected: Boolean read write

IsServer  protected

property IsServer: Boolean read write

LastData  protected

property LastData: TDateTime read

MaxPackageSize

property MaxPackageSize: Integer read write

OnProgress

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

PingFrequency  protected

property PingFrequency: Integer read write

PingTimeout  protected

property PingTimeout: Integer read write

ProcessOption  protected

procedure ProcessOption(aData: TStream)

Parameters:

  • aData:

ReadStream  protected

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

Parameters:

  • aDest:
  • aLen:

SendError

procedure SendError(aId: Integer; aError: Byte)

Parameters:

  • aId:
  • aError:

SendOptions  protected

procedure SendOptions(aData: ROUTF8String)

Parameters:

  • aData:

SendPackage

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

Parameters:

  • aData:
  • aId:

SetAckDetails  protected virtual

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

Parameters:

  • aId:
  • aOk:
  • aErrorNo:

SkipAck

property SkipAck: Boolean read write

SupportsOptions  protected

procedure SupportsOptions

WaitForAck

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

Parameters:

  • aPackage:
  • aTimeout:

 

BaseSuperConnection  protected

property BaseSuperConnection: TROBaseSuperTcpConnection read

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

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

Parameters:

  • aPackage:
  • aTimeout:

 

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 aRestartLoop: Boolean)

Parameters:

  • aRestartLoop:

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

Parameters:

  • aId:
  • aData:

IntSendData  protected

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

Parameters:

  • aId:
  • aData:

ProcessOption  protected

procedure ProcessOption(aData: TStream)

Parameters:

  • aData:

ReadStream  protected

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

Parameters:

  • aDest:
  • aLen:

SendError

procedure SendError(aId: Integer; aError: Byte)

Parameters:

  • aId:
  • aError:

SendOptions  protected

procedure SendOptions(aData: ROUTF8String)

Parameters:

  • aData:

SendPackage

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

Parameters:

  • aData:
  • aId:

SetAckDetails  protected virtual

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

Parameters:

  • aId:
  • aOk:
  • aErrorNo:

SupportsOptions  protected

procedure SupportsOptions

 

OnProgress

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