Home
last modified time | relevance | path

Searched refs:sent (Results 1 – 22 of 22) sorted by path

/unit/
H A DLICENSE55 means any form of electronic, verbal, or written communication sent
/unit/auto/
H A Dsendfile47 off_t sent;
49 sendfile(-1, -1, 0, 0, NULL, &sent, 0);
73 off_t sent;
75 sendfile(-1, -1, 0, &sent, NULL, 0);
104 size_t sent;
107 sendfilev(-1, &vec, 0, &sent);
/unit/pkg/deb/debian.module/
H A Dcopyright.unit-jsc-common340 means any form of electronic, verbal, or written communication sent
/unit/pkg/rpm/rpmbuild/SOURCES/
H A DCOPYRIGHT.unit-jsc-common340 means any form of electronic, verbal, or written communication sent
/unit/src/java/nginx/unit/websocket/
H A DLocalStrings.properties61 wsFrame.controlPayloadTooBig=A control frame was sent with a payload of size [{0}] which is larger …
62 wsFrame.controlNoFin=A control frame was sent that did not have the fin bit set. Control frames are…
64 wsFrame.invalidOpCode= A WebSocket frame was sent with an unrecognised opCode of [{0}]
71 wsFrame.oneByteCloseCode=The client sent a close frame with a single byte payload which is not valid
78 wsFrameClient.ioe=Failure while reading data sent by server
83 wsRemoteEndpoint.acquireTimeout=The current message was not fully sent within the specified timeout
84 wsRemoteEndpoint.closed=Message will not be sent because the WebSocket session has been closed
85 wsRemoteEndpoint.closedDuringMessage=The remainder of the message will not be sent because the WebS…
89 wsRemoteEndpoint.concurrentMessageSend=Messages may not be sent concurrently even when using the as…
/unit/src/
H A Dnxt_aix_send_file.c22 nxt_off_t file_size, sent; in nxt_aix_event_conn_io_send_file() local
80 sent = sfp.bytes_sent; in nxt_aix_event_conn_io_send_file()
83 c->socket.fd, n, sent); in nxt_aix_event_conn_io_send_file()
114 return sent; in nxt_aix_event_conn_io_send_file()
118 return sent; in nxt_aix_event_conn_io_send_file()
121 if (sent < (nxt_off_t) sb.size) { in nxt_aix_event_conn_io_send_file()
125 return sent; in nxt_aix_event_conn_io_send_file()
H A Dnxt_conn.h136 nxt_off_t sent; member
262 nxt_conn_t *c, size_t sent);
H A Dnxt_conn_write.c47 sb.sent = 0; in nxt_conn_io_write()
68 sb.sent += ret; in nxt_conn_io_write()
89 if (sb.sent != 0) { in nxt_conn_io_write()
121 if (ret == 0 || sb.sent != 0) { in nxt_conn_io_write()
127 c->sent += sb.sent; in nxt_conn_io_write()
251 off_t sent = size; in nxt_sendfile() local
253 int rc = sendfile(fd, s, pos, &sent, NULL, 0); in nxt_sendfile()
255 res = (rc == 0 || sent > 0) ? sent : -1; in nxt_sendfile()
259 off_t sent = 0; in nxt_sendfile() local
263 res = (rc == 0 || sent > 0) ? sent : -1; in nxt_sendfile()
[all …]
H A Dnxt_event_conn_job_sendfile.c13 size_t sent; member
123 jbs->sent += ret; in nxt_event_conn_job_sendfile_handler()
165 size_t sent; in nxt_event_conn_job_sendfile_return() local
177 sent = jbs->sent; in nxt_event_conn_job_sendfile_return()
178 c->sent += sent; in nxt_event_conn_job_sendfile_return()
180 nxt_debug(task, "event conn sendfile sent:%z", sent); in nxt_event_conn_job_sendfile_return()
208 if (sent != 0 && c->write_state->timer_autoreset) { in nxt_event_conn_job_sendfile_return()
213 && !nxt_event_conn_write_delayed(task->thread->engine, c, sent)) in nxt_event_conn_job_sendfile_return()
221 if (sent != 0) { in nxt_event_conn_job_sendfile_return()
H A Dnxt_freebsd_sendfile.c40 nxt_off_t sent; in nxt_freebsd_event_conn_io_sendfile() local
99 sent = 0; in nxt_freebsd_event_conn_io_sendfile()
101 file_size, ht, &sent, 0); in nxt_freebsd_event_conn_io_sendfile()
105 nxt_debug(c->socket.task, "sendfile(): %d sent:%O", n, sent); in nxt_freebsd_event_conn_io_sendfile()
129 return sent; in nxt_freebsd_event_conn_io_sendfile()
131 } else if (sent == 0) { in nxt_freebsd_event_conn_io_sendfile()
138 if (sent < (nxt_off_t) sb.size) { in nxt_freebsd_event_conn_io_sendfile()
142 return sent; in nxt_freebsd_event_conn_io_sendfile()
H A Dnxt_h1proto.c1556 nxt_off_t sent; in nxt_h1p_request_body_bytes_sent() local
1561 sent = h1p->conn->sent - h1p->header_size; in nxt_h1p_request_body_bytes_sent()
1563 return (sent > 0) ? sent : 0; in nxt_h1p_request_body_bytes_sent()
1811 c->sent = 0; in nxt_h1p_keepalive()
H A Dnxt_macosx_sendfile.c35 nxt_off_t sent; in nxt_macosx_event_conn_io_sendfile() local
102 sent = hd_size + file_size; in nxt_macosx_event_conn_io_sendfile()
106 fb->file->fd, c->socket.fd, fb->file_pos, sent, in nxt_macosx_event_conn_io_sendfile()
110 fb->file_pos, &sent, ht, 0); in nxt_macosx_event_conn_io_sendfile()
114 nxt_debug(c->socket.task, "sendfile(): %d sent:%O", n, sent); in nxt_macosx_event_conn_io_sendfile()
130 fb->file->fd, c->socket.fd, fb->file_pos, sent, err, in nxt_macosx_event_conn_io_sendfile()
138 return sent; in nxt_macosx_event_conn_io_sendfile()
141 if (sent == 0) { in nxt_macosx_event_conn_io_sendfile()
148 if (sent < (nxt_off_t) sb.size) { in nxt_macosx_event_conn_io_sendfile()
152 return sent; in nxt_macosx_event_conn_io_sendfile()
H A Dnxt_port_socket.c28 nxt_work_queue_t *wq, nxt_buf_t *b, size_t sent, nxt_bool_t mmap_mode);
619 size_t sent, nxt_bool_t mmap_mode) in nxt_port_buf_completion() argument
634 if (sent == 0) { in nxt_port_buf_completion()
646 if (sent < size) { in nxt_port_buf_completion()
649 b->mem.pos += sent; in nxt_port_buf_completion()
653 b->file_pos += sent; in nxt_port_buf_completion()
666 sent -= size; in nxt_port_buf_completion()
H A Dnxt_recvbuf.c59 nxt_recvbuf_update(nxt_buf_t *b, size_t sent) in nxt_recvbuf_update() argument
63 while (b != NULL && sent != 0) { in nxt_recvbuf_update()
71 if (sent < size) { in nxt_recvbuf_update()
72 b->mem.free += sent; in nxt_recvbuf_update()
77 sent -= size; in nxt_recvbuf_update()
H A Dnxt_recvbuf.h21 void nxt_recvbuf_update(nxt_buf_t *b, size_t sent);
H A Dnxt_sendbuf.c331 nxt_sendbuf_update(nxt_buf_t *b, size_t sent) in nxt_sendbuf_update() argument
345 if (sent == 0) { in nxt_sendbuf_update()
349 if (sent < size) { in nxt_sendbuf_update()
352 b->mem.pos += sent; in nxt_sendbuf_update()
356 b->file_pos += sent; in nxt_sendbuf_update()
369 sent -= size; in nxt_sendbuf_update()
H A Dnxt_sendbuf.h43 nxt_off_t sent; member
125 nxt_buf_t *nxt_sendbuf_update(nxt_buf_t *b, size_t sent);
H A Dnxt_solaris_sendfilev.c28 size_t sent; in nxt_solaris_event_conn_io_sendfilev() local
51 sent = 0; in nxt_solaris_event_conn_io_sendfilev()
52 n = sendfilev(c->socket.fd, sfv, nsfv, &sent); in nxt_solaris_event_conn_io_sendfilev()
56 nxt_debug(c->socket.task, "sendfilev(): %d sent:%uz", n, sent); in nxt_solaris_event_conn_io_sendfilev()
78 return sent; in nxt_solaris_event_conn_io_sendfilev()
81 if ((nxt_off_t) sent < size) { in nxt_solaris_event_conn_io_sendfilev()
85 return sent; in nxt_solaris_event_conn_io_sendfilev()
H A Dnxt_unit.c2889 ssize_t sent; in nxt_unit_response_write_nb() local
2901 sent = 0; in nxt_unit_response_write_nb()
2926 sent += part_size; in nxt_unit_response_write_nb()
2944 return sent; in nxt_unit_response_write_nb()
2958 sent += part_size; in nxt_unit_response_write_nb()
2963 return sent; in nxt_unit_response_write_nb()
/unit/src/python/
H A Dnxt_python_asgi_http.c360 ssize_t sent; in nxt_py_asgi_http_response_body() local
437 body_str += sent; in nxt_py_asgi_http_response_body()
438 body_len -= sent; in nxt_py_asgi_http_response_body()
439 body_off += sent; in nxt_py_asgi_http_response_body()
440 http->bytes_sent += sent; in nxt_py_asgi_http_response_body()
561 ssize_t sent; in nxt_py_asgi_http_drain() local
575 if (nxt_slow_path(sent < 0)) { in nxt_py_asgi_http_drain()
583 body_str += sent; in nxt_py_asgi_http_drain()
584 body_len -= sent; in nxt_py_asgi_http_drain()
586 http->send_body_off += sent; in nxt_py_asgi_http_drain()
[all …]
H A Dnxt_python_asgi_lifespan.c42 int v, int *sent, PyObject **future);
532 nxt_py_asgi_lifespan_send_(nxt_py_asgi_lifespan_t *lifespan, int v, int *sent, in nxt_py_asgi_lifespan_send_() argument
537 if (*sent) { in nxt_py_asgi_lifespan_send_()
541 *sent = 1 + v; in nxt_py_asgi_lifespan_send_()
/unit/tools/
H A Dsetup-unit333 sent back to the control API socket.