This function is a callback made only for calls from the applet handler.
Rename it to remove confusion. It's currently called from the Lua code
but that's not correct, we should call the notify and update functions
instead otherwise it will not enable the applet again.
extern struct data_cb si_idle_conn_cb;
struct appctx *stream_int_register_handler(struct stream_interface *si, struct applet *app);
-void si_applet_done(struct stream_interface *si);
+void si_applet_wake_cb(struct stream_interface *si);
void stream_int_update(struct stream_interface *si);
void stream_int_update_conn(struct stream_interface *si);
void stream_int_update_applet(struct stream_interface *si);
si_applet_stop_put(si);
curr->applet->fct(curr);
- si_applet_done(si);
+ si_applet_wake_cb(si);
if (applet_run_queue.n == &curr->runq) {
/* curr was left in the list, move it back to the active list */
bo_skip(oc, len + skip_at_end);
/* Don't wait anything. */
- si_applet_done(&socket->s->si[0]);
+ si_applet_wake_cb(&socket->s->si[0]);
/* If the pattern reclaim to read all the data
* in the connection, got out.
}
/* update buffers. */
- si_applet_done(&socket->s->si[0]);
+ si_applet_wake_cb(&socket->s->si[0]);
socket->s->req.rex = TICK_ETERNITY;
socket->s->res.wex = TICK_ETERNITY;
* may disable the applet's based on the channels and stream interface's final
* states.
*/
-void si_applet_done(struct stream_interface *si)
+void si_applet_wake_cb(struct stream_interface *si)
{
/* update the stream-int, channels, and possibly wake the stream up */
stream_int_notify(si);