From b4fdc49194657e6f1394db4c14ad1185d3737486 Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?M=C3=A1rton=20Elek?= Date: Mon, 18 Sep 2023 13:59:12 +0200 Subject: [PATCH] satellite/repair/checker: persist placement information to the queue Change-Id: I51c7fd5a2a38f9f6620c16eddaed3b4915ffd792 --- satellite/repair/checker/observer.go | 1 + satellite/repair/checker/observer_test.go | 4 +++- 2 files changed, 4 insertions(+), 1 deletion(-) diff --git a/satellite/repair/checker/observer.go b/satellite/repair/checker/observer.go index 1d95556b8..970af0af6 100644 --- a/satellite/repair/checker/observer.go +++ b/satellite/repair/checker/observer.go @@ -405,6 +405,7 @@ func (fork *observerFork) process(ctx context.Context, segment *rangedloop.Segme Position: segment.Position, UpdatedAt: time.Now().UTC(), SegmentHealth: segmentHealth, + Placement: segment.Placement, }, func() { // Counters are increased after the queue has determined // that the segment wasn't already queued for repair. diff --git a/satellite/repair/checker/observer_test.go b/satellite/repair/checker/observer_test.go index 782789f91..110464d1b 100644 --- a/satellite/repair/checker/observer_test.go +++ b/satellite/repair/checker/observer_test.go @@ -607,7 +607,7 @@ func TestObserver_PlacementCheck(t *testing.T) { _, err := planet.Satellites[0].API.Buckets.Service.UpdateBucket(ctx, buckets.Bucket{ ProjectID: planet.Uplinks[0].Projects[0].ID, Name: "testbucket", - Placement: storj.EU, + Placement: storj.PlacementConstraint(1), }) require.NoError(t, err) @@ -672,6 +672,8 @@ func TestObserver_PlacementCheck(t *testing.T) { require.NoError(t, err) require.Equal(t, segments[0].StreamID, injuredSegment.StreamID) + require.Equal(t, segments[0].Placement, injuredSegment.Placement) + require.Equal(t, storj.PlacementConstraint(1), injuredSegment.Placement) count, err := repairQueue.Count(ctx) require.Zero(t, err)