diff options
author | Sverker Eriksson <[email protected]> | 2016-06-02 17:50:41 +0200 |
---|---|---|
committer | Sverker Eriksson <[email protected]> | 2016-08-11 18:15:00 +0200 |
commit | b1b0fe831e1e3a048f09db0c6b0a601e0db62779 (patch) | |
tree | 6ca2773953b8014adc58501ead712c2affaca08d /lib/kernel/src/dist_util.erl | |
parent | 1def6a4b0eeb5d5a78fd76e97a5b7b4bcd06f185 (diff) | |
download | otp-b1b0fe831e1e3a048f09db0c6b0a601e0db62779.tar.gz otp-b1b0fe831e1e3a048f09db0c6b0a601e0db62779.tar.bz2 otp-b1b0fe831e1e3a048f09db0c6b0a601e0db62779.zip |
kernel: Refactor dist_util:con_loop
by separating the constant values into tuple ConData.
and that exposed the fact that TcpAddress and MyNode
where not used.
Diffstat (limited to 'lib/kernel/src/dist_util.erl')
-rw-r--r-- | lib/kernel/src/dist_util.erl | 32 |
1 files changed, 12 insertions, 20 deletions
diff --git a/lib/kernel/src/dist_util.erl b/lib/kernel/src/dist_util.erl index 47d0c1b861..8509a01608 100644 --- a/lib/kernel/src/dist_util.erl +++ b/lib/kernel/src/dist_util.erl @@ -350,15 +350,13 @@ connection(#hs_data{other_node = Node, mark_nodeup(HSData,Address), case FPostNodeup(Socket) of ok -> - con_loop(HSData#hs_data.kernel_pid, - Node, - Socket, - Address, - HSData#hs_data.this_node, - PType, - #tick{}, - HSData#hs_data.mf_tick, - HSData#hs_data.mf_getstat); + con_loop({HSData#hs_data.kernel_pid, + Node, + Socket, + PType, + HSData#hs_data.mf_tick, + HSData#hs_data.mf_getstat}, + #tick{}); _ -> ?shutdown2(Node, connection_setup_failed) end; @@ -454,8 +452,8 @@ mark_nodeup(#hs_data{kernel_pid = Kernel, ?shutdown(Node) end. -con_loop(Kernel, Node, Socket, TcpAddress, - MyNode, Type, Tick, MFTick, MFGetstat) -> +con_loop({Kernel, Node, Socket, Type, MFTick, MFGetstat}=ConData, + Tick) -> receive {tcp_closed, Socket} -> ?shutdown2(Node, connection_closed); @@ -468,15 +466,12 @@ con_loop(Kernel, Node, Socket, TcpAddress, _ -> ignore_it end, - con_loop(Kernel, Node, Socket, TcpAddress, MyNode, Type, - Tick, MFTick, MFGetstat); + con_loop(ConData, Tick); {Kernel, tick} -> case send_tick(Socket, Tick, Type, MFTick, MFGetstat) of {ok, NewTick} -> - con_loop(Kernel, Node, Socket, TcpAddress, - MyNode, Type, NewTick, MFTick, - MFGetstat); + con_loop(ConData, NewTick); {error, not_responding} -> error_msg("** Node ~p not responding **~n" "** Removing (timedout) connection **~n", @@ -489,10 +484,7 @@ con_loop(Kernel, Node, Socket, TcpAddress, case MFGetstat(Socket) of {ok, Read, Write, _} -> From ! {self(), get_status, {ok, Read, Write}}, - con_loop(Kernel, Node, Socket, TcpAddress, - MyNode, - Type, Tick, - MFTick, MFGetstat); + con_loop(ConData, Tick); _ -> ?shutdown2(Node, get_status_failed) end |