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

[#199] putsvc: Refactor streamer initialization

Browse source 
Resolve funlen linter for initTarget method

Signed-off-by: Dmitrii Stepanov <d.stepanov@yadro.com>
This commit is contained in:
Dmitrii Stepanov 2023-04-03 15:40:52 +03:00 committed by Gitea
parent 27bdddc48f
commit ece6c820e7
1 changed files with 15 additions and 9 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

24
pkg/services/object/put/streamer.go
View file

@ -51,7 +51,6 @@ func (p *Streamer) MaxObjectSize() uint64 {
return p.maxPayloadSz return p.maxPayloadSz
} }
// nolint: funlen
func (p *Streamer) initTarget(prm *PutInitPrm) error { func (p *Streamer) initTarget(prm *PutInitPrm) error {
// prevent re-calling // prevent re-calling
if p.target != nil { if p.target != nil {
@ -69,19 +68,26 @@ func (p *Streamer) initTarget(prm *PutInitPrm) error {
} }
if prm.hdr.Signature() != nil { if prm.hdr.Signature() != nil {
p.relay = prm.relay return p.initUntrustedTarget(prm)
}
return p.initTrustedTarget(prm)
}
// prepare untrusted-Put object target func (p *Streamer) initUntrustedTarget(prm *PutInitPrm) error {
p.target = &validatingTarget{ p.relay = prm.relay
nextTarget: p.newCommonTarget(prm),
fmt: p.fmtValidator,
maxPayloadSz: p.maxPayloadSz, // prepare untrusted-Put object target
} p.target = &validatingTarget{
nextTarget: p.newCommonTarget(prm),
fmt: p.fmtValidator,
return nil maxPayloadSz: p.maxPayloadSz,
} }
return nil
}
func (p *Streamer) initTrustedTarget(prm *PutInitPrm) error {
sToken := prm.common.SessionToken() sToken := prm.common.SessionToken()
// prepare trusted-Put object target // prepare trusted-Put object target