TrueCloudLab/frostfs-node
20
1
Fork 27
Code Issues 96 Pull requests 4 Projects Releases 1 Activity Actions

[#194] cmd/neofs-node: Use non-blocking worker pools for Object services

Browse source 
Signed-off-by: Leonard Lyubich <leonard@nspcc.ru>
This commit is contained in:
Leonard Lyubich 2020-11-23 15:09:41 +03:00 committed by Alex Vanin
parent 46dab77705
commit d286824d1d
1 changed files with 8 additions and 6 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

14
cmd/neofs-node/config.go
View file

@ -421,32 +421,34 @@ func initBucket(prefix string, c *cfg) (bucket bucket.Bucket, err error) {
func initObjectPool(cfg *viper.Viper) (pool cfgObjectRoutines) { func initObjectPool(cfg *viper.Viper) (pool cfgObjectRoutines) {
var err error var err error
pool.get, err = ants.NewPool(cfg.GetInt(cfgObjectGetPoolSize)) optNonBlocking := ants.WithNonblocking(true)
pool.get, err = ants.NewPool(cfg.GetInt(cfgObjectGetPoolSize), optNonBlocking)
if err != nil { if err != nil {
fatalOnErr(err) fatalOnErr(err)
} }
pool.head, err = ants.NewPool(cfg.GetInt(cfgObjectHeadPoolSize)) pool.head, err = ants.NewPool(cfg.GetInt(cfgObjectHeadPoolSize), optNonBlocking)
if err != nil { if err != nil {
fatalOnErr(err) fatalOnErr(err)
} }
pool.search, err = ants.NewPool(cfg.GetInt(cfgObjectSearchPoolSize)) pool.search, err = ants.NewPool(cfg.GetInt(cfgObjectSearchPoolSize), optNonBlocking)
if err != nil { if err != nil {
fatalOnErr(err) fatalOnErr(err)
} }
pool.put, err = ants.NewPool(cfg.GetInt(cfgObjectPutPoolSize)) pool.put, err = ants.NewPool(cfg.GetInt(cfgObjectPutPoolSize), optNonBlocking)
if err != nil { if err != nil {
fatalOnErr(err) fatalOnErr(err)
} }
pool.rng, err = ants.NewPool(cfg.GetInt(cfgObjectRangePoolSize)) pool.rng, err = ants.NewPool(cfg.GetInt(cfgObjectRangePoolSize), optNonBlocking)
if err != nil { if err != nil {
fatalOnErr(err) fatalOnErr(err)
} }
pool.rngHash, err = ants.NewPool(cfg.GetInt(cfgObjectRangeHashPoolSize)) pool.rngHash, err = ants.NewPool(cfg.GetInt(cfgObjectRangeHashPoolSize), optNonBlocking)
if err != nil { if err != nil {
fatalOnErr(err) fatalOnErr(err)
} }