Home
last modified time | relevance | path

Searched refs:buf (Results 1 – 25 of 92) sorted by last modified time

1234

/unit/src/
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_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_conf_validation.c1446 u_char buf[nxt_length(NXT_CONF_VLDT_ANY_TYPE_STR)]; in nxt_conf_vldt_type() local
1464 p = buf; in nxt_conf_vldt_type()
1498 expected.length = p - buf; in nxt_conf_vldt_type()
1499 expected.start = buf; in nxt_conf_vldt_type()
H A Dnxt_http_variables.c27 static u_char *nxt_http_log_date(u_char *buf, nxt_realtime_t *now,
363 nxt_http_log_date(u_char *buf, nxt_realtime_t *now, struct tm *tm, in nxt_http_log_date() argument
382 return nxt_sprintf(buf, buf + size, format, in nxt_http_log_date()
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()
H A Dnxt_file.h155 NXT_EXPORT ssize_t nxt_file_write(nxt_file_t *file, const u_char *buf,
157 NXT_EXPORT ssize_t nxt_file_read(nxt_file_t *file, u_char *buf, size_t size,
187 NXT_EXPORT ssize_t nxt_fd_write(nxt_fd_t fd, u_char *buf, size_t size);
188 NXT_EXPORT ssize_t nxt_fd_read(nxt_fd_t fd, u_char *buf, size_t size);
205 #define nxt_write_console(fd, buf, size) \ argument
206 write(fd, buf, size)
216 NXT_EXPORT size_t nxt_dir_current(char *buf, size_t len);
H A Dnxt_file.c166 u_char buf; in nxt_file_read_ahead() local
228 u_char buf; in nxt_file_read_ahead() local
248 u_char buf; in nxt_file_read_ahead() local
332 char *buf; in nxt_file_chown() local
350 if (buf == NULL) { in nxt_file_chown()
364 nxt_free(buf); in nxt_file_chown()
376 if (buf == NULL) { in nxt_file_chown()
390 nxt_free(buf); in nxt_file_chown()
404 nxt_free(buf); in nxt_file_chown()
535 n = write(fd, buf, size); in nxt_fd_write()
[all …]
H A Dnxt_conn_write.c49 sb.buf = b; in nxt_conn_io_write()
78 sb.buf = b; in nxt_conn_io_write()
178 if (niov == 0 && sb->buf == NULL) { in nxt_conn_io_sendbuf()
182 if (niov == 0 && nxt_buf_is_file(sb->buf)) { in nxt_conn_io_sendbuf()
198 b = sb->buf; in nxt_conn_io_sendfile()
358 n = send(sb->socket, buf, size, 0); in nxt_conn_io_send()
443 sb.buf = b; in nxt_event_conn_io_sendbuf()
506 nxt_event_conn_io_send(nxt_conn_t *c, void *buf, size_t size) in nxt_event_conn_io_send() argument
512 n = send(c->socket.fd, buf, size, 0); in nxt_event_conn_io_send()
517 c->socket.fd, buf, size, n); in nxt_event_conn_io_send()
[all …]
H A Dnxt_conf.c99 u_char buf[NXT_CONF_MAX_TOKEN_LEN]; member
540 end = nxt_decode_uri(parse->buf, start, length); in nxt_conf_path_next_token()
545 token->length = end - parse->buf; in nxt_conf_path_next_token()
546 token->start = parse->buf; in nxt_conf_path_next_token()
H A Dnxt_http_request.c30 static u_char *nxt_http_date_cache_handler(u_char *buf, nxt_realtime_t *now,
923 nxt_http_date_cache_handler(u_char *buf, nxt_realtime_t *now, struct tm *tm, in nxt_http_date_cache_handler() argument
926 return nxt_http_date(buf, tm); in nxt_http_date_cache_handler()
H A Dnxt_clone.c76 u_char buf[256]; in nxt_clone_credential_map_write() local
78 end = buf + sizeof(buf); in nxt_clone_credential_map_write()
80 p = nxt_sprintf(buf, end, "/proc/%d/%s", pid, mapfile); in nxt_clone_credential_map_write()
88 mapfd = open((char*)buf, O_RDWR); in nxt_clone_credential_map_write()
90 nxt_alert(task, "failed to open proc map (%s) %E", buf, nxt_errno); in nxt_clone_credential_map_write()
101 "allowed lines %E", buf, nxt_errno); in nxt_clone_credential_map_write()
104 nxt_alert(task, "failed to write proc map (%s) %E", buf, in nxt_clone_credential_map_write()
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_php_sapi.c1581 char buf[256]; local
1583 if (nxt_slow_path(str->length >= (sizeof(buf) - 1))) {
1587 nxt_memcpy(buf, str->start, str->length);
1588 buf[str->length] = '\0';
1590 ret = zend_hash_find(ht, buf, str->length + 1, &entry);
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_sprintf.c159 buf = nxt_cpymem(buf, null, nxt_length(null)); in nxt_vsprintf()
179 buf = nxt_cpymem(buf, null, nxt_length(null)); in nxt_vsprintf()
259 buf = nxt_integer(&spf, buf, err); in nxt_vsprintf()
266 buf = nxt_strerror(err, buf, end - buf); in nxt_vsprintf()
419 buf = nxt_number(&spf, buf, i); in nxt_vsprintf()
429 buf = nxt_integer(&spf, buf, frac); in nxt_vsprintf()
558 buf = nxt_integer(&spf, buf, ui64); in nxt_vsprintf()
566 buf = nxt_cpymem(buf, p, length); in nxt_vsprintf()
570 return buf; in nxt_vsprintf()
682 return buf; in nxt_integer()
[all …]
H A Dnxt_controller.c124 static u_char *nxt_controller_date(u_char *buf, nxt_realtime_t *now,
494 nxt_assert(nxt_buf_used_size(msg->buf) == sizeof(pid)); in nxt_controller_remove_pid_handler()
496 nxt_memcpy(&pid, msg->buf->mem.pos, sizeof(pid)); in nxt_controller_remove_pid_handler()
1636 status = nxt_status_get((nxt_status_report_t *) msg->buf->mem.pos, in nxt_controller_status_handler()
2246 nxt_buf_mem_used_size(&msg->buf->mem), msg->buf->mem.pos); in nxt_controller_conf_handler()
2652 nxt_controller_date(u_char *buf, nxt_realtime_t *now, struct tm *tm, in nxt_controller_date() argument
2661 return nxt_sprintf(buf, buf + size, format, in nxt_controller_date()
H A Dnxt_unit.c1430 l += b->buf.end - b->buf.free; in nxt_unit_process_req_body()
2649 buf = &mmap_buf->buf; in nxt_unit_mmap_buf_send()
2689 buf->free = buf->start; in nxt_unit_mmap_buf_send()
3043 buf = &mmap_buf.buf; in nxt_unit_response_write_cb()
3228 copy = buf->end - buf->free; in nxt_unit_buf_read()
3244 buf = nxt_unit_buf_next(buf); in nxt_unit_buf_read()
3359 buf = &mmap_buf.buf; in nxt_unit_websocket_sendv()
3407 if (buf->free > buf->start) { in nxt_unit_websocket_sendv()
3454 size = ws_impl->buf->buf.end - ws_impl->buf->buf.start; in nxt_unit_websocket_retain()
3465 ws_impl->buf->buf.start = b; in nxt_unit_websocket_retain()
[all …]
H A Dnxt_socket_msg.h47 u_char buf[NXT_OOB_RECV_SIZE]; member
53 u_char buf[NXT_OOB_SEND_SIZE]; member
93 cmsg = (struct cmsghdr *) (oob->buf); in nxt_socket_msg_oob_init()
117 cmsg = (struct cmsghdr *) (oob->buf + oob->size); in nxt_socket_msg_oob_init()
147 msg.msg_control = oob->buf; in nxt_socket_msg_oob_get_fds()
186 msg.msg_control = oob->buf; in nxt_socket_msg_oob_get()
H A Dnxt_http.h304 nxt_http_date(u_char *buf, struct tm *tm) in nxt_http_date() argument
312 return nxt_sprintf(buf, buf + NXT_HTTP_DATE_LEN, in nxt_http_date()
/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()
/unit/src/java/nginx/unit/websocket/
H A DDigestAuthenticator.java25 import org.apache.tomcat.util.buf.HexUtils;
/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/test/go/mirror/
H A Dapp.go11 var buf [32768]byte
12 len, _ := r.Body.Read(buf[:])
15 io.WriteString(w, string(buf[:len]))
/unit/test/go/variables/
H A Dapp.go11 var buf [4096]byte
12 len, _ := r.Body.Read(buf[:])
24 io.WriteString(w, string(buf[:len]))
/unit/src/java/
H A Dnxt_jni_Response.c331 buf = req->response_buf; in nxt_java_get_response_info()
335 || extra_data > (uint32_t) (buf->end - buf->free)) in nxt_java_get_response_info()
930 if (data->buf != NULL && data->buf->free > data->buf->start) { in nxt_java_Response_reset()
931 data->buf->free = data->buf->start; in nxt_java_Response_reset()
940 buf->free = buf->start + sizeof(nxt_unit_response_t) in nxt_java_Response_reset()
955 if (data->buf != NULL && data->buf->free > data->buf->start) { in nxt_java_Response_resetBuffer()
956 data->buf->free = data->buf->start; in nxt_java_Response_resetBuffer()
975 if (data->buf != NULL && data->buf->free > data->buf->start) { in nxt_java_Response_setBufferSize()
987 if (data->buf != NULL in nxt_java_Response_setBufferSize()
988 && (uint32_t) (data->buf->end - data->buf->start) < data->buf_size) in nxt_java_Response_setBufferSize()
[all …]

1234