|
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
|
|
|
80 if (!(buf.data = ngx_alloc(buf.len + 1, ctx->log))) {
|
|
|
81 return NGX_ABORT;
|
|
|
82 }
|
|
|
83 }
|
|
|
84
|
|
|
85 last = ngx_cpymem(buf.data, dname->data, dname->len);
|
|
|
86 *last++ = '/';
|
|
|
87 ngx_memcpy(last, ngx_de_name(&dir), len + 1);
|
|
|
88 fname.data = buf.data;
|
|
|
89
|
|
|
90 ngx_log_debug1(NGX_LOG_DEBUG_CORE, ctx->log, 0,
|
|
|
91 "gc path: \"%s\"", fname.data);
|
|
|
92
|
|
6
|
93 if (!dir.valid_info) {
|
|
0
|
94 if (ngx_de_info(fname.data, &dir) == NGX_FILE_ERROR) {
|
|
|
95 ngx_log_error(NGX_LOG_CRIT, ctx->log, ngx_errno,
|
|
|
96 ngx_de_info_n " \"%s\" failed", fname.data);
|
|
|
97 continue;
|
|
|
98 }
|
|
|
99 }
|
|
|
100
|
|
|
101 if (ngx_de_is_dir(&dir)) {
|
|
|
102
|
|
|
103 ngx_log_debug1(NGX_LOG_DEBUG_CORE, ctx->log, 0,
|
|
|
104 "gc enter dir \"%s\"", fname.data);
|
|
|
105
|
|
|
106 if (level == -1
|
|
|
107 /* there can not be directory on the last level */
|
|
|
108 || level == NGX_MAX_PATH_LEVEL
|
|
|
109 /* an directory from the old path hierarchy */
|
|
|
110 || len != ctx->path->level[level])
|
|
|
111 {
|
|
|
112 if (ngx_collect_garbage(ctx, &fname, -1) == NGX_ABORT) {
|
|
|
113 return NGX_ABORT;
|
|
|
114 }
|
|
|
115
|
|
|
116 fname.data[fname.len] = '\0';
|
|
|
117
|
|
|
118 ngx_log_error(NGX_LOG_NOTICE, ctx->log, 0,
|
|
|
119 "delete old hierachy directory \"%s\"",
|
|
|
120 fname.data);
|
|
|
121
|
|
|
122 if (ngx_delete_dir(fname.data) == NGX_FILE_ERROR) {
|
|
|
123 ngx_log_error(NGX_LOG_CRIT, ctx->log, ngx_errno,
|
|
|
124 ngx_delete_dir_n " \"%s\" failed",
|
|
|
125 fname.data);
|
|
|
126 } else {
|
|
|
127 ctx->deleted++;
|
|
|
128 ctx->freed += ngx_de_size(&dir);
|
|
|
129 }
|
|
|
130
|
|
|
131 continue;
|
|
|
132 }
|
|
|
133
|
|
|
134 if (ngx_collect_garbage(ctx, &fname, level + 1) == NGX_ABORT) {
|
|
|
135 return NGX_ABORT;
|
|
|
136 }
|
|
|
137
|
|
|
138 } else if (ngx_de_is_file(&dir)) {
|
|
|
139
|
|
|
140 ngx_log_debug1(NGX_LOG_DEBUG_CORE, ctx->log, 0,
|
|
|
141 "gc file \"%s\"", fname.data);
|
|
|
142
|
|
|
143 if (level == -1
|
|
|
144 || (level < NGX_MAX_PATH_LEVEL && ctx->path->level[level] != 0))
|
|
|
145 {
|
|
|
146 if (ngx_delete_file(fname.data) == NGX_FILE_ERROR) {
|
|
|
147 ngx_log_error(NGX_LOG_CRIT, ctx->log, ngx_errno,
|
|
|
148 ngx_delete_file_n " \"%s\" failed",
|
|
|
149 fname.data);
|
|
|
150 } else {
|
|
|
151 ctx->deleted++;
|
|
|
152 ctx->freed += ngx_de_size(&dir);
|
|
|
153 }
|
|
|
154
|
|
|
155 continue;
|
|
|
156 }
|
|
|
157
|
|
|
158 if (ctx->handler(ctx, &fname, &dir) == NGX_ABORT) {
|
|
|
159 return NGX_ABORT;
|
|
|
160 }
|
|
|
161
|
|
|
162 } else {
|
|
|
163 ngx_log_error(NGX_LOG_CRIT, ctx->log, ngx_errno,
|
|
16
|
164 "the file \"%s\" has unknown type, deleting",
|
|
|
165 fname.data);
|
|
0
|
166
|
|
|
167 if (ngx_delete_file(fname.data) == NGX_FILE_ERROR) {
|
|
|
168 ngx_log_error(NGX_LOG_CRIT, ctx->log, ngx_errno,
|
|
|
169 ngx_delete_file_n " \"%s\" failed", fname.data);
|
|
|
170 } else {
|
|
|
171 ctx->deleted++;
|
|
|
172 ctx->freed += ngx_de_size(&dir);
|
|
|
173 }
|
|
|
174 }
|
|
|
175 }
|
|
|
176
|
|
|
177 if (buf.len) {
|
|
|
178 ngx_free(buf.data);
|
|
|
179 }
|
|
|
180
|
|
|
181 if (ngx_close_dir(&dir) == NGX_ERROR) {
|
|
|
182 ngx_log_error(NGX_LOG_CRIT, ctx->log, ngx_errno,
|
|
|
183 ngx_close_dir_n " \"%s\" failed", fname.data);
|
|
|
184 }
|
|
|
185
|
|
|
186 return rc;
|
|
|
187 }
|
|
|
188
|
|
|
189
|
|
16
|
190 ngx_int_t ngx_garbage_collector_temp_handler(ngx_gc_t *ctx, ngx_str_t *name,
|
|
|
191 ngx_dir_t *dir)
|
|
0
|
192 {
|
|
|
193 /*
|
|
|
194 * We use mtime only and do not use atime because:
|
|
|
195 * on NTFS access time has a resolution of 1 hour,
|
|
|
196 * on NT FAT access time has a resolution of 1 day,
|
|
|
197 * Unices have the mount option "noatime".
|
|
|
198 */
|
|
|
199
|
|
|
200 if (ngx_time() - ngx_de_mtime(dir) < 3600) {
|
|
|
201 return NGX_OK;
|
|
|
202 }
|
|
|
203
|
|
|
204 ngx_log_error(NGX_LOG_NOTICE, ctx->log, 0,
|
|
16
|
205 "delete the stale temporary file \"%s\"", name->data);
|
|
0
|
206
|
|
|
207 if (ngx_delete_file(name->data) == NGX_FILE_ERROR) {
|
|
|
208 ngx_log_error(NGX_LOG_CRIT, ctx->log, ngx_errno,
|
|
|
209 ngx_delete_file_n " \"%s\" failed", name->data);
|
|
|
210 return NGX_ERROR;
|
|
|
211 }
|
|
|
212
|
|
|
213 ctx->deleted++;
|
|
|
214 ctx->freed += ngx_de_size(dir);
|
|
|
215
|
|
|
216 return NGX_OK;
|
|
|
217 }
|
