ViewVC Help

View File | Revision Log | Show Annotations | Revision Graph | Root Listing

root/i-scream/projects/libstatgrab/src/libstatgrab/process_stats.c

Comparing projects/libstatgrab/src/libstatgrab/process_stats.c (file contents):
Revision 1.17 by tdb, Fri Jan 16 15:54:54 2004 UTC vs.
Revision 1.23 by pajs, Sun Mar 28 18:04:14 2004 UTC

#	Line 17 | Line 17
17		* License along with this library; if not, write to the Free Software
18		* Foundation, Inc., 59 Temple Place, Suite 330, Boston, MA
19		* 02111-1307 USA
20	+	*
21	+	* $Id$
22		*/
23
24		#ifdef HAVE_CONFIG_H
#	Line 32 | Line 34
34		#include <string.h>
35		#endif
36
35	–	#include "tools.h"
37		#ifdef SOLARIS
38		#include <procfs.h>
39		#include <limits.h>
#	Line 45 | Line 46
46		#define MAX_FILE_LENGTH PATH_MAX
47		#endif
48		#ifdef ALLBSD
49	<	#include <kvm.h>
49	>	#include <stdlib.h>
50		#include <sys/param.h>
51		#include <sys/sysctl.h>
52	<	#endif
52	<	#ifdef FREEBSD
52	>	#if defined(FREEBSD) || defined(DFBSD)
53		#include <sys/user.h>
54	+	#else
55	+	#include <sys/proc.h>
56		#endif
55	–
56	–	process_stat_t *get_process_stats(){
57	–
58	–	static process_stat_t process_stat;
59	–
60	–	#if defined(SOLARIS) || defined(LINUX)
61	–	DIR *proc_dir;
62	–	struct dirent *dir_entry;
63	–	char filename[MAX_FILE_LENGTH];
64	–	FILE *f;
57		#endif
58	<	#ifdef LINUX
59	<	char *line_ptr;
60	<	#endif
61	<	#ifdef SOLARIS
58	>
59	>	int get_proc_snapshot(proc_state_t **ps){
60	>	proc_state_t *proc_state = NULL;
61	>	proc_state_t *proc_state_ptr;
62	>	int proc_state_size = 0;
63	>	#if defined(SOLARIS)
64	>	DIR *proc_dir;
65	>	struct dirent *dir_entry;
66	>	char filename[MAX_FILE_LENGTH];
67	>	FILE *f;
68		psinfo_t process_info;
71	–	#endif
72	–	#ifdef ALLBSD
73	–	struct kinfo_proc *kp_stats;
74	–	kvm_t *kvmd;
75	–	int procs;
76	–	#endif
69
70	<	process_stat.sleeping=0;
71	<	process_stat.running=0;
72	<	process_stat.zombie=0;
81	<	process_stat.stopped=0;
82	<	process_stat.total=0;
70	>	if((proc_dir=opendir(PROC_LOCATION))==NULL){
71	>	return NULL;
72	>	}
73
74	<	#if defined(SOLARIS) || defined(LINUX)
75	<	if((proc_dir=opendir(PROC_LOCATION))==NULL){
86	<	return NULL;
87	<	}
74	>	while((dir_entry=readdir(proc_dir))!=NULL){
75	>	if(atoi(dir_entry->d_name) == 0) continue;
76
77	<	while((dir_entry=readdir(proc_dir))!=NULL){
90	<	if(atoi(dir_entry->d_name) == 0) continue;
77	>	snprintf(filename, MAX_FILE_LENGTH, "/proc/%s/psinfo", dir_entry->d_name);
78
79	<	#ifdef SOLARIS
80	<	snprintf(filename, MAX_FILE_LENGTH, "/proc/%s/psinfo", dir_entry->d_name);
81	<	#endif
82	<	#ifdef LINUX
83	<	snprintf(filename, MAX_FILE_LENGTH, "/proc/%s/status", dir_entry->d_name);
84	<	#endif
79	>	if((f=fopen(filename, "r"))==NULL){
80	>	/* Open failed.. Process since vanished, or the path was too long.
81	>	* Ah well, move onwards to the next one */
82	>	continue;
83	>	}
84	>	fread(&process_info, sizeof(psinfo_t), 1, f);
85
86	<	if((f=fopen(filename, "r"))==NULL){
100	<	/* Open failed.. Process since vanished, or the path was too long.
101	<	* Ah well, move onwards to the next one */
102	<	continue;
103	<	}
86	>	proc_state = realloc(proc_state, (1+proc_state_size)*sizeof(proc_state_t));
87
88	<	#ifdef SOLARIS
106	<	fread(&process_info, sizeof(psinfo_t), 1, f);
107	<	if(process_info.pr_lwp.pr_state==1) process_stat.sleeping++;
108	<	if(process_info.pr_lwp.pr_state==2) process_stat.running++;
109	<	if(process_info.pr_lwp.pr_state==3) process_stat.zombie++;
110	<	if(process_info.pr_lwp.pr_state==4) process_stat.stopped++;
111	<	if(process_info.pr_lwp.pr_state==6) process_stat.running++;
112	<	#endif
113	<	#ifdef LINUX
114	<	if((line_ptr=f_read_line(f, "State:"))==NULL){
115	<	fclose(f);
116	<	continue;
117	<	}
118	<	if((line_ptr=strchr(line_ptr, '\t'))==NULL){
119	<	fclose(f);
120	<	continue;
121	<	}
122	<	line_ptr++;
123	<	if(line_ptr=='\0'){
124	<	fclose(f);
125	<	continue;
126	<	}
127	<
128	<	if(*line_ptr=='S') process_stat.sleeping++;
129	<	if(*line_ptr=='R') process_stat.running++;
130	<	if(*line_ptr=='Z') process_stat.zombie++;
131	<	if(*line_ptr=='T') process_stat.stopped++;
132	<	if(*line_ptr=='D') process_stat.stopped++;
133	<	#endif
134	<
135	<	fclose(f);
136	<	}
137	<	closedir(proc_dir);
138	<	#endif
139	<	#ifdef ALLBSD
140	<	if((kvmd = get_kvm()) == NULL){
141	<	return NULL;
142	<	}
143	<
144	<	kp_stats=kvm_getprocs(kvmd, KERN_PROC_ALL, 0, &procs);
145	<
146	<	while(procs--){
147	<	#ifdef FREEBSD5
148	<	if (kp_stats[procs].ki_stat == SSLEEP) process_stat.sleeping++;
149	<	if (kp_stats[procs].ki_stat == SWAIT) process_stat.sleeping++;
150	<	if (kp_stats[procs].ki_stat == SLOCK) process_stat.sleeping++;
151	<	if (kp_stats[procs].ki_stat == SRUN) process_stat.running++;
152	<	if (kp_stats[procs].ki_stat == SIDL) process_stat.running++;
153	<	if (kp_stats[procs].ki_stat == SZOMB) process_stat.zombie++;
154	<	if (kp_stats[procs].ki_stat == SSTOP) process_stat.stopped++;
88	>	proc_state_ptr = proc_state+proc_state_size;
89
90	<	#else
91	<	if (kp_stats[procs].kp_proc.p_stat == SSLEEP) process_stat.sleeping++;
92	<	if (kp_stats[procs].kp_proc.p_stat == SRUN) process_stat.running++;
93	<	if (kp_stats[procs].kp_proc.p_stat == SIDL) process_stat.running++;
94	<	if (kp_stats[procs].kp_proc.p_stat == SZOMB) process_stat.zombie++;
95	<	if (kp_stats[procs].kp_proc.p_stat == SSTOP) process_stat.stopped++;
96	<	#endif
97	<	}
98	<	#endif
90	>	proc_state_ptr->pid = process_info.pr_pid;
91	>	proc_state_ptr->parent = process_info.pr_ppid;
92	>	proc_state_ptr->pgid = process_info.pr_pgid;
93	>	proc_state_ptr->uid = process_info.pr_uid;
94	>	proc_state_ptr->euid = process_info.pr_euid;
95	>	proc_state_ptr->gid = process_info.pr_gid;
96	>	proc_state_ptr->egid = process_info.pr_egid;
97	>	proc_state_ptr->proc_size = (process_info.pr_size) * 1024;
98	>	proc_state_ptr->proc_resident = (process_info.pr_rssize) * 1024;
99	>	proc_state_ptr->time_spent = process_info.pr_time.tv_sec;
100	>	proc_state_ptr->cpu_percent = (process_info.pr_pctcpu * 100.0) / 0x8000;
101	>	proc_state_ptr->process_name = strdup(process_info.pr_fname);
102	>	proc_state_ptr->proctitle = strdup(process_info.pr_psargs);
103
104	<	#ifdef CYGWIN
167	<	return NULL;
104	>	proc_state_size++;
105		#endif
106
170	–	process_stat.total=process_stat.sleeping+process_stat.running+process_stat.zombie+process_stat.stopped;
107
108	<	return &process_stat;
108	>	fclose(f);
109	>	}
110	>	closedir(proc_dir);
111	>	*ps = proc_state;
112	>
113	>	return proc_state_size;
114		}
115	+

Diff Legend

–	Removed lines
+	Added lines
<	Changed lines
>	Changed lines