1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
|
//go:build aix
// +build aix
package perfstat
/*
#cgo LDFLAGS: -lperfstat
#include <libperfstat.h>
#include <string.h>
#include <stdlib.h>
#include "c_helpers.h"
*/
import "C"
import (
"fmt"
"unsafe"
)
func ProcessStat() ([]Process, error) {
var proc *C.perfstat_process_t
var first C.perfstat_id_t
numproc := C.perfstat_process(nil, nil, C.sizeof_perfstat_process_t, 0)
if numproc < 1 {
return nil, fmt.Errorf("perfstat_process() error")
}
plen := C.sizeof_perfstat_process_t * C.ulong(numproc)
proc = (*C.perfstat_process_t)(C.malloc(plen))
defer C.free(unsafe.Pointer(proc))
C.strcpy(&first.name[0], C.CString(""))
r := C.perfstat_process(&first, proc, C.sizeof_perfstat_process_t, numproc)
if r < 0 {
return nil, fmt.Errorf("perfstat_process() error")
}
ps := make([]Process, r)
for i := 0; i < int(r); i++ {
p := C.get_process_stat(proc, C.int(i))
if p != nil {
ps[i] = perfstatprocess2process(p)
}
}
return ps, nil
}
func ThreadStat() ([]Thread, error) {
var thread *C.perfstat_thread_t
var first C.perfstat_id_t
numthr := C.perfstat_thread(nil, nil, C.sizeof_perfstat_thread_t, 0)
if numthr < 1 {
return nil, fmt.Errorf("perfstat_thread() error")
}
thlen := C.sizeof_perfstat_thread_t * C.ulong(numthr)
thread = (*C.perfstat_thread_t)(C.malloc(thlen))
defer C.free(unsafe.Pointer(thread))
C.strcpy(&first.name[0], C.CString(""))
r := C.perfstat_thread(&first, thread, C.sizeof_perfstat_thread_t, numthr)
if r < 0 {
return nil, fmt.Errorf("perfstat_thread() error")
}
th := make([]Thread, r)
for i := 0; i < int(r); i++ {
t := C.get_thread_stat(thread, C.int(i))
if t != nil {
th[i] = perfstatthread2thread(t)
}
}
return th, nil
}
|
