Mercurial > hg > nginx

comparison src/os/unix/ngx_aio_write_chain.c @ 343:6bdf858bff8c

Find changesets by keywords (author, files, the commit message), revision number or hash, or revset expression.
nginx-0.0.3-2004-05-28-19:49:23 import; rename ngx_hunk_t to ngx_buf_t
author Igor Sysoev <igor@sysoev.ru>
date Fri, 28 May 2004 15:49:23 +0000
parents 4a3f18406832
children 7650aea1816f
comparison
equal deleted inserted replaced
342:0ee0642af5f1 343:6bdf858bff8c
17 sent = 0; 17 sent = 0;
18 cl = in; 18 cl = in;
19 19
20 while (cl) { 20 while (cl) {
21 21
22 if (cl->hunk->last - cl->hunk->pos == 0) { 22 if (cl->buf->last - cl->buf->pos == 0) {
23 cl = cl->next; 23 cl = cl->next;
24 continue; 24 continue;
25 } 25 }
26 26
27 /* we can post the single aio operation only */ 27 /* we can post the single aio operation only */
28 28
29 if (!c->write->ready) { 29 if (!c->write->ready) {
30 return cl; 30 return cl;
31 } 31 }
32 32
33 buf = cl->hunk->pos; 33 buf = cl->buf->pos;
34 prev = buf; 34 prev = buf;
35 size = 0; 35 size = 0;
36 36
37 /* coalesce the neighbouring hunks */ 37 /* coalesce the neighbouring bufs */
38 38
39 while (cl && prev == cl->hunk->pos) { 39 while (cl && prev == cl->buf->pos) {
40 size += cl->hunk->last - cl->hunk->pos; 40 size += cl->buf->last - cl->buf->pos;
41 prev = cl->hunk->last; 41 prev = cl->buf->last;
42 cl = cl->next; 42 cl = cl->next;
43 } 43 }
44 44
45 n = ngx_aio_write(c, buf, size); 45 n = ngx_aio_write(c, buf, size);
46 46
58 ngx_log_debug1(NGX_LOG_DEBUG_EVENT, c->log, 0, 58 ngx_log_debug1(NGX_LOG_DEBUG_EVENT, c->log, 0,
59 "aio_write sent: " OFF_T_FMT, c->sent); 59 "aio_write sent: " OFF_T_FMT, c->sent);
60 60
61 for (cl = in; cl; cl = cl->next) { 61 for (cl = in; cl; cl = cl->next) {
62 62
63 if (sent >= cl->hunk->last - cl->hunk->pos) { 63 if (sent >= cl->buf->last - cl->buf->pos) {
64 sent -= cl->hunk->last - cl->hunk->pos; 64 sent -= cl->buf->last - cl->buf->pos;
65 cl->hunk->pos = cl->hunk->last; 65 cl->buf->pos = cl->buf->last;
66 66
67 continue; 67 continue;
68 } 68 }
69 69
70 cl->hunk->pos += sent; 70 cl->buf->pos += sent;
71 71
72 break; 72 break;
73 } 73 }
74 } 74 }
75 75