Differential D12773 Diff 66690 usr.bin/procstat/procstat_sigs.c

Changeset View

Standalone View

usr.bin/procstat/procstat_sigs.c

Show All 31 Lines
#include <sys/param.h>		#include <sys/param.h>
#include <sys/sysctl.h>		#include <sys/sysctl.h>
#include <sys/user.h>		#include <sys/user.h>

#include <ctype.h>		#include <ctype.h>
#include <err.h>		#include <err.h>
#include <errno.h>		#include <errno.h>
#include <signal.h>		#include <signal.h>
		#include <stdbool.h>
		#include <stdint.h>
#include <stdio.h>		#include <stdio.h>
#include <stdlib.h>		#include <stdlib.h>
#include <string.h>		#include <string.h>
#include <libprocstat.h>		#include <libprocstat.h>

#include "procstat.h"		#include "procstat.h"

static void		static void
▲ Show 20 Lines • Show All 109 Lines • ▼ Show 20 Lines	for (i = 0; i < count; i++) {
kipp = &kip[i];		kipp = &kip[i];
asprintf(&threadid, "%d", kipp->ki_tid);		asprintf(&threadid, "%d", kipp->ki_tid);
if (threadid == NULL)		if (threadid == NULL)
xo_errc(1, ENOMEM, "Failed to allocate memory in "		xo_errc(1, ENOMEM, "Failed to allocate memory in "
"procstat_threads_sigs()");		"procstat_threads_sigs()");
xo_open_container(threadid);		xo_open_container(threadid);
xo_emit("{e:thread_id/%6d/%d}", kipp->ki_tid);		xo_emit("{e:thread_id/%6d/%d}", kipp->ki_tid);
xo_open_container("signals");		xo_open_container("signals");

for (j = 1; j <= _SIG_MAXSIG; j++) {		for (j = 1; j <= _SIG_MAXSIG; j++) {
xo_emit("{dk:process_id/%5d/%d} ", kipp->ki_pid);		xo_emit("{dk:process_id/%5d/%d} ", kipp->ki_pid);
xo_emit("{d:thread_id/%6d/%d} ", kipp->ki_tid);		xo_emit("{d:thread_id/%6d/%d} ", kipp->ki_tid);
xo_emit("{d:command/%-16s/%s} ", kipp->ki_comm);		xo_emit("{d:command/%-16s/%s} ", kipp->ki_comm);
procstat_print_signame(j);		procstat_print_signame(j);
xo_emit(" ");		xo_emit(" ");
procstat_print_sig(&kipp->ki_siglist, j, 'P');		procstat_print_sig(&kipp->ki_siglist, j, 'P');
procstat_print_sig(&kipp->ki_sigmask, j, 'B');		procstat_print_sig(&kipp->ki_sigmask, j, 'B');
procstat_close_signame(j);		procstat_close_signame(j);
xo_emit("\n");		xo_emit("\n");
}		}
xo_close_container("signals");		xo_close_container("signals");
		xo_close_container(threadid);
		free(threadid);
		}
		xo_close_container("threads");
		procstat_freeprocs(procstat, kip);
		}

		void
		procstat_fsigblock(struct procstat procstat, struct kinfo_proc kipp)
		{
		struct kinfo_proc *kip;
		char *threadid;
		uintptr_t fastsigblk_addr;
		brooksUnsubmitted Not Done Inline Actions I don't understand how this can work. uintmax_t is always __uint64_t, but for 32-bit ABIs the sysctl outputs 32-bits. brooks: I don't understand how this can work. uintmax_t is always __uint64_t, but for 32-bit ABIs the…
		kibAuthorUnsubmitted Done Inline Actions Right, this should be uintptr_t. Thanks for noting. kib: Right, this should be uintptr_t. Thanks for noting.
		int error, name[4];
		unsigned int count, i;
		size_t len;
		bool has_fastsigblk_addr;

		if ((procstat_opts & PS_OPT_NOHEADER) == 0)
		xo_emit("{T:/%5s %6s %-16s %-16s}\n", "PID", "TID",
		"COMM", "FSIGBLK");

		kip = procstat_getprocs(procstat, KERN_PROC_PID \| KERN_PROC_INC_THREAD,
		kipp->ki_pid, &count);
		if (kip == NULL)
		return;
		xo_emit("{ek:process_id/%5d/%d}", kipp->ki_pid);
		xo_emit("{e:command/%-16s/%s}", kipp->ki_comm);
		xo_open_container("threads");
		kinfo_proc_sort(kip, count);
		for (i = 0; i < count; i++) {
		kipp = &kip[i];
		len = sizeof(fastsigblk_addr);
		name[0] = CTL_KERN;
		name[1] = KERN_PROC;
		name[2] = KERN_PROC_FASTSIGBLK;
		name[3] = kipp->ki_tid;
		error = sysctl(name, 4, &fastsigblk_addr, &len, NULL, 0);
		if (error < 0) {
		if (errno != ESRCH && errno != ENOTTY) {
		warn("sysctl: kern.proc.fastsigblk: %d",
		kipp->ki_tid);
		}
		has_fastsigblk_addr = false;
		} else
		has_fastsigblk_addr = true;

		asprintf(&threadid, "%d", kipp->ki_tid);
		if (threadid == NULL)
		xo_errc(1, ENOMEM, "Failed to allocate memory in "
		"procstat_threads_sigs()");
		xo_open_container(threadid);
		xo_emit("{dk:process_id/%5d/%d} ", kipp->ki_pid);
		xo_emit("{d:thread_id/%6d/%d} ", kipp->ki_tid);
		xo_emit("{d:command/%-16s/%s} ", kipp->ki_comm);
		xo_emit("{e:fsigblock/%#-16jx/%#jx}", has_fastsigblk_addr ?
		(uintmax_t)fastsigblk_addr : (uintmax_t)-1);
		xo_emit("{d:fsigblock/%#-16jx/%#jx}", has_fastsigblk_addr ?
		(uintmax_t)fastsigblk_addr : (uintmax_t)-1);
		xo_emit("\n");
xo_close_container(threadid);		xo_close_container(threadid);
free(threadid);		free(threadid);
}		}
xo_close_container("threads");		xo_close_container("threads");
procstat_freeprocs(procstat, kip);		procstat_freeprocs(procstat, kip);
}		}