From b72d755225201b313c6d27aa46ee409b07d452e6 Mon Sep 17 00:00:00 2001 From: Sam Calder-Mason Date: Tue, 13 Aug 2024 11:46:45 +1000 Subject: [PATCH] fix: Start processing in Client and Peer before returning --- pkg/discovery/coordinator/client.go | 2 ++ pkg/mimicry/p2p/execution/execution.go | 2 ++ 2 files changed, 4 insertions(+) diff --git a/pkg/discovery/coordinator/client.go b/pkg/discovery/coordinator/client.go index 0b92b083..05a41c1a 100644 --- a/pkg/discovery/coordinator/client.go +++ b/pkg/discovery/coordinator/client.go @@ -88,6 +88,8 @@ func (c *Client) Type() string { } func (c *Client) Start(ctx context.Context) error { + c.proc.Start(ctx) + return nil } diff --git a/pkg/mimicry/p2p/execution/execution.go b/pkg/mimicry/p2p/execution/execution.go index a7eb8e1f..f8580811 100644 --- a/pkg/mimicry/p2p/execution/execution.go +++ b/pkg/mimicry/p2p/execution/execution.go @@ -124,6 +124,8 @@ func (p *Peer) Start(ctx context.Context) (<-chan error, error) { return nil, err } + p.txProc.Start(ctx) + p.client.OnHello(ctx, func(ctx context.Context, hello *mimicry.Hello) error { // setup client implementation and version info split := strings.SplitN(hello.Name, "/", 2)