From 52965076650af68c8fc7c65e0b06eb13d27bb118 Mon Sep 17 00:00:00 2001 From: Ethan Buchman Date: Tue, 12 Apr 2016 10:38:54 -0400 Subject: [PATCH] some mempool log statements --- mempool/mempool.go | 3 +++ 1 file changed, 3 insertions(+) diff --git a/mempool/mempool.go b/mempool/mempool.go index 0523e1d3..44b59f97 100644 --- a/mempool/mempool.go +++ b/mempool/mempool.go @@ -157,6 +157,7 @@ func (mem *Mempool) resCbNormal(req *tmsp.Request, res *tmsp.Response) { } mem.txs.PushBack(memTx) } else { + log.Info("Bad Transaction", "res", res) // ignore bad transaction // TODO: handle other retcodes } @@ -188,6 +189,7 @@ func (mem *Mempool) resCbRecheck(req *tmsp.Request, res *tmsp.Response) { if mem.recheckCursor == nil { // Done! atomic.StoreInt32(&mem.rechecking, 0) + log.Info("Done rechecking txs") } default: // ignore other messages @@ -245,6 +247,7 @@ func (mem *Mempool) Update(height int, txs []types.Tx) { goodTxs := mem.filterTxs(txsMap) // Recheck mempool txs if config.GetBool("mempool_recheck") { + log.Info("Recheck txs", "numtxs", len(goodTxs)) mem.recheckTxs(goodTxs) // At this point, mem.txs are being rechecked. // mem.recheckCursor re-scans mem.txs and possibly removes some txs.