mirror of
https://git.haproxy.org/git/haproxy.git/
synced 2025-11-07 12:01:31 +01:00
fe127937a8
The applets don't fiddle with SI_FL_WAIT_ROOM anymore, instead they indicate what they want, possibly that they failed (eg: WAIT_ROOM), and it's done() / update() which finally updates the WAIT_* flags according to the channels' and stream interface's states. This solves the issue of the pauses during a "show sess" without creating busy loops.
51 lines
1.2 KiB
C
51 lines
1.2 KiB
C
/*
|
|
* Functions managing applets
|
|
*
|
|
* Copyright 2000-2015 Willy Tarreau <w@1wt.eu>
|
|
*
|
|
* This program is free software; you can redistribute it and/or
|
|
* modify it under the terms of the GNU General Public License
|
|
* as published by the Free Software Foundation; either version
|
|
* 2 of the License, or (at your option) any later version.
|
|
*
|
|
*/
|
|
|
|
#include <stdio.h>
|
|
#include <stdlib.h>
|
|
|
|
#include <common/config.h>
|
|
#include <common/mini-clist.h>
|
|
#include <proto/applet.h>
|
|
#include <proto/stream.h>
|
|
#include <proto/stream_interface.h>
|
|
|
|
struct list applet_runq = LIST_HEAD_INIT(applet_runq);
|
|
|
|
void applet_run_active()
|
|
{
|
|
struct appctx *curr, *back;
|
|
struct stream_interface *si;
|
|
|
|
list_for_each_entry_safe(curr, back, &applet_runq, runq) {
|
|
si = curr->owner;
|
|
|
|
/* now we'll need a buffer */
|
|
if (!stream_alloc_recv_buffer(si_ic(si))) {
|
|
si->flags |= SI_FL_WAIT_ROOM;
|
|
LIST_DEL(&curr->runq);
|
|
LIST_INIT(&curr->runq);
|
|
continue;
|
|
}
|
|
|
|
/* We always pretend the applet can't get and doesn't want to
|
|
* put, it's up to it to change this if needed. This ensures
|
|
* that one applet which ignores any event will not spin.
|
|
*/
|
|
si_applet_cant_get(si);
|
|
si_applet_stop_put(si);
|
|
|
|
curr->applet->fct(curr);
|
|
si_applet_done(si);
|
|
}
|
|
}
|