Mercurial > hg > nginx

comparison src/os/unix/ngx_solaris_sendfilev_chain.c @ 428:5e73d0ea4dab

Find changesets by keywords (author, files, the commit message), revision number or hash, or revset expression.
nginx-0.0.11-2004-09-16-20:10:13 import
author Igor Sysoev <igor@sysoev.ru>
date Thu, 16 Sep 2004 16:10:13 +0000
parents 7650aea1816f
children 9a97dcdd2421
comparison
equal deleted inserted replaced
427:0d08eabe5c7b 428:5e73d0ea4dab
5 5
6 6
7 #include <ngx_config.h> 7 #include <ngx_config.h>
8 #include <ngx_core.h> 8 #include <ngx_core.h>
9 #include <ngx_event.h> 9 #include <ngx_event.h>
10
11
12 #define NGX_SENDFILEVECS 16
10 13
11 14
12 ngx_chain_t *ngx_solaris_sendfilev_chain(ngx_connection_t *c, ngx_chain_t *in, 15 ngx_chain_t *ngx_solaris_sendfilev_chain(ngx_connection_t *c, ngx_chain_t *in,
13 off_t limit) 16 off_t limit)
14 { 17 {
17 off_t fprev, sprev, send, aligned; 20 off_t fprev, sprev, send, aligned;
18 size_t size, sent; 21 size_t size, sent;
19 ssize_t n; 22 ssize_t n;
20 ngx_int_t eintr, complete; 23 ngx_int_t eintr, complete;
21 ngx_err_t err; 24 ngx_err_t err;
22 sendfilevec_t *sfv; 25 sendfilevec_t *sfv, sfvs[NGX_SENDFILEVECS];
23 ngx_array_t vec; 26 ngx_array_t vec;
24 ngx_event_t *wev; 27 ngx_event_t *wev;
25 ngx_chain_t *cl, *tail; 28 ngx_chain_t *cl, *tail;
26 29
27 wev = c->write; 30 wev = c->write;
30 return in; 33 return in;
31 } 34 }
32 35
33 send = 0; 36 send = 0;
34 complete = 0; 37 complete = 0;
38
39 vec.elts = sfvs;
40 vec.size = sizeof(sendfilevec_t);
41 vec.nalloc = NGX_SENDFILEVECS;
42 vec.pool = c->pool;
35 43
36 for ( ;; ) { 44 for ( ;; ) {
37 fd = SFV_FD_SELF; 45 fd = SFV_FD_SELF;
38 prev = NULL; 46 prev = NULL;
39 fprev = 0; 47 fprev = 0;
40 sfv = NULL; 48 sfv = NULL;
41 eintr = 0; 49 eintr = 0;
42 sent = 0; 50 sent = 0;
43 sprev = send; 51 sprev = send;
44 52
45 ngx_init_array(vec, c->pool, 10, sizeof(sendfilevec_t), 53 vec.nelts = 0;
46 NGX_CHAIN_ERROR);
47 54
48 /* create the sendfilevec and coalesce the neighbouring bufs */ 55 /* create the sendfilevec and coalesce the neighbouring bufs */
49 56
50 for (cl = in; cl && vec.nelts < IOV_MAX && send < limit; cl = cl->next) 57 for (cl = in; cl && vec.nelts < IOV_MAX && send < limit; cl = cl->next)
51 { 58 {
64 71
65 if (prev == cl->buf->pos) { 72 if (prev == cl->buf->pos) {
66 sfv->sfv_len += size; 73 sfv->sfv_len += size;
67 74
68 } else { 75 } else {
69 ngx_test_null(sfv, ngx_push_array(&vec), NGX_CHAIN_ERROR); 76 if (!(sfv = ngx_array_push(&vec))) {
77 return NGX_CHAIN_ERROR;
78 }
79
70 sfv->sfv_fd = SFV_FD_SELF; 80 sfv->sfv_fd = SFV_FD_SELF;
71 sfv->sfv_flag = 0; 81 sfv->sfv_flag = 0;
72 sfv->sfv_off = (off_t) (uintptr_t) cl->buf->pos; 82 sfv->sfv_off = (off_t) (uintptr_t) cl->buf->pos;
73 sfv->sfv_len = size; 83 sfv->sfv_len = size;
74 } 84 }
94 104
95 if (fd == cl->buf->file->fd && fprev == cl->buf->file_pos) { 105 if (fd == cl->buf->file->fd && fprev == cl->buf->file_pos) {
96 sfv->sfv_len += size; 106 sfv->sfv_len += size;
97 107
98 } else { 108 } else {
99 ngx_test_null(sfv, ngx_push_array(&vec), NGX_CHAIN_ERROR); 109 if (!(sfv = ngx_array_push(&vec))) {
110 return NGX_CHAIN_ERROR;
111 }
112
100 fd = cl->buf->file->fd; 113 fd = cl->buf->file->fd;
101 sfv->sfv_fd = fd; 114 sfv->sfv_fd = fd;
102 sfv->sfv_flag = 0; 115 sfv->sfv_flag = 0;
103 sfv->sfv_off = cl->buf->file_pos; 116 sfv->sfv_off = cl->buf->file_pos;
104 sfv->sfv_len = size; 117 sfv->sfv_len = size;