Merge pull request #133 from SergeTupchiy/EMQX-9101-mnesia-unregister…

…-hook EMQX-9101 mnesia unregister hook
emqx · Mar 22, 2023 · 03e50ba · 03e50ba
2 parents a7686da + bb65dc0
commit 03e50ba
Show file tree

Hide file tree

Showing 3 changed files with 13 additions and 3 deletions.
diff --git a/.github/workflows/run_test_case.yaml b/.github/workflows/run_test_case.yaml
@@ -12,13 +12,13 @@ jobs:
             os:
               - ubuntu20.04
             otp:
-              - 24.3.4.2-1
-              - 25.1.2-2
+              - 24.3.4.2-3
+              - 25.1.2-3
             elixir:
               - 1.13.4
             arch:
               - amd64
-        container: ghcr.io/emqx/emqx-builder/5.0-26:${{ matrix.elixir }}-${{ matrix.otp }}-${{ matrix.os }}
+        container: ghcr.io/emqx/emqx-builder/5.0-33:${{ matrix.elixir }}-${{ matrix.otp }}-${{ matrix.os }}
 
         steps:
         - uses: actions/checkout@v1

diff --git a/src/mria_app.erl b/src/mria_app.erl
@@ -38,6 +38,7 @@ start(_Type, _Args) ->
     mria_sup:start_link().
 
 stop(_State) ->
+    mria_rlog:cleanup(),
     mria_config:erase_all_config(),
     ?tp(notice, "Mria is stopped", #{}).
 

diff --git a/src/mria_rlog.erl b/src/mria_rlog.erl
@@ -30,6 +30,7 @@
         , subscribe/4
         , wait_for_shards/2
         , init/0
+        , cleanup/0
 
         , intercept_trans/2
         , ensure_shard/1
@@ -212,3 +213,11 @@ init() ->
         _ ->
             ok
     end.
+
+cleanup() ->
+    case mria_config:whoami() of
+        core ->
+            mnesia_hook:unregister_hook(post_commit);
+        _ ->
+            ok
+    end.