aboutsummaryrefslogtreecommitdiffstats
path: root/pkg
diff options
context:
space:
mode:
authorAleksandr Nogikh <nogikh@google.com>2025-02-04 11:39:48 +0100
committerAleksandr Nogikh <nogikh@google.com>2025-02-04 14:54:47 +0000
commitd39ef2f9994801180e552101c3b63a7b4e4a8579 (patch)
tree64c8f74dd044febda50c3c89100c8290dcdfeb0e /pkg
parent39e250d27f8ab094fbf992d5569eec06d5eb7a10 (diff)
pkg/manager: fix RPCServer ops in RunDiffFuzzer()
We must not only call Listen(), but also Serve().
Diffstat (limited to 'pkg')
-rw-r--r--pkg/manager/diff.go11
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 {