aarifullin/frostfs-node
1
0
Fork 0
forked from TrueCloudLab/frostfs-node
Code Issues Pull requests Projects Releases Packages Wiki Activity

[#543] object/get: Fix potential NPE on request forwarder

Browse source 
Request forwarding callback should be called only if set since it is an
optional parameter. In GetRangeHash forwarder is never set.

Call `forwarder` function only if it is non-nil. Remove no longer needed
`hashOnly` option.

Signed-off-by: Leonard Lyubich <leonard@nspcc.ru>
This commit is contained in:
Leonard Lyubich 2021-05-20 11:04:20 +03:00 committed by Alex Vanin
parent 89b147ebe7
commit b2002ffc6d
3 changed files with 3 additions and 13 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

12
pkg/services/object/get/exec.go
View file

@ -38,7 +38,7 @@ type execCtx struct {
curOff uint64 curOff uint64
head, hash bool head bool
curProcEpoch uint64 curProcEpoch uint64
@ -71,12 +71,6 @@ func withPayloadRange(r *objectSDK.Range) execOption {
} }
} }
func hashOnly() execOption {
return func(c *execCtx) {
c.hash = true
}
}
func (exec *execCtx) setLogger(l *logger.Logger) { func (exec *execCtx) setLogger(l *logger.Logger) {
req := "GET" req := "GET"
if exec.headOnly() { if exec.headOnly() {
@ -152,10 +146,6 @@ func (exec *execCtx) headOnly() bool {
return exec.head return exec.head
} }
func (exec *execCtx) hashOnly() bool {
return exec.hash
}
func (exec *execCtx) netmapEpoch() uint64 { func (exec *execCtx) netmapEpoch() uint64 {
return exec.prm.common.NetmapEpoch() return exec.prm.common.NetmapEpoch()
} }

2
pkg/services/object/get/get.go
View file

@ -41,7 +41,7 @@ func (s *Service) GetRangeHash(ctx context.Context, prm RangeHashPrm) (*RangeHas
hash: util.NewSaltingWriter(h, prm.salt), hash: util.NewSaltingWriter(h, prm.salt),
}) })
if err := s.getRange(ctx, rngPrm, hashOnly()); err != nil { if err := s.getRange(ctx, rngPrm); err != nil {
return nil, err return nil, err
} }

2
pkg/services/object/get/util.go
View file

@ -80,7 +80,7 @@ func (c *clientCacheWrapper) get(addr string) (getClient, error) {
} }
func (c *clientWrapper) getObject(exec *execCtx) (*objectSDK.Object, error) { func (c *clientWrapper) getObject(exec *execCtx) (*objectSDK.Object, error) {
if !exec.assembling && !exec.hashOnly() { if !exec.assembling && exec.prm.forwarder != nil {
return exec.prm.forwarder(c.client) return exec.prm.forwarder(c.client)
} }