Mercurial > hg > nginx-quic
comparison src/os/unix/ngx_solaris_sendfilev_chain.c @ 428:5e73d0ea4dab
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; |