aboutsummaryrefslogtreecommitdiffstats
path: root/serve/serve.c
diff options
context:
space:
mode:
authoreunhhu <[email protected]>2026-10-01 09:10:55 +0100
committereunhhu <[email protected]>2026-10-01 09:10:55 +0100
commit5f5603ce239dce08ae2ec4b0fa828787b220493c (patch)
tree04c77f6202f0de2ac61ccc3d58cdf54e790b9165 /serve/serve.c
parent2128089d94a9a7345775e2725347713a66987039 (diff)
downloadpure-5f5603ce239dce08ae2ec4b0fa828787b220493c.tar.gz
pure-5f5603ce239dce08ae2ec4b0fa828787b220493c.zip
Deliver wires on the sending loop, a step at a time (017, 2b-2)
A wire is now a sender of link/sending.h: its request goes on a non-blocking socket as far as the socket takes it (connect, TLS handshake, write, answer read), and its round waits for the socket or its deadline (10 s with nothing moved). The answer is read as it comes: the head whole, then a sized body counted down, a chunked one (few and small) parsed again as it grows, or a body to the close. The crypto table (version 6) takes the TLS handshake a step at a time, and reads and writes say what they wait for. The owner pushes a wire once a turn, as it does a link. A host whose app sends to ten links and ten wires has 5 threads where it had 24 (none: 3).
Diffstat (limited to 'serve/serve.c')
-rw-r--r--serve/serve.c3
1 files changed, 2 insertions, 1 deletions
diff --git a/serve/serve.c b/serve/serve.c
index 86e38f8..81a338d 100644
--- a/serve/serve.c
+++ b/serve/serve.c
@@ -1845,7 +1845,8 @@ static void feed_outlets(Executor *ex) {
queued = seq;
held += payload.size;
}
- if (link && queued != before) pure_link_push(link); /* the turn's together */
+ if (queued != before && link) pure_link_push(link); /* the turn's together */
+ else if (queued != before && wire) pure_wire_push(wire);
ex->outlet_from[i] = at;
}
uint64_t now = ex->local_count ? now_ms() : 0;