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

modules.rpc-server additions

db4
Sam Anklesaria 2009-04-26 20:34:31 -05:00
parent e6e32f052d
commit 25002fbff0
3 changed files with 20 additions and 6 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

1
extra/modules/remote-loading/remote-loading.factor
View File

@ -1,3 +1,4 @@
USING: modules.rpc-server vocabs ; USING: modules.rpc-server vocabs ;
IN: modules.remote-loading mem-service IN: modules.remote-loading mem-service
: get-vocab ( vocabstr -- vocab ) vocab ; : get-vocab ( vocabstr -- vocab ) vocab ;

18
extra/modules/rpc-server/rpc-server.factor
View File

@ -1,18 +1,19 @@
USING: accessors assocs continuations effects io USING: accessors assocs continuations effects io
io.encodings.binary io.servers.connection kernel io.encodings.binary io.servers.connection kernel
memoize namespaces parser sets sequences serialize threads vocabs memoize namespaces parser sets sequences serialize
vocabs.parser words tools.walker ; threads vocabs vocabs.parser words ;
IN: modules.rpc-server IN: modules.rpc-server
SYMBOL: serving-vocabs V{ } clone serving-vocabs set-global SYMBOL: serving-vocabs V{ } clone serving-vocabs set-global
: do-rpc ( args word -- results ) [ execute ] curry with-datastack ; inline : do-rpc ( args word -- bytes )
[ execute ] curry with-datastack object>bytes ; inline
MEMO: mem-do-rpc ( args word -- results ) do-rpc ; inline MEMO: mem-do-rpc ( args word -- bytes ) do-rpc ; inline
: process ( vocabspec -- ) vocab-words [ deserialize ] dip deserialize : process ( vocabspec -- ) vocab-words [ deserialize ] dip deserialize
swap at "executer" get execute( args word -- results ) serialize flush ; swap at "executer" get execute( args word -- bytes ) write flush ;
: (serve) ( -- ) deserialize dup serving-vocabs get-global index : (serve) ( -- ) deserialize dup serving-vocabs get-global index
[ process ] [ drop ] if ; [ process ] [ drop ] if ;
@ -29,3 +30,10 @@ MEMO: mem-do-rpc ( args word -- results ) do-rpc ; inline
SYNTAX: service \ do-rpc "executer" set (service) ; SYNTAX: service \ do-rpc "executer" set (service) ;
SYNTAX: mem-service \ mem-do-rpc "executer" set (service) ; SYNTAX: mem-service \ mem-do-rpc "executer" set (service) ;
: change-global ( var quot -- ) [ [ get-global ] keep ] dip dip set-global ; inline
load-vocab-hook [
[ dup words>> values
\ mem-do-rpc "memoize" word-prop [ delete-at ] curry each ]
append ] change-global

5
extra/modules/uploads/uploads.factor Normal file
View File

@ -0,0 +1,5 @@
USING: assocs modules.rpc-server vocabs
modules.remote-loading words ;
IN: modules.uploads service
: upload-vocab ( word binary -- ) \ get-vocab "memoize" word-prop set-at ;