Skip to content

Commit

Permalink
Stuff
Browse files Browse the repository at this point in the history
  • Loading branch information
newhoggy committed Nov 27, 2020
1 parent 0fbca7a commit 776d1bd
Showing 1 changed file with 7 additions and 12 deletions.
19 changes: 7 additions & 12 deletions ouroboros-network/src/Ouroboros/Network/Diffusion.hs
Original file line number Diff line number Diff line change
Expand Up @@ -33,12 +33,10 @@ import Network.Mux (MuxTrace (..), WithMuxBearer (..))
import Network.Socket (AddrInfo, SockAddr)
import qualified Network.Socket as Socket

import Ouroboros.Network.Snocket ( FileDescriptor
, LocalAddress
import Ouroboros.Network.Snocket ( LocalAddress
, LocalSnocket
, LocalSocket (..)
, SocketSnocket
, localSocketFileDescriptor
)
import qualified Ouroboros.Network.Snocket as Snocket

Expand Down Expand Up @@ -75,9 +73,9 @@ data DiffusionInitializationTracer
| UsingSystemdSocket !FilePath
| CreateSystemdSocketForSnocketPath !FilePath
| CreatedLocalSocket !FilePath
| ConfiguringLocalSocket !FilePath !FileDescriptor
| ListeningLocalSocket !FilePath !FileDescriptor
| LocalSocketUp !FilePath !FileDescriptor
| ConfiguringLocalSocket !FilePath
| ListeningLocalSocket !FilePath
| LocalSocketUp !FilePath
| CreatingServerSocket !SockAddr
| ConfiguringServerSocket !SockAddr
| ListeningServerSocket !SockAddr
Expand Down Expand Up @@ -365,18 +363,15 @@ runDataDiffusion tracers
-- If a socket was provided it should be ready to accept
Left _ -> pure ()
Right path -> do
traceWith dtDiffusionInitializationTracer . ConfiguringLocalSocket path
=<< localSocketFileDescriptor sd
traceWith dtDiffusionInitializationTracer $ ConfiguringLocalSocket path

Snocket.bind sn sd $ Snocket.localAddressFromPath path

traceWith dtDiffusionInitializationTracer . ListeningLocalSocket path
=<< localSocketFileDescriptor sd
traceWith dtDiffusionInitializationTracer $ ListeningLocalSocket path

Snocket.listen sn sd

traceWith dtDiffusionInitializationTracer . LocalSocketUp path
=<< localSocketFileDescriptor sd
traceWith dtDiffusionInitializationTracer $ LocalSocketUp path

traceWith dtDiffusionInitializationTracer . RunLocalServer =<< Snocket.getLocalAddr sn sd

Expand Down

0 comments on commit 776d1bd

Please sign in to comment.