diff --git a/src/h3.c b/src/h3.c index b5699bfbf..7fbd483c6 100644 --- a/src/h3.c +++ b/src/h3.c @@ -179,11 +179,11 @@ static int h3_headers_to_htx(struct qcs *qcs, struct buffer *buf, uint64_t len, cs = cs_new(); if (!cs) return 1; - cs_attach_endp(&qcs->qcc->conn->obj_type, qcs); + cs_attach_endp(cs, &qcs->qcc->conn->obj_type, qcs); cs->flags |= CS_FL_NOT_FIRST; cs->ctx = qcs; - stream_create_from_cs(cs, &htx_buf); + stream_new(qcs->qcc->conn->owner, cs, &htx_buf); /* buffer is transferred to conn_stream and set to NULL * except on stream creation error. diff --git a/src/hq_interop.c b/src/hq_interop.c index c9d8c9a3d..0e5561d8a 100644 --- a/src/hq_interop.c +++ b/src/hq_interop.c @@ -77,7 +77,7 @@ static int hq_interop_decode_qcs(struct qcs *qcs, int fin, void *ctx) return -1; cs_attach_endp(cs, &qcs->qcc->conn->obj_type, qcs); cs->ctx = qcs; - stream_create_from_cs(cs, &htx_buf); + stream_new(qcs->qcc->conn->owner, cs, &htx_buf); b_del(rxbuf, b_data(rxbuf)); b_free(&htx_buf);