src/base/DelayedAsyncCalls.cc

   1 /*
   2  * Copyright (C) 1996-2023 The Squid Software Foundation and contributors
   3  *
   4  * Squid software is distributed under GPLv2+ license and includes
   5  * contributions from numerous individuals and organizations.
   6  * Please see the COPYING and CONTRIBUTORS files for details.
   7  */
   8
   9 #include "squid.h"
  10 #include "base/AsyncCall.h"
  11 #include "base/DelayedAsyncCalls.h"
  12 #include "debug/Stream.h"
  13
  14 void
  15 DelayedAsyncCalls::delay(const AsyncCall::Pointer &call)
  16 {
  17     debugs(5, 3, call << " after " << deferredReads.size());
  18     deferredReads.add(call);
  19 }
  20
  21 void
  22 DelayedAsyncCalls::schedule()
  23 {
  24     while (auto call = deferredReads.extract())
  25         ScheduleCallHere(call);
  26 }
  27