diff options
| author |   Andrew Opalach <andrew@akon.city>
| 2026-09-07 13:51:09 -0400 |
|---|---|---|
| committer | Andrew Opalach <andrew@akon.city>
| 2026-09-07 13:51:09 -0400 |
| commit | 0d8f4879eedadc6cca1cf454c3e4535359a487a7 (patch) | |
| tree | ded1c86953c23835d665ce8078b2acf80441c920 /src/packet_stream.h | |
| parent | b034b81ad74f61fc2f188c68df40f89b7900d0aa (diff) | |
| download | libnaunet-0d8f4879eedadc6cca1cf454c3e4535359a487a7.tar.gz libnaunet-0d8f4879eedadc6cca1cf454c3e4535359a487a7.tar.bz2 libnaunet-0d8f4879eedadc6cca1cf454c3e4535359a487a7.zip | |
Improve packet_stream API, optimize throughput
Signed-off-by: Andrew Opalach <andrew@akon.city>
Diffstat (limited to 'src/packet_stream.h')
| -rw-r--r-- | src/packet_stream.h | 6 |
1 files changed, 3 insertions, 3 deletions
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); |