git.iko.soy/distributed-process
on master help sign in
Implement a test for unsafeNSendRemote.
c03acb8Facundo Domínguez
distributed-process-tests/src/Control/Distributed/Process/Tests/CH.hs+20
compare with master
unifiedsplit
@@ -1421,6 +1421,25 @@ testUnsafeNSend TestTransport{..} = do
1421
1421
1422 takeMVar clientDone
1422 takeMVar clientDone
1423
1423
1424+testUnsafeNSendRemote :: TestTransport -> Assertion
1425+testUnsafeNSendRemote TestTransport{..} = do
1426+ clientDone <- newEmptyMVar
1427+
1428+ localNode1 <- newLocalNode testTransport initRemoteTable
1429+ localNode2 <- newLocalNode testTransport initRemoteTable
1430+
1431+ _ <- forkProcess localNode1 $ do
1432+ getSelfPid >>= register "foobar"
1433+ liftIO $ putMVar clientDone ()
1434+ () <- expect
1435+ liftIO $ putMVar clientDone ()
1436+
1437+ takeMVar clientDone
1438+ void $ runProcess localNode2 $ do
1439+ unsafeNSendRemote (localNodeId localNode1) "foobar" ()
1440+
1441+ takeMVar clientDone
1442+
1424testUnsafeSendChan :: TestTransport -> Assertion
1443testUnsafeSendChan :: TestTransport -> Assertion
1425testUnsafeSendChan TestTransport{..} = do
1444testUnsafeSendChan TestTransport{..} = do
1426 serverAddr <- newEmptyMVar
1445 serverAddr <- newEmptyMVar
@@ -1561,6 +1580,7 @@ tests testtrans = return [
1561 , testCase "TestUnsafeSend" (testUnsafeSend testtrans)
1580 , testCase "TestUnsafeSend" (testUnsafeSend testtrans)
1562 , testCase "TestUnsafeUSend" (testUnsafeUSend testtrans)
1581 , testCase "TestUnsafeUSend" (testUnsafeUSend testtrans)
1563 , testCase "TestUnsafeNSend" (testUnsafeNSend testtrans)
1582 , testCase "TestUnsafeNSend" (testUnsafeNSend testtrans)
1583+ , testCase "TestUnsafeNSendRemote" (testUnsafeNSendRemote testtrans)
1564 , testCase "TestUnsafeSendChan" (testUnsafeSendChan testtrans)
1584 , testCase "TestUnsafeSendChan" (testUnsafeSendChan testtrans)
1565 -- usend
1585 -- usend
1566 , testCase "USend" (testUSend usend testtrans 50)
1586 , testCase "USend" (testUSend usend testtrans 50)