From 627be12a6e6de944bbbf28a3c4281311800a85a8 Mon Sep 17 00:00:00 2001 From: anlicheng <244108715@qq.com> Date: Mon, 11 May 2026 00:07:57 +0800 Subject: [PATCH] =?UTF-8?q?add=20ssl=20=E5=BF=83=E8=B7=B3=E6=9C=BA?= =?UTF-8?q?=E5=88=B6?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- src/transport/udp_server.erl | 3 +++ 1 file changed, 3 insertions(+) diff --git a/src/transport/udp_server.erl b/src/transport/udp_server.erl index 6a04552..23f8432 100644 --- a/src/transport/udp_server.erl +++ b/src/transport/udp_server.erl @@ -47,8 +47,10 @@ start_link() -> {ok, State :: #state{}} | {ok, State :: #state{}, timeout() | hibernate} | {stop, Reason :: term()} | ignore). init([]) -> + ok = iot_log:set_metadata(), {ok, UdpServerProps} = application:get_env(iot, udp_server), Port = proplists:get_value(port, UdpServerProps), + logger:debug("[udp_server] start at port: ~p", [Port]), {ok, Socket} = gen_udp:open(Port, [binary, {active, true}]), {ok, #state{socket = Socket}}. @@ -116,6 +118,7 @@ handle_heartbeat_packet(Packet, Peer) when is_binary(Packet) -> {ok, UUID, Timestamp, Payload, Mac} -> case efka_client_store:verify_heartbeat(UUID, Timestamp, Payload, Mac) of true -> + logger:warning("[udp_server] heartbeat auth from peer: ~p, uuid: ~p", [Peer, UUID]), Pid = iot_host:get_pid(UUID), iot_host:heartbeat(Pid); false ->