« back to all changes in this revision
Viewing changes to src/core/ngx_garbage_collector.c
- browse files at revision 15
- compare with another revision
- download diff
- download tarball
- view history from revision 15
- Committer: Peter Wolanin
- Date: 2009-09-16 03:11:54 UTC
- Revision ID: pwolanin@heron-20090916031154-0felupj7oq4ubnnw
* Remove src files left over from 0.6
* minor customization to rules and conf
* minor customization to rules and conf
- files removed:
- auto/lib/pcre/patch.config.in
- files modified:
- debian/conf/nginx.conf
added
removed
src/core/ngx_garbage_collector.c
1
2
/*
3
* Copyright (C) Igor Sysoev
4
*/
5
6
7
#include <ngx_config.h>
8
#include <ngx_core.h>
9
10
11
12
ngx_int_t ngx_collect_garbage(ngx_gc_t *ctx, ngx_str_t *dname, ngx_int_t level)
13
{
14
int rc;
15
u_char *last;
16
size_t len;
17
ngx_err_t err;
18
ngx_str_t fname, buf;
19
ngx_dir_t dir;
20
21
buf.len = 0;
22
#if (NGX_SUPPRESS_WARN)
23
buf.data = NULL;
24
fname.data = NULL;
25
#endif
26
27
ngx_log_debug2(NGX_LOG_DEBUG_CORE, ctx->log, 0,
28
"gc dir \"%s\":%d", dname->data, dname->len);
29
30
if (ngx_open_dir(dname, &dir) == NGX_ERROR) {
31
ngx_log_error(NGX_LOG_CRIT, ctx->log, ngx_errno,
32
ngx_open_dir_n " \"%s\" failed", dname->data);
33
return NGX_ERROR;
34
}
35
36
for ( ;; ) {
37
ngx_set_errno(0);
38
if (ngx_read_dir(&dir) == NGX_ERROR) {
39
err = ngx_errno;
40
41
if (err != NGX_ENOMOREFILES) {
42
ngx_log_error(NGX_LOG_CRIT, ctx->log, err,
43
ngx_read_dir_n " \"%s\" failed", dname->data);
44
rc = NGX_ERROR;
45
46
} else {
47
rc = NGX_OK;
48
}
49
50
break;
51
}
52
53
len = ngx_de_namelen(&dir);
54
55
ngx_log_debug2(NGX_LOG_DEBUG_CORE, ctx->log, 0,
56
"gc name \"%s\":%d", ngx_de_name(&dir), len);
57
58
if (len == 1 && ngx_de_name(&dir)[0] == '.') {
59
continue;
60
}
61
62
if (len == 2
63
&& ngx_de_name(&dir)[0] == '.'
64
&& ngx_de_name(&dir)[1] == '.')
65
{
66
continue;
67
}
68
69
fname.len = dname->len + 1+ len;
70
71
if (fname.len + NGX_DIR_MASK_LEN > buf.len) {
72
73
if (buf.len) {
74
ngx_free(buf.data);
75
}
76
77
buf.len = dname->len + 1 + len + NGX_DIR_MASK_LEN;
78
79
buf.data = ngx_alloc(buf.len + 1, ctx->log);
80
if (buf.data == NULL) {
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
93
if (!dir.valid_info) {
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,
164
"the file \"%s\" has unknown type, deleting",
165
fname.data);
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
190
ngx_int_t ngx_garbage_collector_temp_handler(ngx_gc_t *ctx, ngx_str_t *name,
191
ngx_dir_t *dir)
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,
205
"delete the stale temporary file \"%s\"", name->data);
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
}
Loggerhead is a web-based interface for Breezy
Version: 2.0.1