diff options
| author | Aleksandr Nogikh <nogikh@google.com> | 2024-08-30 15:58:57 +0200 |
|---|---|---|
| committer | Aleksandr Nogikh <nogikh@google.com> | 2024-09-02 18:39:02 +0000 |
| commit | 8d09a3b3b53116077d125020ea2db71db49bc8de (patch) | |
| tree | 06e802a01b7f0efda0808bca19486135df4a9948 /syz-manager/hub.go | |
| parent | 1eda0d1459e5ff07903ffa2f8cedf55ae7b24af0 (diff) | |
syz-manager: move repro loop to pkg/manager
This is a potentially reusable piece of functionality.
Diffstat (limited to 'syz-manager/hub.go')
| -rw-r--r-- | syz-manager/hub.go | 9 |
1 files changed, 5 insertions, 4 deletions
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, |