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.c498 process->stream = msg->port_msg.stream; in nxt_main_start_process_handler()
521 port = nxt_runtime_port_find(rt, msg->port_msg.pid, in nxt_main_start_process_handler()
522 msg->port_msg.reply_port); in nxt_main_start_process_handler()
548 port = nxt_runtime_port_find(rt, msg->port_msg.pid, in nxt_main_process_created_handler()
549 msg->port_msg.reply_port); in nxt_main_process_created_handler()
611 nxt_assert(msg->port_msg.reply_port == 0); in nxt_main_process_whoami_handler()
1026 msg->port_msg.reply_port); in nxt_main_port_socket_handler()
1033 msg->port_msg.pid); in nxt_main_port_socket_handler()
1293 msg->port_msg.reply_port); in nxt_main_port_modules_handler()
1454 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.h190 nxt_port_msg_t port_msg; member
203 nxt_port_msg_t port_msg; member
221 #define nxt_recv_msg_cmsg_pid(msg) ((msg)->port_msg.pid)
H A Dnxt_router.c673 if (msg->port_msg.stream == 0) { in nxt_router_new_port_handler()
691 if (msg->port_msg.stream != 0) { in nxt_router_new_port_handler()
745 msg->port_msg.pid, in nxt_router_conf_data_handler()
790 tmcf->stream = msg->port_msg.stream; in nxt_router_conf_data_handler()
1034 if (msg->port_msg.stream == 0) { in nxt_router_remove_pid_handler()
1038 msg->port_msg.type = _NXT_PORT_MSG_RPC_ERROR; in nxt_router_remove_pid_handler()
3867 if (msg->port_msg.last != 0) { in nxt_router_response_ready_handler()
4032 msg->port_msg.pid, msg->port_msg.reply_port); in nxt_router_req_headers_ack_handler()
4035 msg->port_msg.pid); in nxt_router_req_headers_ack_handler()
5570 msg->port_msg.pid, msg->port_msg.reply_port); in nxt_router_get_mmap_handler()
[all …]
H A Dnxt_unit.c1014 port_msg->stream, (int) port_msg->type, in nxt_unit_process_msg()
1018 recv_msg.pid = port_msg->pid; in nxt_unit_process_msg()
1028 port_msg->stream, (int) port_msg->type); in nxt_unit_process_msg()
1034 if (nxt_slow_path(port_msg->nf != 0 || port_msg->mf != 0)) { in nxt_unit_process_msg()
1036 port_msg->stream, (int) port_msg->type); in nxt_unit_process_msg()
1041 if (port_msg->mmap) { in nxt_unit_process_msg()
1054 switch (port_msg->type) { in nxt_unit_process_msg()
1150 port_msg->stream, (int) port_msg->type); in nxt_unit_process_msg()
4898 nxt_port_msg_t *port_msg; in nxt_unit_is_read_queue() local
4924 nxt_port_msg_t *port_msg; in nxt_unit_is_shm_ack() local
[all …]
H A Dnxt_application.c644 process->stream = msg->port_msg.stream; in nxt_proto_start_process_handler()
661 port = nxt_runtime_port_find(rt, msg->port_msg.pid, in nxt_proto_start_process_handler()
662 msg->port_msg.reply_port); in nxt_proto_start_process_handler()
666 -1, msg->port_msg.stream, 0, NULL); in nxt_proto_start_process_handler()
717 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.c519 if (msg->port_msg.type != NXT_PORT_MSG_RPC_READY) { in nxt_controller_conf_init_handler()
1569 if (msg->port_msg.type == NXT_PORT_MSG_RPC_READY) { in nxt_controller_status_handler()
1817 if (msg == NULL || msg->port_msg.type == _NXT_PORT_MSG_RPC_ERROR) { in nxt_controller_process_cert_save()
1898 if (msg->port_msg.type == NXT_PORT_MSG_RPC_READY) { in nxt_controller_conf_handler()
2055 if (msg->port_msg.type == NXT_PORT_MSG_RPC_READY) { in nxt_controller_app_restart_handler()