X-Git-Url: https://gerrit.fd.io/r/gitweb?p=govpp.git;a=blobdiff_plain;f=govpp.go;h=ff45b78fe90d9e063cb7fa82c52fa0fe73a9de1f;hp=6f0cc2e826d149af25b1c4acbc77eee523263671;hb=3da2b73ec5ce77abf796ebeae6dfc149c8d3c698;hpb=0456d22f67865977065886ed58778621b21b7ede diff --git a/govpp.go b/govpp.go index 6f0cc2e..ff45b78 100644 --- a/govpp.go +++ b/govpp.go @@ -25,9 +25,9 @@ var vppAdapter adapter.VppAdapter // VPP Adapter that will be used in the subseq // Connect connects the govpp core to VPP either using the default VPP Adapter, or using the adapter previously // set by SetAdapter (useful mostly just for unit/integration tests with mocked VPP adapter). // This call blocks until VPP is connected, or an error occurs. Only one connection attempt will be performed. -func Connect() (*core.Connection, error) { +func Connect(shm string) (*core.Connection, error) { if vppAdapter == nil { - vppAdapter = vppapiclient.NewVppAdapter() + vppAdapter = vppapiclient.NewVppAdapter(shm) } return core.Connect(vppAdapter) } @@ -37,9 +37,9 @@ func Connect() (*core.Connection, error) { // This call does not block until connection is established, it returns immediately. The caller is // supposed to watch the returned ConnectionState channel for Connected/Disconnected events. // In case of disconnect, the library will asynchronously try to reconnect. -func AsyncConnect() (*core.Connection, chan core.ConnectionEvent, error) { +func AsyncConnect(shm string) (*core.Connection, chan core.ConnectionEvent, error) { if vppAdapter == nil { - vppAdapter = vppapiclient.NewVppAdapter() + vppAdapter = vppapiclient.NewVppAdapter(shm) } return core.AsyncConnect(vppAdapter) } @@ -47,4 +47,4 @@ func AsyncConnect() (*core.Connection, chan core.ConnectionEvent, error) { // SetAdapter sets the adapter that will be used for connections to VPP in the subsequent `Connect` calls. func SetAdapter(ad adapter.VppAdapter) { vppAdapter = ad -} +} \ No newline at end of file