| 18 | } |
| 19 | |
| 20 | static void do_enqueue(struct msg_queue *q, const u8 *add TAKES) |
| 21 | { |
| 22 | tal_arr_expand(&q->q, tal_dup_talarr(q, u8, add)); |
| 23 | |
| 24 | /* In case someone is waiting */ |
| 25 | io_wake(q); |
| 26 | } |
| 27 | |
| 28 | size_t msg_queue_length(const struct msg_queue *q) |
| 29 | { |
no test coverage detected