diff --git a/internal/datanode/segment_replica.go b/internal/datanode/segment_replica.go index 94ca07ccd7..997f68885f 100644 --- a/internal/datanode/segment_replica.go +++ b/internal/datanode/segment_replica.go @@ -155,6 +155,8 @@ func (replica *SegmentReplica) new2FlushedSegment(segID UniqueID) { delete(replica.newSegments, segID) } +// normal2FlushedSegment transfers a segment from *normal* to *flushed* by changing *isFlushed* +// flag into true, and mv the segment from normalSegments map to flushedSegments map. func (replica *SegmentReplica) normal2FlushedSegment(segID UniqueID) { var seg Segment = *replica.normalSegments[segID]