Deleted
Added
nxt_socketpair.c (564:762f8c976ead) | nxt_socketpair.c (1003:a7122e3c6e06) |
---|---|
1 2/* 3 * Copyright (C) Igor Sysoev 4 * Copyright (C) NGINX, Inc. 5 */ 6 7#include <nxt_main.h> 8 --- 80 unchanged lines hidden (view full) --- 89 } 90 91 /* n == -1 */ 92 93 switch (err) { 94 95 case NXT_EAGAIN: 96 nxt_debug(ev->task, "sendmsg(%d) not ready", ev->fd); | 1 2/* 3 * Copyright (C) Igor Sysoev 4 * Copyright (C) NGINX, Inc. 5 */ 6 7#include <nxt_main.h> 8 --- 80 unchanged lines hidden (view full) --- 89 } 90 91 /* n == -1 */ 92 93 switch (err) { 94 95 case NXT_EAGAIN: 96 nxt_debug(ev->task, "sendmsg(%d) not ready", ev->fd); |
97 ev->write_ready = 0; | 97 break; |
98 | 98 |
99 return NXT_AGAIN; | 99 /* 100 * Returned (at least on OSX) when trying to send many small messages. 101 */ 102 case NXT_ENOBUFS: 103 nxt_debug(ev->task, "sendmsg(%d) no buffers", ev->fd); 104 break; |
100 101 case NXT_EINTR: 102 nxt_debug(ev->task, "sendmsg(%d) interrupted", ev->fd); 103 continue; 104 105 default: 106 nxt_alert(ev->task, "sendmsg(%d, %FD, %ui) failed %E", 107 ev->fd, fd, niob, err); 108 109 return NXT_ERROR; 110 } | 105 106 case NXT_EINTR: 107 nxt_debug(ev->task, "sendmsg(%d) interrupted", ev->fd); 108 continue; 109 110 default: 111 nxt_alert(ev->task, "sendmsg(%d, %FD, %ui) failed %E", 112 ev->fd, fd, niob, err); 113 114 return NXT_ERROR; 115 } |
116 117 ev->write_ready = 0; 118 119 return NXT_AGAIN; |
|
111 } 112} 113 114 115ssize_t 116nxt_socketpair_recv(nxt_fd_event_t *ev, nxt_fd_t *fd, nxt_iobuf_t *iob, 117 nxt_uint_t niob) 118{ --- 182 unchanged lines hidden --- | 120 } 121} 122 123 124ssize_t 125nxt_socketpair_recv(nxt_fd_event_t *ev, nxt_fd_t *fd, nxt_iobuf_t *iob, 126 nxt_uint_t niob) 127{ --- 182 unchanged lines hidden --- |