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

Fix TestEvacuateShard #508

Merged
fyrchik merged 1 commit from dstepanov-yadro/frostfs-node:fix/evacuate_test into master 2023-07-17 10:24:07 +00:00
Conversation 4 Commits 1 Files changed 2 +2 -1
2 changed files with 2 additions and 1 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

2
pkg/local_object_storage/engine/evacuate_test.go
View file

@ -28,7 +28,7 @@ import (
func newEngineEvacuate(t *testing.T, shardNum int, objPerShard int) (*StorageEngine, []*shard.ID, []*objectSDK.Object) { func newEngineEvacuate(t *testing.T, shardNum int, objPerShard int) (*StorageEngine, []*shard.ID, []*objectSDK.Object) {
dir := t.TempDir() dir := t.TempDir()
te := testNewEngine(t, WithShardPoolSize(1)). te := testNewEngine(t).
setShardsNumOpts(t, shardNum, func(id int) []shard.Option { setShardsNumOpts(t, shardNum, func(id int) []shard.Option {
return []shard.Option{ return []shard.Option{
shard.WithLogger(&logger.Logger{Logger: zaptest.NewLogger(t)}), shard.WithLogger(&logger.Logger{Logger: zaptest.NewLogger(t)}),

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

@ -154,6 +154,7 @@ func (e *StorageEngine) putToShard(ctx context.Context, sh hashedShard, ind int,
putSuccess = true putSuccess = true
}); err != nil { }); err != nil {
e.log.Warn(logs.EngineCouldNotPutObjectToShard, zap.Error(err))
close(exitCh) close(exitCh)
} }