I've decided to rename "virtual" flows to "monitor" flows.
This commit is contained in:
parent
ab5b1850d0
commit
a44b7ba3e2
|
@ -27,7 +27,7 @@
|
||||||
(define listener
|
(define listener
|
||||||
(transition 'no-state
|
(transition 'no-state
|
||||||
(role 'connection-waiter (topic-subscriber (tcp-channel (wild) server-addr (wild))
|
(role 'connection-waiter (topic-subscriber (tcp-channel (wild) server-addr (wild))
|
||||||
#:virtual? #t)
|
#:monitor? #t)
|
||||||
#:state state
|
#:state state
|
||||||
#:topic t
|
#:topic t
|
||||||
#:on-presence (match t
|
#:on-presence (match t
|
||||||
|
@ -38,7 +38,7 @@
|
||||||
;; PAPER NOTE: This second clause can be replaced with
|
;; PAPER NOTE: This second clause can be replaced with
|
||||||
;; [_ state] for presentation economy
|
;; [_ state] for presentation economy
|
||||||
[(topic 'publisher (tcp-channel remote-addr (== server-addr) _) #t)
|
[(topic 'publisher (tcp-channel remote-addr (== server-addr) _) #t)
|
||||||
;; Ignore virtual flows. They just mean there's
|
;; Ignore monitor flows. They just mean there's
|
||||||
;; someone willing to supply connections to us
|
;; someone willing to supply connections to us
|
||||||
;; at some point in the future.
|
;; at some point in the future.
|
||||||
state]))))
|
state]))))
|
||||||
|
@ -58,8 +58,8 @@
|
||||||
|
|
||||||
(define (repl-boot self-pid)
|
(define (repl-boot self-pid)
|
||||||
(transition 'no-repl-state
|
(transition 'no-repl-state
|
||||||
(role 'spy (or (topic-subscriber (wild) #:virtual? #t)
|
(role 'spy (or (topic-subscriber (wild) #:monitor? #t)
|
||||||
(topic-publisher (wild) #:virtual? #t))
|
(topic-publisher (wild) #:monitor? #t))
|
||||||
#:state state
|
#:state state
|
||||||
[message
|
[message
|
||||||
(write `(APP ,message))
|
(write `(APP ,message))
|
||||||
|
@ -72,7 +72,7 @@
|
||||||
#:state state
|
#:state state
|
||||||
#:topic t
|
#:topic t
|
||||||
#:on-presence
|
#:on-presence
|
||||||
(if (topic-virtual? t)
|
(if (topic-monitor? t)
|
||||||
state
|
state
|
||||||
(match t
|
(match t
|
||||||
[(topic _ (channel-message (channel-stream-name _ cname) _) _)
|
[(topic _ (channel-message (channel-stream-name _ cname) _) _)
|
||||||
|
@ -134,8 +134,8 @@
|
||||||
(bytes-append #"Unknown channel type " type))))))]))
|
(bytes-append #"Unknown channel type " type))))))]))
|
||||||
|
|
||||||
(define (spy marker)
|
(define (spy marker)
|
||||||
(role 'spy (or (topic-subscriber (wild) #:virtual? #t)
|
(role 'spy (or (topic-subscriber (wild) #:monitor? #t)
|
||||||
(topic-publisher (wild) #:virtual? #t))
|
(topic-publisher (wild) #:monitor? #t))
|
||||||
#:state state
|
#:state state
|
||||||
[message
|
[message
|
||||||
(write `(,marker ,message))
|
(write `(,marker ,message))
|
||||||
|
|
|
@ -681,14 +681,14 @@
|
||||||
;; remote peer by virtue of our installation of the handler for
|
;; remote peer by virtue of our installation of the handler for
|
||||||
;; SSH_MSG_CHANNEL_OPEN above.
|
;; SSH_MSG_CHANNEL_OPEN above.
|
||||||
(role 'channel-connector
|
(role 'channel-connector
|
||||||
(set (topic-publisher arbitrary-locally-originated-traffic #:virtual? #t)
|
(set (topic-publisher arbitrary-locally-originated-traffic #:monitor? #t)
|
||||||
(topic-subscriber arbitrary-locally-originated-traffic #:virtual? #t))
|
(topic-subscriber arbitrary-locally-originated-traffic #:monitor? #t))
|
||||||
#:state conn
|
#:state conn
|
||||||
#:topic t
|
#:topic t
|
||||||
#:on-presence
|
#:on-presence
|
||||||
(match t
|
(match t
|
||||||
[(topic _ _ #t)
|
[(topic _ _ #t)
|
||||||
;; Virtual topics appearing indicate receptivity to incoming
|
;; Monitor topics appearing indicate receptivity to incoming
|
||||||
;; channels, and are nothing to do with outgoing channels.
|
;; channels, and are nothing to do with outgoing channels.
|
||||||
conn]
|
conn]
|
||||||
[(or (topic 'publisher (channel-message (channel-stream-name #f cname) _) #f)
|
[(or (topic 'publisher (channel-message (channel-stream-name #f cname) _) #f)
|
||||||
|
|
Loading…
Reference in New Issue