From a2dad19f83ac00101489d7e00751ff9e17719344 Mon Sep 17 00:00:00 2001 From: Andrew Opalach Date: Mon, 14 Sep 2026 08:50:45 -0400 Subject: Direct mode fixes Signed-off-by: Andrew Opalach --- src/packet_pool.h | 6 ++++-- 1 file changed, 4 insertions(+), 2 deletions(-) (limited to 'src/packet_pool.h') diff --git a/src/packet_pool.h b/src/packet_pool.h index 8e21c12..27e6254 100644 --- a/src/packet_pool.h +++ b/src/packet_pool.h @@ -25,6 +25,7 @@ enum { struct nn_packet_pool { struct nn_event_loop *loop; u32 size; + u32 allowed; bool grow; bool flushing; bool disabled; @@ -38,14 +39,15 @@ struct nn_packet_pool { void *userdata; }; -void nn_packet_pool_init(struct nn_packet_pool *pool, u32 size, +void nn_packet_pool_init(struct nn_packet_pool *pool, u32 size, u32 init, struct nn_event_loop *loop, void (*callback)(void *, struct nn_packet *), void *userdata); struct nn_packet *nn_packet_pool_get(struct nn_packet_pool *pool); -void nn_packet_pool_submit(struct nn_packet_pool *pool, struct nn_packet *packet); +bool nn_packet_pool_submit(struct nn_packet_pool *pool, struct nn_packet *packet); void nn_packet_pool_flush(struct nn_packet_pool *pool); void nn_packet_pool_lock(struct nn_packet_pool *pool); void nn_packet_pool_return(struct nn_packet_pool *pool, struct nn_packet *packet); void nn_packet_pool_unlock(struct nn_packet_pool *pool); void nn_packet_pool_disable(struct nn_packet_pool *pool); +struct nn_packet *nn_packet_pool_pop(struct nn_packet_pool *pool); void nn_packet_pool_enable(struct nn_packet_pool *pool); void nn_packet_pool_free(struct nn_packet_pool *pool); -- cgit v1.2.3-101-g0448