MINOR: mux_pt: implement remaining mux_ops methods

This is a basic pass-through implementation which is now basic but
complete and operational, just not used yet.

src/mux_pt.c

@@ -35,6 +35,26 @@ static int mux_pt_wake(struct connection *conn)
 	return conn->data->wake ? conn->data->wake(conn) : 0;
 }
 
+/* callback used to update the mux's polling flags after changing a cs' status.
+ * The caller (cs_mux_update_poll) will take care of propagating any changes to
+ * the transport layer.
+ */
+static void mux_pt_update_poll(struct conn_stream *cs)
+{
+	struct connection *conn = cs->conn;
+	int flags = 0;
+
+	conn_refresh_polling_flags(conn);
+
+	if (cs->flags & CS_FL_DATA_RD_ENA)
+		flags |= CO_FL_XPRT_RD_ENA;
+	if (cs->flags & CS_FL_DATA_WR_ENA)
+		flags |= CO_FL_XPRT_WR_ENA;
+
+	conn->flags = (conn->flags & ~(CO_FL_XPRT_RD_ENA | CO_FL_XPRT_WR_ENA)) | flags;
+	conn_cond_update_xprt_polling(conn);
+}
+
 /* callback to be used by default for the pass-through mux. It simply calls the
  * data layer recv() callback much must be set.
  */
@@ -51,12 +71,87 @@ static void mux_pt_send(struct connection *conn)
 	conn->data->send(conn);
 }
 
+/*
+ * Attach a new stream to a connection
+ * (Used for outgoing connections)
+ */
+static struct conn_stream *mux_pt_attach(struct connection *conn)
+{
+	return NULL;
+}
+
+/*
+ * Detach the stream from the connection
+ * (Used for outgoing connections)
+ */
+static void mux_pt_detach(struct conn_stream *cs)
+{
+}
+
+static void mux_pt_shutr(struct conn_stream *cs, int clean)
+{
+	if (conn_xprt_ready(cs->conn) && cs->conn->xprt->shutr)
+		cs->conn->xprt->shutr(cs->conn, clean);
+}
+
+static void mux_pt_shutw(struct conn_stream *cs, int clean)
+{
+	if (conn_xprt_ready(cs->conn) && cs->conn->xprt->shutw)
+		cs->conn->xprt->shutw(cs->conn, clean);
+}
+
+/*
+ * Called from the upper layer, to get more data
+ */
+static int mux_pt_rcv_buf(struct conn_stream *cs, struct buffer *buf, int count)
+{
+	int ret;
+
+	ret = cs->conn->xprt->rcv_buf(cs->conn, buf, count);
+	if (conn_xprt_read0_pending(cs->conn))
+		cs->flags |= CS_FL_EOS;
+	return (ret);
+}
+
+/* Called from the upper layer, to send data */
+static int mux_pt_snd_buf(struct conn_stream *cs, struct buffer *buf, int flags)
+{
+	return (cs->conn->xprt->snd_buf(cs->conn, buf, flags));
+}
+
+/* Send and get, using splicing */
+static int mux_pt_rcv_pipe(struct conn_stream *cs, struct pipe *pipe, unsigned int count)
+{
+	int ret;
+
+	ret = cs->conn->xprt->rcv_pipe(cs->conn, pipe, count);
+	if (conn_xprt_read0_pending(cs->conn))
+		cs->flags |= CS_FL_EOS;
+	return (ret);
+}
+
+static int mux_pt_snd_pipe(struct conn_stream *cs, struct pipe *pipe)
+{
+	return (cs->conn->xprt->snd_pipe(cs->conn, pipe));
+}
+
 /* The mux operations */
 const struct mux_ops mux_pt_ops = {
 	.init = mux_pt_init,
 	.recv = mux_pt_recv,
 	.send = mux_pt_send,
 	.wake = mux_pt_wake,
+	.update_poll = mux_pt_update_poll,
+	.rcv_buf = mux_pt_rcv_buf,
+	.snd_buf = mux_pt_snd_buf,
+#if defined(CONFIG_HAP_LINUX_SPLICE)
+	.rcv_pipe = mux_pt_rcv_pipe,
+	.snd_pipe = mux_pt_snd_pipe,
+#endif
+	.attach = mux_pt_attach,
+	.detach = mux_pt_detach,
+	.shutr = mux_pt_shutr,
+	.shutw = mux_pt_shutw,
 	.name = "PASS",
 };