diff --git a/apps/efka/src/efka_tcp_server.erl b/apps/efka/src/efka_tcp_server.erl index e47eb8a..e1646e2 100644 --- a/apps/efka/src/efka_tcp_server.erl +++ b/apps/efka/src/efka_tcp_server.erl @@ -22,10 +22,10 @@ init() -> case gen_tcp:listen(Port, [binary, {packet, 4}, {active, false}, {reuseaddr, true}]) of {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); {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) end. @@ -38,9 +38,9 @@ main_loop(ListenSocket) -> % 继续监听下一个连接 main_loop(ListenSocket); {error, closed} -> - efka_logger:debug("Server socket closed~n", []), + lager:debug("[efka_tcp_server] Server socket closed"), exit(tcp_closed); {error, Reason} -> - efka_logger:debug("Accept error: ~p~n", [Reason]), + lager:debug("[efka_tcp_server] Accept error: ~p", [Reason]), exit(Reason) end. \ No newline at end of file