deeper tombstone verify timestamps

Signed-off-by: Leonard Lyubich <[email protected]>

Author: cthulhu-rider

pkg/services/object/get/util.go

@@ -202,7 +202,7 @@ func (e *storageEngineWrapper) get(exec *execCtx) (*object.Object, error) {
 	if exec.headOnly() {
 		st := time.Now()
 		r, err := e.engine.Head(exec.address(), exec.isRaw())
-		fmt.Println("engine.Head:", exec.address().Object(), time.Since(st))
+		fmt.Println("local engine.Head:", exec.address().Object(), time.Since(st))
 		if err != nil {
 			return nil, err
 		}
@@ -213,7 +213,7 @@ func (e *storageEngineWrapper) get(exec *execCtx) (*object.Object, error) {
 	if rng := exec.ctxRange(); rng != nil {
 		st := time.Now()
 		r, err := e.engine.GetRange(exec.address(), rng.GetOffset(), rng.GetLength())
-		fmt.Println("engine.GetRange:", exec.address().Object(), time.Since(st))
+		fmt.Println("local engine.GetRange:", exec.address().Object(), time.Since(st))
 		if err != nil {
 			return nil, err
 		}
@@ -226,7 +226,7 @@ func (e *storageEngineWrapper) get(exec *execCtx) (*object.Object, error) {
 
 	st := time.Now()
 	res, err := e.engine.Get(exec.address())
-	fmt.Println("engine.Get:", exec.address().Object(), time.Since(st))
+	fmt.Println("local engine.Get:", exec.address().Object(), time.Since(st))
 	return res, err
 }
 

pkg/services/object/internal/client/client.go

@@ -7,6 +7,7 @@ import (
 	"errors"
 	"fmt"
 	"io"
+	"time"
 
 	coreclient "github.com/nspcc-dev/neofs-node/pkg/core/client"
 	"github.com/nspcc-dev/neofs-sdk-go/bearer"
@@ -230,7 +231,10 @@ func HeadObject(prm HeadObjectPrm) (*HeadObjectRes, error) {
 
 	prm.cliPrm.WithXHeaders(prm.xHeaders...)
 
+	st := time.Now()
+	fmt.Println("spawn Head request", prm.obj, st)
 	hdr, err := prm.cli.ObjectHead(prm.ctx, prm.cnr, prm.obj, prm.signer, prm.cliPrm)
+	fmt.Println("spawn Head request took", prm.obj, time.Since(st))
 	if err != nil {
 		return nil, fmt.Errorf("read object header from NeoFS: %w", err)
 	}

pkg/services/object/server.go

@@ -590,6 +590,7 @@ func (s *server) Head(ctx context.Context, req *protoobject.HeadRequest) (*proto
 		err error
 		t   = time.Now()
 	)
+	fmt.Println("Head request receipt", base58.Encode(req.GetBody().GetAddress().GetObjectId().GetValue()), t)
 	defer func() {
 		s.pushOpExecResult(stat.MethodObjectHead, err, t)
 		fmt.Println("Head rpc", base58.Encode(req.GetBody().GetAddress().GetObjectId().GetValue()), time.Since(t))

pkg/services/object/tombstone/verify.go

@@ -84,7 +84,7 @@ func (v *Verifier) verifyMember(ctx context.Context, cnr cid.ID, member oid.ID)
 	addr.SetObject(member)
 
 	st := time.Now()
-	fmt.Println("tombstone member heading...", member)
+	fmt.Println("tombstone member heading...", member, st)
 	header, err := v.objs.Head(ctx, addr)
 	fmt.Println("tombstone member heading took", member, time.Since(st))
 	if err != nil {