diff --git a/packages/chain/mempool/mempool.go b/packages/chain/mempool/mempool.go index 32e0c4507b..6ee92e1574 100644 --- a/packages/chain/mempool/mempool.go +++ b/packages/chain/mempool/mempool.go @@ -52,6 +52,7 @@ import ( "github.com/samber/lo" "github.com/iotaledger/hive.go/logger" + consGR "github.com/iotaledger/wasp/packages/chain/cons/cons_gr" "github.com/iotaledger/wasp/packages/chain/mempool/distsync" "github.com/iotaledger/wasp/packages/cryptolib" @@ -505,6 +506,8 @@ func (mpi *mempoolImpl) distSyncRequestReceivedCB(request isc.Request) bool { return false } if err := mpi.shouldAddOffledgerRequest(offLedgerReq); err == nil { + mpi.log.Warn("shouldAddOffledgerRequest: true, trying to add to offledger %T: %+v", request, request) + return mpi.addOffledger(offLedgerReq) } return false diff --git a/packages/chain/mempool/offledger_pool.go b/packages/chain/mempool/offledger_pool.go index 7fdc02b8c4..4a01692ebd 100644 --- a/packages/chain/mempool/offledger_pool.go +++ b/packages/chain/mempool/offledger_pool.go @@ -14,6 +14,7 @@ import ( "github.com/iotaledger/hive.go/ds/shrinkingmap" "github.com/iotaledger/hive.go/logger" + consGR "github.com/iotaledger/wasp/packages/chain/cons/cons_gr" "github.com/iotaledger/wasp/packages/isc" "github.com/iotaledger/wasp/packages/kv/codec" @@ -134,6 +135,7 @@ func (p *OffLedgerPool) Add(request isc.OffLedgerRequest) bool { deleted := p.LimitPoolSize() if lo.Contains(deleted, entry) { // this exact request was deleted from the pool, do not update metrics, or mark available + p.log.Debugf("NOT ADDED, was removed already. reqID: %v as key=%v, senderAccount: %v", request.ID(), ref, account) return false }