Safe Haskell	None
Language	Haskell2010

Ouroboros.Network.Protocol.Handshake

Contents

Re-exports

Description

API for running Handshake protocol.

Synopsis

runHandshakeClient :: (MonadAsync m, MonadEvaluate m, MonadFork m, MonadTimer m, MonadMask m, MonadThrow (STM m), Ord vNumber, NFData vNumber, NFData vData) => Bearer m -> connectionId -> HandshakeArguments connectionId vNumber vData m -> Versions vNumber vData application -> m (Either (HandshakeException vNumber) (HandshakeResult application vNumber vData))
runHandshakeServer :: (MonadAsync m, MonadEvaluate m, MonadFork m, MonadTimer m, MonadMask m, MonadThrow (STM m), Ord vNumber, NFData vNumber, NFData vData) => Bearer m -> connectionId -> HandshakeArguments connectionId vNumber vData m -> Versions vNumber vData application -> m (Either (HandshakeException vNumber) (HandshakeResult application vNumber vData))
data HandshakeArguments connectionId vNumber vData (m :: Type -> Type) = HandshakeArguments {
- haHandshakeTracer :: Tracer m (WithBearer connectionId (TraceSendRecv (Handshake vNumber Term)))
- haBearerTracer :: Tracer m (WithBearer connectionId BearerTrace)
- haHandshakeCodec :: Codec (Handshake vNumber Term) DeserialiseFailure m ByteString
- haVersionDataCodec :: VersionDataCodec Term vNumber vData
- haAcceptVersion :: vData -> vData -> Accept vData
- haQueryVersion :: vData -> Bool
- haTimeLimits :: ProtocolTimeLimits (Handshake vNumber Term)
}
newtype Versions vNum vData r = Versions {
- getVersions :: Map vNum (Version vData r)
}
data HandshakeException vNumber
- = HandshakeProtocolLimit ProtocolLimitFailure
- | HandshakeProtocolError (HandshakeProtocolError vNumber)
data HandshakeProtocolError vNumber
- = HandshakeError (RefuseReason vNumber)
- | NotRecognisedVersion vNumber
- | InvalidServerSelection vNumber Text
- | QueryNotSupported
data HandshakeResult r vNumber vData
- = HandshakeNegotiationResult r vNumber vData
- | HandshakeQueryResult (Map vNumber (Either Text vData))
data RefuseReason vNumber
- = VersionMismatch [vNumber] [Int]
- | HandshakeDecodeError vNumber Text
- | Refused vNumber Text
data Accept vData
- = Accept vData
- | Refuse !Text
handshake_QUERY_SHUTDOWN_DELAY :: DiffTime
module Ouroboros.Network.Protocol.Handshake.Type
module Ouroboros.Network.Protocol.Handshake.Codec
module Ouroboros.Network.Protocol.Handshake.Version
class Acceptable v where
- acceptableVersion :: v -> v -> Accept v
class Queryable v where
- queryVersion :: v -> Bool

Documentation

runHandshakeClient :: (MonadAsync m, MonadEvaluate m, MonadFork m, MonadTimer m, MonadMask m, MonadThrow (STM m), Ord vNumber, NFData vNumber, NFData vData) => Bearer m -> connectionId -> HandshakeArguments connectionId vNumber vData m -> Versions vNumber vData application -> m (Either (HandshakeException vNumber) (HandshakeResult application vNumber vData)) Source #

Run client side of the Handshake protocol

runHandshakeServer :: (MonadAsync m, MonadEvaluate m, MonadFork m, MonadTimer m, MonadMask m, MonadThrow (STM m), Ord vNumber, NFData vNumber, NFData vData) => Bearer m -> connectionId -> HandshakeArguments connectionId vNumber vData m -> Versions vNumber vData application -> m (Either (HandshakeException vNumber) (HandshakeResult application vNumber vData)) Source #

Run server side of the Handshake protocol.

data HandshakeArguments connectionId vNumber vData (m :: Type -> Type) Source #

Common arguments for both Handshake client & server.

Constructors

HandshakeArguments

Fields

haHandshakeTracer :: Tracer m (WithBearer connectionId (TraceSendRecv (Handshake vNumber Term)))
Handshake tracer
haBearerTracer :: Tracer m (WithBearer connectionId BearerTrace)
haHandshakeCodec :: Codec (Handshake vNumber Term) DeserialiseFailure m ByteString
Codec for protocol messages.
haVersionDataCodec :: VersionDataCodec Term vNumber vData
A codec for protocol parameters.
haAcceptVersion :: vData -> vData -> Accept vData
accept version, first argument is our version data the second argument is the remote version data.
haQueryVersion :: vData -> Bool
Whether version data requested a query of support version.
haTimeLimits :: ProtocolTimeLimits (Handshake vNumber Term)
Driver timeouts for Handshake protocol.

newtype Versions vNum vData r Source #

The version map supported by the local agent keyed on the version identifier.

Each Version contains a function which takes negotiated version data and returns negotiated application (the r type variable).

If one needs to combine multiple versions the simplest way is to use one of the combinators: foldMapVersions, combineVersions or the Semigroup instance directly:

fold $ (simpleSingletonVersions ...)
      :| [ (simpleSingletonVersions ...)
         , (simpleSingletonVersions ...)
         , ...
         ]

Constructors

Versions
Fields getVersions :: Map vNum (Version vData r)

Instances

Instances details

Functor (Versions vNum extra) Source #
Instance details Defined in Ouroboros.Network.Protocol.Handshake.Version Methods fmap :: (a -> b) -> Versions vNum extra a -> Versions vNum extra b # (<$) :: a -> Versions vNum extra b -> Versions vNum extra a #
Ord vNum => Semigroup (Versions vNum vData r) Source #
Instance details Defined in Ouroboros.Network.Protocol.Handshake.Version Methods (<>) :: Versions vNum vData r -> Versions vNum vData r -> Versions vNum vData r # sconcat :: NonEmpty (Versions vNum vData r) -> Versions vNum vData r # stimes :: Integral b => b -> Versions vNum vData r -> Versions vNum vData r #

data HandshakeException vNumber Source #

Wrapper around initiator and responder errors experienced by tryHandshake.

TODO: should we have Exception instance? It would be handly in prop_socket_send_recgtv.

Constructors

HandshakeProtocolLimit ProtocolLimitFailure
HandshakeProtocolError (HandshakeProtocolError vNumber)

Instances

Instances details

NFData vNumber => NFData (HandshakeException vNumber) Source #

Instance details

Defined in Ouroboros.Network.Protocol.Handshake

Methods

rnf :: HandshakeException vNumber -> () #

(Typeable versionNumber, Show versionNumber) => Exception (HandshakeException versionNumber) Source #

Instance details

Defined in Ouroboros.Network.Protocol.Handshake

Methods

toException :: HandshakeException versionNumber -> SomeException #

fromException :: SomeException -> Maybe (HandshakeException versionNumber) #

displayException :: HandshakeException versionNumber -> String #

backtraceDesired :: HandshakeException versionNumber -> Bool #

Generic (HandshakeException vNumber) Source #

Instance details

Defined in Ouroboros.Network.Protocol.Handshake

Associated Types

type Rep (HandshakeException vNumber)

Instance details

Defined in Ouroboros.Network.Protocol.Handshake

type Rep (HandshakeException vNumber) = D1 ('MetaData "HandshakeException" "Ouroboros.Network.Protocol.Handshake" "ouroboros-network-1.0.0.0-inplace-framework" 'False) (C1 ('MetaCons "HandshakeProtocolLimit" 'PrefixI 'False) (S1 ('MetaSel ('Nothing :: Maybe Symbol) 'NoSourceUnpackedness 'NoSourceStrictness 'DecidedLazy) (Rec0 ProtocolLimitFailure)) :+: C1 ('MetaCons "HandshakeProtocolError" 'PrefixI 'False) (S1 ('MetaSel ('Nothing :: Maybe Symbol) 'NoSourceUnpackedness 'NoSourceStrictness 'DecidedLazy) (Rec0 (HandshakeProtocolError vNumber))))

Methods

from :: HandshakeException vNumber -> Rep (HandshakeException vNumber) x #

to :: Rep (HandshakeException vNumber) x -> HandshakeException vNumber #

Show vNumber => Show (HandshakeException vNumber) Source #

Instance details

Defined in Ouroboros.Network.Protocol.Handshake

Methods

showsPrec :: Int -> HandshakeException vNumber -> ShowS #

show :: HandshakeException vNumber -> String #

showList :: [HandshakeException vNumber] -> ShowS #

type Rep (HandshakeException vNumber) Source #

Instance details

Defined in Ouroboros.Network.Protocol.Handshake

type Rep (HandshakeException vNumber) = D1 ('MetaData "HandshakeException" "Ouroboros.Network.Protocol.Handshake" "ouroboros-network-1.0.0.0-inplace-framework" 'False) (C1 ('MetaCons "HandshakeProtocolLimit" 'PrefixI 'False) (S1 ('MetaSel ('Nothing :: Maybe Symbol) 'NoSourceUnpackedness 'NoSourceStrictness 'DecidedLazy) (Rec0 ProtocolLimitFailure)) :+: C1 ('MetaCons "HandshakeProtocolError" 'PrefixI 'False) (S1 ('MetaSel ('Nothing :: Maybe Symbol) 'NoSourceUnpackedness 'NoSourceStrictness 'DecidedLazy) (Rec0 (HandshakeProtocolError vNumber))))

data HandshakeProtocolError vNumber Source #

Extends handshake error RefuseReason type, by client specific errors.

Constructors

HandshakeError (RefuseReason vNumber)
NotRecognisedVersion vNumber
InvalidServerSelection vNumber Text
QueryNotSupported

Instances

Instances details

NFData vNumber => NFData (HandshakeProtocolError vNumber) Source #

Instance details

Defined in Ouroboros.Network.Protocol.Handshake.Type

Methods

rnf :: HandshakeProtocolError vNumber -> () #

(Typeable vNumber, Show vNumber) => Exception (HandshakeProtocolError vNumber) Source #

Instance details

Defined in Ouroboros.Network.Protocol.Handshake.Type

Methods

toException :: HandshakeProtocolError vNumber -> SomeException #

fromException :: SomeException -> Maybe (HandshakeProtocolError vNumber) #

displayException :: HandshakeProtocolError vNumber -> String #

backtraceDesired :: HandshakeProtocolError vNumber -> Bool #

Generic (HandshakeProtocolError vNumber) Source #

Instance details

Defined in Ouroboros.Network.Protocol.Handshake.Type

Associated Types

type Rep (HandshakeProtocolError vNumber)

Instance details

Defined in Ouroboros.Network.Protocol.Handshake.Type

type Rep (HandshakeProtocolError vNumber) = D1 ('MetaData "HandshakeProtocolError" "Ouroboros.Network.Protocol.Handshake.Type" "ouroboros-network-1.0.0.0-inplace-framework" 'False) ((C1 ('MetaCons "HandshakeError" 'PrefixI 'False) (S1 ('MetaSel ('Nothing :: Maybe Symbol) 'NoSourceUnpackedness 'NoSourceStrictness 'DecidedLazy) (Rec0 (RefuseReason vNumber))) :+: C1 ('MetaCons "NotRecognisedVersion" 'PrefixI 'False) (S1 ('MetaSel ('Nothing :: Maybe Symbol) 'NoSourceUnpackedness 'NoSourceStrictness 'DecidedLazy) (Rec0 vNumber))) :+: (C1 ('MetaCons "InvalidServerSelection" 'PrefixI 'False) (S1 ('MetaSel ('Nothing :: Maybe Symbol) 'NoSourceUnpackedness 'NoSourceStrictness 'DecidedLazy) (Rec0 vNumber) :*: S1 ('MetaSel ('Nothing :: Maybe Symbol) 'NoSourceUnpackedness 'NoSourceStrictness 'DecidedLazy) (Rec0 Text)) :+: C1 ('MetaCons "QueryNotSupported" 'PrefixI 'False) (U1 :: Type -> Type)))

Methods

from :: HandshakeProtocolError vNumber -> Rep (HandshakeProtocolError vNumber) x #

to :: Rep (HandshakeProtocolError vNumber) x -> HandshakeProtocolError vNumber #

Show vNumber => Show (HandshakeProtocolError vNumber) Source #

Instance details

Defined in Ouroboros.Network.Protocol.Handshake.Type

Methods

showsPrec :: Int -> HandshakeProtocolError vNumber -> ShowS #

show :: HandshakeProtocolError vNumber -> String #

showList :: [HandshakeProtocolError vNumber] -> ShowS #

Eq vNumber => Eq (HandshakeProtocolError vNumber) Source #

Instance details

Defined in Ouroboros.Network.Protocol.Handshake.Type

Methods

(==) :: HandshakeProtocolError vNumber -> HandshakeProtocolError vNumber -> Bool #

(/=) :: HandshakeProtocolError vNumber -> HandshakeProtocolError vNumber -> Bool #

type Rep (HandshakeProtocolError vNumber) Source #

Instance details

Defined in Ouroboros.Network.Protocol.Handshake.Type

type Rep (HandshakeProtocolError vNumber) = D1 ('MetaData "HandshakeProtocolError" "Ouroboros.Network.Protocol.Handshake.Type" "ouroboros-network-1.0.0.0-inplace-framework" 'False) ((C1 ('MetaCons "HandshakeError" 'PrefixI 'False) (S1 ('MetaSel ('Nothing :: Maybe Symbol) 'NoSourceUnpackedness 'NoSourceStrictness 'DecidedLazy) (Rec0 (RefuseReason vNumber))) :+: C1 ('MetaCons "NotRecognisedVersion" 'PrefixI 'False) (S1 ('MetaSel ('Nothing :: Maybe Symbol) 'NoSourceUnpackedness 'NoSourceStrictness 'DecidedLazy) (Rec0 vNumber))) :+: (C1 ('MetaCons "InvalidServerSelection" 'PrefixI 'False) (S1 ('MetaSel ('Nothing :: Maybe Symbol) 'NoSourceUnpackedness 'NoSourceStrictness 'DecidedLazy) (Rec0 vNumber) :*: S1 ('MetaSel ('Nothing :: Maybe Symbol) 'NoSourceUnpackedness 'NoSourceStrictness 'DecidedLazy) (Rec0 Text)) :+: C1 ('MetaCons "QueryNotSupported" 'PrefixI 'False) (U1 :: Type -> Type)))

data HandshakeResult r vNumber vData Source #

The result of a handshake.

Constructors

HandshakeNegotiationResult r vNumber vData
HandshakeQueryResult (Map vNumber (Either Text vData))

Instances

Instances details

(NFData vNumber, NFData vData) => NFData (HandshakeResult r vNumber vData) Source #
Instance details Defined in Ouroboros.Network.Protocol.Handshake.Type Methods rnf :: HandshakeResult r vNumber vData -> () #

data RefuseReason vNumber Source #

Reasons by which a server can refuse proposed version.

Constructors

VersionMismatch [vNumber] [Int]	All of the prosed versions where not known to the server. Since the server sends all versions that it can knows about, some of them we might not be able to decode, so we include raw tags `[Int]`.
HandshakeDecodeError vNumber Text	The server failed to decode version parameters.
Refused vNumber Text	The server refused to run the proposed version parameters

Instances

Instances details

NFData vNumber => NFData (RefuseReason vNumber) Source #

Instance details

Defined in Ouroboros.Network.Protocol.Handshake.Type

Methods

rnf :: RefuseReason vNumber -> () #

(Typeable vNumber, Show vNumber) => Exception (RefuseReason vNumber) Source #

Instance details

Defined in Ouroboros.Network.Protocol.Handshake.Type

Methods

toException :: RefuseReason vNumber -> SomeException #

fromException :: SomeException -> Maybe (RefuseReason vNumber) #

displayException :: RefuseReason vNumber -> String #

backtraceDesired :: RefuseReason vNumber -> Bool #

Generic (RefuseReason vNumber) Source #

Instance details

Defined in Ouroboros.Network.Protocol.Handshake.Type

Associated Types

type Rep (RefuseReason vNumber)

Instance details

Defined in Ouroboros.Network.Protocol.Handshake.Type

type Rep (RefuseReason vNumber) = D1 ('MetaData "RefuseReason" "Ouroboros.Network.Protocol.Handshake.Type" "ouroboros-network-1.0.0.0-inplace-framework" 'False) (C1 ('MetaCons "VersionMismatch" 'PrefixI 'False) (S1 ('MetaSel ('Nothing :: Maybe Symbol) 'NoSourceUnpackedness 'NoSourceStrictness 'DecidedLazy) (Rec0 [vNumber]) :*: S1 ('MetaSel ('Nothing :: Maybe Symbol) 'NoSourceUnpackedness 'NoSourceStrictness 'DecidedLazy) (Rec0 [Int])) :+: (C1 ('MetaCons "HandshakeDecodeError" 'PrefixI 'False) (S1 ('MetaSel ('Nothing :: Maybe Symbol) 'NoSourceUnpackedness 'NoSourceStrictness 'DecidedLazy) (Rec0 vNumber) :*: S1 ('MetaSel ('Nothing :: Maybe Symbol) 'NoSourceUnpackedness 'NoSourceStrictness 'DecidedLazy) (Rec0 Text)) :+: C1 ('MetaCons "Refused" 'PrefixI 'False) (S1 ('MetaSel ('Nothing :: Maybe Symbol) 'NoSourceUnpackedness 'NoSourceStrictness 'DecidedLazy) (Rec0 vNumber) :*: S1 ('MetaSel ('Nothing :: Maybe Symbol) 'NoSourceUnpackedness 'NoSourceStrictness 'DecidedLazy) (Rec0 Text))))

Methods

from :: RefuseReason vNumber -> Rep (RefuseReason vNumber) x #

to :: Rep (RefuseReason vNumber) x -> RefuseReason vNumber #

Show vNumber => Show (RefuseReason vNumber) Source #

Instance details

Defined in Ouroboros.Network.Protocol.Handshake.Type

Methods

showsPrec :: Int -> RefuseReason vNumber -> ShowS #

show :: RefuseReason vNumber -> String #

showList :: [RefuseReason vNumber] -> ShowS #

Eq vNumber => Eq (RefuseReason vNumber) Source #

Instance details

Defined in Ouroboros.Network.Protocol.Handshake.Type

Methods

(==) :: RefuseReason vNumber -> RefuseReason vNumber -> Bool #

(/=) :: RefuseReason vNumber -> RefuseReason vNumber -> Bool #

type Rep (RefuseReason vNumber) Source #

Instance details

Defined in Ouroboros.Network.Protocol.Handshake.Type

type Rep (RefuseReason vNumber) = D1 ('MetaData "RefuseReason" "Ouroboros.Network.Protocol.Handshake.Type" "ouroboros-network-1.0.0.0-inplace-framework" 'False) (C1 ('MetaCons "VersionMismatch" 'PrefixI 'False) (S1 ('MetaSel ('Nothing :: Maybe Symbol) 'NoSourceUnpackedness 'NoSourceStrictness 'DecidedLazy) (Rec0 [vNumber]) :*: S1 ('MetaSel ('Nothing :: Maybe Symbol) 'NoSourceUnpackedness 'NoSourceStrictness 'DecidedLazy) (Rec0 [Int])) :+: (C1 ('MetaCons "HandshakeDecodeError" 'PrefixI 'False) (S1 ('MetaSel ('Nothing :: Maybe Symbol) 'NoSourceUnpackedness 'NoSourceStrictness 'DecidedLazy) (Rec0 vNumber) :*: S1 ('MetaSel ('Nothing :: Maybe Symbol) 'NoSourceUnpackedness 'NoSourceStrictness 'DecidedLazy) (Rec0 Text)) :+: C1 ('MetaCons "Refused" 'PrefixI 'False) (S1 ('MetaSel ('Nothing :: Maybe Symbol) 'NoSourceUnpackedness 'NoSourceStrictness 'DecidedLazy) (Rec0 vNumber) :*: S1 ('MetaSel ('Nothing :: Maybe Symbol) 'NoSourceUnpackedness 'NoSourceStrictness 'DecidedLazy) (Rec0 Text))))

data Accept vData #

Constructors

Accept vData
Refuse !Text

Instances

Instances details

Show vData => Show (Accept vData)
Instance details Defined in Ouroboros.Network.Handshake.Acceptable Methods showsPrec :: Int -> Accept vData -> ShowS # show :: Accept vData -> String # showList :: [Accept vData] -> ShowS #
Eq vData => Eq (Accept vData)
Instance details Defined in Ouroboros.Network.Handshake.Acceptable Methods (==) :: Accept vData -> Accept vData -> Bool # (/=) :: Accept vData -> Accept vData -> Bool #

handshake_QUERY_SHUTDOWN_DELAY :: DiffTime Source #

A 20s delay after query result was send back, before we close the connection. After that delay we close the connection.

Re-exports

module Ouroboros.Network.Protocol.Handshake.Type

module Ouroboros.Network.Protocol.Handshake.Codec

module Ouroboros.Network.Protocol.Handshake.Version

class Acceptable v where #

Methods

acceptableVersion :: v -> v -> Accept v #

Instances

Instances details

Acceptable DataFlowProtocolData Source #
Instance details Defined in Ouroboros.Network.Protocol.Handshake.Unversioned Methods acceptableVersion :: DataFlowProtocolData -> DataFlowProtocolData -> Accept DataFlowProtocolData #
Acceptable UnversionedProtocolData Source #
Instance details Defined in Ouroboros.Network.Protocol.Handshake.Unversioned Methods acceptableVersion :: UnversionedProtocolData -> UnversionedProtocolData -> Accept UnversionedProtocolData #

class Queryable v where #

Methods

queryVersion :: v -> Bool #

Instances

Instances details

Queryable DataFlowProtocolData Source #
Instance details Defined in Ouroboros.Network.Protocol.Handshake.Unversioned Methods queryVersion :: DataFlowProtocolData -> Bool #
Queryable UnversionedProtocolData Source #
Instance details Defined in Ouroboros.Network.Protocol.Handshake.Unversioned Methods queryVersion :: UnversionedProtocolData -> Bool #