Lines Matching refs:pid
122 pid_t pid;
150 hashmap_remove(workers, UINT_TO_PTR(worker->pid));
169 static int worker_new(struct worker **ret, struct udev *udev, struct udev_monitor *worker_monitor, pid_t pid) {
176 assert(pid > 1);
187 worker->pid = pid;
193 r = hashmap_put(workers, UINT_TO_PTR(pid), worker);
226 pid_t pid;
236 pid = fork();
237 switch (pid) {
431 r = worker_new(&worker, udev, worker_monitor, pid);
437 log_debug("seq %llu forked new worker ["PID_FMT"]", udev_device_get_seqnum(event->dev), pid);
456 worker->pid, count);
457 kill(worker->pid, SIGKILL);
511 kill(worker->pid, SIGTERM);
663 if (!ucred || ucred->pid <= 0) {
669 worker = hashmap_get(workers, UINT_TO_PTR(ucred->pid));
671 log_debug("worker ["PID_FMT"] returned, but is no longer tracked", ucred->pid);
931 pid_t pid;
935 pid = waitpid(-1, &status, WNOHANG);
936 if (pid <= 0)
939 worker = hashmap_get(workers, UINT_TO_PTR(pid));
941 log_warning("worker ["PID_FMT"] is unknown, ignoring", pid);
947 log_debug("worker ["PID_FMT"] exited", pid);
949 log_warning("worker ["PID_FMT"] exited with return code %i", pid, WEXITSTATUS(status));
952 pid, WTERMSIG(status), strsignal(WTERMSIG(status)));
954 log_info("worker ["PID_FMT"] stopped", pid);
957 log_info("worker ["PID_FMT"] continued", pid);
960 log_warning("worker ["PID_FMT"] exit with status 0x%04x", pid, status);
965 log_error("worker ["PID_FMT"] failed while handling '%s'", pid, worker->event->devpath);
1249 pid_t pid;
1251 pid = fork();
1252 switch (pid) {
1439 log_error("worker ["PID_FMT"] %s timeout; kill it", worker->pid, event->devpath);
1440 kill(worker->pid, SIGKILL);
1445 log_warning("worker ["PID_FMT"] %s is taking a long time", worker->pid, event->devpath);