annotate ngx_http_delay_body_filter_module.c @ 1:7c2d64d9c656

Working delay body and tests. Depends on rb->filter_need_buffering and rb->buffered, as well as corresponding changes in the request body reading code to work. Might not be the best solution, as current body reading code relies on rb->buffered to be properly set at various stages. Notably, rb->buffered must be cleared when calling the next filter, since the save body filter relies on it. Possible future improvements: implement last buffer checking in the save body filter instead of checking for (rb->rest == 0 && !rb->buffered). The code uses its own event to implement delay timer. To remove the timer in case of abnormal request termination a cleanup handler is added. While in theory it is possible to use a timer on c->read instead, this implies additional changes to the request body reading code. Custom event was chosen to reduce complexity of changes needed.
author Maxim Dounin <mdounin@mdounin.ru>
date Fri, 20 Aug 2021 22:35:05 +0300
parents a386f95c5ae9
children b049c3a0543e
Ignore whitespace changes - Everywhere: Within whitespace: At end of lines:
rev   line source
0
a386f95c5ae9 Initial module skeleton.
Maxim Dounin <mdounin@mdounin.ru>
parents:
diff changeset
1
a386f95c5ae9 Initial module skeleton.
Maxim Dounin <mdounin@mdounin.ru>
parents:
diff changeset
2 /*
a386f95c5ae9 Initial module skeleton.
Maxim Dounin <mdounin@mdounin.ru>
parents:
diff changeset
3 * Copyright (C) Maxim Dounin
a386f95c5ae9 Initial module skeleton.
Maxim Dounin <mdounin@mdounin.ru>
parents:
diff changeset
4 */
a386f95c5ae9 Initial module skeleton.
Maxim Dounin <mdounin@mdounin.ru>
parents:
diff changeset
5
a386f95c5ae9 Initial module skeleton.
Maxim Dounin <mdounin@mdounin.ru>
parents:
diff changeset
6 #include <ngx_config.h>
a386f95c5ae9 Initial module skeleton.
Maxim Dounin <mdounin@mdounin.ru>
parents:
diff changeset
7 #include <ngx_core.h>
a386f95c5ae9 Initial module skeleton.
Maxim Dounin <mdounin@mdounin.ru>
parents:
diff changeset
8 #include <ngx_http.h>
a386f95c5ae9 Initial module skeleton.
Maxim Dounin <mdounin@mdounin.ru>
parents:
diff changeset
9
a386f95c5ae9 Initial module skeleton.
Maxim Dounin <mdounin@mdounin.ru>
parents:
diff changeset
10
a386f95c5ae9 Initial module skeleton.
Maxim Dounin <mdounin@mdounin.ru>
parents:
diff changeset
11 typedef struct {
1
7c2d64d9c656 Working delay body and tests.
Maxim Dounin <mdounin@mdounin.ru>
parents: 0
diff changeset
12 ngx_msec_t delay;
0
a386f95c5ae9 Initial module skeleton.
Maxim Dounin <mdounin@mdounin.ru>
parents:
diff changeset
13 } ngx_http_delay_body_conf_t;
a386f95c5ae9 Initial module skeleton.
Maxim Dounin <mdounin@mdounin.ru>
parents:
diff changeset
14
a386f95c5ae9 Initial module skeleton.
Maxim Dounin <mdounin@mdounin.ru>
parents:
diff changeset
15
1
7c2d64d9c656 Working delay body and tests.
Maxim Dounin <mdounin@mdounin.ru>
parents: 0
diff changeset
16 typedef struct {
7c2d64d9c656 Working delay body and tests.
Maxim Dounin <mdounin@mdounin.ru>
parents: 0
diff changeset
17 ngx_event_t event;
7c2d64d9c656 Working delay body and tests.
Maxim Dounin <mdounin@mdounin.ru>
parents: 0
diff changeset
18 ngx_chain_t *out;
7c2d64d9c656 Working delay body and tests.
Maxim Dounin <mdounin@mdounin.ru>
parents: 0
diff changeset
19 ngx_uint_t buffered;
7c2d64d9c656 Working delay body and tests.
Maxim Dounin <mdounin@mdounin.ru>
parents: 0
diff changeset
20 } ngx_http_delay_body_ctx_t;
7c2d64d9c656 Working delay body and tests.
Maxim Dounin <mdounin@mdounin.ru>
parents: 0
diff changeset
21
7c2d64d9c656 Working delay body and tests.
Maxim Dounin <mdounin@mdounin.ru>
parents: 0
diff changeset
22
7c2d64d9c656 Working delay body and tests.
Maxim Dounin <mdounin@mdounin.ru>
parents: 0
diff changeset
23 static ngx_int_t ngx_http_delay_body_filter(ngx_http_request_t *r,
7c2d64d9c656 Working delay body and tests.
Maxim Dounin <mdounin@mdounin.ru>
parents: 0
diff changeset
24 ngx_chain_t *in);
7c2d64d9c656 Working delay body and tests.
Maxim Dounin <mdounin@mdounin.ru>
parents: 0
diff changeset
25 static void ngx_http_delay_body_cleanup(void *data);
7c2d64d9c656 Working delay body and tests.
Maxim Dounin <mdounin@mdounin.ru>
parents: 0
diff changeset
26 static void ngx_http_delay_body_event_handler(ngx_event_t *ev);
0
a386f95c5ae9 Initial module skeleton.
Maxim Dounin <mdounin@mdounin.ru>
parents:
diff changeset
27 static void *ngx_http_delay_body_create_conf(ngx_conf_t *cf);
a386f95c5ae9 Initial module skeleton.
Maxim Dounin <mdounin@mdounin.ru>
parents:
diff changeset
28 static char *ngx_http_delay_body_merge_conf(ngx_conf_t *cf, void *parent,
a386f95c5ae9 Initial module skeleton.
Maxim Dounin <mdounin@mdounin.ru>
parents:
diff changeset
29 void *child);
a386f95c5ae9 Initial module skeleton.
Maxim Dounin <mdounin@mdounin.ru>
parents:
diff changeset
30 static ngx_int_t ngx_http_delay_body_init(ngx_conf_t *cf);
a386f95c5ae9 Initial module skeleton.
Maxim Dounin <mdounin@mdounin.ru>
parents:
diff changeset
31
a386f95c5ae9 Initial module skeleton.
Maxim Dounin <mdounin@mdounin.ru>
parents:
diff changeset
32
a386f95c5ae9 Initial module skeleton.
Maxim Dounin <mdounin@mdounin.ru>
parents:
diff changeset
33 static ngx_command_t ngx_http_delay_body_commands[] = {
a386f95c5ae9 Initial module skeleton.
Maxim Dounin <mdounin@mdounin.ru>
parents:
diff changeset
34
a386f95c5ae9 Initial module skeleton.
Maxim Dounin <mdounin@mdounin.ru>
parents:
diff changeset
35 { ngx_string("delay_body"),
a386f95c5ae9 Initial module skeleton.
Maxim Dounin <mdounin@mdounin.ru>
parents:
diff changeset
36 NGX_HTTP_MAIN_CONF|NGX_HTTP_SRV_CONF|NGX_HTTP_LOC_CONF|NGX_CONF_FLAG,
a386f95c5ae9 Initial module skeleton.
Maxim Dounin <mdounin@mdounin.ru>
parents:
diff changeset
37 ngx_conf_set_msec_slot,
a386f95c5ae9 Initial module skeleton.
Maxim Dounin <mdounin@mdounin.ru>
parents:
diff changeset
38 NGX_HTTP_LOC_CONF_OFFSET,
a386f95c5ae9 Initial module skeleton.
Maxim Dounin <mdounin@mdounin.ru>
parents:
diff changeset
39 offsetof(ngx_http_delay_body_conf_t, delay),
a386f95c5ae9 Initial module skeleton.
Maxim Dounin <mdounin@mdounin.ru>
parents:
diff changeset
40 NULL },
a386f95c5ae9 Initial module skeleton.
Maxim Dounin <mdounin@mdounin.ru>
parents:
diff changeset
41
a386f95c5ae9 Initial module skeleton.
Maxim Dounin <mdounin@mdounin.ru>
parents:
diff changeset
42 ngx_null_command
a386f95c5ae9 Initial module skeleton.
Maxim Dounin <mdounin@mdounin.ru>
parents:
diff changeset
43 };
a386f95c5ae9 Initial module skeleton.
Maxim Dounin <mdounin@mdounin.ru>
parents:
diff changeset
44
a386f95c5ae9 Initial module skeleton.
Maxim Dounin <mdounin@mdounin.ru>
parents:
diff changeset
45
a386f95c5ae9 Initial module skeleton.
Maxim Dounin <mdounin@mdounin.ru>
parents:
diff changeset
46 static ngx_http_module_t ngx_http_delay_body_module_ctx = {
a386f95c5ae9 Initial module skeleton.
Maxim Dounin <mdounin@mdounin.ru>
parents:
diff changeset
47 NULL, /* preconfiguration */
a386f95c5ae9 Initial module skeleton.
Maxim Dounin <mdounin@mdounin.ru>
parents:
diff changeset
48 ngx_http_delay_body_init, /* postconfiguration */
a386f95c5ae9 Initial module skeleton.
Maxim Dounin <mdounin@mdounin.ru>
parents:
diff changeset
49
a386f95c5ae9 Initial module skeleton.
Maxim Dounin <mdounin@mdounin.ru>
parents:
diff changeset
50 NULL, /* create main configuration */
a386f95c5ae9 Initial module skeleton.
Maxim Dounin <mdounin@mdounin.ru>
parents:
diff changeset
51 NULL, /* init main configuration */
a386f95c5ae9 Initial module skeleton.
Maxim Dounin <mdounin@mdounin.ru>
parents:
diff changeset
52
a386f95c5ae9 Initial module skeleton.
Maxim Dounin <mdounin@mdounin.ru>
parents:
diff changeset
53 NULL, /* create server configuration */
a386f95c5ae9 Initial module skeleton.
Maxim Dounin <mdounin@mdounin.ru>
parents:
diff changeset
54 NULL, /* merge server configuration */
a386f95c5ae9 Initial module skeleton.
Maxim Dounin <mdounin@mdounin.ru>
parents:
diff changeset
55
a386f95c5ae9 Initial module skeleton.
Maxim Dounin <mdounin@mdounin.ru>
parents:
diff changeset
56 ngx_http_delay_body_create_conf, /* create location configuration */
a386f95c5ae9 Initial module skeleton.
Maxim Dounin <mdounin@mdounin.ru>
parents:
diff changeset
57 ngx_http_delay_body_merge_conf /* merge location configuration */
a386f95c5ae9 Initial module skeleton.
Maxim Dounin <mdounin@mdounin.ru>
parents:
diff changeset
58 };
a386f95c5ae9 Initial module skeleton.
Maxim Dounin <mdounin@mdounin.ru>
parents:
diff changeset
59
a386f95c5ae9 Initial module skeleton.
Maxim Dounin <mdounin@mdounin.ru>
parents:
diff changeset
60
a386f95c5ae9 Initial module skeleton.
Maxim Dounin <mdounin@mdounin.ru>
parents:
diff changeset
61 ngx_module_t ngx_http_delay_body_filter_module = {
a386f95c5ae9 Initial module skeleton.
Maxim Dounin <mdounin@mdounin.ru>
parents:
diff changeset
62 NGX_MODULE_V1,
a386f95c5ae9 Initial module skeleton.
Maxim Dounin <mdounin@mdounin.ru>
parents:
diff changeset
63 &ngx_http_delay_body_module_ctx, /* module context */
a386f95c5ae9 Initial module skeleton.
Maxim Dounin <mdounin@mdounin.ru>
parents:
diff changeset
64 ngx_http_delay_body_commands, /* module directives */
a386f95c5ae9 Initial module skeleton.
Maxim Dounin <mdounin@mdounin.ru>
parents:
diff changeset
65 NGX_HTTP_MODULE, /* module type */
a386f95c5ae9 Initial module skeleton.
Maxim Dounin <mdounin@mdounin.ru>
parents:
diff changeset
66 NULL, /* init master */
a386f95c5ae9 Initial module skeleton.
Maxim Dounin <mdounin@mdounin.ru>
parents:
diff changeset
67 NULL, /* init module */
a386f95c5ae9 Initial module skeleton.
Maxim Dounin <mdounin@mdounin.ru>
parents:
diff changeset
68 NULL, /* init process */
a386f95c5ae9 Initial module skeleton.
Maxim Dounin <mdounin@mdounin.ru>
parents:
diff changeset
69 NULL, /* init thread */
a386f95c5ae9 Initial module skeleton.
Maxim Dounin <mdounin@mdounin.ru>
parents:
diff changeset
70 NULL, /* exit thread */
a386f95c5ae9 Initial module skeleton.
Maxim Dounin <mdounin@mdounin.ru>
parents:
diff changeset
71 NULL, /* exit process */
a386f95c5ae9 Initial module skeleton.
Maxim Dounin <mdounin@mdounin.ru>
parents:
diff changeset
72 NULL, /* exit master */
a386f95c5ae9 Initial module skeleton.
Maxim Dounin <mdounin@mdounin.ru>
parents:
diff changeset
73 NGX_MODULE_V1_PADDING
a386f95c5ae9 Initial module skeleton.
Maxim Dounin <mdounin@mdounin.ru>
parents:
diff changeset
74 };
a386f95c5ae9 Initial module skeleton.
Maxim Dounin <mdounin@mdounin.ru>
parents:
diff changeset
75
a386f95c5ae9 Initial module skeleton.
Maxim Dounin <mdounin@mdounin.ru>
parents:
diff changeset
76
a386f95c5ae9 Initial module skeleton.
Maxim Dounin <mdounin@mdounin.ru>
parents:
diff changeset
77 static ngx_http_request_body_filter_pt ngx_http_next_request_body_filter;
a386f95c5ae9 Initial module skeleton.
Maxim Dounin <mdounin@mdounin.ru>
parents:
diff changeset
78
a386f95c5ae9 Initial module skeleton.
Maxim Dounin <mdounin@mdounin.ru>
parents:
diff changeset
79
a386f95c5ae9 Initial module skeleton.
Maxim Dounin <mdounin@mdounin.ru>
parents:
diff changeset
80 static ngx_int_t
a386f95c5ae9 Initial module skeleton.
Maxim Dounin <mdounin@mdounin.ru>
parents:
diff changeset
81 ngx_http_delay_body_filter(ngx_http_request_t *r, ngx_chain_t *in)
a386f95c5ae9 Initial module skeleton.
Maxim Dounin <mdounin@mdounin.ru>
parents:
diff changeset
82 {
1
7c2d64d9c656 Working delay body and tests.
Maxim Dounin <mdounin@mdounin.ru>
parents: 0
diff changeset
83 ngx_int_t rc;
7c2d64d9c656 Working delay body and tests.
Maxim Dounin <mdounin@mdounin.ru>
parents: 0
diff changeset
84 ngx_chain_t *cl, *ln;
7c2d64d9c656 Working delay body and tests.
Maxim Dounin <mdounin@mdounin.ru>
parents: 0
diff changeset
85 ngx_http_cleanup_t *cln;
7c2d64d9c656 Working delay body and tests.
Maxim Dounin <mdounin@mdounin.ru>
parents: 0
diff changeset
86 ngx_http_delay_body_ctx_t *ctx;
0
a386f95c5ae9 Initial module skeleton.
Maxim Dounin <mdounin@mdounin.ru>
parents:
diff changeset
87 ngx_http_delay_body_conf_t *conf;
a386f95c5ae9 Initial module skeleton.
Maxim Dounin <mdounin@mdounin.ru>
parents:
diff changeset
88
a386f95c5ae9 Initial module skeleton.
Maxim Dounin <mdounin@mdounin.ru>
parents:
diff changeset
89 conf = ngx_http_get_module_loc_conf(r, ngx_http_delay_body_filter_module);
a386f95c5ae9 Initial module skeleton.
Maxim Dounin <mdounin@mdounin.ru>
parents:
diff changeset
90
a386f95c5ae9 Initial module skeleton.
Maxim Dounin <mdounin@mdounin.ru>
parents:
diff changeset
91 if (!conf->delay) {
a386f95c5ae9 Initial module skeleton.
Maxim Dounin <mdounin@mdounin.ru>
parents:
diff changeset
92 return ngx_http_next_request_body_filter(r, in);
a386f95c5ae9 Initial module skeleton.
Maxim Dounin <mdounin@mdounin.ru>
parents:
diff changeset
93 }
a386f95c5ae9 Initial module skeleton.
Maxim Dounin <mdounin@mdounin.ru>
parents:
diff changeset
94
a386f95c5ae9 Initial module skeleton.
Maxim Dounin <mdounin@mdounin.ru>
parents:
diff changeset
95 ngx_log_debug0(NGX_LOG_DEBUG_HTTP, r->connection->log, 0,
a386f95c5ae9 Initial module skeleton.
Maxim Dounin <mdounin@mdounin.ru>
parents:
diff changeset
96 "delay request body filter");
a386f95c5ae9 Initial module skeleton.
Maxim Dounin <mdounin@mdounin.ru>
parents:
diff changeset
97
1
7c2d64d9c656 Working delay body and tests.
Maxim Dounin <mdounin@mdounin.ru>
parents: 0
diff changeset
98 ctx = ngx_http_get_module_ctx(r, ngx_http_delay_body_filter_module);
7c2d64d9c656 Working delay body and tests.
Maxim Dounin <mdounin@mdounin.ru>
parents: 0
diff changeset
99
7c2d64d9c656 Working delay body and tests.
Maxim Dounin <mdounin@mdounin.ru>
parents: 0
diff changeset
100 if (ctx == NULL) {
7c2d64d9c656 Working delay body and tests.
Maxim Dounin <mdounin@mdounin.ru>
parents: 0
diff changeset
101 ctx = ngx_pcalloc(r->pool, sizeof(ngx_http_delay_body_ctx_t));
7c2d64d9c656 Working delay body and tests.
Maxim Dounin <mdounin@mdounin.ru>
parents: 0
diff changeset
102 if (ctx == NULL) {
7c2d64d9c656 Working delay body and tests.
Maxim Dounin <mdounin@mdounin.ru>
parents: 0
diff changeset
103 return NGX_ERROR;
7c2d64d9c656 Working delay body and tests.
Maxim Dounin <mdounin@mdounin.ru>
parents: 0
diff changeset
104 }
7c2d64d9c656 Working delay body and tests.
Maxim Dounin <mdounin@mdounin.ru>
parents: 0
diff changeset
105
7c2d64d9c656 Working delay body and tests.
Maxim Dounin <mdounin@mdounin.ru>
parents: 0
diff changeset
106 ngx_http_set_ctx(r, ctx, ngx_http_delay_body_filter_module);
0
a386f95c5ae9 Initial module skeleton.
Maxim Dounin <mdounin@mdounin.ru>
parents:
diff changeset
107
1
7c2d64d9c656 Working delay body and tests.
Maxim Dounin <mdounin@mdounin.ru>
parents: 0
diff changeset
108 #if 1 /* XXX */
7c2d64d9c656 Working delay body and tests.
Maxim Dounin <mdounin@mdounin.ru>
parents: 0
diff changeset
109 r->request_body->filter_need_buffering = 1;
7c2d64d9c656 Working delay body and tests.
Maxim Dounin <mdounin@mdounin.ru>
parents: 0
diff changeset
110 #endif
7c2d64d9c656 Working delay body and tests.
Maxim Dounin <mdounin@mdounin.ru>
parents: 0
diff changeset
111 }
7c2d64d9c656 Working delay body and tests.
Maxim Dounin <mdounin@mdounin.ru>
parents: 0
diff changeset
112
7c2d64d9c656 Working delay body and tests.
Maxim Dounin <mdounin@mdounin.ru>
parents: 0
diff changeset
113 if (ngx_chain_add_copy(r->pool, &ctx->out, in) != NGX_OK) {
7c2d64d9c656 Working delay body and tests.
Maxim Dounin <mdounin@mdounin.ru>
parents: 0
diff changeset
114 return NGX_ERROR;
7c2d64d9c656 Working delay body and tests.
Maxim Dounin <mdounin@mdounin.ru>
parents: 0
diff changeset
115 }
7c2d64d9c656 Working delay body and tests.
Maxim Dounin <mdounin@mdounin.ru>
parents: 0
diff changeset
116
7c2d64d9c656 Working delay body and tests.
Maxim Dounin <mdounin@mdounin.ru>
parents: 0
diff changeset
117 if (!ctx->event.timedout) {
7c2d64d9c656 Working delay body and tests.
Maxim Dounin <mdounin@mdounin.ru>
parents: 0
diff changeset
118 if (!ctx->event.timer_set) {
0
a386f95c5ae9 Initial module skeleton.
Maxim Dounin <mdounin@mdounin.ru>
parents:
diff changeset
119
1
7c2d64d9c656 Working delay body and tests.
Maxim Dounin <mdounin@mdounin.ru>
parents: 0
diff changeset
120 /* cleanup to remove the timer in case of abnormal termination */
7c2d64d9c656 Working delay body and tests.
Maxim Dounin <mdounin@mdounin.ru>
parents: 0
diff changeset
121
7c2d64d9c656 Working delay body and tests.
Maxim Dounin <mdounin@mdounin.ru>
parents: 0
diff changeset
122 cln = ngx_http_cleanup_add(r, 0);
7c2d64d9c656 Working delay body and tests.
Maxim Dounin <mdounin@mdounin.ru>
parents: 0
diff changeset
123 if (cln == NULL) {
7c2d64d9c656 Working delay body and tests.
Maxim Dounin <mdounin@mdounin.ru>
parents: 0
diff changeset
124 return NGX_ERROR;
7c2d64d9c656 Working delay body and tests.
Maxim Dounin <mdounin@mdounin.ru>
parents: 0
diff changeset
125 }
7c2d64d9c656 Working delay body and tests.
Maxim Dounin <mdounin@mdounin.ru>
parents: 0
diff changeset
126
7c2d64d9c656 Working delay body and tests.
Maxim Dounin <mdounin@mdounin.ru>
parents: 0
diff changeset
127 cln->handler = ngx_http_delay_body_cleanup;
7c2d64d9c656 Working delay body and tests.
Maxim Dounin <mdounin@mdounin.ru>
parents: 0
diff changeset
128 cln->data = ctx;
7c2d64d9c656 Working delay body and tests.
Maxim Dounin <mdounin@mdounin.ru>
parents: 0
diff changeset
129
7c2d64d9c656 Working delay body and tests.
Maxim Dounin <mdounin@mdounin.ru>
parents: 0
diff changeset
130 /* add timer */
7c2d64d9c656 Working delay body and tests.
Maxim Dounin <mdounin@mdounin.ru>
parents: 0
diff changeset
131
7c2d64d9c656 Working delay body and tests.
Maxim Dounin <mdounin@mdounin.ru>
parents: 0
diff changeset
132 ctx->event.handler = ngx_http_delay_body_event_handler;
7c2d64d9c656 Working delay body and tests.
Maxim Dounin <mdounin@mdounin.ru>
parents: 0
diff changeset
133 ctx->event.data = r;
7c2d64d9c656 Working delay body and tests.
Maxim Dounin <mdounin@mdounin.ru>
parents: 0
diff changeset
134 ctx->event.log = r->connection->log;
7c2d64d9c656 Working delay body and tests.
Maxim Dounin <mdounin@mdounin.ru>
parents: 0
diff changeset
135
7c2d64d9c656 Working delay body and tests.
Maxim Dounin <mdounin@mdounin.ru>
parents: 0
diff changeset
136 ngx_add_timer(&ctx->event, conf->delay);
7c2d64d9c656 Working delay body and tests.
Maxim Dounin <mdounin@mdounin.ru>
parents: 0
diff changeset
137
7c2d64d9c656 Working delay body and tests.
Maxim Dounin <mdounin@mdounin.ru>
parents: 0
diff changeset
138 ctx->buffered = 1;
7c2d64d9c656 Working delay body and tests.
Maxim Dounin <mdounin@mdounin.ru>
parents: 0
diff changeset
139 #if 1 /* XXX */
7c2d64d9c656 Working delay body and tests.
Maxim Dounin <mdounin@mdounin.ru>
parents: 0
diff changeset
140 r->request_body->buffered++;
7c2d64d9c656 Working delay body and tests.
Maxim Dounin <mdounin@mdounin.ru>
parents: 0
diff changeset
141 #endif
0
a386f95c5ae9 Initial module skeleton.
Maxim Dounin <mdounin@mdounin.ru>
parents:
diff changeset
142 }
a386f95c5ae9 Initial module skeleton.
Maxim Dounin <mdounin@mdounin.ru>
parents:
diff changeset
143
1
7c2d64d9c656 Working delay body and tests.
Maxim Dounin <mdounin@mdounin.ru>
parents: 0
diff changeset
144 return ngx_http_next_request_body_filter(r, NULL);
7c2d64d9c656 Working delay body and tests.
Maxim Dounin <mdounin@mdounin.ru>
parents: 0
diff changeset
145 }
7c2d64d9c656 Working delay body and tests.
Maxim Dounin <mdounin@mdounin.ru>
parents: 0
diff changeset
146
7c2d64d9c656 Working delay body and tests.
Maxim Dounin <mdounin@mdounin.ru>
parents: 0
diff changeset
147 if (ctx->buffered) {
7c2d64d9c656 Working delay body and tests.
Maxim Dounin <mdounin@mdounin.ru>
parents: 0
diff changeset
148 ctx->buffered = 0;
7c2d64d9c656 Working delay body and tests.
Maxim Dounin <mdounin@mdounin.ru>
parents: 0
diff changeset
149 #if 1 /* XXX */
7c2d64d9c656 Working delay body and tests.
Maxim Dounin <mdounin@mdounin.ru>
parents: 0
diff changeset
150 r->request_body->buffered--;
7c2d64d9c656 Working delay body and tests.
Maxim Dounin <mdounin@mdounin.ru>
parents: 0
diff changeset
151 #endif
7c2d64d9c656 Working delay body and tests.
Maxim Dounin <mdounin@mdounin.ru>
parents: 0
diff changeset
152 }
7c2d64d9c656 Working delay body and tests.
Maxim Dounin <mdounin@mdounin.ru>
parents: 0
diff changeset
153
7c2d64d9c656 Working delay body and tests.
Maxim Dounin <mdounin@mdounin.ru>
parents: 0
diff changeset
154 rc = ngx_http_next_request_body_filter(r, ctx->out);
7c2d64d9c656 Working delay body and tests.
Maxim Dounin <mdounin@mdounin.ru>
parents: 0
diff changeset
155
7c2d64d9c656 Working delay body and tests.
Maxim Dounin <mdounin@mdounin.ru>
parents: 0
diff changeset
156 for (cl = ctx->out; cl; /* void */) {
7c2d64d9c656 Working delay body and tests.
Maxim Dounin <mdounin@mdounin.ru>
parents: 0
diff changeset
157 ln = cl;
7c2d64d9c656 Working delay body and tests.
Maxim Dounin <mdounin@mdounin.ru>
parents: 0
diff changeset
158 cl = cl->next;
7c2d64d9c656 Working delay body and tests.
Maxim Dounin <mdounin@mdounin.ru>
parents: 0
diff changeset
159 ngx_free_chain(r->pool, ln);
0
a386f95c5ae9 Initial module skeleton.
Maxim Dounin <mdounin@mdounin.ru>
parents:
diff changeset
160 }
a386f95c5ae9 Initial module skeleton.
Maxim Dounin <mdounin@mdounin.ru>
parents:
diff changeset
161
1
7c2d64d9c656 Working delay body and tests.
Maxim Dounin <mdounin@mdounin.ru>
parents: 0
diff changeset
162 ctx->out = NULL;
7c2d64d9c656 Working delay body and tests.
Maxim Dounin <mdounin@mdounin.ru>
parents: 0
diff changeset
163
7c2d64d9c656 Working delay body and tests.
Maxim Dounin <mdounin@mdounin.ru>
parents: 0
diff changeset
164 return rc;
7c2d64d9c656 Working delay body and tests.
Maxim Dounin <mdounin@mdounin.ru>
parents: 0
diff changeset
165 }
7c2d64d9c656 Working delay body and tests.
Maxim Dounin <mdounin@mdounin.ru>
parents: 0
diff changeset
166
7c2d64d9c656 Working delay body and tests.
Maxim Dounin <mdounin@mdounin.ru>
parents: 0
diff changeset
167
7c2d64d9c656 Working delay body and tests.
Maxim Dounin <mdounin@mdounin.ru>
parents: 0
diff changeset
168 static void
7c2d64d9c656 Working delay body and tests.
Maxim Dounin <mdounin@mdounin.ru>
parents: 0
diff changeset
169 ngx_http_delay_body_cleanup(void *data)
7c2d64d9c656 Working delay body and tests.
Maxim Dounin <mdounin@mdounin.ru>
parents: 0
diff changeset
170 {
7c2d64d9c656 Working delay body and tests.
Maxim Dounin <mdounin@mdounin.ru>
parents: 0
diff changeset
171 ngx_http_delay_body_ctx_t *ctx = data;
7c2d64d9c656 Working delay body and tests.
Maxim Dounin <mdounin@mdounin.ru>
parents: 0
diff changeset
172
7c2d64d9c656 Working delay body and tests.
Maxim Dounin <mdounin@mdounin.ru>
parents: 0
diff changeset
173 if (ctx->event.timer_set) {
7c2d64d9c656 Working delay body and tests.
Maxim Dounin <mdounin@mdounin.ru>
parents: 0
diff changeset
174 ngx_del_timer(&ctx->event);
7c2d64d9c656 Working delay body and tests.
Maxim Dounin <mdounin@mdounin.ru>
parents: 0
diff changeset
175 }
7c2d64d9c656 Working delay body and tests.
Maxim Dounin <mdounin@mdounin.ru>
parents: 0
diff changeset
176 }
7c2d64d9c656 Working delay body and tests.
Maxim Dounin <mdounin@mdounin.ru>
parents: 0
diff changeset
177
7c2d64d9c656 Working delay body and tests.
Maxim Dounin <mdounin@mdounin.ru>
parents: 0
diff changeset
178
7c2d64d9c656 Working delay body and tests.
Maxim Dounin <mdounin@mdounin.ru>
parents: 0
diff changeset
179 static void
7c2d64d9c656 Working delay body and tests.
Maxim Dounin <mdounin@mdounin.ru>
parents: 0
diff changeset
180 ngx_http_delay_body_event_handler(ngx_event_t *ev)
7c2d64d9c656 Working delay body and tests.
Maxim Dounin <mdounin@mdounin.ru>
parents: 0
diff changeset
181 {
7c2d64d9c656 Working delay body and tests.
Maxim Dounin <mdounin@mdounin.ru>
parents: 0
diff changeset
182 ngx_connection_t *c;
7c2d64d9c656 Working delay body and tests.
Maxim Dounin <mdounin@mdounin.ru>
parents: 0
diff changeset
183 ngx_http_request_t *r;
7c2d64d9c656 Working delay body and tests.
Maxim Dounin <mdounin@mdounin.ru>
parents: 0
diff changeset
184
7c2d64d9c656 Working delay body and tests.
Maxim Dounin <mdounin@mdounin.ru>
parents: 0
diff changeset
185 r = ev->data;
7c2d64d9c656 Working delay body and tests.
Maxim Dounin <mdounin@mdounin.ru>
parents: 0
diff changeset
186 c = r->connection;
7c2d64d9c656 Working delay body and tests.
Maxim Dounin <mdounin@mdounin.ru>
parents: 0
diff changeset
187
7c2d64d9c656 Working delay body and tests.
Maxim Dounin <mdounin@mdounin.ru>
parents: 0
diff changeset
188 ngx_log_debug0(NGX_LOG_DEBUG_HTTP, c->log, 0,
7c2d64d9c656 Working delay body and tests.
Maxim Dounin <mdounin@mdounin.ru>
parents: 0
diff changeset
189 "delay request body event");
7c2d64d9c656 Working delay body and tests.
Maxim Dounin <mdounin@mdounin.ru>
parents: 0
diff changeset
190
7c2d64d9c656 Working delay body and tests.
Maxim Dounin <mdounin@mdounin.ru>
parents: 0
diff changeset
191 ngx_post_event(c->read, &ngx_posted_events);
0
a386f95c5ae9 Initial module skeleton.
Maxim Dounin <mdounin@mdounin.ru>
parents:
diff changeset
192 }
a386f95c5ae9 Initial module skeleton.
Maxim Dounin <mdounin@mdounin.ru>
parents:
diff changeset
193
a386f95c5ae9 Initial module skeleton.
Maxim Dounin <mdounin@mdounin.ru>
parents:
diff changeset
194
a386f95c5ae9 Initial module skeleton.
Maxim Dounin <mdounin@mdounin.ru>
parents:
diff changeset
195 static void *
a386f95c5ae9 Initial module skeleton.
Maxim Dounin <mdounin@mdounin.ru>
parents:
diff changeset
196 ngx_http_delay_body_create_conf(ngx_conf_t *cf)
a386f95c5ae9 Initial module skeleton.
Maxim Dounin <mdounin@mdounin.ru>
parents:
diff changeset
197 {
a386f95c5ae9 Initial module skeleton.
Maxim Dounin <mdounin@mdounin.ru>
parents:
diff changeset
198 ngx_http_delay_body_conf_t *conf;
a386f95c5ae9 Initial module skeleton.
Maxim Dounin <mdounin@mdounin.ru>
parents:
diff changeset
199
a386f95c5ae9 Initial module skeleton.
Maxim Dounin <mdounin@mdounin.ru>
parents:
diff changeset
200 conf = ngx_pcalloc(cf->pool, sizeof(ngx_http_delay_body_conf_t));
a386f95c5ae9 Initial module skeleton.
Maxim Dounin <mdounin@mdounin.ru>
parents:
diff changeset
201 if (conf == NULL) {
a386f95c5ae9 Initial module skeleton.
Maxim Dounin <mdounin@mdounin.ru>
parents:
diff changeset
202 return NULL;
a386f95c5ae9 Initial module skeleton.
Maxim Dounin <mdounin@mdounin.ru>
parents:
diff changeset
203 }
a386f95c5ae9 Initial module skeleton.
Maxim Dounin <mdounin@mdounin.ru>
parents:
diff changeset
204
a386f95c5ae9 Initial module skeleton.
Maxim Dounin <mdounin@mdounin.ru>
parents:
diff changeset
205 conf->delay = NGX_CONF_UNSET_MSEC;
a386f95c5ae9 Initial module skeleton.
Maxim Dounin <mdounin@mdounin.ru>
parents:
diff changeset
206
a386f95c5ae9 Initial module skeleton.
Maxim Dounin <mdounin@mdounin.ru>
parents:
diff changeset
207 return conf;
a386f95c5ae9 Initial module skeleton.
Maxim Dounin <mdounin@mdounin.ru>
parents:
diff changeset
208 }
a386f95c5ae9 Initial module skeleton.
Maxim Dounin <mdounin@mdounin.ru>
parents:
diff changeset
209
a386f95c5ae9 Initial module skeleton.
Maxim Dounin <mdounin@mdounin.ru>
parents:
diff changeset
210
a386f95c5ae9 Initial module skeleton.
Maxim Dounin <mdounin@mdounin.ru>
parents:
diff changeset
211 static char *
a386f95c5ae9 Initial module skeleton.
Maxim Dounin <mdounin@mdounin.ru>
parents:
diff changeset
212 ngx_http_delay_body_merge_conf(ngx_conf_t *cf, void *parent, void *child)
a386f95c5ae9 Initial module skeleton.
Maxim Dounin <mdounin@mdounin.ru>
parents:
diff changeset
213 {
a386f95c5ae9 Initial module skeleton.
Maxim Dounin <mdounin@mdounin.ru>
parents:
diff changeset
214 ngx_http_delay_body_conf_t *prev = parent;
a386f95c5ae9 Initial module skeleton.
Maxim Dounin <mdounin@mdounin.ru>
parents:
diff changeset
215 ngx_http_delay_body_conf_t *conf = child;
a386f95c5ae9 Initial module skeleton.
Maxim Dounin <mdounin@mdounin.ru>
parents:
diff changeset
216
a386f95c5ae9 Initial module skeleton.
Maxim Dounin <mdounin@mdounin.ru>
parents:
diff changeset
217 ngx_conf_merge_msec_value(conf->delay, prev->delay, 0);
a386f95c5ae9 Initial module skeleton.
Maxim Dounin <mdounin@mdounin.ru>
parents:
diff changeset
218
a386f95c5ae9 Initial module skeleton.
Maxim Dounin <mdounin@mdounin.ru>
parents:
diff changeset
219 return NGX_CONF_OK;
a386f95c5ae9 Initial module skeleton.
Maxim Dounin <mdounin@mdounin.ru>
parents:
diff changeset
220 }
a386f95c5ae9 Initial module skeleton.
Maxim Dounin <mdounin@mdounin.ru>
parents:
diff changeset
221
a386f95c5ae9 Initial module skeleton.
Maxim Dounin <mdounin@mdounin.ru>
parents:
diff changeset
222
a386f95c5ae9 Initial module skeleton.
Maxim Dounin <mdounin@mdounin.ru>
parents:
diff changeset
223 static ngx_int_t
a386f95c5ae9 Initial module skeleton.
Maxim Dounin <mdounin@mdounin.ru>
parents:
diff changeset
224 ngx_http_delay_body_init(ngx_conf_t *cf)
a386f95c5ae9 Initial module skeleton.
Maxim Dounin <mdounin@mdounin.ru>
parents:
diff changeset
225 {
a386f95c5ae9 Initial module skeleton.
Maxim Dounin <mdounin@mdounin.ru>
parents:
diff changeset
226 ngx_http_next_request_body_filter = ngx_http_top_request_body_filter;
a386f95c5ae9 Initial module skeleton.
Maxim Dounin <mdounin@mdounin.ru>
parents:
diff changeset
227 ngx_http_top_request_body_filter = ngx_http_delay_body_filter;
a386f95c5ae9 Initial module skeleton.
Maxim Dounin <mdounin@mdounin.ru>
parents:
diff changeset
228
a386f95c5ae9 Initial module skeleton.
Maxim Dounin <mdounin@mdounin.ru>
parents:
diff changeset
229 return NGX_OK;
a386f95c5ae9 Initial module skeleton.
Maxim Dounin <mdounin@mdounin.ru>
parents:
diff changeset
230 }