MEDIUM: stconn: merge the app_ops and the data_cb fields
For historical reasons (stream-interface and connections), we used to
require two independent fields for the application level callbacks and
the transport-level functions. Over time the distinction faded away so
much that the low-level functions became specific to the application
and conversely. For example, applets may only work with streams on top
since they rely on the channels, and the stream-level functions differ
between applets and connections. Right now the application level only
contains a wake() callback and the low-level ones contain the functions
that act at the lower level to perform the shutr/shutw and at the upper
level to notify about readability and writability. Let's just merge them
together into a single set and get rid of this confusing distinction.
Note that the check ops do not define any app-level function since these
are only called by streams.
diff --git a/src/applet.c b/src/applet.c
index 37e642f..5253739 100644
--- a/src/applet.c
+++ b/src/applet.c
@@ -252,7 +252,7 @@
stream_dump_and_crash(&app->obj_type, read_freq_ctr(&app->call_rate));
}
- cs->data_cb->wake(cs);
+ cs->app_ops->wake(cs);
channel_release_buffer(cs_ic(cs), &app->buffer_wait);
return t;
}
diff --git a/src/check.c b/src/check.c
index e93e50b..c8fe491 100644
--- a/src/check.c
+++ b/src/check.c
@@ -140,12 +140,6 @@
INITCALL1(STG_REGISTER, trace_register_source, TRACE_SOURCE);
-struct data_cb check_conn_cb = {
- .wake = wake_srv_chk,
- .name = "CHCK",
-};
-
-
/* Dummy frontend used to create all checks sessions. */
struct proxy checks_fe;
diff --git a/src/conn_stream.c b/src/conn_stream.c
index e9c8b15..ffb2b79 100644
--- a/src/conn_stream.c
+++ b/src/conn_stream.c
@@ -41,12 +41,19 @@
static void sc_app_chk_rcv_applet(struct stconn *cs);
static void sc_app_chk_snd_applet(struct stconn *cs);
+static int cs_conn_process(struct stconn *cs);
+static int cs_conn_recv(struct stconn *cs);
+static int cs_conn_send(struct stconn *cs);
+static int cs_applet_process(struct stconn *cs);
+
/* stream connector operations for connections */
struct sc_app_ops sc_app_conn_ops = {
.chk_rcv = sc_app_chk_rcv_conn,
.chk_snd = sc_app_chk_snd_conn,
.shutr = sc_app_shutr_conn,
.shutw = sc_app_shutw_conn,
+ .wake = cs_conn_process,
+ .name = "STRM",
};
/* stream connector operations for embedded tasks */
@@ -55,31 +62,29 @@
.chk_snd = sc_app_chk_snd,
.shutr = sc_app_shutr,
.shutw = sc_app_shutw,
+ .wake = NULL, /* may never be used */
+ .name = "NONE", /* may never be used */
};
-/* stream connector operations for connections */
+/* stream connector operations for applets */
struct sc_app_ops sc_app_applet_ops = {
.chk_rcv = sc_app_chk_rcv_applet,
.chk_snd = sc_app_chk_snd_applet,
.shutr = sc_app_shutr_applet,
.shutw = sc_app_shutw_applet,
-};
-
-static int cs_conn_process(struct stconn *cs);
-static int cs_conn_recv(struct stconn *cs);
-static int cs_conn_send(struct stconn *cs);
-static int cs_applet_process(struct stconn *cs);
-
-struct data_cb cs_data_conn_cb = {
- .wake = cs_conn_process,
- .name = "STRM",
-};
-
-struct data_cb cs_data_applet_cb = {
.wake = cs_applet_process,
.name = "STRM",
};
+/* stream connector for health checks on connections */
+struct sc_app_ops sc_app_check_ops = {
+ .chk_rcv = NULL,
+ .chk_snd = NULL,
+ .shutr = NULL,
+ .shutw = NULL,
+ .wake = wake_srv_chk,
+ .name = "CHCK",
+};
/* Initializes an endpoint */
void sedesc_init(struct sedesc *sedesc)
@@ -130,7 +135,7 @@
cs->state = SC_ST_INI;
cs->hcto = TICK_ETERNITY;
cs->app = NULL;
- cs->data_cb = NULL;
+ cs->app_ops = NULL;
cs->src = NULL;
cs->dst = NULL;
cs->wait_event.tasklet = NULL;
@@ -185,8 +190,7 @@
cs->flags |= flags;
sc_ep_set(cs, SE_FL_DETACHED);
cs->app = &strm->obj_type;
- cs->ops = &sc_app_embedded_ops;
- cs->data_cb = NULL;
+ cs->app_ops = &sc_app_embedded_ops;
return cs;
}
@@ -204,7 +208,7 @@
cs->flags |= flags;
sc_ep_set(cs, SE_FL_DETACHED);
cs->app = &check->obj_type;
- cs->data_cb = &check_conn_cb;
+ cs->app_ops = &sc_app_check_ops;
return cs;
}
@@ -264,8 +268,7 @@
cs->wait_event.events = 0;
}
- cs->ops = &sc_app_conn_ops;
- cs->data_cb = &cs_data_conn_cb;
+ cs->app_ops = &sc_app_conn_ops;
}
else if (cs_check(cs)) {
if (!cs->wait_event.tasklet) {
@@ -277,7 +280,7 @@
cs->wait_event.events = 0;
}
- cs->data_cb = &check_conn_cb;
+ cs->app_ops = &sc_app_check_ops;
}
return 0;
}
@@ -292,10 +295,8 @@
cs->sedesc->se = endp;
sc_ep_set(cs, SE_FL_T_APPLET);
sc_ep_clr(cs, SE_FL_DETACHED);
- if (cs_strm(cs)) {
- cs->ops = &sc_app_applet_ops;
- cs->data_cb = &cs_data_applet_cb;
- }
+ if (cs_strm(cs))
+ cs->app_ops = &sc_app_applet_ops;
}
/* Attaches a stconn to a app layer and sets the relevant
@@ -315,16 +316,13 @@
cs->wait_event.tasklet->context = cs;
cs->wait_event.events = 0;
- cs->ops = &sc_app_conn_ops;
- cs->data_cb = &cs_data_conn_cb;
+ cs->app_ops = &sc_app_conn_ops;
}
else if (sc_ep_test(cs, SE_FL_T_APPLET)) {
- cs->ops = &sc_app_applet_ops;
- cs->data_cb = &cs_data_applet_cb;
+ cs->app_ops = &sc_app_applet_ops;
}
else {
- cs->ops = &sc_app_embedded_ops;
- cs->data_cb = NULL;
+ cs->app_ops = &sc_app_embedded_ops;
}
return 0;
}
@@ -393,8 +391,9 @@
*/
cs->flags &= SC_FL_ISBACK;
if (cs_strm(cs))
- cs->ops = &sc_app_embedded_ops;
- cs->data_cb = NULL;
+ cs->app_ops = &sc_app_embedded_ops;
+ else
+ cs->app_ops = NULL;
cs_free_cond(csp);
}
@@ -409,7 +408,7 @@
return;
cs->app = NULL;
- cs->data_cb = NULL;
+ cs->app_ops = NULL;
sockaddr_free(&cs->src);
sockaddr_free(&cs->dst);
diff --git a/src/connection.c b/src/connection.c
index f286445..e4d26dd 100644
--- a/src/connection.c
+++ b/src/connection.c
@@ -91,7 +91,7 @@
return 0;
fail:
/* let the upper layer know the connection failed */
- cs->data_cb->wake(cs);
+ cs->app_ops->wake(cs);
return -1;
} else
return conn_complete_session(conn);
diff --git a/src/mux_fcgi.c b/src/mux_fcgi.c
index 7a7ea25..bd95aa5 100644
--- a/src/mux_fcgi.c
+++ b/src/mux_fcgi.c
@@ -977,9 +977,9 @@
fcgi_strm_notify_recv(fstrm);
fcgi_strm_notify_send(fstrm);
}
- else if (fcgi_strm_sc(fstrm) && fcgi_strm_sc(fstrm)->data_cb->wake != NULL) {
+ else if (fcgi_strm_sc(fstrm) && fcgi_strm_sc(fstrm)->app_ops->wake != NULL) {
TRACE_POINT(FCGI_EV_STRM_WAKE, fstrm->fconn->conn, fstrm);
- fcgi_strm_sc(fstrm)->data_cb->wake(fcgi_strm_sc(fstrm));
+ fcgi_strm_sc(fstrm)->app_ops->wake(fcgi_strm_sc(fstrm));
}
}
diff --git a/src/mux_h1.c b/src/mux_h1.c
index f0f4372..87a2970 100644
--- a/src/mux_h1.c
+++ b/src/mux_h1.c
@@ -2625,9 +2625,9 @@
h1_wake_stream_for_recv(h1s);
h1_wake_stream_for_send(h1s);
}
- else if (h1s_sc(h1s) && h1s_sc(h1s)->data_cb->wake != NULL) {
+ else if (h1s_sc(h1s) && h1s_sc(h1s)->app_ops->wake != NULL) {
TRACE_POINT(H1_EV_STRM_WAKE, h1s->h1c->conn, h1s);
- h1s_sc(h1s)->data_cb->wake(h1s_sc(h1s));
+ h1s_sc(h1s)->app_ops->wake(h1s_sc(h1s));
}
}
diff --git a/src/mux_h2.c b/src/mux_h2.c
index 694d6a7..dde18dc 100644
--- a/src/mux_h2.c
+++ b/src/mux_h2.c
@@ -1334,9 +1334,9 @@
h2s_notify_recv(h2s);
h2s_notify_send(h2s);
}
- else if (h2s_sc(h2s) && h2s_sc(h2s)->data_cb->wake != NULL) {
+ else if (h2s_sc(h2s) && h2s_sc(h2s)->app_ops->wake != NULL) {
TRACE_POINT(H2_EV_STRM_WAKE, h2s->h2c->conn, h2s);
- h2s_sc(h2s)->data_cb->wake(h2s_sc(h2s));
+ h2s_sc(h2s)->app_ops->wake(h2s_sc(h2s));
}
TRACE_LEAVE(H2_EV_H2S_WAKE, h2s->h2c->conn, h2s);
diff --git a/src/mux_pt.c b/src/mux_pt.c
index fefccd9..cbfc789 100644
--- a/src/mux_pt.c
+++ b/src/mux_pt.c
@@ -252,8 +252,8 @@
ctx->conn->subs->events = 0;
tasklet_wakeup(ctx->conn->subs->tasklet);
ctx->conn->subs = NULL;
- } else if (pt_sc(ctx)->data_cb->wake)
- pt_sc(ctx)->data_cb->wake(pt_sc(ctx));
+ } else if (pt_sc(ctx)->app_ops->wake)
+ pt_sc(ctx)->app_ops->wake(pt_sc(ctx));
TRACE_DEVEL("leaving waking up CS", PT_EV_CONN_WAKE, ctx->conn);
return t;
}
@@ -349,7 +349,7 @@
TRACE_ENTER(PT_EV_CONN_WAKE, ctx->conn);
if (!se_fl_test(ctx->endp, SE_FL_ORPHAN)) {
- ret = pt_sc(ctx)->data_cb->wake ? pt_sc(ctx)->data_cb->wake(pt_sc(ctx)) : 0;
+ ret = pt_sc(ctx)->app_ops->wake ? pt_sc(ctx)->app_ops->wake(pt_sc(ctx)) : 0;
if (ret < 0) {
TRACE_DEVEL("leaving waking up CS", PT_EV_CONN_WAKE, ctx->conn);
diff --git a/src/mux_quic.c b/src/mux_quic.c
index e0036c0..9b37d05 100644
--- a/src/mux_quic.c
+++ b/src/mux_quic.c
@@ -1594,8 +1594,8 @@
qcs_notify_recv(qcs);
qcs_notify_send(qcs);
}
- else if (qcs->endp->sc->data_cb->wake) {
- qcs->endp->sc->data_cb->wake(qcs->endp->sc);
+ else if (qcs->endp->sc->app_ops->wake) {
+ qcs->endp->sc->app_ops->wake(qcs->endp->sc);
}
}
}