save

Author: AskAlexSharov

mdbx/txn.go

@@ -9,10 +9,11 @@ import "C"
 
 import (
 	"fmt"
-	"github.com/erigontech/mdbx-go/mdbx/threads"
 	"log"
 	"time"
 	"unsafe"
+
+	"github.com/erigontech/mdbx-go/mdbx/threads"
 )
 
 // This flags are used exclusively for Txn.OpenDBISimple and Txn.OpenRoot.  The
@@ -221,6 +222,9 @@ type CommitLatencyGC struct {
 	WorkCounter uint32
 	SelfCounter uint32
 
+	MaxRetainedPage uint32
+	MaxReaderLag    uint32
+
 	// WorkPnlMergeTime   time.Duration
 	// WorkPnlMergeVolume uint64
 	// WorkPnlMergeCalls  uint32
@@ -265,10 +269,12 @@ func (txn *Txn) commit() (CommitLatency, error) {
 		Ending:      toDuration(_stat.ending),
 		Whole:       toDuration(_stat.whole),
 		GCDetails: CommitLatencyGC{
-			WorkRtime:   toDuration(_stat.gc_prof.work_rtime_monotonic),
-			WorkRsteps:  uint32(_stat.gc_prof.work_rsteps),
-			WorkRxpages: uint32(_stat.gc_prof.work_xpages),
-			WorkMajflt:  uint32(_stat.gc_prof.work_majflt),
+			WorkRtime:       toDuration(_stat.gc_prof.work_rtime_monotonic),
+			MaxRetainedPage: uint32(_stat.gc_prof.max_retained_page),
+			MaxReaderLag:    uint32(_stat.gc_prof.max_reader_lag),
+			WorkRsteps:      uint32(_stat.gc_prof.work_rsteps),
+			WorkRxpages:     uint32(_stat.gc_prof.work_xpages),
+			WorkMajflt:      uint32(_stat.gc_prof.work_majflt),
 			//WorkPnlMergeTime:   toDuration(_stat.gc_prof.pnl_merge_work.time),
 			//WorkPnlMergeVolume: uint64(_stat.gc_prof.pnl_merge_work.volume),
 			//WorkPnlMergeCalls:  uint32(_stat.gc_prof.pnl_merge_work.calls),