|
@@ -337,7 +337,6 @@ type
|
|
function CreateWaitForAllRequestsThreadRef(const aOnAllDoneRef: TFPHTTPClientPoolSimpleCallbackRef;
|
|
function CreateWaitForAllRequestsThreadRef(const aOnAllDoneRef: TFPHTTPClientPoolSimpleCallbackRef;
|
|
const aSynchronizeOnAllDone: Boolean; const aOwner: TComponent; const aTimeoutMS: Integer): TFPHTTPClientAsyncPoolCustomWaitForAllThread; virtual;
|
|
const aSynchronizeOnAllDone: Boolean; const aOwner: TComponent; const aTimeoutMS: Integer): TFPHTTPClientAsyncPoolCustomWaitForAllThread; virtual;
|
|
{$ENDIF}
|
|
{$ENDIF}
|
|
- procedure WaitForThreadsToFinish; virtual;
|
|
|
|
|
|
|
|
// support for MaxClientsPerServer (add requests that wait for a client to a queue)
|
|
// support for MaxClientsPerServer (add requests that wait for a client to a queue)
|
|
procedure AddToQueue(const aClients: TFPCustomHTTPClients; const aBreakUTC: TDateTime; const aRequest: TFPHTTPClientAbstractAsyncPoolRequest);
|
|
procedure AddToQueue(const aClients: TFPCustomHTTPClients; const aBreakUTC: TDateTime; const aRequest: TFPHTTPClientAbstractAsyncPoolRequest);
|
|
@@ -1129,11 +1128,6 @@ begin
|
|
CreateWaitForAllRequestsThread(aOnAllDone, aSynchronizeOnAllDone, aOwner, aTimeoutMS);
|
|
CreateWaitForAllRequestsThread(aOnAllDone, aSynchronizeOnAllDone, aOwner, aTimeoutMS);
|
|
end;
|
|
end;
|
|
|
|
|
|
-procedure TFPCustomHTTPClientAsyncPool.WaitForThreadsToFinish;
|
|
|
|
-begin
|
|
|
|
- Sleep(10);
|
|
|
|
-end;
|
|
|
|
-
|
|
|
|
{ TFPHTTPClientAsyncPoolRequestThread }
|
|
{ TFPHTTPClientAsyncPoolRequestThread }
|
|
|
|
|
|
constructor TFPHTTPClientAsyncPoolRequestThread.Create(aPool: TFPCustomHTTPClientAsyncPool;
|
|
constructor TFPHTTPClientAsyncPoolRequestThread.Create(aPool: TFPCustomHTTPClientAsyncPool;
|