varnish-cache/bin/varnishd/cache/cache_varnishd.h
0
/*-
1
 * Copyright (c) 2006 Verdens Gang AS
2
 * Copyright (c) 2006-2015 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
 * Stuff that should *never* be exposed to a VMOD
31
 */
32
33
#include "cache.h"
34
35
#include "vsb.h"
36
37
#include <sys/socket.h>
38
39
#include <string.h>
40
#include <limits.h>
41
#include <unistd.h>
42
43
#include "common/common_param.h"
44
45
#ifdef NOT_IN_A_VMOD
46
#  include "VSC_main.h"
47
#endif
48
49
/*--------------------------------------------------------------------*/
50
51
struct vfp;
52
struct vdp;
53
struct cli_proto;
54
struct poolparam;
55
56
/*--------------------------------------------------------------------*/
57
58
typedef enum req_fsm_nxt req_state_f(struct worker *, struct req *);
59
struct req_step {
60
        const char      *name;
61
        req_state_f     *func;
62
};
63
64
extern const struct req_step R_STP_TRANSPORT[1];
65
extern const struct req_step R_STP_RECV[1];
66
67
struct vxid_pool {
68
        uint64_t                next;
69
        uint32_t                count;
70
};
71
72
/*--------------------------------------------------------------------
73
 * Private part of worker threads
74
 */
75
76
struct worker_priv {
77
        unsigned                magic;
78
#define WORKER_PRIV_MAGIC       0x3047db99
79
        struct objhead          *nobjhead;
80
        struct objcore          *nobjcore;
81
        void                    *nhashpriv;
82
        struct vxid_pool        vxid_pool[1];
83
        struct vcl              *vcl;
84
};
85
86
/*--------------------------------------------------------------------
87
 * HTTP Protocol connection structure
88
 *
89
 * This is the protocol independent object for a HTTP connection, used
90
 * both for backend and client sides.
91
 *
92
 */
93
94
struct http_conn {
95
        unsigned                magic;
96
#define HTTP_CONN_MAGIC         0x3e19edd1
97
98
        int                     *rfd;
99
        stream_close_t          doclose;
100
        body_status_t           body_status;
101
        struct ws               *ws;
102
        char                    *rxbuf_b;
103
        char                    *rxbuf_e;
104
        char                    *pipeline_b;
105
        char                    *pipeline_e;
106
        ssize_t                 content_length;
107
        void                    *priv;
108
109
        /* Timeouts */
110
        vtim_dur                first_byte_timeout;
111
        vtim_dur                between_bytes_timeout;
112
};
113
114
enum htc_status_e {
115
#define HTC_STATUS(e, n, s, l) HTC_S_ ## e = n,
116
#include "tbl/htc.h"
117
};
118
119
typedef enum htc_status_e htc_complete_f(struct http_conn *);
120
121
/* -------------------------------------------------------------------*/
122
123
extern volatile struct params * cache_param;
124
125
/* -------------------------------------------------------------------
126
 * The VCF facility is deliberately undocumented, use at your peril.
127
 */
128
129
struct vcf_return {
130
        const char              *name;
131
};
132
133
#define VCF_RETURNS()   \
134
                VCF_RETURN(CONTINUE) \
135
                VCF_RETURN(DEFAULT) \
136
                VCF_RETURN(MISS) \
137
                VCF_RETURN(HIT)
138
139
#define VCF_RETURN(x) extern const struct vcf_return VCF_##x[1];
140
VCF_RETURNS()
141
#undef VCF_RETURN
142
143
typedef const struct vcf_return *vcf_func_f(
144
        struct req *req,
145
        struct objcore **oc,
146
        struct objcore **oc_exp,
147
        int state);
148
149
struct vcf {
150
        unsigned                magic;
151
#define VCF_MAGIC               0x183285d1
152
        vcf_func_f              *func;
153
        void                    *priv;
154
};
155
156
/* Prototypes etc ----------------------------------------------------*/
157
158
/* cache_backend.c */
159
struct backend;
160
161
/* cache_backend_cfg.c */
162
void VBE_InitCfg(void);
163
164
/* cache_ban.c */
165
166
/* for stevedoes resurrecting bans */
167
void BAN_Hold(void);
168
void BAN_Release(void);
169
void BAN_Reload(const uint8_t *ban, unsigned len);
170
struct ban *BAN_FindBan(vtim_real t0);
171
void BAN_RefBan(struct objcore *oc, struct ban *);
172
vtim_real BAN_Time(const struct ban *ban);
173
174
/* cache_busyobj.c */
175
struct busyobj *VBO_GetBusyObj(const struct worker *, const struct req *);
176
void VBO_ReleaseBusyObj(struct worker *wrk, struct busyobj **busyobj);
177
178
/* cache_director.c */
179
int VDI_GetHdr(struct busyobj *);
180
VCL_IP VDI_GetIP(struct busyobj *);
181
void VDI_Finish(struct busyobj *bo);
182
stream_close_t VDI_Http1Pipe(struct req *, struct busyobj *);
183
void VDI_Panic(const struct director *, struct vsb *, const char *nm);
184
void VDI_Event(const struct director *d, enum vcl_event_e ev);
185
void VDI_Init(void);
186
187
/* cache_deliver_proc.c */
188
void VDP_Fini(const struct vdp_ctx *vdc);
189
void VDP_Init(struct vdp_ctx *vdc, struct worker *wrk, struct vsl_log *vsl,
190
    const struct req *req, const struct busyobj *bo, intmax_t *cl);
191
uint64_t VDP_Close(struct vdp_ctx *, struct objcore *, struct boc *);
192
void VDP_Panic(struct vsb *vsb, const struct vdp_ctx *vdc);
193
int VDP_Push(VRT_CTX, struct vdp_ctx *, struct ws *, const struct vdp *,
194
    void *priv);
195
int VDP_ObjIterate(void *priv, unsigned flush, const void *ptr, ssize_t len);
196
int VDP_DeliverObj(struct vdp_ctx *vdc, struct objcore *oc);
197
extern const struct vdp VDP_gunzip;
198
extern const struct vdp VDP_esi;
199
extern const struct vdp VDP_range;
200
201
uint64_t VDPIO_Close(struct vdp_ctx *, struct objcore *, struct boc *);
202
int VDPIO_Upgrade(VRT_CTX, struct vdp_ctx *vdc);
203
int VDPIO_Push(VRT_CTX, struct vdp_ctx *, struct ws *, const struct vdp *,
204
    void *priv);
205
206
207
/* cache_exp.c */
208
vtim_real EXP_Ttl(const struct req *, const struct objcore *);
209
vtim_real EXP_Ttl_grace(const struct req *, const struct objcore *oc);
210
void EXP_RefNewObjcore(struct objcore *);
211
void EXP_Insert(struct worker *wrk, struct objcore *oc);
212
void EXP_Remove(struct objcore *, const struct objcore *);
213
214
#define EXP_Dttl(req, oc) (oc->ttl - (req->t_req - oc->t_origin))
215
216
/* cache_expire.c */
217
218
/*
219
 * The set of variables which control object expiry are inconveniently
220
 * 24 bytes long (double+3*float) and this causes alignment waste if
221
 * we put then in a struct.
222
 * These three macros operate on the struct we don't use.
223
 */
224
225
#define EXP_ZERO(xx)                                                    \
226
        do {                                                            \
227
                (xx)->t_origin = 0.0;                                   \
228
                (xx)->ttl = 0.0;                                        \
229
                (xx)->grace = 0.0;                                      \
230
                (xx)->keep = 0.0;                                       \
231
        } while (0)
232
233
#define EXP_COPY(to,fm)                                                 \
234
        do {                                                            \
235
                (to)->t_origin = (fm)->t_origin;                        \
236
                (to)->ttl = (fm)->ttl;                                  \
237
                (to)->grace = (fm)->grace;                              \
238
                (to)->keep = (fm)->keep;                                \
239
        } while (0)
240
241
#define EXP_WHEN(to)                                                    \
242
        ((to)->t_origin + (to)->ttl + (to)->grace + (to)->keep)
243
244
/* cache_exp.c */
245
void EXP_Rearm(struct objcore *oc, vtim_real now,
246
    vtim_dur ttl, vtim_dur grace, vtim_dur keep);
247
void EXP_Reduce(struct objcore *oc, vtim_real now,
248
    vtim_dur ttl, vtim_dur grace, vtim_dur keep);
249
250
/* From cache_main.c */
251
void BAN_Init(void);
252
void BAN_Compile(void);
253
void BAN_Shutdown(void);
254
255
/* From cache_hash.c */
256
void BAN_NewObjCore(struct objcore *oc);
257
void BAN_DestroyObj(struct objcore *oc);
258
int BAN_CheckObject(struct worker *, struct objcore *, struct req *);
259
260
/* cache_busyobj.c */
261
void VBO_Init(void);
262
263
/* cache_cli.c [CLI] */
264
void CLI_Init(void);
265
void CLI_Run(void);
266
void CLI_AddFuncs(struct cli_proto *p);
267
268
/* cache_expire.c */
269
void EXP_Init(void);
270
void EXP_Shutdown(void);
271
272
/* cache_fetch.c */
273
enum vbf_fetch_mode_e {
274
        VBF_NORMAL = 0,
275
        VBF_PASS = 1,
276
        VBF_BACKGROUND = 2,
277
};
278
void VBF_Fetch(struct worker *wrk, struct req *req,
279
    struct objcore *oc, struct objcore *oldoc, enum vbf_fetch_mode_e);
280
const char *VBF_Get_Filter_List(struct busyobj *);
281
void Bereq_Rollback(VRT_CTX);
282
283
/* cache_fetch_proc.c */
284
void VFP_Init(void);
285
struct vfp_entry *VFP_Push(struct vfp_ctx *, const struct vfp *);
286
enum vfp_status VFP_GetStorage(struct vfp_ctx *, ssize_t *sz, uint8_t **ptr);
287
void VFP_Extend(const struct vfp_ctx *, ssize_t sz, enum vfp_status);
288
void VFP_Setup(struct vfp_ctx *vc, struct worker *wrk);
289
int VFP_Open(VRT_CTX, struct vfp_ctx *);
290
uint64_t VFP_Close(struct vfp_ctx *);
291
292
extern const struct vfp VFP_gunzip;
293
extern const struct vfp VFP_gzip;
294
extern const struct vfp VFP_testgunzip;
295
extern const struct vfp VFP_esi;
296
extern const struct vfp VFP_esi_gzip;
297
298
/* cache_http.c */
299
void HTTP_Init(void);
300
301
/* cache_http1_proto.c */
302
303
htc_complete_f HTTP1_Complete;
304
uint16_t HTTP1_DissectRequest(struct http_conn *, struct http *);
305
uint16_t HTTP1_DissectResponse(struct http_conn *, struct http *resp,
306
    const struct http *req);
307
struct v1l;
308
unsigned HTTP1_Write(struct v1l *v1l, const struct http *hp, const int*);
309
310
/* cache_main.c */
311
vxid_t VXID_Get(const struct worker *, uint64_t marker);
312
extern pthread_key_t panic_key;
313
extern pthread_key_t witness_key;
314
315
void THR_SetName(const char *name);
316
const char* THR_GetName(void);
317
void THR_SetBusyobj(const struct busyobj *);
318
struct busyobj * THR_GetBusyobj(void);
319
void THR_SetRequest(const struct req *);
320
struct req * THR_GetRequest(void);
321
void THR_SetWorker(const struct worker *);
322
struct worker * THR_GetWorker(void);
323
void THR_Init(void);
324
325
/* cache_lck.c */
326
void LCK_Init(void);
327
328
/* cache_mempool.c */
329
void MPL_AssertSane(const void *item);
330
struct mempool * MPL_New(const char *name, volatile struct poolparam *pp,
331
    volatile unsigned *cur_size);
332
void MPL_Destroy(struct mempool **mpp);
333
void *MPL_Get(struct mempool *mpl, unsigned *size);
334
void MPL_Free(struct mempool *mpl, void *item);
335
336
/* cache_obj.c */
337
void ObjInit(void);
338
struct objcore * ObjNew(const struct worker *);
339
void ObjDestroy(const struct worker *, struct objcore **);
340
int ObjGetSpace(struct worker *, struct objcore *, ssize_t *sz, uint8_t **ptr);
341
void ObjExtend(struct worker *, struct objcore *, ssize_t l, int final);
342
uint64_t ObjWaitExtend(const struct worker *, const struct objcore *,
343
    uint64_t l, enum boc_state_e *statep);
344
void ObjSetState(struct worker *, const struct objcore *,
345
    enum boc_state_e next);
346
void ObjWaitState(const struct objcore *, enum boc_state_e want);
347
void ObjTouch(struct worker *, struct objcore *, vtim_real now);
348
void ObjFreeObj(struct worker *, struct objcore *);
349
void ObjSlim(struct worker *, struct objcore *);
350
void *ObjSetAttr(struct worker *, struct objcore *, enum obj_attr,
351
    ssize_t len, const void *);
352
int ObjCopyAttr(struct worker *, struct objcore *, struct objcore *,
353
    enum obj_attr attr);
354
void ObjBocDone(struct worker *, struct objcore *, struct boc **);
355
// VAI
356
uint64_t ObjVAIGetExtend(struct worker *, const struct objcore *, uint64_t,
357
    enum boc_state_e *, struct vai_qe *);
358
void ObjVAICancel(struct worker *, struct boc *, struct vai_qe *);
359
360
int ObjSetDouble(struct worker *, struct objcore *, enum obj_attr, double);
361
int ObjSetU64(struct worker *, struct objcore *, enum obj_attr, uint64_t);
362
int ObjSetXID(struct worker *, struct objcore *, vxid_t);
363
364
void ObjSetFlag(struct worker *, struct objcore *, enum obj_flags of, int val);
365
366
void ObjSendEvent(struct worker *, struct objcore *oc, unsigned event);
367
368
#define OEV_INSERT      (1U<<1)
369
#define OEV_BANCHG      (1U<<2)
370
#define OEV_TTLCHG      (1U<<3)
371
#define OEV_EXPIRE      (1U<<4)
372
373
#define OEV_MASK (OEV_INSERT|OEV_BANCHG|OEV_TTLCHG|OEV_EXPIRE)
374
375
typedef void obj_event_f(struct worker *, void *priv, struct objcore *,
376
    unsigned);
377
378
uintptr_t ObjSubscribeEvents(obj_event_f *, void *, unsigned mask);
379
void ObjUnsubscribeEvents(uintptr_t *);
380
381
/* cache_panic.c */
382
void PAN_Init(void);
383
int PAN__DumpStruct(struct vsb *vsb, int block, int track, const void *ptr,
384
    const char *smagic, unsigned magic, const char *fmt, ...)
385
    v_printflike_(7,8);
386
387
#define PAN_CheckMagic(vsb, ptr, exp)                                   \
388
        do {                                                            \
389
                if ((ptr)->magic != (exp))                              \
390
                        VSB_printf((vsb),                               \
391
                            "MAGIC at %p is 0x%08x (Should be: %s/0x%08x)\n", \
392
                            ptr, (ptr)->magic, #exp, exp);              \
393
        } while(0)
394
395
#define PAN_dump_struct(vsb, ptr, magic, ...)           \
396
    PAN__DumpStruct(vsb, 1, 1, ptr, #magic, magic, __VA_ARGS__)
397
398
#define PAN_dump_oneline(vsb, ptr, magic, ...)          \
399
    PAN__DumpStruct(vsb, 0, 1, ptr, #magic, magic, __VA_ARGS__)
400
401
#define PAN_dump_once(vsb, ptr, magic, ...)             \
402
    PAN__DumpStruct(vsb, 1, 0, ptr, #magic, magic, __VA_ARGS__)
403
404
#define PAN_dump_once_oneline(vsb, ptr, magic, ...)             \
405
    PAN__DumpStruct(vsb, 0, 0, ptr, #magic, magic, __VA_ARGS__)
406
407
/* cache_pool.c */
408
void Pool_Init(void);
409
int Pool_Task(struct pool *pp, struct pool_task *task, enum task_prio prio);
410
int Pool_Task_Arg(struct worker *, enum task_prio, task_func_t *,
411
    const void *arg, size_t arg_len);
412
void Pool_Sumstat(const struct worker *w);
413
int Pool_TrySumstat(const struct worker *wrk);
414
void Pool_PurgeStat(unsigned nobj);
415
int Pool_Task_Any(struct pool_task *task, enum task_prio prio);
416
void pan_pool(struct vsb *);
417
418
/* cache_range.c */
419
int VRG_CheckBo(struct busyobj *);
420
421
/* cache_req.c */
422
struct req *Req_New(struct sess *, const struct req *);
423
void Req_Release(struct req *);
424
void Req_Rollback(VRT_CTX);
425
void Req_Cleanup(struct sess *sp, struct worker *wrk, struct req *req);
426
void Req_Fail(struct req *req, stream_close_t reason);
427
void Req_AcctLogCharge(struct VSC_main_wrk *, struct req *);
428
void Req_LogHit(struct worker *, struct req *, struct objcore *, intmax_t);
429
const char *Req_LogStart(const struct worker *, struct req *);
430
431
/* cache_req_body.c */
432
int VRB_Ignore(struct req *);
433
ssize_t VRB_Cache(struct req *, ssize_t maxsize);
434
void VRB_Free(struct req *);
435
436
/* cache_req_fsm.c [CNT] */
437
438
int Resp_Setup_Deliver(struct req *);
439
void Resp_Setup_Synth(struct req *);
440
441
enum req_fsm_nxt {
442
        REQ_FSM_MORE,
443
        REQ_FSM_DONE,
444
        REQ_FSM_DISEMBARK,
445
};
446
447
void CNT_Embark(struct worker *, struct req *);
448
enum req_fsm_nxt CNT_Request(struct req *);
449
450
/* cache_session.c */
451
void SES_NewPool(struct pool *, unsigned pool_no);
452
void SES_DestroyPool(struct pool *);
453
void SES_Wait(struct sess *, const struct transport *);
454
void SES_Ref(struct sess *sp);
455
void SES_Rel(struct sess *sp);
456
457
void HTC_Status(enum htc_status_e, const char **, const char **);
458
void HTC_RxInit(struct http_conn *htc, struct ws *ws);
459
void HTC_RxPipeline(struct http_conn *htc, char *);
460
enum htc_status_e HTC_RxStuff(struct http_conn *, htc_complete_f *,
461
    vtim_real *t1, vtim_real *t2, vtim_real ti, vtim_real tn, vtim_dur td,
462
    int maxbytes);
463
464
#define SESS_ATTR(UP, low, typ, len)                                    \
465
        int SES_Set_##low(const struct sess *sp, const typ *src);       \
466
        int SES_Reserve_##low(struct sess *sp, typ **dst, ssize_t *sz);
467
#include "tbl/sess_attr.h"
468
int SES_Set_String_Attr(struct sess *sp, enum sess_attr a, const char *src);
469
470
/* cache_shmlog.c */
471
extern struct VSC_main *VSC_C_main;
472
void VSM_Init(void);
473
void VSL_Setup(struct vsl_log *vsl, void *ptr, size_t len);
474
void VSL_ChgId(struct vsl_log *vsl, const char *typ, const char *why,
475
    vxid_t vxid);
476
void VSL_End(struct vsl_log *vsl);
477
void VSL_Flush(struct vsl_log *, int overflow);
478
479
/* cache_conn_pool.c */
480
struct conn_pool;
481
void VCP_Init(void);
482
void VCP_Panic(struct vsb *, struct conn_pool *);
483
void VCP_RelPoll(void);
484
485
/* cache_backend_probe.c */
486
void VBP_Init(void);
487
488
/* cache_vary.c */
489
int VRY_Create(struct busyobj *bo, struct vsb **psb);
490
int VRY_Match(const struct req *, const uint8_t *vary);
491
void VRY_Prep(struct req *);
492
void VRY_Clear(struct req *);
493
enum vry_finish_flag { KEEP, DISCARD };
494
void VRY_Finish(struct req *req, enum vry_finish_flag);
495
496
/* cache_vcl.c */
497
void VCL_Bo2Ctx(struct vrt_ctx *, struct busyobj *);
498
void VCL_Req2Ctx(struct vrt_ctx *, struct req *);
499
struct vrt_ctx *VCL_Get_CliCtx(int);
500
struct vsb *VCL_Rel_CliCtx(struct vrt_ctx **);
501
void VCL_Panic(struct vsb *, const char *nm, const struct vcl *);
502
void VCL_Poll(void);
503
void VCL_Init(void);
504
505
#define VCL_MET_MAC(l,u,t,b) \
506
    void VCL_##l##_method(struct vcl *, struct worker *, struct req *, \
507
        struct busyobj *bo, void *specific);
508
#include "tbl/vcl_returns.h"
509
510
511
typedef int vcl_be_func(struct cli *, struct director *, void *);
512
513
int VCL_IterDirector(struct cli *, const char *, vcl_be_func *, void *);
514
515
/* cache_vrt.c */
516
void pan_privs(struct vsb *, const struct vrt_privs *);
517
518
/* cache_vrt_filter.c */
519
int VCL_StackVFP(struct vfp_ctx *, const struct vcl *, const char *);
520
int VCL_StackVDP(struct vdp_ctx *vdc, const struct vcl *vcl, const char *fl,
521
    struct req *req, struct busyobj *bo);
522
const char *resp_Get_Filter_List(struct req *req);
523
void VCL_VRT_Init(void);
524
525
/* cache_vrt_vcl.c */
526
const char *VCL_Return_Name(unsigned);
527
const char *VCL_Method_Name(unsigned);
528
void VCL_Refresh(struct vcl **);
529
void VCL_Recache(const struct worker *, struct vcl **);
530
void VCL_Ref(struct vcl *);
531
void VCL_Rel(struct vcl **);
532
VCL_BACKEND VCL_DefaultDirector(const struct vcl *);
533
const struct vrt_backend_probe *VCL_DefaultProbe(const struct vcl *);
534
535
/* cache_vrt_priv.c */
536
extern struct vrt_privs cli_task_privs[1];
537
void VCL_TaskEnter(struct vrt_privs *);
538
void VCL_TaskLeave(VRT_CTX, struct vrt_privs *);
539
540
/* cache_vrt_vmod.c */
541
void VMOD_Init(void);
542
void VMOD_Panic(struct vsb *);
543
544
#if defined(ENABLE_COVERAGE) || defined(ENABLE_SANITIZER)
545
#  define DONT_DLCLOSE_VMODS
546
#endif
547
548
/* cache_wrk.c */
549
void WRK_Init(void);
550
void WRK_AddStat(const struct worker *);
551
void WRK_Log(enum VSL_tag_e, const char *, ...);
552
553
/* cache_vpi.c */
554
extern const size_t vpi_wrk_len;
555
void VPI_wrk_init(struct worker *, void *, size_t);
556
void VPI_Panic(struct vsb *, const struct wrk_vpi *, const struct vcl *);
557
558
/* cache_ws.c */
559
void WS_Panic(struct vsb *, const struct ws *);
560
static inline int
561 650
WS_IsReserved(const struct ws *ws)
562
{
563
564 650
        return (ws->r != NULL);
565
}
566
567
void *WS_AtOffset(const struct ws *ws, unsigned off, unsigned len);
568
unsigned WS_ReservationOffset(const struct ws *ws);
569
int WS_Pipeline(struct ws *, const void *b, const void *e, unsigned rollback);
570
571
/* cache_ws_common.c */
572
void WS_Id(const struct ws *ws, char *id);
573
void WS_Rollback(struct ws *, uintptr_t);
574
575
/* http1/cache_http1_pipe.c */
576
void V1P_Init(void);
577
578
/* cache_http2_deliver.c */
579
void V2D_Init(void);
580
581
/* stevedore.c */
582
void STV_open(void);
583
void STV_close(void);
584
const struct stevedore *STV_next(void);
585
int STV_BanInfoDrop(const uint8_t *ban, unsigned len);
586
int STV_BanInfoNew(const uint8_t *ban, unsigned len);
587
void STV_BanExport(const uint8_t *banlist, unsigned len);
588
// STV_NewObject() len is space for OBJ_VARATTR
589
int STV_NewObject(struct worker *, struct objcore *,
590
    const struct stevedore *, unsigned len);
591
592
struct stv_buffer;
593
struct stv_buffer *STV_AllocBuf(struct worker *wrk, const struct stevedore *stv,
594
    size_t size);
595
void STV_FreeBuf(struct worker *wrk, struct stv_buffer **pstvbuf);
596
void *STV_GetBufPtr(struct stv_buffer *stvbuf, size_t *psize);
597
598
#ifdef WITH_PERSISTENT_STORAGE
599
/* storage_persistent.c */
600
void SMP_Ready(void);
601
#endif
602
603
#define FEATURE(x)      COM_FEATURE(cache_param->feature_bits, x)
604
#define EXPERIMENT(x)   COM_EXPERIMENT(cache_param->experimental_bits, x)
605
#define DO_DEBUG(x)     COM_DO_DEBUG(cache_param->debug_bits, x)
606
607
#define DSL(debug_bit, id, ...)                                 \
608
        do {                                                    \
609
                if (DO_DEBUG(debug_bit))                        \
610
                        VSL(SLT_Debug, (id), __VA_ARGS__);      \
611
        } while (0)
612
613
#define DSLb(debug_bit, ...)                                    \
614
        do {                                                    \
615
                if (DO_DEBUG(debug_bit))                        \
616
                        WRK_Log(SLT_Debug, __VA_ARGS__);        \
617
        } while (0)