From 72b08b89bcde266d8ec4abc77b01fcc0cc95bea0 Mon Sep 17 00:00:00 2001
From: Aleksandr Nogikh <nogikh@google.com>
Date: Tue, 15 Apr 2025 15:40:27 +0200
Subject: pkg/manager: provide diff fuzzer state dumps

Make the fuzzing step of syz-cluster create the manager.DiffStore object
explicitly and dump its state to the logs after finishing the fuzzing
session.
---
 pkg/manager/diff_store.go | 37 +++++++++++++++++++++++++++++++++++++
 1 file changed, 37 insertions(+)

(limited to 'pkg/manager/diff_store.go')

diff --git a/pkg/manager/diff_store.go b/pkg/manager/diff_store.go
index 76e2b97ff..2fb7d7f19 100644
--- a/pkg/manager/diff_store.go
+++ b/pkg/manager/diff_store.go
@@ -4,9 +4,12 @@
 package manager
 
 import (
+	"bytes"
 	"fmt"
 	"path/filepath"
+	"sort"
 	"sync"
+	"text/tabwriter"
 	"time"
 
 	"github.com/google/syzkaller/pkg/log"
@@ -116,6 +119,40 @@ func (s *DiffFuzzerStore) List() []DiffBug {
 	return list
 }
 
+func (s *DiffFuzzerStore) PlainTextDump() []byte {
+	list := s.List()
+	sort.Slice(list, func(i, j int) bool {
+		// Put patched-only on top, otherwise sort by the title.
+		first, second := list[i].PatchedOnly(), list[j].PatchedOnly()
+		if first != second {
+			return first
+		}
+		return list[i].Title < list[j].Title
+	})
+	var buf bytes.Buffer
+	w := tabwriter.NewWriter(&buf, 0, 0, 1, ' ', 0)
+	fmt.Fprintln(w, "Title\tOn-Base\tOn-Patched")
+
+	printInfo := func(info *DiffBugInfo) {
+		if info.Crashes > 0 {
+			fmt.Fprintf(w, "%d crashes", info.Crashes)
+		}
+		if info.Repro != "" {
+			fmt.Fprintf(w, "[reproduced]")
+		}
+	}
+
+	for _, item := range list {
+		fmt.Fprintf(w, "%s\t", item.Title)
+		printInfo(&item.Base)
+		fmt.Fprintf(w, "\t")
+		printInfo(&item.Patched)
+		fmt.Fprintf(w, "\n")
+	}
+	w.Flush()
+	return buf.Bytes()
+}
+
 func (s *DiffFuzzerStore) saveFile(title, name string, data []byte) string {
 	hash := crashHash(title)
 	path := filepath.Join(s.BasePath, "crashes", hash)
-- 
cgit mrf-deployment