wip

closes #96
closes #72
closes #129

todo:
close #57
close #139

Author: amonks

CREDITS.txt

@@ -166,8 +166,8 @@ SOFTWARE.
 
 
 
-github.com/containerd/[email protected]
-====================================
+github.com/containerd/[email protected]-0.20230313162750-1ae8d489ac81
+==================================================================
 
 
                                  Apache License
@@ -471,7 +471,7 @@ SOFTWARE.
 
 
 
-github.com/muesli/[email protected]20230316100256-276c6243b2f6
+github.com/muesli/[email protected]20211031195517-c9f0611b6c70
 =========================================================
 
 MIT License
@@ -633,7 +633,7 @@ SOFTWARE.
 
 
 
-golang.org/x/sync@v0.6.0
+golang.org/x/sync@v0.7.0
 ========================
 
 Copyright (c) 2009 The Go Authors. All rights reserved.
@@ -666,7 +666,7 @@ OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE.
 
 
 
-golang.org/x/sys@v0.18.0
+golang.org/x/sys@v0.19.0
 ========================
 
 Copyright (c) 2009 The Go Authors. All rights reserved.
@@ -699,7 +699,7 @@ OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE.
 
 
 
-golang.org/x/term@v0.18.0
+golang.org/x/term@v0.19.0
 =========================
 
 Copyright (c) 2009 The Go Authors. All rights reserved.

cmd/lockfinder/main.go

@@ -0,0 +1,90 @@
+package main
+
+import (
+	"bufio"
+	"flag"
+	"fmt"
+	"os"
+	"regexp"
+	"strings"
+)
+
+func main() {
+	if err := run(); err != nil {
+		panic(err)
+	}
+}
+
+var logfile = flag.String("logfile", "mutex.log", "path to mutex.log file to consider")
+
+func run() error {
+	flag.Parse()
+
+	file, err := os.Open(*logfile)
+	if err != nil {
+		return err
+	}
+	defer file.Close()
+
+	l := &lockfinder{
+		m: map[string]string{},
+	}
+
+	scn := bufio.NewScanner(file)
+	for scn.Scan() {
+		l.handleLine(scn.Text())
+	}
+	if err := scn.Err(); err != nil {
+		return err
+	}
+
+	fmt.Println(l.report())
+	return nil
+}
+
+type lockfinder struct {
+	m map[string]string
+}
+
+var re = regexp.MustCompile(`(?P<Date>.{25}) \[(?P<Lock>.+)](?P<Fn>.*) (?P<Op>.*s) lock$`)
+
+func (l *lockfinder) handleLine(line string) error {
+	match := re.FindStringSubmatch(line)
+	if len(match) == 0 {
+		return nil
+	}
+	lock, fn, op := match[re.SubexpIndex("Lock")], match[re.SubexpIndex("Fn")], match[re.SubexpIndex("Op")]
+	switch op {
+	case "seeks":
+	case "receives":
+		l.m[lock] = fn
+	case "releases":
+		l.m[lock] = ""
+	}
+	return nil
+}
+
+type Operation int
+
+const (
+	unknownOperation Operation = iota
+	OperationGotLock
+	OperationSeeksLock
+	OperationUnlocks
+)
+
+func (l *lockfinder) report() string {
+	var buf strings.Builder
+	fmt.Fprintf(&buf, "report\n")
+	for lock, fn := range l.m {
+		if fn != "" {
+			fmt.Fprintf(&buf, "- %s is held by %s\n", lock, fn)
+		}
+	}
+	for lock, fn := range l.m {
+		if fn == "" {
+			fmt.Fprintf(&buf, "- %s is not held\n", lock)
+		}
+	}
+	return buf.String()
+}

cmd/messagestringer/main.go

@@ -0,0 +1,65 @@
+package main
+
+import (
+	"flag"
+	"go/ast"
+	"go/parser"
+	"go/token"
+	"os"
+	"path/filepath"
+	"strings"
+)
+
+var (
+	file   = flag.String("file", os.Getenv("GOFILE"), "the file to search for msg types")
+	prefix = flag.String("prefix", "msg", "a prefix; types whose names have this prefix will be generated")
+)
+
+func main() {
+	flag.Parse()
+	if err := run(); err != nil {
+		panic(err)
+	}
+}
+
+func run() error {
+	fset := token.NewFileSet()
+	f, err := parser.ParseFile(fset, *file, nil, 0)
+	if err != nil {
+		return err
+	}
+
+	var (
+		packageName string
+		ts          []string
+	)
+	ast.Inspect(f, func(n ast.Node) bool {
+		switch n := n.(type) {
+		case *ast.File:
+			packageName = n.Name.String()
+		case *ast.TypeSpec:
+			name := n.Name.String()
+			if strings.HasPrefix(name, *prefix) {
+				ts = append(ts, name)
+			}
+		}
+		return true
+	})
+
+	var b strings.Builder
+	b.WriteString("package " + packageName + "\n\n")
+	b.WriteString("import \"fmt\"\n\n")
+	for _, t := range ts {
+		b.WriteString("func (msg " + t + ") String() string {\n")
+		b.WriteString("\treturn fmt.Sprintf(\"[" + t + " %#v]\", msg)\n")
+		b.WriteString("}\n\n")
+	}
+
+	outputName := strings.TrimSuffix(*file, filepath.Ext(*file))
+	outputFilename := outputName + "_msgstrings.go"
+	if err := os.WriteFile(outputFilename, []byte(b.String()), 0644); err != nil {
+		return err
+	}
+
+	return nil
+}