external/slipstream
1
0
Fork 0
mirror of https://github.com/EndPositive/slipstream.git synced 2025-10-08 12:25:04 +00:00
Code Issues Projects Releases Packages Wiki Activity Actions

Decrease number of polls

Browse source
This commit is contained in:
Jop Zitman 2025-01-18 11:22:48 +08:00
parent 52a97ded1b
commit 1bd6c0d76d
2 changed files with 6 additions and 8 deletions
Download patch file Download diff file Expand all files Collapse all files

1
include/slipstream_slot.h
View file

@ -12,6 +12,7 @@ typedef struct st_slot_t {
picoquic_cnx_t* cnx;
uint64_t created_time;
bool is_poll_packet;
bool responded;
} slot_t;
#endif // SLIPSTREAM_SLOT

13
src/slipstream_sockloop.c
View file

@ -57,7 +57,6 @@ int slipstream_packet_loop_(picoquic_network_thread_ctx_t* thread_ctx, picoquic_
const picoquic_packet_loop_cb_fn loop_callback = thread_ctx->loop_callback;
void* loop_callback_ctx = thread_ctx->loop_callback_ctx;
slot_t slots[PICOQUIC_PACKET_LOOP_RECV_MAX] = {0};
slot_t send_slot = {0};
while (!thread_ctx->thread_should_close) {
if (loop_callback) {
@ -145,13 +144,7 @@ int slipstream_packet_loop_(picoquic_network_thread_ctx_t* thread_ctx, picoquic_
const size_t max_slots = param->is_client ? PICOQUIC_PACKET_LOOP_SEND_MAX : nb_slots_written;
while (nb_slots_read < max_slots) {
uint8_t send_buffer[send_buffer_size];
slot_t* slot;
if (param->is_client) {
memset(&send_slot, 0, sizeof(slot_t));
slot = &send_slot;
} else {
slot = &slots[nb_slots_read];
}
slot_t* slot = &slots[nb_slots_read];
assert(slot != NULL);
nb_slots_read++;
@ -218,6 +211,7 @@ int slipstream_packet_loop_(picoquic_network_thread_ctx_t* thread_ctx, picoquic_
return bytes_sent;
}
slot->responded = 1;
nb_packets_sent++;
}
@ -235,6 +229,9 @@ int slipstream_packet_loop_(picoquic_network_thread_ctx_t* thread_ctx, picoquic_
if (slot->cnx == NULL) {
continue; // in case the slot written was a bogus message
}
if (slot->responded) {
continue; // already responded
}
slot->cnx->is_poll_requested = 1;