TF5TCPServer

type TF5TCPServer = class(TComponent)

protected

  procedure Init; virtual;

  procedure InitDefaults; virtual;

  procedure Lock;

  procedure Unlock;

  procedure Log();

  procedure LogParameter(); overload;

  procedure LogException();

  procedure CheckNotActive;

  procedure SetAddressFamily();

  procedure SetBindAddress();

  procedure SetServerPort();

  procedure SetMaxBacklog();

  procedure SetMaxClients();

  procedure SetMinReadBufferSize();

  procedure SetMaxReadBufferSize();

  procedure SetMinWriteBufferSize();

  procedure SetMaxWriteBufferSize();

  procedure SetSocketReadBufferSize();

  procedure SetSocketWriteBufferSize();

  procedure SetTrackLastActivityTime();

  procedure SetProcessThreadCount();

  procedure SetUseWorkerThread();

  procedure ServerSocketLog();

  procedure ClientLog();

  procedure TriggerClientAccept(); virtual;

  procedure TriggerClientCreate(); virtual;

  procedure TriggerClientAdd(); virtual;

  procedure TriggerClientRemove(); virtual;

  procedure TriggerClientDestroy(); virtual;

  procedure TriggerClientStateChange(); virtual;

  procedure TriggerClientNegotiating(); virtual;

  procedure TriggerClientConnected(); virtual;

  procedure TriggerClientReady(); virtual;

  procedure TriggerClientReadShutdown(); virtual;

  procedure TriggerClientShutdown(); virtual;

  procedure TriggerClientClose(); virtual;

  procedure TriggerClientRead(); virtual;

  procedure TriggerClientWrite(); virtual;

  procedure TriggerClientReadActivity(); virtual;

  procedure TriggerClientWorkerExecute(); virtual;

  function GetState;

  function GetStateStr;

  function GetStateErrorMsg;

  procedure SetState();

  procedure ServerActive; virtual;

  procedure ServerStarting; virtual;

  procedure ServerReady; virtual;

  procedure ServerError();

  procedure ServerStopping; virtual;

  procedure ServerInactive; virtual;

  procedure StartControlThread;

  procedure StartAcceptThread;

  procedure StartPollThreads;

  procedure StopServerThreads;

  procedure ServerCloseClients;

  procedure ServerCloseServer;

  procedure ServerClose; virtual;

  procedure ServerSetStateError(); virtual;

  procedure ServerSetStateReady; virtual;

  procedure ServerStart; virtual;

  procedure ServerStop; virtual;

  procedure ServerActivate; virtual;

  procedure ServerDeactivate; virtual;

  procedure ServerSetError();

  procedure ServerSetReady;

  procedure ServerSetActive;

  procedure ServerSetInactive;

  procedure SetActive();

  procedure Loaded; override;

  function CreateClient(); virtual;

  function CanAcceptClient;

  function ServerAcceptClient();

  function ServerDropClient;

  procedure ProcessClient();

  function ControlThreadListen();

  function ControlThreadDropClients();

  procedure ControlThreadExecute();

  procedure AcceptThreadAcceptSocket();

  procedure AcceptThreadExecute();

  procedure ProcessPollLongThreadExecute();

  procedure AddAcceptedClientsToPollShort;

  procedure AddAcceptedClientsToPollSpin;

  procedure ProcessPollShortThreadStartPoll;

  procedure ProcessPollShortThreadClientPoll();

  procedure ProcessPollShortThreadClientProcess();

  procedure ProcessPollShortThreadCompletePoll;

  procedure ProcessPollShortThreadExecute();

  procedure ProcessPollSpinThreadClientPoll();

  procedure ProcessPollSpinThreadClientProcess();

  procedure ProcessPollSpinThreadExecute();

  function GetActiveClientCount;

  function GetClientCount;

  function GetReadRate;

  function GetWriteRate;

public

  constructor Create(); override;

  destructor Destroy; override;

  procedure Finalise; virtual;

  property AddressFamily: TIPAddressFamily; [rw]

  property BindAddress: string; [rw]

  property ServerPort: Integer; [rw]

  property MaxBacklog: Integer; [rw]

  property MaxClients: Integer; [rw]

  property MinReadBufferSize: Integer; [rw]

  property MaxReadBufferSize: Integer; [rw]

  property MinWriteBufferSize: Integer; [rw]

  property MaxWriteBufferSize: Integer; [rw]

  property SocketReadBufferSize: Integer; [rw]

  property SocketWriteBufferSize: Integer; [rw]

  property TrackLastActivityTime: Boolean; [rw]

  property ProcessThreadCount: Integer; [rw]

  property OnLog: TTCPServerLogEvent; [rw]

  property OnActive: TTCPServerNotifyEvent; [rw]

  property OnStarting: TTCPServerNotifyEvent; [rw]

  property OnError: TTCPServerNotifyEvent; [rw]

  property OnReady: TTCPServerNotifyEvent; [rw]

  property OnStopping: TTCPServerNotifyEvent; [rw]

  property OnInactive: TTCPServerNotifyEvent; [rw]

  property OnStateChanged: TTCPServerStateEvent; [rw]

  property OnThreadIdle: TTCPServerIdleEvent; [rw]

  property OnClientAccept: TTCPServerAcceptEvent; [rw]

  property OnClientCreate: TTCPServerClientEvent; [rw]

  property OnClientAdd: TTCPServerClientEvent; [rw]

  property OnClientRemove: TTCPServerClientEvent; [rw]

  property OnClientDestroy: TTCPServerClientEvent; [rw]

  property OnClientStateChange: TTCPServerClientEvent; [rw]

  property OnClientNegotiating: TTCPServerClientEvent; [rw]

  property OnClientConnected: TTCPServerClientEvent; [rw]

  property OnClientReady: TTCPServerClientEvent; [rw]

  property OnClientReadShutdown: TTCPServerClientEvent; [rw]

  property OnClientShutdown: TTCPServerClientEvent; [rw]

  property OnClientClose: TTCPServerClientEvent; [rw]

  property OnClientRead: TTCPServerClientEvent; [rw]

  property OnClientWrite: TTCPServerClientEvent; [rw]

  property OnClientReadActivity: TTCPServerClientEvent; [rw]

  property State: TTCPServerState; [r]

  property StateStr: string; [r]

  property StateErrorMsg: string; [r]

  property Active: Boolean; [rw]

  procedure Start();

  procedure Stop;

  property ActiveClientCount: Integer; [r]

  property ClientCount: Integer; [r]

  function ClientIterateFirst;

  function ClientIterateNext();

  property ReadRate: Int64; [r]

  property WriteRate: Int64; [r]

  property UseWorkerThread: Boolean; [rw]

  property OnClientWorkerExecute: TTCPServerClientWorkerExecuteEvent; [rw]

  property UserTag: NativeInt; [rw]

  property UserObject: TObject; [rw]

end;

TF5TCPServer

TObject