TROBaseSuperChannelWorker
Overview
Location
- Unit: uROBaseSuperTcpConnection.pas
- Ancestry: TROBaseSuperChannelWorker
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)