Mercurial > hg > nginx-quic

comparison src/os/unix/ngx_linux_sendfile_chain.c @ 198:34995c5ec6c4

Find changesets by keywords (author, files, the commit message), revision number or hash, or revset expression.
nginx-0.0.1-2003-11-27-22:01:37 import
author Igor Sysoev <igor@sysoev.ru>
date Thu, 27 Nov 2003 19:01:37 +0000
parents 11fbd0fc041d
children a65b630b3a66
comparison
equal deleted inserted replaced
197:0b81c7a0b133 198:34995c5ec6c4
6 6
7 ngx_chain_t *ngx_linux_sendfile_chain(ngx_connection_t *c, ngx_chain_t *in) 7 ngx_chain_t *ngx_linux_sendfile_chain(ngx_connection_t *c, ngx_chain_t *in)
8 { 8 {
9 int rc; 9 int rc;
10 char *prev; 10 char *prev;
11 off_t offset; 11 off_t fprev;
12 size_t size, fsize, sent; 12 size_t size, fsize, sent;
13 ngx_int_t use_cork, eintr; 13 ngx_int_t use_cork, eintr;
14 struct iovec *iov; 14 struct iovec *iov;
15 ngx_err_t err; 15 ngx_err_t err;
16 ngx_hunk_t *file; 16 ngx_hunk_t *file;
17 ngx_array_t header; 17 ngx_array_t header;
18 ngx_event_t *wev; 18 ngx_event_t *wev;
19 ngx_chain_t *cl, *tail; 19 ngx_chain_t *cl, *tail;
20 #if (HAVE_SENDFILE64)
21 off_t offset;
22 #else
23 int32_t offset;
24 #endif
20 25
21 wev = c->write; 26 wev = c->write;
22 27
23 if (!wev->ready) { 28 if (!wev->ready) {
24 return in; 29 return in;
80 85
81 /* get the file hunk */ 86 /* get the file hunk */
82 87
83 file = cl->hunk; 88 file = cl->hunk;
84 fsize = (size_t) (file->file_last - file->file_pos); 89 fsize = (size_t) (file->file_last - file->file_pos);
85 offset = file->file_last; 90 fprev = file->file_last;
86 cl = cl->next; 91 cl = cl->next;
87 92
88 /* coalesce the neighbouring file hunks */ 93 /* coalesce the neighbouring file hunks */
89 94
90 while (cl && (cl->hunk->type & NGX_HUNK_FILE)) { 95 while (cl && (cl->hunk->type & NGX_HUNK_FILE)) {
91 if (file->file->fd != cl->hunk->file->fd 96 if (file->file->fd != cl->hunk->file->fd
92 || offset != cl->hunk->file_pos) 97 || fprev != cl->hunk->file_pos)
93 { 98 {
94 break; 99 break;
95 } 100 }
96 101
97 fsize += (size_t) (cl->hunk->file_last - cl->hunk->file_pos); 102 fsize += (size_t) (cl->hunk->file_last - cl->hunk->file_pos);
98 offset = cl->hunk->file_last; 103 fprev = cl->hunk->file_last;
99 cl = cl->next; 104 cl = cl->next;
100 } 105 }
101 } 106 }
102 107
103 /* 108 /*
106 */ 111 */
107 112
108 tail = cl; 113 tail = cl;
109 114
110 if (fsize) { 115 if (fsize) {
116 #if (HAVE_SENDFILE64)
111 offset = file->file_pos; 117 offset = file->file_pos;
118 #else
119 offset = (int32_t) file->file_pos;
120 #endif
112 rc = sendfile(c->fd, file->file->fd, &offset, fsize); 121 rc = sendfile(c->fd, file->file->fd, &offset, fsize);
113 122
114 if (rc == -1) { 123 if (rc == -1) {
115 err = ngx_errno; 124 err = ngx_errno;
116 if (err == NGX_EAGAIN) { 125 if (err == NGX_EAGAIN) {