line |
true |
false |
branch |
11
|
0 |
1 |
EvNew(13, ev->member, ev->members, pe_watcher*); |
12
|
0 |
1 |
Zero(ev->member, ev->members, pe_watcher*); |
22
|
12 |
1 |
for (xx=0; xx < gp->members; xx++) { |
24
|
10 |
2 |
if (mb) |
36
|
0 |
1 |
if (!ev->callback) |
38
|
0 |
1 |
if (!sv_2interval("group", gp->timeout, &timeout)) |
41
|
0 |
1 |
gp->since = WaHARD(ev)? gp->tm.at : NVtime(); |
57
|
0 |
0 |
for (xx=0; xx < gp->members; xx++) { |
59
|
0 |
0 |
if (!mb) continue; |
60
|
0 |
0 |
if (gp->since < mb->cbtime) { |
65
|
0 |
0 |
if (!sv_2interval("group", gp->timeout, &timeout)) |
69
|
0 |
0 |
if (remaining > IntervalEpsilon) { |
83
|
1 |
10 |
if (gp == (pe_group*) wa) { |
85
|
1 |
0 |
croak("Event: can't add group '%s' to itself", |
89
|
53 |
2 |
for (xx=0; xx < gp->members; xx++) { |
90
|
8 |
45 |
if (!gp->member[xx]) { |
95
|
2 |
8 |
if (!ok) { /* expand array */ |
97
|
0 |
2 |
EvNew(13, ary, gp->members*2, pe_watcher*); |
98
|
0 |
2 |
Zero(ary, gp->members*2, pe_watcher*); |
99
|
0 |
2 |
Copy(gp->member, ary, gp->members, sizeof(pe_watcher*)); |
109
|
0 |
0 |
for (xx=0; xx < gp->members; xx++) { |
110
|
0 |
0 |
if (gp->member[xx] != target) |
120
|
1 |
0 |
if (nval) { |
129
|
0 |
1 |
XPUSHs(gp->timeout); |
136
|
0 |
13 |
if (!nval) |
143
|
0 |
0 |
if (!nval) |