Add duration to TxInboundAddedToMempool

Add the time it took to add TXs to the mempool to the
TxInboundAddedToMempool tracer.

Author: karknu

ouroboros-network/sim-tests-lib/Test/Ouroboros/Network/Testnet.hs

@@ -588,7 +588,7 @@ unit_txSubmission_allTransactions (ArbTxDecisionPolicy decisionPolicy)
                   case x of
                     -- When we add txids to the mempool, we collect them
                     -- into the map
-                    DiffusionTxSubmissionInbound (TraceTxInboundAddedToMempool txids) ->
+                    DiffusionTxSubmissionInbound (TraceTxInboundAddedToMempool txids _) ->
                       Map.alter (maybe (Just []) (Just . sort . (txids ++))) n rr
                     -- When the node is shutdown we have to reset the accepted
                     -- txids list

ouroboros-network/src/Ouroboros/Network/TxSubmission/Inbound/Server.hs

@@ -16,6 +16,7 @@ import Data.Set qualified as Set
 import Control.Concurrent.Class.MonadSTM.Strict
 import Control.Exception (assert)
 import Control.Monad.Class.MonadThrow
+import Control.Monad.Class.MonadTime.SI
 import Control.Tracer (Tracer, traceWith)
 
 import Network.TypedProtocol.Pipelined
@@ -43,6 +44,7 @@ txSubmissionInboundV2
   :: forall txid tx idx m.
      ( MonadSTM   m
      , MonadThrow m
+     , MonadMonotonicTime m
      , Ord txid
      )
   => Tracer m (TraceTxSubmissionInbound txid tx)
@@ -70,9 +72,15 @@ txSubmissionInboundV2
         txd@TxDecision { txdTxsToRequest = txsToReq, txdTxsToMempool = txs }
           <- readTxDecision
         traceWith tracer (TraceTxInboundDecision txd)
+
+        !start <- getMonotonicTime
         txidsAccepted <- mempoolAddTxs txs
+        !end <- getMonotonicTime
+        let duration = diffTime end start
+
         traceWith tracer $
-          TraceTxInboundAddedToMempool txidsAccepted
+          TraceTxInboundAddedToMempool txidsAccepted duration
+
         let !collected = length txs
         let !accepted = length txidsAccepted
         traceWith tracer $

ouroboros-network/src/Ouroboros/Network/TxSubmission/Inbound/Types.hs

@@ -22,6 +22,7 @@ module Ouroboros.Network.TxSubmission.Inbound.Types
   ) where
 
 import Control.Exception (Exception (..))
+import Control.Monad.Class.MonadTime.SI
 import Data.Map.Strict (Map)
 import Data.Sequence.Strict (StrictSeq)
 import Data.Set (Set)
@@ -294,7 +295,7 @@ data TraceTxSubmissionInbound txid tx =
     -- | Server received 'MsgDone'
   | TraceTxInboundCanRequestMoreTxs Int
   | TraceTxInboundCannotRequestMoreTxs Int
-  | TraceTxInboundAddedToMempool [txid]
+  | TraceTxInboundAddedToMempool [txid] DiffTime
 
   --
   -- messages emitted by the new implementation of the server in