nginx: src/os/unix/ngx_files.c annotate

annotate src/os/unix/ngx_files.c @ 9266:93bbb9fbf30d default tip

Fixed compilation on NetBSD 10. NetBSD 10 changed struct kevent's udata type from "intptr_t" to "void *", similarly to how it is defined on other systems. This breaks compilation, since intptr_t is assumed on NetBSD. Fix is to limit special intptr_t handling to NetBSD versions before 10.0. To simplify testing, relevant definitions are moved from configure to code (which seems to be the right thing anyway).

author	Maxim Dounin <mdounin@mdounin.ru>
date	Mon, 06 May 2024 00:07:33 +0300
parents	e88cdaa0f1ff
children

rev	line source
441 da8c5707af39 nginx-0.1.0-2004-09-28-12:34:51 import; set copyright and remove unused files Igor Sysoev <igor@sysoev.ru> parents: 344 diff changeset	1
da8c5707af39 nginx-0.1.0-2004-09-28-12:34:51 import; set copyright and remove unused files Igor Sysoev <igor@sysoev.ru> parents: 344 diff changeset	2 /*
444 42d11f017717 nginx-0.1.0-2004-09-29-20:00:49 import; remove years from copyright Igor Sysoev <igor@sysoev.ru> parents: 441 diff changeset	3 * Copyright (C) Igor Sysoev
4412 d620f497c50f Copyright updated. Maxim Konovalov <maxim@nginx.com> parents: 4299 diff changeset	4 * Copyright (C) Nginx, Inc.
441 da8c5707af39 nginx-0.1.0-2004-09-28-12:34:51 import; set copyright and remove unused files Igor Sysoev <igor@sysoev.ru> parents: 344 diff changeset	5 */
da8c5707af39 nginx-0.1.0-2004-09-28-12:34:51 import; set copyright and remove unused files Igor Sysoev <igor@sysoev.ru> parents: 344 diff changeset	6
5 62b1a364857c nginx-0.0.1-2002-08-23-20:14:30 import Igor Sysoev <igor@sysoev.ru> parents: diff changeset	7
33 b2e039840718 nginx-0.0.1-2002-12-19-20:49:51 import Igor Sysoev <igor@sysoev.ru> parents: 9 diff changeset	8 #include <ngx_config.h>
8 708f8bb772ec nginx-0.0.1-2002-09-02-18:48:24 import Igor Sysoev <igor@sysoev.ru> parents: 6 diff changeset	9 #include <ngx_core.h>
74 17ab1af8c3dd nginx-0.0.1-2003-04-11-20:01:14 import Igor Sysoev <igor@sysoev.ru> parents: 73 diff changeset	10
8 708f8bb772ec nginx-0.0.1-2002-09-02-18:48:24 import Igor Sysoev <igor@sysoev.ru> parents: 6 diff changeset	11
6022 1fdba317ee6d Added support for offloading read() in thread pools. Valentin Bartenev <vbart@nginx.com> parents: 4943 diff changeset	12 #if (NGX_THREADS)
1fdba317ee6d Added support for offloading read() in thread pools. Valentin Bartenev <vbart@nginx.com> parents: 4943 diff changeset	13 #include <ngx_thread_pool.h>
1fdba317ee6d Added support for offloading read() in thread pools. Valentin Bartenev <vbart@nginx.com> parents: 4943 diff changeset	14 static void ngx_thread_read_handler(void data, ngx_log_t log);
6442 6e10518f95d8 Threads: offloading of temp files writing to thread pools. Maxim Dounin <mdounin@mdounin.ru> parents: 6441 diff changeset	15 static void ngx_thread_write_chain_to_file_handler(void data, ngx_log_t log);
6022 1fdba317ee6d Added support for offloading read() in thread pools. Valentin Bartenev <vbart@nginx.com> parents: 4943 diff changeset	16 #endif
1fdba317ee6d Added support for offloading read() in thread pools. Valentin Bartenev <vbart@nginx.com> parents: 4943 diff changeset	17
6421 3832b608dc8d Introduced the ngx_chain_to_iovec() function. Valentin Bartenev <vbart@nginx.com> parents: 6301 diff changeset	18 static ngx_chain_t ngx_chain_to_iovec(ngx_iovec_t vec, ngx_chain_t *cl);
3832b608dc8d Introduced the ngx_chain_to_iovec() function. Valentin Bartenev <vbart@nginx.com> parents: 6301 diff changeset	19 static ssize_t ngx_writev_file(ngx_file_t file, ngx_iovec_t vec,
6300 be6af0906a4d Moved file writev() handling code to a separate function. Valentin Bartenev <vbart@nginx.com> parents: 6299 diff changeset	20 off_t offset);
be6af0906a4d Moved file writev() handling code to a separate function. Valentin Bartenev <vbart@nginx.com> parents: 6299 diff changeset	21
6022 1fdba317ee6d Added support for offloading read() in thread pools. Valentin Bartenev <vbart@nginx.com> parents: 4943 diff changeset	22
3294 04cfc09b8b8d export aio presence knowledge to prevent using "aio sendfile", Igor Sysoev <igor@sysoev.ru> parents: 3200 diff changeset	23 #if (NGX_HAVE_FILE_AIO)
04cfc09b8b8d export aio presence knowledge to prevent using "aio sendfile", Igor Sysoev <igor@sysoev.ru> parents: 3200 diff changeset	24
04cfc09b8b8d export aio presence knowledge to prevent using "aio sendfile", Igor Sysoev <igor@sysoev.ru> parents: 3200 diff changeset	25 ngx_uint_t ngx_file_aio = 1;
04cfc09b8b8d export aio presence knowledge to prevent using "aio sendfile", Igor Sysoev <igor@sysoev.ru> parents: 3200 diff changeset	26
04cfc09b8b8d export aio presence knowledge to prevent using "aio sendfile", Igor Sysoev <igor@sysoev.ru> parents: 3200 diff changeset	27 #endif
04cfc09b8b8d export aio presence knowledge to prevent using "aio sendfile", Igor Sysoev <igor@sysoev.ru> parents: 3200 diff changeset	28
04cfc09b8b8d export aio presence knowledge to prevent using "aio sendfile", Igor Sysoev <igor@sysoev.ru> parents: 3200 diff changeset	29
561 e48ebafc6939 nginx-0.3.2-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 501 diff changeset	30 ssize_t
e48ebafc6939 nginx-0.3.2-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 501 diff changeset	31 ngx_read_file(ngx_file_t file, u_char buf, size_t size, off_t offset)
8 708f8bb772ec nginx-0.0.1-2002-09-02-18:48:24 import Igor Sysoev <igor@sysoev.ru> parents: 6 diff changeset	32 {
561 e48ebafc6939 nginx-0.3.2-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 501 diff changeset	33 ssize_t n;
5 62b1a364857c nginx-0.0.1-2002-08-23-20:14:30 import Igor Sysoev <igor@sysoev.ru> parents: diff changeset	34
257 70e1c7d2b83d nginx-0.0.2-2004-02-11-20:08:49 import Igor Sysoev <igor@sysoev.ru> parents: 196 diff changeset	35 ngx_log_debug4(NGX_LOG_DEBUG_CORE, file->log, 0,
461 a88a3e4e158f nginx-0.1.5-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 457 diff changeset	36 "read: %d, %p, %uz, %O", file->fd, buf, size, offset);
8 708f8bb772ec nginx-0.0.1-2002-09-02-18:48:24 import Igor Sysoev <igor@sysoev.ru> parents: 6 diff changeset	37
469 2ff194b74f1e nginx-0.1.9-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 467 diff changeset	38 #if (NGX_HAVE_PREAD)
182 3c49eaf3f522 nginx-0.0.1-2003-11-13-09:14:05 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	39
8 708f8bb772ec nginx-0.0.1-2002-09-02-18:48:24 import Igor Sysoev <igor@sysoev.ru> parents: 6 diff changeset	40 n = pread(file->fd, buf, size, offset);
708f8bb772ec nginx-0.0.1-2002-09-02-18:48:24 import Igor Sysoev <igor@sysoev.ru> parents: 6 diff changeset	41
9 6f58641241bb nginx-0.0.1-2002-09-07-14:14:25 import Igor Sysoev <igor@sysoev.ru> parents: 8 diff changeset	42 if (n == -1) {
257 70e1c7d2b83d nginx-0.0.2-2004-02-11-20:08:49 import Igor Sysoev <igor@sysoev.ru> parents: 196 diff changeset	43 ngx_log_error(NGX_LOG_CRIT, file->log, ngx_errno,
3157 a2c1b4f74ea7 log file name for read/write errors Igor Sysoev <igor@sysoev.ru> parents: 2615 diff changeset	44 "pread() \"%s\" failed", file->name.data);
9 6f58641241bb nginx-0.0.1-2002-09-07-14:14:25 import Igor Sysoev <igor@sysoev.ru> parents: 8 diff changeset	45 return NGX_ERROR;
6f58641241bb nginx-0.0.1-2002-09-07-14:14:25 import Igor Sysoev <igor@sysoev.ru> parents: 8 diff changeset	46 }
8 708f8bb772ec nginx-0.0.1-2002-09-02-18:48:24 import Igor Sysoev <igor@sysoev.ru> parents: 6 diff changeset	47
182 3c49eaf3f522 nginx-0.0.1-2003-11-13-09:14:05 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	48 #else
3c49eaf3f522 nginx-0.0.1-2003-11-13-09:14:05 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	49
190 02a715e85df1 nginx-0.0.1-2003-11-19-00:34:08 import Igor Sysoev <igor@sysoev.ru> parents: 186 diff changeset	50 if (file->sys_offset != offset) {
182 3c49eaf3f522 nginx-0.0.1-2003-11-13-09:14:05 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	51 if (lseek(file->fd, offset, SEEK_SET) == -1) {
3157 a2c1b4f74ea7 log file name for read/write errors Igor Sysoev <igor@sysoev.ru> parents: 2615 diff changeset	52 ngx_log_error(NGX_LOG_CRIT, file->log, ngx_errno,
a2c1b4f74ea7 log file name for read/write errors Igor Sysoev <igor@sysoev.ru> parents: 2615 diff changeset	53 "lseek() \"%s\" failed", file->name.data);
182 3c49eaf3f522 nginx-0.0.1-2003-11-13-09:14:05 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	54 return NGX_ERROR;
3c49eaf3f522 nginx-0.0.1-2003-11-13-09:14:05 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	55 }
191 71ce40b3c37b nginx-0.0.1-2003-11-19-19:26:41 import Igor Sysoev <igor@sysoev.ru> parents: 190 diff changeset	56
71ce40b3c37b nginx-0.0.1-2003-11-19-19:26:41 import Igor Sysoev <igor@sysoev.ru> parents: 190 diff changeset	57 file->sys_offset = offset;
182 3c49eaf3f522 nginx-0.0.1-2003-11-13-09:14:05 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	58 }
3c49eaf3f522 nginx-0.0.1-2003-11-13-09:14:05 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	59
3c49eaf3f522 nginx-0.0.1-2003-11-13-09:14:05 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	60 n = read(file->fd, buf, size);
3c49eaf3f522 nginx-0.0.1-2003-11-13-09:14:05 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	61
3c49eaf3f522 nginx-0.0.1-2003-11-13-09:14:05 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	62 if (n == -1) {
3157 a2c1b4f74ea7 log file name for read/write errors Igor Sysoev <igor@sysoev.ru> parents: 2615 diff changeset	63 ngx_log_error(NGX_LOG_CRIT, file->log, ngx_errno,
a2c1b4f74ea7 log file name for read/write errors Igor Sysoev <igor@sysoev.ru> parents: 2615 diff changeset	64 "read() \"%s\" failed", file->name.data);
182 3c49eaf3f522 nginx-0.0.1-2003-11-13-09:14:05 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	65 return NGX_ERROR;
3c49eaf3f522 nginx-0.0.1-2003-11-13-09:14:05 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	66 }
3c49eaf3f522 nginx-0.0.1-2003-11-13-09:14:05 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	67
190 02a715e85df1 nginx-0.0.1-2003-11-19-00:34:08 import Igor Sysoev <igor@sysoev.ru> parents: 186 diff changeset	68 file->sys_offset += n;
02a715e85df1 nginx-0.0.1-2003-11-19-00:34:08 import Igor Sysoev <igor@sysoev.ru> parents: 186 diff changeset	69
182 3c49eaf3f522 nginx-0.0.1-2003-11-13-09:14:05 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	70 #endif
3c49eaf3f522 nginx-0.0.1-2003-11-13-09:14:05 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	71
35 79c1fce18e71 nginx-0.0.1-2002-12-21-20:14:50 import Igor Sysoev <igor@sysoev.ru> parents: 33 diff changeset	72 file->offset += n;
79c1fce18e71 nginx-0.0.1-2002-12-21-20:14:50 import Igor Sysoev <igor@sysoev.ru> parents: 33 diff changeset	73
8 708f8bb772ec nginx-0.0.1-2002-09-02-18:48:24 import Igor Sysoev <igor@sysoev.ru> parents: 6 diff changeset	74 return n;
5 62b1a364857c nginx-0.0.1-2002-08-23-20:14:30 import Igor Sysoev <igor@sysoev.ru> parents: diff changeset	75 }
62b1a364857c nginx-0.0.1-2002-08-23-20:14:30 import Igor Sysoev <igor@sysoev.ru> parents: diff changeset	76
73 4534060fde92 nginx-0.0.1-2003-04-10-19:08:54 import Igor Sysoev <igor@sysoev.ru> parents: 35 diff changeset	77
6022 1fdba317ee6d Added support for offloading read() in thread pools. Valentin Bartenev <vbart@nginx.com> parents: 4943 diff changeset	78 #if (NGX_THREADS)
1fdba317ee6d Added support for offloading read() in thread pools. Valentin Bartenev <vbart@nginx.com> parents: 4943 diff changeset	79
1fdba317ee6d Added support for offloading read() in thread pools. Valentin Bartenev <vbart@nginx.com> parents: 4943 diff changeset	80 typedef struct {
6442 6e10518f95d8 Threads: offloading of temp files writing to thread pools. Maxim Dounin <mdounin@mdounin.ru> parents: 6441 diff changeset	81 ngx_fd_t fd;
6e10518f95d8 Threads: offloading of temp files writing to thread pools. Maxim Dounin <mdounin@mdounin.ru> parents: 6441 diff changeset	82 ngx_uint_t write; /* unsigned write:1; */
6022 1fdba317ee6d Added support for offloading read() in thread pools. Valentin Bartenev <vbart@nginx.com> parents: 4943 diff changeset	83
6442 6e10518f95d8 Threads: offloading of temp files writing to thread pools. Maxim Dounin <mdounin@mdounin.ru> parents: 6441 diff changeset	84 u_char *buf;
6e10518f95d8 Threads: offloading of temp files writing to thread pools. Maxim Dounin <mdounin@mdounin.ru> parents: 6441 diff changeset	85 size_t size;
6e10518f95d8 Threads: offloading of temp files writing to thread pools. Maxim Dounin <mdounin@mdounin.ru> parents: 6441 diff changeset	86 ngx_chain_t *chain;
6e10518f95d8 Threads: offloading of temp files writing to thread pools. Maxim Dounin <mdounin@mdounin.ru> parents: 6441 diff changeset	87 off_t offset;
6e10518f95d8 Threads: offloading of temp files writing to thread pools. Maxim Dounin <mdounin@mdounin.ru> parents: 6441 diff changeset	88
6e10518f95d8 Threads: offloading of temp files writing to thread pools. Maxim Dounin <mdounin@mdounin.ru> parents: 6441 diff changeset	89 size_t nbytes;
6e10518f95d8 Threads: offloading of temp files writing to thread pools. Maxim Dounin <mdounin@mdounin.ru> parents: 6441 diff changeset	90 ngx_err_t err;
6e10518f95d8 Threads: offloading of temp files writing to thread pools. Maxim Dounin <mdounin@mdounin.ru> parents: 6441 diff changeset	91 } ngx_thread_file_ctx_t;
6022 1fdba317ee6d Added support for offloading read() in thread pools. Valentin Bartenev <vbart@nginx.com> parents: 4943 diff changeset	92
1fdba317ee6d Added support for offloading read() in thread pools. Valentin Bartenev <vbart@nginx.com> parents: 4943 diff changeset	93
1fdba317ee6d Added support for offloading read() in thread pools. Valentin Bartenev <vbart@nginx.com> parents: 4943 diff changeset	94 ssize_t
6441 9fd738b85fad Threads: task pointer stored in ngx_file_t. Maxim Dounin <mdounin@mdounin.ru> parents: 6421 diff changeset	95 ngx_thread_read(ngx_file_t file, u_char buf, size_t size, off_t offset,
9fd738b85fad Threads: task pointer stored in ngx_file_t. Maxim Dounin <mdounin@mdounin.ru> parents: 6421 diff changeset	96 ngx_pool_t *pool)
6022 1fdba317ee6d Added support for offloading read() in thread pools. Valentin Bartenev <vbart@nginx.com> parents: 4943 diff changeset	97 {
1fdba317ee6d Added support for offloading read() in thread pools. Valentin Bartenev <vbart@nginx.com> parents: 4943 diff changeset	98 ngx_thread_task_t *task;
6442 6e10518f95d8 Threads: offloading of temp files writing to thread pools. Maxim Dounin <mdounin@mdounin.ru> parents: 6441 diff changeset	99 ngx_thread_file_ctx_t *ctx;
6022 1fdba317ee6d Added support for offloading read() in thread pools. Valentin Bartenev <vbart@nginx.com> parents: 4943 diff changeset	100
1fdba317ee6d Added support for offloading read() in thread pools. Valentin Bartenev <vbart@nginx.com> parents: 4943 diff changeset	101 ngx_log_debug4(NGX_LOG_DEBUG_CORE, file->log, 0,
1fdba317ee6d Added support for offloading read() in thread pools. Valentin Bartenev <vbart@nginx.com> parents: 4943 diff changeset	102 "thread read: %d, %p, %uz, %O",
1fdba317ee6d Added support for offloading read() in thread pools. Valentin Bartenev <vbart@nginx.com> parents: 4943 diff changeset	103 file->fd, buf, size, offset);
1fdba317ee6d Added support for offloading read() in thread pools. Valentin Bartenev <vbart@nginx.com> parents: 4943 diff changeset	104
6441 9fd738b85fad Threads: task pointer stored in ngx_file_t. Maxim Dounin <mdounin@mdounin.ru> parents: 6421 diff changeset	105 task = file->thread_task;
6022 1fdba317ee6d Added support for offloading read() in thread pools. Valentin Bartenev <vbart@nginx.com> parents: 4943 diff changeset	106
1fdba317ee6d Added support for offloading read() in thread pools. Valentin Bartenev <vbart@nginx.com> parents: 4943 diff changeset	107 if (task == NULL) {
6442 6e10518f95d8 Threads: offloading of temp files writing to thread pools. Maxim Dounin <mdounin@mdounin.ru> parents: 6441 diff changeset	108 task = ngx_thread_task_alloc(pool, sizeof(ngx_thread_file_ctx_t));
6022 1fdba317ee6d Added support for offloading read() in thread pools. Valentin Bartenev <vbart@nginx.com> parents: 4943 diff changeset	109 if (task == NULL) {
1fdba317ee6d Added support for offloading read() in thread pools. Valentin Bartenev <vbart@nginx.com> parents: 4943 diff changeset	110 return NGX_ERROR;
1fdba317ee6d Added support for offloading read() in thread pools. Valentin Bartenev <vbart@nginx.com> parents: 4943 diff changeset	111 }
1fdba317ee6d Added support for offloading read() in thread pools. Valentin Bartenev <vbart@nginx.com> parents: 4943 diff changeset	112
9202 e88cdaa0f1ff AIO operations now add timers (ticket #2162). Maxim Dounin <mdounin@mdounin.ru> parents: 7670 diff changeset	113 task->event.log = file->log;
e88cdaa0f1ff AIO operations now add timers (ticket #2162). Maxim Dounin <mdounin@mdounin.ru> parents: 7670 diff changeset	114
6441 9fd738b85fad Threads: task pointer stored in ngx_file_t. Maxim Dounin <mdounin@mdounin.ru> parents: 6421 diff changeset	115 file->thread_task = task;
6022 1fdba317ee6d Added support for offloading read() in thread pools. Valentin Bartenev <vbart@nginx.com> parents: 4943 diff changeset	116 }
1fdba317ee6d Added support for offloading read() in thread pools. Valentin Bartenev <vbart@nginx.com> parents: 4943 diff changeset	117
1fdba317ee6d Added support for offloading read() in thread pools. Valentin Bartenev <vbart@nginx.com> parents: 4943 diff changeset	118 ctx = task->ctx;
1fdba317ee6d Added support for offloading read() in thread pools. Valentin Bartenev <vbart@nginx.com> parents: 4943 diff changeset	119
1fdba317ee6d Added support for offloading read() in thread pools. Valentin Bartenev <vbart@nginx.com> parents: 4943 diff changeset	120 if (task->event.complete) {
1fdba317ee6d Added support for offloading read() in thread pools. Valentin Bartenev <vbart@nginx.com> parents: 4943 diff changeset	121 task->event.complete = 0;
1fdba317ee6d Added support for offloading read() in thread pools. Valentin Bartenev <vbart@nginx.com> parents: 4943 diff changeset	122
6442 6e10518f95d8 Threads: offloading of temp files writing to thread pools. Maxim Dounin <mdounin@mdounin.ru> parents: 6441 diff changeset	123 if (ctx->write) {
6e10518f95d8 Threads: offloading of temp files writing to thread pools. Maxim Dounin <mdounin@mdounin.ru> parents: 6441 diff changeset	124 ngx_log_error(NGX_LOG_ALERT, file->log, 0,
6e10518f95d8 Threads: offloading of temp files writing to thread pools. Maxim Dounin <mdounin@mdounin.ru> parents: 6441 diff changeset	125 "invalid thread call, read instead of write");
6e10518f95d8 Threads: offloading of temp files writing to thread pools. Maxim Dounin <mdounin@mdounin.ru> parents: 6441 diff changeset	126 return NGX_ERROR;
6e10518f95d8 Threads: offloading of temp files writing to thread pools. Maxim Dounin <mdounin@mdounin.ru> parents: 6441 diff changeset	127 }
6e10518f95d8 Threads: offloading of temp files writing to thread pools. Maxim Dounin <mdounin@mdounin.ru> parents: 6441 diff changeset	128
6022 1fdba317ee6d Added support for offloading read() in thread pools. Valentin Bartenev <vbart@nginx.com> parents: 4943 diff changeset	129 if (ctx->err) {
1fdba317ee6d Added support for offloading read() in thread pools. Valentin Bartenev <vbart@nginx.com> parents: 4943 diff changeset	130 ngx_log_error(NGX_LOG_CRIT, file->log, ctx->err,
1fdba317ee6d Added support for offloading read() in thread pools. Valentin Bartenev <vbart@nginx.com> parents: 4943 diff changeset	131 "pread() \"%s\" failed", file->name.data);
1fdba317ee6d Added support for offloading read() in thread pools. Valentin Bartenev <vbart@nginx.com> parents: 4943 diff changeset	132 return NGX_ERROR;
1fdba317ee6d Added support for offloading read() in thread pools. Valentin Bartenev <vbart@nginx.com> parents: 4943 diff changeset	133 }
1fdba317ee6d Added support for offloading read() in thread pools. Valentin Bartenev <vbart@nginx.com> parents: 4943 diff changeset	134
6442 6e10518f95d8 Threads: offloading of temp files writing to thread pools. Maxim Dounin <mdounin@mdounin.ru> parents: 6441 diff changeset	135 return ctx->nbytes;
6022 1fdba317ee6d Added support for offloading read() in thread pools. Valentin Bartenev <vbart@nginx.com> parents: 4943 diff changeset	136 }
1fdba317ee6d Added support for offloading read() in thread pools. Valentin Bartenev <vbart@nginx.com> parents: 4943 diff changeset	137
6442 6e10518f95d8 Threads: offloading of temp files writing to thread pools. Maxim Dounin <mdounin@mdounin.ru> parents: 6441 diff changeset	138 task->handler = ngx_thread_read_handler;
6e10518f95d8 Threads: offloading of temp files writing to thread pools. Maxim Dounin <mdounin@mdounin.ru> parents: 6441 diff changeset	139
6e10518f95d8 Threads: offloading of temp files writing to thread pools. Maxim Dounin <mdounin@mdounin.ru> parents: 6441 diff changeset	140 ctx->write = 0;
6e10518f95d8 Threads: offloading of temp files writing to thread pools. Maxim Dounin <mdounin@mdounin.ru> parents: 6441 diff changeset	141
6022 1fdba317ee6d Added support for offloading read() in thread pools. Valentin Bartenev <vbart@nginx.com> parents: 4943 diff changeset	142 ctx->fd = file->fd;
1fdba317ee6d Added support for offloading read() in thread pools. Valentin Bartenev <vbart@nginx.com> parents: 4943 diff changeset	143 ctx->buf = buf;
1fdba317ee6d Added support for offloading read() in thread pools. Valentin Bartenev <vbart@nginx.com> parents: 4943 diff changeset	144 ctx->size = size;
1fdba317ee6d Added support for offloading read() in thread pools. Valentin Bartenev <vbart@nginx.com> parents: 4943 diff changeset	145 ctx->offset = offset;
1fdba317ee6d Added support for offloading read() in thread pools. Valentin Bartenev <vbart@nginx.com> parents: 4943 diff changeset	146
1fdba317ee6d Added support for offloading read() in thread pools. Valentin Bartenev <vbart@nginx.com> parents: 4943 diff changeset	147 if (file->thread_handler(task, file) != NGX_OK) {
1fdba317ee6d Added support for offloading read() in thread pools. Valentin Bartenev <vbart@nginx.com> parents: 4943 diff changeset	148 return NGX_ERROR;
1fdba317ee6d Added support for offloading read() in thread pools. Valentin Bartenev <vbart@nginx.com> parents: 4943 diff changeset	149 }
1fdba317ee6d Added support for offloading read() in thread pools. Valentin Bartenev <vbart@nginx.com> parents: 4943 diff changeset	150
1fdba317ee6d Added support for offloading read() in thread pools. Valentin Bartenev <vbart@nginx.com> parents: 4943 diff changeset	151 return NGX_AGAIN;
1fdba317ee6d Added support for offloading read() in thread pools. Valentin Bartenev <vbart@nginx.com> parents: 4943 diff changeset	152 }
1fdba317ee6d Added support for offloading read() in thread pools. Valentin Bartenev <vbart@nginx.com> parents: 4943 diff changeset	153
1fdba317ee6d Added support for offloading read() in thread pools. Valentin Bartenev <vbart@nginx.com> parents: 4943 diff changeset	154
1fdba317ee6d Added support for offloading read() in thread pools. Valentin Bartenev <vbart@nginx.com> parents: 4943 diff changeset	155 #if (NGX_HAVE_PREAD)
1fdba317ee6d Added support for offloading read() in thread pools. Valentin Bartenev <vbart@nginx.com> parents: 4943 diff changeset	156
1fdba317ee6d Added support for offloading read() in thread pools. Valentin Bartenev <vbart@nginx.com> parents: 4943 diff changeset	157 static void
1fdba317ee6d Added support for offloading read() in thread pools. Valentin Bartenev <vbart@nginx.com> parents: 4943 diff changeset	158 ngx_thread_read_handler(void data, ngx_log_t log)
1fdba317ee6d Added support for offloading read() in thread pools. Valentin Bartenev <vbart@nginx.com> parents: 4943 diff changeset	159 {
6442 6e10518f95d8 Threads: offloading of temp files writing to thread pools. Maxim Dounin <mdounin@mdounin.ru> parents: 6441 diff changeset	160 ngx_thread_file_ctx_t *ctx = data;
6022 1fdba317ee6d Added support for offloading read() in thread pools. Valentin Bartenev <vbart@nginx.com> parents: 4943 diff changeset	161
1fdba317ee6d Added support for offloading read() in thread pools. Valentin Bartenev <vbart@nginx.com> parents: 4943 diff changeset	162 ssize_t n;
1fdba317ee6d Added support for offloading read() in thread pools. Valentin Bartenev <vbart@nginx.com> parents: 4943 diff changeset	163
1fdba317ee6d Added support for offloading read() in thread pools. Valentin Bartenev <vbart@nginx.com> parents: 4943 diff changeset	164 ngx_log_debug0(NGX_LOG_DEBUG_CORE, log, 0, "thread read handler");
1fdba317ee6d Added support for offloading read() in thread pools. Valentin Bartenev <vbart@nginx.com> parents: 4943 diff changeset	165
1fdba317ee6d Added support for offloading read() in thread pools. Valentin Bartenev <vbart@nginx.com> parents: 4943 diff changeset	166 n = pread(ctx->fd, ctx->buf, ctx->size, ctx->offset);
1fdba317ee6d Added support for offloading read() in thread pools. Valentin Bartenev <vbart@nginx.com> parents: 4943 diff changeset	167
1fdba317ee6d Added support for offloading read() in thread pools. Valentin Bartenev <vbart@nginx.com> parents: 4943 diff changeset	168 if (n == -1) {
1fdba317ee6d Added support for offloading read() in thread pools. Valentin Bartenev <vbart@nginx.com> parents: 4943 diff changeset	169 ctx->err = ngx_errno;
1fdba317ee6d Added support for offloading read() in thread pools. Valentin Bartenev <vbart@nginx.com> parents: 4943 diff changeset	170
1fdba317ee6d Added support for offloading read() in thread pools. Valentin Bartenev <vbart@nginx.com> parents: 4943 diff changeset	171 } else {
6442 6e10518f95d8 Threads: offloading of temp files writing to thread pools. Maxim Dounin <mdounin@mdounin.ru> parents: 6441 diff changeset	172 ctx->nbytes = n;
6022 1fdba317ee6d Added support for offloading read() in thread pools. Valentin Bartenev <vbart@nginx.com> parents: 4943 diff changeset	173 ctx->err = 0;
1fdba317ee6d Added support for offloading read() in thread pools. Valentin Bartenev <vbart@nginx.com> parents: 4943 diff changeset	174 }
1fdba317ee6d Added support for offloading read() in thread pools. Valentin Bartenev <vbart@nginx.com> parents: 4943 diff changeset	175
1fdba317ee6d Added support for offloading read() in thread pools. Valentin Bartenev <vbart@nginx.com> parents: 4943 diff changeset	176 #if 0
1fdba317ee6d Added support for offloading read() in thread pools. Valentin Bartenev <vbart@nginx.com> parents: 4943 diff changeset	177 ngx_time_update();
1fdba317ee6d Added support for offloading read() in thread pools. Valentin Bartenev <vbart@nginx.com> parents: 4943 diff changeset	178 #endif
1fdba317ee6d Added support for offloading read() in thread pools. Valentin Bartenev <vbart@nginx.com> parents: 4943 diff changeset	179
1fdba317ee6d Added support for offloading read() in thread pools. Valentin Bartenev <vbart@nginx.com> parents: 4943 diff changeset	180 ngx_log_debug4(NGX_LOG_DEBUG_CORE, log, 0,
6480 f01ab2dbcfdc Fixed logging. Sergey Kandaurov <pluknet@nginx.com> parents: 6442 diff changeset	181 "pread: %z (err: %d) of %uz @%O",
6022 1fdba317ee6d Added support for offloading read() in thread pools. Valentin Bartenev <vbart@nginx.com> parents: 4943 diff changeset	182 n, ctx->err, ctx->size, ctx->offset);
1fdba317ee6d Added support for offloading read() in thread pools. Valentin Bartenev <vbart@nginx.com> parents: 4943 diff changeset	183 }
1fdba317ee6d Added support for offloading read() in thread pools. Valentin Bartenev <vbart@nginx.com> parents: 4943 diff changeset	184
1fdba317ee6d Added support for offloading read() in thread pools. Valentin Bartenev <vbart@nginx.com> parents: 4943 diff changeset	185 #else
1fdba317ee6d Added support for offloading read() in thread pools. Valentin Bartenev <vbart@nginx.com> parents: 4943 diff changeset	186
1fdba317ee6d Added support for offloading read() in thread pools. Valentin Bartenev <vbart@nginx.com> parents: 4943 diff changeset	187 #error pread() is required!
1fdba317ee6d Added support for offloading read() in thread pools. Valentin Bartenev <vbart@nginx.com> parents: 4943 diff changeset	188
1fdba317ee6d Added support for offloading read() in thread pools. Valentin Bartenev <vbart@nginx.com> parents: 4943 diff changeset	189 #endif
1fdba317ee6d Added support for offloading read() in thread pools. Valentin Bartenev <vbart@nginx.com> parents: 4943 diff changeset	190
1fdba317ee6d Added support for offloading read() in thread pools. Valentin Bartenev <vbart@nginx.com> parents: 4943 diff changeset	191 #endif /* NGX_THREADS */
1fdba317ee6d Added support for offloading read() in thread pools. Valentin Bartenev <vbart@nginx.com> parents: 4943 diff changeset	192
1fdba317ee6d Added support for offloading read() in thread pools. Valentin Bartenev <vbart@nginx.com> parents: 4943 diff changeset	193
561 e48ebafc6939 nginx-0.3.2-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 501 diff changeset	194 ssize_t
e48ebafc6939 nginx-0.3.2-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 501 diff changeset	195 ngx_write_file(ngx_file_t file, u_char buf, size_t size, off_t offset)
73 4534060fde92 nginx-0.0.1-2003-04-10-19:08:54 import Igor Sysoev <igor@sysoev.ru> parents: 35 diff changeset	196 {
6299 5170c3040ce1 Handled EINTR from write() and pwrite() syscalls. Valentin Bartenev <vbart@nginx.com> parents: 6298 diff changeset	197 ssize_t n, written;
5170c3040ce1 Handled EINTR from write() and pwrite() syscalls. Valentin Bartenev <vbart@nginx.com> parents: 6298 diff changeset	198 ngx_err_t err;
73 4534060fde92 nginx-0.0.1-2003-04-10-19:08:54 import Igor Sysoev <igor@sysoev.ru> parents: 35 diff changeset	199
461 a88a3e4e158f nginx-0.1.5-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 457 diff changeset	200 ngx_log_debug4(NGX_LOG_DEBUG_CORE, file->log, 0,
a88a3e4e158f nginx-0.1.5-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 457 diff changeset	201 "write: %d, %p, %uz, %O", file->fd, buf, size, offset);
a88a3e4e158f nginx-0.1.5-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 457 diff changeset	202
3163 34cbd6e86218 handle short pwrite() to log an error cause: ENOSPC, EDQUOT, or EFBIG Igor Sysoev <igor@sysoev.ru> parents: 3157 diff changeset	203 written = 0;
34cbd6e86218 handle short pwrite() to log an error cause: ENOSPC, EDQUOT, or EFBIG Igor Sysoev <igor@sysoev.ru> parents: 3157 diff changeset	204
469 2ff194b74f1e nginx-0.1.9-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 467 diff changeset	205 #if (NGX_HAVE_PWRITE)
182 3c49eaf3f522 nginx-0.0.1-2003-11-13-09:14:05 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	206
3163 34cbd6e86218 handle short pwrite() to log an error cause: ENOSPC, EDQUOT, or EFBIG Igor Sysoev <igor@sysoev.ru> parents: 3157 diff changeset	207 for ( ;; ) {
3657 fbd7dad43a4e fix ngx_write_file() buf Igor Sysoev <igor@sysoev.ru> parents: 3651 diff changeset	208 n = pwrite(file->fd, buf + written, size, offset);
3163 34cbd6e86218 handle short pwrite() to log an error cause: ENOSPC, EDQUOT, or EFBIG Igor Sysoev <igor@sysoev.ru> parents: 3157 diff changeset	209
34cbd6e86218 handle short pwrite() to log an error cause: ENOSPC, EDQUOT, or EFBIG Igor Sysoev <igor@sysoev.ru> parents: 3157 diff changeset	210 if (n == -1) {
6299 5170c3040ce1 Handled EINTR from write() and pwrite() syscalls. Valentin Bartenev <vbart@nginx.com> parents: 6298 diff changeset	211 err = ngx_errno;
5170c3040ce1 Handled EINTR from write() and pwrite() syscalls. Valentin Bartenev <vbart@nginx.com> parents: 6298 diff changeset	212
5170c3040ce1 Handled EINTR from write() and pwrite() syscalls. Valentin Bartenev <vbart@nginx.com> parents: 6298 diff changeset	213 if (err == NGX_EINTR) {
5170c3040ce1 Handled EINTR from write() and pwrite() syscalls. Valentin Bartenev <vbart@nginx.com> parents: 6298 diff changeset	214 ngx_log_debug0(NGX_LOG_DEBUG_CORE, file->log, err,
5170c3040ce1 Handled EINTR from write() and pwrite() syscalls. Valentin Bartenev <vbart@nginx.com> parents: 6298 diff changeset	215 "pwrite() was interrupted");
5170c3040ce1 Handled EINTR from write() and pwrite() syscalls. Valentin Bartenev <vbart@nginx.com> parents: 6298 diff changeset	216 continue;
5170c3040ce1 Handled EINTR from write() and pwrite() syscalls. Valentin Bartenev <vbart@nginx.com> parents: 6298 diff changeset	217 }
5170c3040ce1 Handled EINTR from write() and pwrite() syscalls. Valentin Bartenev <vbart@nginx.com> parents: 6298 diff changeset	218
5170c3040ce1 Handled EINTR from write() and pwrite() syscalls. Valentin Bartenev <vbart@nginx.com> parents: 6298 diff changeset	219 ngx_log_error(NGX_LOG_CRIT, file->log, err,
3163 34cbd6e86218 handle short pwrite() to log an error cause: ENOSPC, EDQUOT, or EFBIG Igor Sysoev <igor@sysoev.ru> parents: 3157 diff changeset	220 "pwrite() \"%s\" failed", file->name.data);
34cbd6e86218 handle short pwrite() to log an error cause: ENOSPC, EDQUOT, or EFBIG Igor Sysoev <igor@sysoev.ru> parents: 3157 diff changeset	221 return NGX_ERROR;
34cbd6e86218 handle short pwrite() to log an error cause: ENOSPC, EDQUOT, or EFBIG Igor Sysoev <igor@sysoev.ru> parents: 3157 diff changeset	222 }
73 4534060fde92 nginx-0.0.1-2003-04-10-19:08:54 import Igor Sysoev <igor@sysoev.ru> parents: 35 diff changeset	223
3163 34cbd6e86218 handle short pwrite() to log an error cause: ENOSPC, EDQUOT, or EFBIG Igor Sysoev <igor@sysoev.ru> parents: 3157 diff changeset	224 file->offset += n;
34cbd6e86218 handle short pwrite() to log an error cause: ENOSPC, EDQUOT, or EFBIG Igor Sysoev <igor@sysoev.ru> parents: 3157 diff changeset	225 written += n;
74 17ab1af8c3dd nginx-0.0.1-2003-04-11-20:01:14 import Igor Sysoev <igor@sysoev.ru> parents: 73 diff changeset	226
3163 34cbd6e86218 handle short pwrite() to log an error cause: ENOSPC, EDQUOT, or EFBIG Igor Sysoev <igor@sysoev.ru> parents: 3157 diff changeset	227 if ((size_t) n == size) {
34cbd6e86218 handle short pwrite() to log an error cause: ENOSPC, EDQUOT, or EFBIG Igor Sysoev <igor@sysoev.ru> parents: 3157 diff changeset	228 return written;
34cbd6e86218 handle short pwrite() to log an error cause: ENOSPC, EDQUOT, or EFBIG Igor Sysoev <igor@sysoev.ru> parents: 3157 diff changeset	229 }
34cbd6e86218 handle short pwrite() to log an error cause: ENOSPC, EDQUOT, or EFBIG Igor Sysoev <igor@sysoev.ru> parents: 3157 diff changeset	230
34cbd6e86218 handle short pwrite() to log an error cause: ENOSPC, EDQUOT, or EFBIG Igor Sysoev <igor@sysoev.ru> parents: 3157 diff changeset	231 offset += n;
34cbd6e86218 handle short pwrite() to log an error cause: ENOSPC, EDQUOT, or EFBIG Igor Sysoev <igor@sysoev.ru> parents: 3157 diff changeset	232 size -= n;
73 4534060fde92 nginx-0.0.1-2003-04-10-19:08:54 import Igor Sysoev <igor@sysoev.ru> parents: 35 diff changeset	233 }
4534060fde92 nginx-0.0.1-2003-04-10-19:08:54 import Igor Sysoev <igor@sysoev.ru> parents: 35 diff changeset	234
182 3c49eaf3f522 nginx-0.0.1-2003-11-13-09:14:05 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	235 #else
3c49eaf3f522 nginx-0.0.1-2003-11-13-09:14:05 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	236
190 02a715e85df1 nginx-0.0.1-2003-11-19-00:34:08 import Igor Sysoev <igor@sysoev.ru> parents: 186 diff changeset	237 if (file->sys_offset != offset) {
182 3c49eaf3f522 nginx-0.0.1-2003-11-13-09:14:05 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	238 if (lseek(file->fd, offset, SEEK_SET) == -1) {
3157 a2c1b4f74ea7 log file name for read/write errors Igor Sysoev <igor@sysoev.ru> parents: 2615 diff changeset	239 ngx_log_error(NGX_LOG_CRIT, file->log, ngx_errno,
a2c1b4f74ea7 log file name for read/write errors Igor Sysoev <igor@sysoev.ru> parents: 2615 diff changeset	240 "lseek() \"%s\" failed", file->name.data);
182 3c49eaf3f522 nginx-0.0.1-2003-11-13-09:14:05 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	241 return NGX_ERROR;
3c49eaf3f522 nginx-0.0.1-2003-11-13-09:14:05 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	242 }
191 71ce40b3c37b nginx-0.0.1-2003-11-19-19:26:41 import Igor Sysoev <igor@sysoev.ru> parents: 190 diff changeset	243
71ce40b3c37b nginx-0.0.1-2003-11-19-19:26:41 import Igor Sysoev <igor@sysoev.ru> parents: 190 diff changeset	244 file->sys_offset = offset;
182 3c49eaf3f522 nginx-0.0.1-2003-11-13-09:14:05 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	245 }
3c49eaf3f522 nginx-0.0.1-2003-11-13-09:14:05 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	246
3163 34cbd6e86218 handle short pwrite() to log an error cause: ENOSPC, EDQUOT, or EFBIG Igor Sysoev <igor@sysoev.ru> parents: 3157 diff changeset	247 for ( ;; ) {
3657 fbd7dad43a4e fix ngx_write_file() buf Igor Sysoev <igor@sysoev.ru> parents: 3651 diff changeset	248 n = write(file->fd, buf + written, size);
182 3c49eaf3f522 nginx-0.0.1-2003-11-13-09:14:05 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	249
3163 34cbd6e86218 handle short pwrite() to log an error cause: ENOSPC, EDQUOT, or EFBIG Igor Sysoev <igor@sysoev.ru> parents: 3157 diff changeset	250 if (n == -1) {
6299 5170c3040ce1 Handled EINTR from write() and pwrite() syscalls. Valentin Bartenev <vbart@nginx.com> parents: 6298 diff changeset	251 err = ngx_errno;
5170c3040ce1 Handled EINTR from write() and pwrite() syscalls. Valentin Bartenev <vbart@nginx.com> parents: 6298 diff changeset	252
5170c3040ce1 Handled EINTR from write() and pwrite() syscalls. Valentin Bartenev <vbart@nginx.com> parents: 6298 diff changeset	253 if (err == NGX_EINTR) {
5170c3040ce1 Handled EINTR from write() and pwrite() syscalls. Valentin Bartenev <vbart@nginx.com> parents: 6298 diff changeset	254 ngx_log_debug0(NGX_LOG_DEBUG_CORE, file->log, err,
5170c3040ce1 Handled EINTR from write() and pwrite() syscalls. Valentin Bartenev <vbart@nginx.com> parents: 6298 diff changeset	255 "write() was interrupted");
5170c3040ce1 Handled EINTR from write() and pwrite() syscalls. Valentin Bartenev <vbart@nginx.com> parents: 6298 diff changeset	256 continue;
5170c3040ce1 Handled EINTR from write() and pwrite() syscalls. Valentin Bartenev <vbart@nginx.com> parents: 6298 diff changeset	257 }
5170c3040ce1 Handled EINTR from write() and pwrite() syscalls. Valentin Bartenev <vbart@nginx.com> parents: 6298 diff changeset	258
5170c3040ce1 Handled EINTR from write() and pwrite() syscalls. Valentin Bartenev <vbart@nginx.com> parents: 6298 diff changeset	259 ngx_log_error(NGX_LOG_CRIT, file->log, err,
3163 34cbd6e86218 handle short pwrite() to log an error cause: ENOSPC, EDQUOT, or EFBIG Igor Sysoev <igor@sysoev.ru> parents: 3157 diff changeset	260 "write() \"%s\" failed", file->name.data);
34cbd6e86218 handle short pwrite() to log an error cause: ENOSPC, EDQUOT, or EFBIG Igor Sysoev <igor@sysoev.ru> parents: 3157 diff changeset	261 return NGX_ERROR;
34cbd6e86218 handle short pwrite() to log an error cause: ENOSPC, EDQUOT, or EFBIG Igor Sysoev <igor@sysoev.ru> parents: 3157 diff changeset	262 }
182 3c49eaf3f522 nginx-0.0.1-2003-11-13-09:14:05 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	263
6298 8f6d753c1953 Adjusted file->sys_offset after the write() syscall. Valentin Bartenev <vbart@nginx.com> parents: 6241 diff changeset	264 file->sys_offset += n;
3163 34cbd6e86218 handle short pwrite() to log an error cause: ENOSPC, EDQUOT, or EFBIG Igor Sysoev <igor@sysoev.ru> parents: 3157 diff changeset	265 file->offset += n;
34cbd6e86218 handle short pwrite() to log an error cause: ENOSPC, EDQUOT, or EFBIG Igor Sysoev <igor@sysoev.ru> parents: 3157 diff changeset	266 written += n;
182 3c49eaf3f522 nginx-0.0.1-2003-11-13-09:14:05 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	267
3163 34cbd6e86218 handle short pwrite() to log an error cause: ENOSPC, EDQUOT, or EFBIG Igor Sysoev <igor@sysoev.ru> parents: 3157 diff changeset	268 if ((size_t) n == size) {
34cbd6e86218 handle short pwrite() to log an error cause: ENOSPC, EDQUOT, or EFBIG Igor Sysoev <igor@sysoev.ru> parents: 3157 diff changeset	269 return written;
34cbd6e86218 handle short pwrite() to log an error cause: ENOSPC, EDQUOT, or EFBIG Igor Sysoev <igor@sysoev.ru> parents: 3157 diff changeset	270 }
182 3c49eaf3f522 nginx-0.0.1-2003-11-13-09:14:05 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	271
3163 34cbd6e86218 handle short pwrite() to log an error cause: ENOSPC, EDQUOT, or EFBIG Igor Sysoev <igor@sysoev.ru> parents: 3157 diff changeset	272 size -= n;
34cbd6e86218 handle short pwrite() to log an error cause: ENOSPC, EDQUOT, or EFBIG Igor Sysoev <igor@sysoev.ru> parents: 3157 diff changeset	273 }
34cbd6e86218 handle short pwrite() to log an error cause: ENOSPC, EDQUOT, or EFBIG Igor Sysoev <igor@sysoev.ru> parents: 3157 diff changeset	274 #endif
74 17ab1af8c3dd nginx-0.0.1-2003-04-11-20:01:14 import Igor Sysoev <igor@sysoev.ru> parents: 73 diff changeset	275 }
17ab1af8c3dd nginx-0.0.1-2003-04-11-20:01:14 import Igor Sysoev <igor@sysoev.ru> parents: 73 diff changeset	276
17ab1af8c3dd nginx-0.0.1-2003-04-11-20:01:14 import Igor Sysoev <igor@sysoev.ru> parents: 73 diff changeset	277
561 e48ebafc6939 nginx-0.3.2-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 501 diff changeset	278 ngx_fd_t
1046 bb139aba3199 rename mode to access Igor Sysoev <igor@sysoev.ru> parents: 735 diff changeset	279 ngx_open_tempfile(u_char *name, ngx_uint_t persistent, ngx_uint_t access)
303 00c5660d2707 nginx-0.0.3-2004-04-01-20:20:53 import Igor Sysoev <igor@sysoev.ru> parents: 290 diff changeset	280 {
00c5660d2707 nginx-0.0.3-2004-04-01-20:20:53 import Igor Sysoev <igor@sysoev.ru> parents: 290 diff changeset	281 ngx_fd_t fd;
00c5660d2707 nginx-0.0.3-2004-04-01-20:20:53 import Igor Sysoev <igor@sysoev.ru> parents: 290 diff changeset	282
1046 bb139aba3199 rename mode to access Igor Sysoev <igor@sysoev.ru> parents: 735 diff changeset	283 fd = open((const char *) name, O_CREAT\|O_EXCL\|O_RDWR,
bb139aba3199 rename mode to access Igor Sysoev <igor@sysoev.ru> parents: 735 diff changeset	284 access ? access : 0600);
303 00c5660d2707 nginx-0.0.3-2004-04-01-20:20:53 import Igor Sysoev <igor@sysoev.ru> parents: 290 diff changeset	285
00c5660d2707 nginx-0.0.3-2004-04-01-20:20:53 import Igor Sysoev <igor@sysoev.ru> parents: 290 diff changeset	286 if (fd != -1 && !persistent) {
4794 4163fb9dcfcb Explicitly ignore returned value from unlink() in ngx_open_tempfile(). Andrey Belov <defan@nginx.com> parents: 4737 diff changeset	287 (void) unlink((const char *) name);
303 00c5660d2707 nginx-0.0.3-2004-04-01-20:20:53 import Igor Sysoev <igor@sysoev.ru> parents: 290 diff changeset	288 }
00c5660d2707 nginx-0.0.3-2004-04-01-20:20:53 import Igor Sysoev <igor@sysoev.ru> parents: 290 diff changeset	289
00c5660d2707 nginx-0.0.3-2004-04-01-20:20:53 import Igor Sysoev <igor@sysoev.ru> parents: 290 diff changeset	290 return fd;
00c5660d2707 nginx-0.0.3-2004-04-01-20:20:53 import Igor Sysoev <igor@sysoev.ru> parents: 290 diff changeset	291 }
00c5660d2707 nginx-0.0.3-2004-04-01-20:20:53 import Igor Sysoev <igor@sysoev.ru> parents: 290 diff changeset	292
00c5660d2707 nginx-0.0.3-2004-04-01-20:20:53 import Igor Sysoev <igor@sysoev.ru> parents: 290 diff changeset	293
561 e48ebafc6939 nginx-0.3.2-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 501 diff changeset	294 ssize_t
e48ebafc6939 nginx-0.3.2-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 501 diff changeset	295 ngx_write_chain_to_file(ngx_file_t file, ngx_chain_t cl, off_t offset,
e48ebafc6939 nginx-0.3.2-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 501 diff changeset	296 ngx_pool_t *pool)
74 17ab1af8c3dd nginx-0.0.1-2003-04-11-20:01:14 import Igor Sysoev <igor@sysoev.ru> parents: 73 diff changeset	297 {
4220 4be8dd8dd547 Fixed unix ngx_write_chain_to_file() to return total bytes written. Maxim Dounin <mdounin@mdounin.ru> parents: 3861 diff changeset	298 ssize_t total, n;
6421 3832b608dc8d Introduced the ngx_chain_to_iovec() function. Valentin Bartenev <vbart@nginx.com> parents: 6301 diff changeset	299 ngx_iovec_t vec;
3832b608dc8d Introduced the ngx_chain_to_iovec() function. Valentin Bartenev <vbart@nginx.com> parents: 6301 diff changeset	300 struct iovec iovs[NGX_IOVS_PREALLOCATE];
74 17ab1af8c3dd nginx-0.0.1-2003-04-11-20:01:14 import Igor Sysoev <igor@sysoev.ru> parents: 73 diff changeset	301
461 a88a3e4e158f nginx-0.1.5-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 457 diff changeset	302 /* use pwrite() if there is the only buf in a chain */
74 17ab1af8c3dd nginx-0.0.1-2003-04-11-20:01:14 import Igor Sysoev <igor@sysoev.ru> parents: 73 diff changeset	303
170 c42be4185301 nginx-0.0.1-2003-11-03-01:56:18 import Igor Sysoev <igor@sysoev.ru> parents: 154 diff changeset	304 if (cl->next == NULL) {
343 6bdf858bff8c nginx-0.0.3-2004-05-28-19:49:23 import; rename ngx_hunk_t to ngx_buf_t Igor Sysoev <igor@sysoev.ru> parents: 303 diff changeset	305 return ngx_write_file(file, cl->buf->pos,
6bdf858bff8c nginx-0.0.3-2004-05-28-19:49:23 import; rename ngx_hunk_t to ngx_buf_t Igor Sysoev <igor@sysoev.ru> parents: 303 diff changeset	306 (size_t) (cl->buf->last - cl->buf->pos),
194 2357fa41738a nginx-0.0.1-2003-11-21-09:30:49 import Igor Sysoev <igor@sysoev.ru> parents: 191 diff changeset	307 offset);
74 17ab1af8c3dd nginx-0.0.1-2003-04-11-20:01:14 import Igor Sysoev <igor@sysoev.ru> parents: 73 diff changeset	308 }
17ab1af8c3dd nginx-0.0.1-2003-04-11-20:01:14 import Igor Sysoev <igor@sysoev.ru> parents: 73 diff changeset	309
4220 4be8dd8dd547 Fixed unix ngx_write_chain_to_file() to return total bytes written. Maxim Dounin <mdounin@mdounin.ru> parents: 3861 diff changeset	310 total = 0;
4be8dd8dd547 Fixed unix ngx_write_chain_to_file() to return total bytes written. Maxim Dounin <mdounin@mdounin.ru> parents: 3861 diff changeset	311
6421 3832b608dc8d Introduced the ngx_chain_to_iovec() function. Valentin Bartenev <vbart@nginx.com> parents: 6301 diff changeset	312 vec.iovs = iovs;
3832b608dc8d Introduced the ngx_chain_to_iovec() function. Valentin Bartenev <vbart@nginx.com> parents: 6301 diff changeset	313 vec.nalloc = NGX_IOVS_PREALLOCATE;
170 c42be4185301 nginx-0.0.1-2003-11-03-01:56:18 import Igor Sysoev <igor@sysoev.ru> parents: 154 diff changeset	314
461 a88a3e4e158f nginx-0.1.5-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 457 diff changeset	315 do {
a88a3e4e158f nginx-0.1.5-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 457 diff changeset	316 /* create the iovec and coalesce the neighbouring bufs */
6421 3832b608dc8d Introduced the ngx_chain_to_iovec() function. Valentin Bartenev <vbart@nginx.com> parents: 6301 diff changeset	317 cl = ngx_chain_to_iovec(&vec, cl);
170 c42be4185301 nginx-0.0.1-2003-11-03-01:56:18 import Igor Sysoev <igor@sysoev.ru> parents: 154 diff changeset	318
461 a88a3e4e158f nginx-0.1.5-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 457 diff changeset	319 /* use pwrite() if there is the only iovec buffer */
170 c42be4185301 nginx-0.0.1-2003-11-03-01:56:18 import Igor Sysoev <igor@sysoev.ru> parents: 154 diff changeset	320
6421 3832b608dc8d Introduced the ngx_chain_to_iovec() function. Valentin Bartenev <vbart@nginx.com> parents: 6301 diff changeset	321 if (vec.count == 1) {
3832b608dc8d Introduced the ngx_chain_to_iovec() function. Valentin Bartenev <vbart@nginx.com> parents: 6301 diff changeset	322 n = ngx_write_file(file, (u_char *) iovs[0].iov_base,
3832b608dc8d Introduced the ngx_chain_to_iovec() function. Valentin Bartenev <vbart@nginx.com> parents: 6301 diff changeset	323 iovs[0].iov_len, offset);
4221 3203ddb78279 Fixed another return in unix ngx_write_chain_to_file(). Maxim Dounin <mdounin@mdounin.ru> parents: 4220 diff changeset	324
3203ddb78279 Fixed another return in unix ngx_write_chain_to_file(). Maxim Dounin <mdounin@mdounin.ru> parents: 4220 diff changeset	325 if (n == NGX_ERROR) {
3203ddb78279 Fixed another return in unix ngx_write_chain_to_file(). Maxim Dounin <mdounin@mdounin.ru> parents: 4220 diff changeset	326 return n;
3203ddb78279 Fixed another return in unix ngx_write_chain_to_file(). Maxim Dounin <mdounin@mdounin.ru> parents: 4220 diff changeset	327 }
3203ddb78279 Fixed another return in unix ngx_write_chain_to_file(). Maxim Dounin <mdounin@mdounin.ru> parents: 4220 diff changeset	328
3203ddb78279 Fixed another return in unix ngx_write_chain_to_file(). Maxim Dounin <mdounin@mdounin.ru> parents: 4220 diff changeset	329 return total + n;
461 a88a3e4e158f nginx-0.1.5-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 457 diff changeset	330 }
170 c42be4185301 nginx-0.0.1-2003-11-03-01:56:18 import Igor Sysoev <igor@sysoev.ru> parents: 154 diff changeset	331
6421 3832b608dc8d Introduced the ngx_chain_to_iovec() function. Valentin Bartenev <vbart@nginx.com> parents: 6301 diff changeset	332 n = ngx_writev_file(file, &vec, offset);
74 17ab1af8c3dd nginx-0.0.1-2003-04-11-20:01:14 import Igor Sysoev <igor@sysoev.ru> parents: 73 diff changeset	333
6300 be6af0906a4d Moved file writev() handling code to a separate function. Valentin Bartenev <vbart@nginx.com> parents: 6299 diff changeset	334 if (n == NGX_ERROR) {
be6af0906a4d Moved file writev() handling code to a separate function. Valentin Bartenev <vbart@nginx.com> parents: 6299 diff changeset	335 return n;
461 a88a3e4e158f nginx-0.1.5-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 457 diff changeset	336 }
a88a3e4e158f nginx-0.1.5-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 457 diff changeset	337
4938 64ffc28850bb Core: fixed ngx_write_chain_to_file() with IOV_MAX reached. Maxim Dounin <mdounin@mdounin.ru> parents: 4919 diff changeset	338 offset += n;
4220 4be8dd8dd547 Fixed unix ngx_write_chain_to_file() to return total bytes written. Maxim Dounin <mdounin@mdounin.ru> parents: 3861 diff changeset	339 total += n;
74 17ab1af8c3dd nginx-0.0.1-2003-04-11-20:01:14 import Igor Sysoev <igor@sysoev.ru> parents: 73 diff changeset	340
461 a88a3e4e158f nginx-0.1.5-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 457 diff changeset	341 } while (cl);
73 4534060fde92 nginx-0.0.1-2003-04-10-19:08:54 import Igor Sysoev <igor@sysoev.ru> parents: 35 diff changeset	342
4220 4be8dd8dd547 Fixed unix ngx_write_chain_to_file() to return total bytes written. Maxim Dounin <mdounin@mdounin.ru> parents: 3861 diff changeset	343 return total;
73 4534060fde92 nginx-0.0.1-2003-04-10-19:08:54 import Igor Sysoev <igor@sysoev.ru> parents: 35 diff changeset	344 }
4534060fde92 nginx-0.0.1-2003-04-10-19:08:54 import Igor Sysoev <igor@sysoev.ru> parents: 35 diff changeset	345
4534060fde92 nginx-0.0.1-2003-04-10-19:08:54 import Igor Sysoev <igor@sysoev.ru> parents: 35 diff changeset	346
6421 3832b608dc8d Introduced the ngx_chain_to_iovec() function. Valentin Bartenev <vbart@nginx.com> parents: 6301 diff changeset	347 static ngx_chain_t *
3832b608dc8d Introduced the ngx_chain_to_iovec() function. Valentin Bartenev <vbart@nginx.com> parents: 6301 diff changeset	348 ngx_chain_to_iovec(ngx_iovec_t vec, ngx_chain_t cl)
3832b608dc8d Introduced the ngx_chain_to_iovec() function. Valentin Bartenev <vbart@nginx.com> parents: 6301 diff changeset	349 {
3832b608dc8d Introduced the ngx_chain_to_iovec() function. Valentin Bartenev <vbart@nginx.com> parents: 6301 diff changeset	350 size_t total, size;
3832b608dc8d Introduced the ngx_chain_to_iovec() function. Valentin Bartenev <vbart@nginx.com> parents: 6301 diff changeset	351 u_char *prev;
3832b608dc8d Introduced the ngx_chain_to_iovec() function. Valentin Bartenev <vbart@nginx.com> parents: 6301 diff changeset	352 ngx_uint_t n;
3832b608dc8d Introduced the ngx_chain_to_iovec() function. Valentin Bartenev <vbart@nginx.com> parents: 6301 diff changeset	353 struct iovec *iov;
3832b608dc8d Introduced the ngx_chain_to_iovec() function. Valentin Bartenev <vbart@nginx.com> parents: 6301 diff changeset	354
3832b608dc8d Introduced the ngx_chain_to_iovec() function. Valentin Bartenev <vbart@nginx.com> parents: 6301 diff changeset	355 iov = NULL;
3832b608dc8d Introduced the ngx_chain_to_iovec() function. Valentin Bartenev <vbart@nginx.com> parents: 6301 diff changeset	356 prev = NULL;
3832b608dc8d Introduced the ngx_chain_to_iovec() function. Valentin Bartenev <vbart@nginx.com> parents: 6301 diff changeset	357 total = 0;
3832b608dc8d Introduced the ngx_chain_to_iovec() function. Valentin Bartenev <vbart@nginx.com> parents: 6301 diff changeset	358 n = 0;
3832b608dc8d Introduced the ngx_chain_to_iovec() function. Valentin Bartenev <vbart@nginx.com> parents: 6301 diff changeset	359
3832b608dc8d Introduced the ngx_chain_to_iovec() function. Valentin Bartenev <vbart@nginx.com> parents: 6301 diff changeset	360 for ( /* void */ ; cl; cl = cl->next) {
6574 7eb19447b2de Core: skip special buffers on writing (ticket #981). Maxim Dounin <mdounin@mdounin.ru> parents: 6480 diff changeset	361
7eb19447b2de Core: skip special buffers on writing (ticket #981). Maxim Dounin <mdounin@mdounin.ru> parents: 6480 diff changeset	362 if (ngx_buf_special(cl->buf)) {
7eb19447b2de Core: skip special buffers on writing (ticket #981). Maxim Dounin <mdounin@mdounin.ru> parents: 6480 diff changeset	363 continue;
7eb19447b2de Core: skip special buffers on writing (ticket #981). Maxim Dounin <mdounin@mdounin.ru> parents: 6480 diff changeset	364 }
7eb19447b2de Core: skip special buffers on writing (ticket #981). Maxim Dounin <mdounin@mdounin.ru> parents: 6480 diff changeset	365
6421 3832b608dc8d Introduced the ngx_chain_to_iovec() function. Valentin Bartenev <vbart@nginx.com> parents: 6301 diff changeset	366 size = cl->buf->last - cl->buf->pos;
3832b608dc8d Introduced the ngx_chain_to_iovec() function. Valentin Bartenev <vbart@nginx.com> parents: 6301 diff changeset	367
3832b608dc8d Introduced the ngx_chain_to_iovec() function. Valentin Bartenev <vbart@nginx.com> parents: 6301 diff changeset	368 if (prev == cl->buf->pos) {
3832b608dc8d Introduced the ngx_chain_to_iovec() function. Valentin Bartenev <vbart@nginx.com> parents: 6301 diff changeset	369 iov->iov_len += size;
3832b608dc8d Introduced the ngx_chain_to_iovec() function. Valentin Bartenev <vbart@nginx.com> parents: 6301 diff changeset	370
3832b608dc8d Introduced the ngx_chain_to_iovec() function. Valentin Bartenev <vbart@nginx.com> parents: 6301 diff changeset	371 } else {
3832b608dc8d Introduced the ngx_chain_to_iovec() function. Valentin Bartenev <vbart@nginx.com> parents: 6301 diff changeset	372 if (n == vec->nalloc) {
3832b608dc8d Introduced the ngx_chain_to_iovec() function. Valentin Bartenev <vbart@nginx.com> parents: 6301 diff changeset	373 break;
3832b608dc8d Introduced the ngx_chain_to_iovec() function. Valentin Bartenev <vbart@nginx.com> parents: 6301 diff changeset	374 }
3832b608dc8d Introduced the ngx_chain_to_iovec() function. Valentin Bartenev <vbart@nginx.com> parents: 6301 diff changeset	375
3832b608dc8d Introduced the ngx_chain_to_iovec() function. Valentin Bartenev <vbart@nginx.com> parents: 6301 diff changeset	376 iov = &vec->iovs[n++];
3832b608dc8d Introduced the ngx_chain_to_iovec() function. Valentin Bartenev <vbart@nginx.com> parents: 6301 diff changeset	377
3832b608dc8d Introduced the ngx_chain_to_iovec() function. Valentin Bartenev <vbart@nginx.com> parents: 6301 diff changeset	378 iov->iov_base = (void *) cl->buf->pos;
3832b608dc8d Introduced the ngx_chain_to_iovec() function. Valentin Bartenev <vbart@nginx.com> parents: 6301 diff changeset	379 iov->iov_len = size;
3832b608dc8d Introduced the ngx_chain_to_iovec() function. Valentin Bartenev <vbart@nginx.com> parents: 6301 diff changeset	380 }
3832b608dc8d Introduced the ngx_chain_to_iovec() function. Valentin Bartenev <vbart@nginx.com> parents: 6301 diff changeset	381
3832b608dc8d Introduced the ngx_chain_to_iovec() function. Valentin Bartenev <vbart@nginx.com> parents: 6301 diff changeset	382 prev = cl->buf->pos + size;
3832b608dc8d Introduced the ngx_chain_to_iovec() function. Valentin Bartenev <vbart@nginx.com> parents: 6301 diff changeset	383 total += size;
3832b608dc8d Introduced the ngx_chain_to_iovec() function. Valentin Bartenev <vbart@nginx.com> parents: 6301 diff changeset	384 }
3832b608dc8d Introduced the ngx_chain_to_iovec() function. Valentin Bartenev <vbart@nginx.com> parents: 6301 diff changeset	385
3832b608dc8d Introduced the ngx_chain_to_iovec() function. Valentin Bartenev <vbart@nginx.com> parents: 6301 diff changeset	386 vec->count = n;
3832b608dc8d Introduced the ngx_chain_to_iovec() function. Valentin Bartenev <vbart@nginx.com> parents: 6301 diff changeset	387 vec->size = total;
3832b608dc8d Introduced the ngx_chain_to_iovec() function. Valentin Bartenev <vbart@nginx.com> parents: 6301 diff changeset	388
3832b608dc8d Introduced the ngx_chain_to_iovec() function. Valentin Bartenev <vbart@nginx.com> parents: 6301 diff changeset	389 return cl;
3832b608dc8d Introduced the ngx_chain_to_iovec() function. Valentin Bartenev <vbart@nginx.com> parents: 6301 diff changeset	390 }
3832b608dc8d Introduced the ngx_chain_to_iovec() function. Valentin Bartenev <vbart@nginx.com> parents: 6301 diff changeset	391
3832b608dc8d Introduced the ngx_chain_to_iovec() function. Valentin Bartenev <vbart@nginx.com> parents: 6301 diff changeset	392
6300 be6af0906a4d Moved file writev() handling code to a separate function. Valentin Bartenev <vbart@nginx.com> parents: 6299 diff changeset	393 static ssize_t
6421 3832b608dc8d Introduced the ngx_chain_to_iovec() function. Valentin Bartenev <vbart@nginx.com> parents: 6301 diff changeset	394 ngx_writev_file(ngx_file_t file, ngx_iovec_t vec, off_t offset)
6300 be6af0906a4d Moved file writev() handling code to a separate function. Valentin Bartenev <vbart@nginx.com> parents: 6299 diff changeset	395 {
be6af0906a4d Moved file writev() handling code to a separate function. Valentin Bartenev <vbart@nginx.com> parents: 6299 diff changeset	396 ssize_t n;
be6af0906a4d Moved file writev() handling code to a separate function. Valentin Bartenev <vbart@nginx.com> parents: 6299 diff changeset	397 ngx_err_t err;
be6af0906a4d Moved file writev() handling code to a separate function. Valentin Bartenev <vbart@nginx.com> parents: 6299 diff changeset	398
6301 b5a87b51be24 Used the pwritev() syscall for writing files where possible. Valentin Bartenev <vbart@nginx.com> parents: 6300 diff changeset	399 ngx_log_debug3(NGX_LOG_DEBUG_CORE, file->log, 0,
6421 3832b608dc8d Introduced the ngx_chain_to_iovec() function. Valentin Bartenev <vbart@nginx.com> parents: 6301 diff changeset	400 "writev: %d, %uz, %O", file->fd, vec->size, offset);
6301 b5a87b51be24 Used the pwritev() syscall for writing files where possible. Valentin Bartenev <vbart@nginx.com> parents: 6300 diff changeset	401
b5a87b51be24 Used the pwritev() syscall for writing files where possible. Valentin Bartenev <vbart@nginx.com> parents: 6300 diff changeset	402 #if (NGX_HAVE_PWRITEV)
b5a87b51be24 Used the pwritev() syscall for writing files where possible. Valentin Bartenev <vbart@nginx.com> parents: 6300 diff changeset	403
b5a87b51be24 Used the pwritev() syscall for writing files where possible. Valentin Bartenev <vbart@nginx.com> parents: 6300 diff changeset	404 eintr:
b5a87b51be24 Used the pwritev() syscall for writing files where possible. Valentin Bartenev <vbart@nginx.com> parents: 6300 diff changeset	405
6421 3832b608dc8d Introduced the ngx_chain_to_iovec() function. Valentin Bartenev <vbart@nginx.com> parents: 6301 diff changeset	406 n = pwritev(file->fd, vec->iovs, vec->count, offset);
6301 b5a87b51be24 Used the pwritev() syscall for writing files where possible. Valentin Bartenev <vbart@nginx.com> parents: 6300 diff changeset	407
b5a87b51be24 Used the pwritev() syscall for writing files where possible. Valentin Bartenev <vbart@nginx.com> parents: 6300 diff changeset	408 if (n == -1) {
b5a87b51be24 Used the pwritev() syscall for writing files where possible. Valentin Bartenev <vbart@nginx.com> parents: 6300 diff changeset	409 err = ngx_errno;
b5a87b51be24 Used the pwritev() syscall for writing files where possible. Valentin Bartenev <vbart@nginx.com> parents: 6300 diff changeset	410
b5a87b51be24 Used the pwritev() syscall for writing files where possible. Valentin Bartenev <vbart@nginx.com> parents: 6300 diff changeset	411 if (err == NGX_EINTR) {
b5a87b51be24 Used the pwritev() syscall for writing files where possible. Valentin Bartenev <vbart@nginx.com> parents: 6300 diff changeset	412 ngx_log_debug0(NGX_LOG_DEBUG_CORE, file->log, err,
b5a87b51be24 Used the pwritev() syscall for writing files where possible. Valentin Bartenev <vbart@nginx.com> parents: 6300 diff changeset	413 "pwritev() was interrupted");
b5a87b51be24 Used the pwritev() syscall for writing files where possible. Valentin Bartenev <vbart@nginx.com> parents: 6300 diff changeset	414 goto eintr;
b5a87b51be24 Used the pwritev() syscall for writing files where possible. Valentin Bartenev <vbart@nginx.com> parents: 6300 diff changeset	415 }
b5a87b51be24 Used the pwritev() syscall for writing files where possible. Valentin Bartenev <vbart@nginx.com> parents: 6300 diff changeset	416
b5a87b51be24 Used the pwritev() syscall for writing files where possible. Valentin Bartenev <vbart@nginx.com> parents: 6300 diff changeset	417 ngx_log_error(NGX_LOG_CRIT, file->log, err,
b5a87b51be24 Used the pwritev() syscall for writing files where possible. Valentin Bartenev <vbart@nginx.com> parents: 6300 diff changeset	418 "pwritev() \"%s\" failed", file->name.data);
b5a87b51be24 Used the pwritev() syscall for writing files where possible. Valentin Bartenev <vbart@nginx.com> parents: 6300 diff changeset	419 return NGX_ERROR;
b5a87b51be24 Used the pwritev() syscall for writing files where possible. Valentin Bartenev <vbart@nginx.com> parents: 6300 diff changeset	420 }
b5a87b51be24 Used the pwritev() syscall for writing files where possible. Valentin Bartenev <vbart@nginx.com> parents: 6300 diff changeset	421
6421 3832b608dc8d Introduced the ngx_chain_to_iovec() function. Valentin Bartenev <vbart@nginx.com> parents: 6301 diff changeset	422 if ((size_t) n != vec->size) {
6301 b5a87b51be24 Used the pwritev() syscall for writing files where possible. Valentin Bartenev <vbart@nginx.com> parents: 6300 diff changeset	423 ngx_log_error(NGX_LOG_CRIT, file->log, 0,
b5a87b51be24 Used the pwritev() syscall for writing files where possible. Valentin Bartenev <vbart@nginx.com> parents: 6300 diff changeset	424 "pwritev() \"%s\" has written only %z of %uz",
6421 3832b608dc8d Introduced the ngx_chain_to_iovec() function. Valentin Bartenev <vbart@nginx.com> parents: 6301 diff changeset	425 file->name.data, n, vec->size);
6301 b5a87b51be24 Used the pwritev() syscall for writing files where possible. Valentin Bartenev <vbart@nginx.com> parents: 6300 diff changeset	426 return NGX_ERROR;
b5a87b51be24 Used the pwritev() syscall for writing files where possible. Valentin Bartenev <vbart@nginx.com> parents: 6300 diff changeset	427 }
b5a87b51be24 Used the pwritev() syscall for writing files where possible. Valentin Bartenev <vbart@nginx.com> parents: 6300 diff changeset	428
b5a87b51be24 Used the pwritev() syscall for writing files where possible. Valentin Bartenev <vbart@nginx.com> parents: 6300 diff changeset	429 #else
b5a87b51be24 Used the pwritev() syscall for writing files where possible. Valentin Bartenev <vbart@nginx.com> parents: 6300 diff changeset	430
6300 be6af0906a4d Moved file writev() handling code to a separate function. Valentin Bartenev <vbart@nginx.com> parents: 6299 diff changeset	431 if (file->sys_offset != offset) {
be6af0906a4d Moved file writev() handling code to a separate function. Valentin Bartenev <vbart@nginx.com> parents: 6299 diff changeset	432 if (lseek(file->fd, offset, SEEK_SET) == -1) {
be6af0906a4d Moved file writev() handling code to a separate function. Valentin Bartenev <vbart@nginx.com> parents: 6299 diff changeset	433 ngx_log_error(NGX_LOG_CRIT, file->log, ngx_errno,
be6af0906a4d Moved file writev() handling code to a separate function. Valentin Bartenev <vbart@nginx.com> parents: 6299 diff changeset	434 "lseek() \"%s\" failed", file->name.data);
be6af0906a4d Moved file writev() handling code to a separate function. Valentin Bartenev <vbart@nginx.com> parents: 6299 diff changeset	435 return NGX_ERROR;
be6af0906a4d Moved file writev() handling code to a separate function. Valentin Bartenev <vbart@nginx.com> parents: 6299 diff changeset	436 }
be6af0906a4d Moved file writev() handling code to a separate function. Valentin Bartenev <vbart@nginx.com> parents: 6299 diff changeset	437
be6af0906a4d Moved file writev() handling code to a separate function. Valentin Bartenev <vbart@nginx.com> parents: 6299 diff changeset	438 file->sys_offset = offset;
be6af0906a4d Moved file writev() handling code to a separate function. Valentin Bartenev <vbart@nginx.com> parents: 6299 diff changeset	439 }
be6af0906a4d Moved file writev() handling code to a separate function. Valentin Bartenev <vbart@nginx.com> parents: 6299 diff changeset	440
be6af0906a4d Moved file writev() handling code to a separate function. Valentin Bartenev <vbart@nginx.com> parents: 6299 diff changeset	441 eintr:
be6af0906a4d Moved file writev() handling code to a separate function. Valentin Bartenev <vbart@nginx.com> parents: 6299 diff changeset	442
6421 3832b608dc8d Introduced the ngx_chain_to_iovec() function. Valentin Bartenev <vbart@nginx.com> parents: 6301 diff changeset	443 n = writev(file->fd, vec->iovs, vec->count);
6300 be6af0906a4d Moved file writev() handling code to a separate function. Valentin Bartenev <vbart@nginx.com> parents: 6299 diff changeset	444
be6af0906a4d Moved file writev() handling code to a separate function. Valentin Bartenev <vbart@nginx.com> parents: 6299 diff changeset	445 if (n == -1) {
be6af0906a4d Moved file writev() handling code to a separate function. Valentin Bartenev <vbart@nginx.com> parents: 6299 diff changeset	446 err = ngx_errno;
be6af0906a4d Moved file writev() handling code to a separate function. Valentin Bartenev <vbart@nginx.com> parents: 6299 diff changeset	447
be6af0906a4d Moved file writev() handling code to a separate function. Valentin Bartenev <vbart@nginx.com> parents: 6299 diff changeset	448 if (err == NGX_EINTR) {
be6af0906a4d Moved file writev() handling code to a separate function. Valentin Bartenev <vbart@nginx.com> parents: 6299 diff changeset	449 ngx_log_debug0(NGX_LOG_DEBUG_CORE, file->log, err,
be6af0906a4d Moved file writev() handling code to a separate function. Valentin Bartenev <vbart@nginx.com> parents: 6299 diff changeset	450 "writev() was interrupted");
be6af0906a4d Moved file writev() handling code to a separate function. Valentin Bartenev <vbart@nginx.com> parents: 6299 diff changeset	451 goto eintr;
be6af0906a4d Moved file writev() handling code to a separate function. Valentin Bartenev <vbart@nginx.com> parents: 6299 diff changeset	452 }
be6af0906a4d Moved file writev() handling code to a separate function. Valentin Bartenev <vbart@nginx.com> parents: 6299 diff changeset	453
be6af0906a4d Moved file writev() handling code to a separate function. Valentin Bartenev <vbart@nginx.com> parents: 6299 diff changeset	454 ngx_log_error(NGX_LOG_CRIT, file->log, err,
be6af0906a4d Moved file writev() handling code to a separate function. Valentin Bartenev <vbart@nginx.com> parents: 6299 diff changeset	455 "writev() \"%s\" failed", file->name.data);
be6af0906a4d Moved file writev() handling code to a separate function. Valentin Bartenev <vbart@nginx.com> parents: 6299 diff changeset	456 return NGX_ERROR;
be6af0906a4d Moved file writev() handling code to a separate function. Valentin Bartenev <vbart@nginx.com> parents: 6299 diff changeset	457 }
be6af0906a4d Moved file writev() handling code to a separate function. Valentin Bartenev <vbart@nginx.com> parents: 6299 diff changeset	458
6421 3832b608dc8d Introduced the ngx_chain_to_iovec() function. Valentin Bartenev <vbart@nginx.com> parents: 6301 diff changeset	459 if ((size_t) n != vec->size) {
6300 be6af0906a4d Moved file writev() handling code to a separate function. Valentin Bartenev <vbart@nginx.com> parents: 6299 diff changeset	460 ngx_log_error(NGX_LOG_CRIT, file->log, 0,
be6af0906a4d Moved file writev() handling code to a separate function. Valentin Bartenev <vbart@nginx.com> parents: 6299 diff changeset	461 "writev() \"%s\" has written only %z of %uz",
6421 3832b608dc8d Introduced the ngx_chain_to_iovec() function. Valentin Bartenev <vbart@nginx.com> parents: 6301 diff changeset	462 file->name.data, n, vec->size);
6300 be6af0906a4d Moved file writev() handling code to a separate function. Valentin Bartenev <vbart@nginx.com> parents: 6299 diff changeset	463 return NGX_ERROR;
be6af0906a4d Moved file writev() handling code to a separate function. Valentin Bartenev <vbart@nginx.com> parents: 6299 diff changeset	464 }
be6af0906a4d Moved file writev() handling code to a separate function. Valentin Bartenev <vbart@nginx.com> parents: 6299 diff changeset	465
6301 b5a87b51be24 Used the pwritev() syscall for writing files where possible. Valentin Bartenev <vbart@nginx.com> parents: 6300 diff changeset	466 file->sys_offset += n;
6300 be6af0906a4d Moved file writev() handling code to a separate function. Valentin Bartenev <vbart@nginx.com> parents: 6299 diff changeset	467
6301 b5a87b51be24 Used the pwritev() syscall for writing files where possible. Valentin Bartenev <vbart@nginx.com> parents: 6300 diff changeset	468 #endif
b5a87b51be24 Used the pwritev() syscall for writing files where possible. Valentin Bartenev <vbart@nginx.com> parents: 6300 diff changeset	469
6300 be6af0906a4d Moved file writev() handling code to a separate function. Valentin Bartenev <vbart@nginx.com> parents: 6299 diff changeset	470 file->offset += n;
be6af0906a4d Moved file writev() handling code to a separate function. Valentin Bartenev <vbart@nginx.com> parents: 6299 diff changeset	471
be6af0906a4d Moved file writev() handling code to a separate function. Valentin Bartenev <vbart@nginx.com> parents: 6299 diff changeset	472 return n;
be6af0906a4d Moved file writev() handling code to a separate function. Valentin Bartenev <vbart@nginx.com> parents: 6299 diff changeset	473 }
be6af0906a4d Moved file writev() handling code to a separate function. Valentin Bartenev <vbart@nginx.com> parents: 6299 diff changeset	474
be6af0906a4d Moved file writev() handling code to a separate function. Valentin Bartenev <vbart@nginx.com> parents: 6299 diff changeset	475
6442 6e10518f95d8 Threads: offloading of temp files writing to thread pools. Maxim Dounin <mdounin@mdounin.ru> parents: 6441 diff changeset	476 #if (NGX_THREADS)
6e10518f95d8 Threads: offloading of temp files writing to thread pools. Maxim Dounin <mdounin@mdounin.ru> parents: 6441 diff changeset	477
6e10518f95d8 Threads: offloading of temp files writing to thread pools. Maxim Dounin <mdounin@mdounin.ru> parents: 6441 diff changeset	478 ssize_t
6e10518f95d8 Threads: offloading of temp files writing to thread pools. Maxim Dounin <mdounin@mdounin.ru> parents: 6441 diff changeset	479 ngx_thread_write_chain_to_file(ngx_file_t file, ngx_chain_t cl, off_t offset,
6e10518f95d8 Threads: offloading of temp files writing to thread pools. Maxim Dounin <mdounin@mdounin.ru> parents: 6441 diff changeset	480 ngx_pool_t *pool)
6e10518f95d8 Threads: offloading of temp files writing to thread pools. Maxim Dounin <mdounin@mdounin.ru> parents: 6441 diff changeset	481 {
6e10518f95d8 Threads: offloading of temp files writing to thread pools. Maxim Dounin <mdounin@mdounin.ru> parents: 6441 diff changeset	482 ngx_thread_task_t *task;
6e10518f95d8 Threads: offloading of temp files writing to thread pools. Maxim Dounin <mdounin@mdounin.ru> parents: 6441 diff changeset	483 ngx_thread_file_ctx_t *ctx;
6e10518f95d8 Threads: offloading of temp files writing to thread pools. Maxim Dounin <mdounin@mdounin.ru> parents: 6441 diff changeset	484
6e10518f95d8 Threads: offloading of temp files writing to thread pools. Maxim Dounin <mdounin@mdounin.ru> parents: 6441 diff changeset	485 ngx_log_debug3(NGX_LOG_DEBUG_CORE, file->log, 0,
6e10518f95d8 Threads: offloading of temp files writing to thread pools. Maxim Dounin <mdounin@mdounin.ru> parents: 6441 diff changeset	486 "thread write chain: %d, %p, %O",
6e10518f95d8 Threads: offloading of temp files writing to thread pools. Maxim Dounin <mdounin@mdounin.ru> parents: 6441 diff changeset	487 file->fd, cl, offset);
6e10518f95d8 Threads: offloading of temp files writing to thread pools. Maxim Dounin <mdounin@mdounin.ru> parents: 6441 diff changeset	488
6e10518f95d8 Threads: offloading of temp files writing to thread pools. Maxim Dounin <mdounin@mdounin.ru> parents: 6441 diff changeset	489 task = file->thread_task;
6e10518f95d8 Threads: offloading of temp files writing to thread pools. Maxim Dounin <mdounin@mdounin.ru> parents: 6441 diff changeset	490
6e10518f95d8 Threads: offloading of temp files writing to thread pools. Maxim Dounin <mdounin@mdounin.ru> parents: 6441 diff changeset	491 if (task == NULL) {
6e10518f95d8 Threads: offloading of temp files writing to thread pools. Maxim Dounin <mdounin@mdounin.ru> parents: 6441 diff changeset	492 task = ngx_thread_task_alloc(pool,
6e10518f95d8 Threads: offloading of temp files writing to thread pools. Maxim Dounin <mdounin@mdounin.ru> parents: 6441 diff changeset	493 sizeof(ngx_thread_file_ctx_t));
6e10518f95d8 Threads: offloading of temp files writing to thread pools. Maxim Dounin <mdounin@mdounin.ru> parents: 6441 diff changeset	494 if (task == NULL) {
6e10518f95d8 Threads: offloading of temp files writing to thread pools. Maxim Dounin <mdounin@mdounin.ru> parents: 6441 diff changeset	495 return NGX_ERROR;
6e10518f95d8 Threads: offloading of temp files writing to thread pools. Maxim Dounin <mdounin@mdounin.ru> parents: 6441 diff changeset	496 }
6e10518f95d8 Threads: offloading of temp files writing to thread pools. Maxim Dounin <mdounin@mdounin.ru> parents: 6441 diff changeset	497
9202 e88cdaa0f1ff AIO operations now add timers (ticket #2162). Maxim Dounin <mdounin@mdounin.ru> parents: 7670 diff changeset	498 task->event.log = file->log;
e88cdaa0f1ff AIO operations now add timers (ticket #2162). Maxim Dounin <mdounin@mdounin.ru> parents: 7670 diff changeset	499
6442 6e10518f95d8 Threads: offloading of temp files writing to thread pools. Maxim Dounin <mdounin@mdounin.ru> parents: 6441 diff changeset	500 file->thread_task = task;
6e10518f95d8 Threads: offloading of temp files writing to thread pools. Maxim Dounin <mdounin@mdounin.ru> parents: 6441 diff changeset	501 }
6e10518f95d8 Threads: offloading of temp files writing to thread pools. Maxim Dounin <mdounin@mdounin.ru> parents: 6441 diff changeset	502
6e10518f95d8 Threads: offloading of temp files writing to thread pools. Maxim Dounin <mdounin@mdounin.ru> parents: 6441 diff changeset	503 ctx = task->ctx;
6e10518f95d8 Threads: offloading of temp files writing to thread pools. Maxim Dounin <mdounin@mdounin.ru> parents: 6441 diff changeset	504
6e10518f95d8 Threads: offloading of temp files writing to thread pools. Maxim Dounin <mdounin@mdounin.ru> parents: 6441 diff changeset	505 if (task->event.complete) {
6e10518f95d8 Threads: offloading of temp files writing to thread pools. Maxim Dounin <mdounin@mdounin.ru> parents: 6441 diff changeset	506 task->event.complete = 0;
6e10518f95d8 Threads: offloading of temp files writing to thread pools. Maxim Dounin <mdounin@mdounin.ru> parents: 6441 diff changeset	507
6e10518f95d8 Threads: offloading of temp files writing to thread pools. Maxim Dounin <mdounin@mdounin.ru> parents: 6441 diff changeset	508 if (!ctx->write) {
6e10518f95d8 Threads: offloading of temp files writing to thread pools. Maxim Dounin <mdounin@mdounin.ru> parents: 6441 diff changeset	509 ngx_log_error(NGX_LOG_ALERT, file->log, 0,
6e10518f95d8 Threads: offloading of temp files writing to thread pools. Maxim Dounin <mdounin@mdounin.ru> parents: 6441 diff changeset	510 "invalid thread call, write instead of read");
6e10518f95d8 Threads: offloading of temp files writing to thread pools. Maxim Dounin <mdounin@mdounin.ru> parents: 6441 diff changeset	511 return NGX_ERROR;
6e10518f95d8 Threads: offloading of temp files writing to thread pools. Maxim Dounin <mdounin@mdounin.ru> parents: 6441 diff changeset	512 }
6e10518f95d8 Threads: offloading of temp files writing to thread pools. Maxim Dounin <mdounin@mdounin.ru> parents: 6441 diff changeset	513
6e10518f95d8 Threads: offloading of temp files writing to thread pools. Maxim Dounin <mdounin@mdounin.ru> parents: 6441 diff changeset	514 if (ctx->err \|\| ctx->nbytes == 0) {
6e10518f95d8 Threads: offloading of temp files writing to thread pools. Maxim Dounin <mdounin@mdounin.ru> parents: 6441 diff changeset	515 ngx_log_error(NGX_LOG_CRIT, file->log, ctx->err,
6e10518f95d8 Threads: offloading of temp files writing to thread pools. Maxim Dounin <mdounin@mdounin.ru> parents: 6441 diff changeset	516 "pwritev() \"%s\" failed", file->name.data);
6e10518f95d8 Threads: offloading of temp files writing to thread pools. Maxim Dounin <mdounin@mdounin.ru> parents: 6441 diff changeset	517 return NGX_ERROR;
6e10518f95d8 Threads: offloading of temp files writing to thread pools. Maxim Dounin <mdounin@mdounin.ru> parents: 6441 diff changeset	518 }
6e10518f95d8 Threads: offloading of temp files writing to thread pools. Maxim Dounin <mdounin@mdounin.ru> parents: 6441 diff changeset	519
6e10518f95d8 Threads: offloading of temp files writing to thread pools. Maxim Dounin <mdounin@mdounin.ru> parents: 6441 diff changeset	520 file->offset += ctx->nbytes;
6e10518f95d8 Threads: offloading of temp files writing to thread pools. Maxim Dounin <mdounin@mdounin.ru> parents: 6441 diff changeset	521 return ctx->nbytes;
6e10518f95d8 Threads: offloading of temp files writing to thread pools. Maxim Dounin <mdounin@mdounin.ru> parents: 6441 diff changeset	522 }
6e10518f95d8 Threads: offloading of temp files writing to thread pools. Maxim Dounin <mdounin@mdounin.ru> parents: 6441 diff changeset	523
6e10518f95d8 Threads: offloading of temp files writing to thread pools. Maxim Dounin <mdounin@mdounin.ru> parents: 6441 diff changeset	524 task->handler = ngx_thread_write_chain_to_file_handler;
6e10518f95d8 Threads: offloading of temp files writing to thread pools. Maxim Dounin <mdounin@mdounin.ru> parents: 6441 diff changeset	525
6e10518f95d8 Threads: offloading of temp files writing to thread pools. Maxim Dounin <mdounin@mdounin.ru> parents: 6441 diff changeset	526 ctx->write = 1;
6e10518f95d8 Threads: offloading of temp files writing to thread pools. Maxim Dounin <mdounin@mdounin.ru> parents: 6441 diff changeset	527
6e10518f95d8 Threads: offloading of temp files writing to thread pools. Maxim Dounin <mdounin@mdounin.ru> parents: 6441 diff changeset	528 ctx->fd = file->fd;
6e10518f95d8 Threads: offloading of temp files writing to thread pools. Maxim Dounin <mdounin@mdounin.ru> parents: 6441 diff changeset	529 ctx->chain = cl;
6e10518f95d8 Threads: offloading of temp files writing to thread pools. Maxim Dounin <mdounin@mdounin.ru> parents: 6441 diff changeset	530 ctx->offset = offset;
6e10518f95d8 Threads: offloading of temp files writing to thread pools. Maxim Dounin <mdounin@mdounin.ru> parents: 6441 diff changeset	531
6e10518f95d8 Threads: offloading of temp files writing to thread pools. Maxim Dounin <mdounin@mdounin.ru> parents: 6441 diff changeset	532 if (file->thread_handler(task, file) != NGX_OK) {
6e10518f95d8 Threads: offloading of temp files writing to thread pools. Maxim Dounin <mdounin@mdounin.ru> parents: 6441 diff changeset	533 return NGX_ERROR;
6e10518f95d8 Threads: offloading of temp files writing to thread pools. Maxim Dounin <mdounin@mdounin.ru> parents: 6441 diff changeset	534 }
6e10518f95d8 Threads: offloading of temp files writing to thread pools. Maxim Dounin <mdounin@mdounin.ru> parents: 6441 diff changeset	535
6e10518f95d8 Threads: offloading of temp files writing to thread pools. Maxim Dounin <mdounin@mdounin.ru> parents: 6441 diff changeset	536 return NGX_AGAIN;
6e10518f95d8 Threads: offloading of temp files writing to thread pools. Maxim Dounin <mdounin@mdounin.ru> parents: 6441 diff changeset	537 }
6e10518f95d8 Threads: offloading of temp files writing to thread pools. Maxim Dounin <mdounin@mdounin.ru> parents: 6441 diff changeset	538
6e10518f95d8 Threads: offloading of temp files writing to thread pools. Maxim Dounin <mdounin@mdounin.ru> parents: 6441 diff changeset	539
6e10518f95d8 Threads: offloading of temp files writing to thread pools. Maxim Dounin <mdounin@mdounin.ru> parents: 6441 diff changeset	540 static void
6e10518f95d8 Threads: offloading of temp files writing to thread pools. Maxim Dounin <mdounin@mdounin.ru> parents: 6441 diff changeset	541 ngx_thread_write_chain_to_file_handler(void data, ngx_log_t log)
6e10518f95d8 Threads: offloading of temp files writing to thread pools. Maxim Dounin <mdounin@mdounin.ru> parents: 6441 diff changeset	542 {
6e10518f95d8 Threads: offloading of temp files writing to thread pools. Maxim Dounin <mdounin@mdounin.ru> parents: 6441 diff changeset	543 ngx_thread_file_ctx_t *ctx = data;
6e10518f95d8 Threads: offloading of temp files writing to thread pools. Maxim Dounin <mdounin@mdounin.ru> parents: 6441 diff changeset	544
6e10518f95d8 Threads: offloading of temp files writing to thread pools. Maxim Dounin <mdounin@mdounin.ru> parents: 6441 diff changeset	545 #if (NGX_HAVE_PWRITEV)
6e10518f95d8 Threads: offloading of temp files writing to thread pools. Maxim Dounin <mdounin@mdounin.ru> parents: 6441 diff changeset	546
6e10518f95d8 Threads: offloading of temp files writing to thread pools. Maxim Dounin <mdounin@mdounin.ru> parents: 6441 diff changeset	547 off_t offset;
6e10518f95d8 Threads: offloading of temp files writing to thread pools. Maxim Dounin <mdounin@mdounin.ru> parents: 6441 diff changeset	548 ssize_t n;
6e10518f95d8 Threads: offloading of temp files writing to thread pools. Maxim Dounin <mdounin@mdounin.ru> parents: 6441 diff changeset	549 ngx_err_t err;
6e10518f95d8 Threads: offloading of temp files writing to thread pools. Maxim Dounin <mdounin@mdounin.ru> parents: 6441 diff changeset	550 ngx_chain_t *cl;
6e10518f95d8 Threads: offloading of temp files writing to thread pools. Maxim Dounin <mdounin@mdounin.ru> parents: 6441 diff changeset	551 ngx_iovec_t vec;
6e10518f95d8 Threads: offloading of temp files writing to thread pools. Maxim Dounin <mdounin@mdounin.ru> parents: 6441 diff changeset	552 struct iovec iovs[NGX_IOVS_PREALLOCATE];
6e10518f95d8 Threads: offloading of temp files writing to thread pools. Maxim Dounin <mdounin@mdounin.ru> parents: 6441 diff changeset	553
6e10518f95d8 Threads: offloading of temp files writing to thread pools. Maxim Dounin <mdounin@mdounin.ru> parents: 6441 diff changeset	554 vec.iovs = iovs;
6e10518f95d8 Threads: offloading of temp files writing to thread pools. Maxim Dounin <mdounin@mdounin.ru> parents: 6441 diff changeset	555 vec.nalloc = NGX_IOVS_PREALLOCATE;
6e10518f95d8 Threads: offloading of temp files writing to thread pools. Maxim Dounin <mdounin@mdounin.ru> parents: 6441 diff changeset	556
6e10518f95d8 Threads: offloading of temp files writing to thread pools. Maxim Dounin <mdounin@mdounin.ru> parents: 6441 diff changeset	557 cl = ctx->chain;
6e10518f95d8 Threads: offloading of temp files writing to thread pools. Maxim Dounin <mdounin@mdounin.ru> parents: 6441 diff changeset	558 offset = ctx->offset;
6e10518f95d8 Threads: offloading of temp files writing to thread pools. Maxim Dounin <mdounin@mdounin.ru> parents: 6441 diff changeset	559
6e10518f95d8 Threads: offloading of temp files writing to thread pools. Maxim Dounin <mdounin@mdounin.ru> parents: 6441 diff changeset	560 ctx->nbytes = 0;
6e10518f95d8 Threads: offloading of temp files writing to thread pools. Maxim Dounin <mdounin@mdounin.ru> parents: 6441 diff changeset	561 ctx->err = 0;
6e10518f95d8 Threads: offloading of temp files writing to thread pools. Maxim Dounin <mdounin@mdounin.ru> parents: 6441 diff changeset	562
6e10518f95d8 Threads: offloading of temp files writing to thread pools. Maxim Dounin <mdounin@mdounin.ru> parents: 6441 diff changeset	563 do {
6e10518f95d8 Threads: offloading of temp files writing to thread pools. Maxim Dounin <mdounin@mdounin.ru> parents: 6441 diff changeset	564 /* create the iovec and coalesce the neighbouring bufs */
6e10518f95d8 Threads: offloading of temp files writing to thread pools. Maxim Dounin <mdounin@mdounin.ru> parents: 6441 diff changeset	565 cl = ngx_chain_to_iovec(&vec, cl);
6e10518f95d8 Threads: offloading of temp files writing to thread pools. Maxim Dounin <mdounin@mdounin.ru> parents: 6441 diff changeset	566
6e10518f95d8 Threads: offloading of temp files writing to thread pools. Maxim Dounin <mdounin@mdounin.ru> parents: 6441 diff changeset	567 eintr:
6e10518f95d8 Threads: offloading of temp files writing to thread pools. Maxim Dounin <mdounin@mdounin.ru> parents: 6441 diff changeset	568
6e10518f95d8 Threads: offloading of temp files writing to thread pools. Maxim Dounin <mdounin@mdounin.ru> parents: 6441 diff changeset	569 n = pwritev(ctx->fd, iovs, vec.count, offset);
6e10518f95d8 Threads: offloading of temp files writing to thread pools. Maxim Dounin <mdounin@mdounin.ru> parents: 6441 diff changeset	570
6e10518f95d8 Threads: offloading of temp files writing to thread pools. Maxim Dounin <mdounin@mdounin.ru> parents: 6441 diff changeset	571 if (n == -1) {
6e10518f95d8 Threads: offloading of temp files writing to thread pools. Maxim Dounin <mdounin@mdounin.ru> parents: 6441 diff changeset	572 err = ngx_errno;
6e10518f95d8 Threads: offloading of temp files writing to thread pools. Maxim Dounin <mdounin@mdounin.ru> parents: 6441 diff changeset	573
6e10518f95d8 Threads: offloading of temp files writing to thread pools. Maxim Dounin <mdounin@mdounin.ru> parents: 6441 diff changeset	574 if (err == NGX_EINTR) {
6e10518f95d8 Threads: offloading of temp files writing to thread pools. Maxim Dounin <mdounin@mdounin.ru> parents: 6441 diff changeset	575 ngx_log_debug0(NGX_LOG_DEBUG_CORE, log, err,
6e10518f95d8 Threads: offloading of temp files writing to thread pools. Maxim Dounin <mdounin@mdounin.ru> parents: 6441 diff changeset	576 "pwritev() was interrupted");
6e10518f95d8 Threads: offloading of temp files writing to thread pools. Maxim Dounin <mdounin@mdounin.ru> parents: 6441 diff changeset	577 goto eintr;
6e10518f95d8 Threads: offloading of temp files writing to thread pools. Maxim Dounin <mdounin@mdounin.ru> parents: 6441 diff changeset	578 }
6e10518f95d8 Threads: offloading of temp files writing to thread pools. Maxim Dounin <mdounin@mdounin.ru> parents: 6441 diff changeset	579
6e10518f95d8 Threads: offloading of temp files writing to thread pools. Maxim Dounin <mdounin@mdounin.ru> parents: 6441 diff changeset	580 ctx->err = err;
6e10518f95d8 Threads: offloading of temp files writing to thread pools. Maxim Dounin <mdounin@mdounin.ru> parents: 6441 diff changeset	581 return;
6e10518f95d8 Threads: offloading of temp files writing to thread pools. Maxim Dounin <mdounin@mdounin.ru> parents: 6441 diff changeset	582 }
6e10518f95d8 Threads: offloading of temp files writing to thread pools. Maxim Dounin <mdounin@mdounin.ru> parents: 6441 diff changeset	583
6e10518f95d8 Threads: offloading of temp files writing to thread pools. Maxim Dounin <mdounin@mdounin.ru> parents: 6441 diff changeset	584 if ((size_t) n != vec.size) {
6e10518f95d8 Threads: offloading of temp files writing to thread pools. Maxim Dounin <mdounin@mdounin.ru> parents: 6441 diff changeset	585 ctx->nbytes = 0;
6e10518f95d8 Threads: offloading of temp files writing to thread pools. Maxim Dounin <mdounin@mdounin.ru> parents: 6441 diff changeset	586 return;
6e10518f95d8 Threads: offloading of temp files writing to thread pools. Maxim Dounin <mdounin@mdounin.ru> parents: 6441 diff changeset	587 }
6e10518f95d8 Threads: offloading of temp files writing to thread pools. Maxim Dounin <mdounin@mdounin.ru> parents: 6441 diff changeset	588
6e10518f95d8 Threads: offloading of temp files writing to thread pools. Maxim Dounin <mdounin@mdounin.ru> parents: 6441 diff changeset	589 ctx->nbytes += n;
6e10518f95d8 Threads: offloading of temp files writing to thread pools. Maxim Dounin <mdounin@mdounin.ru> parents: 6441 diff changeset	590 offset += n;
6e10518f95d8 Threads: offloading of temp files writing to thread pools. Maxim Dounin <mdounin@mdounin.ru> parents: 6441 diff changeset	591 } while (cl);
6e10518f95d8 Threads: offloading of temp files writing to thread pools. Maxim Dounin <mdounin@mdounin.ru> parents: 6441 diff changeset	592
6e10518f95d8 Threads: offloading of temp files writing to thread pools. Maxim Dounin <mdounin@mdounin.ru> parents: 6441 diff changeset	593 #else
6e10518f95d8 Threads: offloading of temp files writing to thread pools. Maxim Dounin <mdounin@mdounin.ru> parents: 6441 diff changeset	594
6e10518f95d8 Threads: offloading of temp files writing to thread pools. Maxim Dounin <mdounin@mdounin.ru> parents: 6441 diff changeset	595 ctx->err = NGX_ENOSYS;
6e10518f95d8 Threads: offloading of temp files writing to thread pools. Maxim Dounin <mdounin@mdounin.ru> parents: 6441 diff changeset	596 return;
6e10518f95d8 Threads: offloading of temp files writing to thread pools. Maxim Dounin <mdounin@mdounin.ru> parents: 6441 diff changeset	597
6e10518f95d8 Threads: offloading of temp files writing to thread pools. Maxim Dounin <mdounin@mdounin.ru> parents: 6441 diff changeset	598 #endif
6e10518f95d8 Threads: offloading of temp files writing to thread pools. Maxim Dounin <mdounin@mdounin.ru> parents: 6441 diff changeset	599 }
6e10518f95d8 Threads: offloading of temp files writing to thread pools. Maxim Dounin <mdounin@mdounin.ru> parents: 6441 diff changeset	600
6e10518f95d8 Threads: offloading of temp files writing to thread pools. Maxim Dounin <mdounin@mdounin.ru> parents: 6441 diff changeset	601 #endif /* NGX_THREADS */
6e10518f95d8 Threads: offloading of temp files writing to thread pools. Maxim Dounin <mdounin@mdounin.ru> parents: 6441 diff changeset	602
6e10518f95d8 Threads: offloading of temp files writing to thread pools. Maxim Dounin <mdounin@mdounin.ru> parents: 6441 diff changeset	603
561 e48ebafc6939 nginx-0.3.2-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 501 diff changeset	604 ngx_int_t
681 7e24168b0853 nginx-0.4.0-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 633 diff changeset	605 ngx_set_file_time(u_char *name, ngx_fd_t fd, time_t s)
7e24168b0853 nginx-0.4.0-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 633 diff changeset	606 {
7e24168b0853 nginx-0.4.0-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 633 diff changeset	607 struct timeval tv[2];
7e24168b0853 nginx-0.4.0-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 633 diff changeset	608
3861 cf80c0b0109a set current atime while setting mtime Igor Sysoev <igor@sysoev.ru> parents: 3657 diff changeset	609 tv[0].tv_sec = ngx_time();
681 7e24168b0853 nginx-0.4.0-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 633 diff changeset	610 tv[0].tv_usec = 0;
7e24168b0853 nginx-0.4.0-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 633 diff changeset	611 tv[1].tv_sec = s;
7e24168b0853 nginx-0.4.0-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 633 diff changeset	612 tv[1].tv_usec = 0;
7e24168b0853 nginx-0.4.0-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 633 diff changeset	613
7e24168b0853 nginx-0.4.0-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 633 diff changeset	614 if (utimes((char *) name, tv) != -1) {
7e24168b0853 nginx-0.4.0-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 633 diff changeset	615 return NGX_OK;
7e24168b0853 nginx-0.4.0-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 633 diff changeset	616 }
7e24168b0853 nginx-0.4.0-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 633 diff changeset	617
7e24168b0853 nginx-0.4.0-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 633 diff changeset	618 return NGX_ERROR;
7e24168b0853 nginx-0.4.0-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 633 diff changeset	619 }
7e24168b0853 nginx-0.4.0-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 633 diff changeset	620
7e24168b0853 nginx-0.4.0-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 633 diff changeset	621
7e24168b0853 nginx-0.4.0-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 633 diff changeset	622 ngx_int_t
3651 515d50917016 ngx_create_file_mapping() Igor Sysoev <igor@sysoev.ru> parents: 3322 diff changeset	623 ngx_create_file_mapping(ngx_file_mapping_t *fm)
515d50917016 ngx_create_file_mapping() Igor Sysoev <igor@sysoev.ru> parents: 3322 diff changeset	624 {
515d50917016 ngx_create_file_mapping() Igor Sysoev <igor@sysoev.ru> parents: 3322 diff changeset	625 fm->fd = ngx_open_file(fm->name, NGX_FILE_RDWR, NGX_FILE_TRUNCATE,
515d50917016 ngx_create_file_mapping() Igor Sysoev <igor@sysoev.ru> parents: 3322 diff changeset	626 NGX_FILE_DEFAULT_ACCESS);
7086 577628e6b6a6 Style. Sergey Kandaurov <pluknet@nginx.com> parents: 6574 diff changeset	627
3651 515d50917016 ngx_create_file_mapping() Igor Sysoev <igor@sysoev.ru> parents: 3322 diff changeset	628 if (fm->fd == NGX_INVALID_FILE) {
515d50917016 ngx_create_file_mapping() Igor Sysoev <igor@sysoev.ru> parents: 3322 diff changeset	629 ngx_log_error(NGX_LOG_CRIT, fm->log, ngx_errno,
515d50917016 ngx_create_file_mapping() Igor Sysoev <igor@sysoev.ru> parents: 3322 diff changeset	630 ngx_open_file_n " \"%s\" failed", fm->name);
515d50917016 ngx_create_file_mapping() Igor Sysoev <igor@sysoev.ru> parents: 3322 diff changeset	631 return NGX_ERROR;
515d50917016 ngx_create_file_mapping() Igor Sysoev <igor@sysoev.ru> parents: 3322 diff changeset	632 }
515d50917016 ngx_create_file_mapping() Igor Sysoev <igor@sysoev.ru> parents: 3322 diff changeset	633
515d50917016 ngx_create_file_mapping() Igor Sysoev <igor@sysoev.ru> parents: 3322 diff changeset	634 if (ftruncate(fm->fd, fm->size) == -1) {
515d50917016 ngx_create_file_mapping() Igor Sysoev <igor@sysoev.ru> parents: 3322 diff changeset	635 ngx_log_error(NGX_LOG_CRIT, fm->log, ngx_errno,
515d50917016 ngx_create_file_mapping() Igor Sysoev <igor@sysoev.ru> parents: 3322 diff changeset	636 "ftruncate() \"%s\" failed", fm->name);
515d50917016 ngx_create_file_mapping() Igor Sysoev <igor@sysoev.ru> parents: 3322 diff changeset	637 goto failed;
515d50917016 ngx_create_file_mapping() Igor Sysoev <igor@sysoev.ru> parents: 3322 diff changeset	638 }
515d50917016 ngx_create_file_mapping() Igor Sysoev <igor@sysoev.ru> parents: 3322 diff changeset	639
515d50917016 ngx_create_file_mapping() Igor Sysoev <igor@sysoev.ru> parents: 3322 diff changeset	640 fm->addr = mmap(NULL, fm->size, PROT_READ\|PROT_WRITE, MAP_SHARED,
515d50917016 ngx_create_file_mapping() Igor Sysoev <igor@sysoev.ru> parents: 3322 diff changeset	641 fm->fd, 0);
515d50917016 ngx_create_file_mapping() Igor Sysoev <igor@sysoev.ru> parents: 3322 diff changeset	642 if (fm->addr != MAP_FAILED) {
515d50917016 ngx_create_file_mapping() Igor Sysoev <igor@sysoev.ru> parents: 3322 diff changeset	643 return NGX_OK;
515d50917016 ngx_create_file_mapping() Igor Sysoev <igor@sysoev.ru> parents: 3322 diff changeset	644 }
515d50917016 ngx_create_file_mapping() Igor Sysoev <igor@sysoev.ru> parents: 3322 diff changeset	645
515d50917016 ngx_create_file_mapping() Igor Sysoev <igor@sysoev.ru> parents: 3322 diff changeset	646 ngx_log_error(NGX_LOG_CRIT, fm->log, ngx_errno,
515d50917016 ngx_create_file_mapping() Igor Sysoev <igor@sysoev.ru> parents: 3322 diff changeset	647 "mmap(%uz) \"%s\" failed", fm->size, fm->name);
515d50917016 ngx_create_file_mapping() Igor Sysoev <igor@sysoev.ru> parents: 3322 diff changeset	648
515d50917016 ngx_create_file_mapping() Igor Sysoev <igor@sysoev.ru> parents: 3322 diff changeset	649 failed:
515d50917016 ngx_create_file_mapping() Igor Sysoev <igor@sysoev.ru> parents: 3322 diff changeset	650
515d50917016 ngx_create_file_mapping() Igor Sysoev <igor@sysoev.ru> parents: 3322 diff changeset	651 if (ngx_close_file(fm->fd) == NGX_FILE_ERROR) {
515d50917016 ngx_create_file_mapping() Igor Sysoev <igor@sysoev.ru> parents: 3322 diff changeset	652 ngx_log_error(NGX_LOG_ALERT, fm->log, ngx_errno,
515d50917016 ngx_create_file_mapping() Igor Sysoev <igor@sysoev.ru> parents: 3322 diff changeset	653 ngx_close_file_n " \"%s\" failed", fm->name);
515d50917016 ngx_create_file_mapping() Igor Sysoev <igor@sysoev.ru> parents: 3322 diff changeset	654 }
515d50917016 ngx_create_file_mapping() Igor Sysoev <igor@sysoev.ru> parents: 3322 diff changeset	655
515d50917016 ngx_create_file_mapping() Igor Sysoev <igor@sysoev.ru> parents: 3322 diff changeset	656 return NGX_ERROR;
515d50917016 ngx_create_file_mapping() Igor Sysoev <igor@sysoev.ru> parents: 3322 diff changeset	657 }
515d50917016 ngx_create_file_mapping() Igor Sysoev <igor@sysoev.ru> parents: 3322 diff changeset	658
515d50917016 ngx_create_file_mapping() Igor Sysoev <igor@sysoev.ru> parents: 3322 diff changeset	659
515d50917016 ngx_create_file_mapping() Igor Sysoev <igor@sysoev.ru> parents: 3322 diff changeset	660 void
515d50917016 ngx_create_file_mapping() Igor Sysoev <igor@sysoev.ru> parents: 3322 diff changeset	661 ngx_close_file_mapping(ngx_file_mapping_t *fm)
515d50917016 ngx_create_file_mapping() Igor Sysoev <igor@sysoev.ru> parents: 3322 diff changeset	662 {
515d50917016 ngx_create_file_mapping() Igor Sysoev <igor@sysoev.ru> parents: 3322 diff changeset	663 if (munmap(fm->addr, fm->size) == -1) {
515d50917016 ngx_create_file_mapping() Igor Sysoev <igor@sysoev.ru> parents: 3322 diff changeset	664 ngx_log_error(NGX_LOG_CRIT, fm->log, ngx_errno,
515d50917016 ngx_create_file_mapping() Igor Sysoev <igor@sysoev.ru> parents: 3322 diff changeset	665 "munmap(%uz) \"%s\" failed", fm->size, fm->name);
515d50917016 ngx_create_file_mapping() Igor Sysoev <igor@sysoev.ru> parents: 3322 diff changeset	666 }
515d50917016 ngx_create_file_mapping() Igor Sysoev <igor@sysoev.ru> parents: 3322 diff changeset	667
515d50917016 ngx_create_file_mapping() Igor Sysoev <igor@sysoev.ru> parents: 3322 diff changeset	668 if (ngx_close_file(fm->fd) == NGX_FILE_ERROR) {
515d50917016 ngx_create_file_mapping() Igor Sysoev <igor@sysoev.ru> parents: 3322 diff changeset	669 ngx_log_error(NGX_LOG_ALERT, fm->log, ngx_errno,
515d50917016 ngx_create_file_mapping() Igor Sysoev <igor@sysoev.ru> parents: 3322 diff changeset	670 ngx_close_file_n " \"%s\" failed", fm->name);
515d50917016 ngx_create_file_mapping() Igor Sysoev <igor@sysoev.ru> parents: 3322 diff changeset	671 }
515d50917016 ngx_create_file_mapping() Igor Sysoev <igor@sysoev.ru> parents: 3322 diff changeset	672 }
515d50917016 ngx_create_file_mapping() Igor Sysoev <igor@sysoev.ru> parents: 3322 diff changeset	673
515d50917016 ngx_create_file_mapping() Igor Sysoev <igor@sysoev.ru> parents: 3322 diff changeset	674
515d50917016 ngx_create_file_mapping() Igor Sysoev <igor@sysoev.ru> parents: 3322 diff changeset	675 ngx_int_t
561 e48ebafc6939 nginx-0.3.2-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 501 diff changeset	676 ngx_open_dir(ngx_str_t name, ngx_dir_t dir)
186 c1f3a3c7c5db nginx-0.0.1-2003-11-17-00:49:42 import Igor Sysoev <igor@sysoev.ru> parents: 182 diff changeset	677 {
290 87e73f067470 nginx-0.0.2-2004-03-16-10:10:12 import Igor Sysoev <igor@sysoev.ru> parents: 278 diff changeset	678 dir->dir = opendir((const char *) name->data);
186 c1f3a3c7c5db nginx-0.0.1-2003-11-17-00:49:42 import Igor Sysoev <igor@sysoev.ru> parents: 182 diff changeset	679
c1f3a3c7c5db nginx-0.0.1-2003-11-17-00:49:42 import Igor Sysoev <igor@sysoev.ru> parents: 182 diff changeset	680 if (dir->dir == NULL) {
c1f3a3c7c5db nginx-0.0.1-2003-11-17-00:49:42 import Igor Sysoev <igor@sysoev.ru> parents: 182 diff changeset	681 return NGX_ERROR;
c1f3a3c7c5db nginx-0.0.1-2003-11-17-00:49:42 import Igor Sysoev <igor@sysoev.ru> parents: 182 diff changeset	682 }
c1f3a3c7c5db nginx-0.0.1-2003-11-17-00:49:42 import Igor Sysoev <igor@sysoev.ru> parents: 182 diff changeset	683
457 ded1284520cc nginx-0.1.3-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 455 diff changeset	684 dir->valid_info = 0;
186 c1f3a3c7c5db nginx-0.0.1-2003-11-17-00:49:42 import Igor Sysoev <igor@sysoev.ru> parents: 182 diff changeset	685
c1f3a3c7c5db nginx-0.0.1-2003-11-17-00:49:42 import Igor Sysoev <igor@sysoev.ru> parents: 182 diff changeset	686 return NGX_OK;
c1f3a3c7c5db nginx-0.0.1-2003-11-17-00:49:42 import Igor Sysoev <igor@sysoev.ru> parents: 182 diff changeset	687 }
561 e48ebafc6939 nginx-0.3.2-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 501 diff changeset	688
e48ebafc6939 nginx-0.3.2-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 501 diff changeset	689
727 532d15ddbe68 glob support in include Igor Sysoev <igor@sysoev.ru> parents: 681 diff changeset	690 ngx_int_t
2234 c7c319896bb4 ) autoconfigure struct dirent capabilities Igor Sysoev <igor@sysoev.ru>* parents: 2210 diff changeset	691 ngx_read_dir(ngx_dir_t *dir)
c7c319896bb4 ) autoconfigure struct dirent capabilities Igor Sysoev <igor@sysoev.ru>* parents: 2210 diff changeset	692 {
c7c319896bb4 ) autoconfigure struct dirent capabilities Igor Sysoev <igor@sysoev.ru>* parents: 2210 diff changeset	693 dir->de = readdir(dir->dir);
c7c319896bb4 ) autoconfigure struct dirent capabilities Igor Sysoev <igor@sysoev.ru>* parents: 2210 diff changeset	694
c7c319896bb4 ) autoconfigure struct dirent capabilities Igor Sysoev <igor@sysoev.ru>* parents: 2210 diff changeset	695 if (dir->de) {
c7c319896bb4 ) autoconfigure struct dirent capabilities Igor Sysoev <igor@sysoev.ru>* parents: 2210 diff changeset	696 #if (NGX_HAVE_D_TYPE)
c7c319896bb4 ) autoconfigure struct dirent capabilities Igor Sysoev <igor@sysoev.ru>* parents: 2210 diff changeset	697 dir->type = dir->de->d_type;
2550 5e87ddb4764f XFS on Linux does not set dirent.d_type, Igor Sysoev <igor@sysoev.ru> parents: 2248 diff changeset	698 #else
3200 26784c34e8be ) reset cached dirent.d_type after stat() Igor Sysoev <igor@sysoev.ru>* parents: 3164 diff changeset	699 dir->type = 0;
2234 c7c319896bb4 ) autoconfigure struct dirent capabilities Igor Sysoev <igor@sysoev.ru>* parents: 2210 diff changeset	700 #endif
c7c319896bb4 ) autoconfigure struct dirent capabilities Igor Sysoev <igor@sysoev.ru>* parents: 2210 diff changeset	701 return NGX_OK;
c7c319896bb4 ) autoconfigure struct dirent capabilities Igor Sysoev <igor@sysoev.ru>* parents: 2210 diff changeset	702 }
c7c319896bb4 ) autoconfigure struct dirent capabilities Igor Sysoev <igor@sysoev.ru>* parents: 2210 diff changeset	703
c7c319896bb4 ) autoconfigure struct dirent capabilities Igor Sysoev <igor@sysoev.ru>* parents: 2210 diff changeset	704 return NGX_ERROR;
c7c319896bb4 ) autoconfigure struct dirent capabilities Igor Sysoev <igor@sysoev.ru>* parents: 2210 diff changeset	705 }
c7c319896bb4 ) autoconfigure struct dirent capabilities Igor Sysoev <igor@sysoev.ru>* parents: 2210 diff changeset	706
c7c319896bb4 ) autoconfigure struct dirent capabilities Igor Sysoev <igor@sysoev.ru>* parents: 2210 diff changeset	707
c7c319896bb4 ) autoconfigure struct dirent capabilities Igor Sysoev <igor@sysoev.ru>* parents: 2210 diff changeset	708 ngx_int_t
727 532d15ddbe68 glob support in include Igor Sysoev <igor@sysoev.ru> parents: 681 diff changeset	709 ngx_open_glob(ngx_glob_t *gl)
532d15ddbe68 glob support in include Igor Sysoev <igor@sysoev.ru> parents: 681 diff changeset	710 {
1980 b5263e401884 ignore glob no match error Igor Sysoev <igor@sysoev.ru> parents: 1046 diff changeset	711 int n;
b5263e401884 ignore glob no match error Igor Sysoev <igor@sysoev.ru> parents: 1046 diff changeset	712
4943 1e2d5d3f9f6b Core: removed GLOB_NOSORT glob option. Maxim Dounin <mdounin@mdounin.ru> parents: 4938 diff changeset	713 n = glob((char *) gl->pattern, 0, NULL, &gl->pglob);
1980 b5263e401884 ignore glob no match error Igor Sysoev <igor@sysoev.ru> parents: 1046 diff changeset	714
b5263e401884 ignore glob no match error Igor Sysoev <igor@sysoev.ru> parents: 1046 diff changeset	715 if (n == 0) {
b5263e401884 ignore glob no match error Igor Sysoev <igor@sysoev.ru> parents: 1046 diff changeset	716 return NGX_OK;
b5263e401884 ignore glob no match error Igor Sysoev <igor@sysoev.ru> parents: 1046 diff changeset	717 }
b5263e401884 ignore glob no match error Igor Sysoev <igor@sysoev.ru> parents: 1046 diff changeset	718
2199 ffb512f0eabd fix building on FreeBSD prior to 4.8, it has no GLOB_NOMATCH Igor Sysoev <igor@sysoev.ru> parents: 2129 diff changeset	719 #ifdef GLOB_NOMATCH
ffb512f0eabd fix building on FreeBSD prior to 4.8, it has no GLOB_NOMATCH Igor Sysoev <igor@sysoev.ru> parents: 2129 diff changeset	720
1980 b5263e401884 ignore glob no match error Igor Sysoev <igor@sysoev.ru> parents: 1046 diff changeset	721 if (n == GLOB_NOMATCH && gl->test) {
727 532d15ddbe68 glob support in include Igor Sysoev <igor@sysoev.ru> parents: 681 diff changeset	722 return NGX_OK;
532d15ddbe68 glob support in include Igor Sysoev <igor@sysoev.ru> parents: 681 diff changeset	723 }
532d15ddbe68 glob support in include Igor Sysoev <igor@sysoev.ru> parents: 681 diff changeset	724
2199 ffb512f0eabd fix building on FreeBSD prior to 4.8, it has no GLOB_NOMATCH Igor Sysoev <igor@sysoev.ru> parents: 2129 diff changeset	725 #endif
ffb512f0eabd fix building on FreeBSD prior to 4.8, it has no GLOB_NOMATCH Igor Sysoev <igor@sysoev.ru> parents: 2129 diff changeset	726
727 532d15ddbe68 glob support in include Igor Sysoev <igor@sysoev.ru> parents: 681 diff changeset	727 return NGX_ERROR;
532d15ddbe68 glob support in include Igor Sysoev <igor@sysoev.ru> parents: 681 diff changeset	728 }
532d15ddbe68 glob support in include Igor Sysoev <igor@sysoev.ru> parents: 681 diff changeset	729
532d15ddbe68 glob support in include Igor Sysoev <igor@sysoev.ru> parents: 681 diff changeset	730
532d15ddbe68 glob support in include Igor Sysoev <igor@sysoev.ru> parents: 681 diff changeset	731 ngx_int_t
532d15ddbe68 glob support in include Igor Sysoev <igor@sysoev.ru> parents: 681 diff changeset	732 ngx_read_glob(ngx_glob_t gl, ngx_str_t name)
532d15ddbe68 glob support in include Igor Sysoev <igor@sysoev.ru> parents: 681 diff changeset	733 {
2210 2cae41e51622 fix build on Linux and Solaris introduced in r2200 Igor Sysoev <igor@sysoev.ru> parents: 2199 diff changeset	734 size_t count;
2cae41e51622 fix build on Linux and Solaris introduced in r2200 Igor Sysoev <igor@sysoev.ru> parents: 2199 diff changeset	735
2cae41e51622 fix build on Linux and Solaris introduced in r2200 Igor Sysoev <igor@sysoev.ru> parents: 2199 diff changeset	736 #ifdef GLOB_NOMATCH
2cae41e51622 fix build on Linux and Solaris introduced in r2200 Igor Sysoev <igor@sysoev.ru> parents: 2199 diff changeset	737 count = (size_t) gl->pglob.gl_pathc;
2cae41e51622 fix build on Linux and Solaris introduced in r2200 Igor Sysoev <igor@sysoev.ru> parents: 2199 diff changeset	738 #else
2cae41e51622 fix build on Linux and Solaris introduced in r2200 Igor Sysoev <igor@sysoev.ru> parents: 2199 diff changeset	739 count = (size_t) gl->pglob.gl_matchc;
2cae41e51622 fix build on Linux and Solaris introduced in r2200 Igor Sysoev <igor@sysoev.ru> parents: 2199 diff changeset	740 #endif
2cae41e51622 fix build on Linux and Solaris introduced in r2200 Igor Sysoev <igor@sysoev.ru> parents: 2199 diff changeset	741
2cae41e51622 fix build on Linux and Solaris introduced in r2200 Igor Sysoev <igor@sysoev.ru> parents: 2199 diff changeset	742 if (gl->n < count) {
727 532d15ddbe68 glob support in include Igor Sysoev <igor@sysoev.ru> parents: 681 diff changeset	743
532d15ddbe68 glob support in include Igor Sysoev <igor@sysoev.ru> parents: 681 diff changeset	744 name->len = (size_t) ngx_strlen(gl->pglob.gl_pathv[gl->n]);
532d15ddbe68 glob support in include Igor Sysoev <igor@sysoev.ru> parents: 681 diff changeset	745 name->data = (u_char *) gl->pglob.gl_pathv[gl->n];
532d15ddbe68 glob support in include Igor Sysoev <igor@sysoev.ru> parents: 681 diff changeset	746 gl->n++;
532d15ddbe68 glob support in include Igor Sysoev <igor@sysoev.ru> parents: 681 diff changeset	747
532d15ddbe68 glob support in include Igor Sysoev <igor@sysoev.ru> parents: 681 diff changeset	748 return NGX_OK;
532d15ddbe68 glob support in include Igor Sysoev <igor@sysoev.ru> parents: 681 diff changeset	749 }
532d15ddbe68 glob support in include Igor Sysoev <igor@sysoev.ru> parents: 681 diff changeset	750
532d15ddbe68 glob support in include Igor Sysoev <igor@sysoev.ru> parents: 681 diff changeset	751 return NGX_DONE;
532d15ddbe68 glob support in include Igor Sysoev <igor@sysoev.ru> parents: 681 diff changeset	752 }
532d15ddbe68 glob support in include Igor Sysoev <igor@sysoev.ru> parents: 681 diff changeset	753
532d15ddbe68 glob support in include Igor Sysoev <igor@sysoev.ru> parents: 681 diff changeset	754
532d15ddbe68 glob support in include Igor Sysoev <igor@sysoev.ru> parents: 681 diff changeset	755 void
532d15ddbe68 glob support in include Igor Sysoev <igor@sysoev.ru> parents: 681 diff changeset	756 ngx_close_glob(ngx_glob_t *gl)
532d15ddbe68 glob support in include Igor Sysoev <igor@sysoev.ru> parents: 681 diff changeset	757 {
532d15ddbe68 glob support in include Igor Sysoev <igor@sysoev.ru> parents: 681 diff changeset	758 globfree(&gl->pglob);
532d15ddbe68 glob support in include Igor Sysoev <igor@sysoev.ru> parents: 681 diff changeset	759 }
532d15ddbe68 glob support in include Igor Sysoev <igor@sysoev.ru> parents: 681 diff changeset	760
532d15ddbe68 glob support in include Igor Sysoev <igor@sysoev.ru> parents: 681 diff changeset	761
611 3f8a2132b93d nginx-0.3.27-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 577 diff changeset	762 ngx_err_t
3f8a2132b93d nginx-0.3.27-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 577 diff changeset	763 ngx_trylock_fd(ngx_fd_t fd)
561 e48ebafc6939 nginx-0.3.2-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 501 diff changeset	764 {
e48ebafc6939 nginx-0.3.2-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 501 diff changeset	765 struct flock fl;
e48ebafc6939 nginx-0.3.2-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 501 diff changeset	766
4737 9acc1a5a5b9a Made sure to initialize the entire "struct flock" allocated on stack. Ruslan Ermilov <ru@nginx.com> parents: 4412 diff changeset	767 ngx_memzero(&fl, sizeof(struct flock));
611 3f8a2132b93d nginx-0.3.27-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 577 diff changeset	768 fl.l_type = F_WRLCK;
561 e48ebafc6939 nginx-0.3.2-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 501 diff changeset	769 fl.l_whence = SEEK_SET;
611 3f8a2132b93d nginx-0.3.27-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 577 diff changeset	770
3f8a2132b93d nginx-0.3.27-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 577 diff changeset	771 if (fcntl(fd, F_SETLK, &fl) == -1) {
3f8a2132b93d nginx-0.3.27-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 577 diff changeset	772 return ngx_errno;
3f8a2132b93d nginx-0.3.27-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 577 diff changeset	773 }
3f8a2132b93d nginx-0.3.27-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 577 diff changeset	774
3f8a2132b93d nginx-0.3.27-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 577 diff changeset	775 return 0;
3f8a2132b93d nginx-0.3.27-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 577 diff changeset	776 }
3f8a2132b93d nginx-0.3.27-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 577 diff changeset	777
3f8a2132b93d nginx-0.3.27-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 577 diff changeset	778
3f8a2132b93d nginx-0.3.27-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 577 diff changeset	779 ngx_err_t
3f8a2132b93d nginx-0.3.27-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 577 diff changeset	780 ngx_lock_fd(ngx_fd_t fd)
3f8a2132b93d nginx-0.3.27-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 577 diff changeset	781 {
3f8a2132b93d nginx-0.3.27-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 577 diff changeset	782 struct flock fl;
3f8a2132b93d nginx-0.3.27-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 577 diff changeset	783
4737 9acc1a5a5b9a Made sure to initialize the entire "struct flock" allocated on stack. Ruslan Ermilov <ru@nginx.com> parents: 4412 diff changeset	784 ngx_memzero(&fl, sizeof(struct flock));
561 e48ebafc6939 nginx-0.3.2-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 501 diff changeset	785 fl.l_type = F_WRLCK;
611 3f8a2132b93d nginx-0.3.27-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 577 diff changeset	786 fl.l_whence = SEEK_SET;
561 e48ebafc6939 nginx-0.3.2-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 501 diff changeset	787
611 3f8a2132b93d nginx-0.3.27-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 577 diff changeset	788 if (fcntl(fd, F_SETLKW, &fl) == -1) {
3f8a2132b93d nginx-0.3.27-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 577 diff changeset	789 return ngx_errno;
561 e48ebafc6939 nginx-0.3.2-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 501 diff changeset	790 }
e48ebafc6939 nginx-0.3.2-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 501 diff changeset	791
611 3f8a2132b93d nginx-0.3.27-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 577 diff changeset	792 return 0;
561 e48ebafc6939 nginx-0.3.2-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 501 diff changeset	793 }
e48ebafc6939 nginx-0.3.2-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 501 diff changeset	794
e48ebafc6939 nginx-0.3.2-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 501 diff changeset	795
611 3f8a2132b93d nginx-0.3.27-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 577 diff changeset	796 ngx_err_t
3f8a2132b93d nginx-0.3.27-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 577 diff changeset	797 ngx_unlock_fd(ngx_fd_t fd)
561 e48ebafc6939 nginx-0.3.2-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 501 diff changeset	798 {
e48ebafc6939 nginx-0.3.2-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 501 diff changeset	799 struct flock fl;
e48ebafc6939 nginx-0.3.2-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 501 diff changeset	800
4737 9acc1a5a5b9a Made sure to initialize the entire "struct flock" allocated on stack. Ruslan Ermilov <ru@nginx.com> parents: 4412 diff changeset	801 ngx_memzero(&fl, sizeof(struct flock));
561 e48ebafc6939 nginx-0.3.2-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 501 diff changeset	802 fl.l_type = F_UNLCK;
611 3f8a2132b93d nginx-0.3.27-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 577 diff changeset	803 fl.l_whence = SEEK_SET;
561 e48ebafc6939 nginx-0.3.2-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 501 diff changeset	804
611 3f8a2132b93d nginx-0.3.27-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 577 diff changeset	805 if (fcntl(fd, F_SETLK, &fl) == -1) {
3f8a2132b93d nginx-0.3.27-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 577 diff changeset	806 return ngx_errno;
561 e48ebafc6939 nginx-0.3.2-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 501 diff changeset	807 }
e48ebafc6939 nginx-0.3.2-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 501 diff changeset	808
611 3f8a2132b93d nginx-0.3.27-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 577 diff changeset	809 return 0;
561 e48ebafc6939 nginx-0.3.2-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 501 diff changeset	810 }
2129 25add486e7aa directio Igor Sysoev <igor@sysoev.ru> parents: 1980 diff changeset	811
25add486e7aa directio Igor Sysoev <igor@sysoev.ru> parents: 1980 diff changeset	812
4299 11e47bf300db FreeBSD 10-current has recently gotten POSIX_FADV_* macros. Maxim Konovalov <maxim@nginx.com> parents: 4221 diff changeset	813 #if (NGX_HAVE_POSIX_FADVISE) && !(NGX_HAVE_F_READAHEAD)
3322 e19df6e65352 fix posix_fadvise() error handling Igor Sysoev <igor@sysoev.ru> parents: 3294 diff changeset	814
e19df6e65352 fix posix_fadvise() error handling Igor Sysoev <igor@sysoev.ru> parents: 3294 diff changeset	815 ngx_int_t
e19df6e65352 fix posix_fadvise() error handling Igor Sysoev <igor@sysoev.ru> parents: 3294 diff changeset	816 ngx_read_ahead(ngx_fd_t fd, size_t n)
e19df6e65352 fix posix_fadvise() error handling Igor Sysoev <igor@sysoev.ru> parents: 3294 diff changeset	817 {
e19df6e65352 fix posix_fadvise() error handling Igor Sysoev <igor@sysoev.ru> parents: 3294 diff changeset	818 int err;
e19df6e65352 fix posix_fadvise() error handling Igor Sysoev <igor@sysoev.ru> parents: 3294 diff changeset	819
e19df6e65352 fix posix_fadvise() error handling Igor Sysoev <igor@sysoev.ru> parents: 3294 diff changeset	820 err = posix_fadvise(fd, 0, 0, POSIX_FADV_SEQUENTIAL);
e19df6e65352 fix posix_fadvise() error handling Igor Sysoev <igor@sysoev.ru> parents: 3294 diff changeset	821
e19df6e65352 fix posix_fadvise() error handling Igor Sysoev <igor@sysoev.ru> parents: 3294 diff changeset	822 if (err == 0) {
e19df6e65352 fix posix_fadvise() error handling Igor Sysoev <igor@sysoev.ru> parents: 3294 diff changeset	823 return 0;
e19df6e65352 fix posix_fadvise() error handling Igor Sysoev <igor@sysoev.ru> parents: 3294 diff changeset	824 }
e19df6e65352 fix posix_fadvise() error handling Igor Sysoev <igor@sysoev.ru> parents: 3294 diff changeset	825
e19df6e65352 fix posix_fadvise() error handling Igor Sysoev <igor@sysoev.ru> parents: 3294 diff changeset	826 ngx_set_errno(err);
e19df6e65352 fix posix_fadvise() error handling Igor Sysoev <igor@sysoev.ru> parents: 3294 diff changeset	827 return NGX_FILE_ERROR;
e19df6e65352 fix posix_fadvise() error handling Igor Sysoev <igor@sysoev.ru> parents: 3294 diff changeset	828 }
e19df6e65352 fix posix_fadvise() error handling Igor Sysoev <igor@sysoev.ru> parents: 3294 diff changeset	829
e19df6e65352 fix posix_fadvise() error handling Igor Sysoev <igor@sysoev.ru> parents: 3294 diff changeset	830 #endif
e19df6e65352 fix posix_fadvise() error handling Igor Sysoev <igor@sysoev.ru> parents: 3294 diff changeset	831
e19df6e65352 fix posix_fadvise() error handling Igor Sysoev <igor@sysoev.ru> parents: 3294 diff changeset	832
2129 25add486e7aa directio Igor Sysoev <igor@sysoev.ru> parents: 1980 diff changeset	833 #if (NGX_HAVE_O_DIRECT)
25add486e7aa directio Igor Sysoev <igor@sysoev.ru> parents: 1980 diff changeset	834
25add486e7aa directio Igor Sysoev <igor@sysoev.ru> parents: 1980 diff changeset	835 ngx_int_t
2248 1adec90a0e46 disable directio for unaligned reads in Linux Igor Sysoev <igor@sysoev.ru> parents: 2234 diff changeset	836 ngx_directio_on(ngx_fd_t fd)
2129 25add486e7aa directio Igor Sysoev <igor@sysoev.ru> parents: 1980 diff changeset	837 {
25add486e7aa directio Igor Sysoev <igor@sysoev.ru> parents: 1980 diff changeset	838 int flags;
25add486e7aa directio Igor Sysoev <igor@sysoev.ru> parents: 1980 diff changeset	839
25add486e7aa directio Igor Sysoev <igor@sysoev.ru> parents: 1980 diff changeset	840 flags = fcntl(fd, F_GETFL);
25add486e7aa directio Igor Sysoev <igor@sysoev.ru> parents: 1980 diff changeset	841
25add486e7aa directio Igor Sysoev <igor@sysoev.ru> parents: 1980 diff changeset	842 if (flags == -1) {
3164 b1b1775698d5 uniform ngx_directio_on/off() interface with other file functions Igor Sysoev <igor@sysoev.ru> parents: 3163 diff changeset	843 return NGX_FILE_ERROR;
2129 25add486e7aa directio Igor Sysoev <igor@sysoev.ru> parents: 1980 diff changeset	844 }
25add486e7aa directio Igor Sysoev <igor@sysoev.ru> parents: 1980 diff changeset	845
25add486e7aa directio Igor Sysoev <igor@sysoev.ru> parents: 1980 diff changeset	846 return fcntl(fd, F_SETFL, flags \| O_DIRECT);
25add486e7aa directio Igor Sysoev <igor@sysoev.ru> parents: 1980 diff changeset	847 }
25add486e7aa directio Igor Sysoev <igor@sysoev.ru> parents: 1980 diff changeset	848
2248 1adec90a0e46 disable directio for unaligned reads in Linux Igor Sysoev <igor@sysoev.ru> parents: 2234 diff changeset	849
1adec90a0e46 disable directio for unaligned reads in Linux Igor Sysoev <igor@sysoev.ru> parents: 2234 diff changeset	850 ngx_int_t
1adec90a0e46 disable directio for unaligned reads in Linux Igor Sysoev <igor@sysoev.ru> parents: 2234 diff changeset	851 ngx_directio_off(ngx_fd_t fd)
1adec90a0e46 disable directio for unaligned reads in Linux Igor Sysoev <igor@sysoev.ru> parents: 2234 diff changeset	852 {
1adec90a0e46 disable directio for unaligned reads in Linux Igor Sysoev <igor@sysoev.ru> parents: 2234 diff changeset	853 int flags;
1adec90a0e46 disable directio for unaligned reads in Linux Igor Sysoev <igor@sysoev.ru> parents: 2234 diff changeset	854
1adec90a0e46 disable directio for unaligned reads in Linux Igor Sysoev <igor@sysoev.ru> parents: 2234 diff changeset	855 flags = fcntl(fd, F_GETFL);
1adec90a0e46 disable directio for unaligned reads in Linux Igor Sysoev <igor@sysoev.ru> parents: 2234 diff changeset	856
1adec90a0e46 disable directio for unaligned reads in Linux Igor Sysoev <igor@sysoev.ru> parents: 2234 diff changeset	857 if (flags == -1) {
3164 b1b1775698d5 uniform ngx_directio_on/off() interface with other file functions Igor Sysoev <igor@sysoev.ru> parents: 3163 diff changeset	858 return NGX_FILE_ERROR;
2248 1adec90a0e46 disable directio for unaligned reads in Linux Igor Sysoev <igor@sysoev.ru> parents: 2234 diff changeset	859 }
1adec90a0e46 disable directio for unaligned reads in Linux Igor Sysoev <igor@sysoev.ru> parents: 2234 diff changeset	860
1adec90a0e46 disable directio for unaligned reads in Linux Igor Sysoev <igor@sysoev.ru> parents: 2234 diff changeset	861 return fcntl(fd, F_SETFL, flags & ~O_DIRECT);
1adec90a0e46 disable directio for unaligned reads in Linux Igor Sysoev <igor@sysoev.ru> parents: 2234 diff changeset	862 }
1adec90a0e46 disable directio for unaligned reads in Linux Igor Sysoev <igor@sysoev.ru> parents: 2234 diff changeset	863
2129 25add486e7aa directio Igor Sysoev <igor@sysoev.ru> parents: 1980 diff changeset	864 #endif
2615 ceef364208c8 ngx_fs_bsize() Igor Sysoev <igor@sysoev.ru> parents: 2550 diff changeset	865
ceef364208c8 ngx_fs_bsize() Igor Sysoev <igor@sysoev.ru> parents: 2550 diff changeset	866
ceef364208c8 ngx_fs_bsize() Igor Sysoev <igor@sysoev.ru> parents: 2550 diff changeset	867 #if (NGX_HAVE_STATFS)
ceef364208c8 ngx_fs_bsize() Igor Sysoev <igor@sysoev.ru> parents: 2550 diff changeset	868
ceef364208c8 ngx_fs_bsize() Igor Sysoev <igor@sysoev.ru> parents: 2550 diff changeset	869 size_t
ceef364208c8 ngx_fs_bsize() Igor Sysoev <igor@sysoev.ru> parents: 2550 diff changeset	870 ngx_fs_bsize(u_char *name)
ceef364208c8 ngx_fs_bsize() Igor Sysoev <igor@sysoev.ru> parents: 2550 diff changeset	871 {
ceef364208c8 ngx_fs_bsize() Igor Sysoev <igor@sysoev.ru> parents: 2550 diff changeset	872 struct statfs fs;
ceef364208c8 ngx_fs_bsize() Igor Sysoev <igor@sysoev.ru> parents: 2550 diff changeset	873
ceef364208c8 ngx_fs_bsize() Igor Sysoev <igor@sysoev.ru> parents: 2550 diff changeset	874 if (statfs((char *) name, &fs) == -1) {
ceef364208c8 ngx_fs_bsize() Igor Sysoev <igor@sysoev.ru> parents: 2550 diff changeset	875 return 512;
ceef364208c8 ngx_fs_bsize() Igor Sysoev <igor@sysoev.ru> parents: 2550 diff changeset	876 }
ceef364208c8 ngx_fs_bsize() Igor Sysoev <igor@sysoev.ru> parents: 2550 diff changeset	877
ceef364208c8 ngx_fs_bsize() Igor Sysoev <igor@sysoev.ru> parents: 2550 diff changeset	878 if ((fs.f_bsize % 512) != 0) {
ceef364208c8 ngx_fs_bsize() Igor Sysoev <igor@sysoev.ru> parents: 2550 diff changeset	879 return 512;
ceef364208c8 ngx_fs_bsize() Igor Sysoev <igor@sysoev.ru> parents: 2550 diff changeset	880 }
ceef364208c8 ngx_fs_bsize() Igor Sysoev <igor@sysoev.ru> parents: 2550 diff changeset	881
7668 0a04e5e4c40b Large block sizes on Linux are now ignored (ticket #1168). Maxim Dounin <mdounin@mdounin.ru> parents: 7086 diff changeset	882 #if (NGX_LINUX)
0a04e5e4c40b Large block sizes on Linux are now ignored (ticket #1168). Maxim Dounin <mdounin@mdounin.ru> parents: 7086 diff changeset	883 if ((size_t) fs.f_bsize > ngx_pagesize) {
0a04e5e4c40b Large block sizes on Linux are now ignored (ticket #1168). Maxim Dounin <mdounin@mdounin.ru> parents: 7086 diff changeset	884 return 512;
0a04e5e4c40b Large block sizes on Linux are now ignored (ticket #1168). Maxim Dounin <mdounin@mdounin.ru> parents: 7086 diff changeset	885 }
0a04e5e4c40b Large block sizes on Linux are now ignored (ticket #1168). Maxim Dounin <mdounin@mdounin.ru> parents: 7086 diff changeset	886 #endif
0a04e5e4c40b Large block sizes on Linux are now ignored (ticket #1168). Maxim Dounin <mdounin@mdounin.ru> parents: 7086 diff changeset	887
2615 ceef364208c8 ngx_fs_bsize() Igor Sysoev <igor@sysoev.ru> parents: 2550 diff changeset	888 return (size_t) fs.f_bsize;
ceef364208c8 ngx_fs_bsize() Igor Sysoev <igor@sysoev.ru> parents: 2550 diff changeset	889 }
ceef364208c8 ngx_fs_bsize() Igor Sysoev <igor@sysoev.ru> parents: 2550 diff changeset	890
7670 ccb5ff87ab3e Cache: introduced min_free cache clearing. Maxim Dounin <mdounin@mdounin.ru> parents: 7668 diff changeset	891
ccb5ff87ab3e Cache: introduced min_free cache clearing. Maxim Dounin <mdounin@mdounin.ru> parents: 7668 diff changeset	892 off_t
ccb5ff87ab3e Cache: introduced min_free cache clearing. Maxim Dounin <mdounin@mdounin.ru> parents: 7668 diff changeset	893 ngx_fs_available(u_char *name)
ccb5ff87ab3e Cache: introduced min_free cache clearing. Maxim Dounin <mdounin@mdounin.ru> parents: 7668 diff changeset	894 {
ccb5ff87ab3e Cache: introduced min_free cache clearing. Maxim Dounin <mdounin@mdounin.ru> parents: 7668 diff changeset	895 struct statfs fs;
ccb5ff87ab3e Cache: introduced min_free cache clearing. Maxim Dounin <mdounin@mdounin.ru> parents: 7668 diff changeset	896
ccb5ff87ab3e Cache: introduced min_free cache clearing. Maxim Dounin <mdounin@mdounin.ru> parents: 7668 diff changeset	897 if (statfs((char *) name, &fs) == -1) {
ccb5ff87ab3e Cache: introduced min_free cache clearing. Maxim Dounin <mdounin@mdounin.ru> parents: 7668 diff changeset	898 return NGX_MAX_OFF_T_VALUE;
ccb5ff87ab3e Cache: introduced min_free cache clearing. Maxim Dounin <mdounin@mdounin.ru> parents: 7668 diff changeset	899 }
ccb5ff87ab3e Cache: introduced min_free cache clearing. Maxim Dounin <mdounin@mdounin.ru> parents: 7668 diff changeset	900
ccb5ff87ab3e Cache: introduced min_free cache clearing. Maxim Dounin <mdounin@mdounin.ru> parents: 7668 diff changeset	901 return (off_t) fs.f_bavail * fs.f_bsize;
ccb5ff87ab3e Cache: introduced min_free cache clearing. Maxim Dounin <mdounin@mdounin.ru> parents: 7668 diff changeset	902 }
ccb5ff87ab3e Cache: introduced min_free cache clearing. Maxim Dounin <mdounin@mdounin.ru> parents: 7668 diff changeset	903
2615 ceef364208c8 ngx_fs_bsize() Igor Sysoev <igor@sysoev.ru> parents: 2550 diff changeset	904 #elif (NGX_HAVE_STATVFS)
ceef364208c8 ngx_fs_bsize() Igor Sysoev <igor@sysoev.ru> parents: 2550 diff changeset	905
ceef364208c8 ngx_fs_bsize() Igor Sysoev <igor@sysoev.ru> parents: 2550 diff changeset	906 size_t
ceef364208c8 ngx_fs_bsize() Igor Sysoev <igor@sysoev.ru> parents: 2550 diff changeset	907 ngx_fs_bsize(u_char *name)
ceef364208c8 ngx_fs_bsize() Igor Sysoev <igor@sysoev.ru> parents: 2550 diff changeset	908 {
ceef364208c8 ngx_fs_bsize() Igor Sysoev <igor@sysoev.ru> parents: 2550 diff changeset	909 struct statvfs fs;
ceef364208c8 ngx_fs_bsize() Igor Sysoev <igor@sysoev.ru> parents: 2550 diff changeset	910
ceef364208c8 ngx_fs_bsize() Igor Sysoev <igor@sysoev.ru> parents: 2550 diff changeset	911 if (statvfs((char *) name, &fs) == -1) {
ceef364208c8 ngx_fs_bsize() Igor Sysoev <igor@sysoev.ru> parents: 2550 diff changeset	912 return 512;
ceef364208c8 ngx_fs_bsize() Igor Sysoev <igor@sysoev.ru> parents: 2550 diff changeset	913 }
ceef364208c8 ngx_fs_bsize() Igor Sysoev <igor@sysoev.ru> parents: 2550 diff changeset	914
ceef364208c8 ngx_fs_bsize() Igor Sysoev <igor@sysoev.ru> parents: 2550 diff changeset	915 if ((fs.f_frsize % 512) != 0) {
ceef364208c8 ngx_fs_bsize() Igor Sysoev <igor@sysoev.ru> parents: 2550 diff changeset	916 return 512;
ceef364208c8 ngx_fs_bsize() Igor Sysoev <igor@sysoev.ru> parents: 2550 diff changeset	917 }
ceef364208c8 ngx_fs_bsize() Igor Sysoev <igor@sysoev.ru> parents: 2550 diff changeset	918
7668 0a04e5e4c40b Large block sizes on Linux are now ignored (ticket #1168). Maxim Dounin <mdounin@mdounin.ru> parents: 7086 diff changeset	919 #if (NGX_LINUX)
0a04e5e4c40b Large block sizes on Linux are now ignored (ticket #1168). Maxim Dounin <mdounin@mdounin.ru> parents: 7086 diff changeset	920 if ((size_t) fs.f_frsize > ngx_pagesize) {
0a04e5e4c40b Large block sizes on Linux are now ignored (ticket #1168). Maxim Dounin <mdounin@mdounin.ru> parents: 7086 diff changeset	921 return 512;
0a04e5e4c40b Large block sizes on Linux are now ignored (ticket #1168). Maxim Dounin <mdounin@mdounin.ru> parents: 7086 diff changeset	922 }
0a04e5e4c40b Large block sizes on Linux are now ignored (ticket #1168). Maxim Dounin <mdounin@mdounin.ru> parents: 7086 diff changeset	923 #endif
0a04e5e4c40b Large block sizes on Linux are now ignored (ticket #1168). Maxim Dounin <mdounin@mdounin.ru> parents: 7086 diff changeset	924
2615 ceef364208c8 ngx_fs_bsize() Igor Sysoev <igor@sysoev.ru> parents: 2550 diff changeset	925 return (size_t) fs.f_frsize;
ceef364208c8 ngx_fs_bsize() Igor Sysoev <igor@sysoev.ru> parents: 2550 diff changeset	926 }
ceef364208c8 ngx_fs_bsize() Igor Sysoev <igor@sysoev.ru> parents: 2550 diff changeset	927
7670 ccb5ff87ab3e Cache: introduced min_free cache clearing. Maxim Dounin <mdounin@mdounin.ru> parents: 7668 diff changeset	928
ccb5ff87ab3e Cache: introduced min_free cache clearing. Maxim Dounin <mdounin@mdounin.ru> parents: 7668 diff changeset	929 off_t
ccb5ff87ab3e Cache: introduced min_free cache clearing. Maxim Dounin <mdounin@mdounin.ru> parents: 7668 diff changeset	930 ngx_fs_available(u_char *name)
ccb5ff87ab3e Cache: introduced min_free cache clearing. Maxim Dounin <mdounin@mdounin.ru> parents: 7668 diff changeset	931 {
ccb5ff87ab3e Cache: introduced min_free cache clearing. Maxim Dounin <mdounin@mdounin.ru> parents: 7668 diff changeset	932 struct statvfs fs;
ccb5ff87ab3e Cache: introduced min_free cache clearing. Maxim Dounin <mdounin@mdounin.ru> parents: 7668 diff changeset	933
ccb5ff87ab3e Cache: introduced min_free cache clearing. Maxim Dounin <mdounin@mdounin.ru> parents: 7668 diff changeset	934 if (statvfs((char *) name, &fs) == -1) {
ccb5ff87ab3e Cache: introduced min_free cache clearing. Maxim Dounin <mdounin@mdounin.ru> parents: 7668 diff changeset	935 return NGX_MAX_OFF_T_VALUE;
ccb5ff87ab3e Cache: introduced min_free cache clearing. Maxim Dounin <mdounin@mdounin.ru> parents: 7668 diff changeset	936 }
ccb5ff87ab3e Cache: introduced min_free cache clearing. Maxim Dounin <mdounin@mdounin.ru> parents: 7668 diff changeset	937
ccb5ff87ab3e Cache: introduced min_free cache clearing. Maxim Dounin <mdounin@mdounin.ru> parents: 7668 diff changeset	938 return (off_t) fs.f_bavail * fs.f_frsize;
ccb5ff87ab3e Cache: introduced min_free cache clearing. Maxim Dounin <mdounin@mdounin.ru> parents: 7668 diff changeset	939 }
ccb5ff87ab3e Cache: introduced min_free cache clearing. Maxim Dounin <mdounin@mdounin.ru> parents: 7668 diff changeset	940
2615 ceef364208c8 ngx_fs_bsize() Igor Sysoev <igor@sysoev.ru> parents: 2550 diff changeset	941 #else
ceef364208c8 ngx_fs_bsize() Igor Sysoev <igor@sysoev.ru> parents: 2550 diff changeset	942
ceef364208c8 ngx_fs_bsize() Igor Sysoev <igor@sysoev.ru> parents: 2550 diff changeset	943 size_t
ceef364208c8 ngx_fs_bsize() Igor Sysoev <igor@sysoev.ru> parents: 2550 diff changeset	944 ngx_fs_bsize(u_char *name)
ceef364208c8 ngx_fs_bsize() Igor Sysoev <igor@sysoev.ru> parents: 2550 diff changeset	945 {
ceef364208c8 ngx_fs_bsize() Igor Sysoev <igor@sysoev.ru> parents: 2550 diff changeset	946 return 512;
ceef364208c8 ngx_fs_bsize() Igor Sysoev <igor@sysoev.ru> parents: 2550 diff changeset	947 }
ceef364208c8 ngx_fs_bsize() Igor Sysoev <igor@sysoev.ru> parents: 2550 diff changeset	948
7670 ccb5ff87ab3e Cache: introduced min_free cache clearing. Maxim Dounin <mdounin@mdounin.ru> parents: 7668 diff changeset	949
ccb5ff87ab3e Cache: introduced min_free cache clearing. Maxim Dounin <mdounin@mdounin.ru> parents: 7668 diff changeset	950 off_t
ccb5ff87ab3e Cache: introduced min_free cache clearing. Maxim Dounin <mdounin@mdounin.ru> parents: 7668 diff changeset	951 ngx_fs_available(u_char *name)
ccb5ff87ab3e Cache: introduced min_free cache clearing. Maxim Dounin <mdounin@mdounin.ru> parents: 7668 diff changeset	952 {
ccb5ff87ab3e Cache: introduced min_free cache clearing. Maxim Dounin <mdounin@mdounin.ru> parents: 7668 diff changeset	953 return NGX_MAX_OFF_T_VALUE;
ccb5ff87ab3e Cache: introduced min_free cache clearing. Maxim Dounin <mdounin@mdounin.ru> parents: 7668 diff changeset	954 }
ccb5ff87ab3e Cache: introduced min_free cache clearing. Maxim Dounin <mdounin@mdounin.ru> parents: 7668 diff changeset	955
2615 ceef364208c8 ngx_fs_bsize() Igor Sysoev <igor@sysoev.ru> parents: 2550 diff changeset	956 #endif

Mercurial > hg > nginx

annotate src/os/unix/ngx_files.c @ 9266:93bbb9fbf30d default tip