VOL-1690: Close the etcd watcher channels after we are done watching for etcd events.
Also ensure that the etcd watcher context is canceled after we are done using the etcd Watcher interface.
Change-Id: I237d7e7f2c2d05c5998d26560ff9abea653e04a2
diff --git a/rw_core/core/transaction.go b/rw_core/core/transaction.go
index b2d01a4..11f3d4e 100644
--- a/rw_core/core/transaction.go
+++ b/rw_core/core/transaction.go
@@ -247,6 +247,7 @@
var res int
events := ctx.kvClient.Watch(c.txnKey)
+ defer ctx.kvClient.CloseWatch(c.txnKey, events)
for {
select {