]>
git.ipfire.org Git - thirdparty/squid.git/blob - src/ipc/Kids.cc
2 * Copyright (C) 1996-2015 The Squid Software Foundation and contributors
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.
9 /* DEBUG: section 54 Interprocess Communication */
12 #include "base/TextException.h"
15 #include "SquidConfig.h"
30 storage
.reserve(NumberOfKids());
34 // add Kid records for all workers
35 for (int i
= 0; i
< Config
.workers
; ++i
) {
36 snprintf(kid_name
, sizeof(kid_name
), "(squid-%d)", (int)(storage
.size()+1));
37 storage
.push_back(Kid(kid_name
));
40 // add Kid records for all disk processes
41 for (int i
= 0; i
< Config
.cacheSwap
.n_strands
; ++i
) {
42 snprintf(kid_name
, sizeof(kid_name
), "(squid-disk-%d)", (int)(storage
.size()+1));
43 storage
.push_back(Kid(kid_name
));
46 // if coordination is needed, add a Kid record for Coordinator
47 if (storage
.size() > 1) {
48 snprintf(kid_name
, sizeof(kid_name
), "(squid-coord-%d)", (int)(storage
.size()+1));
49 storage
.push_back(Kid(kid_name
));
52 Must(storage
.size() == static_cast<size_t>(NumberOfKids()));
55 /// returns kid by pid
56 Kid
* Kids::find(pid_t pid
)
61 for (size_t i
= 0; i
< storage
.size(); ++i
) {
62 if (storage
[i
].getPid() == pid
)
68 /// returns the kid by index, useful for kids iteration
69 Kid
& Kids::get(size_t i
)
75 /// whether all kids are hopeless
76 bool Kids::allHopeless() const
78 for (size_t i
= 0; i
< storage
.size(); ++i
) {
79 if (!storage
[i
].hopeless())
85 /// whether all kids called exited happy
86 bool Kids::allExitedHappy() const
88 for (size_t i
= 0; i
< storage
.size(); ++i
) {
89 if (!storage
[i
].exitedHappy())
95 /// whether some kids died from a given signal
96 bool Kids::someSignaled(const int sgnl
) const
98 for (size_t i
= 0; i
< storage
.size(); ++i
) {
99 if (storage
[i
].signaled(sgnl
))
105 /// whether some kids are running
106 bool Kids::someRunning() const
108 for (size_t i
= 0; i
< storage
.size(); ++i
) {
109 if (storage
[i
].running())
115 /// whether some kids should be restarted by master
116 bool Kids::shouldRestartSome() const
118 for (size_t i
= 0; i
< storage
.size(); ++i
) {
119 if (storage
[i
].shouldRestart())
125 /// returns the number of kids
126 size_t Kids::count() const
128 return storage
.size();