|
94 | 94 |
|
95 | 95 | -compile({no_auto_import, [get/1, get/2, nodes/0]}).
|
96 | 96 |
|
| 97 | +%% `sys:get_status/1''s spec only allows `sys:name()' but can work on any |
| 98 | +%% `erlang:send_destination()' including a `ra:server_id()'. |
| 99 | +-dialyzer({nowarn_function, get_sys_status/1}). |
| 100 | +-dialyzer({no_match, [status/0, cluster_status_from_khepri/0]}). |
| 101 | + |
97 | 102 | -define(RA_SYSTEM, coordination).
|
98 | 103 | -define(RA_CLUSTER_NAME, metadata_store).
|
99 | 104 | -define(RA_FRIENDLY_NAME, "RabbitMQ metadata store").
|
@@ -157,8 +162,7 @@ add_member(JoiningNode, [_ | _] = Cluster) ->
|
157 | 162 | {ok, already_member}
|
158 | 163 | end.
|
159 | 164 |
|
160 |
| -pick_node_in_cluster(Cluster) when is_list(Cluster) -> |
161 |
| - ?assertNotEqual([], Cluster), |
| 165 | +pick_node_in_cluster([_ | _] = Cluster) when is_list(Cluster) -> |
162 | 166 | ThisNode = node(),
|
163 | 167 | case lists:member(ThisNode, Cluster) of
|
164 | 168 | true -> ThisNode;
|
@@ -404,6 +408,7 @@ status() ->
|
404 | 408 | end
|
405 | 409 | end || N <- Nodes].
|
406 | 410 |
|
| 411 | + |
407 | 412 | get_sys_status(Proc) ->
|
408 | 413 | try lists:nth(5, element(4, sys:get_status(Proc))) of
|
409 | 414 | Sys -> {ok, Sys}
|
@@ -540,7 +545,7 @@ check_cluster_consistency() ->
|
540 | 545 | {error, not_found} ->
|
541 | 546 | ok;
|
542 | 547 | {error, _} = E ->
|
543 |
| - throw(E) |
| 548 | + E |
544 | 549 | end.
|
545 | 550 |
|
546 | 551 | nodes_excl_me(Nodes) -> Nodes -- [node()].
|
|
0 commit comments