From c0ff69f67ed6450071c9f300ddd7d8f04923bd84 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 --- syndicate/distributed/federation.rkt | 5 +++-- syndicate/distributed/internal-protocol.rkt | 1 + 2 files changed, 4 insertions(+), 2 deletions(-) diff --git a/syndicate/distributed/federation.rkt b/syndicate/distributed/federation.rkt index 8b7d015..cb74a3e 100644 --- a/syndicate/distributed/federation.rkt +++ b/syndicate/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/syndicate/distributed/internal-protocol.rkt b/syndicate/distributed/internal-protocol.rkt index d58df31..07b519d 100644 --- a/syndicate/distributed/internal-protocol.rkt +++ b/syndicate/distributed/internal-protocol.rkt @@ -26,3 +26,4 @@ ;; Federated links generally (assertion-struct federated-link (id scope)) +(assertion-struct federated-link-ready (id))