🚀 go-pugleaf

Hi,

I am trying to create a blocking tcp client connection using the TTcpClient
component
(using D7 pro) if in blocking mode I have to keep checking if data it there,
so I have
created a worker thread when a connection is successful that checks and
reads in
data this fires the OnReceive method with the data. It all works but I am
unsure about
sychronization and if its ok to send data with the component when the worker
thread
is checking / reading data.

Thanks for any advice

neehah

code:

TWorkThread = class(TThread)
  private
    FClientSocket: TCustomIpClient;
  protected
    procedure Execute; override;
  public
    constructor Create(ClientSocket: TCustomIpClient); reintroduce; virtual;
    destructor Destroy; override;
  end;

  TTcpThreadClient = class(TCustomIpClient)
  private
    FWorkThread: TWorkThread;
  public
    constructor Create(AOwner: TComponent); override;
    destructor Destroy; override;
    function Connect: Boolean; overload;
    procedure Disconnect overload;
  published
    property Connected;
    property RemoteHost;
    property RemotePort;
    property OnCreateHandle;
    property OnDestroyHandle;
    property OnConnect;
    property OnDisconnect;
    property OnReceive;
    property OnSend;
    property OnError;
  end;

implementation

{ TTcpThreadClient }

function TTcpThreadClient.Connect: Boolean;
var
  Temp: Boolean;
begin

  if Connected then
    Disconnect;

  Temp := inherited Connect;
  file://create the worker thread
  if Temp then
  begin
    if not Assigned(FWorkThread) then
      FWorkThread := TWorkThread.Create(Self);
  end;

  Result := Temp;
end;

constructor TTcpThreadClient.Create(AOwner: TComponent);
begin
  inherited;
  BlockMode := bmBlocking;
end;

destructor TTcpThreadClient.Destroy;
begin
  inherited;
end;

procedure TTcpThreadClient.Disconnect;
begin
  inherited;

  FWorkThread := nil;
end;

{ TWorkThread }

constructor TWorkThread.Create(ClientSocket: TCustomIpClient);
begin
  inherited Create(false);

  FClientSocket := ClientSocket;
  FreeOnTerminate := True;
  Resume;
end;

destructor TWorkThread.Destroy;
begin
  inherited;
end;

procedure TWorkThread.Execute;
const
  BufSize = 32768;
var
  ReadBuf: array[0..BufSize-1] of byte;
begin
  file://inherited; abstract method

  try
    while (not Terminated) and (FClientSocket.Connected) do
    begin
      if FClientSocket.WaitForData(10) then
      begin
        file://we have data read in
        FillChar(ReadBuf, BufSize, 0);
        FClientSocket.ReceiveBuf(ReadBuf, BufSize);
      end;
    end;
  except
    file://deal with exceptions
  end;

end;