From: Frédéric Lécaille <flecaille@haproxy.com>
Date: Fri, 3 Sep 2021 13:56:18 +0000 (+0200)
Subject: MINOR: quic: Attach the QUIC connection to a thread.
X-Git-Tag: v2.5-dev8~46
X-Git-Url: http://git.ipfire.org/?a=commitdiff_plain;h=d4d6aa7b5c2623371e9ef4f68109127659536f88;p=thirdparty%2Fhaproxy.git

MINOR: quic: Attach the QUIC connection to a thread.

Compute a thread ID from a QUIC CID and attach the I/O handler to this
thread.
---

diff --git a/include/haproxy/xprt_quic.h b/include/haproxy/xprt_quic.h
index 0586124d08..1158d0de55 100644
--- a/include/haproxy/xprt_quic.h
+++ b/include/haproxy/xprt_quic.h
@@ -117,6 +117,12 @@ static inline void quic_cid_dump(struct buffer *buf, struct quic_cid *cid)
 	chunk_appendf(buf, ")");
 }
 
+/* Simply compute a thread ID from a CID */
+static inline unsigned long quic_get_cid_tid(const struct quic_cid *cid)
+{
+	return cid->data[0] % global.nbthread;
+}
+
 /* Free the CIDs attached to <conn> QUIC connection.
  * Always succeeds.
  */
diff --git a/src/xprt_quic.c b/src/xprt_quic.c
index ee7004bf4e..cfe43b1a53 100644
--- a/src/xprt_quic.c
+++ b/src/xprt_quic.c
@@ -4406,6 +4406,7 @@ static int qc_conn_init(struct connection *conn, void **xprt_ctx)
 		struct bind_conf *bc = __objt_listener(conn->target)->bind_conf;
 		struct quic_conn *qc = ctx->conn->qc;
 
+		ctx->wait_event.tasklet->tid = quic_get_cid_tid(&qc->scid);
 		if (ssl_bio_and_sess_init(conn, bc->initial_ctx,
 		                          &ctx->ssl, &ctx->bio, ha_quic_meth, ctx) == -1)
 			goto err;