fix: timer

ethersphere · Sep 21, 2023 · f8adc4b · f8adc4b
1 parent b9f308f
commit f8adc4b
Showing 1 changed file with 7 additions and 2 deletions.
diff --git a/pkg/storer/compact.go b/pkg/storer/compact.go
@@ -28,8 +28,6 @@ func Compact(ctx context.Context, basePath string, opts *Options, validate bool)
 
 	logger := opts.Logger
 
-	n := time.Now()
-
 	logger.Info("starting compaction")
 
 	store, err := initStore(basePath, opts)
@@ -57,6 +55,8 @@ func Compact(ctx context.Context, basePath string, opts *Options, validate bool)
 		validationWork(ctx, logger, store, sharkyRecover)
 	}
 
+	n := time.Now()
+
 	iteratateItemsC := make(chan chunkstore.IterateResult)
 	chunkstore.Iterate(ctx, store, iteratateItemsC)
 
@@ -144,6 +144,11 @@ func Compact(ctx context.Context, basePath string, opts *Options, validate bool)
 
 func validationWork(ctx context.Context, logger log.Logger, store storage.Store, sharky *sharky.Recovery) {
 
+	n := time.Now()
+	defer func() {
+		logger.Info("validation finished", "duration", time.Since(n))
+	}()
+
 	iteratateItemsC := make(chan chunkstore.IterateResult)
 	chunkstore.Iterate(ctx, store, iteratateItemsC)