varnish-cache/bin/varnishd/cache/cache_req_fsm.c
0
/*-
1
 * Copyright (c) 2006 Verdens Gang AS
2
 * Copyright (c) 2006-2017 Varnish Software AS
3
 * All rights reserved.
4
 *
5
 * Author: Poul-Henning Kamp <phk@phk.freebsd.dk>
6
 *
7
 * SPDX-License-Identifier: BSD-2-Clause
8
 *
9
 * Redistribution and use in source and binary forms, with or without
10
 * modification, are permitted provided that the following conditions
11
 * are met:
12
 * 1. Redistributions of source code must retain the above copyright
13
 *    notice, this list of conditions and the following disclaimer.
14
 * 2. Redistributions in binary form must reproduce the above copyright
15
 *    notice, this list of conditions and the following disclaimer in the
16
 *    documentation and/or other materials provided with the distribution.
17
 *
18
 * THIS SOFTWARE IS PROVIDED BY THE AUTHOR AND CONTRIBUTORS ``AS IS'' AND
19
 * ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE
20
 * IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE
21
 * ARE DISCLAIMED.  IN NO EVENT SHALL AUTHOR OR CONTRIBUTORS BE LIABLE
22
 * FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL
23
 * DAMAGES (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS
24
 * OR SERVICES; LOSS OF USE, DATA, OR PROFITS; OR BUSINESS INTERRUPTION)
25
 * HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT
26
 * LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY
27
 * OUT OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF
28
 * SUCH DAMAGE.
29
 *
30
 * This file contains the request-handling state engine, which is intended to
31
 * (over time) be(come) protocol agnostic.
32
 * We already use this now with ESI:includes, which are for all relevant
33
 * purposes a different "protocol"
34
 *
35
 * A special complication is the fact that we can suspend processing of
36
 * a request when hash-lookup finds a busy objhdr.
37
 *
38
 */
39
40
#include "config.h"
41
42
#include "cache_varnishd.h"
43
#include "cache_filter.h"
44
#include "cache_objhead.h"
45
#include "cache_transport.h"
46
#include "vcc_interface.h"
47
48
#include "http1/cache_http1.h"
49
#include "storage/storage.h"
50
#include "vcl.h"
51
#include "vct.h"
52
#include "vsha256.h"
53
#include "vtim.h"
54
55
#define REQ_STEPS \
56
  REQ_STEP(transport,           TRANSPORT,      ) \
57
  REQ_STEP(restart,             RESTART,        static) \
58
  REQ_STEP(recv,                RECV,           ) \
59
  REQ_STEP(pipe,                PIPE,           static) \
60
  REQ_STEP(pass,                PASS,           static) \
61
  REQ_STEP(lookup,              LOOKUP,         static) \
62
  REQ_STEP(purge,               PURGE,          static) \
63
  REQ_STEP(miss,                MISS,           static) \
64
  REQ_STEP(fetch,               FETCH,          static) \
65
  REQ_STEP(deliver,             DELIVER,        static) \
66
  REQ_STEP(vclfail,             VCLFAIL,        static) \
67
  REQ_STEP(synth,               SYNTH,          static) \
68
  REQ_STEP(transmit,            TRANSMIT,       static) \
69
  REQ_STEP(finish,              FINISH,         static)
70
71
#define REQ_STEP(l, U, priv) \
72
    static req_state_f cnt_##l; \
73
    priv const struct req_step R_STP_##U[1] = {{ \
74
        .name = "Req Step " #l, \
75
        .func = cnt_##l, \
76
    }};
77
REQ_STEPS
78
#undef REQ_STEP
79
80
/*--------------------------------------------------------------------
81
 * Handle "Expect:" and "Connection:" on incoming request
82
 */
83
84
static enum req_fsm_nxt v_matchproto_(req_state_f)
85 7514
cnt_transport(struct worker *wrk, struct req *req)
86
{
87
        const char *p;
88
89 7514
        CHECK_OBJ_NOTNULL(wrk, WORKER_MAGIC);
90 7514
        CHECK_OBJ_NOTNULL(req, REQ_MAGIC);
91 7514
        CHECK_OBJ_NOTNULL(req->http, HTTP_MAGIC);
92 7514
        CHECK_OBJ_NOTNULL(req->transport, TRANSPORT_MAGIC);
93 7514
        AN(req->req_body_status);
94
95 7514
        if (http_GetHdr(req->http, H_Expect, &p)) {
96 24
                if (!http_expect_eq(p, 100-continue)) {
97 4
                        req->doclose = SC_RX_JUNK;
98 4
                        (void)req->transport->minimal_response(req, 417);
99 4
                        wrk->stats->client_req_417++;
100 4
                        return (REQ_FSM_DONE);
101
                }
102 20
                if (req->http->protover >= 11 &&
103 20
                    req->htc->pipeline_b == NULL)       // XXX: HTTP1 vs 2 ?
104 18
                        req->want100cont = 1;
105 20
                http_Unset(req->http, H_Expect);
106 20
        }
107
108 7510
        AZ(req->err_code);
109
110 7510
        req->doclose = http_DoConnection(req->http, SC_REQ_CLOSE);
111 7510
        if (req->doclose == SC_RX_BAD) {
112 6
                wrk->stats->client_req_400++;
113 6
                (void)req->transport->minimal_response(req, 400);
114 6
                return (REQ_FSM_DONE);
115
        }
116
117 7504
        if (req->req_body_status->avail == 1) {
118 258
                AN(req->transport->req_body != NULL);
119 258
                VFP_Setup(req->vfc, wrk);
120 258
                req->vfc->resp = req->http;             // XXX
121 258
                req->transport->req_body(req);
122 258
        }
123
124 7504
        req->ws_req = WS_Snapshot(req->ws);
125 7504
        HTTP_Clone(req->http0, req->http);      // For ESI & restart
126 7504
        req->req_step = R_STP_RECV;
127 7504
        return (REQ_FSM_MORE);
128 7514
}
129
130
/*--------------------------------------------------------------------
131
 * Deliver an object to client
132
 */
133
134
int
135 6609
Resp_Setup_Deliver(struct req *req)
136
{
137
        struct http *h;
138
        struct objcore *oc;
139
        const void *hdrs;
140
141 6609
        CHECK_OBJ_NOTNULL(req, REQ_MAGIC);
142 6609
        oc = req->objcore;
143 6609
        CHECK_OBJ_NOTNULL(oc, OBJCORE_MAGIC);
144
145 6609
        h = req->resp;
146
147 6609
        HTTP_Setup(h, req->ws, req->vsl, SLT_RespMethod);
148
149 6609
        hdrs = ObjGetAttr(req->wrk, oc, OA_HEADERS, NULL);
150 6609
        if (hdrs == NULL || HTTP_Decode(h, hdrs))
151 4
                return (-1);
152
153 6605
        http_ForceField(h, HTTP_HDR_PROTO, "HTTP/1.1");
154
155 6605
        if (req->is_hit)
156 4552
                http_PrintfHeader(h, "X-Varnish: %ju %ju", VXID(req->vsl->wid),
157 2276
                    VXID(ObjGetXID(req->wrk, oc)));
158
        else
159 4329
                http_PrintfHeader(h, "X-Varnish: %ju", VXID(req->vsl->wid));
160
161
        /*
162
         * We base Age calculation upon the last timestamp taken during client
163
         * request processing. This gives some inaccuracy, but since Age is only
164
         * full second resolution that shouldn't matter. (Last request timestamp
165
         * could be a Start timestamp taken before the object entered into cache
166
         * leading to negative age. Truncate to zero in that case).
167
         */
168 13210
        http_PrintfHeader(h, "Age: %.0f",
169 6605
            floor(fmax(0., req->t_prev - oc->t_origin)));
170
171 6605
        http_AppendHeader(h, H_Via, http_ViaHeader());
172
173 7155
        if (cache_param->http_gzip_support &&
174 6596
            ObjCheckFlag(req->wrk, oc, OF_GZIPED) &&
175 550
            !RFC2616_Req_Gzip(req->http))
176 200
                RFC2616_Weaken_Etag(h);
177 6605
        return (0);
178 6609
}
179
180
void
181 1128
Resp_Setup_Synth(struct req *req)
182
{
183
        struct http *h;
184
185 1128
        CHECK_OBJ_NOTNULL(req, REQ_MAGIC);
186
187 1128
        h = req->resp;
188
189 1128
        HTTP_Setup(h, req->ws, req->vsl, SLT_RespMethod);
190
191 1128
        AZ(req->objcore);
192 1128
        http_PutResponse(h, "HTTP/1.1", req->err_code, req->err_reason);
193
194 1128
        http_TimeHeader(h, "Date: ", W_TIM_real(req->wrk));
195 1128
        http_SetHeader(h, "Server: Varnish");
196 1128
        http_PrintfHeader(h, "X-Varnish: %ju", VXID(req->vsl->wid));
197
198
        /*
199
         * For late 100-continue, we suggest to VCL to close the connection to
200
         * neither send a 100-continue nor drain-read the request. But VCL has
201
         * the option to veto by removing Connection: close
202
         */
203 1128
        if (req->want100cont)
204 6
                http_SetHeader(h, "Connection: close");
205 1128
}
206
207
static enum req_fsm_nxt v_matchproto_(req_state_f)
208 6589
cnt_deliver(struct worker *wrk, struct req *req)
209
{
210
        unsigned status;
211
212 6589
        CHECK_OBJ_NOTNULL(wrk, WORKER_MAGIC);
213 6589
        CHECK_OBJ_NOTNULL(req, REQ_MAGIC);
214 6589
        CHECK_OBJ_NOTNULL(req->objcore, OBJCORE_MAGIC);
215 6589
        CHECK_OBJ_NOTNULL(req->objcore->objhead, OBJHEAD_MAGIC);
216 6589
        AZ(req->stale_oc);
217 6589
        AN(req->vcl);
218
219 6589
        assert(req->objcore->refcnt > 0);
220
221 6589
        ObjTouch(req->wrk, req->objcore, req->t_prev);
222
223 6589
        if (Resp_Setup_Deliver(req)) {
224 4
                (void)HSH_DerefObjCore(wrk, &req->objcore);
225 4
                req->err_code = 500;
226 4
                req->req_step = R_STP_SYNTH;
227 4
                return (REQ_FSM_MORE);
228
        }
229
230 6585
        status = http_GetStatus(req->resp);
231 6585
        if (cache_param->http_range_support && status == 200 &&
232 5850
            !(req->objcore->flags & OC_F_PRIVATE))
233 4746
                http_ForceHeader(req->resp, H_Accept_Ranges, "bytes");
234
235 6585
        req->t_resp = W_TIM_real(wrk);
236 6585
        VCL_deliver_method(req->vcl, wrk, req, NULL, NULL);
237
238 6585
        assert(req->restarts <= req->max_restarts);
239
240 6585
        if (wrk->vpi->handling != VCL_RET_DELIVER) {
241 260
                HSH_Cancel(wrk, req->objcore, NULL);
242 260
                (void)HSH_DerefObjCore(wrk, &req->objcore);
243 260
                http_Teardown(req->resp);
244
245 260
                switch (wrk->vpi->handling) {
246
                case VCL_RET_RESTART:
247 62
                        req->req_step = R_STP_RESTART;
248 62
                        break;
249
                case VCL_RET_FAIL:
250 182
                        req->req_step = R_STP_VCLFAIL;
251 182
                        break;
252
                case VCL_RET_SYNTH:
253 16
                        req->req_step = R_STP_SYNTH;
254 16
                        break;
255
                default:
256 0
                        WRONG("Illegal return from vcl_deliver{}");
257 0
                }
258
259 260
                return (REQ_FSM_MORE);
260
        }
261
262 6325
        VSLb_ts_req(req, "Process", W_TIM_real(wrk));
263
264 6325
        assert(wrk->vpi->handling == VCL_RET_DELIVER);
265
266 6325
        if (IS_TOPREQ(req) && RFC2616_Do_Cond(req))
267 60
                http_PutResponse(req->resp, "HTTP/1.1", 304, NULL);
268
269 6325
        req->req_step = R_STP_TRANSMIT;
270 6325
        return (REQ_FSM_MORE);
271 6589
}
272
273
/*--------------------------------------------------------------------
274
 * VCL failed, die horribly
275
 */
276
277
static enum req_fsm_nxt v_matchproto_(req_state_f)
278 324
cnt_vclfail(struct worker *wrk, struct req *req)
279
{
280
        struct vrt_ctx ctx[1];
281
282 324
        CHECK_OBJ_NOTNULL(wrk, WORKER_MAGIC);
283 324
        CHECK_OBJ_NOTNULL(req, REQ_MAGIC);
284
285 324
        AZ(req->objcore);
286 324
        AZ(req->stale_oc);
287
288 324
        INIT_OBJ(ctx, VRT_CTX_MAGIC);
289 324
        VCL_Req2Ctx(ctx, req);
290
291 324
        Req_Rollback(ctx);
292
293 324
        if (req->req_reset) {
294 54
                req->err_code = 408;
295 54
                req->err_reason = "Client disconnected";
296 54
        } else {
297 270
                req->err_code = 503;
298 270
                req->err_reason = "VCL failed";
299
        }
300 324
        req->req_step = R_STP_SYNTH;
301 324
        req->doclose = SC_VCL_FAILURE;
302 324
        req->vdp_filter_list = NULL;
303 324
        return (REQ_FSM_MORE);
304
}
305
306
/*--------------------------------------------------------------------
307
 * Emit a synthetic response
308
 */
309
310
static enum req_fsm_nxt v_matchproto_(req_state_f)
311 1124
cnt_synth(struct worker *wrk, struct req *req)
312
{
313
        struct vsb *synth_body;
314
        ssize_t sz, szl;
315
        uint16_t status;
316
        uint8_t *ptr;
317
        const char *body;
318
319 1124
        CHECK_OBJ_NOTNULL(wrk, WORKER_MAGIC);
320 1124
        CHECK_OBJ_NOTNULL(req, REQ_MAGIC);
321
322 1124
        AZ(req->objcore);
323 1124
        AZ(req->stale_oc);
324
325 1124
        wrk->stats->s_synth++;
326
327 1124
        if (req->err_code < 100)
328 0
                req->err_code = 501;
329
330 1124
        Resp_Setup_Synth(req);
331
332 1124
        req->vdp_filter_list = NULL;
333 1124
        synth_body = VSB_new_auto();
334 1124
        AN(synth_body);
335
336 1124
        req->t_resp = W_TIM_real(wrk);
337 1124
        VCL_synth_method(req->vcl, wrk, req, NULL, synth_body);
338
339 1124
        AZ(VSB_finish(synth_body));
340
341 1124
        VSLb_ts_req(req, "Process", W_TIM_real(wrk));
342
343 1124
        while (wrk->vpi->handling == VCL_RET_FAIL) {
344 62
                if (req->esi_level > 0) {
345 2
                        wrk->vpi->handling = VCL_RET_DELIVER;
346 2
                        break;
347
                }
348 60
                VSB_destroy(&synth_body);
349 60
                (void)VRB_Ignore(req);
350 60
                status = req->req_reset ? 408 : 500;
351 60
                (void)req->transport->minimal_response(req, status);
352 60
                req->doclose = SC_VCL_FAILURE; // XXX: Not necessary any more ?
353 60
                VSLb_ts_req(req, "Resp", W_TIM_real(wrk));
354 60
                http_Teardown(req->resp);
355 60
                return (REQ_FSM_DONE);
356
        }
357
358 1064
        if (wrk->vpi->handling == VCL_RET_RESTART && req->restarts > req->max_restarts)
359 2
                wrk->vpi->handling = VCL_RET_DELIVER;
360
361 1064
        if (wrk->vpi->handling == VCL_RET_RESTART) {
362
                /*
363
                 * XXX: Should we reset req->doclose = SC_VCL_FAILURE
364
                 * XXX: If so, to what ?
365
                 */
366 22
                HTTP_Setup(req->resp, req->ws, req->vsl, SLT_RespMethod);
367 22
                VSB_destroy(&synth_body);
368 22
                req->req_step = R_STP_RESTART;
369 22
                return (REQ_FSM_MORE);
370
        }
371 1042
        assert(wrk->vpi->handling == VCL_RET_DELIVER);
372
373 1042
        http_Unset(req->resp, H_Content_Length);
374 2084
        http_PrintfHeader(req->resp, "Content-Length: %zd",
375 1042
            VSB_len(synth_body));
376
377 1800
        if (req->doclose == SC_NULL &&
378 764
            (http_HdrIs(req->resp, H_Connection, "close") ||
379 758
            http_HdrIs(req->http, H_Connection, "close")))
380 8
                req->doclose = SC_RESP_CLOSE;
381
382
        /* Discard any lingering request body before delivery */
383 1042
        (void)VRB_Ignore(req);
384
385 1042
        req->objcore = HSH_Private(wrk);
386 1042
        CHECK_OBJ_NOTNULL(req->objcore, OBJCORE_MAGIC);
387 1042
        szl = -1;
388 1042
        if (STV_NewObject(wrk, req->objcore, stv_transient, 0)) {
389 1038
                body = VSB_data(synth_body);
390 1038
                szl = VSB_len(synth_body);
391 1038
                assert(szl >= 0);
392 2014
                while (szl > 0) {
393 976
                        sz = szl;
394 976
                        if (! ObjGetSpace(wrk, req->objcore, &sz, &ptr)) {
395 0
                                szl = -1;
396 0
                                break;
397
                        }
398 976
                        if (sz > szl)
399 0
                                sz = szl;
400 976
                        szl -= sz;
401 976
                        memcpy(ptr, body, sz);
402 976
                        ObjExtend(wrk, req->objcore, sz, szl == 0 ? 1 : 0);
403 976
                        body += sz;
404
                }
405 1038
        }
406
407 1042
        if (szl >= 0)
408 1038
                AZ(ObjSetU64(wrk, req->objcore, OA_LEN, VSB_len(synth_body)));
409 1042
        HSH_DerefBoc(wrk, req->objcore);
410 1042
        VSB_destroy(&synth_body);
411
412 1042
        if (szl < 0) {
413 4
                VSLb(req->vsl, SLT_Error, "Could not get storage");
414 4
                req->doclose = SC_OVERLOAD;
415 4
                VSLb_ts_req(req, "Resp", W_TIM_real(wrk));
416 4
                (void)HSH_DerefObjCore(wrk, &req->objcore);
417 4
                http_Teardown(req->resp);
418 4
                return (REQ_FSM_DONE);
419
        }
420
421 1038
        req->req_step = R_STP_TRANSMIT;
422 1038
        return (REQ_FSM_MORE);
423 1124
}
424
425
/*--------------------------------------------------------------------
426
 * The mechanics of sending a response (from deliver or synth)
427
 */
428
429
static enum req_fsm_nxt v_matchproto_(req_state_f)
430 7362
cnt_transmit(struct worker *wrk, struct req *req)
431
{
432 7362
        enum req_fsm_nxt nxt = REQ_FSM_MORE;
433
        enum vtr_deliver_e dnxt;
434
        uint16_t status;
435
        int sendbody, head;
436
        intmax_t clval;
437
438 7362
        CHECK_OBJ_NOTNULL(wrk, WORKER_MAGIC);
439 7362
        CHECK_OBJ_NOTNULL(req, REQ_MAGIC);
440 7362
        CHECK_OBJ_NOTNULL(req->transport, TRANSPORT_MAGIC);
441 7362
        CHECK_OBJ_NOTNULL(req->objcore, OBJCORE_MAGIC);
442 7362
        AZ(req->stale_oc);
443 7362
        AZ(req->res_pipe | req->res_esi);
444 7362
        AZ(req->boc);
445 7362
        req->req_step = R_STP_FINISH;
446
447
        /* Grab a ref to the bo if there is one (=streaming) */
448 7362
        req->boc = HSH_RefBoc(req->objcore);
449 7362
        if (req->boc && req->boc->state < BOS_STREAM)
450 0
                ObjWaitState(req->objcore, BOS_STREAM);
451 7362
        clval = http_GetContentLength(req->resp);
452
        /* RFC 7230, 3.3.3 */
453 7362
        status = http_GetStatus(req->resp);
454 7362
        head = http_method_eq(req->http0->hd[HTTP_HDR_METHOD].b, HEAD);
455
456 7362
        if (req->boc != NULL || (req->objcore->flags & (OC_F_FAILED)))
457 1725
                req->resp_len = clval;
458
        else
459 5637
                req->resp_len = ObjGetLen(req->wrk, req->objcore);
460
461 7362
        if (head || status < 200 || status == 204 || status == 304) {
462
                // rfc7230,l,1748,1752
463 338
                sendbody = 0;
464 338
        } else {
465 7024
                sendbody = 1;
466
        }
467
468 7362
        VDP_Init(req->vdc, req->wrk, req->vsl, req, NULL, &req->resp_len);
469 7362
        if (req->vdp_filter_list == NULL)
470 6793
                req->vdp_filter_list = resp_Get_Filter_List(req);
471 7362
        if (req->vdp_filter_list == NULL ||
472 7364
            VCL_StackVDP(req->vdc, req->vcl, req->vdp_filter_list, req, NULL)) {
473 128
                VSLb(req->vsl, SLT_Error, "Failure to push processors");
474 128
                req->doclose = SC_OVERLOAD;
475 128
                req->acct.resp_bodybytes +=
476 128
                        VDP_Close(req->vdc, req->objcore, req->boc);
477 128
        } else {
478 7238
                if (status < 200 || status == 204) {
479
                        // rfc7230,l,1691,1695
480 47
                        http_Unset(req->resp, H_Content_Length);
481 7238
                } else if (status == 304) {
482
                        // rfc7230,l,1675,1677
483 68
                        http_Unset(req->resp, H_Content_Length);
484 7191
                } else if (clval >= 0 && clval == req->resp_len) {
485
                        /* Reuse C-L header */
486 7123
                } else if (head) {
487
                        /* rfc9110,l,3226,3227
488
                         * "MAY send Content-Length ... [for] HEAD"
489
                         * do not touch to support cached HEAD #4245
490
                         */
491 8
                        req->resp_len = 0;
492 8
                } else {
493 1833
                        http_Unset(req->resp, H_Content_Length);
494 1833
                        if (req->resp_len >= 0)
495 2176
                                http_PrintfHeader(req->resp,
496 1088
                                    "Content-Length: %jd", req->resp_len);
497
                }
498 7238
                if (req->resp_len == 0)
499 2068
                        sendbody = 0;
500 7238
                dnxt = req->transport->deliver(req, sendbody);
501 7238
                if (dnxt == VTR_D_DISEMBARK)
502 144
                        nxt = REQ_FSM_DISEMBARK;
503
                else
504 7094
                        assert(dnxt == VTR_D_DONE);
505
        }
506 7366
        return (nxt);
507
}
508
509
static enum req_fsm_nxt v_matchproto_(req_state_f)
510 7362
cnt_finish(struct worker *wrk, struct req *req)
511
{
512
513 7362
        CHECK_OBJ_NOTNULL(wrk, WORKER_MAGIC);
514 7362
        CHECK_OBJ_NOTNULL(req, REQ_MAGIC);
515
516 7362
        VSLb_ts_req(req, "Resp", W_TIM_real(wrk));
517
518 7362
        if (req->doclose == SC_NULL && (req->objcore->flags & OC_F_FAILED)) {
519
                /* The object we delivered failed due to a streaming error.
520
                 * Fail the request. */
521 32
                req->doclose = SC_TX_ERROR;
522 32
        }
523
524 7362
        if (req->boc != NULL) {
525 1722
                HSH_DerefBoc(wrk, req->objcore);
526 1722
                req->boc = NULL;
527 1722
        }
528
529 7362
        (void)HSH_DerefObjCore(wrk, &req->objcore);
530 7362
        http_Teardown(req->resp);
531
532 7362
        req->vdp_filter_list = NULL;
533 7362
        req->res_pipe = 0;
534 7362
        req->res_esi = 0;
535 7362
        return (REQ_FSM_DONE);
536
}
537
538
/*--------------------------------------------------------------------
539
 * Initiated a fetch (pass/miss) which we intend to deliver
540
 */
541
542
static enum req_fsm_nxt v_matchproto_(req_state_f)
543 4372
cnt_fetch(struct worker *wrk, struct req *req)
544
{
545
546 4372
        CHECK_OBJ_NOTNULL(wrk, WORKER_MAGIC);
547 4372
        CHECK_OBJ_NOTNULL(req, REQ_MAGIC);
548 4372
        CHECK_OBJ_NOTNULL(req->objcore, OBJCORE_MAGIC);
549 4372
        AZ(req->stale_oc);
550
551 4372
        wrk->stats->s_fetch++;
552 4372
        (void)VRB_Ignore(req);
553
554 4372
        if (req->objcore->flags & OC_F_FAILED) {
555 54
                req->err_code = 503;
556 54
                req->req_step = R_STP_SYNTH;
557 54
                (void)HSH_DerefObjCore(wrk, &req->objcore);
558 54
                AZ(req->objcore);
559 54
                return (REQ_FSM_MORE);
560
        }
561
562 4318
        req->req_step = R_STP_DELIVER;
563 4318
        return (REQ_FSM_MORE);
564 4372
}
565
566
/*--------------------------------------------------------------------
567
 * Attempt to lookup objhdr from hash.  We disembark and reenter
568
 * this state if we get suspended on a busy objhdr.
569
 */
570
571
static enum req_fsm_nxt v_matchproto_(req_state_f)
572 5314
cnt_lookup(struct worker *wrk, struct req *req)
573
{
574
        struct objcore *oc, *busy;
575
        enum lookup_e lr;
576
        int waitinglist_gen;
577
578 5314
        CHECK_OBJ_NOTNULL(wrk, WORKER_MAGIC);
579 5314
        CHECK_OBJ_NOTNULL(req, REQ_MAGIC);
580 5314
        AZ(req->stale_oc);
581
582 5314
        AN(req->vcl);
583
584 5314
        VRY_Prep(req);
585 5314
        waitinglist_gen = req->waitinglist_gen;
586
587 5314
        if (req->waitinglist_gen) {
588 114
                CHECK_OBJ_NOTNULL(req->objcore, OBJCORE_MAGIC);
589 114
                req->waitinglist_gen = 0;
590 114
        } else
591 5200
                AZ(req->objcore);
592
593 5314
        wrk->strangelove = 0;
594 5314
        lr = HSH_Lookup(req, &oc, &busy);
595 5314
        if (lr == HSH_BUSY) {
596
                /*
597
                 * We lost the session to a busy object, disembark the
598
                 * worker thread.   We return to STP_LOOKUP when the busy
599
                 * object has been unbusied, and still have the objhead
600
                 * around to restart the lookup with.
601
                 */
602 113
                return (REQ_FSM_DISEMBARK);
603
        }
604 5201
        assert(wrk->strangelove >= 0);
605 5201
        if ((unsigned)wrk->strangelove >= cache_param->vary_notice)
606 248
                VSLb(req->vsl, SLT_Notice, "vsl: High number of variants (%d)",
607 124
                    wrk->strangelove);
608 5201
        if (waitinglist_gen)
609 113
                VSLb_ts_req(req, "Waitinglist", W_TIM_real(wrk));
610
611 5201
        if (req->vcf != NULL) {
612 12
                (void)req->vcf->func(req, NULL, NULL, 2);
613 12
                req->vcf = NULL;
614 12
        }
615
616 5201
        if (busy == NULL) {
617 2170
                VRY_Finish(req, DISCARD);
618 2170
        } else {
619 3031
                AN(busy->flags & OC_F_BUSY);
620 3031
                VRY_Finish(req, KEEP);
621
        }
622
623 5201
        AZ(req->objcore);
624 5201
        if (lr == HSH_MISS || lr == HSH_HITMISS) {
625 2843
                AN(busy);
626 2843
                AN(busy->flags & OC_F_BUSY);
627 2843
                req->objcore = busy;
628 2843
                req->stale_oc = oc;
629 2843
                req->req_step = R_STP_MISS;
630 2843
                if (lr == HSH_HITMISS)
631 72
                        req->is_hitmiss = 1;
632 2843
                return (REQ_FSM_MORE);
633
        }
634 2358
        if (lr == HSH_HITPASS) {
635 22
                AZ(busy);
636 22
                AZ(oc);
637 22
                req->req_step = R_STP_PASS;
638 22
                req->is_hitpass = 1;
639 22
                return (REQ_FSM_MORE);
640
        }
641
642 2336
        assert(lr == HSH_HIT || lr == HSH_GRACE);
643
644 2336
        CHECK_OBJ_NOTNULL(oc, OBJCORE_MAGIC);
645 2336
        AZ(oc->flags & OC_F_BUSY);
646 2336
        req->objcore = oc;
647 2336
        AZ(oc->flags & OC_F_HFM);
648
649 2336
        VCL_hit_method(req->vcl, wrk, req, NULL, NULL);
650
651 2336
        switch (wrk->vpi->handling) {
652
        case VCL_RET_DELIVER:
653 2274
                if (busy != NULL) {
654 174
                        AZ(oc->flags & OC_F_HFM);
655 174
                        CHECK_OBJ_NOTNULL(busy->boc, BOC_MAGIC);
656
                        // XXX: shouldn't we go to miss?
657 174
                        VBF_Fetch(wrk, req, busy, oc, VBF_BACKGROUND);
658 174
                        wrk->stats->s_fetch++;
659 174
                        wrk->stats->s_bgfetch++;
660 174
                } else {
661 2100
                        (void)VRB_Ignore(req);// XXX: handle err
662
                }
663 2274
                wrk->stats->cache_hit++;
664 2274
                req->is_hit = 1;
665 2274
                if (lr == HSH_GRACE)
666 180
                        wrk->stats->cache_hit_grace++;
667 2274
                req->req_step = R_STP_DELIVER;
668 2274
                return (REQ_FSM_MORE);
669
        case VCL_RET_RESTART:
670 30
                req->req_step = R_STP_RESTART;
671 30
                break;
672
        case VCL_RET_FAIL:
673 10
                req->req_step = R_STP_VCLFAIL;
674 10
                break;
675
        case VCL_RET_SYNTH:
676 18
                req->req_step = R_STP_SYNTH;
677 18
                break;
678
        case VCL_RET_PASS:
679 4
                wrk->stats->cache_hit++;
680 4
                req->is_hit = 1;
681 4
                req->req_step = R_STP_PASS;
682 4
                break;
683
        default:
684 0
                WRONG("Illegal return from vcl_hit{}");
685 0
        }
686
687
        /* Drop our object, we won't need it */
688 62
        (void)HSH_DerefObjCore(wrk, &req->objcore);
689
690 62
        if (busy != NULL) {
691 14
                HSH_Withdraw(wrk, &busy);
692 14
                VRY_Clear(req);
693 14
        }
694
695 62
        return (REQ_FSM_MORE);
696 5314
}
697
698
/*--------------------------------------------------------------------
699
 * Cache miss.
700
 */
701
702
static enum req_fsm_nxt v_matchproto_(req_state_f)
703 2841
cnt_miss(struct worker *wrk, struct req *req)
704
{
705
706 2841
        CHECK_OBJ_NOTNULL(wrk, WORKER_MAGIC);
707 2841
        CHECK_OBJ_NOTNULL(req, REQ_MAGIC);
708 2841
        AN(req->vcl);
709 2841
        CHECK_OBJ_NOTNULL(req->objcore, OBJCORE_MAGIC);
710 2841
        CHECK_OBJ_ORNULL(req->stale_oc, OBJCORE_MAGIC);
711
712 2841
        VCL_miss_method(req->vcl, wrk, req, NULL, NULL);
713 2841
        switch (wrk->vpi->handling) {
714
        case VCL_RET_FETCH:
715 2804
                wrk->stats->cache_miss++;
716 2804
                VBF_Fetch(wrk, req, req->objcore, req->stale_oc, VBF_NORMAL);
717 2804
                if (req->stale_oc != NULL)
718 136
                        (void)HSH_DerefObjCore(wrk, &req->stale_oc);
719 2804
                req->req_step = R_STP_FETCH;
720 2804
                return (REQ_FSM_MORE);
721
        case VCL_RET_FAIL:
722 7
                req->req_step = R_STP_VCLFAIL;
723 7
                break;
724
        case VCL_RET_SYNTH:
725 16
                req->req_step = R_STP_SYNTH;
726 16
                break;
727
        case VCL_RET_RESTART:
728 8
                req->req_step = R_STP_RESTART;
729 8
                break;
730
        case VCL_RET_PASS:
731 6
                req->req_step = R_STP_PASS;
732 6
                break;
733
        default:
734 0
                WRONG("Illegal return from vcl_miss{}");
735 0
        }
736 37
        VRY_Clear(req);
737 37
        if (req->stale_oc != NULL)
738 2
                (void)HSH_DerefObjCore(wrk, &req->stale_oc);
739 37
        HSH_Withdraw(wrk, &req->objcore);
740 37
        return (REQ_FSM_MORE);
741 2841
}
742
743
/*--------------------------------------------------------------------
744
 * Pass processing
745
 */
746
747
static enum req_fsm_nxt v_matchproto_(req_state_f)
748 1572
cnt_pass(struct worker *wrk, struct req *req)
749
{
750
751 1572
        CHECK_OBJ_NOTNULL(wrk, WORKER_MAGIC);
752 1572
        CHECK_OBJ_NOTNULL(req, REQ_MAGIC);
753 1572
        AN(req->vcl);
754 1572
        AZ(req->objcore);
755 1572
        AZ(req->stale_oc);
756
757 1572
        VCL_pass_method(req->vcl, wrk, req, NULL, NULL);
758 1572
        switch (wrk->vpi->handling) {
759
        case VCL_RET_FAIL:
760 2
                req->req_step = R_STP_VCLFAIL;
761 2
                break;
762
        case VCL_RET_SYNTH:
763 2
                req->req_step = R_STP_SYNTH;
764 2
                break;
765
        case VCL_RET_RESTART:
766 0
                req->req_step = R_STP_RESTART;
767 0
                break;
768
        case VCL_RET_FETCH:
769 1568
                wrk->stats->s_pass++;
770 1568
                req->objcore = HSH_Private(wrk);
771 1568
                CHECK_OBJ_NOTNULL(req->objcore, OBJCORE_MAGIC);
772 1568
                VBF_Fetch(wrk, req, req->objcore, NULL, VBF_PASS);
773 1568
                req->req_step = R_STP_FETCH;
774 1568
                break;
775
        default:
776 0
                WRONG("Illegal return from cnt_pass{}");
777 0
        }
778 1572
        return (REQ_FSM_MORE);
779
}
780
781
/*--------------------------------------------------------------------
782
 * Pipe mode
783
 */
784
785
static enum req_fsm_nxt v_matchproto_(req_state_f)
786 60
cnt_pipe(struct worker *wrk, struct req *req)
787
{
788
        struct busyobj *bo;
789
        enum req_fsm_nxt nxt;
790
791 60
        CHECK_OBJ_NOTNULL(wrk, WORKER_MAGIC);
792 60
        CHECK_OBJ_NOTNULL(req, REQ_MAGIC);
793 60
        AZ(req->objcore);
794 60
        AZ(req->stale_oc);
795 60
        AN(req->vcl);
796
797 60
        wrk->stats->s_pipe++;
798 60
        bo = VBO_GetBusyObj(wrk, req);
799 60
        CHECK_OBJ_NOTNULL(bo, BUSYOBJ_MAGIC);
800 60
        VSLb(bo->vsl, SLT_Begin, "bereq %ju pipe", VXID(req->vsl->wid));
801 60
        VSLb(req->vsl, SLT_Link, "bereq %ju pipe", VXID(bo->vsl->wid));
802 60
        VSLb_ts_busyobj(bo, "Start", W_TIM_real(wrk));
803 60
        THR_SetBusyobj(bo);
804 60
        bo->sp = req->sp;
805 60
        SES_Ref(bo->sp);
806
807 60
        HTTP_Setup(bo->bereq, req->ws, bo->vsl, SLT_BereqMethod);
808 60
        http_FilterReq(bo->bereq, req->http, 0);        // XXX: 0 ?
809 60
        http_PrintfHeader(bo->bereq, "X-Varnish: %ju", VXID(req->vsl->wid));
810 60
        http_ForceHeader(bo->bereq, H_Connection, "close");
811
812 60
        if (req->want100cont) {
813 0
                http_SetHeader(bo->bereq, "Expect: 100-continue");
814 0
                req->want100cont = 0;
815 0
        }
816
817 60
        bo->wrk = wrk;
818 60
        bo->task_deadline = NAN; /* XXX: copy req->task_deadline */
819 60
        if (WS_Overflowed(req->ws))
820 2
                wrk->vpi->handling = VCL_RET_FAIL;
821
        else
822 58
                VCL_pipe_method(req->vcl, wrk, req, bo, NULL);
823
824 60
        switch (wrk->vpi->handling) {
825
        case VCL_RET_SYNTH:
826 6
                req->req_step = R_STP_SYNTH;
827 6
                nxt = REQ_FSM_MORE;
828 6
                break;
829
        case VCL_RET_PIPE:
830 50
                VSLb_ts_req(req, "Process", W_TIM_real(wrk));
831 50
                VSLb_ts_busyobj(bo, "Process", wrk->lastused);
832 50
                if (V1P_Enter() == 0) {
833 48
                        AZ(bo->req);
834 48
                        bo->req = req;
835 48
                        bo->wrk = wrk;
836
                        /* Unless cached, reqbody is not our job */
837 48
                        if (req->req_body_status != BS_CACHED)
838 46
                                req->req_body_status = BS_NONE;
839 48
                        SES_Close(req->sp, VDI_Http1Pipe(req, bo));
840 48
                        nxt = REQ_FSM_DONE;
841 48
                        V1P_Leave();
842 48
                        break;
843
                }
844 2
                wrk->stats->pipe_limited++;
845
                /* fall through */
846
        case VCL_RET_FAIL:
847 6
                req->req_step = R_STP_VCLFAIL;
848 6
                nxt = REQ_FSM_MORE;
849 6
                break;
850
        default:
851 0
                WRONG("Illegal return from vcl_pipe{}");
852 0
        }
853 60
        http_Teardown(bo->bereq);
854 60
        SES_Rel(bo->sp);
855 60
        VBO_ReleaseBusyObj(wrk, &bo);
856 60
        THR_SetBusyobj(NULL);
857 60
        return (nxt);
858
}
859
860
/*--------------------------------------------------------------------
861
 * Handle restart events
862
 */
863
864
static enum req_fsm_nxt v_matchproto_(req_state_f)
865 146
cnt_restart(struct worker *wrk, struct req *req)
866
{
867
868 146
        CHECK_OBJ_NOTNULL(wrk, WORKER_MAGIC);
869 146
        CHECK_OBJ_NOTNULL(req, REQ_MAGIC);
870 146
        AZ(req->objcore);
871 146
        AZ(req->stale_oc);
872
873 146
        if (++req->restarts > req->max_restarts) {
874 20
                VSLb(req->vsl, SLT_VCL_Error, "Too many restarts");
875 20
                req->err_code = 503;
876 20
                req->req_step = R_STP_SYNTH;
877 20
        } else {
878
                // XXX: ReqEnd + ReqAcct ?
879 126
                VSLb_ts_req(req, "Restart", W_TIM_real(wrk));
880 252
                VSL_ChgId(req->vsl, "req", "restart",
881 126
                    VXID_Get(wrk, VSL_CLIENTMARKER));
882 126
                VSLb_ts_req(req, "Start", req->t_prev);
883 126
                req->err_code = 0;
884 126
                req->req_step = R_STP_RECV;
885
        }
886 146
        return (REQ_FSM_MORE);
887
}
888
889
/*
890
 * prepare the request for vcl_recv, either initially or after a reset
891
 * e.g. due to vcl switching
892
 *
893
 * TODO
894
 * - make restarts == 0 bit re-usable for rollback
895
 * - remove duplication with Req_Cleanup()
896
 */
897
898
static void v_matchproto_(req_state_f)
899 7648
cnt_recv_prep(struct req *req, const char *ci)
900
{
901
902 7648
        if (req->restarts == 0) {
903
                /*
904
                 * This really should be done earlier, but we want to capture
905
                 * it in the VSL log.
906
                 */
907 7522
                http_AppendHeader(req->http, H_X_Forwarded_For, ci);
908 7522
                http_AppendHeader(req->http, H_Via, http_ViaHeader());
909 7522
                http_CollectHdr(req->http, H_Cache_Control);
910
911
                /* By default we use the first backend */
912 15044
                VRT_Assign_Backend(&req->director_hint,
913 7522
                    VCL_DefaultDirector(req->vcl));
914
915 7522
                req->d_ttl = -1;
916 7522
                req->d_grace = -1;
917 7522
                req->disable_esi = 0;
918 7522
                req->hash_always_miss = 0;
919 7522
                req->hash_ignore_busy = 0;
920 7522
                req->hash_ignore_vary = 0;
921 7522
                req->client_identity = NULL;
922 7522
                req->storage = NULL;
923 7522
                req->trace = FEATURE(FEATURE_TRACE);
924 7522
        }
925
926 7648
        req->is_hit = 0;
927 7648
        req->is_hitmiss = 0;
928 7648
        req->is_hitpass = 0;
929 7648
        req->err_code = 0;
930 7648
        req->err_reason = NULL;
931
932 7648
        req->vfp_filter_list = NULL;
933 7648
}
934
935
/*--------------------------------------------------------------------
936
 * We have a complete request, set everything up and start it.
937
 * We can come here both with a request from the client and with
938
 * a interior request during ESI delivery.
939
 */
940
941
static enum req_fsm_nxt v_matchproto_(req_state_f)
942 7622
cnt_recv(struct worker *wrk, struct req *req)
943
{
944
        unsigned recv_handling;
945
        struct VSHA256Context sha256ctx;
946
        const char *ci;
947
948 7622
        CHECK_OBJ_NOTNULL(wrk, WORKER_MAGIC);
949 7622
        CHECK_OBJ_NOTNULL(req, REQ_MAGIC);
950 7622
        AN(req->vcl);
951 7622
        AZ(req->objcore);
952 7622
        AZ(req->stale_oc);
953 7622
        AZ(req->err_code);
954
955 7622
        AZ(isnan(req->t_first));
956 7622
        AZ(isnan(req->t_prev));
957 7622
        AZ(isnan(req->t_req));
958
959 7622
        ci = Req_LogStart(wrk, req);
960 7622
        http_VSL_log(req->http);
961
962 7622
        if (http_CountHdr(req->http0, H_Host) > 1) {
963 4
                VSLb(req->vsl, SLT_BogoHeader, "Multiple Host: headers");
964 4
                wrk->stats->client_req_400++;
965 4
                req->doclose = SC_RX_BAD;
966 4
                (void)req->transport->minimal_response(req, 400);
967 4
                return (REQ_FSM_DONE);
968
        }
969
970 7618
        if (http_CountHdr(req->http0, H_Content_Length) > 1) {
971 2
                VSLb(req->vsl, SLT_BogoHeader, "Multiple Content-Length: headers");
972 2
                wrk->stats->client_req_400++;
973 2
                req->doclose = SC_RX_BAD;
974 2
                (void)req->transport->minimal_response(req, 400);
975 2
                return (REQ_FSM_DONE);
976
        }
977
978 7616
        cnt_recv_prep(req, ci);
979
980 7616
        if (req->req_body_status == BS_ERROR) {
981 0
                req->doclose = SC_OVERLOAD;
982 0
                return (REQ_FSM_DONE);
983
        }
984
985 7616
        VCL_recv_method(req->vcl, wrk, req, NULL, NULL);
986
987 7616
        if (wrk->vpi->handling == VCL_RET_FAIL) {
988 94
                req->req_step = R_STP_VCLFAIL;
989 94
                return (REQ_FSM_MORE);
990
        }
991
992 7522
        if (wrk->vpi->handling == VCL_RET_VCL && req->restarts == 0) {
993
                // Req_Rollback has happened in VPI_vcl_select
994 26
                assert(WS_Snapshot(req->ws) == req->ws_req);
995 26
                cnt_recv_prep(req, ci);
996 26
                VCL_recv_method(req->vcl, wrk, req, NULL, NULL);
997 26
        }
998
999 7522
        if (req->want100cont && !req->late100cont) {
1000 8
                req->want100cont = 0;
1001 8
                if (req->transport->minimal_response(req, 100)) {
1002 0
                        req->doclose = SC_REM_CLOSE;
1003 0
                        return (REQ_FSM_DONE);
1004
                }
1005 8
        }
1006
1007
        /* Attempts to cache req.body may fail */
1008 7522
        if (req->req_body_status == BS_ERROR) {
1009 10
                req->doclose = SC_RX_BODY;
1010 10
                (void)req->transport->minimal_response(req, 400);
1011 10
                return (REQ_FSM_DONE);
1012
        }
1013
1014 7512
        recv_handling = wrk->vpi->handling;
1015
1016
        /* We wash the A-E header here for the sake of VRY */
1017 14949
        if (cache_param->http_gzip_support &&
1018 7501
             (recv_handling != VCL_RET_PIPE) &&
1019 7437
             (recv_handling != VCL_RET_PASS)) {
1020 5901
                if (RFC2616_Req_Gzip(req->http)) {
1021 440
                        http_ForceHeader(req->http, H_Accept_Encoding, "gzip");
1022 440
                } else {
1023 5461
                        http_Unset(req->http, H_Accept_Encoding);
1024
                }
1025 5901
        }
1026
1027 7512
        VSHA256_Init(&sha256ctx);
1028 7512
        VCL_hash_method(req->vcl, wrk, req, NULL, &sha256ctx);
1029 7512
        if (wrk->vpi->handling == VCL_RET_FAIL)
1030 25
                recv_handling = wrk->vpi->handling;
1031
        else
1032 7487
                assert(wrk->vpi->handling == VCL_RET_LOOKUP);
1033 7512
        VSHA256_Final(req->digest, &sha256ctx);
1034
1035 7512
        switch (recv_handling) {
1036
        case VCL_RET_VCL:
1037 16
                VSLb(req->vsl, SLT_VCL_Error,
1038
                    "Illegal return(vcl): %s",
1039 8
                    req->restarts ? "Not after restarts" :
1040
                    "Only from active VCL");
1041 8
                req->err_code = 503;
1042 8
                req->req_step = R_STP_SYNTH;
1043 8
                break;
1044
        case VCL_RET_PURGE:
1045 16
                req->req_step = R_STP_PURGE;
1046 16
                break;
1047
        case VCL_RET_HASH:
1048 5201
                req->req_step = R_STP_LOOKUP;
1049 5201
                break;
1050
        case VCL_RET_PIPE:
1051 64
                if (!IS_TOPREQ(req)) {
1052 0
                        VSLb(req->vsl, SLT_VCL_Error,
1053
                            "vcl_recv{} returns pipe for ESI included object."
1054
                            "  Doing pass.");
1055 0
                        req->req_step = R_STP_PASS;
1056 64
                } else if (req->http0->protover > 11) {
1057 4
                        VSLb(req->vsl, SLT_VCL_Error,
1058
                            "vcl_recv{} returns pipe for HTTP/2 request."
1059
                            "  Doing pass.");
1060 4
                        req->req_step = R_STP_PASS;
1061 4
                } else {
1062 60
                        req->req_step = R_STP_PIPE;
1063
                }
1064 64
                break;
1065
        case VCL_RET_PASS:
1066 1536
                req->req_step = R_STP_PASS;
1067 1536
                break;
1068
        case VCL_RET_SYNTH:
1069 648
                req->req_step = R_STP_SYNTH;
1070 648
                break;
1071
        case VCL_RET_RESTART:
1072 18
                req->req_step = R_STP_RESTART;
1073 18
                break;
1074
        case VCL_RET_FAIL:
1075 21
                req->req_step = R_STP_VCLFAIL;
1076 21
                break;
1077
        default:
1078 0
                WRONG("Illegal return from vcl_recv{}");
1079 0
        }
1080 7512
        return (REQ_FSM_MORE);
1081 7622
}
1082
1083
/*--------------------------------------------------------------------
1084
 * Find the objhead, purge it.
1085
 *
1086
 * In VCL, a restart is necessary to get a new object
1087
 */
1088
1089
static enum req_fsm_nxt v_matchproto_(req_state_f)
1090 16
cnt_purge(struct worker *wrk, struct req *req)
1091
{
1092
        struct objcore *oc, *boc;
1093
        enum lookup_e lr;
1094
1095 16
        CHECK_OBJ_NOTNULL(wrk, WORKER_MAGIC);
1096 16
        CHECK_OBJ_NOTNULL(req, REQ_MAGIC);
1097 16
        AZ(req->objcore);
1098 16
        AZ(req->stale_oc);
1099
1100 16
        AN(req->vcl);
1101
1102 16
        VRY_Prep(req);
1103
1104 16
        AZ(req->objcore);
1105 16
        req->hash_always_miss = 1;
1106 16
        lr = HSH_Lookup(req, &oc, &boc);
1107 16
        assert (lr == HSH_MISS);
1108 16
        AZ(oc);
1109 16
        CHECK_OBJ_NOTNULL(boc, OBJCORE_MAGIC);
1110 16
        VRY_Finish(req, DISCARD);
1111
1112 16
        (void)HSH_Purge(wrk, boc->objhead, req->t_req, 0, 0, 0);
1113
1114 16
        HSH_Withdraw(wrk, &boc);
1115
1116 16
        VCL_purge_method(req->vcl, wrk, req, NULL, NULL);
1117 16
        switch (wrk->vpi->handling) {
1118
        case VCL_RET_RESTART:
1119 6
                req->req_step = R_STP_RESTART;
1120 6
                break;
1121
        case VCL_RET_FAIL:
1122 2
                req->req_step = R_STP_VCLFAIL;
1123 2
                break;
1124
        case VCL_RET_SYNTH:
1125 8
                req->req_step = R_STP_SYNTH;
1126 8
                break;
1127
        default:
1128 0
                WRONG("Illegal return from vcl_purge{}");
1129 0
        }
1130 16
        return (REQ_FSM_MORE);
1131
}
1132
1133
/*--------------------------------------------------------------------
1134
 * Central state engine dispatcher.
1135
 *
1136
 * Kick the session around until it has had enough.
1137
 *
1138
 */
1139
1140
static void v_matchproto_(req_state_f)
1141 893
cnt_diag(struct req *req, const char *state)
1142
{
1143
1144 893
        CHECK_OBJ_NOTNULL(req, REQ_MAGIC);
1145
1146 1786
        VSLb(req->vsl,  SLT_Debug, "vxid %ju STP_%s sp %p vcl %p",
1147 893
            VXID(req->vsl->wid), state, req->sp, req->vcl);
1148 893
        VSL_Flush(req->vsl, 0);
1149 893
}
1150
1151
void
1152 7914
CNT_Embark(struct worker *wrk, struct req *req)
1153
{
1154
1155 7914
        CHECK_OBJ_NOTNULL(wrk, WORKER_MAGIC);
1156 7914
        CHECK_OBJ_NOTNULL(req, REQ_MAGIC);
1157
1158
        /* wrk can have changed for restarts */
1159 7914
        req->vfc->wrk = req->wrk = wrk;
1160 7914
        wrk->vsl = req->vsl;
1161 7914
        if (req->req_step == R_STP_TRANSPORT && req->vcl == NULL) {
1162 6782
                VCL_Refresh(&wrk->wpriv->vcl);
1163 6782
                req->vcl = wrk->wpriv->vcl;
1164 6782
                wrk->wpriv->vcl = NULL;
1165 6782
                VSLbs(req->vsl, SLT_VCL_use, TOSTRAND(VCL_Name(req->vcl)));
1166 6782
        }
1167
1168 7914
        AN(req->vcl);
1169 7914
}
1170
1171
enum req_fsm_nxt
1172 7770
CNT_Request(struct req *req)
1173
{
1174
        struct vrt_ctx ctx[1];
1175
        struct worker *wrk;
1176
        enum req_fsm_nxt nxt;
1177
1178 7770
        CHECK_OBJ_NOTNULL(req, REQ_MAGIC);
1179
1180 7770
        wrk = req->wrk;
1181 7770
        CHECK_OBJ_NOTNULL(wrk, WORKER_MAGIC);
1182
1183 7770
        CHECK_OBJ_NOTNULL(req->transport, TRANSPORT_MAGIC);
1184 7770
        AN(req->transport->deliver);
1185 7770
        AN(req->transport->minimal_response);
1186
1187
        /*
1188
         * Possible entrance states
1189
         */
1190 7770
        assert(
1191
            req->req_step == R_STP_LOOKUP ||
1192
            req->req_step == R_STP_FINISH ||
1193
            req->req_step == R_STP_TRANSPORT);
1194
1195 7770
        AN(VXID_TAG(req->vsl->wid) & VSL_CLIENTMARKER);
1196 7770
        AN(req->vcl);
1197
1198 59982
        for (nxt = REQ_FSM_MORE; nxt == REQ_FSM_MORE; ) {
1199
                /*
1200
                 * This is a good place to be paranoid about the various
1201
                 * pointers still pointing to the things we expect.
1202
                 */
1203 52212
                CHECK_OBJ_NOTNULL(wrk, WORKER_MAGIC);
1204 52212
                CHECK_OBJ_NOTNULL(wrk->wpriv, WORKER_PRIV_MAGIC);
1205 52212
                CHECK_OBJ_ORNULL(wrk->wpriv->nobjhead, OBJHEAD_MAGIC);
1206 52212
                CHECK_OBJ_NOTNULL(req, REQ_MAGIC);
1207 52212
                CHECK_OBJ_NOTNULL(req->doclose, STREAM_CLOSE_MAGIC);
1208
1209 52212
                AN(req->req_step);
1210 52212
                AN(req->req_step->name);
1211 52212
                AN(req->req_step->func);
1212 52212
                if (DO_DEBUG(DBG_REQ_STATE))
1213 893
                        cnt_diag(req, req->req_step->name);
1214 52212
                nxt = req->req_step->func(wrk, req);
1215 52212
                CHECK_OBJ_ORNULL(wrk->wpriv->nobjhead, OBJHEAD_MAGIC);
1216
        }
1217 7770
        wrk->vsl = NULL;
1218 7770
        if (nxt == REQ_FSM_DONE) {
1219 7500
                INIT_OBJ(ctx, VRT_CTX_MAGIC);
1220 7500
                VCL_Req2Ctx(ctx, req);
1221 7500
                if (IS_TOPREQ(req)) {
1222 6768
                        VCL_TaskLeave(ctx, req->top->privs);
1223 6768
                        if (req->top->vcl0 != NULL)
1224 24
                                VCL_Recache(wrk, &req->top->vcl0);
1225 6768
                }
1226 7500
                VCL_TaskLeave(ctx, req->privs);
1227 7500
                assert(!IS_NO_VXID(req->vsl->wid));
1228 7500
                VRB_Free(req);
1229 7500
                VRT_Assign_Backend(&req->director_hint, NULL);
1230 7500
                req->wrk = NULL;
1231 7500
        }
1232 7770
        assert(nxt == REQ_FSM_DISEMBARK || !WS_IsReserved(req->ws));
1233 7770
        return (nxt);
1234
}