TBlockSocket

type TBlockSocket = class(TObject)

protected

  FSocket: TSocket;

  FLastError: Integer;

  FLastErrorDesc: string;

  FOwner: TObject;

  procedure SetDelayedOption();

  procedure DelayedOption();

  procedure ProcessDelayedOptions;

  procedure InternalCreateSocket();

  procedure SetSin();

  function GetSinIP();

  function GetSinPort();

  procedure DoStatus();

  procedure DoReadFilter();

  procedure DoMonitor();

  procedure DoCreateSocket;

  procedure DoHeartbeat;

  procedure LimitBandwidth();

  procedure SetBandwidth();

  function TestStopFlag;

  procedure InternalSendStream(); virtual;

  function InternalCanRead(); virtual;

  function InternalCanWrite(); virtual;

public

  constructor Create;

  constructor CreateAlternate();

  destructor Destroy; override;

  procedure CreateSocket;

  procedure CreateSocketByName();

  procedure CloseSocket; virtual;

  procedure AbortSocket; virtual;

  procedure Bind();

  procedure Connect(); virtual;

  procedure Listen; virtual;

  function Accept; virtual;

  function SendBuffer(); virtual;

  procedure SendByte(); virtual;

  procedure SendString(); virtual;

  procedure SendInteger(); virtual;

  procedure SendBlock(); virtual;

  procedure SendStreamRaw(); virtual;

  procedure SendStream(); virtual;

  procedure SendStreamIndy(); virtual;

  function RecvBuffer(); virtual;

  function RecvBufferEx(); virtual;

  function RecvBufferStr(); virtual;

  function RecvByte(); virtual;

  function RecvInteger(); virtual;

  function RecvString(); virtual;

  function RecvTerminated(); virtual;

  function RecvPacket(); virtual;

  function RecvBlock(); virtual;

  procedure RecvStreamRaw(); virtual;

  procedure RecvStreamSize();

  procedure RecvStream(); virtual;

  procedure RecvStreamIndy(); virtual;

  function PeekBuffer(); virtual;

  function PeekByte(); virtual;

  function WaitingData; virtual;

  function WaitingDataEx;

  procedure Purge;

  procedure SetLinger();

  procedure GetSinLocal;

  procedure GetSinRemote;

  procedure GetSins;

  procedure ResetLastError;

  function SockCheck(); virtual;

  procedure ExceptCheck;

  function LocalName;

  procedure ResolveNameToIP();

  function ResolveName();

  function ResolveIPToName();

  function ResolvePort();

  procedure SetRemoteSin();

  function GetLocalSinIP; virtual;

  function GetRemoteSinIP; virtual;

  function GetLocalSinPort; virtual;

  function GetRemoteSinPort; virtual;

  function CanRead(); virtual;

  function CanReadEx(); virtual;

  function CanWrite(); virtual;

  function SendBufferTo(); virtual;

  function RecvBufferFrom(); virtual;

  function GroupCanRead();

  procedure EnableReuse();

  procedure SetTimeout();

  procedure SetSendTimeout();

  procedure SetRecvTimeout();

  function GetSocketType; virtual;

  function GetSocketProtocol; virtual;

  property WSAData: TWSAData; [r]

  property FDset: TFDSet; [r]

  property LocalSin: TVarSin; [rw]

  property RemoteSin: TVarSin; [rw]

  property Socket: TSocket; [rw]

  property LastError: Integer; [r]

  property LastErrorDesc: string; [r]

  property LineBuffer: AnsiString; [rw]

  property SizeRecvBuffer: Integer; [rw]

  property SizeSendBuffer: Integer; [rw]

  property NonBlockMode: Boolean; [rw]

  property TTL: Integer; [rw]

  property IP6used: Boolean; [r]

  property RecvCounter: Int64; [r]

  property SendCounter: Int64; [r]

published

  class function GetErrorDesc();

  function GetErrorDescEx; virtual;

  property Tag: Integer; [rw]

  property RaiseExcept: Boolean; [rw]

  property MaxLineLength: Integer; [rw]

  property MaxSendBandwidth: Integer; [rw]

  property MaxRecvBandwidth: Integer; [rw]

  property MaxBandwidth: Integer; [w]

  property ConvertLineEnd: Boolean; [rw]

  property Family: TSocketFamily; [rw]

  property PreferIP4: Boolean; [rw]

  property InterPacketTimeout: Boolean; [rw]

  property SendMaxChunk: Integer; [rw]

  property StopFlag: Boolean; [rw]

  property NonblockSendTimeout: Integer; [rw]

  property ConnectionTimeout: Integer; [rw]

  property OnStatus: THookSocketStatus; [rw]

  property OnReadFilter: THookDataFilter; [rw]

  property OnCreateSocket: THookCreateSocket; [rw]

  property OnMonitor: THookMonitor; [rw]

  property OnHeartbeat: THookHeartbeat; [rw]

  property HeartbeatRate: Integer; [rw]

  property Owner: TObject; [rw]

end;

TBlockSocket

TObject