Send into the alias in cets_mon_cleaner

esl · Jul 28, 2023 · ca9d9b5 · ca9d9b5
1 parent e417050
commit ca9d9b5
Show file tree

Hide file tree

Showing 2 changed files with 8 additions and 4 deletions.
diff --git a/src/cets_mon_cleaner.erl b/src/cets_mon_cleaner.erl
@@ -97,16 +97,16 @@ handle_erase(State) ->
     maps:foreach(fun send_down_all/2, State),
     maps:with(state_keys(), State).
 
-send_down_all(Mon, Pid) when is_reference(Mon) ->
-    Pid ! {cets_remote_down, Mon, all};
+send_down_all(Mon, _Pid) when is_reference(Mon) ->
+    Mon ! {cets_remote_down, Mon, all};
 send_down_all(_Key, _Val) ->
     true.
 
 handle_remote_down(Num, State) ->
     maps:foreach(fun(K, V) -> send_remote_down(K, V, Num) end, State),
     State.
 
-send_remote_down(Mon, Pid, Num) when is_reference(Mon) ->
-    Pid ! {cets_remote_down, Mon, Num};
+send_remote_down(Mon, _Pid, Num) when is_reference(Mon) ->
+    Mon ! {cets_remote_down, Mon, Num};
 send_remote_down(_Key, _Val, _Num) ->
     true.
diff --git a/test/cets_SUITE.erl b/test/cets_SUITE.erl
@@ -630,6 +630,10 @@ remote_down_is_not_received_after_timeout(Config) ->
     Ref = erlang:monitor(process, Pid2),
     exit(Pid2, kill),
     receive_down_for_monitor(Ref),
+    MonProc = remote_down_is_not_received_after_timeout_1_mon,
+    MonProc ! check,
+    %% Ensure check processed
+    gen_server:call(MonProc, dump),
     ensure_no_down_message().
 
 start(Node, Tab) ->