Lines Matching refs:pid

42 static nxt_process_t *nxt_runtime_process_get(nxt_runtime_t *rt, nxt_pid_t pid);
218 u_char *nfd, *pid; in nxt_runtime_systemd_listen_sockets() local
234 pid = (u_char *) getenv("LISTEN_PID"); in nxt_runtime_systemd_listen_sockets()
235 if (pid == NULL) { in nxt_runtime_systemd_listen_sockets()
244 if (nxt_pid != nxt_int_parse(pid, nxt_strlen(pid))) { in nxt_runtime_systemd_listen_sockets()
531 nxt_debug(task, "%d sending quit to %PI", rt->type, port->pid); in nxt_runtime_stop_all_processes()
769 rt->pid = NXT_PID; in nxt_runtime_conf_init()
808 ret = nxt_file_name_create(rt->mem_pool, &file_name, "%s%Z", rt->pid); in nxt_runtime_conf_init()
1023 rt->pid = p; in nxt_runtime_conf_read_cmd()
1366 u_char pid[NXT_INT64_T_LEN + nxt_length("\n")]; in nxt_runtime_pid_file_create() local
1379 length = nxt_sprintf(pid, pid + sizeof(pid), "%PI%n", nxt_pid) - pid; in nxt_runtime_pid_file_create()
1381 if (nxt_file_write(&file, pid, length, 0) != length) { in nxt_runtime_pid_file_create()
1433 && *(nxt_pid_t *) lhq->key.start == process->pid) in nxt_runtime_lvlhsh_pid_test()
1450 nxt_runtime_process_lhq_pid(nxt_lvlhsh_query_t *lhq, nxt_pid_t *pid) in nxt_runtime_process_lhq_pid() argument
1452 lhq->key_hash = nxt_murmur_hash2(pid, sizeof(*pid)); in nxt_runtime_process_lhq_pid()
1453 lhq->key.length = sizeof(*pid); in nxt_runtime_process_lhq_pid()
1454 lhq->key.start = (u_char *) pid; in nxt_runtime_process_lhq_pid()
1460 nxt_runtime_process_find(nxt_runtime_t *rt, nxt_pid_t pid) in nxt_runtime_process_find() argument
1467 nxt_runtime_process_lhq_pid(&lhq, &pid); in nxt_runtime_process_find()
1475 nxt_thread_log_debug("process %PI not found", pid); in nxt_runtime_process_find()
1485 nxt_runtime_process_get(nxt_runtime_t *rt, nxt_pid_t pid) in nxt_runtime_process_get() argument
1490 nxt_runtime_process_lhq_pid(&lhq, &pid); in nxt_runtime_process_get()
1495 nxt_thread_log_debug("process %PI found", pid); in nxt_runtime_process_get()
1513 process->pid = pid; in nxt_runtime_process_get()
1530 nxt_thread_log_debug("process %PI insert", pid); in nxt_runtime_process_get()
1534 nxt_thread_log_debug("process %PI insert failed", pid); in nxt_runtime_process_get()
1555 nxt_runtime_process_lhq_pid(&lhq, &process->pid); in nxt_runtime_process_add()
1574 port->pid = process->pid; in nxt_runtime_process_add()
1582 nxt_thread_log_debug("process %PI added", process->pid); in nxt_runtime_process_add()
1586 nxt_thread_log_debug("process %PI failed to add", process->pid); in nxt_runtime_process_add()
1597 nxt_pid_t pid; in nxt_runtime_process_remove() local
1600 pid = process->pid; in nxt_runtime_process_remove()
1602 nxt_runtime_process_lhq_pid(&lhq, &pid); in nxt_runtime_process_remove()
1617 nxt_thread_log_debug("process %PI removed", pid); in nxt_runtime_process_remove()
1621 nxt_thread_log_debug("process %PI remove failed", pid); in nxt_runtime_process_remove()
1640 nxt_pid_t pid, nxt_port_id_t id, nxt_process_type_t type) in nxt_runtime_process_port_create() argument
1645 process = nxt_runtime_process_get(rt, pid); in nxt_runtime_process_port_create()
1650 port = nxt_port_new(task, id, pid, type); in nxt_runtime_process_port_create()
1711 nxt_runtime_port_find(nxt_runtime_t *rt, nxt_pid_t pid, in nxt_runtime_port_find() argument
1714 return nxt_port_hash_find(&rt->ports, pid, port_id); in nxt_runtime_port_find()