vppShmFile = "vpe-api"
)
-// global VPP binary API client adapter context
-var client *VppClient
+// global VPP binary API client, library vppapiclient only supports
+// single connection at a time
+var globalVppClient *vppClient
-// VppClient is the default implementation of the VppAPI.
-type VppClient struct {
+// stubVppClient is the default implementation of the VppAPI.
+type vppClient struct {
shmPrefix string
msgCallback adapter.MsgCallback
}
// NewVppClient returns a new VPP binary API client.
-func NewVppClient(shmPrefix string) *VppClient {
- return &VppClient{
+func NewVppClient(shmPrefix string) adapter.VppAPI {
+ return &vppClient{
shmPrefix: shmPrefix,
}
}
// Connect connects the process to VPP.
-func (a *VppClient) Connect() error {
- if client != nil {
+func (a *vppClient) Connect() error {
+ if globalVppClient != nil {
return fmt.Errorf("already connected to binary API, disconnect first")
}
return fmt.Errorf("connecting to VPP binary API failed (rc=%v)", rc)
}
- client = a
+ globalVppClient = a
return nil
}
// Disconnect disconnects the process from VPP.
-func (a *VppClient) Disconnect() error {
- client = nil
+func (a *vppClient) Disconnect() error {
+ globalVppClient = nil
rc := C.govpp_disconnect()
if rc != 0 {
}
// GetMsgID returns a runtime message ID for the given message name and CRC.
-func (a *VppClient) GetMsgID(msgName string, msgCrc string) (uint16, error) {
+func (a *vppClient) GetMsgID(msgName string, msgCrc string) (uint16, error) {
nameAndCrc := C.CString(msgName + "_" + msgCrc)
defer C.free(unsafe.Pointer(nameAndCrc))
}
// SendMsg sends a binary-encoded message to VPP.
-func (a *VppClient) SendMsg(context uint32, data []byte) error {
+func (a *vppClient) SendMsg(context uint32, data []byte) error {
rc := C.govpp_send(C.uint32_t(context), unsafe.Pointer(&data[0]), C.size_t(len(data)))
if rc != 0 {
return fmt.Errorf("unable to send the message (rc=%v)", rc)
// SetMsgCallback sets a callback function that will be called by the adapter
// whenever a message comes from VPP.
-func (a *VppClient) SetMsgCallback(cb adapter.MsgCallback) {
+func (a *vppClient) SetMsgCallback(cb adapter.MsgCallback) {
a.msgCallback = cb
}
// WaitReady blocks until shared memory for sending
// binary api calls is present on the file system.
-func (a *VppClient) WaitReady() error {
+func (a *vppClient) WaitReady() error {
var path string
// join the path to the shared memory segment
sliceHeader := &reflect.SliceHeader{Data: uintptr(data), Len: int(size), Cap: int(size)}
byteSlice := *(*[]byte)(unsafe.Pointer(sliceHeader))
- client.msgCallback(uint16(msgID), byteSlice)
+ globalVppClient.msgCallback(uint16(msgID), byteSlice)
}