#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 uint32_t*
-govpp_stat_segment_ls(uint8_t ** pattern)
+govpp_stat_segment_ls(uint8_t **pattern)
{
return stat_segment_ls(pattern);
}
return data->combined_counter_vec[index][index2].bytes;
}
+static uint8_t**
+govpp_stat_segment_data_get_name_vector(stat_segment_data_t *data)
+{
+ 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]; // VPP 19.04 is required!
+}
+
static void
govpp_stat_segment_data_free(stat_segment_data_t *data)
{
*/
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))
}
stat.Data = adapter.CombinedCounterStat(vector)
+ case adapter.NameVector:
+ length := int(C.govpp_stat_segment_vec_len(unsafe.Pointer(C.govpp_stat_segment_data_get_name_vector(&v))))
+ var vector []adapter.Name
+ for k := 0; k < length; k++ {
+ s := C.govpp_stat_segment_data_get_name_vector_index(&v, C.int(k))
+ var name adapter.Name
+ if s != nil {
+ name = adapter.Name(C.GoString(s))
+ }
+ vector = append(vector, name)
+ }
+ stat.Data = adapter.NameStat(vector)
+
default:
- fmt.Fprintf(os.Stderr, "invalid stat type: %v (%d)", typ, typ)
+ fmt.Fprintf(os.Stderr, "invalid stat type: %v (%v)\n", typ, name)
continue
}