yuanbiao
/
emqx
1
0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

fix: bpapi undef abort on old node

This commit is contained in:
zhongwencool 2024-03-26 13:06:56 +08:00
parent c8487d8890
commit 56a40d61ae
1 changed files with 4 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

9
apps/emqx/src/bpapi/emqx_bpapi.erl
View File

@ -88,11 +88,10 @@ announce(Node, App) ->
{ok, Data} = file:consult(?MODULE:versions_file(App)), {ok, Data} = file:consult(?MODULE:versions_file(App)),
%% replicant(5.6.0) will call old core(<5.6.0) announce_fun/2 is undef on old core %% replicant(5.6.0) will call old core(<5.6.0) announce_fun/2 is undef on old core
%% so we just use anonymous function to update. %% so we just use anonymous function to update.
try case mria:transaction(?COMMON_SHARD, fun ?MODULE:announce_fun/2, [Node, Data]) of
{atomic, ok} = mria:transaction(?COMMON_SHARD, fun ?MODULE:announce_fun/2, [Node, Data]), {atomic, ok} ->
ok ok;
catch {aborted, {undef, [{?MODULE, announce_fun, _, _} | _]}} ->
error:undef ->
{atomic, ok} = mria:transaction( {atomic, ok} = mria:transaction(
?COMMON_SHARD, ?COMMON_SHARD,
fun() -> fun() ->