@@ -1421,6 +1421,25 @@ testUnsafeNSend TestTransport{..} = do
1421
1421
1422
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
+
1424
1443
testUnsafeSendChan :: TestTransport -> Assertion
1425
1444
testUnsafeSendChan TestTransport {.. } = do
1426
1445
serverAddr <- newEmptyMVar
@@ -1561,6 +1580,7 @@ tests testtrans = return [
1561
1580
, testCase " TestUnsafeSend" (testUnsafeSend testtrans)
1562
1581
, testCase " TestUnsafeUSend" (testUnsafeUSend testtrans)
1563
1582
, testCase " TestUnsafeNSend" (testUnsafeNSend testtrans)
1583
+ , testCase " TestUnsafeNSendRemote" (testUnsafeNSendRemote testtrans)
1564
1584
, testCase " TestUnsafeSendChan" (testUnsafeSendChan testtrans)
1565
1585
-- usend
1566
1586
, testCase " USend" (testUSend usend testtrans 50 )
0 commit comments