57 lines
1.4 KiB
Go
57 lines
1.4 KiB
Go
|
package gotoc
|
||
|
|
|
||
|
|
/*
|
||
|
|
#include "../../../../../Include/sigar.h"
|
||
|
|
#include "../../../../../Include/sigar_ptql.h"
|
||
|
|
#include <stdio.h>
|
||
|
|
#include <stdlib.h>
|
||
|
|
*/
|
||
|
|
import "C"
|
||
|
|
|
||
|
|
import (
|
||
|
|
"fmt"
|
||
|
|
"github.com/vmware/leap/util"
|
||
|
|
)
|
||
|
|
|
||
|
|
|
||
|
|
func ExecutePtql(ptql string, infoTypesMask ProcInfoType) (result []*ProcessInfo, err error){
|
||
|
|
defer util.Panic2Error(&err)
|
||
|
|
|
||
|
|
var query *C.sigar_ptql_query_t
|
||
|
|
var queryError *C.sigar_ptql_error_t
|
||
|
|
var proclist C.sigar_proc_list_t
|
||
|
|
|
||
|
|
sigar := GetSigarHandle()
|
||
|
|
ptqlC := C.CString(ptql)
|
||
|
|
//defer C.sigar_ptql_query_destroy(query)
|
||
|
|
defer C.sigar_proc_list_destroy(sigar, &proclist)
|
||
|
|
defer C.sigar_ptql_re_impl_set(sigar, nil, nil)
|
||
|
|
defer Free(ptqlC)
|
||
|
|
|
||
|
|
if status := C.sigar_ptql_query_create(&query, ptqlC, queryError) ; status != SIGAR_OK {
|
||
|
|
err = fmt.Errorf("Failed to create sigar ptql query for: %v with errorcode: %v", ptql, status)
|
||
|
|
return nil,err
|
||
|
|
}
|
||
|
|
|
||
|
|
C.sigar_ptql_query_find(sigar, query, &proclist)
|
||
|
|
C.sigar_ptql_query_destroy(query)
|
||
|
|
|
||
|
|
/*
|
||
|
|
noOfProcesses := int(proclist.number)
|
||
|
|
result = make([]*ProcessInfo, noOfProcesses)
|
||
|
|
pids := *(*[]C.sigar_pid_t) (CArr2SlicePtr(noOfProcesses, proclist.data))
|
||
|
|
for i,pid := range pids {
|
||
|
|
procInfo,err := GetProcInfo(uint64(pid), infoTypesMask)
|
||
|
|
if err != nil {
|
||
|
|
return nil,err
|
||
|
|
}
|
||
|
|
result[i] = procInfo
|
||
|
|
}
|
||
|
|
|
||
|
|
return result,nil*/
|
||
|
|
|
||
|
|
processes,err := getProcInfos(&proclist, infoTypesMask, sigar)
|
||
|
|
return processes.Processes,err
|
||
|
|
}
|
||
|
|
|