line |
true |
false |
branch |
51
|
3 |
0 |
(timers->timers = zmq_timers_new()) == NULL || |
52
|
3 |
0 |
(timers->wakeup_context = zmq_ctx_new()) == NULL || |
53
|
3 |
0 |
(timers->wakeup_send = zmq_socket (timers->wakeup_context, ZMQ_PAIR)) == NULL || |
57
|
3 |
0 |
if ((rc = zmq_bind (timers->wakeup_recv, "inproc://_wakeup")) < 0 || |
|
3 |
0 |
if ((rc = zmq_bind (timers->wakeup_recv, "inproc://_wakeup")) < 0 || |
80
|
0 |
3 |
assert (timers); |
81
|
0 |
3 |
assert (timers->timer_count == 0); |
88
|
3 |
0 |
if (timers->thread) |
108
|
0 |
24 |
assert (context); |
113
|
24 |
0 |
(timer->send = zmq_socket (context, ZMQ_PAIR)) == NULL || |
123
|
24 |
0 |
if ((rc = zmq_bind (timer->recv, endpoint)) < 0 || |
|
24 |
0 |
if ((rc = zmq_bind (timer->recv, endpoint)) < 0 || |
124
|
24 |
0 |
(rc = zmq_setsockopt (timer->recv, ZMQ_CONFLATE, &v, sizeof (v))) < 0 || |
142
|
0 |
24 |
assert (timer); |
143
|
0 |
24 |
assert (timer->send); |
147
|
24 |
0 |
if (timer->recv && !timer->recv_sv) |
|
0 |
24 |
if (timer->recv && !timer->recv_sv) |
160
|
0 |
27 |
assert (timer); |
161
|
0 |
27 |
assert (timer->timers); |
168
|
3 |
24 |
if (!timers->running) |
186
|
0 |
24 |
assert (timers); |
187
|
0 |
24 |
assert (context); |
192
|
0 |
24 |
if (timer == NULL) |
209
|
0 |
27 |
assert (timer); |
212
|
24 |
3 |
if (timer->running) |
217
|
0 |
27 |
while (zmq_recv (timer->recv, NULL, 0, ZMQ_DONTWAIT) == 0); |
223
|
0 |
52 |
assert (timer); |
225
|
27 |
25 |
if (timer->running) |
238
|
1 |
0 |
if (timer->running) |
253
|
0 |
1 |
assert (timer); |
262
|
0 |
38 |
assert (timer); |
271
|
0 |
24 |
assert (timer); |
279
|
0 |
1 |
assert (timer); |
285
|
0 |
24 |
assert (timer); |
291
|
0 |
124 |
assert (timer); |
297
|
0 |
24 |
assert (timer); |
298
|
0 |
24 |
assert (sv); |
299
|
0 |
24 |
assert (timer->recv_sv == NULL); |
311
|
0 |
6 |
assert (timer); |
312
|
0 |
6 |
assert (interval > 0); |
322
|
0 |
8 |
assert (timer); |
337
|
109 |
3 |
while (running) |
342
|
0 |
109 |
while (zmq_recv (timers->wakeup_recv, NULL, 0, ZMQ_DONTWAIT) == 0); |
348
|
79 |
109 |
while (--timers->run_count >= 0) |
353
|
13 |
66 |
if (timer->interval == 0) |
360
|
79 |
30 |
if (timers->last) |
369
|
106 |
3 |
if (running) |
376
|
0 |
80 |
assert (arg); |
381
|
0 |
80 |
assert (timer->id == timer_id); |
388
|
80 |
0 |
if (index == 0) |
393
|
0 |
80 |
assert (timers->last); |