TrueCloudLab/frostfs-node
20
1
Fork 28
Code Issues 114 Pull requests 4 Projects Releases 2 Activity Actions

[#1689] linter: Fix staticcheck warning: 'variable naming format'

Browse source 
Change-Id: I8f8b63a6a5f9b6feb7c91f70fe8ac092575b145c
Signed-off-by: Alexander Chuprov <a.chuprov@yadro.com>
This commit is contained in:
Alexander Chuprov 2025-04-07 17:19:34 +03:00
parent 46fd5e17b2
commit faec499b38
Signed by: achuprov
GPG key ID: 2D916FFD803B0EDD
3 changed files with 17 additions and 17 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

26
pkg/local_object_storage/blobstor/blobovniczatree/manager.go
View file

@ -141,8 +141,8 @@ func (b *sharedDB) SystemPath() string {
return b.path return b.path
} }
// levelDbManager stores pointers of the sharedDB's for the leaf directory of the blobovnicza tree. // levelDBManager stores pointers of the sharedDB's for the leaf directory of the blobovnicza tree.
type levelDbManager struct { type levelDBManager struct {
dbMtx *sync.RWMutex dbMtx *sync.RWMutex
databases map[uint64]*sharedDB databases map[uint64]*sharedDB
@ -157,8 +157,8 @@ type levelDbManager struct {
func newLevelDBManager(options []blobovnicza.Option, rootPath string, lvlPath string, func newLevelDBManager(options []blobovnicza.Option, rootPath string, lvlPath string,
readOnly bool, metrics blobovnicza.Metrics, openDBCounter *openDBCounter, closedFlag *atomic.Bool, log *logger.Logger, readOnly bool, metrics blobovnicza.Metrics, openDBCounter *openDBCounter, closedFlag *atomic.Bool, log *logger.Logger,
) *levelDbManager { ) *levelDBManager {
result := &levelDbManager{ result := &levelDBManager{
databases: make(map[uint64]*sharedDB), databases: make(map[uint64]*sharedDB),
dbMtx: &sync.RWMutex{}, dbMtx: &sync.RWMutex{},
@ -173,7 +173,7 @@ func newLevelDBManager(options []blobovnicza.Option, rootPath string, lvlPath st
return result return result
} }
func (m *levelDbManager) GetByIndex(idx uint64) *sharedDB { func (m *levelDBManager) GetByIndex(idx uint64) *sharedDB {
res := m.getDBIfExists(idx) res := m.getDBIfExists(idx)
if res != nil { if res != nil {
return res return res
@ -181,14 +181,14 @@ func (m *levelDbManager) GetByIndex(idx uint64) *sharedDB {
return m.getOrCreateDB(idx) return m.getOrCreateDB(idx)
} }
func (m *levelDbManager) getDBIfExists(idx uint64) *sharedDB { func (m *levelDBManager) getDBIfExists(idx uint64) *sharedDB {
m.dbMtx.RLock() m.dbMtx.RLock()
defer m.dbMtx.RUnlock() defer m.dbMtx.RUnlock()
return m.databases[idx] return m.databases[idx]
} }
func (m *levelDbManager) getOrCreateDB(idx uint64) *sharedDB { func (m *levelDBManager) getOrCreateDB(idx uint64) *sharedDB {
m.dbMtx.Lock() m.dbMtx.Lock()
defer m.dbMtx.Unlock() defer m.dbMtx.Unlock()
@ -202,7 +202,7 @@ func (m *levelDbManager) getOrCreateDB(idx uint64) *sharedDB {
return db return db
} }
func (m *levelDbManager) hasAnyDB() bool { func (m *levelDBManager) hasAnyDB() bool {
m.dbMtx.RLock() m.dbMtx.RLock()
defer m.dbMtx.RUnlock() defer m.dbMtx.RUnlock()
@ -213,7 +213,7 @@ func (m *levelDbManager) hasAnyDB() bool {
// //
// The blobovnicza opens at the first request, closes after the last request. // The blobovnicza opens at the first request, closes after the last request.
type dbManager struct { type dbManager struct {
levelToManager map[string]*levelDbManager levelToManager map[string]*levelDBManager
levelToManagerGuard *sync.RWMutex levelToManagerGuard *sync.RWMutex
closedFlag *atomic.Bool closedFlag *atomic.Bool
dbCounter *openDBCounter dbCounter *openDBCounter
@ -231,7 +231,7 @@ func newDBManager(rootPath string, options []blobovnicza.Option, readOnly bool,
options: options, options: options,
readOnly: readOnly, readOnly: readOnly,
metrics: metrics, metrics: metrics,
levelToManager: make(map[string]*levelDbManager), levelToManager: make(map[string]*levelDBManager),
levelToManagerGuard: &sync.RWMutex{}, levelToManagerGuard: &sync.RWMutex{},
log: log, log: log,
closedFlag: &atomic.Bool{}, closedFlag: &atomic.Bool{},
@ -266,7 +266,7 @@ func (m *dbManager) Close() {
m.dbCounter.WaitUntilAllClosed() m.dbCounter.WaitUntilAllClosed()
} }
func (m *dbManager) getLevelManager(lvlPath string) *levelDbManager { func (m *dbManager) getLevelManager(lvlPath string) *levelDBManager {
result := m.getLevelManagerIfExists(lvlPath) result := m.getLevelManagerIfExists(lvlPath)
if result != nil { if result != nil {
return result return result
@ -274,14 +274,14 @@ func (m *dbManager) getLevelManager(lvlPath string) *levelDbManager {
return m.getOrCreateLevelManager(lvlPath) return m.getOrCreateLevelManager(lvlPath)
} }
func (m *dbManager) getLevelManagerIfExists(lvlPath string) *levelDbManager { func (m *dbManager) getLevelManagerIfExists(lvlPath string) *levelDBManager {
m.levelToManagerGuard.RLock() m.levelToManagerGuard.RLock()
defer m.levelToManagerGuard.RUnlock() defer m.levelToManagerGuard.RUnlock()
return m.levelToManager[lvlPath] return m.levelToManager[lvlPath]
} }
func (m *dbManager) getOrCreateLevelManager(lvlPath string) *levelDbManager { func (m *dbManager) getOrCreateLevelManager(lvlPath string) *levelDBManager {
m.levelToManagerGuard.Lock() m.levelToManagerGuard.Lock()
defer m.levelToManagerGuard.Unlock() defer m.levelToManagerGuard.Unlock()

4
pkg/local_object_storage/blobstor/blobovniczatree/rebuild.go
View file

@ -328,7 +328,7 @@ func (b *Blobovniczas) moveObject(ctx context.Context, source *blobovnicza.Blobo
return nil return nil
} }
func (b *Blobovniczas) dropDB(ctx context.Context, path string, shDb *sharedDB) (bool, error) { func (b *Blobovniczas) dropDB(ctx context.Context, path string, shDB *sharedDB) (bool, error) {
select { select {
case <-ctx.Done(): case <-ctx.Done():
return false, ctx.Err() return false, ctx.Err()
@ -341,7 +341,7 @@ func (b *Blobovniczas) dropDB(ctx context.Context, path string, shDb *sharedDB)
b.dbFilesGuard.Lock() b.dbFilesGuard.Lock()
defer b.dbFilesGuard.Unlock() defer b.dbFilesGuard.Unlock()
if err := shDb.CloseAndRemoveFile(ctx); err != nil { if err := shDB.CloseAndRemoveFile(ctx); err != nil {
return false, err return false, err
} }
b.commondbManager.CleanResources(path) b.commondbManager.CleanResources(path)

4
pkg/local_object_storage/pilorama/inmemory.go
View file

@ -192,7 +192,7 @@ func (t tree) getByPath(attr string, path []string, latest bool) []Node {
} }
var nodes []Node var nodes []Node
var lastTs Timestamp var lastTS Timestamp
children := t.getChildren(curNode) children := t.getChildren(curNode)
for i := range children { for i := range children {
@ -200,7 +200,7 @@ func (t tree) getByPath(attr string, path []string, latest bool) []Node {
fileName := string(info.Meta.GetAttr(attr)) fileName := string(info.Meta.GetAttr(attr))
if fileName == path[len(path)-1] { if fileName == path[len(path)-1] {
if latest { if latest {
if info.Meta.Time >= lastTs { if info.Meta.Time >= lastTS {
nodes = append(nodes[:0], children[i]) nodes = append(nodes[:0], children[i])
} }
} else { } else {