aboutsummaryrefslogtreecommitdiff
diff options
context:
space:
mode:
-rw-r--r--funcs.go1
-rw-r--r--tx.go2
2 files changed, 2 insertions, 1 deletions
diff --git a/funcs.go b/funcs.go
index b418cd7..91d6bc8 100644
--- a/funcs.go
+++ b/funcs.go
@@ -35,6 +35,7 @@ func init() {
func newTx() *Tx {
tx := txPool.Get().(*Tx)
tx.tries = 0
+ tx.completed = false
return tx
}
diff --git a/tx.go b/tx.go
index f613efb..065cb6c 100644
--- a/tx.go
+++ b/tx.go
@@ -125,7 +125,7 @@ func (tx *Tx) recycle() {
delete(tx.watching, v)
v.watchers.Delete(tx)
}
- txPool.Put(tx)
+ //txPool.Put(tx)
}
func (tx *Tx) lockAllVars() {