Added lock in callback

Signed-off-by: Saurabh Deoras <[email protected]>
talakad · Feb 15, 2018 · ab5c48c · ab5c48c
1 parent ec088b7
commit ab5c48c
Showing 1 changed file with 3 additions and 0 deletions.
diff --git a/osdconfig/callback.go b/osdconfig/callback.go
@@ -34,6 +34,9 @@ func (manager *configManager) execNodeCallbacks(f CallbackNodeConfigFunc, data *
 // this callback simply receives data from kvdb and reflects it on a channel it receives in opaque
 func (manager *configManager) kvdbCallback(prefix string,
 	opaque interface{}, kvp *kvdb.KVPair, err error) error {
+	manager.Lock()
+	defer manager.Unlock()
+
 	c, ok := opaque.(*dataToKvdb)
 	if !ok {
 		return fmt.Errorf("opaque value type is incorrect")