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

Responsibility transfer during outbound websocket connection establishment

This commit is contained in:
Tony Garnock-Jones 2018-08-14 17:38:36 +01:00
parent eb70563edb
commit 47094c11c4
1 changed files with 12 additions and 9 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

21
racket/syndicate/drivers/websocket.rkt
View File

@ -215,16 +215,19 @@
(define (spawn-connection local-addr remote-addr id c control-ch)
(actor #:name (list 'drivers/websocket:connect local-addr remote-addr id)
#:assertions*
(patch-added
(patch-seq
(let-values (((la lp ra rp) (ws-conn-peer-addresses c)))
(assert (websocket-peer-details local-addr remote-addr la lp ra rp)))
(sub (observe (websocket-message remote-addr local-addr ?))) ;; monitor peer
(pub (websocket-message remote-addr local-addr ?)) ;; may send messages to peer
(sub (websocket-message local-addr remote-addr ?)) ;; want segments from peer
(sub (inbound (websocket-incoming-message id ?))) ;; segments from driver thd
))
websocket-connection-behaviour
(connection-state local-addr remote-addr c control-ch)
(patch-seq
(let-values (((la lp ra rp) (ws-conn-peer-addresses c)))
(assert (websocket-peer-details local-addr remote-addr la lp ra rp)))
(sub (observe (websocket-message remote-addr local-addr ?))) ;; monitor peer
(pub (websocket-message remote-addr local-addr ?)) ;; may send messages to peer
(sub (websocket-message local-addr remote-addr ?)) ;; want segments from peer
(sub (inbound (websocket-incoming-message id ?))) ;; segments from driver thd
)))
(connection-state local-addr remote-addr c control-ch)
'()))
;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;