Lines Matching refs:pid

16     nxt_pid_t pid);
49 nxt_port_new(nxt_task_t *task, nxt_port_id_t id, nxt_pid_t pid, in nxt_port_new() argument
65 port->pid = pid; in nxt_port_new()
81 nxt_thread_log_debug("port %p %d:%d new, type %d", port, pid, id, type); in nxt_port_new()
92 nxt_debug(task, "port %p %d:%d close, type %d", port, port->pid, in nxt_port_close()
129 nxt_debug(task, "port %p %d:%d release, type %d", port, port->pid, in nxt_port_release()
164 port->pid = nxt_pid; in nxt_port_enable()
210 new_port->pair[1], new_port->pid); in nxt_port_send_new_port()
214 if (process->pid == new_port->pid || process->pid == nxt_pid) { in nxt_port_send_new_port()
242 new_port->pair[1], port->pid); in nxt_port_send_port()
248 msg->pid = new_port->pid; in nxt_port_send_port()
273 msg->fd[0], new_port_msg->pid, new_port_msg->id); in nxt_port_new_port_handler()
275 port = nxt_runtime_port_find(rt, new_port_msg->pid, new_port_msg->id); in nxt_port_new_port_handler()
277 nxt_debug(task, "port %PI:%d already exists", new_port_msg->pid, in nxt_port_new_port_handler()
287 port = nxt_runtime_process_port_create(task, rt, new_port_msg->pid, in nxt_port_new_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()
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()
386 if (nxt_pid == process->pid) { in nxt_port_change_log_file()
457 nxt_pid_t pid; in nxt_port_remove_notify_others() local
464 pid = process->pid; in nxt_port_remove_notify_others()
472 if (p->pid == nxt_pid in nxt_port_remove_notify_others()
473 || p->pid == pid in nxt_port_remove_notify_others()
486 sizeof(pid)); in nxt_port_remove_notify_others()
492 buf->mem.free = nxt_cpymem(buf->mem.free, &pid, sizeof(pid)); in nxt_port_remove_notify_others()
504 nxt_pid_t pid; in nxt_port_remove_pid_handler() local
509 nxt_assert(nxt_buf_used_size(buf) == sizeof(pid)); in nxt_port_remove_pid_handler()
511 nxt_memcpy(&pid, buf->mem.pos, sizeof(nxt_pid_t)); in nxt_port_remove_pid_handler()
513 nxt_port_remove_pid(task, msg, pid); in nxt_port_remove_pid_handler()
519 nxt_pid_t pid) in nxt_port_remove_pid() argument
524 msg->u.removed_pid = pid; in nxt_port_remove_pid()
526 nxt_debug(task, "port remove pid %PI handler", pid); in nxt_port_remove_pid()
530 nxt_port_rpc_remove_peer(task, msg->port, pid); in nxt_port_remove_pid()
532 process = nxt_runtime_process_find(rt, pid); in nxt_port_remove_pid()