Compute affected peers by the aggregate change, not the incoming action.
This commit is contained in:
parent
01b6bf92ee
commit
c3b2df00cd
|
@ -82,7 +82,7 @@
|
||||||
(define new-routing-table (mux-routing-table new-m))
|
(define new-routing-table (mux-routing-table new-m))
|
||||||
(define echo-cancelled-assertions (echo-cancelled-routing-table new-m))
|
(define echo-cancelled-assertions (echo-cancelled-routing-table new-m))
|
||||||
(define affected-pids
|
(define affected-pids
|
||||||
(let ((pids (compute-affected-pids old-routing-table aggregate-assertions))) ;; hmm
|
(let ((pids (compute-affected-pids old-routing-table aggregate-assertions)))
|
||||||
(tset-remove (tset-add pids label) 'meta))) ;; TODO: removing meta is weird
|
(tset-remove (tset-add pids label) 'meta))) ;; TODO: removing meta is weird
|
||||||
(values (for/list [(pid (tset->list affected-pids))]
|
(values (for/list [(pid (tset->list affected-pids))]
|
||||||
(cons pid (scn (biased-intersection echo-cancelled-assertions
|
(cons pid (scn (biased-intersection echo-cancelled-assertions
|
||||||
|
|
|
@ -87,7 +87,7 @@
|
||||||
(define old-routing-table (mux-routing-table old-m))
|
(define old-routing-table (mux-routing-table old-m))
|
||||||
(define new-routing-table (mux-routing-table new-m))
|
(define new-routing-table (mux-routing-table new-m))
|
||||||
(define affected-pids
|
(define affected-pids
|
||||||
(let ((pids (compute-affected-pids old-routing-table delta)))
|
(let ((pids (compute-affected-pids old-routing-table delta-aggregate/no-echo)))
|
||||||
(tset-remove (tset-add pids label) 'meta))) ;; TODO: removing meta is weird
|
(tset-remove (tset-add pids label) 'meta))) ;; TODO: removing meta is weird
|
||||||
(values (for/list [(pid (tset->list affected-pids))]
|
(values (for/list [(pid (tset->list affected-pids))]
|
||||||
(cond [(equal? pid label)
|
(cond [(equal? pid label)
|
||||||
|
|
Loading…
Reference in New Issue