/unit/src/ |
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_port.c | 268 new_port_msg = (nxt_port_msg_new_port_t *) msg->buf->mem.pos; in nxt_port_new_port_handler() 417 b = msg->buf; in nxt_port_change_log_file_handler() 443 b = msg->buf; in nxt_port_data_handler() 458 nxt_buf_t *buf; in nxt_port_remove_notify_others() local 488 if (nxt_slow_path(buf == NULL)) { in nxt_port_remove_notify_others() 492 buf->mem.free = nxt_cpymem(buf->mem.free, &pid, sizeof(pid)); in nxt_port_remove_notify_others() 495 process->stream, 0, buf); in nxt_port_remove_notify_others() 505 nxt_buf_t *buf; in nxt_port_remove_pid_handler() local 507 buf = msg->buf; in nxt_port_remove_pid_handler() 509 nxt_assert(nxt_buf_used_size(buf) == sizeof(pid)); in nxt_port_remove_pid_handler() [all …]
|
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_port_memory.c | 727 bmem = msg->buf; in nxt_port_mmap_write() 770 pb = &msg->buf; in nxt_port_mmap_read() 773 for (b = msg->buf; b != NULL; b = b->next) { in nxt_port_mmap_read()
|
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_port_socket.c | 176 msg.buf = b; in nxt_port_socket_write2() 225 msg.buf = NULL; in nxt_port_socket_write2() 407 sb.buf = msg->buf; in nxt_port_write_handler() 457 msg->buf = nxt_port_buf_completion(task, wq, msg->buf, plain_size, in nxt_port_write_handler() 775 msg.buf = b; in nxt_port_read_handler() 994 msg.buf = b; in nxt_port_queue_read_handler() 1189 b = orig_b = msg->buf; in nxt_port_read_msg_process() 1208 nxt_buf_chain_add(&fmsg->buf, msg->buf); in nxt_port_read_msg_process() 1211 msg->buf = NULL; in nxt_port_read_msg_process() 1220 msg->buf = fmsg->buf; in nxt_port_read_msg_process() [all …]
|
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_recvbuf.c | 22 for (b = rb->buf; b != NULL; b = b->next) { in nxt_recvbuf_mem_coalesce()
|
H A D | nxt_recvbuf.h | 12 nxt_buf_t *buf; member
|
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_router_request.h | 11 nxt_buf_t *buf; member
|
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_script.c | 348 u_char *buf, *p; in nxt_script_store_load() local 369 buf = NULL; in nxt_script_store_load() 407 p = nxt_realloc(buf, size); in nxt_script_store_load() 413 buf = p; in nxt_script_store_load() 421 file.name = buf; in nxt_script_store_load() 438 if (buf != NULL) { in nxt_script_store_load() 439 nxt_free(buf); in nxt_script_store_load() 448 if (buf != NULL) { in nxt_script_store_load() 449 nxt_free(buf); in nxt_script_store_load() 580 name.start = msg->buf->mem.pos; in nxt_script_store_get_handler() [all …]
|
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_sendbuf.h | 39 nxt_buf_t *buf; member 55 nxt_buf_t *buf; member
|
H A D | nxt_sockaddr.c | 445 return buf; in nxt_inet6_ntop() 479 p = buf; in nxt_inet6_ntop() 788 end = buf + length; in nxt_inet_addr() 790 while (buf < end) { in nxt_inet_addr() 792 c = *buf++; in nxt_inet_addr() 833 end = buf + length; in nxt_inet6_addr() 835 if (buf[0] == ':') { in nxt_inet6_addr() 836 buf++; in nxt_inet6_addr() 846 while (buf < end) { in nxt_inet6_addr() 847 c = *buf++; in nxt_inet6_addr() [all …]
|
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_socket.h | 80 struct sockaddr buf; member
|
H A D | nxt_socket_msg.c | 24 msg.msg_control = (void *) oob->buf; in nxt_sendmsg() 47 msg.msg_control = oob->buf; in nxt_recvmsg() 48 msg.msg_controllen = sizeof(oob->buf); in nxt_recvmsg()
|
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_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_sprintf.h | 15 NXT_EXPORT u_char *nxt_cdecl nxt_sprintf(u_char *buf, u_char *end, 17 NXT_EXPORT u_char *nxt_vsprintf(u_char *buf, u_char *end,
|
H A D | nxt_string.h | 32 #define nxt_strchr(buf, delim) \ argument 33 (u_char *) strchr((char *) buf, delim) 36 #define nxt_memzero(buf, length) \ argument 37 (void) memset(buf, 0, length) 40 #define nxt_memset(buf, c, length) \ argument 41 (void) memset(buf, c, length)
|
H A D | nxt_thread_time.c | 38 nxt_time_string_t *ts, u_char *buf); 226 nxt_thread_time_string(nxt_thread_t *thr, nxt_time_string_t *ts, u_char *buf) in nxt_thread_time_string() argument 236 return nxt_thread_time_string_no_cache(thr, ts, buf); in nxt_thread_time_string() 243 return buf; in nxt_thread_time_string() 329 return buf; in nxt_thread_time_string() 340 return buf; in nxt_thread_time_string() 346 return nxt_cpymem(buf, tsc->string.start, tsc->string.length); in nxt_thread_time_string() 352 u_char *buf) in nxt_thread_time_string_no_cache() argument 373 return ts->handler(buf, &now, &tm, ts->size, ts->format); in nxt_thread_time_string_no_cache()
|
H A D | nxt_thread_time.h | 20 u_char *(*handler)(u_char *buf, nxt_realtime_t *now, 69 nxt_time_string_t *ts, u_char *buf);
|