1 IN: concurrency.distributed.tests
2 USING: tools.test concurrency.distributed kernel io.files
3 arrays io.sockets system combinators threads math sequences
4 concurrency.messaging continuations accessors prettyprint ;
6 : test-node ( -- addrspec )
8 { [ os unix? ] [ "distributed-concurrency-test" temp-file <local> ] }
9 { [ os windows? ] [ "127.0.0.1" 1238 <inet4> ] }
12 [ ] [ [ "distributed-concurrency-test" temp-file delete-file ] ignore-errors ] unit-test
14 [ ] [ test-node dup (start-node) ] unit-test
18 receive first2 >r 3 + r> send
19 "thread-a" unregister-process
21 "thread-a" swap register-process
26 "thread-a" test-node <remote-process> send
31 [ ] [ test-node stop-node ] unit-test