#include <stdio.h>
#include <stdint.h>
#include <arpa/inet.h>
-#include <vpp-api/client/vppapiclient.h>
+#include <vpp-api/client/vppapiclient.h> // VPP has to be installed!
#include <vpp-api/client/stat_client.h>
static int
static uint8_t**
govpp_stat_segment_data_get_name_vector(stat_segment_data_t *data)
{
- return data->name_vector;
+ return data->name_vector; // VPP 19.04 is required!
}
static char*
govpp_stat_segment_data_get_name_vector_index(stat_segment_data_t *data, int index)
{
- return data->name_vector[index];
+ return data->name_vector[index]; // VPP 19.04 is required!
}
static void
*/
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)