[VOL-1429] This commit adds a flag to bypass the transaction processing
in single core instance. It also removes the hardcoded KV store
path prefix and put it as part of the config. Adding the ability for
a calling function to change the transaction timeout.
Change-Id: I8570b44b34db99b46410dafd58c6c5b86ea97b41
diff --git a/rw_core/main.go b/rw_core/main.go
index 336e731..2a29499 100644
--- a/rw_core/main.go
+++ b/rw_core/main.go
@@ -124,11 +124,14 @@
err := rw.setKVClient()
if err == nil {
// Setup KV transaction context
- c.SetTransactionContext(rw.config.InstanceID,
- "service/voltha/transactions/",
+ txnPrefix := rw.config.KVStoreDataPrefix + "/transactions/"
+ if err = c.SetTransactionContext(rw.config.InstanceID,
+ txnPrefix,
rw.kvClient,
rw.config.KVStoreTimeout,
- rw.config.KVTxnKeyDelTime)
+ rw.config.KVTxnKeyDelTime); err != nil {
+ log.Fatal("creating-transaction-context-failed")
+ }
}
// Setup Kafka Client