Home
last modified time | relevance | path

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

1234

/unit/src/
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_port.c268 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 Dnxt_port.h196 nxt_buf_t *buf; member
210 nxt_buf_t *buf; member
314 nxt_buf_t buf; member
H A Dnxt_port_memory.c727 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 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_port_socket.c176 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 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_recvbuf.c22 for (b = rb->buf; b != NULL; b = b->next) { in nxt_recvbuf_mem_coalesce()
H A Dnxt_recvbuf.h12 nxt_buf_t *buf; member
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_router_request.h11 nxt_buf_t *buf; member
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_script.c348 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 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_sendbuf.h39 nxt_buf_t *buf; member
55 nxt_buf_t *buf; member
H A Dnxt_sockaddr.c445 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 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_socket.h80 struct sockaddr buf; member
H A Dnxt_socket_msg.c24 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 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_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_sprintf.h15 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 Dnxt_string.h32 #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 Dnxt_thread_time.c38 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 Dnxt_thread_time.h20 u_char *(*handler)(u_char *buf, nxt_realtime_t *now,
69 nxt_time_string_t *ts, u_char *buf);

1234