idserveriohandlersocket.pas

photo.163.com 相册下载器 多线程下载

{ $HDR$}
{**********************************************************************}
{ Unit archived using Team Coherence                                   }
{ Team Coherence is Copyright 2002 by Quality Software Components      }
{                                                                      }
{ For further information / comments, visit our WEB site at            }
{ http://www.TeamCoherence.com                                         }
{**********************************************************************}
{}
{ $Log:  13961: IdServerIOHandlerSocket.pas 
{
{   Rev 1.15    2004.02.03 4:17:04 PM  czhower
{ For unit name changes.
}
{
{   Rev 1.14    2004.01.20 10:03:32 PM  czhower
{ InitComponent
}
{
{   Rev 1.13    2003.10.11 5:50:00 PM  czhower
{ -VCL fixes for servers
{ -Chain suport for servers (Super core)
{ -Scheduler upgrades
{ -Full yarn support
}
{
{   Rev 1.12    10/5/2003 03:03:58 AM  JPMugaas
{ Should compile.
}
{
{   Rev 1.11    2003.09.19 10:11:20 PM  czhower
{ Next stage of fiber support in servers.
}
{
{   Rev 1.10    2003.09.19 11:54:34 AM  czhower
{ -Completed more features necessary for servers
{ -Fixed some bugs
}
{
{   Rev 1.9    2003.09.18 4:10:28 PM  czhower
{ Preliminary changes for Yarn support.
}
{
{   Rev 1.8    2003.07.14 10:15:36 PM  czhower
{ Changed timeout to 250 from 100
}
{
    Rev 1.7    3/29/2003 5:55:02 PM  BGooijen
  now calls AfterAccept
}
{
    Rev 1.6    3/13/2003 10:18:28 AM  BGooijen
  Server side fibers, bug fixes
}
{
{   Rev 1.5    1-17-2003 22:22:04  BGooijen
{ new design
}
{
{   Rev 1.4    1-1-2003 16:28:26  BGooijen
{ Changed TIdThread to TIdYarn
}
{
{   Rev 1.3    12-7-2002 17:02:32  BGooijen
{ Now creates IOHandlerSockets of class IOHandlerSocketClass.
{ This is more flexible for descendants
}
{
{   Rev 1.2    12-7-2002 12:34:38  BGooijen
{ Re-enabled IPv6 support
}
{
{   Rev 1.1    05/12/2002 15:32:00  AO'Neill
}
{
{   Rev 1.0    12/2/2002 05:01:30 PM  JPMugaas
{ Rechecked in due to file corruption.
}
unit IdServerIOHandlerSocket;

interface

uses
  Classes,
  IdSocketHandle, IdGlobal, IdThread, IdServerIOHandler, IdStackConsts, IdIOHandler, IdScheduler,
  IdIOHandlerSocket, IdYarn,
  SysUtils;

type
  TIdIOHandlerSocketClass = class of TIdIOHandlerSocket;

  TIdServerIOHandlerSocket = class(TIdServerIOHandler)
  protected
    IOHandlerSocketClass: TIdIOHandlerSocketClass;
    //
    procedure InitComponent; override;
  public
    function Accept(
      ASocket: TIdSocketHandle;
      AListenerThread: TIdThread;
      AYarn: TIdYarn
      ): TIdIOHandler;
      override;
    procedure Init; override;
  end;

implementation

{ TIdServerIOHandlerSocket }

procedure TIdServerIOHandlerSocket.Init;
begin
  //
end;

function TIdServerIOHandlerSocket.Accept(
  ASocket: TIdSocketHandle;
  AListenerThread: TIdThread;
  AYarn: TIdYarn
  ): TIdIOHandler;
var
  LIOHandler: TIdIOHandlerSocket;
begin
  LIOHandler := IOHandlerSocketClass.Create(nil);
  LIOHandler.Open;
  Result := nil;
  while not AListenerThread.Stopped do try
    if ASocket.Select(250) then begin
      if LIOHandler.Binding.Accept(ASocket.Handle) then begin
        LIOHandler.AfterAccept;
        Result := LIOHandler;
        Break;
      end else begin
        FreeAndNil(LIOHandler);
        Break;
      end;
    end;
  finally
    if AListenerThread.Stopped then begin
      FreeAndNil(LIOHandler);
    end;
  end;
end;

procedure TIdServerIOHandlerSocket.InitComponent;
begin
  inherited;
  IOHandlerSocketClass := TIdIOHandlerSocket;
end;

end.