syndicate-lang
/
racket-ssh-2012
1
0
Fork 0
Code Issues Pull Requests Projects Releases Wiki Activity

Cope with merge of spawn/monitor into spawn.

This commit is contained in:
Tony Garnock-Jones 2012-06-23 07:55:47 -04:00
parent 9501a73fc5
commit e6c867ab7f
2 changed files with 15 additions and 9 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

19
new-server.rkt
View File

@ -153,18 +153,21 @@
(extend-transition
(prefix-transition (ssh-reader local-addr remote-addr)
(at-meta-level (send-tcp-mode remote-addr local-addr 'bytes)))
(spawn/monitor (ssh-writer local-addr remote-addr) #:debug-name 'ssh-writer)
(spawn (ssh-writer local-addr remote-addr)
#:monitor? #t
#:debug-name 'ssh-writer)
;; Wait for a cycle to let the reader and writer get
;; started, then tell the reader we are ready for a
;; single packet and spawn the session manager.
(yield #:state state
(transition state
(send-message (inbound-credit 1))
(spawn/monitor (ssh-session local-identification
remote-identification
repl-boot
'server)
#:debug-name 'ssh-session))))]))))
(spawn (ssh-session local-identification
remote-identification
repl-boot
'server)
#:monitor? #t
#:debug-name 'ssh-session))))]))))
(define (exn->outbound-packet reason)
(outbound-packet (ssh-msg-disconnect (exn:fail:contract:protocol-reason-code reason)
@ -207,7 +210,9 @@
(at-meta-level (send-tcp-mode remote-addr local-addr 'lines))
(at-meta-level (send-tcp-credit remote-addr local-addr 1))
(spawn/monitor (read-handshake-and-become-reader) #:debug-name 'ssh-reader)
(spawn (read-handshake-and-become-reader)
#:monitor? #t
#:debug-name 'ssh-reader)
(spawn (transition active-exception-handler
(role 'monitor-listener (topic-subscriber (monitor (wild) (wild)))

5
ssh-session.rkt
View File

@ -870,8 +870,9 @@
peer-identification-string
#f)
(spawn/monitor (nested-vm 'ssh-application-vm application-boot)
#:debug-name 'ssh-application-vm)
(spawn (nested-vm 'ssh-application-vm application-boot)
#:monitor? #t
#:debug-name 'ssh-application-vm)
(role 'rekey-waiter (topic-subscriber (timer-expired 'rekey-timer (wild)))
#:state conn