1 f0f4401f 2004-04-23 devnull #include <u.h>
2 f0f4401f 2004-04-23 devnull #include <sys/types.h>
3 f0f4401f 2004-04-23 devnull #include <sys/protosw.h>
4 f0f4401f 2004-04-23 devnull #include <sys/socket.h>
5 f0f4401f 2004-04-23 devnull #include <sys/sysctl.h>
6 f0f4401f 2004-04-23 devnull #include <sys/time.h>
7 f0f4401f 2004-04-23 devnull #include <sys/dkstat.h>
8 f0f4401f 2004-04-23 devnull #include <net/if.h>
9 f0f4401f 2004-04-23 devnull #include <net/if_var.h>
10 f0f4401f 2004-04-23 devnull #include <net/if_dl.h>
11 f0f4401f 2004-04-23 devnull #include <net/if_types.h>
12 8187859d 2005-10-05 devnull #include <ifaddrs.h>
13 f0f4401f 2004-04-23 devnull #include <sys/ioctl.h>
14 f0f4401f 2004-04-23 devnull #include <limits.h>
15 f0f4401f 2004-04-23 devnull #include <libc.h>
16 f0f4401f 2004-04-23 devnull #include <bio.h>
18 8187859d 2005-10-05 devnull #include <mach/mach.h>
19 8187859d 2005-10-05 devnull #include <mach/mach_time.h>
20 8187859d 2005-10-05 devnull #include <CoreFoundation/CoreFoundation.h>
21 8187859d 2005-10-05 devnull #include <IOKit/ps/IOPowerSources.h>
22 8187859d 2005-10-05 devnull AUTOFRAMEWORK(CoreFoundation)
23 8187859d 2005-10-05 devnull AUTOFRAMEWORK(IOKit)
25 f0f4401f 2004-04-23 devnull #include "dat.h"
27 8187859d 2005-10-05 devnull typedef struct Sample Sample;
29 8187859d 2005-10-05 devnull struct Sample
31 8187859d 2005-10-05 devnull uint seq;
32 8187859d 2005-10-05 devnull host_cpu_load_info_data_t cpu, p_cpu;
33 8187859d 2005-10-05 devnull vm_size_t pgsize;
34 8187859d 2005-10-05 devnull double divisor;
35 8187859d 2005-10-05 devnull uint64_t time, p_time;
36 8187859d 2005-10-05 devnull vm_statistics_data_t vm_stat, p_vm_stat;
37 8187859d 2005-10-05 devnull boolean_t purgeable_is_valid;
38 8187859d 2005-10-05 devnull struct xsw_usage xsu;
39 8187859d 2005-10-05 devnull boolean_t xsu_valid;
40 8187859d 2005-10-05 devnull integer_t syscalls_mach, p_syscalls_mach;
41 8187859d 2005-10-05 devnull integer_t syscalls_unix, p_syscalls_unix;
42 8187859d 2005-10-05 devnull ulong csw, p_csw;
43 8187859d 2005-10-05 devnull uint net_ifaces;
44 8187859d 2005-10-05 devnull uvlong net_ipackets, p_net_ipackets;
45 8187859d 2005-10-05 devnull uvlong net_opackets, p_net_opackets;
46 8187859d 2005-10-05 devnull uvlong net_ibytes, p_net_ibytes;
47 8187859d 2005-10-05 devnull uvlong net_obytes, p_net_obytes;
48 8187859d 2005-10-05 devnull uvlong net_errors, p_net_errors;
49 8187859d 2005-10-05 devnull ulong usecs;
52 8187859d 2005-10-05 devnull static Sample sample;
54 8187859d 2005-10-05 devnull void xsample(int);
55 8187859d 2005-10-05 devnull void xapm(int);
56 f0f4401f 2004-04-23 devnull void xloadavg(int);
57 f0f4401f 2004-04-23 devnull void xcpu(int);
58 f0f4401f 2004-04-23 devnull void xswap(int);
59 8187859d 2005-10-05 devnull void xvm(int);
60 f0f4401f 2004-04-23 devnull void xnet(int);
62 f0f4401f 2004-04-23 devnull void (*statfn[])(int) =
66 f0f4401f 2004-04-23 devnull xloadavg,
74 8187859d 2005-10-05 devnull static mach_port_t stat_port;
77 8187859d 2005-10-05 devnull sampleinit(void)
79 8187859d 2005-10-05 devnull mach_timebase_info_data_t info;
81 8187859d 2005-10-05 devnull if(stat_port)
84 8187859d 2005-10-05 devnull stat_port = mach_host_self();
85 8187859d 2005-10-05 devnull memset(&sample, 0, sizeof sample);
86 8187859d 2005-10-05 devnull if(host_page_size(stat_port, &sample.pgsize) != KERN_SUCCESS)
87 8187859d 2005-10-05 devnull sample.pgsize = 4096;
89 8187859d 2005-10-05 devnull // populate clock tick info for timestamps
90 8187859d 2005-10-05 devnull mach_timebase_info(&info);
91 8187859d 2005-10-05 devnull sample.divisor = 1000.0 * (double)info.denom/info.numer;
92 8187859d 2005-10-05 devnull sample.time = mach_absolute_time();
96 8187859d 2005-10-05 devnull samplenet(void)
98 8187859d 2005-10-05 devnull struct ifaddrs *ifa_list, *ifa;
99 f3832660 2005-10-19 devnull struct if_data *if_data;
101 8187859d 2005-10-05 devnull ifa_list = nil;
102 f3832660 2005-10-19 devnull sample.net_ifaces = 0;
103 8187859d 2005-10-05 devnull if(getifaddrs(&ifa_list) == 0){
104 8187859d 2005-10-05 devnull sample.p_net_ipackets = sample.net_ipackets;
105 8187859d 2005-10-05 devnull sample.p_net_opackets = sample.net_opackets;
106 8187859d 2005-10-05 devnull sample.p_net_ibytes = sample.net_ibytes;
107 f3832660 2005-10-19 devnull sample.p_net_obytes = sample.net_obytes;
108 8187859d 2005-10-05 devnull sample.p_net_errors = sample.net_errors;
110 8187859d 2005-10-05 devnull sample.net_ipackets = 0;
111 8187859d 2005-10-05 devnull sample.net_opackets = 0;
112 8187859d 2005-10-05 devnull sample.net_ibytes = 0;
113 8187859d 2005-10-05 devnull sample.net_obytes = 0;
114 8187859d 2005-10-05 devnull sample.net_errors = 0;
115 8187859d 2005-10-05 devnull sample.net_ifaces = 0;
117 f3832660 2005-10-19 devnull for(ifa=ifa_list; ifa; ifa=ifa->ifa_next){
118 8187859d 2005-10-05 devnull if(ifa->ifa_addr->sa_family != AF_LINK)
119 8187859d 2005-10-05 devnull continue;
120 8187859d 2005-10-05 devnull if((ifa->ifa_flags&(IFF_UP|IFF_RUNNING)) == 0)
121 8187859d 2005-10-05 devnull continue;
122 8187859d 2005-10-05 devnull if(ifa->ifa_data == nil)
123 8187859d 2005-10-05 devnull continue;
124 8187859d 2005-10-05 devnull if(strncmp(ifa->ifa_name, "lo", 2) == 0) /* loopback */
125 8187859d 2005-10-05 devnull continue;
127 f3832660 2005-10-19 devnull if_data = (struct if_data*)ifa->ifa_data;
128 8187859d 2005-10-05 devnull sample.net_ipackets += if_data->ifi_ipackets;
129 8187859d 2005-10-05 devnull sample.net_opackets += if_data->ifi_opackets;
130 8187859d 2005-10-05 devnull sample.net_ibytes += if_data->ifi_ibytes;
131 f3832660 2005-10-19 devnull sample.net_obytes += if_data->ifi_obytes;
132 f3832660 2005-10-19 devnull sample.net_errors += if_data->ifi_ierrors + if_data->ifi_oerrors;
133 8187859d 2005-10-05 devnull sample.net_ifaces++;
135 8187859d 2005-10-05 devnull freeifaddrs(ifa_list);
141 8187859d 2005-10-05 devnull * The following forces the program to be run with the suid root as
142 8187859d 2005-10-05 devnull * all the other stat monitoring apps get set:
144 8187859d 2005-10-05 devnull * -rwsr-xr-x 1 root wheel 83088 Mar 20 2005 /usr/bin/top
145 8187859d 2005-10-05 devnull * -rwsrwxr-x 1 root admin 54048 Mar 20 2005
146 8187859d 2005-10-05 devnull * /Applications/Utilities/Activity Monitor.app/Contents/Resources/pmTool
148 8187859d 2005-10-05 devnull * If Darwin eventually encompases more into sysctl then this
149 8187859d 2005-10-05 devnull * won't be required.
152 f3832660 2005-10-19 devnull samplevents(void)
154 8187859d 2005-10-05 devnull uint i, j, pcnt, tcnt;
155 8187859d 2005-10-05 devnull mach_msg_type_number_t count;
156 8187859d 2005-10-05 devnull kern_return_t error;
157 8187859d 2005-10-05 devnull processor_set_t *psets, pset;
158 8187859d 2005-10-05 devnull task_t *tasks;
159 8187859d 2005-10-05 devnull task_events_info_data_t events;
161 8187859d 2005-10-05 devnull if((error = host_processor_sets(stat_port, &psets, &pcnt)) != KERN_SUCCESS){
162 8187859d 2005-10-05 devnull Bprint(&bout, "host_processor_sets: %s (make sure auxstats is setuid root)\n",
163 8187859d 2005-10-05 devnull mach_error_string(error));
167 8187859d 2005-10-05 devnull sample.p_syscalls_mach = sample.syscalls_mach;
168 8187859d 2005-10-05 devnull sample.p_syscalls_unix = sample.syscalls_unix;
169 8187859d 2005-10-05 devnull sample.p_csw = sample.csw;
171 8187859d 2005-10-05 devnull sample.syscalls_mach = 0;
172 8187859d 2005-10-05 devnull sample.syscalls_unix = 0;
173 8187859d 2005-10-05 devnull sample.csw = 0;
175 8187859d 2005-10-05 devnull for(i=0; i<pcnt; i++){
176 8187859d 2005-10-05 devnull if((error=host_processor_set_priv(stat_port, psets[i], &pset)) != KERN_SUCCESS){
177 8187859d 2005-10-05 devnull Bprint(&bout, "host_processor_set_priv: %s\n", mach_error_string(error));
180 f3832660 2005-10-19 devnull if((error=processor_set_tasks(pset, &tasks, &tcnt)) != KERN_SUCCESS){
181 f3832660 2005-10-19 devnull Bprint(&bout, "processor_set_tasks: %s\n", mach_error_string(error));
184 8187859d 2005-10-05 devnull for(j=0; j<tcnt; j++){
185 8187859d 2005-10-05 devnull count = TASK_EVENTS_INFO_COUNT;
186 8187859d 2005-10-05 devnull if(task_info(tasks[j], TASK_EVENTS_INFO, (task_info_t)&events, &count) == KERN_SUCCESS){
187 8187859d 2005-10-05 devnull sample.syscalls_mach += events.syscalls_mach;
188 8187859d 2005-10-05 devnull sample.syscalls_unix += events.syscalls_unix;
189 8187859d 2005-10-05 devnull sample.csw += events.csw;
192 8187859d 2005-10-05 devnull if(tasks[j] != mach_task_self())
193 8187859d 2005-10-05 devnull mach_port_deallocate(mach_task_self(), tasks[j]);
196 8187859d 2005-10-05 devnull if((error = vm_deallocate((vm_map_t)mach_task_self(),
197 8187859d 2005-10-05 devnull (vm_address_t)tasks, tcnt*sizeof(task_t))) != KERN_SUCCESS){
198 8187859d 2005-10-05 devnull Bprint(&bout, "vm_deallocate: %s\n", mach_error_string(error));
202 8187859d 2005-10-05 devnull if((error = mach_port_deallocate(mach_task_self(), pset)) != KERN_SUCCESS
203 8187859d 2005-10-05 devnull || (error = mach_port_deallocate(mach_task_self(), psets[i])) != KERN_SUCCESS){
204 8187859d 2005-10-05 devnull Bprint(&bout, "mach_port_deallocate: %s\n", mach_error_string(error));
209 8187859d 2005-10-05 devnull if((error = vm_deallocate((vm_map_t)mach_task_self(), (vm_address_t)psets,
210 8187859d 2005-10-05 devnull pcnt*sizeof(processor_set_t))) != KERN_SUCCESS){
211 8187859d 2005-10-05 devnull Bprint(&bout, "vm_deallocate: %s\n", mach_error_string(error));
217 8187859d 2005-10-05 devnull xsample(int first)
219 8187859d 2005-10-05 devnull int mib[2];
220 8187859d 2005-10-05 devnull mach_msg_type_number_t count;
221 8187859d 2005-10-05 devnull size_t len;
223 8187859d 2005-10-05 devnull if(first){
224 8187859d 2005-10-05 devnull sampleinit();
228 8187859d 2005-10-05 devnull sample.seq++;
229 8187859d 2005-10-05 devnull sample.p_time = sample.time;
230 8187859d 2005-10-05 devnull sample.time = mach_absolute_time();
232 8187859d 2005-10-05 devnull sample.p_vm_stat = sample.vm_stat;
233 8187859d 2005-10-05 devnull count = sizeof(sample.vm_stat) / sizeof(natural_t);
234 8187859d 2005-10-05 devnull host_statistics(stat_port, HOST_VM_INFO, (host_info_t)&sample.vm_stat, &count);
236 8187859d 2005-10-05 devnull if(sample.seq == 1)
237 8187859d 2005-10-05 devnull sample.p_vm_stat = sample.vm_stat;
239 8187859d 2005-10-05 devnull mib[0] = CTL_VM;
240 8187859d 2005-10-05 devnull mib[1] = VM_SWAPUSAGE;
241 8187859d 2005-10-05 devnull len = sizeof sample.xsu;
242 8187859d 2005-10-05 devnull sample.xsu_valid = TRUE;
243 f3832660 2005-10-19 devnull if(sysctl(mib, 2, &sample.xsu, &len, NULL, 0) < 0 && errno == ENOENT)
244 8187859d 2005-10-05 devnull sample.xsu_value = FALSE;
246 8187859d 2005-10-05 devnull samplenet();
247 8187859d 2005-10-05 devnull sampleevents();
249 8187859d 2005-10-05 devnull sample.p_cpu = sample.cpu;
250 8187859d 2005-10-05 devnull count = HOST_CPU_LOAD_INFO_COUNT;
251 8187859d 2005-10-05 devnull host_statistics(stat_port, HOST_CPU_LOAD_INFO, (host_info_t)&sample.cpu, &count);
252 f3832660 2005-10-19 devnull sample.usecs = (double)(sample.time - sample.p_time)/sample.divisor;
253 8187859d 2005-10-05 devnull Bprint(&bout, "usecs %lud\n", sample.usecs);
257 8187859d 2005-10-05 devnull xapm(int first)
259 8187859d 2005-10-05 devnull int i, battery;
260 8187859d 2005-10-05 devnull CFArrayRef array;
261 8187859d 2005-10-05 devnull CFDictionaryRef dict;
262 8187859d 2005-10-05 devnull CFTypeRef cf, src, value;
264 f0f4401f 2004-04-23 devnull if(first)
267 8187859d 2005-10-05 devnull src = IOPSCopyPowerSourcesInfo();
268 8187859d 2005-10-05 devnull array = IOPSCopyPowerSourcesList(src);
270 8187859d 2005-10-05 devnull for(i=0; i<CFArrayGetCount(array); i++){
271 8187859d 2005-10-05 devnull cf = CFArrayGetValueAtIndex(array, i);
272 8187859d 2005-10-05 devnull dict = IOPSGetPowerSourceDescription(src, cf);
273 8187859d 2005-10-05 devnull if(dict != nil){
274 8187859d 2005-10-05 devnull value = CFDictionaryGetValue(dict, CFSTR("Current Capacity"));
275 8187859d 2005-10-05 devnull if(value != nil){
276 8187859d 2005-10-05 devnull if(!CFNumberGetValue(value, kCFNumberIntType, &battery))
277 8187859d 2005-10-05 devnull battery = 100;
278 8187859d 2005-10-05 devnull Bprint(&bout, "battery =%d 100\n", battery);
284 8187859d 2005-10-05 devnull CFRelease(array);
285 8187859d 2005-10-05 devnull CFRelease(src);
289 8187859d 2005-10-05 devnull xnet(int first)
292 8187859d 2005-10-05 devnull uvlong err, in, inb, out, outb;
294 8187859d 2005-10-05 devnull n = sample.net_ifaces;
295 8187859d 2005-10-05 devnull in = sample.net_ipackets;
296 8187859d 2005-10-05 devnull out = sample.net_opackets;
297 8187859d 2005-10-05 devnull inb = sample.net_ibytes;
298 8187859d 2005-10-05 devnull outb = sample.net_obytes;
299 8187859d 2005-10-05 devnull err = sample.net_errors;
301 8187859d 2005-10-05 devnull Bprint(&bout, "etherb %llud %d\n", inb+outb, n*1000000);
302 8187859d 2005-10-05 devnull Bprint(&bout, "ether %llud %d\n", in+out, n*1000);
303 8187859d 2005-10-05 devnull Bprint(&bout, "ethererr %llud %d\n", err, n*1000);
304 8187859d 2005-10-05 devnull Bprint(&bout, "etherin %llud %d\n", in, n*1000);
305 8187859d 2005-10-05 devnull Bprint(&bout, "etherout %llud %d\n", out, n*1000);
306 8187859d 2005-10-05 devnull Bprint(&bout, "etherinb %llud %d\n", inb, n*1000);
307 8187859d 2005-10-05 devnull Bprint(&bout, "etheroutb %llud %d\n", outb, n*1000);
311 f0f4401f 2004-04-23 devnull rsys(char *name, char *buf, int len)
313 f0f4401f 2004-04-23 devnull size_t l;
315 f0f4401f 2004-04-23 devnull l = len;
316 f0f4401f 2004-04-23 devnull if(sysctlbyname(name, buf, &l, nil, 0) < 0)
317 f0f4401f 2004-04-23 devnull return -1;
318 f0f4401f 2004-04-23 devnull buf[l] = 0;
319 f0f4401f 2004-04-23 devnull return l;
323 f0f4401f 2004-04-23 devnull isys(char *name)
325 f0f4401f 2004-04-23 devnull ulong u;
326 f0f4401f 2004-04-23 devnull size_t l;
328 f0f4401f 2004-04-23 devnull l = sizeof u;
329 f0f4401f 2004-04-23 devnull if(sysctlbyname(name, &u, &l, nil, 0) < 0)
330 f0f4401f 2004-04-23 devnull return 0;
331 f0f4401f 2004-04-23 devnull return u;
335 8187859d 2005-10-05 devnull xvm(int first)
337 8187859d 2005-10-05 devnull uvlong total;
339 8187859d 2005-10-05 devnull if(first)
342 8187859d 2005-10-05 devnull total = sample.vm_stat.free_count
343 8187859d 2005-10-05 devnull + sample.vm_stat.active_count
344 8187859d 2005-10-05 devnull + sample.vm_stat.inactive_count
345 8187859d 2005-10-05 devnull + sample.vm_stat.wire_count;
346 8187859d 2005-10-05 devnull if(total)
347 f3832660 2005-10-19 devnull Bprint(&bout, "mem =%lld %lld\n", sample.vm_stat.active_count, total);
349 8187859d 2005-10-05 devnull Bprint(&bout, "context %lld 1000\n", (vlong)sample.csw);
350 8187859d 2005-10-05 devnull Bprint(&bout, "syscall %lld 1000\n", (vlong)sample.syscalls_mach+sample.syscalls_unix);
351 8187859d 2005-10-05 devnull Bprint(&bout, "intr %lld 1000\n",
352 8187859d 2005-10-05 devnull isys("vm.stats.sys.v_intr")
353 8187859d 2005-10-05 devnull +isys("vm.stats.sys.v_trap"));
355 f3832660 2005-10-19 devnull Bprint(&bout, "fault %lld 1000\n", sample.vm_stat.faults);
356 8187859d 2005-10-05 devnull Bprint(&bout, "fork %lld 1000\n",
357 8187859d 2005-10-05 devnull isys("vm.stats.vm.v_rforks")
358 f0f4401f 2004-04-23 devnull +isys("vm.stats.vm.v_vforks"));
360 8187859d 2005-10-05 devnull // Bprint(&bout, "hits %lud of %lud lookups (%d%% hit rate)\n",
361 8187859d 2005-10-05 devnull // (asamp.vm_stat.hits),
362 8187859d 2005-10-05 devnull // (asamp.vm_stat.lookups),
363 8187859d 2005-10-05 devnull // (natural_t)(((double)asamp.vm_stat.hits*100)/ (double)asamp.vm_stat.lookups));
367 f0f4401f 2004-04-23 devnull xcpu(int first)
369 8187859d 2005-10-05 devnull ulong user, sys, idle, nice, t;
371 8187859d 2005-10-05 devnull if(first)
374 8187859d 2005-10-05 devnull sys = sample.cpu.cpu_ticks[CPU_STATE_SYSTEM] -
375 8187859d 2005-10-05 devnull sample.p_cpu.cpu_ticks[CPU_STATE_SYSTEM];
376 8187859d 2005-10-05 devnull idle = sample.cpu.cpu_ticks[CPU_STATE_IDLE] -
377 8187859d 2005-10-05 devnull sample.p_cpu.cpu_ticks[CPU_STATE_IDLE];
378 8187859d 2005-10-05 devnull user = sample.cpu.cpu_ticks[CPU_STATE_USER] -
379 8187859d 2005-10-05 devnull sample.p_cpu.cpu_ticks[CPU_STATE_USER];
380 8187859d 2005-10-05 devnull nice = sample.cpu.cpu_ticks[CPU_STATE_NICE] -
381 8187859d 2005-10-05 devnull sample.p_cpu.cpu_ticks[CPU_STATE_NICE];
383 8187859d 2005-10-05 devnull t = sys+idle+user+nice;
385 8187859d 2005-10-05 devnull Bprint(&bout, "user =%lud %lud\n", user, t);
386 8187859d 2005-10-05 devnull Bprint(&bout, "sys =%lud %lud\n", sys, t);
387 8187859d 2005-10-05 devnull Bprint(&bout, "idle =%lud %lud\n", idle, t);
388 8187859d 2005-10-05 devnull Bprint(&bout, "nice =%lud %lud\n", nice, t);
392 f0f4401f 2004-04-23 devnull xloadavg(int first)
394 f0f4401f 2004-04-23 devnull double l[3];
396 f0f4401f 2004-04-23 devnull if(first)
399 f0f4401f 2004-04-23 devnull if(getloadavg(l, 3) < 0)
401 f0f4401f 2004-04-23 devnull Bprint(&bout, "load %d 1000\n", (int)(l[0]*1000.0));
405 f0f4401f 2004-04-23 devnull xswap(int first)
407 8187859d 2005-10-05 devnull if(first)
410 8187859d 2005-10-05 devnull if(sample.xsu_valid)
411 8187859d 2005-10-05 devnull Bprint(&bout, "swap %lld %lld\n",
412 f3832660 2005-10-19 devnull (vlong)sample.xsu.xsu_used,
413 8187859d 2005-10-05 devnull (vlong)sample.xsu.xsu_total);
