74  * This structure is used to hold a SNMP table entry
90 	uint64_t	r_tick;		/* tick when entry refreshed */
108  * Malloc a new entry and add it to the list
115 	struct swrun_entry *entry;  in swrun_entry_create()  local
117 	if ((entry = malloc(sizeof(*entry))) == NULL) {  in swrun_entry_create()
121 	memset(entry, 0, sizeof(*entry));  in swrun_entry_create()
122 	entry->index = idx;  in swrun_entry_create()
124 	INSERT_OBJECT_INT(entry, &swrun_tbl);  in swrun_entry_create()
125 	return (entry);  in swrun_entry_create()
129  * Unlink the entry from the list and then free its heap memory
132 swrun_entry_delete(struct swrun_entry *entry)  in swrun_entry_delete()  argument
135 	assert(entry != NULL);  in swrun_entry_delete()
137 	TAILQ_REMOVE(&swrun_tbl, entry, link);  in swrun_entry_delete()
139 	free(entry->name);  in swrun_entry_delete()
140 	free(entry->path);  in swrun_entry_delete()
141 	free(entry->parameters);  in swrun_entry_delete()
142 	free(entry);  in swrun_entry_delete()
151 	struct swrun_entry *entry;  in swrun_entry_find_by_index()  local
153 	TAILQ_FOREACH(entry, &swrun_tbl, link)  in swrun_entry_find_by_index()
154 		if (entry->index == idx)  in swrun_entry_find_by_index()
155 			return (entry);  in swrun_entry_find_by_index()
199  * Make an SNMP table entry from a kernel one.
203     struct swrun_entry *entry)  in kinfo_proc_to_swrun_entry()  argument
210 	entry->name = reallocf(entry->name, pname_len);  in kinfo_proc_to_swrun_entry()
211 	if (entry->name != NULL)  in kinfo_proc_to_swrun_entry()
212 		strlcpy(entry->name, kp->ki_comm, pname_len);  in kinfo_proc_to_swrun_entry()
214 	entry->id = &oid_zeroDotZero; /* unknown id - FIXME */  in kinfo_proc_to_swrun_entry()
238 			entry->path = reallocf(entry->path, path_len);  in kinfo_proc_to_swrun_entry()
239 			if (entry->path != NULL) {  in kinfo_proc_to_swrun_entry()
240 				memset(entry->path, '\0', path_len);  in kinfo_proc_to_swrun_entry()
241 				strlcpy((char*)entry->path, *argv, path_len);  in kinfo_proc_to_swrun_entry()
263 		entry->parameters = reallocf(entry->parameters, pname_len);  in kinfo_proc_to_swrun_entry()
264 		strlcpy(entry->parameters, param, pname_len);  in kinfo_proc_to_swrun_entry()
267 	entry->type = (int32_t)(IS_KERNPROC(kp) ? SRT_OPERATING_SYSTEM :  in kinfo_proc_to_swrun_entry()
270 	entry->status = (int32_t)swrun_OS_get_proc_status(kp);  in kinfo_proc_to_swrun_entry()
274 	entry->perfCPU = (cpu_time > (uint64_t)INT_MAX ? INT_MAX : cpu_time);  in kinfo_proc_to_swrun_entry()
275 	entry->perfMemory = kp->ki_size / 1024; /* in kilo-bytes */  in kinfo_proc_to_swrun_entry()
276 	entry->r_tick = get_ticks();  in kinfo_proc_to_swrun_entry()
280  * Create a table entry for a KLD
284     struct swrun_entry *entry)  in kld_file_stat_to_swrun()  argument
289 	assert(entry != NULL);  in kld_file_stat_to_swrun()
295 	entry->name = reallocf(entry->name, name_len);  in kld_file_stat_to_swrun()
296 	if (entry->name != NULL)  in kld_file_stat_to_swrun()
297 		strlcpy((char *)entry->name, kfs->name, name_len);  in kld_file_stat_to_swrun()
300 	entry->path = NULL;  in kld_file_stat_to_swrun()
303 	entry->parameters = NULL;  in kld_file_stat_to_swrun()
305 	entry->id = &oid_zeroDotZero; /* unknown id - FIXME */  in kld_file_stat_to_swrun()
308 		entry->type = (int32_t)SRT_OPERATING_SYSTEM;  in kld_file_stat_to_swrun()
309 		SWOSIndex = entry->index;  in kld_file_stat_to_swrun()
311 		entry->type = (int32_t)SRT_DEVICE_DRIVER; /* well, not really */  in kld_file_stat_to_swrun()
313 	entry->status = (int32_t)SRS_RUNNING;  in kld_file_stat_to_swrun()
314 	entry->perfCPU = 0;			/* Info not available */  in kld_file_stat_to_swrun()
315 	entry->perfMemory = kfs->size / 1024;	/* in kilo-bytes */  in kld_file_stat_to_swrun()
316 	entry->r_tick = get_ticks();  in kld_file_stat_to_swrun()
328 	struct swrun_entry *entry;  in swrun_OS_get_procs()  local
341 		entry = swrun_entry_find_by_index((int32_t)kp->ki_pid + 1);  in swrun_OS_get_procs()
342 		if (entry == NULL) {  in swrun_OS_get_procs()
343 			/* new entry - get memory for it */  in swrun_OS_get_procs()
344 			entry = swrun_entry_create((int32_t)kp->ki_pid + 1);  in swrun_OS_get_procs()
345 			if (entry == NULL)  in swrun_OS_get_procs()
348 		entry->flags |= HR_SWRUN_FOUND;	/* mark it as found */  in swrun_OS_get_procs()
350 		kinfo_proc_to_swrun_entry(kp, entry);  in swrun_OS_get_procs()
361 	struct swrun_entry *entry;  in swrun_OS_get_kinfo()  local
376 		entry = swrun_entry_find_by_index(NO_PID + 1 + stat.id);  in swrun_OS_get_kinfo()
377 		if (entry == NULL) {  in swrun_OS_get_kinfo()
378 			/* new entry - get memory for it */  in swrun_OS_get_kinfo()
379 			entry = swrun_entry_create(NO_PID + 1 + stat.id);  in swrun_OS_get_kinfo()
380 			if (entry == NULL)  in swrun_OS_get_kinfo()
383 		entry->flags |= HR_SWRUN_FOUND; /* mark it as found */  in swrun_OS_get_kinfo()
385 		kld_file_stat_to_swrun(&stat, entry);  in swrun_OS_get_kinfo()
396 	struct swrun_entry *entry, *entry_tmp;  in refresh_swrun_tbl()  local
403 	/* mark each entry as missing */  in refresh_swrun_tbl()
404 	TAILQ_FOREACH(entry, &swrun_tbl, link)  in refresh_swrun_tbl()
405 		entry->flags &= ~HR_SWRUN_FOUND;  in refresh_swrun_tbl()
413 	TAILQ_FOREACH_SAFE(entry, &swrun_tbl, link, entry_tmp)  in refresh_swrun_tbl()
414 		if (!(entry->flags & HR_SWRUN_FOUND))  in refresh_swrun_tbl()
415 			swrun_entry_delete(entry);  in refresh_swrun_tbl()
423  * Update the information in this entry
426 fetch_swrun_entry(struct swrun_entry *entry)  in fetch_swrun_entry()  argument
432 	assert(entry !=  NULL);  in fetch_swrun_entry()
434 	if (entry->index >= NO_PID + 1)	{  in fetch_swrun_entry()
442 		if (kldstat(entry->index - NO_PID - 1, &stat) == -1) {  in fetch_swrun_entry()
448 			     entry->index -  NO_PID - 1);  in fetch_swrun_entry()
449 			entry->status = (int32_t)SRS_INVALID;  in fetch_swrun_entry()
451 			kld_file_stat_to_swrun(&stat, entry);  in fetch_swrun_entry()
457 		    entry->index - 1, &nproc);  in fetch_swrun_entry()
459 			HRDBG("missing item with PID=%d", entry->index - 1);  in fetch_swrun_entry()
460 			entry->status = (int32_t)SRS_INVALID;  in fetch_swrun_entry()
462 			kinfo_proc_to_swrun_entry(plist, entry);  in fetch_swrun_entry()
467  * Invalidate entry. For KLDs we try to unload it, for processes we SIGKILL it.
470 invalidate_swrun_entry(struct swrun_entry *entry, int commit)  in invalidate_swrun_entry()  argument
476 	assert(entry !=  NULL);  in invalidate_swrun_entry()
478 	if (entry->index >= NO_PID + 1)	{  in invalidate_swrun_entry()
481 		    entry->index -  NO_PID - 1);  in invalidate_swrun_entry()
483 		if (entry->index == SWOSIndex) {  in invalidate_swrun_entry()
489 		if (kldstat(entry->index - NO_PID - 1, &stat) == -1) {  in invalidate_swrun_entry()
496 			    entry->index - NO_PID - 1);  in invalidate_swrun_entry()
497 			entry->status = (int32_t)SRS_INVALID;  in invalidate_swrun_entry()
524 		    entry->index - 1, &nproc);  in invalidate_swrun_entry()
526 			HRDBG("missing item with PID=%d", entry->index - 1);  in invalidate_swrun_entry()
527 			entry->status = (int32_t)SRS_INVALID;  in invalidate_swrun_entry()
534 		if (kill(entry->index - 1, commit ? SIGKILL : 0) < 0) {  in invalidate_swrun_entry()
536 			    entry->index - 1);  in invalidate_swrun_entry()
539 				entry->status = (int32_t)SRS_INVALID;  in invalidate_swrun_entry()
582 	struct swrun_entry *entry;  in op_hrSWRunTable()  local
590 		if ((entry = NEXT_OBJECT_INT(&swrun_tbl,  in op_hrSWRunTable()
594 		value->var.subs[sub] = entry->index;  in op_hrSWRunTable()
598 		if ((entry = FIND_OBJECT_INT(&swrun_tbl,  in op_hrSWRunTable()
604 		if ((entry = FIND_OBJECT_INT(&swrun_tbl,  in op_hrSWRunTable()
608 		if (entry->r_tick < this_tick)  in op_hrSWRunTable()
609 			fetch_swrun_entry(entry);  in op_hrSWRunTable()
617 			if (entry->status == (int32_t)SRS_INVALID)  in op_hrSWRunTable()
628 			return (invalidate_swrun_entry(entry, 0));  in op_hrSWRunTable()
636 		if ((entry = FIND_OBJECT_INT(&swrun_tbl,  in op_hrSWRunTable()
644 			    entry->status != (int32_t)SRS_INVALID)  in op_hrSWRunTable()
645 				(void)invalidate_swrun_entry(entry, 1);  in op_hrSWRunTable()
657 		value->v.integer = entry->index;  in op_hrSWRunTable()
661 		if (entry->name != NULL)  in op_hrSWRunTable()
662 			ret = string_get(value, entry->name, -1);  in op_hrSWRunTable()
668 		assert(entry->id != NULL);  in op_hrSWRunTable()
669 		value->v.oid = *entry->id;  in op_hrSWRunTable()
673 		if (entry->path != NULL)  in op_hrSWRunTable()
674 			ret = string_get(value, entry->path, -1);  in op_hrSWRunTable()
680 		if (entry->parameters != NULL)  in op_hrSWRunTable()
681 			ret = string_get(value, entry->parameters, -1);  in op_hrSWRunTable()
687 		value->v.integer = entry->type;  in op_hrSWRunTable()
691 		value->v.integer = entry->status;  in op_hrSWRunTable()
746 	struct swrun_entry *entry;  in op_hrSWRunPerfTable()  local
753 		if ((entry = NEXT_OBJECT_INT(&swrun_tbl,  in op_hrSWRunPerfTable()
757 		value->var.subs[sub] = entry->index;  in op_hrSWRunPerfTable()
761 		if ((entry = FIND_OBJECT_INT(&swrun_tbl,  in op_hrSWRunPerfTable()
767 		if ((entry = FIND_OBJECT_INT(&swrun_tbl,  in op_hrSWRunPerfTable()
782 		value->v.integer = entry->perfCPU;  in op_hrSWRunPerfTable()
786 		value->v.integer = entry->perfMemory;  in op_hrSWRunPerfTable()