Fields

• isTxs ∷ !(TxSeq (TxMeasureWithDiffTime blk) (ValidatedTxWithDiffs blk))

  Transactions currently in the mempool

  NOTE: the total size of the transactions in isTxs may exceed the current capacity (isCapacity). When the capacity computed from the ledger has shrunk, we don't remove transactions from the Mempool to satisfy the new lower limit. We let the transactions get removed in the normal way: by becoming invalid w.r.t. the updated ledger state. We treat a Mempool over capacity in the same way as a Mempool at capacity.

• isTxIds ∷ !(Set (GenTxId blk))

  The cached IDs of transactions currently in the mempool.

  This allows one to more quickly lookup transactions by ID from a MempoolSnapshot (see snapshotHasTx).

  This should always be in-sync with the transactions in isTxs.

• isTxKeys ∷ !(LedgerTables blk KeysMK)

  The cached set of keys needed for the transactions currently in the mempool.

  INVARIANT: isTxKeys == foldMap (getTransactionKeySets . txForgetValidated) $ toList isTxs

• isTxValues ∷ !(LedgerTables blk ValuesMK)

  The cached values corresponding to reading isTxKeys at isLedgerState. These values can be used unless we switch to a different ledger state. It usually happens in the forging loop that the same ledger state that was in isLedgerState is used, but ticked to a different slot so we can reuse these values.

  INVARIANT: isTxValues should be equal to getForkerAtTarget ... isLedgerState >>= f -> forkerReadTables f isTxKeys

• isLedgerState ∷ !(TickedLedgerState blk DiffMK)

  The cached ledger state after applying the transactions in the Mempool against the chain's ledger state. New transactions will be validated against this ledger.

  INVARIANT: isLedgerState is the ledger resulting from applying the transactions in isTxs against the ledger identified isTip as tip.

• isTip ∷ !(Point blk)

  The tip of the chain that isTxs was validated against

• isSlotNo ∷ !SlotNo

  The most recent SlotNo that isTxs was validated against

  Note in particular that if the mempool is revalidated against a state S at slot s, then the state will be ticked (for now to the successor slot, see tickLedgerState) and isSlotNo will be set to succ s, which is different from the slot of the original ledger state, which will remain in isTip.

• isLastTicketNo ∷ !TicketNo

  The mempool TicketNo counter.

  See vrLastTicketNo for more information.

• isCapacity ∷ !(TxMeasure blk)

  Current maximum capacity of the Mempool. Result of computeMempoolCapacity using the current chain's TickedLedgerState.

  NOTE: this does not correspond to isLedgerState, which is the TickedLedgerState after applying the transactions in the Mempool. There might be a transaction in the Mempool triggering a change in the maximum transaction capacity of a block, which would change the Mempool's capacity (unless overridden). We don't want the Mempool's capacity to depend on its contents. The mempool is assuming all its transactions will be in the next block. So any changes caused by that block will take effect after applying it and will only affect the next block.

• isRemovalCounter ∷ !Word64

  A monotonic counter bumped each time implRemoveTxsEvenIfValid drops a transaction. A sync carries it along its (off-lock) candidate and re-checks it against the committed state under the lock: a mismatch means a removal raced the sync, whose candidate may have resurrected the dropped tx, so it must retry. Preserved by adds and syncs, bumped only by removals.

Fields

• validatedTx ∷ !(Validated (GenTx blk))
   
• validatedTxDiffs ∷ !(LedgerTables blk DiffMK)
   

Fields

• mpEnvLedger ∷ LedgerInterface m blk
   
• mpEnvForker ∷ StrictMVar m (ReadOnlyForker m LedgerState blk)
   
• mpEnvLedgerCfg ∷ LedgerConfig blk
   
• mpEnvStateVar ∷ StrictTMVar m (InternalState blk)

  The single, authoritative internal state of the mempool, which doubles as the writer lock. Writers (adds, removes and the sync merge) takeTMVar it, do their work, and putTMVar the new state; readers (getSnapshot, getCapacity, getSnapshotFor) readTMVar it. Because it is a single cell, the whole capacity accounting has one source of truth and cannot diverge. A reader only ever blocks for the duration a writer holds the lock; the sync keeps that short by doing its large LedgerDB read before taking the lock (see implSyncWithLedger), so only the (sub-second) merge is under it.

• mpEnvAddTxsRemoteFifo ∷ StrictMVar m ()
   
• mpEnvAddTxsAllFifo ∷ StrictMVar m ()
   
• mpEnvTracer ∷ Tracer m (TraceEventMempool blk)
   
• mpEnvCapacityOverride ∷ MempoolCapacityBytesOverride
   
• mpEnvTimeoutConfig ∷ Maybe MempoolTimeoutConfig
   

Fields

• getCurrentLedgerState ∷ STM m (MempoolLedgerDBView m blk)
   

Fields

• mldViewState ∷ LedgerState blk EmptyMK

  The ledger state currently at the tip of the LedgerDB

• mldViewGetForker ∷ m (Either GetForkerError (ReadOnlyForker m LedgerState blk))

  An action to get a forker at mldViewState or an error in the unlikely case that such state is now gone from the LedgerDB.

  The forker is not tracked as a resource because shutting down the mempool only happens if the system is going down, and in that case open forkers are unimportant.

Fields

• newInternalState ∷ !(InternalState blk)

  The internal state after revalidation

• removedTxs ∷ ![Invalidated blk]

  The previously valid transactions that were now invalid

Fields

• (Validated (GenTx blk))

  New, valid transaction that was added to the Mempool.

• MempoolSize

  The size of the Mempool before adding the transaction.

• MempoolSize

  The size of the Mempool after adding the transaction.

Fields

• (GenTx blk)

  New, invalid transaction thas was rejected and thus not added to the Mempool.

• (ApplyTxErr blk)

  The reason for rejecting the transaction.

• MempoolRejectionDetails

  More details about the reason

• MempoolSize

  The current size of the Mempool.

Fields

• [(GenTx blk, ApplyTxErr blk)]

  Previously valid transactions that are no longer valid because of changes in the ledger state (details are in the provided ApplyTxErr). These transactions have been removed from the Mempool.

• MempoolSize

  The current size of the Mempool.

Fields

• (NonEmpty (GenTxId blk))

  Transactions that have been manually removed from the Mempool.

• [GenTx blk]

  Previously valid transactions that are no longer valid because they dependend on transactions that were manually removed from the Mempool. These transactions have also been removed from the Mempool.

  This list shares not transactions with the list of manually removed transactions.

• MempoolSize

  The current size of the Mempool.

Fields

• EnclosingTimed

  How long the sync operation took.