| 35 | } |
| 36 | |
| 37 | struct msg_queue *msg_queue_new(const tal_t *ctx, bool fd_passing) |
| 38 | { |
| 39 | struct msg_queue *q = tal(ctx, struct msg_queue); |
| 40 | q->fd_passing = fd_passing; |
| 41 | membuf_init(&q->mb, tal_arr(q, const u8 *, 0), 0, membuf_tal_resize); |
| 42 | |
| 43 | if (q->fd_passing) |
| 44 | tal_add_destructor(q, destroy_msg_queue); |
| 45 | return q; |
| 46 | } |
| 47 | |
| 48 | static void do_enqueue(struct msg_queue *q, const u8 *add TAKES) |
| 49 | { |
no outgoing calls
no test coverage detected