From c04fea1ab95aeac74fe7757b7c158f51249d18e6 Mon Sep 17 00:00:00 2001 From: Tony Garnock-Jones Date: Tue, 11 Jun 2019 18:47:56 +0100 Subject: [PATCH] Switch to federated-link-ready --- imperative/distributed/federation.rkt | 5 +++-- imperative/distributed/internal-protocol.rkt | 1 + 2 files changed, 4 insertions(+), 2 deletions(-) diff --git a/imperative/distributed/federation.rkt b/imperative/distributed/federation.rkt index 8b7d015..cb74a3e 100644 --- a/imperative/distributed/federation.rkt +++ b/imperative/distributed/federation.rkt @@ -111,8 +111,8 @@ (push-out p)) (define (wrap p) (message-poa->server session-id p)) - (during (server-envelope management-scope (observe (message-poa->server session-id _))) - (during (from-server peer-addr (observe (message-poa->server session-id _))) + (during (server-envelope management-scope (federated-link-ready session-id)) + (during (from-server peer-addr (federated-link-ready session-id)) (drain-in (lambda (p) (send! (server-proposal management-scope (wrap p))))) (drain-out (lambda (p) (send! (to-server peer-addr (wrap p))))))))))) @@ -302,6 +302,7 @@ [_ (void)])))) (during (server-envelope management-scope (federated-link $linkid scope)) + (assert (server-proposal management-scope (federated-link-ready linkid))) (define turn (turn-recorder (lambda (items) diff --git a/imperative/distributed/internal-protocol.rkt b/imperative/distributed/internal-protocol.rkt index d58df31..07b519d 100644 --- a/imperative/distributed/internal-protocol.rkt +++ b/imperative/distributed/internal-protocol.rkt @@ -26,3 +26,4 @@ ;; Federated links generally (assertion-struct federated-link (id scope)) +(assertion-struct federated-link-ready (id))