Merge pull request #814 from c-wind/master

add txn.Rollback on txn error
2015-12-31 12:39:24 +08:00
parent 1faad8a14e cc0d4d8b8b
commit d64166c65b
1 changed files with 1 additions and 0 deletions
--- a/kv/txn.go
+++ b/kv/txn.go
@ -38,6 +38,7 @@ func RunInNewTxn(store Storage, retryable bool, f func(txn Transaction) error) e
 			continue
 		}
 		if err != nil {
+			txn.Rollback()
 			return errors.Trace(err)
 		}