/unit/src/ |
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_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_conf_validation.c | 1446 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 D | nxt_http_variables.c | 27 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 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()
|
H A D | nxt_file.h | 155 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 D | nxt_file.c | 166 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 D | nxt_conn_write.c | 49 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 D | nxt_conf.c | 99 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 D | nxt_http_request.c | 30 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 D | nxt_clone.c | 76 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 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_php_sapi.c | 1581 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 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_sprintf.c | 159 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 D | nxt_controller.c | 124 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 D | nxt_unit.c | 1430 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 D | nxt_socket_msg.h | 47 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 D | nxt_http.h | 304 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 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()
|
/unit/src/java/nginx/unit/websocket/ |
H A D | DigestAuthenticator.java | 25 import org.apache.tomcat.util.buf.HexUtils;
|
/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/test/go/mirror/ |
H A D | app.go | 11 var buf [32768]byte 12 len, _ := r.Body.Read(buf[:]) 15 io.WriteString(w, string(buf[:len]))
|
/unit/test/go/variables/ |
H A D | app.go | 11 var buf [4096]byte 12 len, _ := r.Body.Read(buf[:]) 24 io.WriteString(w, string(buf[:len]))
|
/unit/src/java/ |
H A D | nxt_jni_Response.c | 331 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 …]
|