achuprov/frostfs-node
1
0
Fork 0
forked from TrueCloudLab/frostfs-node
Code Pull requests Activity

[#956] node: Remove pool sizes from config struct

Browse source 
They are available through the pool methods and unused outside of the
function that sets them.

Signed-off-by: Evgenii Stratonikov <e.stratonikov@yadro.com>
This commit is contained in:
Evgenii Stratonikov 2024-02-02 20:17:04 +03:00 committed by Evgenii Stratonikov
parent edbe06e07e
commit 426cf58b98
1 changed files with 8 additions and 14 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

22
cmd/frostfs-node/config.go
View file

@ -632,14 +632,8 @@ type cfgAccessPolicyEngine struct {
type cfgObjectRoutines struct { type cfgObjectRoutines struct {
putRemote *ants.Pool putRemote *ants.Pool
putRemoteCapacity int
putLocal *ants.Pool putLocal *ants.Pool
putLocalCapacity int
replicatorPoolSize int
replication *ants.Pool replication *ants.Pool
} }
@ -1094,20 +1088,20 @@ func initObjectPool(cfg *config.Config) (pool cfgObjectRoutines) {
optNonBlocking := ants.WithNonblocking(true) optNonBlocking := ants.WithNonblocking(true)
pool.putRemoteCapacity = objectconfig.Put(cfg).PoolSizeRemote() putRemoteCapacity := objectconfig.Put(cfg).PoolSizeRemote()
pool.putRemote, err = ants.NewPool(pool.putRemoteCapacity, optNonBlocking) pool.putRemote, err = ants.NewPool(putRemoteCapacity, optNonBlocking)
fatalOnErr(err) fatalOnErr(err)
pool.putLocalCapacity = objectconfig.Put(cfg).PoolSizeLocal() putLocalCapacity := objectconfig.Put(cfg).PoolSizeLocal()
pool.putLocal, err = ants.NewPool(pool.putLocalCapacity, optNonBlocking) pool.putLocal, err = ants.NewPool(putLocalCapacity, optNonBlocking)
fatalOnErr(err) fatalOnErr(err)
pool.replicatorPoolSize = replicatorconfig.PoolSize(cfg) replicatorPoolSize := replicatorconfig.PoolSize(cfg)
if pool.replicatorPoolSize <= 0 { if replicatorPoolSize <= 0 {
pool.replicatorPoolSize = pool.putRemoteCapacity replicatorPoolSize = putRemoteCapacity
} }
pool.replication, err = ants.NewPool(pool.replicatorPoolSize) pool.replication, err = ants.NewPool(replicatorPoolSize)
fatalOnErr(err) fatalOnErr(err)
return pool return pool