log elapsed time when could not receive object

This commit is contained in:
Evgeniy Kulikov 2020-02-14 13:06:43 +03:00
parent 01e152774f
commit 307f008dac
No known key found for this signature in database
GPG key ID: BF6AEE0A2A699BF2

View file

@ -7,6 +7,7 @@ import (
"path" "path"
"strconv" "strconv"
"strings" "strings"
"time"
"github.com/labstack/echo/v4" "github.com/labstack/echo/v4"
"github.com/nspcc-dev/neofs-api/container" "github.com/nspcc-dev/neofs-api/container"
@ -22,6 +23,7 @@ func (r *router) receiveFile(c echo.Context) error {
cid refs.CID cid refs.CID
oid refs.ObjectID oid refs.ObjectID
obj *object.Object obj *object.Object
start = time.Now()
ctx = c.Request().Context() ctx = c.Request().Context()
con, err = r.pool.getConnection(ctx) con, err = r.pool.getConnection(ctx)
download = c.QueryParam("download") != "" download = c.QueryParam("download") != ""
@ -74,7 +76,9 @@ func (r *router) receiveFile(c echo.Context) error {
errors.Wrap(err, "could not prepare connection").Error(), errors.Wrap(err, "could not prepare connection").Error(),
) )
} else if obj, err = receiveObject(cli); err != nil { } else if obj, err = receiveObject(cli); err != nil {
log.Error("could not receive object", zap.Error(err)) log.Error("could not receive object",
zap.Duration("elapsed", time.Since(start)),
zap.Error(err))
switch { switch {
case strings.Contains(err.Error(), object.ErrNotFound.Error()), case strings.Contains(err.Error(), object.ErrNotFound.Error()),