From 0d8f4879eedadc6cca1cf454c3e4535359a487a7 Mon Sep 17 00:00:00 2001 From: Andrew Opalach Date: Mon, 7 Sep 2026 13:51:09 -0400 Subject: Improve packet_stream API, optimize throughput Signed-off-by: Andrew Opalach --- src/packet_stream.h | 6 +++--- 1 file changed, 3 insertions(+), 3 deletions(-) (limited to 'src/packet_stream.h') diff --git a/src/packet_stream.h b/src/packet_stream.h index d60af16..623f61f 100644 --- a/src/packet_stream.h +++ b/src/packet_stream.h @@ -30,6 +30,7 @@ struct nn_packet_stream { bool (*connection_callback)(void *, struct nn_packet_stream *); void (*connection_closed_callback)(void *, struct nn_packet_stream *); void (*packet_callback)(void *, struct nn_packet_stream *, struct nn_packet *); + void (*packet_dequeued_callback)(void *, struct nn_packet *); void (*packet_sent_callback)(void *, struct nn_packet *); void (*packets_sent_callback)(void *, struct nn_packet **, u32); void *userdata; @@ -38,11 +39,10 @@ struct nn_packet_stream { void nn_packet_stream_init(struct nn_packet_stream *stream, bool (*connection_callback)(void *, struct nn_packet_stream *), void (*connection_closed_callback)(void *, struct nn_packet_stream *), void *userdata); -void nn_packet_stream_set_nodelay(struct nn_packet_stream *stream, s32 no_delay); void nn_packet_stream_from_socket(struct nn_packet_stream *stream, struct nn_event_loop *loop, struct nn_socket *sock); -void nn_packet_stream_connect(struct nn_packet_stream *stream, struct nn_event_loop *loop, +bool nn_packet_stream_connect(struct nn_packet_stream *stream, struct nn_event_loop *loop, u8 id, u8 type, str *addr, u16 port); -void nn_packet_stream_reconnect(struct nn_packet_stream *stream, str *addr, u16 port); +bool nn_packet_stream_reconnect(struct nn_packet_stream *stream, str *addr, u16 port); bool nn_packet_stream_set_connected(struct nn_packet_stream *stream); void nn_packet_stream_cork(struct nn_packet_stream *stream, bool cork); bool nn_packet_stream_send_packet(struct nn_packet_stream *stream, struct nn_packet *packet); -- cgit v1.2.3-101-g0448