fix: Start processing in Client and Peer before returning

ethpandaops · Aug 13, 2024 · b72d755 · b72d755
1 parent 592b95e
commit b72d755
Show file tree

Hide file tree

Showing 2 changed files with 4 additions and 0 deletions.
diff --git 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
@@ -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)