+ // start directory watcher
+ if err := watcher.Add(filepath.Dir(c.socketPath)); err != nil {
+ return err
+ }
+
+ timeout := time.NewTimer(MaxWaitReady)
+ for {
+ select {
+ case <-timeout.C:
+ return fmt.Errorf("timeout waiting (%s) for socket file: %s", MaxWaitReady, c.socketPath)
+
+ case e := <-watcher.Errors:
+ return e
+
+ case ev := <-watcher.Events:
+ log.Debugf("watcher event: %+v", ev)
+ if ev.Name == c.socketPath && (ev.Op&fsnotify.Create) == fsnotify.Create {
+ // socket created, we are ready
+ return nil
+ }
+ }
+ }
+}
+
+func (c *Client) Connect() error {
+ // check if socket exists
+ if _, err := os.Stat(c.socketPath); os.IsNotExist(err) {
+ return fmt.Errorf("VPP API socket file %s does not exist", c.socketPath)
+ } else if err != nil {
+ return fmt.Errorf("VPP API socket error: %v", err)
+ }
+
+ if err := c.connect(c.socketPath); err != nil {