| 83 | } |
| 84 | |
| 85 | const u8 *msg_dequeue(struct msg_queue *q) |
| 86 | { |
| 87 | size_t n = msg_queue_length(q); |
| 88 | |
| 89 | if (!n) |
| 90 | return NULL; |
| 91 | |
| 92 | return membuf_consume(&q->mb, 1)[0]; |
| 93 | } |
| 94 | |
| 95 | int msg_extract_fd(const struct msg_queue *q, const u8 *msg) |
| 96 | { |
no test coverage detected