appctx->applet->release(appctx);
}
-/* let an applet indicate that it wants to put some data into the input buffer */
-static inline void si_applet_want_put(struct stream_interface *si)
+/* Report that a stream interface wants to put some data into the input buffer */
+static inline void si_want_put(struct stream_interface *si)
{
si->flags |= SI_FL_WANT_PUT;
}
-/* let an applet indicate that it wanted to put some data into the input buffer
- * but it couldn't.
- */
-static inline void si_applet_cant_put(struct stream_interface *si)
+/* Report that a stream interface failed to put some data into the input buffer */
+static inline void si_cant_put(struct stream_interface *si)
{
si->flags |= SI_FL_WANT_PUT | SI_FL_WAIT_ROOM;
}
-/* let an applet indicate that it doesn't want to put data into the input buffer */
-static inline void si_applet_stop_put(struct stream_interface *si)
+/* Report that a stream interface doesn't want to put data into the input buffer */
+static inline void si_stop_put(struct stream_interface *si)
{
si->flags &= ~SI_FL_WANT_PUT;
}
-/* let an applet indicate that it wants to get some data from the output buffer */
-static inline void si_applet_want_get(struct stream_interface *si)
+/* Report that a stream interface wants to get some data from the output buffer */
+static inline void si_want_get(struct stream_interface *si)
{
si->flags |= SI_FL_WANT_GET;
}
-/* let an applet indicate that it wanted to get some data from the output buffer
- * but it couldn't.
- */
-static inline void si_applet_cant_get(struct stream_interface *si)
+/* Report that a stream interface failed to get some data from the output buffer */
+static inline void si_cant_get(struct stream_interface *si)
{
si->flags |= SI_FL_WANT_GET | SI_FL_WAIT_DATA;
}
-/* let an applet indicate that it doesn't want to get data from the input buffer */
-static inline void si_applet_stop_get(struct stream_interface *si)
+/* Report that a stream interface doesn't want to get data from the output buffer */
+static inline void si_stop_get(struct stream_interface *si)
{
si->flags &= ~SI_FL_WANT_GET;
}
SI_FL_NONE = 0x0000, /* nothing */
SI_FL_EXP = 0x0001, /* timeout has expired */
SI_FL_ERR = 0x0002, /* a non-recoverable error has occurred */
- SI_FL_WAIT_ROOM = 0x0004, /* waiting for space to store incoming data */
- SI_FL_WAIT_DATA = 0x0008, /* waiting for more data to send */
+ SI_FL_WAIT_ROOM = 0x0004, /* stream-int waits for space to store incoming data */
+ SI_FL_WAIT_DATA = 0x0008, /* stream-int waits for more outgoing data to send */
SI_FL_ISBACK = 0x0010, /* 0 for front-side SI, 1 for back-side */
SI_FL_DONT_WAKE = 0x0020, /* resync in progress, don't wake up */
SI_FL_INDEP_STR = 0x0040, /* independent streams = don't update rex on write */
SI_FL_NOLINGER = 0x0080, /* may close without lingering. One-shot. */
SI_FL_NOHALF = 0x0100, /* no half close, close both sides at once */
SI_FL_SRC_ADDR = 0x1000, /* get the source ip/port with getsockname */
- SI_FL_WANT_PUT = 0x2000, /* an applet would like to put some data into the buffer */
- SI_FL_WANT_GET = 0x4000, /* an applet would like to get some data from the buffer */
+ SI_FL_WANT_PUT = 0x2000, /* a stream-int would like to put some data into the buffer */
+ SI_FL_WANT_GET = 0x4000, /* a stream-int would like to get some data from the buffer */
SI_FL_CLEAN_ABRT = 0x8000, /* SI_FL_ERR is used to report aborts, and not SHUTR */
};
* check if this buffer was allocated or not. This let a chance
* for applets to do some other processing if needed. */
if (!si_alloc_ibuf(si, &app->buffer_wait))
- si_applet_cant_put(si);
+ si_cant_put(si);
/* 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);
+ si_cant_get(si);
+ si_stop_put(si);
app->applet->fct(app);
si_applet_wake_cb(si);
offset = 0;
if (ret <= 0) {
if (ret == -3 || ret == -1) {
- si_applet_cant_put(si);
+ si_cant_put(si);
break;
}
return -1;
/* Check if the input buffer is avalaible. */
if (res->buf.size == 0) {
- si_applet_cant_put(si);
+ si_cant_put(si);
goto out;
}
if (!next_key) {
chunk_printf(&trash, "%p: %s (shctx:%p, available blocks:%d)\n", cache, cache->id, shctx_ptr(cache), shctx_ptr(cache)->nbav);
if (ci_putchk(si_ic(si), &trash) == -1) {
- si_applet_cant_put(si);
+ si_cant_put(si);
return 0;
}
}
shctx_unlock(shctx_ptr(cache));
if (ci_putchk(si_ic(si), &trash) == -1) {
- si_applet_cant_put(si);
+ si_cant_put(si);
return 0;
}
}
/* Check if the input buffer is avalaible. */
if (res->buf.size == 0) {
- si_applet_cant_put(si);
+ si_cant_put(si);
goto out;
}
* would want to return some info right after parsing.
*/
if (buffer_almost_full(si_ib(si))) {
- si_applet_cant_put(si);
+ si_cant_put(si);
break;
}
cli_get_severity_output(appctx)) != -1)
appctx->st0 = CLI_ST_PROMPT;
else
- si_applet_cant_put(si);
+ si_cant_put(si);
break;
case CLI_ST_PRINT_FREE: {
const char *msg = appctx->ctx.cli.err;
appctx->st0 = CLI_ST_PROMPT;
}
else
- si_applet_cant_put(si);
+ si_cant_put(si);
break;
}
case CLI_ST_CALLBACK: /* use custom pointer */
if (ci_putstr(si_ic(si), prompt) != -1)
appctx->st0 = CLI_ST_GETREQ;
else
- si_applet_cant_put(si);
+ si_cant_put(si);
}
/* If the output functions are still there, it means they require more room. */
chunk_printf(&trash, "%s\n", *var);
if (ci_putchk(si_ic(si), &trash) == -1) {
- si_applet_cant_put(si);
+ si_cant_put(si);
return 0;
}
if (appctx->st2 == STAT_ST_END)
chunk_appendf(&trash, "\n");
if (ci_putchk(si_ic(si), &trash) == -1) {
- si_applet_cant_put(si);
+ si_cant_put(si);
return 0;
}
skip:
if (ci_putchk(si_ic(si), &trash) == -1) {
chunk_reset(&trash);
chunk_printf(&trash, "[output too large, cannot dump]\n");
- si_applet_cant_put(si);
+ si_cant_put(si);
}
/* dump complete */
case STAT_ST_INIT:
chunk_printf(&trash, "# socket lvl processes\n");
if (ci_putchk(si_ic(si), &trash) == -1) {
- si_applet_cant_put(si);
+ si_cant_put(si);
return 0;
}
appctx->st2 = STAT_ST_LIST;
}
if (ci_putchk(si_ic(si), &trash) == -1) {
- si_applet_cant_put(si);
+ si_cant_put(si);
return 0;
}
}
}
if (ci_putchk(si_ic(si), &trash) == -1) {
- si_applet_cant_put(si);
+ si_cant_put(si);
return 0;
}
ret = ci_putblk(si_ic(si), buf, framesz+4);
if (ret <= 0) {
if ((ret == -3 && b_is_null(&si_ic(si)->buf)) || ret == -1) {
- si_applet_cant_put(si);
+ si_cant_put(si);
return 1; /* retry */
}
SPOE_APPCTX(appctx)->status_code = SPOE_FRM_ERR_IO;
static int
spoe_wakeup_appctx(struct appctx *appctx)
{
- si_applet_want_get(appctx->owner);
- si_applet_want_put(appctx->owner);
+ si_want_get(appctx->owner);
+ si_want_put(appctx->owner);
appctx_wakeup(appctx);
return 1;
}
int ret;
if (si->state <= SI_ST_CON) {
- si_applet_want_put(si);
+ si_want_put(si);
task_wakeup(si_strm(si)->task, TASK_WOKEN_MSG);
goto stop;
}
stream_set_backend(strm, conf->agent->b.be);
/* applet is waiting for data */
- si_applet_cant_get(&strm->si[0]);
+ si_cant_get(&strm->si[0]);
appctx_wakeup(appctx);
strm->do_log = NULL;
* to be notified whenever the connection completes.
*/
if (!(c->flags & CO_FL_CONNECTED)) {
- si_applet_cant_get(si);
- si_applet_cant_put(si);
+ si_cant_get(si);
+ si_cant_put(si);
return;
}
* to write, so we set the flag cant put
*/
if (notification_registered(&appctx->ctx.hlua_cosocket.wake_on_write))
- si_applet_cant_put(si);
+ si_cant_put(si);
}
/* This function is called when the "struct stream" is destroyed.
/* inform the stream that we want to be notified whenever the
* connection completes.
*/
- si_applet_cant_get(&s->si[0]);
- si_applet_cant_put(&s->si[0]);
+ si_cant_get(&s->si[0]);
+ si_cant_put(&s->si[0]);
appctx_wakeup(appctx);
hlua->flags |= HLUA_MUST_GC;
* the request buffer if its not required.
*/
if (chn->buf.size == 0) {
- si_applet_cant_put(chn_prod(chn));
+ si_cant_put(chn_prod(chn));
MAY_LJMP(hlua_yieldk(L, 0, 0, hlua_channel_append_yield, TICK_ETERNITY, 0));
}
* the request buffer if its not required.
*/
if (chn->buf.size == 0) {
- si_applet_cant_put(chn_prod(chn));
+ si_cant_put(chn_prod(chn));
MAY_LJMP(hlua_yieldk(L, 0, 0, hlua_channel_send_yield, TICK_ETERNITY, 0));
}
/* Data not yet avalaible. return yield. */
if (ret == 0) {
- si_applet_cant_get(si);
+ si_cant_get(si);
MAY_LJMP(hlua_yieldk(L, 0, 0, hlua_applet_tcp_getline_yield, TICK_ETERNITY, 0));
}
/* Data not yet avalaible. return yield. */
if (ret == 0) {
- si_applet_cant_get(si);
+ si_cant_get(si);
MAY_LJMP(hlua_yieldk(L, 0, 0, hlua_applet_tcp_recv_yield, TICK_ETERNITY, 0));
}
luaL_addlstring(&appctx->b, blk1, len1);
luaL_addlstring(&appctx->b, blk2, len2);
co_skip(si_oc(si), len1 + len2);
- si_applet_cant_get(si);
+ si_cant_get(si);
MAY_LJMP(hlua_yieldk(L, 0, 0, hlua_applet_tcp_recv_yield, TICK_ETERNITY, 0));
} else {
if (len > 0) {
lua_pushinteger(L, len);
lua_replace(L, 2);
- si_applet_cant_get(si);
+ si_cant_get(si);
MAY_LJMP(hlua_yieldk(L, 0, 0, hlua_applet_tcp_recv_yield, TICK_ETERNITY, 0));
}
* applet, and returns a yield.
*/
if (l < len) {
- si_applet_cant_put(si);
+ si_cant_put(si);
MAY_LJMP(hlua_yieldk(L, 0, 0, hlua_applet_tcp_send_yield, TICK_ETERNITY, 0));
}
* If ret is -1, we dont have room in the buffer, so we yield.
*/
if (ret == -1) {
- si_applet_cant_put(si);
+ si_cant_put(si);
MAY_LJMP(hlua_yieldk(L, 0, 0, hlua_applet_http_getline_yield, TICK_ETERNITY, 0));
}
appctx->appctx->ctx.hlua_apphttp.flags &= ~APPLET_100C;
/* Data not yet avalaible. return yield. */
if (ret == 0) {
- si_applet_cant_get(si);
+ si_cant_get(si);
MAY_LJMP(hlua_yieldk(L, 0, 0, hlua_applet_http_getline_yield, TICK_ETERNITY, 0));
}
* If ret is -1, we dont have room in the buffer, so we yield.
*/
if (ret == -1) {
- si_applet_cant_put(si);
+ si_cant_put(si);
MAY_LJMP(hlua_yieldk(L, 0, 0, hlua_applet_http_recv_yield, TICK_ETERNITY, 0));
}
appctx->appctx->ctx.hlua_apphttp.flags &= ~APPLET_100C;
/* Data not yet avalaible. return yield. */
if (ret == 0) {
- si_applet_cant_get(si);
+ si_cant_get(si);
MAY_LJMP(hlua_yieldk(L, 0, 0, hlua_applet_http_recv_yield, TICK_ETERNITY, 0));
}
if (len > 0) {
lua_pushinteger(L, len);
lua_replace(L, 2);
- si_applet_cant_get(si);
+ si_cant_get(si);
MAY_LJMP(hlua_yieldk(L, 0, 0, hlua_applet_http_recv_yield, TICK_ETERNITY, 0));
}
* applet, and returns a yield.
*/
if (l < len) {
- si_applet_cant_put(si);
+ si_cant_put(si);
MAY_LJMP(hlua_yieldk(L, 0, 0, hlua_applet_http_send_yield, TICK_ETERNITY, 0));
}
/* If ret is -1, we dont have room in the buffer, so we yield. */
if (ret == -1) {
- si_applet_cant_put(si);
+ si_cant_put(si);
MAY_LJMP(hlua_yieldk(L, 0, 0, hlua_applet_http_start_response_yield, TICK_ETERNITY, 0));
}
* will send some data and after call the applet, otherwise it call
* the applet ASAP.
*/
- si_applet_cant_put(si);
+ si_cant_put(si);
appctx_wakeup(ctx);
t->expire = TICK_ETERNITY;
return t;
RESET_SAFE_LJMP(hlua->T);
/* Wakeup the applet ASAP. */
- si_applet_cant_get(si);
- si_applet_cant_put(si);
+ si_cant_get(si);
+ si_cant_put(si);
return 1;
}
RESET_SAFE_LJMP(hlua->T);
/* Wakeup the applet when data is ready for read. */
- si_applet_cant_get(si);
+ si_cant_get(si);
return 1;
}
/* Wait for full HTTP analysys. */
if (unlikely(strm->txn->req.msg_state < HTTP_MSG_BODY)) {
- si_applet_cant_get(si);
+ si_cant_get(si);
return;
}
if (ret == 0)
len1 = 0;
if (len1 + len2 < strm->txn->req.eoh + strm->txn->req.eol) {
- si_applet_cant_get(si);
+ si_cant_get(si);
return;
}
/* no enough space error. */
if (ret == -1) {
- si_applet_cant_put(si);
+ si_cant_put(si);
return;
}
case HLUA_E_AGAIN:
/* We want write. */
if (HLUA_IS_WAKERESWR(hlua))
- si_applet_cant_put(si);
+ si_cant_put(si);
/* Set the timeout. */
if (hlua->wake_time != TICK_ETERNITY)
task_schedule(hlua->task, hlua->wake_time);
const char *msg = (startup_logs ? startup_logs : "No startup alerts/warnings.\n");
if (ci_putstr(si_ic(si), msg) == -1) {
- si_applet_cant_put(si);
+ si_cant_put(si);
return 0;
}
return 1;
*/
LIST_ADDQ(&elt->back_refs, &appctx->ctx.map.bref.users);
HA_SPIN_UNLOCK(PATREF_LOCK, &appctx->ctx.map.ref->lock);
- si_applet_cant_put(si);
+ si_cant_put(si);
return 0;
}
chunk_reset(&trash);
chunk_appendf(&trash, "# id (file) description\n");
if (ci_putchk(si_ic(si), &trash) == -1) {
- si_applet_cant_put(si);
+ si_cant_put(si);
return 0;
}
/* let's try again later from this stream. We add ourselves into
* this stream's users so that it can remove us upon termination.
*/
- si_applet_cant_put(si);
+ si_cant_put(si);
return 0;
}
* this stream's users so that it can remove us upon termination.
*/
HA_SPIN_UNLOCK(PATREF_LOCK, &appctx->ctx.map.ref->lock);
- si_applet_cant_put(si);
+ si_cant_put(si);
return 0;
}
dump_pools_to_trash();
if (ci_putchk(si_ic(si), &trash) == -1) {
- si_applet_cant_put(si);
+ si_cant_put(si);
return 0;
}
return 1;
HA_SPIN_UNLOCK(PEER_LOCK, &curpeer->lock);
return;
full:
- si_applet_cant_put(si);
+ si_cant_put(si);
goto out;
}
s->flags = SF_ASSIGNED|SF_ADDR_SET;
/* applet is waiting for data */
- si_applet_cant_get(&s->si[0]);
+ si_cant_get(&s->si[0]);
appctx_wakeup(appctx);
/* initiate an outgoing connection */
bk_f_forced_id, srv_f_forced_id, srv->hostname ? srv->hostname : "-", srv->svc_port,
srvrecord ? srvrecord : "-");
if (ci_putchk(si_ic(si), &trash) == -1) {
- si_applet_cant_put(si);
+ si_cant_put(si);
return 0;
}
}
if (appctx->st2 == STAT_ST_HEAD) {
chunk_printf(&trash, "%d\n# %s\n", SRV_STATE_FILE_VERSION, SRV_STATE_FILE_FIELD_NAMES);
if (ci_putchk(si_ic(si), &trash) == -1) {
- si_applet_cant_put(si);
+ si_cant_put(si);
return 0;
}
appctx->st2 = STAT_ST_INFO;
if (!appctx->ctx.cli.p0) {
chunk_printf(&trash, "# name\n");
if (ci_putchk(si_ic(si), &trash) == -1) {
- si_applet_cant_put(si);
+ si_cant_put(si);
return 0;
}
appctx->ctx.cli.p0 = proxies_list;
chunk_appendf(&trash, "%s\n", curproxy->id);
if (ci_putchk(si_ic(si), &trash) == -1) {
- si_applet_cant_put(si);
+ si_cant_put(si);
return 0;
}
}
cant_send_unlock:
HA_SPIN_UNLOCK(PROXY_LOCK, &appctx->ctx.errors.px->lock);
cant_send:
- si_applet_cant_put(si);
+ si_cant_put(si);
return 0;
}
snprintf(trash.area, trash.size, "%d (initial %d)\n", sv->uweight,
sv->iweight);
if (ci_putstr(si_ic(si), trash.area) == -1) {
- si_applet_cant_put(si);
+ si_cant_put(si);
return 0;
}
return 1;
chunk_appendf(&trash, "# id (file)\n");
if (ci_putchk(si_ic(si), &trash) == -1) {
- si_applet_cant_put(si);
+ si_cant_put(si);
return 0;
}
* this stream's users so that it can remove us upon termination.
*/
HA_RWLOCK_RDUNLOCK(TLSKEYS_REF_LOCK, &ref->lock);
- si_applet_cant_put(si);
+ si_cant_put(si);
return 0;
}
appctx->ctx.cli.i1++;
/* let's try again later from this stream. We add ourselves into
* this stream's users so that it can remove us upon termination.
*/
- si_applet_cant_put(si);
+ si_cant_put(si);
return 0;
}
if (appctx->ctx.stats.flags & STAT_FMT_HTML) {
stats_dump_html_px_hdr(si, px, uri);
if (ci_putchk(rep, &trash) == -1) {
- si_applet_cant_put(si);
+ si_cant_put(si);
return 0;
}
}
/* print the frontend */
if (stats_dump_fe_stats(si, px)) {
if (ci_putchk(rep, &trash) == -1) {
- si_applet_cant_put(si);
+ si_cant_put(si);
return 0;
}
}
/* stats.l has been initialized above */
for (; appctx->ctx.stats.l != &px->conf.listeners; appctx->ctx.stats.l = l->by_fe.n) {
if (buffer_almost_full(&rep->buf)) {
- si_applet_cant_put(si);
+ si_cant_put(si);
return 0;
}
/* print the frontend */
if (stats_dump_li_stats(si, px, l, flags)) {
if (ci_putchk(rep, &trash) == -1) {
- si_applet_cant_put(si);
+ si_cant_put(si);
return 0;
}
}
/* stats.sv has been initialized above */
for (; appctx->ctx.stats.sv != NULL; appctx->ctx.stats.sv = sv->next) {
if (buffer_almost_full(&rep->buf)) {
- si_applet_cant_put(si);
+ si_cant_put(si);
return 0;
}
if (stats_dump_sv_stats(si, px, flags, sv)) {
if (ci_putchk(rep, &trash) == -1) {
- si_applet_cant_put(si);
+ si_cant_put(si);
return 0;
}
}
/* print the backend */
if (stats_dump_be_stats(si, px, flags)) {
if (ci_putchk(rep, &trash) == -1) {
- si_applet_cant_put(si);
+ si_cant_put(si);
return 0;
}
}
if (appctx->ctx.stats.flags & STAT_FMT_HTML) {
stats_dump_html_px_end(si, px);
if (ci_putchk(rep, &trash) == -1) {
- si_applet_cant_put(si);
+ si_cant_put(si);
return 0;
}
}
stats_dump_csv_header();
if (ci_putchk(rep, &trash) == -1) {
- si_applet_cant_put(si);
+ si_cant_put(si);
return 0;
}
if (appctx->ctx.stats.flags & STAT_FMT_HTML) {
stats_dump_html_info(si, uri);
if (ci_putchk(rep, &trash) == -1) {
- si_applet_cant_put(si);
+ si_cant_put(si);
return 0;
}
}
/* dump proxies */
while (appctx->ctx.stats.px) {
if (buffer_almost_full(&rep->buf)) {
- si_applet_cant_put(si);
+ si_cant_put(si);
return 0;
}
else
stats_dump_json_end();
if (ci_putchk(rep, &trash) == -1) {
- si_applet_cant_put(si);
+ si_cant_put(si);
return 0;
}
}
chunk_appendf(&trash, "\r\n");
if (ci_putchk(si_ic(si), &trash) == -1) {
- si_applet_cant_put(si);
+ si_cant_put(si);
return 0;
}
scope_txt);
if (ci_putchk(si_ic(si), &trash) == -1) {
- si_applet_cant_put(si);
+ si_cant_put(si);
return 0;
}
/* Check if the input buffer is avalaible. */
if (res->buf.size == 0) {
- si_applet_cant_put(si);
+ si_cant_put(si);
goto out;
}
si_ic(si)->to_forward = 0;
chunk_printf(&trash, "\r\n000000\r\n");
if (ci_putchk(si_ic(si), &trash) == -1) {
- si_applet_cant_put(si);
+ si_cant_put(si);
si_ic(si)->to_forward = last_fwd;
goto out;
}
if (last_len != data_len) {
chunk_printf(&trash, "\r\n%06x\r\n", (last_len - data_len));
if (ci_putchk(si_ic(si), &trash) == -1)
- si_applet_cant_put(si);
+ si_cant_put(si);
si_ic(si)->total += (last_len - data_len);
b_add(si_ib(si), last_len - data_len);
if (appctx->ctx.stats.flags & STAT_CHUNKED) {
chunk_printf(&trash, "\r\n0\r\n\r\n");
if (ci_putchk(si_ic(si), &trash) == -1) {
- si_applet_cant_put(si);
+ si_cant_put(si);
goto out;
}
}
* emitting large blocks into small TCP windows.
*/
if (!channel_is_empty(res))
- si_applet_stop_get(si);
+ si_stop_get(si);
}
/* Dump all fields from <info> into <out> using the "show info" format (name: value) */
stats_dump_info_fields(&trash, info);
if (ci_putchk(si_ic(si), &trash) == -1) {
- si_applet_cant_put(si);
+ si_cant_put(si);
return 0;
}
stats_dump_json_schema(&trash);
if (ci_putchk(si_ic(si), &trash) == -1) {
- si_applet_cant_put(si);
+ si_cant_put(si);
return 0;
}
chunk_appendf(msg, "# contents not dumped due to insufficient privileges\n");
if (ci_putchk(si_ic(si), msg) == -1) {
- si_applet_cant_put(si);
+ si_cant_put(si);
return 0;
}
chunk_appendf(msg, "\n");
if (ci_putchk(si_ic(si), msg) == -1) {
- si_applet_cant_put(si);
+ si_cant_put(si);
return 0;
}
/* finish initialization of the accepted file descriptor */
if (appctx)
- si_applet_want_get(&s->si[0]);
+ si_want_get(&s->si[0]);
if (sess->fe->accept && sess->fe->accept(s) < 0)
goto out_fail_accept;
/* Stops the applet sheduling, in case of the init function miss
* some data.
*/
- si_applet_stop_get(&s->si[1]);
+ si_stop_get(&s->si[1]);
/* Call initialisation. */
if (rule->applet.init)
}
/* Now we can schedule the applet. */
- si_applet_cant_get(&s->si[1]);
+ si_cant_get(&s->si[1]);
appctx_wakeup(appctx);
if (sess->fe == s->be) /* report it if the request was intercepted by the frontend */
/* stream changed, no need to go any further */
chunk_appendf(&trash, " *** session terminated while we were watching it ***\n");
if (ci_putchk(si_ic(si), &trash) == -1) {
- si_applet_cant_put(si);
+ si_cant_put(si);
return 0;
}
appctx->ctx.sess.uid = 0;
(unsigned int)strm->res.buf.size);
if (ci_putchk(si_ic(si), &trash) == -1) {
- si_applet_cant_put(si);
+ si_cant_put(si);
return 0;
}
/* let's try again later from this stream. We add ourselves into
* this stream's users so that it can remove us upon termination.
*/
- si_applet_cant_put(si);
+ si_cant_put(si);
LIST_ADDQ(&curr_strm->back_refs, &appctx->ctx.sess.bref.users);
HA_SPIN_UNLOCK(STRMS_LOCK, &streams_lock);
return 0;
chunk_appendf(&trash, "Session not found.\n");
if (ci_putchk(si_ic(si), &trash) == -1) {
- si_applet_cant_put(si);
+ si_cant_put(si);
HA_SPIN_UNLOCK(STRMS_LOCK, &streams_lock);
return 0;
}
if (!appctx)
return NULL;
- si_applet_cant_get(si);
+ si_cant_get(si);
appctx_wakeup(appctx);
return si_appctx(si);
}
projects / thirdparty / haproxy.git / commitdiff
