[VOL-1547] Add port to logical device when device is active
This commit consists of the following changes:
1) Fix the issue where flows were received when the logical
device flow graph was not ready.
2) Update the default kafka config for improved performance
3) Add a lock to the device ownership logic to ensure the
lock map does not get corrupted.
Change-Id: I840d572e06ed5acf0f3bc1ce423a0ada8f335543
diff --git a/db/kvstore/etcdclient.go b/db/kvstore/etcdclient.go
index 887a167..e5f6dfe 100644
--- a/db/kvstore/etcdclient.go
+++ b/db/kvstore/etcdclient.go
@@ -431,14 +431,14 @@
}
func (c *EtcdClient) listenForKeyChange(channel v3Client.WatchChan, ch chan<- *Event) {
- log.Infow("start-listening-on-channel", log.Fields{"channel": ch})
+ log.Debug("start-listening-on-channel ...")
for resp := range channel {
for _, ev := range resp.Events {
//log.Debugf("%s %q : %q\n", ev.Type, ev.Kv.Key, ev.Kv.Value)
ch <- NewEvent(getEventType(ev), ev.Kv.Key, ev.Kv.Value)
}
}
- log.Info("stop-listening-on-channel")
+ log.Debug("stop-listening-on-channel ...")
}
func getEventType(event *v3Client.Event) int {