Skip to content

Commit 8fc1655

Browse files
committed
kvserver: call subsumption code unconditionally
It works (or should work, based on my reading) when there are no subsumed descs and in that case is a no-op.
1 parent 91590ed commit 8fc1655

File tree

1 file changed

+11
-10
lines changed

1 file changed

+11
-10
lines changed

pkg/kv/kvserver/snapshot_apply_prepare.go

Lines changed: 11 additions & 10 deletions
Original file line numberDiff line numberDiff line change
@@ -39,7 +39,11 @@ type prepareSnapApplyInput struct {
3939
// prepareSnapApply writes the unreplicated SST for the snapshot and clears disk data for subsumed replicas.
4040
func prepareSnapApply(
4141
ctx context.Context, input prepareSnapApplyInput,
42-
) (clearedUnreplicatedSpan roachpb.Span, clearedSubsumedSpans []roachpb.Span, _ error) {
42+
) (
43+
roachpb.Span, // clearedUnreplicatedSpan
44+
[]roachpb.Span, // clearedSubsumedSpans
45+
error,
46+
) {
4347
// Step 1: Write unreplicated SST
4448
unreplicatedSSTFile, clearedUnreplicatedSpan, err := writeUnreplicatedSST(
4549
ctx, input.id, input.st, input.truncState, input.hardState, input.logSL,
@@ -51,15 +55,12 @@ func prepareSnapApply(
5155
return roachpb.Span{}, nil, err
5256
}
5357

54-
if len(input.subsumedDescs) > 0 {
55-
spans, err := clearSubsumedReplicaDiskData(
56-
ctx, input.st, input.todoEng, input.writeSST,
57-
input.desc, input.subsumedDescs,
58-
)
59-
if err != nil {
60-
return roachpb.Span{}, nil, err
61-
}
62-
clearedSubsumedSpans = spans
58+
clearedSubsumedSpans, err := clearSubsumedReplicaDiskData(
59+
ctx, input.st, input.todoEng, input.writeSST,
60+
input.desc, input.subsumedDescs,
61+
)
62+
if err != nil {
63+
return roachpb.Span{}, nil, err
6364
}
6465

6566
return clearedUnreplicatedSpan, clearedSubsumedSpans, nil

0 commit comments

Comments
 (0)