*/
import "C"
import (
+ "errors"
"fmt"
"os"
"unsafe"
"git.fd.io/govpp.git/adapter"
)
+var (
+ ErrStatDirBusy = errors.New("stat dir busy")
+ ErrStatDumpBusy = errors.New("stat dump busy")
+)
+
var (
// DefaultStatSocket is the default path for the VPP stat socket file.
DefaultStatSocket = "/run/vpp/stats.sock"
func (c *statClient) ListStats(patterns ...string) (stats []string, err error) {
dir := C.govpp_stat_segment_ls(convertStringSlice(patterns))
+ if dir == nil {
+ return nil, ErrStatDirBusy
+ }
defer C.govpp_stat_segment_vec_free(unsafe.Pointer(dir))
l := C.govpp_stat_segment_vec_len(unsafe.Pointer(dir))
func (c *statClient) DumpStats(patterns ...string) (stats []*adapter.StatEntry, err error) {
dir := C.govpp_stat_segment_ls(convertStringSlice(patterns))
+ if dir == nil {
+ return nil, ErrStatDirBusy
+ }
defer C.govpp_stat_segment_vec_free(unsafe.Pointer(dir))
dump := C.govpp_stat_segment_dump(dir)
+ if dump == nil {
+ return nil, ErrStatDumpBusy
+ }
defer C.govpp_stat_segment_data_free(dump)
l := C.govpp_stat_segment_vec_len(unsafe.Pointer(dump))
var vector []adapter.Name
for k := 0; k < length; k++ {
s := C.govpp_stat_segment_data_get_name_vector_index(&v, C.int(k))
- if s == nil {
- continue
+ var name adapter.Name
+ if s != nil {
+ name = adapter.Name(C.GoString(s))
}
- vector = append(vector, adapter.Name(C.GoString(s)))
+ vector = append(vector, name)
}
stat.Data = adapter.NameStat(vector)