We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent 1cfddf5 commit ec6d517Copy full SHA for ec6d517
src/mria_status.erl
@@ -86,7 +86,12 @@ start_link() ->
86
%% as compared with `get_core_node'.
87
-spec upstream_node(mria_rlog:shard(), timeout()) -> {ok, node()} | timeout.
88
upstream_node(Shard, Timeout) ->
89
- optvar:read(?optvar({?core_node, Shard}), Timeout).
+ case optvar:read(?optvar({?upstream_pid, Shard}), Timeout) of
90
+ {ok, Pid} ->
91
+ {ok, node(Pid)};
92
+ timeout ->
93
+ timeout
94
+ end.
95
96
%% @doc Return pid of the core node agent that serves us.
97
-spec upstream(mria_rlog:shard()) -> {ok, pid()} | disconnected.
0 commit comments