| Safe Haskell | None |
|---|---|
| Language | Haskell2010 |
Ouroboros.Consensus.MiniProtocol.ObjectDiffusion.Inbound
Documentation
objectDiffusionInbound Source #
Arguments
| ∷ ∀ objectId object (m ∷ Type → Type). (Ord objectId, Show objectId, Typeable objectId, Typeable object, NoThunks objectId, NoThunks object, MonadSTM m, MonadThrow m) | |
| ⇒ Tracer m (TraceObjectDiffusionInbound objectId object) | |
| → (NumObjectsUnacknowledged, NumObjectIdsReq, NumObjectsReq) | Maximum values for outstanding FIFO length, number of IDs to request, and number of objects to request |
| → ObjectPoolWriter objectId object m | |
| → NodeToNodeVersion | |
| → ControlMessageSTM m | |
| → ObjectDiffusionInboundPipelined objectId object m () |
data TraceObjectDiffusionInbound objectId object Source #
Constructors
| TraceObjectDiffusionInboundCollectedObjects Int | Number of objects just about to be inserted. |
| TraceObjectDiffusionInboundAddedObjects NumObjectsProcessed | Just processed object pass/fail breakdown. |
| TraceObjectDiffusionInboundRecvControlMessage ControlMessage | Received a |
| TraceObjectDiffusionInboundCanRequestMoreObjects Int | |
| TraceObjectDiffusionInboundCannotRequestMoreObjects Int |
Instances
| Show (TraceObjectDiffusionInbound objectId object) Source # | |
Defined in Ouroboros.Consensus.MiniProtocol.ObjectDiffusion.Inbound Methods showsPrec ∷ Int → TraceObjectDiffusionInbound objectId object → ShowS # show ∷ TraceObjectDiffusionInbound objectId object → String # showList ∷ [TraceObjectDiffusionInbound objectId object] → ShowS # | |
| Eq (TraceObjectDiffusionInbound objectId object) Source # | |
Defined in Ouroboros.Consensus.MiniProtocol.ObjectDiffusion.Inbound Methods (==) ∷ TraceObjectDiffusionInbound objectId object → TraceObjectDiffusionInbound objectId object → Bool # (/=) ∷ TraceObjectDiffusionInbound objectId object → TraceObjectDiffusionInbound objectId object → Bool # | |
data ObjectDiffusionInboundError objectId object Source #
Constructors
| ProtocolErrorObjectsDifferentThanRequested (Set objectId) (Set objectId) | |
| ProtocolErrorObjectIdsNotRequested Int Int | |
| ProtocolErrorObjectIdsAlreadyKnown (Set objectId) | |
| ProtocolErrorObjectIdsDuplicate (Map objectId Int) |
Instances
| (Show objectId, Typeable object, Typeable objectId) ⇒ Exception (ObjectDiffusionInboundError objectId object) Source # | |
Defined in Ouroboros.Consensus.MiniProtocol.ObjectDiffusion.Inbound Methods toException ∷ ObjectDiffusionInboundError objectId object → SomeException # fromException ∷ SomeException → Maybe (ObjectDiffusionInboundError objectId object) # displayException ∷ ObjectDiffusionInboundError objectId object → String # backtraceDesired ∷ ObjectDiffusionInboundError objectId object → Bool # | |
| Show objectId ⇒ Show (ObjectDiffusionInboundError objectId object) Source # | |
Defined in Ouroboros.Consensus.MiniProtocol.ObjectDiffusion.Inbound Methods showsPrec ∷ Int → ObjectDiffusionInboundError objectId object → ShowS # show ∷ ObjectDiffusionInboundError objectId object → String # showList ∷ [ObjectDiffusionInboundError objectId object] → ShowS # | |
newtype NumObjectsProcessed Source #
Constructors
| NumObjectsProcessed | |
Fields | |
Instances
| Show NumObjectsProcessed Source # | |
Defined in Ouroboros.Consensus.MiniProtocol.ObjectDiffusion.Inbound Methods showsPrec ∷ Int → NumObjectsProcessed → ShowS # show ∷ NumObjectsProcessed → String # showList ∷ [NumObjectsProcessed] → ShowS # | |
| Eq NumObjectsProcessed Source # | |
Defined in Ouroboros.Consensus.MiniProtocol.ObjectDiffusion.Inbound Methods | |