|
0
|
1
|
|
|
2 /*
|
|
|
3 * Copyright (C) Igor Sysoev
|
|
|
4 */
|
|
|
5
|
|
|
6
|
|
|
7 #include <ngx_config.h>
|
|
|
8 #include <ngx_core.h>
|
|
|
9 #include <ngx_garbage_collector.h>
|
|
|
10
|
|
|
11
|
|
|
12
|
|
48
|
13 ngx_int_t ngx_collect_garbage(ngx_gc_t *ctx, ngx_str_t *dname, ngx_int_t level)
|
|
0
|
14 {
|
|
|
15 int rc;
|
|
|
16 u_char *last;
|
|
|
17 size_t len;
|
|
|
18 ngx_err_t err;
|
|
|
19 ngx_str_t fname, buf;
|
|
|
20 ngx_dir_t dir;
|
|
|
21
|
|
|
22 buf.len = 0;
|
|
|
23 #if (NGX_SUPPRESS_WARN)
|
|
|
24 buf.data = NULL;
|
|
|
25 fname.data = NULL;
|
|
|
26 #endif
|
|
|
27
|
|
|
28 ngx_log_debug2(NGX_LOG_DEBUG_CORE, ctx->log, 0,
|
|
|
29 "gc dir \"%s\":%d", dname->data, dname->len);
|
|
|
30
|
|
|
31 if (ngx_open_dir(dname, &dir) == NGX_ERROR) {
|
|
|
32 ngx_log_error(NGX_LOG_CRIT, ctx->log, ngx_errno,
|
|
|
33 ngx_open_dir_n " \"%s\" failed", dname->data);
|
|
|
34 return NGX_ERROR;
|
|
|
35 }
|
|
|
36
|
|
|
37 for ( ;; ) {
|
|
|
38 ngx_set_errno(0);
|
|
|
39 if (ngx_read_dir(&dir) == NGX_ERROR) {
|
|
|
40 err = ngx_errno;
|
|
|
41
|
|
|
42 if (err != NGX_ENOMOREFILES) {
|
|
|
43 ngx_log_error(NGX_LOG_CRIT, ctx->log, err,
|
|
|
44 ngx_read_dir_n " \"%s\" failed", dname->data);
|
|
|
45 rc = NGX_ERROR;
|
|
|
46
|
|
|
47 } else {
|
|
|
48 rc = NGX_OK;
|
|
|
49 }
|
|
|
50
|
|
|
51 break;
|
|
|
52 }
|
|
|
53
|
|
|
54 len = ngx_de_namelen(&dir);
|
|
|
55
|
|
|
56 ngx_log_debug2(NGX_LOG_DEBUG_CORE, ctx->log, 0,
|
|
|
57 "gc name \"%s\":%d", ngx_de_name(&dir), len);
|
|
|
58
|
|
|
59 if (len == 1 && ngx_de_name(&dir)[0] == '.') {
|
|
|
60 continue;
|
|
|
61 }
|
|
|
62
|
|
|
63 if (len == 2
|
|
|
64 && ngx_de_name(&dir)[0] == '.'
|
|
|
65 && ngx_de_name(&dir)[1] == '.')
|
|
|
66 {
|
|
|
67 continue;
|
|
|
68 }
|
|
|
69
|
|
|
70 fname.len = dname->len + 1+ len;
|
|
|
71
|
|
|
72 if (fname.len + NGX_DIR_MASK_LEN > buf.len) {
|
|
|
73
|
|
|
74 if (buf.len) {
|
|
|
75 ngx_free(buf.data);
|
|
|
76 }
|
|
|
77
|
|
|
78 buf.len = dname->len + 1 + len + NGX_DIR_MASK_LEN;
|
|
|
79
|
|
50
|
80 buf.data = ngx_alloc(buf.len + 1, ctx->log);
|
|
|
81 if (buf.data == NULL) {
|
|
0
|
82 return NGX_ABORT;
|
|
|
83 }
|
|
|
84 }
|
|
|
85
|
|
|
86 last = ngx_cpymem(buf.data, dname->data, dname->len);
|
|
|
87 *last++ = '/';
|
|
|
88 ngx_memcpy(last, ngx_de_name(&dir), len + 1);
|
|
|
89 fname.data = buf.data;
|
|
|
90
|
|
|
91 ngx_log_debug1(NGX_LOG_DEBUG_CORE, ctx->log, 0,
|
|
|
92 "gc path: \"%s\"", fname.data);
|
|
|
93
|
|
6
|
94 if (!dir.valid_info) {
|
|
0
|
95 if (ngx_de_info(fname.data, &dir) == NGX_FILE_ERROR) {
|
|
|
96 ngx_log_error(NGX_LOG_CRIT, ctx->log, ngx_errno,
|
|
|
97 ngx_de_info_n " \"%s\" failed", fname.data);
|
|
|
98 continue;
|
|
|
99 }
|
|
|
100 }
|
|
|
101
|
|
|
102 if (ngx_de_is_dir(&dir)) {
|
|
|
103
|
|
|
104 ngx_log_debug1(NGX_LOG_DEBUG_CORE, ctx->log, 0,
|
|
|
105 "gc enter dir \"%s\"", fname.data);
|
|
|
106
|
|
|
107 if (level == -1
|
|
|
108 /* there can not be directory on the last level */
|
|
|
109 || level == NGX_MAX_PATH_LEVEL
|
|
|
110 /* an directory from the old path hierarchy */
|
|
|
111 || len != ctx->path->level[level])
|
|
|
112 {
|
|
|
113 if (ngx_collect_garbage(ctx, &fname, -1) == NGX_ABORT) {
|
|
|
114 return NGX_ABORT;
|
|
|
115 }
|
|
|
116
|
|
|
117 fname.data[fname.len] = '\0';
|
|
|
118
|
|
|
119 ngx_log_error(NGX_LOG_NOTICE, ctx->log, 0,
|
|
|
120 "delete old hierachy directory \"%s\"",
|
|
|
121 fname.data);
|
|
|
122
|
|
|
123 if (ngx_delete_dir(fname.data) == NGX_FILE_ERROR) {
|
|
|
124 ngx_log_error(NGX_LOG_CRIT, ctx->log, ngx_errno,
|
|
|
125 ngx_delete_dir_n " \"%s\" failed",
|
|
|
126 fname.data);
|
|
|
127 } else {
|
|
|
128 ctx->deleted++;
|
|
|
129 ctx->freed += ngx_de_size(&dir);
|
|
|
130 }
|
|
|
131
|
|
|
132 continue;
|
|
|
133 }
|
|
|
134
|
|
|
135 if (ngx_collect_garbage(ctx, &fname, level + 1) == NGX_ABORT) {
|
|
|
136 return NGX_ABORT;
|
|
|
137 }
|
|
|
138
|
|
|
139 } else if (ngx_de_is_file(&dir)) {
|
|
|
140
|
|
|
141 ngx_log_debug1(NGX_LOG_DEBUG_CORE, ctx->log, 0,
|
|
|
142 "gc file \"%s\"", fname.data);
|
|
|
143
|
|
|
144 if (level == -1
|
|
|
145 || (level < NGX_MAX_PATH_LEVEL && ctx->path->level[level] != 0))
|
|
|
146 {
|
|
|
147 if (ngx_delete_file(fname.data) == NGX_FILE_ERROR) {
|
|
|
148 ngx_log_error(NGX_LOG_CRIT, ctx->log, ngx_errno,
|
|
|
149 ngx_delete_file_n " \"%s\" failed",
|
|
|
150 fname.data);
|
|
|
151 } else {
|
|
|
152 ctx->deleted++;
|
|
|
153 ctx->freed += ngx_de_size(&dir);
|
|
|
154 }
|
|
|
155
|
|
|
156 continue;
|
|
|
157 }
|
|
|
158
|
|
|
159 if (ctx->handler(ctx, &fname, &dir) == NGX_ABORT) {
|
|
|
160 return NGX_ABORT;
|
|
|
161 }
|
|
|
162
|
|
|
163 } else {
|
|
|
164 ngx_log_error(NGX_LOG_CRIT, ctx->log, ngx_errno,
|
|
16
|
165 "the file \"%s\" has unknown type, deleting",
|
|
|
166 fname.data);
|
|
0
|
167
|
|
|
168 if (ngx_delete_file(fname.data) == NGX_FILE_ERROR) {
|
|
|
169 ngx_log_error(NGX_LOG_CRIT, ctx->log, ngx_errno,
|
|
|
170 ngx_delete_file_n " \"%s\" failed", fname.data);
|
|
|
171 } else {
|
|
|
172 ctx->deleted++;
|
|
|
173 ctx->freed += ngx_de_size(&dir);
|
|
|
174 }
|
|
|
175 }
|
|
|
176 }
|
|
|
177
|
|
|
178 if (buf.len) {
|
|
|
179 ngx_free(buf.data);
|
|
|
180 }
|
|
|
181
|
|
|
182 if (ngx_close_dir(&dir) == NGX_ERROR) {
|
|
|
183 ngx_log_error(NGX_LOG_CRIT, ctx->log, ngx_errno,
|
|
|
184 ngx_close_dir_n " \"%s\" failed", fname.data);
|
|
|
185 }
|
|
|
186
|
|
|
187 return rc;
|
|
|
188 }
|
|
|
189
|
|
|
190
|
|
16
|
191 ngx_int_t ngx_garbage_collector_temp_handler(ngx_gc_t *ctx, ngx_str_t *name,
|
|
|
192 ngx_dir_t *dir)
|
|
0
|
193 {
|
|
|
194 /*
|
|
|
195 * We use mtime only and do not use atime because:
|
|
|
196 * on NTFS access time has a resolution of 1 hour,
|
|
|
197 * on NT FAT access time has a resolution of 1 day,
|
|
|
198 * Unices have the mount option "noatime".
|
|
|
199 */
|
|
|
200
|
|
|
201 if (ngx_time() - ngx_de_mtime(dir) < 3600) {
|
|
|
202 return NGX_OK;
|
|
|
203 }
|
|
|
204
|
|
|
205 ngx_log_error(NGX_LOG_NOTICE, ctx->log, 0,
|
|
16
|
206 "delete the stale temporary file \"%s\"", name->data);
|
|
0
|
207
|
|
|
208 if (ngx_delete_file(name->data) == NGX_FILE_ERROR) {
|
|
|
209 ngx_log_error(NGX_LOG_CRIT, ctx->log, ngx_errno,
|
|
|
210 ngx_delete_file_n " \"%s\" failed", name->data);
|
|
|
211 return NGX_ERROR;
|
|
|
212 }
|
|
|
213
|
|
|
214 ctx->deleted++;
|
|
|
215 ctx->freed += ngx_de_size(dir);
|
|
|
216
|
|
|
217 return NGX_OK;
|
|
|
218 }
|
