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

[#67] node: Make engine's IsLocked public

Browse source 
It will allow reusing that method in expiration checks.

Signed-off-by: Pavel Karpy <p.karpy@yadro.com>
This commit is contained in:
Pavel Karpy 2023-03-15 03:42:49 +03:00
parent 22be532cbd
commit f006f3b342
1 changed files with 3 additions and 2 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

5
pkg/local_object_storage/engine/inhume.go
View file

@ -81,7 +81,7 @@ func (e *StorageEngine) inhume(prm InhumePrm) (InhumeRes, error) {
for i := range prm.addrs { for i := range prm.addrs {
if !prm.forceRemoval { if !prm.forceRemoval {
locked, err := e.isLocked(prm.addrs[i]) locked, err := e.IsLocked(prm.addrs[i])
if err != nil { if err != nil {
e.log.Warn("removing an object without full locking check", e.log.Warn("removing an object without full locking check",
zap.Error(err), zap.Error(err),
@ -179,7 +179,8 @@ func (e *StorageEngine) inhumeAddr(addr oid.Address, prm shard.InhumePrm, checkE
return ok, retErr return ok, retErr
} }
func (e *StorageEngine) isLocked(addr oid.Address) (bool, error) { // IsLocked checks whether an object is locked according to StorageEngine's state.
func (e *StorageEngine) IsLocked(addr oid.Address) (bool, error) {
var locked bool var locked bool
var err error var err error
var outErr error var outErr error