File tree Expand file tree Collapse file tree 1 file changed +5
-3
lines changed
distributed-process-tests/src/Control/Distributed/Process/Tests Expand file tree Collapse file tree 1 file changed +5
-3
lines changed Original file line number Diff line number Diff line change @@ -305,14 +305,16 @@ testSpawnRace TestTransport{..} rtable = do
305
305
wrapEP e =
306
306
e { NT. connect = \ x y z -> do
307
307
healthy <- newIORef True
308
- fmap (fmap $ wrapConnection healthy) $ NT. connect e x y z
308
+ fmap (fmap $ wrapConnection healthy e x ) $ NT. connect e x y z
309
309
}
310
310
311
- wrapConnection :: IORef Bool -> NT. Connection -> NT. Connection
312
- wrapConnection healthy (NT. Connection s closeC) =
311
+ wrapConnection :: IORef Bool -> NT. EndPoint -> NT. EndPointAddress
312
+ -> NT. Connection -> NT. Connection
313
+ wrapConnection healthy e remoteAddr (NT. Connection s closeC) =
313
314
flip NT. Connection closeC $ \ msg -> do
314
315
when (msg == messageToPayload (createMessage () )) $ do
315
316
writeIORef healthy False
317
+ testBreakConnection (NT. address e) remoteAddr
316
318
isHealthy <- readIORef healthy
317
319
if isHealthy then s msg
318
320
else return $ Left $ NT. TransportError NT. SendFailed " "
You can’t perform that action at this time.
0 commit comments