syndicate-lang
/
syndicate-2017
1
0
Fork 0
Code Issues Pull Requests Projects Releases Wiki Activity

fix network spawning issues

This commit is contained in:
Sam Caldwell 2016-02-23 16:05:51 -05:00
parent 79cd6eac1a
commit 5c6f8aed31
1 changed files with 7 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

11
prospect/core.rkt
View File

@ -258,7 +258,7 @@
other)])) other)]))
(match-lambda (match-lambda
[(network-boot-spec boot-actions) [(network-boot-spec boot-actions)
(create-network w boot-actions)] (transition (create-network w boot-actions) '())]
[(list behavior initial-transition) [(list behavior initial-transition)
(create-process w behavior initial-transition)]) (create-process w behavior initial-transition)])
(lambda (exn) (lambda (exn)
@ -316,12 +316,15 @@
[event-channels (hash-set (network-event-channels w) pid event-chan)] [event-channels (hash-set (network-event-channels w) pid event-chan)]
[action-channels (hash-set (network-action-channels w) pid action-chan)])) [action-channels (hash-set (network-action-channels w) pid action-chan)]))
;; Network PID (Listof Action) -> Network ;; Network (Listof Action) -> Network
(define (create-network w pid boot-actions) (define (create-network w boot-actions)
(define-values (new-mux pid delta delta-aggregate)
(mux-add-stream (network-mux w) empty-patch))
(define event-chan (make-async-channel)) (define event-chan (make-async-channel))
(define action-chan (make-async-channel)) (define action-chan (make-async-channel))
(fork-network pid boot-actions event-chan action-chan) (fork-network pid boot-actions event-chan action-chan)
(struct-copy network w (struct-copy network w
[mux new-mux]
[event-channels (hash-set (network-event-channels w) pid event-chan)] [event-channels (hash-set (network-event-channels w) pid event-chan)]
[action-channels (hash-set (network-action-channels w) pid action-chan)])) [action-channels (hash-set (network-action-channels w) pid action-chan)]))
@ -433,7 +436,7 @@
(make-spawn-network (lambda () (list boot-action ...)))) (make-spawn-network (lambda () (list boot-action ...))))
(define (make-spawn-network boot-actions-thunk) (define (make-spawn-network boot-actions-thunk)
(network-boot-spec (clean-actions (boot-actions-thunk)))) (spawn (lambda () (network-boot-spec (clean-actions (boot-actions-thunk))))))
(define (transition-bind k t0) (define (transition-bind k t0)
(match t0 (match t0