TF5TCPClient

type TF5TCPClient = class(TComponent)

protected

  FAddressFamily: TTCPClientAddressFamily;

  FHost: string;

  FPort: string;

  FLocalHost: string;

  FLocalPort: string;

  FRetryFailedConnect: Boolean;

  FRetryFailedConnectDelaySec: Integer;

  FRetryFailedConnectMaxAttempts: Integer;

  FReconnectOnDisconnect: Boolean;

  FUseWorkerThread: Boolean;

  FWaitForStartup: Boolean;

  FTrackLastActivityTime: Boolean;

  FUserTag: NativeInt;

  FUserObject: TObject;

  FOnLog: TTCPClientLogEvent;

  FOnError: TTCPClientErrorEvent;

  FOnStateChanged: TTCPClientStateEvent;

  FOnActive: TTCPClientNotifyEvent;

  FOnStart: TTCPClientNotifyEvent;

  FOnStartFailed: TTCPClientNotifyEvent;

  FOnStarted: TTCPClientNotifyEvent;

  FOnConnectFailed: TTCPClientNotifyEvent;

  FOnConnected: TTCPClientNotifyEvent;

  FOnNegotiating: TTCPClientNotifyEvent;

  FOnReadyFailed: TTCPClientNotifyEvent;

  FOnReady: TTCPClientNotifyEvent;

  FOnRead: TTCPClientNotifyEvent;

  FOnWrite: TTCPClientNotifyEvent;

  FOnReadActivity: TTCPClientNotifyEvent;

  FOnReadShutdown: TTCPClientNotifyEvent;

  FOnShutdown: TTCPClientNotifyEvent;

  FOnClose: TTCPClientNotifyEvent;

  FOnStop: TTCPClientNotifyEvent;

  FOnStopped: TTCPClientNotifyEvent;

  FOnInactive: TTCPClientNotifyEvent;

  FOnProcessThreadIdle: TTCPClientNotifyEvent;

  FOnMainThreadWait: TTCPClientNotifyEvent;

  FOnThreadWait: TTCPClientNotifyEvent;

  FOnWorkerExecute: TTCPClientWorkerExecuteEvent;

  FLock: TCriticalSection;

  FActive: Boolean;

  FState: TTCPClientState;

  FIsStopping: Boolean;

  FErrorMessage: string;

  FErrorCode: NativeInt;

  FWaitStartEvent: TAbortableMultiWaitEvent;

  FWaitReadyEvent: TAbortableMultiWaitEvent;

  FProcessThread: TTCPClientProcessThread;

  FActivateOnLoaded: Boolean;

  FIPAddressFamily: TIPAddressFamily;

  FSocket: TSysSocket;

  FLocalAddr: TSocketAddr;

  FConnectAddr: TSocketAddr;

  FConnection: TTCPConnection;

  procedure Init; virtual;

  procedure InitDefaults; virtual;

  procedure Lock;

  procedure Unlock;

  procedure Log();

  function GetState;

  function GetStateStr;

  procedure SetState();

  procedure CheckNotActive;

  procedure CheckActive;

  procedure SetAddressFamily();

  procedure SetHost();

  procedure SetPort();

  function GetPortInt;

  procedure SetPortInt();

  procedure SetLocalHost();

  procedure SetLocalPort();

  procedure SetRetryFailedConnect();

  procedure SetRetryFailedConnectDelaySec();

  procedure SetRetryFailedConnectMaxAttempts();

  procedure SetReconnectOnDisconnect();

  procedure SetUseWorkerThread();

  procedure SetWaitForStartup();

  procedure Loaded; override;

  procedure LogTriggerException();

  procedure TriggerProcessThreadIdle; virtual;

  procedure TriggerError; virtual;

  procedure TriggerStateChanged; virtual;

  procedure TriggerActive; virtual;

  procedure TriggerStart; virtual;

  procedure TriggerStartFailed; virtual;

  procedure TriggerStarted; virtual;

  procedure TriggerConnected; virtual;

  procedure TriggerConnectFailed; virtual;

  procedure TriggerNegotiating; virtual;

  procedure TriggerReadyFailed; virtual;

  procedure TriggerReady; virtual;

  procedure TriggerRead; virtual;

  procedure TriggerWrite; virtual;

  procedure TriggerReadActivity; virtual;

  procedure TriggerReadShutdown; virtual;

  procedure TriggerShutdown; virtual;

  procedure TriggerClose; virtual;

  procedure TriggerStop; virtual;

  procedure TriggerStopped; virtual;

  procedure TriggerInactive; virtual;

  procedure SetError();

  procedure SetStartFailed;

  procedure SetStarted;

  procedure SetConnected;

  procedure SetNegotiating;

  procedure SetReadyFailed;

  procedure SetReady;

  procedure SetClosed;

  procedure SetStopped;

  procedure SocketLog();

  procedure ConnectionLog();

  procedure ConnectionStateChange();

  procedure ConnectionReadShutdown();

  procedure ConnectionShutdown();

  procedure ConnectionClose();

  procedure ConnectionRead();

  procedure ConnectionWrite();

  procedure ConnectionReadActivity();

  procedure ConnectionWorkerExecute();

  function GetConnection;

  procedure CreateConnection;

  procedure FreeConnection;

  function GetBlockingConnection;

  procedure DoResolveLocal;

  procedure DoBind;

  procedure DoResolve;

  procedure DoConnect;

  procedure DoClose;

  procedure StartProcessThread;

  procedure StopProcessThread;

  function ProcessMessage();

  procedure ProcessThreadExecute();

  procedure TerminateProcessThread;

  procedure TerminateWorkerThread;

  procedure ClientStop;

  procedure ClientDeactivate;

  procedure ClientSetInactive;

  procedure ValidateParameters;

  procedure ClientStart;

  procedure ClientInitialiseActive;

  procedure ClientActivate;

  procedure ClientSetActive;

  procedure SetActive();

  procedure ClientWaitStartup();

  procedure Wait; virtual;

public

  constructor Create(); override;

  destructor Destroy; override;

  procedure Finalise;

  property AddressFamily: TTCPClientAddressFamily; [rw]

  property Host: string; [rw]

  property Port: string; [rw]

  property PortInt: Integer; [rw]

  property LocalHost: string; [rw]

  property LocalPort: string; [rw]

  property TrackLastActivityTime: Boolean; [rw]

  property RetryFailedConnect: Boolean; [rw]

  property RetryFailedConnectDelaySec: Integer; [rw]

  property RetryFailedConnectMaxAttempts: Integer; [rw]

  property ReconnectOnDisconnect: Boolean; [rw]

  property OnLog: TTCPClientLogEvent; [rw]

  property OnProcessThreadIdle: TTCPClientNotifyEvent; [rw]

  property OnError: TTCPClientErrorEvent; [rw]

  property OnStateChanged: TTCPClientStateEvent; [rw]

  property OnActive: TTCPClientNotifyEvent; [rw]

  property OnStart: TTCPClientNotifyEvent; [rw]

  property OnStartFailed: TTCPClientNotifyEvent; [rw]

  property OnStarted: TTCPClientNotifyEvent; [rw]

  property OnConnected: TTCPClientNotifyEvent; [rw]

  property OnConnectFailed: TTCPClientNotifyEvent; [rw]

  property OnNegotiating: TTCPClientNotifyEvent; [rw]

  property OnReadyFailed: TTCPClientNotifyEvent; [rw]

  property OnReady: TTCPClientNotifyEvent; [rw]

  property OnRead: TTCPClientNotifyEvent; [rw]

  property OnWrite: TTCPClientNotifyEvent; [rw]

  property OnReadActivity: TTCPClientNotifyEvent; [rw]

  property OnReadShutdown: TTCPClientNotifyEvent; [rw]

  property OnShutdown: TTCPClientNotifyEvent; [rw]

  property OnClose: TTCPClientNotifyEvent; [rw]

  property OnStop: TTCPClientNotifyEvent; [rw]

  property OnStopped: TTCPClientNotifyEvent; [rw]

  property OnInactive: TTCPClientNotifyEvent; [rw]

  property WaitForStartup: Boolean; [rw]

  property State: TTCPClientState; [r]

  property StateStr: string; [r]

  property ErrorMessage: string; [r]

  property ErrorCode: NativeInt; [r]

  function IsConnecting;

  function IsConnectingOrConnected;

  function IsConnected;

  function IsConnectionClosed;

  function IsShutdownComplete;

  function IsStopping;

  property Active: Boolean; [rw]

  procedure Start();

  procedure Stop;

  procedure Shutdown;

  procedure Close;

  property Connection: TTCPConnection; [r]

  property BlockingConnection: TTCPBlockingConnection; [r]

  property UseWorkerThread: Boolean; [rw]

  property OnWorkerExecute: TTCPClientWorkerExecuteEvent; [rw]

  property OnMainThreadWait: TTCPClientNotifyEvent; [rw]

  property OnThreadWait: TTCPClientNotifyEvent; [rw]

  function WaitForState();

  function WaitForConnect();

  function WaitForClose();

  property UserTag: NativeInt; [rw]

  property UserObject: TObject; [rw]

end;

TF5TCPClient

TObject