steve
/
factor
1
0
Fork 0
Code Issues Pull Requests Releases Wiki Activity

concurrency.distributed-tests: add test for send-/reply-synchronous

factor-shell
Alexander Iljin 2018-01-03 03:44:12 +03:00 committed by John Benediktsson
parent a25bffeb01
commit 620ab30ed7
1 changed files with 15 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

16
basis/concurrency/distributed/distributed-tests.factor
View File

@ -1,4 +1,4 @@
USING: arrays calendar concurrency.distributed USING: accessors arrays calendar concurrency.distributed
concurrency.messaging io.sockets kernel math namespaces concurrency.messaging io.sockets kernel math namespaces
sequences threads tools.test ; sequences threads tools.test ;
FROM: concurrency.messaging => receive send ; FROM: concurrency.messaging => receive send ;
@ -6,6 +6,7 @@ IN: concurrency.distributed.tests
CONSTANT: test-ip "127.0.0.1" CONSTANT: test-ip "127.0.0.1"
CONSTANT: test-port 57234 CONSTANT: test-port 57234
CONSTANT: test-port2 57235
[ 8 ] [ [ 8 ] [
local-node get local-node get
@ -24,3 +25,16 @@ CONSTANT: test-port 57234
] with-variable ] with-variable
] unit-test ] unit-test
[ 15 ] [
local-node get
test-ip test-port2 <inet4> start-node
local-node get swap local-node set-global
local-node [
[
receive dup data>> 3 * swap reply-synchronous
"thread-s" unregister-remote-thread
] "Thread S" spawn "thread-s" register-remote-thread
5 test-ip test-port2 <inet4> "thread-s" <remote-thread> send-synchronous
stop-node
] with-variable
] unit-test