Skip to content

Commit e3ea015

Browse files
committed
revert accidental change
1 parent b1da8e5 commit e3ea015

File tree

1 file changed

+1
-8
lines changed

1 file changed

+1
-8
lines changed

src/ra_log_segment_writer.erl

Lines changed: 1 addition & 8 deletions
Original file line numberDiff line numberDiff line change
@@ -330,7 +330,6 @@ flush_mem_table_range(ServerUId, {Tid, Seq},
330330
#state{data_dir = DataDir,
331331
segment_conf = SegConf} = State) ->
332332
Dir = filename:join(DataDir, binary_to_list(ServerUId)),
333-
% StartIdx = start_index(ServerUId, StartIdx0),
334333
case open_file(Dir, SegConf) of
335334
enoent ->
336335
?DEBUG("segment_writer: skipping segment as directory ~ts does "
@@ -522,13 +521,7 @@ open_file(Dir, SegConf) ->
522521
%% existing which could happen after server deletion
523522
case ra_log_segment:open(File, SegConf#{mode => append}) of
524523
{ok, Segment} ->
525-
case ra_log_segment:segref(Segment) of
526-
undefined ->
527-
Segment;
528-
_ ->
529-
%% has entries, open successor
530-
open_successor_segment(Segment, SegConf)
531-
end;
524+
Segment;
532525
{error, missing_segment_header} ->
533526
%% a file was created by the segment header had not been
534527
%% synced. In this case it is typically safe to just delete

0 commit comments

Comments
 (0)