From 8d09a3b3b53116077d125020ea2db71db49bc8de Mon Sep 17 00:00:00 2001 From: Aleksandr Nogikh Date: Fri, 30 Aug 2024 15:58:57 +0200 Subject: syz-manager: move repro loop to pkg/manager This is a potentially reusable piece of functionality. --- syz-manager/hub.go | 9 +++++---- 1 file changed, 5 insertions(+), 4 deletions(-) (limited to 'syz-manager/hub.go') diff --git a/syz-manager/hub.go b/syz-manager/hub.go index 5fd2356f6..58fac33f2 100644 --- a/syz-manager/hub.go +++ b/syz-manager/hub.go @@ -14,6 +14,7 @@ import ( "github.com/google/syzkaller/pkg/flatrpc" "github.com/google/syzkaller/pkg/fuzzer" "github.com/google/syzkaller/pkg/log" + "github.com/google/syzkaller/pkg/manager" "github.com/google/syzkaller/pkg/mgrconfig" "github.com/google/syzkaller/pkg/report" "github.com/google/syzkaller/pkg/report/crash" @@ -60,7 +61,7 @@ func (mgr *Manager) hubSyncLoop(keyGet keyGetter) { } if mgr.cfg.Reproduce && mgr.dash != nil { // Request reproducers from hub only if there is nothing else to reproduce. - hc.needMoreRepros = mgr.reproMgr.Empty + hc.needMoreRepros = mgr.reproLoop.Empty } hc.loop() } @@ -75,7 +76,7 @@ type HubConnector struct { fresh bool hubCorpus map[string]bool newRepros [][]byte - hubReproQueue chan *Crash + hubReproQueue chan *manager.Crash needMoreRepros func() bool keyGet keyGetter @@ -304,8 +305,8 @@ func (hc *HubConnector) processRepros(repros [][]byte) int { if hc.leak { typ = crash.MemoryLeak } - hc.hubReproQueue <- &Crash{ - fromHub: true, + hc.hubReproQueue <- &manager.Crash{ + FromHub: true, Report: &report.Report{ Type: typ, Output: repro, -- cgit mrf-deployment