From 5c646b970a6ab6d71e75979d55f084245efcf7e8 Mon Sep 17 00:00:00 2001
From: Luca Moser <moser.luca@gmail.com>
Date: Tue, 14 Jul 2020 18:14:48 +0200
Subject: [PATCH] print DBStats() func ints
---
packages/binary/messagelayer/tangle/tangle.go | 6 ++++++
1 file changed, 6 insertions(+)
diff --git a/packages/binary/messagelayer/tangle/tangle.go b/packages/binary/messagelayer/tangle/tangle.go
index c56cf589..19234e71 100644
--- a/packages/binary/messagelayer/tangle/tangle.go
+++ b/packages/binary/messagelayer/tangle/tangle.go
@@ -2,6 +2,7 @@ package tangle
import (
"container/list"
+ "fmt"
"runtime"
"time"
@@ -66,6 +67,8 @@ func New(store kvstore.KVStore) (result *Tangle) {
Events: *newEvents(),
}
+ result.DBStats()
+
result.solidifierWorkerPool.Tune(runtime.GOMAXPROCS(0))
return
}
@@ -147,7 +150,9 @@ func (tangle *Tangle) Prune() error {
// DBStats returns the number of solid messages and total number of messages in the database, furthermore the average time it takes to solidify messages.
func (tangle *Tangle) DBStats() (solidCount int, messageCount int, avgSolidificationTime float64) {
var sumSolidificationTime time.Duration
+ var iterations int
tangle.messageMetadataStorage.ForEach(func(key []byte, cachedObject objectstorage.CachedObject) bool {
+ iterations++
cachedObject.Consume(func(object objectstorage.StorableObject) {
msgMetaData := object.(*MessageMetadata)
messageCount++
@@ -160,6 +165,7 @@ func (tangle *Tangle) DBStats() (solidCount int, messageCount int, avgSolidifica
return true
})
avgSolidificationTime = float64(sumSolidificationTime.Milliseconds()) / float64(solidCount)
+ fmt.Println("solid", solidCount, "message", messageCount, "iterations", iterations)
return
}
--
GitLab