From bb752f1025b0bec591e3a1d8a7f66d2846d3a874 Mon Sep 17 00:00:00 2001 From: Martin Sumner Date: Tue, 10 Apr 2018 09:54:35 +0100 Subject: [PATCH] de-terminate bookie --- src/leveled_bookie.erl | 32 ++++++++++++++++---------------- 1 file changed, 16 insertions(+), 16 deletions(-) diff --git a/src/leveled_bookie.erl b/src/leveled_bookie.erl index a97f4af..cdfdb32 100644 --- a/src/leveled_bookie.erl +++ b/src/leveled_bookie.erl @@ -742,6 +742,20 @@ handle_call(trim, _From, State) when State#state.head_only == true -> PSQN = leveled_penciller:pcl_persistedsqn(State#state.penciller), {reply, leveled_inker:ink_trim(State#state.inker, PSQN), State}; handle_call(close, _From, State) -> + ok = + case is_process_alive(State#state.inker) of + true -> + leveled_inker:ink_close(State#state.inker); + false -> + ok + end, + ok = + case is_process_alive(State#state.penciller) of + true -> + leveled_penciller:pcl_close(State#state.penciller); + false -> + ok + end, {stop, normal, ok, State}; handle_call(destroy, _From, State=#state{is_snapshot=Snp}) when Snp == false -> leveled_log:log("B0011", []), @@ -759,22 +773,8 @@ handle_cast(_Msg, State) -> handle_info(_Info, State) -> {noreply, State}. -terminate(Reason, State) -> - leveled_log:log("B0003", [Reason]), - ok = - case is_process_alive(State#state.inker) of - true -> - leveled_inker:ink_close(State#state.inker); - false -> - ok - end, - ok = - case is_process_alive(State#state.penciller) of - true -> - leveled_penciller:pcl_close(State#state.penciller); - false -> - ok - end. +terminate(Reason, _State) -> + leveled_log:log("B0003", [Reason]). code_change(_OldVsn, State, _Extra) -> {ok, State}.