suzanne.soy/racket
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

[Distributed Places] fix failing drdr tests

Browse Source
This commit is contained in:
Kevin Tew 2012-07-31 13:56:38 -06:00
parent 6b48d34867
commit 04839b39f8
6 changed files with 10 additions and 9 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
collects/racket/place/distributed.rkt
View File

@ -1409,7 +1409,7 @@
#:thunk [thunk #f]) #:thunk [thunk #f])
(define-values (node pl) (define-values (node pl)
(spawn-node-supervise-place-at/exec host (spawn-node-supervise-place-at/exec host
(mk-place-creation-addr (->writeable-module-path place-path) place-func thunk) (mk-place-creation-addr (->writeable-module-path place-path) place-func #f thunk)
#:listen-port listen-port #:listen-port listen-port
#:initial-message initial-message #:initial-message initial-message
#:racket-path racketpath #:racket-path racketpath
@ -1427,7 +1427,7 @@
#:named [named #f] #:named [named #f]
#:thunk [thunk #f]) #:thunk [thunk #f])
(spawn-node-supervise-place-at/exec host (spawn-node-supervise-place-at/exec host
(mk-place-creation-addr (->writeable-module-path place-path) place-func thunk) (mk-place-creation-addr (->writeable-module-path place-path) place-func #f thunk)
#:listen-port listen-port #:listen-port listen-port
#:initial-message initial-message #:initial-message initial-message
#:racket-path racketpath #:racket-path racketpath

2
collects/racket/place/distributed/examples/multiple/master.rkt
View File

@ -25,7 +25,7 @@
(define (main) (define (main)
(define bank-node (spawn-node-with--place-at "localhost" #:listen-port 6344 bank-path 'make-bank)) (define bank-node (spawn-node-with-place-at "localhost" #:listen-port 6344 bank-path 'make-bank))
(define bank-place (send bank-node get-first-place)) (define bank-place (send bank-node get-first-place))
(message-router (message-router
(spawn-place-worker-at 6341 "ONE") (spawn-place-worker-at 6341 "ONE")

2
collects/racket/place/distributed/examples/restart/master.rkt
View File

@ -15,6 +15,6 @@
(define (main) (define (main)
(message-router (message-router
(spawn-node-with-place-thunk-at "localhost" #:listen-port 6345 (quote-module-name) 'wait-place-thunk #:restart-on-exit #t) (spawn-node-with-place-at "localhost" #:listen-port 6345 (quote-module-name) 'wait-place-thunk #:thunk #t #:restart-on-exit #t)
(after-seconds 50 (after-seconds 50
(exit 0)))) (exit 0))))

4
collects/racket/place/distributed/examples/restart/restarter.rkt
View File

@ -15,5 +15,5 @@
(define (main) (define (main)
(message-router (message-router
(spawn-node-with-place-thunk-at "localhost" #:listen-port 6345 (quote-module-name) 'wait-place-thunk (spawn-node-with-place-at "localhost" #:listen-port 6345 (quote-module-name) 'wait-place-thunk
#:restart-on-exit (restart-every 5 #:retry 3)))) #:thunk #t #:restart-on-exit (restart-every 5 #:retry 3))))

4
collects/tests/racket/place/distributed/distributed.rkt
View File

@ -25,8 +25,8 @@
ok?))) ok?)))
(define remote-node (spawn-remote-racket-node "localhost" #:listen-port 6344)) (define remote-node (spawn-remote-racket-node "localhost" #:listen-port 6344))
(define tuple-place (supervise-named-dynamic-place-at remote-node 'tuple-server tuple-path 'make-tuple-server)) (define tuple-place (supervise-place-at remote-node #:named 'tuple-server tuple-path 'make-tuple-server))
(define bank-place (supervise-dynamic-place-at remote-node bank-path 'make-bank)) (define bank-place (supervise-place-at remote-node bank-path 'make-bank))
(message-router (message-router
remote-node remote-node

3
collects/tests/racket/place/distributed/restarter.rkt
View File

@ -15,11 +15,12 @@
(define (main) (define (main)
(message-router (message-router
(spawn-node-with-place-thunk-at (spawn-node-with-place-at
"localhost" "localhost"
#:listen-port 6345 #:listen-port 6345
(quote-module-name) (quote-module-name)
'wait-place-thunk 'wait-place-thunk
#:thunk #t
#:restart-on-exit (restart-every 5 #:restart-on-exit (restart-every 5
#:retry 3 #:retry 3
#:on-final-fail (lambda () #:on-final-fail (lambda ()