diff options
| author | David Ansari <david.ansari@gmx.de> | 2022-08-04 10:49:14 +0000 |
|---|---|---|
| committer | David Ansari <david.ansari@gmx.de> | 2022-08-04 16:25:30 +0200 |
| commit | 93ad8017098dd6ea17c66508d99033a4dd618569 (patch) | |
| tree | 77a407775135fb2174c31ba3234ee9ad22272fcd | |
| parent | ef13342db9d666e1f8f379f3b3feb1d076e14ce1 (diff) | |
| download | rabbitmq-server-git-93ad8017098dd6ea17c66508d99033a4dd618569.tar.gz | |
Log at debug level when "global hang workaround" is applied
because it outputs the whole process state of global_name_server.
Also, fix erroneous comments.
(cherry picked from commit 2a1f27d02cec868be20717c30e9b328751d49113)
| -rw-r--r-- | deps/rabbit/src/rabbit_node_monitor.erl | 12 |
1 files changed, 6 insertions, 6 deletions
diff --git a/deps/rabbit/src/rabbit_node_monitor.erl b/deps/rabbit/src/rabbit_node_monitor.erl index 291bae00ad..447dde637f 100644 --- a/deps/rabbit/src/rabbit_node_monitor.erl +++ b/deps/rabbit/src/rabbit_node_monitor.erl @@ -276,13 +276,13 @@ pause_if_all_down_guard(PreferredNodes, LastNodes, LastState) -> %% state, causing global:sync/0 to never return. %% %% 1. A process is spawned. -%% 2. If after 15", global:sync() didn't return, the "global" +%% 2. If after 10", global:sync() didn't return, the "global" %% state is parsed. %% 3. If it detects that a sync is blocked for more than 10", %% the process sends fake nodedown/nodeup events to the two %% nodes involved (one local, one remote). %% 4. Both "global" instances restart their synchronisation. -%% 5. globao:sync() finally returns. +%% 5. global:sync() finally returns. %% %% FIXME: Remove this workaround, once we got rid of the change to %% "dist_auto_connect" and fixed the bugs uncovered. @@ -297,13 +297,13 @@ workaround_global_hang() -> receive global_sync_done -> ok - after 10000 -> + after 10_000 -> find_blocked_global_peers() end. find_blocked_global_peers() -> Snapshot1 = snapshot_global_dict(), - timer:sleep(10000), + timer:sleep(10_000), Snapshot2 = snapshot_global_dict(), find_blocked_global_peers1(Snapshot2, Snapshot1). @@ -324,8 +324,8 @@ find_blocked_global_peers1([], _) -> unblock_global_peer(PeerNode) -> ThisNode = node(), PeerState = rpc:call(PeerNode, sys, get_status, [global_name_server]), - logger:info( - "Global hang workaround: global state on ~s seems broken~n" + logger:debug( + "Global hang workaround: global state on ~s seems inconsistent~n" " * Peer global state: ~p~n" " * Local global state: ~p~n" "Faking nodedown/nodeup between ~s and ~s", |