Mercurial > hg > nginx-vendor-current

comparison src/os/unix/ngx_files.c @ 0:f0b350454894 NGINX_0_1_0

Find changesets by keywords (author, files, the commit message), revision number or hash, or revset expression.
nginx 0.1.0 *) The first public version.
author Igor Sysoev <http://sysoev.ru>
date Mon, 04 Oct 2004 00:00:00 +0400
parents
children 4b2dafa26fe2
comparison
equal deleted inserted replaced
-1:000000000000 0:f0b350454894
1
2 /*
3 * Copyright (C) Igor Sysoev
4 */
5
6
7 #include <ngx_config.h>
8 #include <ngx_core.h>
9
10
11 ssize_t ngx_read_file(ngx_file_t *file, u_char *buf, size_t size, off_t offset)
12 {
13 ssize_t n;
14
15 ngx_log_debug4(NGX_LOG_DEBUG_CORE, file->log, 0,
16 "read: %d, %X, %d, " OFF_T_FMT, file->fd, buf, size, offset);
17
18 #if (HAVE_PREAD)
19
20 n = pread(file->fd, buf, size, offset);
21
22 if (n == -1) {
23 ngx_log_error(NGX_LOG_CRIT, file->log, ngx_errno,
24 "pread() failed, file \"%s\"", file->name.data);
25 return NGX_ERROR;
26 }
27
28 #else
29
30 if (file->sys_offset != offset) {
31 if (lseek(file->fd, offset, SEEK_SET) == -1) {
32 ngx_log_error(NGX_LOG_CRIT, file->log, ngx_errno, "lseek() failed");
33 return NGX_ERROR;
34 }
35
36 file->sys_offset = offset;
37 }
38
39 n = read(file->fd, buf, size);
40
41 if (n == -1) {
42 ngx_log_error(NGX_LOG_CRIT, file->log, ngx_errno, "read() failed");
43 return NGX_ERROR;
44 }
45
46 file->sys_offset += n;
47
48 #endif
49
50 file->offset += n;
51
52 return n;
53 }
54
55
56 ssize_t ngx_write_file(ngx_file_t *file, u_char *buf, size_t size, off_t offset)
57 {
58 ssize_t n;
59
60 #if (HAVE_PWRITE)
61
62 n = pwrite(file->fd, buf, size, offset);
63
64 if (n == -1) {
65 ngx_log_error(NGX_LOG_CRIT, file->log, ngx_errno, "pwrite() failed");
66 return NGX_ERROR;
67 }
68
69 if ((size_t) n != size) {
70 ngx_log_error(NGX_LOG_CRIT, file->log, 0,
71 "pwrite() has written only %d of %d", n, size);
72 return NGX_ERROR;
73 }
74
75 #else
76
77 if (file->sys_offset != offset) {
78 if (lseek(file->fd, offset, SEEK_SET) == -1) {
79 ngx_log_error(NGX_LOG_CRIT, file->log, ngx_errno, "lseek() failed");
80 return NGX_ERROR;
81 }
82
83 file->sys_offset = offset;
84 }
85
86 n = write(file->fd, buf, size);
87
88 if (n == -1) {
89 ngx_log_error(NGX_LOG_CRIT, file->log, ngx_errno, "write() failed");
90 return NGX_ERROR;
91 }
92
93 if ((size_t) n != size) {
94 ngx_log_error(NGX_LOG_CRIT, file->log, 0,
95 "write() has written only %d of %d", n, size);
96 return NGX_ERROR;
97 }
98
99 file->sys_offset += n;
100
101 #endif
102
103 file->offset += n;
104
105 return n;
106 }
107
108
109 int ngx_open_tempfile(u_char *name, ngx_uint_t persistent)
110 {
111 ngx_fd_t fd;
112
113 fd = open((const char *) name, O_CREAT|O_EXCL|O_RDWR, 0600);
114
115 if (fd != -1 && !persistent) {
116 unlink((const char *) name);
117 }
118
119 return fd;
120 }
121
122
123 ssize_t ngx_write_chain_to_file(ngx_file_t *file, ngx_chain_t *cl,
124 off_t offset, ngx_pool_t *pool)
125 {
126 u_char *prev;
127 size_t size;
128 ssize_t n;
129 struct iovec *iov;
130 ngx_err_t err;
131 ngx_array_t io;
132
133 /* use pwrite() if there's the only buf in a chain */
134
135 if (cl->next == NULL) {
136 return ngx_write_file(file, cl->buf->pos,
137 (size_t) (cl->buf->last - cl->buf->pos),
138 offset);
139 }
140
141 prev = NULL;
142 iov = NULL;
143 size = 0;
144
145 ngx_init_array(io, pool, 10, sizeof(struct iovec), NGX_ERROR);
146
147 /* create the iovec and coalesce the neighbouring bufs */
148
149 while (cl) {
150 if (prev == cl->buf->pos) {
151 iov->iov_len += cl->buf->last - cl->buf->pos;
152
153 } else {
154 ngx_test_null(iov, ngx_push_array(&io), NGX_ERROR);
155 iov->iov_base = (void *) cl->buf->pos;
156 iov->iov_len = cl->buf->last - cl->buf->pos;
157 }
158
159 size += cl->buf->last - cl->buf->pos;
160 prev = cl->buf->last;
161 cl = cl->next;
162 }
163
164 /* use pwrite() if there's the only iovec buffer */
165
166 if (io.nelts == 1) {
167 iov = io.elts;
168 return ngx_write_file(file, (u_char *) iov[0].iov_base, iov[0].iov_len,
169 offset);
170 }
171
172 if (file->sys_offset != offset) {
173 if (lseek(file->fd, offset, SEEK_SET) == -1) {
174 ngx_log_error(NGX_LOG_CRIT, file->log, ngx_errno, "lseek() failed");
175 return NGX_ERROR;
176 }
177
178 file->sys_offset = offset;
179 }
180
181 n = writev(file->fd, io.elts, io.nelts);
182
183 if (n == -1) {
184 ngx_log_error(NGX_LOG_CRIT, file->log, ngx_errno, "writev() failed");
185 return NGX_ERROR;
186 }
187
188 if ((size_t) n != size) {
189 ngx_log_error(NGX_LOG_CRIT, file->log, 0,
190 "writev() has written only %d of %d", n, size);
191 return NGX_ERROR;
192 }
193
194 file->sys_offset += n;
195 file->offset += n;
196
197 return n;
198 }
199
200
201 int ngx_open_dir(ngx_str_t *name, ngx_dir_t *dir)
202 {
203 dir->dir = opendir((const char *) name->data);
204
205 if (dir->dir == NULL) {
206 return NGX_ERROR;
207 }
208
209 dir->info_valid = 0;
210
211 return NGX_OK;
212 }
213
214
215 #if 0
216
217 ssize_t ngx_read_file(ngx_file_t *file, char *buf, size_t size, off_t offset)
218 {
219 if (!file->read->ready) {
220
221 ngx_memzero(&file->iocb, sizeof(iocb));
222 file->iocb.aio_fildes = file->fd;
223 file->iocb.aio_buf = buf;
224 file->iocb.aio_nbytes = size;
225 file->iocb.aio_offset = offset;
226 #if (USE_AIO_KQUEUE)
227 file->iocb.aio_sigevent.sigev_notify = SIGEV_KEVENT;
228 file->iocb.aio_sigevent.sigev_notify_kqueue = tid->kq;
229 file->iocb.aio_sigevent.sigev_value = (union sigval) file;
230 #endif
231 #if (USE_AIO_SIGNAL)
232 file->iocb.aio_sigevent.sigev_notify = SIGEV_SIGNAL;
233 file->iocb.aio_sigevent.sigev_signo = NGX_SIGAIO;
234 #ifndef __FreeBSD__
235 file->iocb.aio_sigevent.sigev_value.sival_ptr = file;
236 #endif
237 #endif
238
239 if (aio_read(&file->iocb) == -1) {
240 ngx_log_error(NGX_LOG_ERR, file->log, ngx_errno,
241 "aio_read() failed");
242 return NGX_ERROR;
243
244 n = aio_error(&file->iocb);
245 if (n == EINPROGRESS)
246 return NGX_AGAIN;
247
248 if (n == -1) {
249 ngx_log_error(NGX_LOG_ERR, file->log, ngx_errno,
250 "aio_read() failed");
251 return NGX_ERROR;
252 }
253 }
254
255 ngx_assert(file->iocb.aio_buf == buf), return NGX_ERROR,
256 "ngx_aio_read_file: another buffer is passed");
257
258 n = aio_return(&file->iocb);
259 if (n == -1) {
260 ngx_log_error(NGX_LOG_ERR, file->log, ngx_errno,
261 "aio_read() failed");
262 return NGX_ERROR;
263 }
264
265 return n;
266 }
267
268 #endif