Mercurial > hg > nginx-vendor-0-6

comparison src/os/unix/ngx_aio_write_chain.c @ 0:f0b350454894 NGINX_0_1_0

Find changesets by keywords (author, files, the commit message), revision number or hash, or revset expression.
nginx 0.1.0 *) The first public version.
author Igor Sysoev <http://sysoev.ru>
date Mon, 04 Oct 2004 00:00:00 +0400
parents
children 46833bd150cb
comparison
equal deleted inserted replaced
-1:000000000000 0:f0b350454894
1
2 /*
3 * Copyright (C) Igor Sysoev
4 */
5
6
7 #include <ngx_config.h>
8 #include <ngx_core.h>
9 #include <ngx_event.h>
10 #include <ngx_aio.h>
11
12
13 ngx_chain_t *ngx_aio_write_chain(ngx_connection_t *c, ngx_chain_t *in,
14 off_t limit)
15 {
16 int n;
17 u_char *buf, *prev;
18 off_t send, sent;
19 size_t len;
20 ssize_t size;
21 ngx_err_t err;
22 ngx_chain_t *cl;
23
24 send = 0;
25 sent = 0;
26 cl = in;
27
28 while (cl) {
29
30 if (cl->buf->pos == cl->buf->last) {
31 cl = cl->next;
32 continue;
33 }
34
35 /* we can post the single aio operation only */
36
37 if (!c->write->ready) {
38 return cl;
39 }
40
41 buf = cl->buf->pos;
42 prev = buf;
43 len = 0;
44
45 /* coalesce the neighbouring bufs */
46
47 while (cl && prev == cl->buf->pos && send < limit) {
48 if (ngx_buf_special(cl->buf)) {
49 continue;
50 }
51
52 size = cl->buf->last - cl->buf->pos;
53
54 if (send + size > limit) {
55 size = limit - send;
56 }
57
58 len += size;
59 prev = cl->buf->pos + size;
60 send += size;
61 cl = cl->next;
62 }
63
64 n = ngx_aio_write(c, buf, len);
65
66 ngx_log_debug1(NGX_LOG_DEBUG_EVENT, c->log, 0, "aio_write: %d", n);
67
68 if (n == NGX_ERROR) {
69 return NGX_CHAIN_ERROR;
70 }
71
72 if (n > 0) {
73 sent += n;
74 c->sent += n;
75 }
76
77 ngx_log_debug1(NGX_LOG_DEBUG_EVENT, c->log, 0,
78 "aio_write sent: " OFF_T_FMT, c->sent);
79
80 for (cl = in; cl; cl = cl->next) {
81
82 if (sent >= cl->buf->last - cl->buf->pos) {
83 sent -= cl->buf->last - cl->buf->pos;
84 cl->buf->pos = cl->buf->last;
85
86 continue;
87 }
88
89 cl->buf->pos += sent;
90
91 break;
92 }
93 }
94
95 return cl;
96 }