]>
Commit | Line | Data |
---|---|---|
1 | /* | |
2 | * Copyright (C) 1996-2025 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 | /* DEBUG: section 41 Event Processing */ | |
10 | ||
11 | #include "squid.h" | |
12 | #include "base/AsyncCall.h" | |
13 | #include "base/AsyncCallQueue.h" | |
14 | #include "debug/Stream.h" | |
15 | ||
16 | AsyncCallQueue *AsyncCallQueue::TheInstance = nullptr; | |
17 | ||
18 | // Fire all scheduled calls; returns true if at least one call was fired. | |
19 | // The calls may be added while the current call is in progress. | |
20 | bool | |
21 | AsyncCallQueue::fire() | |
22 | { | |
23 | const auto made = scheduled.size() > 0; | |
24 | while (const auto call = scheduled.extract()) { | |
25 | CodeContext::Reset(call->codeContext); | |
26 | debugs(call->debugSection, call->debugLevel, "entering " << *call); | |
27 | call->make(); | |
28 | debugs(call->debugSection, call->debugLevel, "leaving " << *call); | |
29 | } | |
30 | if (made) | |
31 | CodeContext::Reset(); | |
32 | return made; | |
33 | } | |
34 | ||
35 | AsyncCallQueue & | |
36 | AsyncCallQueue::Instance() | |
37 | { | |
38 | // TODO: how to remove this frequent check while supporting early calls? | |
39 | if (!TheInstance) | |
40 | TheInstance = new AsyncCallQueue(); | |
41 | ||
42 | return *TheInstance; | |
43 | } | |
44 |