Home
last modified time | relevance | path

Searched refs:buf (Results 51 – 75 of 92) sorted by relevance

1234

/unit/src/
H A Dnxt_conn_read.c140 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 Dnxt_gnutls.c37 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 Dnxt_unit.h153 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 Dnxt_main_process.c66 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 Dnxt_recvbuf.h12 nxt_buf_t *buf; member
H A Dnxt_sendbuf.c29 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 Dnxt_conn.h56 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 Dnxt_sendbuf.h39 nxt_buf_t *buf; member
55 nxt_buf_t *buf; member
H A Dnxt_router_request.h11 nxt_buf_t *buf; member
H A Dnxt_sockaddr.h85 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 Dnxt_process.c763 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 Dnxt_event_engine.c269 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 Dnxt_port_rpc.c372 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 Dnxt_router.c549 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 Dnxt_openssl.c96 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 Dnxt_h1proto_websocket.c586 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 Dnxt_recvbuf.c22 for (b = rb->buf; b != NULL; b = b->next) { in nxt_recvbuf_mem_coalesce()
H A Dnxt_port.h196 nxt_buf_t *buf; member
210 nxt_buf_t *buf; member
314 nxt_buf_t buf; member
H A Dnxt_socket.h80 struct sockaddr buf; member
H A Dnxt_java.c519 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 Dnxt_runtime.c951 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 Dnxt_jni.h38 nxt_unit_buf_t *buf; member
/unit/src/python/
H A Dnxt_python_wsgi.c82 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 Dunit.cpp944 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 Dnxt_napi.h366 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()

1234