diff --git a/src/h3.c b/src/h3.c index 1469dfb25..fc68432f8 100644 --- a/src/h3.c +++ b/src/h3.c @@ -703,23 +703,6 @@ static struct task *h3_uqs_task(struct task *t, void *ctx, unsigned int state) return NULL; } -#if 0 -/* Initialiaze uni-stream with as tasklet */ -static int h3_uqs_init(struct h3_uqs *h3_uqs, - struct task *(*t)(struct task *, void *, unsigned int)) -{ - h3_uqs->qcs = NULL; - h3_uqs->cb = NULL; - h3_uqs->wait_event.tasklet = tasklet_new(); - if (!h3_uqs->wait_event.tasklet) - return 0; - - h3_uqs->wait_event.tasklet->process = t; - h3_uqs->wait_event.tasklet->context = h3_uqs; - return 1; -} -#endif - /* Release all the tasklet attached to uni-stream */ static inline void h3_uqs_tasklet_release(struct h3_uqs *h3_uqs) { diff --git a/src/mux_quic.c b/src/mux_quic.c index 55a4dc557..d16fd9777 100644 --- a/src/mux_quic.c +++ b/src/mux_quic.c @@ -1842,45 +1842,6 @@ static size_t qc_rcv_buf(struct conn_stream *cs, struct buffer *buf, size_t coun return ret; } -/* Called from the upper layer, to send data from buffer for no more than - * bytes. Returns the number of bytes effectively sent. Some status - * flags may be updated on the mux. - */ -size_t luqs_snd_buf(struct qcs *qcs, struct buffer *buf, size_t count, int flags) -{ - size_t room, total = 0; - struct qcc *qcc = qcs->qcc; - struct buffer *res; - - TRACE_ENTER(QC_EV_QCS_SEND|QC_EV_STRM_SEND, qcs->qcc->conn); - if (!count) - goto out; - - res = &qcs->tx.buf; - if (!qc_get_buf(qcc, res)) { - qcc->flags |= QC_CF_MUX_MALLOC; - goto out; - } - - room = b_room(res); - if (!room) - goto out; - - if (count > room) - count = room; - - total += b_xfer(res, buf, count); - qcs_push_frame(qcs, res, 0, 0); - - out: - TRACE_LEAVE(QC_EV_QCS_SEND|QC_EV_STRM_SEND, qcs->qcc->conn); - return total; - - err: - TRACE_DEVEL("leaving on stream error", QC_EV_QCS_SEND|QC_EV_STRM_SEND, qcs->qcc->conn); - return total; -} - /* for debugging with CLI's "show fd" command */ static int qc_show_fd(struct buffer *msg, struct connection *conn) {