Skip to content

Commit 6330cb3

Browse files
author
Daniil Fedotov
committed
Log message store stopping
1 parent e18cd06 commit 6330cb3

File tree

1 file changed

+2
-0
lines changed

1 file changed

+2
-0
lines changed

src/rabbit_msg_store.erl

Lines changed: 2 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -985,6 +985,7 @@ terminate(_Reason, State = #msstate { index_state = IndexState,
985985
flying_ets = FlyingEts,
986986
clients = Clients,
987987
dir = Dir }) ->
988+
rabbit_log:info("Stopping message store for directory ~p", [Dir]),
988989
%% stop the gc first, otherwise it could be working and we pull
989990
%% out the ets tables from under it.
990991
ok = rabbit_msg_store_gc:stop(GCPid),
@@ -1001,6 +1002,7 @@ terminate(_Reason, State = #msstate { index_state = IndexState,
10011002
IndexModule:terminate(IndexState),
10021003
ok = store_recovery_terms([{client_refs, dict:fetch_keys(Clients)},
10031004
{index_module, IndexModule}], Dir),
1005+
rabbit_log:info("Message store is stopped for directory ~p", [Dir]),
10041006
State3 #msstate { index_state = undefined,
10051007
current_file_handle = undefined }.
10061008

0 commit comments

Comments
 (0)