more verbose info on chunk indexing

rusq · Feb 12, 2024 · a8f513e · a8f513e
1 parent 30d207d
commit a8f513e
Show file tree

Hide file tree

Showing 2 changed files with 4 additions and 2 deletions.
diff --git a/internal/chunk/chunk.go b/internal/chunk/chunk.go
@@ -155,7 +155,7 @@ func channelUsersID(channelID string) GroupID {
 }
 
 func (c *Chunk) String() string {
-	return fmt.Sprintf("%s: %s", c.Type, c.ID())
+	return c.Type.String() + ": " + string(c.ID())
 }
 
 // Timestamps returns the timestamps of the messages in the chunk.  For files

diff --git a/internal/chunk/file.go b/internal/chunk/file.go
@@ -109,6 +109,7 @@ type decoder interface {
 
 // indexChunks indexes the records in the reader and returns an index.
 func indexChunks(dec decoder) (index, error) {
+	start := time.Now()
 	idx := make(index, 200) // buffer for 200 chunks to avoid reallocations.
 	var id GroupID
 	for i := 0; ; i++ {
@@ -124,7 +125,8 @@ func indexChunks(dec decoder) (index, error) {
 		id = chunk.ID()
 		idx[id] = append(idx[id], offset)
 	}
-	logger.Default.Debugf("indexing chunks: %d: called from %v", len(idx), caller(2))
+
+	logger.Default.Debugf("indexing chunks: %d: called from %v, took %s (%.2f/sec)", len(idx), caller(2), time.Since(start), float64(len(idx))/time.Since(start).Seconds())
 	return idx, nil
 }