Wake watchers until the var changes again

1 files changed, 5 insertions, 1 deletions

diff --git a/funcs.go b/funcs.go
index 59c0e74..b8c8464 100644
--- a/funcs.go
+++ b/funcs.go
@@ -74,7 +74,7 @@ retry:
 	}
 	// verify the read log
 	tx.lockAllVars()
-	if !tx.verify() {
+	if tx.inputsChanged() {
 		tx.unlock()
 		expvars.Add("failed commits", 1)
 		if profileFailedCommits {
@@ -84,6 +84,10 @@ retry:
 	}
 	// commit the write log and broadcast that variables have changed
 	tx.commit()
+	tx.mu.Lock()
+	tx.completed = true
+	tx.cond.Broadcast()
+	tx.mu.Unlock()
 	tx.unlock()
 	expvars.Add("commits", 1)
 	tx.recycle()