From f947453e59808a5251a5867a8ef2586305de28b3 Mon Sep 17 00:00:00 2001
From: anlicheng <244108715@qq.com>
Date: Tue, 22 Apr 2025 15:58:58 +0800
Subject: [PATCH] fix

---
 apps/efka/src/efka_transport.erl | 15 +++++----------
 1 file changed, 5 insertions(+), 10 deletions(-)

diff --git a/apps/efka/src/efka_transport.erl b/apps/efka/src/efka_transport.erl
index 2756bad..8bc944f 100644
--- a/apps/efka/src/efka_transport.erl
+++ b/apps/efka/src/efka_transport.erl
@@ -69,12 +69,9 @@ init([ParentPid]) ->
         {active, true},
         {verify, verify_none}
     ],
-    case ssl:connect(Host, Port, SslOptions, 5000) of
-        {ok, Socket} ->
-            {ok, #state{parent_pid = ParentPid, host = Host, port = Port, socket = Socket}};
-        {error, Reason} ->
-            {stop, Reason}
-    end.
+    {ok, Socket} = ssl:connect(Host, Port, SslOptions, 5000),
+
+    {ok, #state{parent_pid = ParentPid, host = Host, port = Port, socket = Socket}}.
 
 %% @private
 %% @doc Handling call messages
@@ -145,12 +142,10 @@ handle_info({ssl, Socket, <<?PACKET_PUBLISH, PacketId:32, Msg/binary>>}, State =
     {noreply, State#state{}};
 
 handle_info({ssl_error, Socket, Reason}, State = #state{socket = Socket}) ->
-    lager:warning("[efka_agent] socket close with reason: ~p", [Reason]),
-    {stop, transport_error, State};
+    {stop, Reason, State};
 
 handle_info({ssl_closed, Socket}, State = #state{socket = Socket}) ->
-    lager:warning("[efka_agent] socket closed"),
-    {stop, transport_closed, State};
+    {stop, ssl_closed, State};
 
 handle_info(_Info, State = #state{}) ->
     {noreply, State}.