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

[#314] wc: Simplify background workers naming

Browse source 
Also, drop not used arg.

Signed-off-by: Pavel Karpy <p.karpy@yadro.com>
This commit is contained in:
Pavel Karpy 2023-05-05 18:40:57 +03:00
parent 77b1b80e73
commit 1e6ffd45ad
1 changed files with 5 additions and 5 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

10
pkg/local_object_storage/writecache/flush.go
View file

@ -37,7 +37,7 @@ const (
func (c *Cache) runFlushLoop() {
for i := 0; i < c.workersCount; i++ {
c.wg.Add(1)
go c.flushWorker(i)
go c.smallObjectsFlusher()
}
c.wg.Add(1)
@ -56,7 +56,7 @@ func (c *Cache) runFlushLoop() {
for {
select {
case <-tt.C:
c.flushDB()
c.flushSmallObjects()
tt.Reset(defaultFlushInterval)
case <-c.closeCh:
return
@ -65,7 +65,7 @@ func (c *Cache) runFlushLoop() {
}()
}
func (c *Cache) flushDB() {
func (c *Cache) flushSmallObjects() {
var lastKey []byte
var m []objectInfo
for {
@ -228,8 +228,8 @@ func (c *Cache) flushFSTree(ctx context.Context, ignoreErrors bool) error {
return err
}
// flushWorker writes objects to the main storage.
func (c *Cache) flushWorker(_ int) {
// smallObjectsFlusher writes small objects to the main storage.
func (c *Cache) smallObjectsFlusher() {
defer c.wg.Done()
var obj *object.Object