ViewVC Help

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

root/i-scream/projects/pystatgrab/_statgrab.pyx

Comparing projects/pystatgrab/_statgrab.pyx (file contents):
Revision 1.12 by tdb, Sun May 30 15:21:19 2004 UTC vs.
Revision 1.18 by ats, Wed Sep 14 18:15:44 2005 UTC

#	Line 1 | Line 1
1		#
2		# i-scream pystatgrab
3	<	# http://www.i-scream.org
3	>	# http://www.i-scream.org/pystatgrab/
4		# Copyright (C) 2000-2004 i-scream
5		#
6		# This program is free software; you can redistribute it and/or
#	Line 21 | Line 21
21		#
22
23		ctypedef long time_t
24	+	ctypedef int pid_t
25	+	ctypedef int uid_t
26	+	ctypedef int gid_t
27
28		cdef extern from "statgrab.h":
29	+	cdef extern int sg_init()
30	+	cdef extern int sg_drop_privileges()
31	+
32	+	ctypedef enum sg_error:
33	+	SG_ERROR_NONE = 0
34	+	SG_ERROR_ASPRINTF
35	+	SG_ERROR_DEVSTAT_GETDEVS
36	+	SG_ERROR_DEVSTAT_SELECTDEVS
37	+	SG_ERROR_ENOENT
38	+	SG_ERROR_GETIFADDRS
39	+	SG_ERROR_GETMNTINFO
40	+	SG_ERROR_GETPAGESIZE
41	+	SG_ERROR_KSTAT_DATA_LOOKUP
42	+	SG_ERROR_KSTAT_LOOKUP
43	+	SG_ERROR_KSTAT_OPEN
44	+	SG_ERROR_KSTAT_READ
45	+	SG_ERROR_KVM_GETSWAPINFO
46	+	SG_ERROR_KVM_OPENFILES
47	+	SG_ERROR_MALLOC
48	+	SG_ERROR_OPEN
49	+	SG_ERROR_OPENDIR
50	+	SG_ERROR_PARSE
51	+	SG_ERROR_SETEGID
52	+	SG_ERROR_SETEUID
53	+	SG_ERROR_SETMNTENT
54	+	SG_ERROR_SOCKET
55	+	SG_ERROR_SWAPCTL
56	+	SG_ERROR_SYSCONF
57	+	SG_ERROR_SYSCTL
58	+	SG_ERROR_SYSCTLBYNAME
59	+	SG_ERROR_SYSCTLNAMETOMIB
60	+	SG_ERROR_UNAME
61	+	SG_ERROR_UNSUPPORTED
62	+	SG_ERROR_XSW_VER_MISMATCH
63	+
64	+	cdef extern void sg_set_error(sg_error code, char *arg)
65	+	cdef extern void sg_set_error_with_errno(sg_error code, char *arg)
66	+	cdef extern sg_error sg_get_error()
67	+	cdef extern char *sg_get_error_arg()
68	+	cdef extern int sg_get_error_errno()
69	+	cdef extern char *sg_str_error(sg_error code)
70	+
71	+	ctypedef struct sg_host_info:
72	+	char *os_name
73	+	char *os_release
74	+	char *os_version
75	+	char *platform
76	+	char *hostname
77	+	time_t uptime
78	+
79	+	cdef extern sg_host_info *sg_get_host_info()
80	+
81		ctypedef struct sg_cpu_stats:
82		long long user
83		long long kernel
#	Line 33 | Line 88 | cdef extern from "statgrab.h":
88		long long total
89		time_t systime
90
91	+	cdef extern sg_cpu_stats *sg_get_cpu_stats()
92	+	cdef extern sg_cpu_stats *sg_get_cpu_stats_diff()
93	+
94		ctypedef struct sg_cpu_percents:
95		float user
96		float kernel
#	Line 42 | Line 100 | cdef extern from "statgrab.h":
100		float nice
101		time_t time_taken
102
103	+	cdef extern sg_cpu_percents *sg_get_cpu_percents()
104	+
105		ctypedef struct sg_mem_stats:
106		long long total
107		long long free
108		long long used
109		long long cache
110
111	+	cdef extern sg_mem_stats *sg_get_mem_stats()
112	+
113		ctypedef struct sg_load_stats:
114		double min1
115		double min5
116		double min15
117
118	+	cdef extern sg_load_stats *sg_get_load_stats()
119	+
120		ctypedef struct sg_user_stats:
121		char *name_list
122		int num_entries
123
124	+	cdef extern sg_user_stats *sg_get_user_stats()
125	+
126		ctypedef struct sg_swap_stats:
127		long long total
128		long long used
129		long long free
130
131	<	ctypedef struct sg_host_info:
66	<	char *os_name
67	<	char *os_release
68	<	char *os_version
69	<	char *platform
70	<	char *hostname
71	<	time_t uptime
131	>	cdef extern sg_swap_stats *sg_get_swap_stats()
132
133		ctypedef struct sg_fs_stats:
134		char *device_name
#	Line 80 | Line 140 | cdef extern from "statgrab.h":
140		long long total_inodes
141		long long used_inodes
142		long long free_inodes
143	+	long long avail_inodes
144	+	long long io_size
145	+	long long block_size
146	+	long long total_blocks
147	+	long long free_blocks
148	+	long long used_blocks
149	+	long long avail_blocks
150
151	+	cdef extern sg_fs_stats *sg_get_fs_stats(int *entries)
152	+
153		ctypedef struct sg_disk_io_stats:
154		char *disk_name
155		long long read_bytes
156		long long write_bytes
157		time_t systime
158
159	<	ctypedef struct sg_process_count:
160	<	int total
92	<	int running
93	<	int sleeping
94	<	int stopped
95	<	int zombie
159	>	cdef extern sg_disk_io_stats *sg_get_disk_io_stats(int *entries)
160	>	cdef extern sg_disk_io_stats *sg_get_disk_io_stats_diff(int *entries)
161
162		ctypedef struct sg_network_io_stats:
163		char *interface_name
#	Line 105 | Line 170 | cdef extern from "statgrab.h":
170		long long collisions
171		time_t systime
172
173	+	cdef extern sg_network_io_stats *sg_get_network_io_stats(int *entries)
174	+	cdef extern sg_network_io_stats *sg_get_network_io_stats_diff(int *entries)
175	+
176		ctypedef enum sg_iface_duplex:
177		SG_IFACE_DUPLEX_FULL
178		SG_IFACE_DUPLEX_HALF
#	Line 113 | Line 181 | cdef extern from "statgrab.h":
181		ctypedef struct sg_network_iface_stats:
182		char *interface_name
183		int speed
184	<	sg_iface_duplex dup
184	>	sg_iface_duplex duplex
185		int up
186
187	+	cdef extern sg_network_iface_stats *sg_get_network_iface_stats(int *entries)
188	+
189		ctypedef struct sg_page_stats:
190		long long pages_pagein
191		long long pages_pageout
192		time_t systime
193
124	–	cdef extern sg_cpu_stats *sg_get_cpu_stats()
125	–	cdef extern sg_cpu_stats *sg_get_cpu_stats_diff()
126	–	cdef extern sg_cpu_percents *sg_get_cpu_percents()
127	–	cdef extern sg_mem_stats *sg_get_mem_stats()
128	–	cdef extern sg_load_stats *sg_get_load_stats()
129	–	cdef extern sg_user_stats *sg_get_user_stats()
130	–	cdef extern sg_swap_stats *sg_get_swap_stats()
131	–	cdef extern sg_host_info *sg_get_host_info()
132	–	cdef extern sg_fs_stats *sg_get_fs_stats(int *entries)
133	–	cdef extern sg_disk_io_stats *sg_get_disk_io_stats(int *entries)
134	–	cdef extern sg_disk_io_stats *sg_get_disk_io_stats_diff(int *entries)
135	–	cdef extern sg_process_count *sg_get_process_count()
136	–	cdef extern sg_network_io_stats *sg_get_network_io_stats(int *entries)
137	–	cdef extern sg_network_io_stats *sg_get_network_io_stats_diff(int *entries)
138	–	cdef extern sg_network_iface_stats *sg_get_network_iface_stats(int *entries)
194		cdef extern sg_page_stats *sg_get_page_stats()
195		cdef extern sg_page_stats *sg_get_page_stats_diff()
141	–	cdef extern int sg_init()
142	–	cdef extern int sg_drop_privileges()
196
197	+	ctypedef enum sg_process_state:
198	+	SG_PROCESS_STATE_RUNNING
199	+	SG_PROCESS_STATE_SLEEPING
200	+	SG_PROCESS_STATE_STOPPED
201	+	SG_PROCESS_STATE_ZOMBIE
202	+	SG_PROCESS_STATE_UNKNOWN
203
204	+	ctypedef struct sg_process_stats:
205	+	char *process_name
206	+	char *proctitle
207	+	pid_t pid
208	+	pid_t parent
209	+	pid_t pgid
210	+	uid_t uid
211	+	uid_t euid
212	+	gid_t gid
213	+	gid_t egid
214	+	unsigned long long proc_size
215	+	unsigned long long proc_resident
216	+	time_t time_spent
217	+	double cpu_percent
218	+	int nice
219	+	sg_process_state state
220	+
221	+	cdef extern sg_process_stats *sg_get_process_stats(int *entries)
222	+
223	+	ctypedef struct sg_process_count:
224	+	int total
225	+	int running
226	+	int sleeping
227	+	int stopped
228	+	int zombie
229	+
230	+	cdef extern sg_process_count *sg_get_process_count()
231	+
232	+
233	+	py_SG_ERROR_NONE = SG_ERROR_NONE
234	+	py_SG_ERROR_ASPRINTF = SG_ERROR_ASPRINTF
235	+	py_SG_ERROR_DEVSTAT_GETDEVS = SG_ERROR_DEVSTAT_GETDEVS
236	+	py_SG_ERROR_DEVSTAT_SELECTDEVS = SG_ERROR_DEVSTAT_SELECTDEVS
237	+	py_SG_ERROR_ENOENT = SG_ERROR_ENOENT
238	+	py_SG_ERROR_GETIFADDRS = SG_ERROR_GETIFADDRS
239	+	py_SG_ERROR_GETMNTINFO = SG_ERROR_GETMNTINFO
240	+	py_SG_ERROR_GETPAGESIZE = SG_ERROR_GETPAGESIZE
241	+	py_SG_ERROR_KSTAT_DATA_LOOKUP = SG_ERROR_KSTAT_DATA_LOOKUP
242	+	py_SG_ERROR_KSTAT_LOOKUP = SG_ERROR_KSTAT_LOOKUP
243	+	py_SG_ERROR_KSTAT_OPEN = SG_ERROR_KSTAT_OPEN
244	+	py_SG_ERROR_KSTAT_READ = SG_ERROR_KSTAT_READ
245	+	py_SG_ERROR_KVM_GETSWAPINFO = SG_ERROR_KVM_GETSWAPINFO
246	+	py_SG_ERROR_KVM_OPENFILES = SG_ERROR_KVM_OPENFILES
247	+	py_SG_ERROR_MALLOC = SG_ERROR_MALLOC
248	+	py_SG_ERROR_OPEN = SG_ERROR_OPEN
249	+	py_SG_ERROR_OPENDIR = SG_ERROR_OPENDIR
250	+	py_SG_ERROR_PARSE = SG_ERROR_PARSE
251	+	py_SG_ERROR_SETEGID = SG_ERROR_SETEGID
252	+	py_SG_ERROR_SETEUID = SG_ERROR_SETEUID
253	+	py_SG_ERROR_SETMNTENT = SG_ERROR_SETMNTENT
254	+	py_SG_ERROR_SOCKET = SG_ERROR_SOCKET
255	+	py_SG_ERROR_SWAPCTL = SG_ERROR_SWAPCTL
256	+	py_SG_ERROR_SYSCONF = SG_ERROR_SYSCONF
257	+	py_SG_ERROR_SYSCTL = SG_ERROR_SYSCTL
258	+	py_SG_ERROR_SYSCTLBYNAME = SG_ERROR_SYSCTLBYNAME
259	+	py_SG_ERROR_SYSCTLNAMETOMIB = SG_ERROR_SYSCTLNAMETOMIB
260	+	py_SG_ERROR_UNAME = SG_ERROR_UNAME
261	+	py_SG_ERROR_UNSUPPORTED = SG_ERROR_UNSUPPORTED
262	+	py_SG_ERROR_XSW_VER_MISMATCH = SG_ERROR_XSW_VER_MISMATCH
263	+
264		py_SG_IFACE_DUPLEX_FULL = SG_IFACE_DUPLEX_FULL
265		py_SG_IFACE_DUPLEX_HALF = SG_IFACE_DUPLEX_HALF
266		py_SG_IFACE_DUPLEX_UNKNOWN = SG_IFACE_DUPLEX_UNKNOWN
267
268	+	py_SG_PROCESS_STATE_RUNNING = SG_PROCESS_STATE_RUNNING
269	+	py_SG_PROCESS_STATE_SLEEPING = SG_PROCESS_STATE_SLEEPING
270	+	py_SG_PROCESS_STATE_STOPPED = SG_PROCESS_STATE_STOPPED
271	+	py_SG_PROCESS_STATE_ZOMBIE = SG_PROCESS_STATE_ZOMBIE
272	+	py_SG_PROCESS_STATE_UNKNOWN = SG_PROCESS_STATE_UNKNOWN
273
274	+
275		class Result:
276		def __init__(self, attrs):
277		self.attrs = attrs
#	Line 164 | Line 289 | class StatgrabException(Exception):
289		return repr(self.value)
290
291
292	+	def py_sg_init():
293	+	if sg_init() == 0:
294	+	return True
295	+	else:
296	+	return False
297	+
298	+	def py_sg_drop_privileges():
299	+	if sg_drop_privileges() == 0:
300	+	return True
301	+	else:
302	+	return False
303	+
304	+	def py_sg_set_error(code, arg):
305	+	sg_set_error(code, arg)
306	+
307	+	def py_sg_set_error_with_errno(code, arg):
308	+	sg_set_error_with_errno(code, arg)
309	+
310	+	def py_sg_get_error():
311	+	cdef sg_error s
312	+	s = sg_get_error()
313	+	return s
314	+
315	+	def py_sg_get_error_arg():
316	+	s = sg_get_error_arg()
317	+	return s
318	+
319	+	def py_sg_get_error_errno():
320	+	s = sg_get_error_errno()
321	+	return s
322	+
323	+	def py_sg_str_error(code):
324	+	s = sg_str_error(code)
325	+	return s
326	+
327	+	def py_sg_get_host_info():
328	+	cdef sg_host_info *s
329	+	s = sg_get_host_info()
330	+	if s == NULL:
331	+	raise StatgrabException, 'sg_get_host_info() returned NULL'
332	+	return Result(
333	+	{'os_name': s.os_name,
334	+	'os_release': s.os_release,
335	+	'os_version': s.os_version,
336	+	'platform': s.platform,
337	+	'hostname': s.hostname,
338	+	'uptime': s.uptime,
339	+	}
340	+	)
341	+
342		def py_sg_get_cpu_stats():
343		cdef sg_cpu_stats *s
344		s = sg_get_cpu_stats()
#	Line 262 | Line 437 | def py_sg_get_swap_stats():
437		}
438		)
439
265	–	def py_sg_get_host_info():
266	–	cdef sg_host_info *s
267	–	s = sg_get_host_info()
268	–	if s == NULL:
269	–	raise StatgrabException, 'sg_get_host_info() returned NULL'
270	–	return Result(
271	–	{'os_name': s.os_name,
272	–	'os_release': s.os_release,
273	–	'os_version': s.os_version,
274	–	'platform': s.platform,
275	–	'hostname': s.hostname,
276	–	'uptime': s.uptime,
277	–	}
278	–	)
279	–
440		def py_sg_get_fs_stats():
441		cdef sg_fs_stats *s
442		cdef int entries
#	Line 295 | Line 455 | def py_sg_get_fs_stats():
455		'total_inodes': s.total_inodes,
456		'used_inodes': s.used_inodes,
457		'free_inodes': s.free_inodes,
458	+	'avail_inodes': s.avail_inodes,
459	+	'io_size': s.io_size,
460	+	'block_size': s.block_size,
461	+	'total_blocks': s.total_blocks,
462	+	'free_blocks': s.free_blocks,
463	+	'used_blocks': s.used_blocks,
464	+	'avail_blocks': s.avail_blocks,
465		}
466		))
467		s = s + 1
#	Line 336 | Line 503 | def py_sg_get_disk_io_stats_diff():
503		s = s + 1
504		return list
505
339	–	def py_sg_get_process_count():
340	–	cdef sg_process_count *s
341	–	s = sg_get_process_count()
342	–	if s == NULL:
343	–	raise StatgrabException, 'sg_get_process_count() returned NULL'
344	–	return Result(
345	–	{'total': s.total,
346	–	'running': s.running,
347	–	'sleeping': s.sleeping,
348	–	'stopped': s.stopped,
349	–	'zombie': s.zombie,
350	–	}
351	–	)
352	–
506		def py_sg_get_network_io_stats():
507		cdef sg_network_io_stats *s
508		cdef int entries
#	Line 407 | Line 560 | def py_sg_get_network_iface_stats():
560		list.append(Result(
561		{'interface_name': s.interface_name,
562		'speed': s.speed,
563	<	'dup': s.dup,
563	>	'duplex': s.duplex,
564		'up' : s.up,
565		}
566		))
#	Line 436 | Line 589 | def py_sg_get_page_stats_diff():
589		}
590		)
591
592	<	def py_sg_init():
593	<	if sg_init() == 0:
594	<	return True
595	<	else:
596	<	return False
592	>	def py_sg_get_process_stats():
593	>	cdef sg_process_stats *s
594	>	cdef int entries
595	>	s = sg_get_process_stats(&entries)
596	>	if s == NULL:
597	>	raise StatgrabException, 'sg_get_process_stats() returned NULL'
598	>	list = []
599	>	for i from 0 <= i < entries:
600	>	if s.process_name is NULL:
601	>	process_name = ''
602	>	else:
603	>	process_name = s.process_name
604	>	if s.proctitle is NULL:
605	>	proctitle = ''
606	>	else:
607	>	proctitle = s.proctitle
608	>	list.append(Result(
609	>	{'process_name': process_name,
610	>	'proctitle' : proctitle,
611	>	'pid' : s.pid,
612	>	'parent' : s.parent,
613	>	'pgid' : s.pgid,
614	>	'uid' : s.uid,
615	>	'euid' : s.euid,
616	>	'gid' : s.gid,
617	>	'egid' : s.egid,
618	>	'proc_size' : s.proc_size,
619	>	'proc_resident' : s.proc_resident,
620	>	'time_spent' : s.time_spent,
621	>	'cpu_percent' : s.cpu_percent,
622	>	'nice' : s.nice,
623	>	'state' : s.state,
624	>	}
625	>	))
626	>	s = s + 1
627	>	return list
628
629	<	def py_sg_drop_privileges():
630	<	if sg_drop_privileges() == 0:
631	<	return True
632	<	else:
633	<	return False
629	>	def py_sg_get_process_count():
630	>	cdef sg_process_count *s
631	>	s = sg_get_process_count()
632	>	if s == NULL:
633	>	raise StatgrabException, 'sg_get_process_count() returned NULL'
634	>	return Result(
635	>	{'total': s.total,
636	>	'running': s.running,
637	>	'sleeping': s.sleeping,
638	>	'stopped': s.stopped,
639	>	'zombie': s.zombie,
640	>	}
641	>	)

Diff Legend

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