Remove retry profiles on Tx recycle

This may fix a memory leak where the *Tx in retry profile keys holds on to old Tx and their writes.

1 files changed, 3 insertions, 0 deletions

diff --git a/tx.go b/tx.go
index 8f70c1b..9be08b5 100644
--- a/tx.go
+++ b/tx.go
@@ -145,6 +145,9 @@ func (tx *Tx) recycle() {
 		delete(tx.watching, v)
 		v.watchers.Delete(tx)
 	}
+	tx.removeRetryProfiles()
+	// I don't think we can reuse Txs, because the "completed" field should/needs to be set
+	// indefinitely after use.
 	//txPool.Put(tx)
 }