Skip to content

Commit 91590ed

Browse files
committed
kvserver: remove prepareSnapApply return type
1 parent 9fb67f9 commit 91590ed

File tree

2 files changed

+11
-20
lines changed

2 files changed

+11
-20
lines changed

pkg/kv/kvserver/replica_raftstorage.go

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -552,12 +552,12 @@ func (r *Replica) applySnapshotRaftMuLocked(
552552
subsumedDescs: subsumedDescs,
553553
}
554554

555-
prepResult, err := prepareSnapApply(ctx, prepInput)
555+
clearedUnreplicatedSpan, clearedSubsumedSpans, err := prepareSnapApply(ctx, prepInput)
556556
if err != nil {
557557
return err
558558
}
559-
clearedSpans = append(clearedSpans, prepResult.clearedUnreplicatedSpan)
560-
clearedSpans = append(clearedSpans, prepResult.clearedSubsumedSpans...)
559+
clearedSpans = append(clearedSpans, clearedUnreplicatedSpan)
560+
clearedSpans = append(clearedSpans, clearedSubsumedSpans...)
561561

562562
// Drop the entry cache before ingestion, like a real truncation would.
563563
//

pkg/kv/kvserver/snapshot_apply_prepare.go

Lines changed: 8 additions & 17 deletions
Original file line numberDiff line numberDiff line change
@@ -36,42 +36,33 @@ type prepareSnapApplyInput struct {
3636
subsumedDescs []*roachpb.RangeDescriptor
3737
}
3838

39-
// preparedSnapApply contains the results of preparing the snapshot for ingestion.
40-
// TODO: remove
41-
type preparedSnapApply struct {
42-
clearedUnreplicatedSpan roachpb.Span
43-
clearedSubsumedSpans []roachpb.Span
44-
}
45-
4639
// prepareSnapApply writes the unreplicated SST for the snapshot and clears disk data for subsumed replicas.
47-
func prepareSnapApply(ctx context.Context, input prepareSnapApplyInput) (preparedSnapApply, error) {
40+
func prepareSnapApply(
41+
ctx context.Context, input prepareSnapApplyInput,
42+
) (clearedUnreplicatedSpan roachpb.Span, clearedSubsumedSpans []roachpb.Span, _ error) {
4843
// Step 1: Write unreplicated SST
49-
unreplicatedSSTFile, clearedSpan, err := writeUnreplicatedSST(
44+
unreplicatedSSTFile, clearedUnreplicatedSpan, err := writeUnreplicatedSST(
5045
ctx, input.id, input.st, input.truncState, input.hardState, input.logSL,
5146
)
5247
if err != nil {
53-
return preparedSnapApply{}, err
48+
return roachpb.Span{}, nil, err
5449
}
5550
if err := input.writeSST(ctx, unreplicatedSSTFile.Data()); err != nil {
56-
return preparedSnapApply{}, err
51+
return roachpb.Span{}, nil, err
5752
}
5853

59-
var clearedSubsumedSpans []roachpb.Span
6054
if len(input.subsumedDescs) > 0 {
6155
spans, err := clearSubsumedReplicaDiskData(
6256
ctx, input.st, input.todoEng, input.writeSST,
6357
input.desc, input.subsumedDescs,
6458
)
6559
if err != nil {
66-
return preparedSnapApply{}, err
60+
return roachpb.Span{}, nil, err
6761
}
6862
clearedSubsumedSpans = spans
6963
}
7064

71-
return preparedSnapApply{
72-
clearedUnreplicatedSpan: clearedSpan,
73-
clearedSubsumedSpans: clearedSubsumedSpans,
74-
}, nil
65+
return clearedUnreplicatedSpan, clearedSubsumedSpans, nil
7566
}
7667

7768
// writeUnreplicatedSST creates an SST for snapshot application that

0 commit comments

Comments
 (0)