From f17613b5f7db7689d7983914e9b12da0d2bc0929 Mon Sep 17 00:00:00 2001 From: Maciej Szlosarczyk Date: Thu, 11 Jul 2019 10:06:16 +0300 Subject: [PATCH] Reformat code --- apps/epp_proxy/src/epp_tcp_worker.erl | 23 ++++++++++++----------- 1 file changed, 12 insertions(+), 11 deletions(-) diff --git a/apps/epp_proxy/src/epp_tcp_worker.erl b/apps/epp_proxy/src/epp_tcp_worker.erl index fb21dba..e04894e 100644 --- a/apps/epp_proxy/src/epp_tcp_worker.erl +++ b/apps/epp_proxy/src/epp_tcp_worker.erl @@ -98,9 +98,9 @@ handle_cast(process_command, %% Else, go back to the beginning of the loop. if Command =:= "logout" -> case gen_tcp:shutdown(Socket, read_write) of - ok -> {stop, normal, State}; - {error, closed} -> {stop, normal, State} - end; + ok -> {stop, normal, State}; + {error, closed} -> {stop, normal, State} + end; true -> gen_server:cast(self(), process_command), {noreply, @@ -135,13 +135,13 @@ state_from_socket(Socket, State) -> frame_from_socket(Socket, State) -> case gen_tcp:recv(Socket, 0, ?DefaultTimeout) of - {ok, Data} -> - EPPEnvelope = binary:part(Data, {0, 4}), - ReportedLength = binary:decode_unsigned(EPPEnvelope, - big), - read_until_exhausted(Socket, ReportedLength, Data); - {error, closed} -> log_and_exit(State); - {error, timeout} -> log_on_timeout(State) + {ok, Data} -> + EPPEnvelope = binary:part(Data, {0, 4}), + ReportedLength = binary:decode_unsigned(EPPEnvelope, + big), + read_until_exhausted(Socket, ReportedLength, Data); + {error, closed} -> log_and_exit(State); + {error, timeout} -> log_on_timeout(State) end. %% When an EPP message is long, it will be received in smaller chunks. @@ -156,7 +156,8 @@ read_until_exhausted(Socket, ExpectedLength, Frame) -> binary:part(Frame, {byte_size(Frame), 4 - ExpectedLength}); ExpectedLength > byte_size(Frame) -> - {ok, NextFrame} = gen_tcp:recv(Socket, 0, ?DefaultTimeout), + {ok, NextFrame} = gen_tcp:recv(Socket, 0, + ?DefaultTimeout), NewFrame = <>, read_until_exhausted(Socket, ExpectedLength, NewFrame) end.