46 lines
1.2 KiB
Factor
Executable File
46 lines
1.2 KiB
Factor
Executable File
! Copyright (C) 2005 Chris Double. All Rights Reserved.
|
|
! See http://factorcode.org/license.txt for BSD license.
|
|
USING: serialize sequences concurrency.messaging threads io
|
|
io.server qualified arrays namespaces kernel io.encodings.binary
|
|
accessors ;
|
|
FROM: io.sockets => host-name <inet> with-client ;
|
|
IN: concurrency.distributed
|
|
|
|
SYMBOL: local-node
|
|
|
|
: handle-node-client ( -- )
|
|
deserialize
|
|
[ first2 get-process send ]
|
|
[ stop-server ] if* ;
|
|
|
|
: (start-node) ( addrspecs addrspec -- )
|
|
local-node set-global
|
|
[
|
|
"concurrency.distributed"
|
|
binary
|
|
[ handle-node-client ] with-server
|
|
] curry "Distributed concurrency server" spawn drop ;
|
|
|
|
: start-node ( port -- )
|
|
[ internet-server ]
|
|
[ host-name swap <inet> ] bi
|
|
(start-node) ;
|
|
|
|
TUPLE: remote-process id node ;
|
|
|
|
C: <remote-process> remote-process
|
|
|
|
: send-remote-message ( message node -- )
|
|
binary [ serialize ] with-client ;
|
|
|
|
M: remote-process send ( message thread -- )
|
|
[ id>> 2array ] [ node>> ] bi
|
|
send-remote-message ;
|
|
|
|
M: thread (serialize) ( obj -- )
|
|
thread-id local-node get-global <remote-process>
|
|
(serialize) ;
|
|
|
|
: stop-node ( node -- )
|
|
f swap send-remote-message ;
|