1
1
{-# LANGUAGE DataKinds #-}
2
- {-# LANGUAGE OverloadedStrings #-}
3
2
{-# LANGUAGE NamedFieldPuns #-}
4
3
5
4
module Trace.Forward.Run.DataPoint.Acceptor
@@ -8,21 +7,21 @@ module Trace.Forward.Run.DataPoint.Acceptor
8
7
) where
9
8
10
9
import qualified Codec.Serialise as CBOR
10
+ import Control.Concurrent.STM.TMVar (putTMVar )
11
+ import Control.Concurrent.STM.TVar (modifyTVar' , readTVar , readTVarIO )
11
12
import Control.Exception (finally )
12
13
import Control.Monad (unless )
13
14
import Control.Monad.Extra (ifM )
14
15
import Control.Monad.STM (atomically , check )
15
- import Control.Concurrent.STM.TVar (modifyTVar' , readTVar , readTVarIO )
16
- import Control.Concurrent.STM.TMVar (putTMVar )
17
16
import qualified Data.ByteString.Lazy as LBS
18
17
import Data.Void (Void )
19
- import Ouroboros.Network.Mux (MuxMode (.. ), MuxPeer (.. ), RunMiniProtocol (.. ))
20
18
import Ouroboros.Network.Driver.Simple (runPeer )
19
+ import Ouroboros.Network.Mux (MuxMode (.. ), MuxPeer (.. ), RunMiniProtocol (.. ))
21
20
21
+ import Trace.Forward.Configuration.DataPoint (AcceptorConfiguration (.. ))
22
22
import qualified Trace.Forward.Protocol.DataPoint.Acceptor as Acceptor
23
23
import qualified Trace.Forward.Protocol.DataPoint.Codec as Acceptor
24
24
import Trace.Forward.Protocol.DataPoint.Type (DataPointName )
25
- import Trace.Forward.Configuration.DataPoint (AcceptorConfiguration (.. ))
26
25
import Trace.Forward.Utils.DataPoint (DataPointRequestor (.. ))
27
26
28
27
acceptDataPointsInit
@@ -46,7 +45,7 @@ runPeerWithRequestor
46
45
-> IO DataPointRequestor
47
46
-> IO ()
48
47
-> MuxPeer LBS. ByteString IO ()
49
- runPeerWithRequestor config mkDPRequestor peerErrorHandler =
48
+ runPeerWithRequestor config mkDPRequestor peerErrorHandler =
50
49
MuxPeerRaw $ \ channel -> do
51
50
dpRequestor <- mkDPRequestor
52
51
runPeer
0 commit comments