← Back to branch summary

~nginx/nginx/1.0

« back to all changes in this revision

Viewing changes to src/os/unix/ngx_send.c

  • Committer: Michael Lustfield
  • Date: 2010-12-01 08:06:25 UTC
  • Revision ID: michael@profarius.com-20101201080625-y8i4bq0e54ev2qwy
Tags: 0.9.0
Nginx v0.9.0

Show diffs side-by-side

added added

removed removed

Lines of Context:
src/os/unix/ngx_send.c
 
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
 
 
11
 
 
12
ssize_t
 
13
ngx_unix_send(ngx_connection_t *c, u_char *buf, size_t size)
 
14
{
 
15
    ssize_t       n;
 
16
    ngx_err_t     err;
 
17
    ngx_event_t  *wev;
 
18
 
 
19
    wev = c->write;
 
20
 
 
21
#if (NGX_HAVE_KQUEUE)
 
22
 
 
23
    if ((ngx_event_flags & NGX_USE_KQUEUE_EVENT) && wev->pending_eof) {
 
24
        (void) ngx_connection_error(c, wev->kq_errno,
 
25
                               "kevent() reported about an closed connection");
 
26
        wev->error = 1;
 
27
        return NGX_ERROR;
 
28
    }
 
29
 
 
30
#endif
 
31
 
 
32
    for ( ;; ) {
 
33
        n = send(c->fd, buf, size, 0);
 
34
 
 
35
        ngx_log_debug3(NGX_LOG_DEBUG_EVENT, c->log, 0,
 
36
                       "send: fd:%d %d of %d", c->fd, n, size);
 
37
 
 
38
        if (n > 0) {
 
39
            if (n < (ssize_t) size) {
 
40
                wev->ready = 0;
 
41
            }
 
42
 
 
43
            c->sent += n;
 
44
 
 
45
            return n;
 
46
        }
 
47
 
 
48
        err = ngx_socket_errno;
 
49
 
 
50
        if (n == 0) {
 
51
            ngx_log_error(NGX_LOG_ALERT, c->log, err, "send() returned zero");
 
52
            wev->ready = 0;
 
53
            return n;
 
54
        }
 
55
 
 
56
        if (err == NGX_EAGAIN || err == NGX_EINTR) {
 
57
            wev->ready = 0;
 
58
 
 
59
            ngx_log_debug0(NGX_LOG_DEBUG_EVENT, c->log, err,
 
60
                           "send() not ready");
 
61
 
 
62
            if (err == NGX_EAGAIN) {
 
63
                return NGX_AGAIN;
 
64
            }
 
65
 
 
66
        } else {
 
67
            wev->error = 1;
 
68
            (void) ngx_connection_error(c, err, "send() failed");
 
69
            return NGX_ERROR;
 
70
        }
 
71
    }
 
72
}