/unit/src/ |
H A D | nxt_conn_read.c | 140 rb.buf = b; in nxt_conn_io_recvbuf() 198 nxt_conn_io_recv(nxt_conn_t *c, void *buf, size_t size, nxt_uint_t flags) in nxt_conn_io_recv() argument 204 n = recv(c->socket.fd, buf, size, flags); in nxt_conn_io_recv() 209 c->socket.fd, buf, size, flags, n); in nxt_conn_io_recv() 247 c->socket.fd, buf, size, flags, err); in nxt_conn_io_recv()
|
H A D | nxt_gnutls.c | 37 static ssize_t nxt_gnutls_pull(gnutls_transport_ptr_t data, void *buf, 39 static ssize_t nxt_gnutls_push(gnutls_transport_ptr_t data, const void *buf, 49 static ssize_t nxt_gnutls_conn_io_send(nxt_event_conn_t *c, void *buf, 352 nxt_gnutls_pull(gnutls_transport_ptr_t data, void *buf, size_t size) in nxt_gnutls_pull() argument 361 n = thr->engine->event->io->recv(c, buf, size, 0); in nxt_gnutls_pull() 373 nxt_gnutls_push(gnutls_transport_ptr_t data, const void *buf, size_t size) in nxt_gnutls_push() argument 382 n = thr->engine->event->io->send(c, (u_char *) buf, size); in nxt_gnutls_push() 540 nxt_gnutls_conn_io_send(nxt_event_conn_t *c, void *buf, size_t size) in nxt_gnutls_conn_io_send() argument 548 n = gnutls_record_send(ssltls->session, buf, size); in nxt_gnutls_conn_io_send() 551 c->socket.fd, buf, size, n); in nxt_gnutls_conn_io_send() [all …]
|
H A D | nxt_unit.h | 153 const void *buf, size_t buf_size, 158 void *buf, size_t buf_size, void *oob, size_t *oob_size); 294 int nxt_unit_buf_send(nxt_unit_buf_t *buf); 296 void nxt_unit_buf_free(nxt_unit_buf_t *buf); 298 nxt_unit_buf_t *nxt_unit_buf_next(nxt_unit_buf_t *buf);
|
H A D | nxt_main_process.c | 66 const char *name, u_char *buf, size_t size); 410 nxt_buf_mem_used_size(&msg->buf->mem), msg->buf->mem.pos); in nxt_main_data_handler() 697 nxt_buf_t *buf; in nxt_main_process_whoami_handler() local 705 if (nxt_slow_path(msg->buf == NULL in nxt_main_process_whoami_handler() 759 if (nxt_slow_path(buf == NULL)) { in nxt_main_process_whoami_handler() 763 buf->mem.free = nxt_cpymem(buf->mem.free, &pid, sizeof(nxt_pid_t)); in nxt_main_process_whoami_handler() 1134 b = msg->buf; in nxt_main_port_socket_handler() 1320 b = msg->buf; in nxt_main_port_socket_unlink_handler() 1443 b = msg->buf; in nxt_main_port_modules_handler() 1670 u_char *buf, size_t size) in nxt_main_file_store() argument [all …]
|
H A D | nxt_recvbuf.h | 12 nxt_buf_t *buf; member
|
H A D | nxt_sendbuf.c | 29 for (b = sb->buf; b != NULL && total < sb->limit; b = b->next) { in nxt_sendbuf_mem_coalesce0() 81 sb->buf = b; in nxt_sendbuf_mem_coalesce0() 99 for (b = sb->buf; b != NULL && total < sb->limit; b = b->next) { in nxt_sendbuf_mem_coalesce() 155 sb->buf = b; in nxt_sendbuf_mem_coalesce() 171 b = sb->buf; in nxt_sendbuf_file_coalesce() 201 sb->buf = b; in nxt_sendbuf_file_coalesce()
|
H A D | nxt_conn.h | 56 ssize_t (*recv)(nxt_conn_t *c, void *buf, 83 ssize_t (*send)(nxt_conn_t *c, void *buf, 250 ssize_t nxt_conn_io_recv(nxt_conn_t *c, void *buf, size_t size, 257 ssize_t nxt_conn_io_send(nxt_task_t *task, nxt_sendbuf_t *sb, void *buf, 265 ssize_t nxt_event_conn_io_send(nxt_conn_t *c, void *buf, size_t size);
|
H A D | nxt_sendbuf.h | 39 nxt_buf_t *buf; member 55 nxt_buf_t *buf; member
|
H A D | nxt_router_request.h | 11 nxt_buf_t *buf; member
|
H A D | nxt_sockaddr.h | 85 NXT_EXPORT in_addr_t nxt_inet_addr(u_char *buf, size_t len); 87 NXT_EXPORT nxt_int_t nxt_inet6_addr(struct in6_addr *in6_addr, u_char *buf,
|
H A D | nxt_process.c | 763 nxt_buf_t *buf; in nxt_process_whoami() local 777 buf = nxt_buf_mem_alloc(main_port->mem_pool, sizeof(nxt_pid_t), 0); in nxt_process_whoami() 778 if (nxt_slow_path(buf == NULL)) { in nxt_process_whoami() 782 buf->mem.free = nxt_cpymem(buf->mem.free, &nxt_ppid, sizeof(nxt_pid_t)); in nxt_process_whoami() 789 nxt_mp_free(main_port->mem_pool, buf); in nxt_process_whoami() 797 fd, stream, my_port->id, buf); in nxt_process_whoami() 802 nxt_mp_free(main_port->mem_pool, buf); in nxt_process_whoami() 815 nxt_buf_t *buf; in nxt_process_whoami_ok() local 822 buf = msg->buf; in nxt_process_whoami_ok() 824 nxt_assert(nxt_buf_used_size(buf) == sizeof(nxt_pid_t)); in nxt_process_whoami_ok() [all …]
|
H A D | nxt_event_engine.c | 269 u_char buf; in nxt_event_engine_signal() local 283 buf = (u_char) signo; in nxt_event_engine_signal() 284 (void) nxt_fd_write(engine->pipe->fds[1], &buf, 1); in nxt_event_engine_signal() 295 u_char buf[128]; in nxt_event_engine_signal_pipe() local 304 n = nxt_fd_read(ev->fd, buf, sizeof(buf)); in nxt_event_engine_signal_pipe() 307 signo = buf[i]; in nxt_event_engine_signal_pipe() 321 } while (n == sizeof(buf)); in nxt_event_engine_signal_pipe()
|
H A D | nxt_port_rpc.c | 372 nxt_buf_t buf; in nxt_port_rpc_remove_peer() local 390 nxt_memzero(&buf, sizeof(buf)); in nxt_port_rpc_remove_peer() 394 msg.buf = &buf; in nxt_port_rpc_remove_peer() 506 msg.buf = &nxt_port_close_dummy_buf; in nxt_port_rpc_close()
|
H A D | nxt_router.c | 549 if (msg_info->buf == NULL) { in nxt_router_msg_cancel() 580 msg_info->buf = NULL; in nxt_router_msg_cancel() 4101 if (msg->buf == b) { in nxt_router_response_ready_handler() 4103 msg->buf = NULL; in nxt_router_response_ready_handler() 5277 req_rpc_data->msg_info.buf = buf; in nxt_router_app_prepare_request() 5321 buf->mem.pos = buf->mem.free; in nxt_router_app_prepare_request() 5610 buf = out; in nxt_router_prepare_msg() 5611 tail = &buf->next; in nxt_router_prepare_msg() 5632 *tail = buf; in nxt_router_prepare_msg() 5648 buf->mem.free = nxt_cpymem(buf->mem.free, pos, copy_size); in nxt_router_prepare_msg() [all …]
|
H A D | nxt_openssl.c | 96 void *buf, size_t size); 639 u_char buf[80]; local 685 len = nxt_base64_decode(buf, value.start, value.length); 687 nxt_memcpy(ticket->name, buf, 16); 690 nxt_memcpy(ticket->aes_key, buf + 16, 16); 691 nxt_memcpy(ticket->hmac_key, buf + 32, 16); 695 nxt_memcpy(ticket->hmac_key, buf + 16, 32); 696 nxt_memcpy(ticket->aes_key, buf + 48, 32); 1394 ret = SSL_write(tls->session, buf, size); 1399 sb->socket, buf, size, ret, err); [all …]
|
H A D | nxt_h1proto_websocket.c | 586 u_char buf[125]; in hxt_h1p_send_ws_error() local 590 p = nxt_vsprintf(buf, buf + sizeof(buf), (char *) err->desc.start, in hxt_h1p_send_ws_error() 594 desc.start = buf; in hxt_h1p_send_ws_error() 595 desc.length = p - buf; in hxt_h1p_send_ws_error()
|
H A D | nxt_recvbuf.c | 22 for (b = rb->buf; b != NULL; b = b->next) { in nxt_recvbuf_mem_coalesce()
|
H A D | nxt_port.h | 196 nxt_buf_t *buf; member 210 nxt_buf_t *buf; member 314 nxt_buf_t buf; member
|
H A D | nxt_socket.h | 80 struct sockaddr buf; member
|
H A D | nxt_java.c | 519 data->buf = NULL; in nxt_java_request_handler() 538 if (data->buf != NULL) { in nxt_java_request_handler() 539 nxt_unit_buf_send(data->buf); in nxt_java_request_handler() 541 data->buf = NULL; in nxt_java_request_handler()
|
H A D | nxt_runtime.c | 951 u_char buf[1024]; in nxt_runtime_conf_read_cmd() local 1224 end = nxt_sprintf(buf, buf + sizeof(buf), "unknown option \"%s\", " in nxt_runtime_conf_read_cmd() 1228 write(STDERR_FILENO, buf, end - buf); in nxt_runtime_conf_read_cmd() 1462 char buf[NXT_MAX_PATH_LEN]; in nxt_current_directory() local 1464 length = nxt_dir_current(buf, NXT_MAX_PATH_LEN); in nxt_current_directory() 1470 p = nxt_cpymem(name->start, buf, length); in nxt_current_directory()
|
/unit/src/java/ |
H A D | nxt_jni.h | 38 nxt_unit_buf_t *buf; member
|
/unit/src/python/ |
H A D | nxt_python_wsgi.c | 82 static int nxt_python_str_buf(PyObject *str, char **buf, uint32_t *len, 1129 nxt_python_str_buf(PyObject *str, char **buf, uint32_t *len, PyObject **bytes) in nxt_python_str_buf() argument 1132 *buf = PyBytes_AS_STRING(str); in nxt_python_str_buf() 1142 *buf = PyBytes_AS_STRING(*bytes); in nxt_python_str_buf() 1180 char *buf; in nxt_py_input_read() local 1224 buf = PyBytes_AS_STRING(content); in nxt_py_input_read() 1226 size = nxt_unit_request_read(pctx->req, buf, size); in nxt_py_input_read() 1281 void *buf; in nxt_py_input_getline() local 1299 buf = PyBytes_AS_STRING(content); in nxt_py_input_getline() 1301 res = nxt_unit_request_read(pctx->req, buf, res); in nxt_py_input_getline()
|
/unit/src/nodejs/unit-http/ |
H A D | unit.cpp | 944 nxt_unit_buf_t *buf; in response_write() local 969 buf = req->response_buf; in response_write() 972 buf = nxt_unit_response_buf_alloc(req, buf_len); in response_write() 973 if (buf == NULL) { in response_write() 978 have_buf_len = napi.get_value_string_utf8(argv[0], buf->free, in response_write() 981 buf->free += have_buf_len; in response_write() 983 ret = nxt_unit_buf_send(buf); in response_write()
|
H A D | nxt_napi.h | 366 get_value_string_latin1(napi_value val, char *buf, size_t bufsize) in get_value_string_latin1() 371 status = napi_get_value_string_latin1(env_, val, buf, bufsize, &res); in get_value_string_latin1() 396 get_value_string_utf8(napi_value val, char *buf, size_t bufsize) in get_value_string_utf8() 401 status = napi_get_value_string_utf8(env_, val, buf, bufsize, &res); in get_value_string_utf8()
|