static void helperRequestFree(helper_request * r);
static void helperStatefulRequestFree(helper_stateful_request * r);
static void StatefulEnqueue(statefulhelper * hlp, helper_stateful_request * r);
+static void helperStatefulServerKickQueue(helper_stateful_server * srv);
static bool helperStartStats(StoreEntry *sentry, void *hlp, const char *label);
if ((buf != NULL) && lastserver) {
debugs(84, 5, "StatefulSubmit with lastserver " << lastserver);
- assert(lastserver->flags.reserved == S_HELPER_RESERVED;
- asser(!(lastserver->request));
+ assert(lastserver->flags.reserved == S_HELPER_RESERVED);
+ assert(!(lastserver->request));
debugs(84, 5, "StatefulSubmit dispatching");
helperStatefulDispatch(lastserver, r);
case S_HELPER_RESERVE: /* 'pin' this helper for the caller */
- srv->flags.reserved = S_HELPER_RESERVED;
- debugs(84, 5, "StatefulHandleRead: reserving " << hlp->id_name << " #" << srv->index + 1);
+ srv->flags.reserved = S_HELPER_RESERVED;
+ debugs(84, 5, "StatefulHandleRead: reserving " << hlp->id_name << " #" << srv->index + 1);
break;
static void
helperStatefulServerKickQueue(helper_stateful_server * srv)
{
- helper_stateful_request *r;
-
if (!srv->flags.shutdown) {
helperStatefulKickQueue(srv->parent);
} else if (!srv->flags.closing && srv->flags.reserved == S_HELPER_FREE && !srv->flags.busy) {