|
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