From 6ca3491f421e8506fa3ff832a51b3a7d8a5c7ef6 Mon Sep 17 00:00:00 2001
From: Paul Buetow <paul@buetow.org>
Date: Sun, 6 Apr 2025 21:27:31 +0300
Subject: initial dumping in new ior data format

---
 internal/flamegraph/collapsed.go | 97 ----------------------------------------
 1 file changed, 97 deletions(-)
 delete mode 100644 internal/flamegraph/collapsed.go

(limited to 'internal/flamegraph/collapsed.go')

diff --git a/internal/flamegraph/collapsed.go b/internal/flamegraph/collapsed.go
deleted file mode 100644
index 60c0b7f..0000000
--- a/internal/flamegraph/collapsed.go
+++ /dev/null
@@ -1,97 +0,0 @@
-package flamegraph
-
-import (
-	"fmt"
-	"ior/internal/types"
-	"os"
-	"strings"
-	"sync"
-)
-
-type collapsedCounter struct {
-	count    uint64
-	duration uint64
-}
-
-func (c *collapsedCounter) add(other collapsedCounter) {
-	c.count += other.count
-	c.duration += other.duration
-}
-
-// TODO: Clean up all code commented with COLLAPSED once collapsed here retired.
-type collapsed map[string]map[types.TraceId]collapsedCounter
-
-func (c collapsed) merge(other collapsed) (merged int) {
-	for k, v := range other {
-		if _, ok := c[k]; !ok {
-			c[k] = make(map[types.TraceId]collapsedCounter)
-		}
-		for traceId, cnt := range v {
-			if existingCnt, ok := c[k][traceId]; ok {
-				existingCnt.add(cnt)
-				merged++
-				c[k][traceId] = existingCnt
-				continue
-			}
-			c[k][traceId] = cnt
-		}
-	}
-	return
-}
-
-func (c collapsed) dump() {
-	var wg sync.WaitGroup
-	wg.Add(4)
-
-	go c.dumpBy(&wg, "ior-by-path-count-flamegraph.collapsed", true, func(cnt collapsedCounter) uint64 {
-		return cnt.count
-	})
-	go c.dumpBy(&wg, "ior-by-path-duration-flamegraph.collapsed", true, func(cnt collapsedCounter) uint64 {
-		return cnt.duration
-	})
-	go c.dumpBy(&wg, "ior-by-syscall-count-flamegraph.collapsed", false, func(cnt collapsedCounter) uint64 {
-		return cnt.count
-	})
-	go c.dumpBy(&wg, "ior-by-syscall-duration-flamegraph.collapsed", false, func(cnt collapsedCounter) uint64 {
-		return cnt.duration
-	})
-
-	wg.Wait()
-}
-
-func (c collapsed) dumpBy(wg *sync.WaitGroup, outfile string, syscallAtTop bool, by func(collapsedCounter) uint64) {
-	defer wg.Done()
-
-	defer fmt.Println("Dumping done")
-	fmt.Println("Dumping", outfile)
-
-	file, err := os.Create(outfile)
-	if err != nil {
-		panic(err)
-	}
-	defer file.Close()
-
-	for path, value := range c {
-		var sb strings.Builder
-
-		for i, part := range strings.Split(path, "/") {
-			if i > 1 {
-				sb.WriteString(";")
-				sb.WriteString("/")
-			}
-			sb.WriteString(part)
-		}
-
-		for traceId, cnt := range value {
-			var err error
-			if syscallAtTop {
-				_, err = fmt.Fprintf(file, "%s;syscall`%s %v\n", sb.String(), traceId.Name(), by(cnt))
-			} else {
-				_, err = fmt.Fprintf(file, "syscall`%s;%s %v\n", traceId.Name(), sb.String(), by(cnt))
-			}
-			if err != nil {
-				panic(err)
-			}
-		}
-	}
-}
-- 
cgit v1.2.3