diff options
| author | Aleksandr Nogikh <nogikh@google.com> | 2025-02-04 11:39:48 +0100 |
|---|---|---|
| committer | Aleksandr Nogikh <nogikh@google.com> | 2025-02-04 14:54:47 +0000 |
| commit | d39ef2f9994801180e552101c3b63a7b4e4a8579 (patch) | |
| tree | 64c8f74dd044febda50c3c89100c8290dcdfeb0e /pkg/manager | |
| parent | 39e250d27f8ab094fbf992d5569eec06d5eb7a10 (diff) | |
pkg/manager: fix RPCServer ops in RunDiffFuzzer()
We must not only call Listen(), but also Serve().
Diffstat (limited to 'pkg/manager')
| -rw-r--r-- | pkg/manager/diff.go | 11 |
1 files changed, 9 insertions, 2 deletions
diff --git a/pkg/manager/diff.go b/pkg/manager/diff.go index 8525015da..f472cbf18 100644 --- a/pkg/manager/diff.go +++ b/pkg/manager/diff.go @@ -294,8 +294,15 @@ func (kc *kernelContext) Loop() error { if err := kc.serv.Listen(); err != nil { return fmt.Errorf("failed to start rpc server: %w", err) } - kc.pool.Loop(kc.ctx) - return nil + eg, ctx := errgroup.WithContext(kc.ctx) + eg.Go(func() error { + return kc.serv.Serve(ctx) + }) + eg.Go(func() error { + kc.pool.Loop(ctx) + return nil + }) + return eg.Wait() } func (kc *kernelContext) MaxSignal() signal.Signal { |
