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

perf(emqx_router): optimise trans result receive

This commit is contained in:
Zaiming Shi 2021-05-05 20:10:42 +02:00 committed by Zaiming (Stone) Shi
parent 84e032f2e1
commit eeffc209df
1 changed files with 7 additions and 11 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

18
src/emqx_router.erl
View File

@ -271,24 +271,20 @@ maybe_trans(Fun, Args) ->
trans(Fun, Args) -> trans(Fun, Args) ->
%% trigger selective receive optimization of compiler, %% trigger selective receive optimization of compiler,
%% ideal for handling bursty traffic. %% ideal for handling bursty traffic.
Ref = erlang:make_ref(), {_, RefMon} = spawn_monitor(
Owner = self(),
{WPid, RefMon} = spawn_monitor(
fun() -> fun() ->
Res = case mnesia:transaction(Fun, Args) of Res = case mnesia:transaction(Fun, Args) of
{atomic, Ok} -> Ok; {atomic, Ok} -> Ok;
{aborted, Reason} -> {error, Reason} {aborted, Reason} -> {error, Reason}
end, end,
Owner ! {Ref, Res} exit({shutdown, Res})
end), end),
receive receive
{Ref, TransRes} -> {'DOWN', RefMon, process, _, Info} ->
receive case Info of
{'DOWN', RefMon, process, WPid, normal} -> ok {shutdown, Res} -> Res;
end, _ -> {error, {trans_crash, Info}}
TransRes; end
{'DOWN', RefMon, process, WPid, Info} ->
{error, {trans_crash, Info}}
end. end.
lock_router() -> lock_router() ->