MINOR: h2/stream_interface: Reintroduce te wake() method.
For the time being, reintroduce the wake methods, it may be revisited later.h
diff --git a/src/mux_h2.c b/src/mux_h2.c
index 6160381..d856a60 100644
--- a/src/mux_h2.c
+++ b/src/mux_h2.c
@@ -1137,7 +1137,8 @@
sw->wait_reason &= ~SUB_CAN_RECV;
tasklet_wakeup(sw->task);
h2s->recv_wait_list = NULL;
- }
+ } else if (h2s->cs->data_cb->wake != NULL)
+ h2s->cs->data_cb->wake(h2s->cs);
if (flags & CS_FL_ERROR && h2s->st < H2_SS_ERROR)
h2s->st = H2_SS_ERROR;
@@ -2483,6 +2484,14 @@
return 0;
}
+static int h2_wake(struct connection *conn)
+{
+ struct h2c *h2c = conn->mux_ctx;
+
+ return (h2_process(h2c));
+}
+
+
/* Connection timeout management. The principle is that if there's no receipt
* nor sending for a certain amount of time, the connection is closed. If the
* MUX buffer still has lying data or is not allocatable, the connection is
@@ -3756,6 +3765,7 @@
/* The mux operations */
const struct mux_ops h2_ops = {
.init = h2_init,
+ .wake = h2_wake,
.update_poll = h2_update_poll,
.snd_buf = h2_snd_buf,
.rcv_buf = h2_rcv_buf,