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

[Distributed Places] use racket -lm to launch new racket nodes instead of -tm

Browse Source
This commit is contained in:
Kevin Tew 2012-10-09 14:29:44 -06:00
parent 444aaf6eb7
commit 40ca07ee7c
2 changed files with 11 additions and 9 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

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

@ -26,7 +26,6 @@
(provide ssh-bin-path (provide ssh-bin-path
racket-path racket-path
distributed-launch-path
DEFAULT-ROUTER-PORT DEFAULT-ROUTER-PORT
@ -1403,7 +1402,7 @@
#:initial-message [initial-message #f] #:initial-message [initial-message #f]
#:racket-path [racketpath (racket-path)] #:racket-path [racketpath (racket-path)]
#:ssh-bin-path [sshpath (ssh-bin-path)] #:ssh-bin-path [sshpath (ssh-bin-path)]
#:distributed-launch-path [distributedlaunchpath (->writeable-module-path distributed-launch-path)] #:distributed-launch-path [distributedlaunchpath #f]
#:restart-on-exit [restart-on-exit #f] #:restart-on-exit [restart-on-exit #f]
#:named [named #f] #:named [named #f]
#:thunk [thunk #f]) #:thunk [thunk #f])
@ -1422,7 +1421,7 @@
#:initial-message [initial-message #f] #:initial-message [initial-message #f]
#:racket-path [racketpath (racket-path)] #:racket-path [racketpath (racket-path)]
#:ssh-bin-path [sshpath (ssh-bin-path)] #:ssh-bin-path [sshpath (ssh-bin-path)]
#:distributed-launch-path [distributedlaunchpath (->writeable-module-path distributed-launch-path)] #:distributed-launch-path [distributedlaunchpath #f]
#:restart-on-exit [restart-on-exit #f] #:restart-on-exit [restart-on-exit #f]
#:named [named #f] #:named [named #f]
#:thunk [thunk #f]) #:thunk [thunk #f])
@ -1439,7 +1438,7 @@
#:initial-message [initial-message #f] #:initial-message [initial-message #f]
#:racket-path [racketpath (racket-path)] #:racket-path [racketpath (racket-path)]
#:ssh-bin-path [sshpath (ssh-bin-path)] #:ssh-bin-path [sshpath (ssh-bin-path)]
#:distributed-launch-path [distributedlaunchpath (->writeable-module-path distributed-launch-path)] #:distributed-launch-path [distributedlaunchpath #f]
#:restart-on-exit [restart-on-exit #f]) #:restart-on-exit [restart-on-exit #f])
(define node (spawn-remote-racket-node host (define node (spawn-remote-racket-node host
#:listen-port listen-port #:listen-port listen-port
@ -1467,18 +1466,20 @@
(define (spawn-remote-racket-node host #:listen-port [listen-port DEFAULT-ROUTER-PORT] (define (spawn-remote-racket-node host #:listen-port [listen-port DEFAULT-ROUTER-PORT]
#:racket-path [racketpath (racket-path)] #:racket-path [racketpath (racket-path)]
#:ssh-bin-path [sshpath (ssh-bin-path)] #:ssh-bin-path [sshpath (ssh-bin-path)]
#:distributed-launch-path [distributedlaunchpath (->writeable-module-path distributed-launch-path)] #:distributed-launch-path [distributedlaunchpath #f]
#:use-current-ports [use-current-ports #f]) #:use-current-ports [use-current-ports #f])
(new remote-node% (new remote-node%
[host-name host] [host-name host]
[listen-port listen-port] [listen-port listen-port]
[cmdline-list (list sshpath host racketpath "-tm" distributedlaunchpath "spawn" (->string listen-port))] [cmdline-list (if distributedlaunchpath
(list sshpath host racketpath "-tm" distributedlaunchpath "spawn" (->string listen-port))
(list sshpath host racketpath "-lm racket/place/distributed/launch spawn" (->string listen-port)))]
[use-current-ports use-current-ports])) [use-current-ports use-current-ports]))
(define (create-place-node host #:listen-port [listen-port DEFAULT-ROUTER-PORT] (define (create-place-node host #:listen-port [listen-port DEFAULT-ROUTER-PORT]
#:racket-path [racketpath (racket-path)] #:racket-path [racketpath (racket-path)]
#:ssh-bin-path [sshpath (ssh-bin-path)] #:ssh-bin-path [sshpath (ssh-bin-path)]
#:distributed-launch-path [distributedlaunchpath (->writeable-module-path distributed-launch-path)] #:distributed-launch-path [distributedlaunchpath #f]
#:use-current-ports [use-current-ports #t]) #:use-current-ports [use-current-ports #t])
(spawn-remote-racket-node host (spawn-remote-racket-node host
#:listen-port listen-port #:listen-port listen-port
@ -1508,6 +1509,7 @@
(define-syntax-rule (after-seconds _seconds _body ...) (define-syntax-rule (after-seconds _seconds _body ...)
(new after-seconds% [seconds _seconds] [thunk (lambda () _body ...)])) (new after-seconds% [seconds _seconds] [thunk (lambda () _body ...)]))
;; -> node name ->
(define (connect-to-named-place node name) (define (connect-to-named-place node name)
(send node remote-connect name)) (send node remote-connect name))
@ -1668,7 +1670,7 @@
(define (spawn-node-at host #:listen-port [listen-port DEFAULT-ROUTER-PORT] (define (spawn-node-at host #:listen-port [listen-port DEFAULT-ROUTER-PORT]
#:racket-path [racketpath (racket-path)] #:racket-path [racketpath (racket-path)]
#:ssh-bin-path [sshpath (ssh-bin-path)] #:ssh-bin-path [sshpath (ssh-bin-path)]
#:distributed-launch-path [distributedlaunchpath (->writeable-module-path distributed-launch-path)]) #:distributed-launch-path [distributedlaunchpath #f])
(define ch (make-channel)) (define ch (make-channel))
(thread (thread

2
collects/scribblings/reference/distributed.scrbl
View File

@ -188,7 +188,7 @@ Spawns a new remote node at @racket[hostname] and returns a @racket[remote-node%
[#:racket-path racket-path string-path? (racket-path)] [#:racket-path racket-path string-path? (racket-path)]
[#:ssh-bin-path ssh-path string-path? (ssh-bin-path)] [#:ssh-bin-path ssh-path string-path? (ssh-bin-path)]
[#:distributed-launch-path launcher-path string-path? (path->string distributed-launch-path)] [#:distributed-launch-path launcher-path string-path? (path->string distributed-launch-path)]
[#:use-current-ports use-current-ports #t]) (is-a?/c remote-node%)]{ [#:use-current-ports use-current-ports boolean? #t]) (is-a?/c remote-node%)]{
Like @racket[spawn-remote-racket-node], but the @racket[current-output-port] and @racket[current-error-port] Like @racket[spawn-remote-racket-node], but the @racket[current-output-port] and @racket[current-error-port]
are used as the standard ports for the spawned process instead of new pipe ports.} are used as the standard ports for the spawned process instead of new pipe ports.}