Home
last modified time | relevance | path

Searched refs:port_msg (Results 1 – 11 of 11) sorted by relevance

/unit/src/
H A Dnxt_port_socket.c183 msg.port_msg.stream = stream; in nxt_port_socket_write2()
184 msg.port_msg.pid = nxt_pid; in nxt_port_socket_write2()
188 msg.port_msg.mmap = 0; in nxt_port_socket_write2()
189 msg.port_msg.nf = 0; in nxt_port_socket_write2()
190 msg.port_msg.mf = 0; in nxt_port_socket_write2()
195 qmsg.pm = msg.port_msg; in nxt_port_socket_write2()
864 msg.port_msg = smsg->port_msg; in nxt_port_queue_read_handler()
978 smsg->port_msg = msg.port_msg; in nxt_port_queue_read_handler()
1139 last = msg->port_msg.mf == 0; in nxt_port_frag_find()
1251 fmsg->port_msg.nf = 0; in nxt_port_read_msg_process()
[all …]
H A Dnxt_port_rpc.c317 stream = msg->port_msg.stream; in nxt_port_rpc_handler()
319 last = msg->port_msg.last; in nxt_port_rpc_handler()
320 type = msg->port_msg.type; in nxt_port_rpc_handler()
397 msg.port_msg.pid = nxt_pid; in nxt_port_rpc_remove_peer()
413 msg.port_msg.stream = stream; in nxt_port_rpc_remove_peer()
414 msg.port_msg.last = 1; in nxt_port_rpc_remove_peer()
509 msg.port_msg.pid = nxt_pid; in nxt_port_rpc_close()
511 msg.port_msg.last = 1; in nxt_port_rpc_close()
512 msg.port_msg.mmap = 0; in nxt_port_rpc_close()
513 msg.port_msg.nf = 0; in nxt_port_rpc_close()
[all …]
H A Dnxt_main_process.c510 process->stream = msg->port_msg.stream; in nxt_main_start_process_handler()
533 port = nxt_runtime_port_find(rt, msg->port_msg.pid, in nxt_main_start_process_handler()
534 msg->port_msg.reply_port); in nxt_main_start_process_handler()
560 port = nxt_runtime_port_find(rt, msg->port_msg.pid, in nxt_main_process_created_handler()
561 msg->port_msg.reply_port); in nxt_main_process_created_handler()
623 nxt_assert(msg->port_msg.reply_port == 0); in nxt_main_process_whoami_handler()
1038 msg->port_msg.reply_port); in nxt_main_port_socket_handler()
1045 msg->port_msg.pid); in nxt_main_port_socket_handler()
1303 msg->port_msg.reply_port); in nxt_main_port_modules_handler()
1464 if (nxt_slow_path(msg->port_msg.pid != ctl_port->pid)) { in nxt_main_port_conf_store_handler()
[all …]
H A Dnxt_port.c177 if (nxt_fast_path(msg->port_msg.type < NXT_PORT_MSG_MAX)) { in nxt_port_handler()
180 msg->port->socket.fd, msg->port_msg.type, in nxt_port_handler()
184 handlers[msg->port_msg.type](task, msg); in nxt_port_handler()
190 msg->port->socket.fd, msg->port_msg.type); in nxt_port_handler()
318 process = nxt_runtime_process_find(rt, msg->port_msg.pid); in nxt_port_process_ready_handler()
331 nxt_debug(task, "process %PI ready", msg->port_msg.pid); in nxt_port_process_ready_handler()
340 nxt_port_send_new_port(task, rt, port, msg->port_msg.stream); in nxt_port_process_ready_handler()
358 process = nxt_runtime_process_find(rt, msg->port_msg.pid); in nxt_port_mmap_handler()
361 msg->port_msg.pid); in nxt_port_mmap_handler()
H A Dnxt_cert.c962 port = nxt_runtime_port_find(task->thread->runtime, msg->port_msg.pid,
963 msg->port_msg.reply_port);
1038 msg->port_msg.stream, 0, b);
1055 msg->port_msg.stream, 0, NULL);
1134 port = nxt_runtime_port_find(task->thread->runtime, msg->port_msg.pid, in nxt_cert_store_get_handler()
1135 msg->port_msg.reply_port); in nxt_cert_store_get_handler()
1139 msg->port_msg.pid, msg->port_msg.reply_port); in nxt_cert_store_get_handler()
1147 msg->port_msg.pid); in nxt_cert_store_get_handler()
1187 msg->port_msg.stream, 0, NULL); in nxt_cert_store_get_handler()
H A Dnxt_port.h185 nxt_port_msg_t port_msg; member
198 nxt_port_msg_t port_msg; member
216 #define nxt_recv_msg_cmsg_pid(msg) ((msg)->port_msg.pid)
H A Dnxt_unit.c1000 port_msg->stream, (int) port_msg->type, in nxt_unit_process_msg()
1004 recv_msg.pid = port_msg->pid; in nxt_unit_process_msg()
1014 port_msg->stream, (int) port_msg->type); in nxt_unit_process_msg()
1020 if (nxt_slow_path(port_msg->nf != 0 || port_msg->mf != 0)) { in nxt_unit_process_msg()
1022 port_msg->stream, (int) port_msg->type); in nxt_unit_process_msg()
1027 if (port_msg->mmap) { in nxt_unit_process_msg()
1040 switch (port_msg->type) { in nxt_unit_process_msg()
1136 port_msg->stream, (int) port_msg->type); in nxt_unit_process_msg()
4884 nxt_port_msg_t *port_msg; in nxt_unit_is_read_queue() local
4910 nxt_port_msg_t *port_msg; in nxt_unit_is_shm_ack() local
[all …]
H A Dnxt_router.c695 if (msg->port_msg.stream == 0) { in nxt_router_new_port_handler()
713 if (msg->port_msg.stream != 0) { in nxt_router_new_port_handler()
767 msg->port_msg.pid, in nxt_router_conf_data_handler()
812 tmcf->stream = msg->port_msg.stream; in nxt_router_conf_data_handler()
978 if (msg->port_msg.stream == 0) { in nxt_router_remove_pid_handler()
982 msg->port_msg.type = _NXT_PORT_MSG_RPC_ERROR; in nxt_router_remove_pid_handler()
4207 if (msg->port_msg.last != 0) { in nxt_router_response_ready_handler()
4372 msg->port_msg.pid, msg->port_msg.reply_port); in nxt_router_req_headers_ack_handler()
4375 msg->port_msg.pid); in nxt_router_req_headers_ack_handler()
5904 msg->port_msg.pid, msg->port_msg.reply_port); in nxt_router_get_mmap_handler()
[all …]
H A Dnxt_application.c637 process->stream = msg->port_msg.stream; in nxt_proto_start_process_handler()
652 port = nxt_runtime_port_find(rt, msg->port_msg.pid, in nxt_proto_start_process_handler()
653 msg->port_msg.reply_port); in nxt_proto_start_process_handler()
657 -1, msg->port_msg.stream, 0, NULL); in nxt_proto_start_process_handler()
708 pid = msg->port_msg.pid; in nxt_proto_process_created_handler()
H A Dnxt_port_memory.c760 msg->port_msg.mmap = 1; in nxt_port_mmap_write()
781 msg->port_msg.pid); in nxt_port_mmap_read()
784 msg->port_msg.pid, mmap_msg); in nxt_port_mmap_read()
H A Dnxt_controller.c511 if (msg->port_msg.type != NXT_PORT_MSG_RPC_READY) { in nxt_controller_conf_init_handler()
1648 if (msg == NULL || msg->port_msg.type == _NXT_PORT_MSG_RPC_ERROR) { in nxt_controller_process_cert_save()
1729 if (msg->port_msg.type == NXT_PORT_MSG_RPC_READY) { in nxt_controller_conf_handler()
1886 if (msg->port_msg.type == NXT_PORT_MSG_RPC_READY) { in nxt_controller_app_restart_handler()