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

[#1225] engine: Log the error when check object existence

Browse source 
Signed-off-by: Anton Nikiforov <an.nikiforov@yadro.com>
This commit is contained in:
Anton Nikiforov 2024-07-03 17:14:47 +03:00 committed by Evgenii Stratonikov
parent 80d7459560
commit bbe95dac8b
2 changed files with 6 additions and 0 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

1
internal/logs/logs.go
View file

@ -205,6 +205,7 @@ const (
EngineCouldNotReloadAShard = "could not reload a shard" EngineCouldNotReloadAShard = "could not reload a shard"
EngineAddedNewShard = "added new shard" EngineAddedNewShard = "added new shard"
EngineCouldNotPutObjectToShard = "could not put object to shard" EngineCouldNotPutObjectToShard = "could not put object to shard"
EngineCouldNotCheckObjectExistence = "could not check object existence when put object to shard"
EngineErrorDuringSearchingForObjectChildren = "error during searching for object children" EngineErrorDuringSearchingForObjectChildren = "error during searching for object children"
EngineCouldNotInhumeObjectInShard = "could not inhume object in shard" EngineCouldNotInhumeObjectInShard = "could not inhume object in shard"
EngineStartingRemovalOfLocallyredundantCopies = "starting removal of locally-redundant copies" EngineStartingRemovalOfLocallyredundantCopies = "starting removal of locally-redundant copies"

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

@ -149,6 +149,11 @@ func (e *StorageEngine) putToShard(ctx context.Context, sh hashedShard, pool uti
// object is already found but // object is already found but
// expired => do nothing with it // expired => do nothing with it
res.status = putToShardExists res.status = putToShardExists
} else {
e.log.Warn(logs.EngineCouldNotCheckObjectExistence,
zap.Stringer("shard_id", sh.ID()),
zap.String("error", err.Error()),
zap.String("trace_id", tracingPkg.GetTraceID(ctx)))
} }
return // this is not ErrAlreadyRemoved error so we can go to the next shard return // this is not ErrAlreadyRemoved error so we can go to the next shard