git.iko.soy/distributed-process
on master help sign in
Added a NOOP closeTransport to the MVar transport. It passes all demos too
62eb0b1Ryan Newton
examples/DemoTransport.hs+3−3
compare with master
unifiedsplit
@@ -136,10 +136,10 @@ logServer name targetEnd = forever $ do
136runWAllTranports :: (IO Transport -> IO ()) -> Int -> IO ()
136runWAllTranports :: (IO Transport -> IO ()) -> Int -> IO ()
137runWAllTranports demo offset = do
137runWAllTranports demo offset = do
138 putStrLn "------------------------------------------------------------"
138 putStrLn "------------------------------------------------------------"
139−-- putStrLn " MVAR transport:"
139+ putStrLn " MVAR transport:"
140−-- demo Network.Transport.MVar.mkTransport
140+ demo Network.Transport.MVar.mkTransport
141− putStrLn "\n TCP transport:"
142
141
142+ putStrLn "\n TCP transport:"
143 cntr <- newIORef 0
143 cntr <- newIORef 0
144 demo$ do cnt <- readIORef cntr
144 demo$ do cnt <- readIORef cntr
145 writeIORef cntr (cnt+1)
145 writeIORef cntr (cnt+1)
network-transport/src/Network/Transport/MVar.hs+1
@@ -32,6 +32,7 @@ mkTransport = do
32 case BS.readInt bs of
32 case BS.readInt bs of
33 Nothing -> error "dummyBackend.deserializeSourceEnd: cannot parse"
33 Nothing -> error "dummyBackend.deserializeSourceEnd: cannot parse"
34 Just (n,_) -> Just . mkSourceAddr channels $ n
34 Just (n,_) -> Just . mkSourceAddr channels $ n
35+ , closeTransport = return ()
35 }
36 }
36 where
37 where
37 mkSourceAddr :: Chans -> Int -> SourceAddr
38 mkSourceAddr :: Chans -> Int -> SourceAddr