diff options
| author | Tim Watson <tim@rabbitmq.com> | 2013-12-20 13:43:16 +0000 |
|---|---|---|
| committer | Tim Watson <tim@rabbitmq.com> | 2013-12-20 13:43:16 +0000 |
| commit | b74ce00920bc9f8165fd3d493f4ae88c81be2d38 (patch) | |
| tree | f3dbf893ffc49c39696e0fe5bb2020c33e954651 /src | |
| parent | 67adf2465cbf852317fd6ade0c0d6892bd1a1850 (diff) | |
| download | rabbitmq-server-git-b74ce00920bc9f8165fd3d493f4ae88c81be2d38.tar.gz | |
Trap exits and ensure we close the table on shutdown
Diffstat (limited to 'src')
| -rw-r--r-- | src/rabbit_recovery_terms.erl | 4 |
1 files changed, 3 insertions, 1 deletions
diff --git a/src/rabbit_recovery_terms.erl b/src/rabbit_recovery_terms.erl index f8138e0e4a..558604ccea 100644 --- a/src/rabbit_recovery_terms.erl +++ b/src/rabbit_recovery_terms.erl @@ -120,6 +120,7 @@ flush() -> ok. init(_) -> + process_flag(trap_exit, true), create_table(), {ok, undefined}. @@ -133,7 +134,8 @@ handle_info(_Info, State) -> {noreply, State}. terminate(_Reason, _State) -> - ok = dets:sync(?MODULE). + ok = dets:sync(?MODULE), + ok = dets:close(?MODULE). code_change(_OldVsn, State, _Extra) -> {ok, State}. |