summaryrefslogtreecommitdiff
path: root/src/packet_pool.h
diff options
context:
space:
mode:
Diffstat (limited to 'src/packet_pool.h')
-rw-r--r--src/packet_pool.h6
1 files changed, 4 insertions, 2 deletions
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);