Browse Source

Flush monitor messages after demonitoring.

Roberto Ostinelli 5 years ago
parent
commit
11a3d2749d
2 changed files with 2 additions and 2 deletions
  1. 1 1
      src/syn_groups.erl
  2. 1 1
      src/syn_registry.erl

+ 1 - 1
src/syn_groups.erl

@@ -408,7 +408,7 @@ leave_on_node(GroupName, Pid) ->
             case find_processes_entry_by_pid(Pid) of
             case find_processes_entry_by_pid(Pid) of
                 [Entry] ->
                 [Entry] ->
                     %% demonitor
                     %% demonitor
-                    erlang:demonitor(Entry#syn_groups_table.monitor_ref);
+                    erlang:demonitor(Entry#syn_groups_table.monitor_ref, [flush]);
                 _ ->
                 _ ->
                     ok
                     ok
             end,
             end,

+ 1 - 1
src/syn_registry.erl

@@ -411,7 +411,7 @@ unregister_on_node(Name) ->
 
 
         Entry when Entry#syn_registry_table.monitor_ref =/= undefined ->
         Entry when Entry#syn_registry_table.monitor_ref =/= undefined ->
             %% demonitor
             %% demonitor
-            erlang:demonitor(Entry#syn_registry_table.monitor_ref),
+            erlang:demonitor(Entry#syn_registry_table.monitor_ref, [flush]),
             %% remove from table
             %% remove from table
             remove_from_local_table(Name);
             remove_from_local_table(Name);