X-Git-Url: https://gerrit.fd.io/r/gitweb?a=blobdiff_plain;ds=sidebyside;f=extras%2Flibmemif%2Fadapter.go;h=0cee589f471d487272f0f21b97490b3eca34db6b;hb=refs%2Fchanges%2F69%2F28169%2F2;hp=d238df61fe7cafe3a1e8f0014c349ea9a31d0166;hpb=6bfc1a27011d44cbf915607feb276a847148dd30;p=govpp.git

diff --git a/extras/libmemif/adapter.go b/extras/libmemif/adapter.go
index d238df6..0cee589 100644
--- a/extras/libmemif/adapter.go
+++ b/extras/libmemif/adapter.go
@@ -34,7 +34,7 @@ import (
 #include <stdint.h>
 #include <string.h>
 #include <sys/eventfd.h>
-#include <libmemif.h>
+#include <libmemif.h> 	// <-- VPP must be installed!
 
 // Feature tests.
 #ifndef MEMIF_HAVE_CANCEL_POLL_EVENT
@@ -50,7 +50,7 @@ memif_cancel_poll_event ()
 // are much easier to work with in cgo.
 typedef struct
 {
-	char *socket_filename;
+	memif_socket_handle_t socket;
 	char *secret;
 	uint8_t num_s2m_rings;
 	uint8_t num_m2s_rings;
@@ -108,7 +108,7 @@ govpp_memif_create (memif_conn_handle_t *conn, govpp_memif_conn_args_t *go_args,
 {
 	memif_conn_args_t args;
 	memset (&args, 0, sizeof (args));
-	args.socket_filename = (char *)go_args->socket_filename;
+	args.socket = (char *)go_args->socket;
 	if (go_args->secret != NULL)
 	{
 		strncpy ((char *)args.secret, go_args->secret,
@@ -132,6 +132,12 @@ govpp_memif_create (memif_conn_handle_t *conn, govpp_memif_conn_args_t *go_args,
 						private_ctx);
 }
 
+static int
+govpp_memif_create_socket (memif_socket_handle_t *sock, char *filename)
+{
+	return memif_create_socket(sock, filename, NULL);
+}
+
 // govpp_memif_get_details keeps reallocating buffer until it is large enough.
 // The buffer is returned to be deallocated when it is no longer needed.
 static int
@@ -365,8 +371,9 @@ type Memif struct {
 	MemifMeta
 
 	// Per-library references
-	ifIndex int                   // index used in the Go-libmemif context (Context.memifs)
-	cHandle C.memif_conn_handle_t // handle used in C-libmemif
+	ifIndex int                     // index used in the Go-libmemif context (Context.memifs)
+	cHandle C.memif_conn_handle_t   // connection handle used in C-libmemif
+	sHandle C.memif_socket_handle_t // socket handle used in C-libmemif
 
 	// Callbacks
 	callbacks *MemifCallbacks
@@ -589,9 +596,13 @@ func CreateInterface(config *MemifConfig, callbacks *MemifCallbacks) (memif *Mem
 	args := &C.govpp_memif_conn_args_t{}
 	// - socket file name
 	if config.SocketFilename != "" {
-		args.socket_filename = C.CString(config.SocketFilename)
-		defer C.free(unsafe.Pointer(args.socket_filename))
+		log.WithField("name", config.SocketFilename).Debug("A new memif socket was created")
+		errCode := C.govpp_memif_create_socket(&memif.sHandle, C.CString(config.SocketFilename))
+		if getMemifError(int(errCode)) != nil {
+			return nil, err
+		}
 	}
+	args.socket = memif.sHandle
 	// - interface ID
 	args.interface_id = C.uint32_t(config.ConnID)
 	// - interface name
@@ -632,8 +643,7 @@ func CreateInterface(config *MemifConfig, callbacks *MemifCallbacks) (memif *Mem
 
 	// Create memif in C-libmemif.
 	errCode := C.govpp_memif_create(&memif.cHandle, args, unsafe.Pointer(uintptr(memif.ifIndex)))
-	err = getMemifError(int(errCode))
-	if err != nil {
+	if getMemifError(int(errCode)) != nil {
 		return nil, err
 	}
 
@@ -771,7 +781,7 @@ func (memif *Memif) TxBurst(queueID uint8, packets []RawPacketData) (count uint1
 	}
 
 	var bufCount int
-	var buffers []*txPacketBuffer
+	buffers := make([]*txPacketBuffer, 0)
 	cQueueID := C.uint16_t(queueID)
 
 	for _, packet := range packets {
@@ -916,6 +926,7 @@ func (memif *Memif) TxBurst(queueID uint8, packets []RawPacketData) (count uint1
 // Rx queue.
 func (memif *Memif) RxBurst(queueID uint8, count uint16) (packets []RawPacketData, err error) {
 	var recvCount C.uint16_t
+	packets = make([]RawPacketData, 0)
 
 	if count == 0 {
 		return packets, nil