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