anlicheng/ekfa
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

fix tcp_server

Browse Source
This commit is contained in:
anlicheng 2025-05-09 21:33:05 +08:00
parent ebcaba4a14
commit 77d3b765d7
1 changed files with 4 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

8
apps/efka/src/efka_tcp_server.erl
View File

@ -22,10 +22,10 @@ init() ->
case gen_tcp:listen(Port, [binary, {packet, 4}, {active, false}, {reuseaddr, true}]) of case gen_tcp:listen(Port, [binary, {packet, 4}, {active, false}, {reuseaddr, true}]) of
{ok, ListenSocket} -> {ok, ListenSocket} ->
efka_logger:debug("Server started on port ~p~n", [Port]), lager:debug("[efka_tcp_server] Server started on port ~p~n", [Port]),
main_loop(ListenSocket); main_loop(ListenSocket);
{error, Reason} -> {error, Reason} ->
efka_logger:debug("Failed to start server: ~p~n", [Reason]), lager:debug("[efka_tcp_server] Failed to start server: ~p~n", [Reason]),
exit(Reason) exit(Reason)
end. end.
@ -38,9 +38,9 @@ main_loop(ListenSocket) ->
% 继续监听下一个连接 % 继续监听下一个连接
main_loop(ListenSocket); main_loop(ListenSocket);
{error, closed} -> {error, closed} ->
efka_logger:debug("Server socket closed~n", []), lager:debug("[efka_tcp_server] Server socket closed"),
exit(tcp_closed); exit(tcp_closed);
{error, Reason} -> {error, Reason} ->
efka_logger:debug("Accept error: ~p~n", [Reason]), lager:debug("[efka_tcp_server] Accept error: ~p", [Reason]),
exit(Reason) exit(Reason)
end. end.