diff --git a/src/mux_quic.c b/src/mux_quic.c index fc51f0f7d..a7e383820 100644 --- a/src/mux_quic.c +++ b/src/mux_quic.c @@ -741,7 +741,7 @@ static int qc_init(struct connection *conn, struct proxy *prx, LIST_INIT(&qcc->buf_wait.list); MT_LIST_INIT(&qcc->qcs_rxbuf_wlist); - conn->ctx = qcc; + HA_ATOMIC_STORE(&conn->ctx, qcc); if (t) task_queue(t); diff --git a/src/xprt_quic.c b/src/xprt_quic.c index 5bc3495d5..eec3b5cd0 100644 --- a/src/xprt_quic.c +++ b/src/xprt_quic.c @@ -3441,8 +3441,13 @@ static ssize_t qc_lstnr_pkt_rcv(unsigned char **buf, const unsigned char *end, TRACE_PROTO("New packet", QUIC_EV_CONN_LPKT, qc->conn, pkt); - if (conn_ctx) - /* Wake the tasklet of the QUIC connection packet handler. */ + /* Wake up the connection packet handler task from here only if all + * the contexts have been initialized, especially the mux context + * conn_ctx->conn->ctx. Note that this is ->start xprt callback which + * will start it if these contexts for the connection are not already + * initialized. + */ + if (conn_ctx && HA_ATOMIC_LOAD(&conn_ctx->conn->ctx)) tasklet_wakeup(conn_ctx->wait_event.tasklet); TRACE_LEAVE(QUIC_EV_CONN_LPKT, qc->conn, pkt);