diff --git a/apps/efka/src/efka_agent.erl b/apps/efka/src/efka_agent.erl index 23f76c7..0ef4df8 100644 --- a/apps/efka/src/efka_agent.erl +++ b/apps/efka/src/efka_agent.erl @@ -85,7 +85,7 @@ handle_info({timeout, _, create_transport}, State = #state{}) -> {ok, TransportPid} -> Ref = efka_transport:auth_request(TransportPid, 5000), receive - %% 验证通过 + %% 验证通过 {auth_reply, Ref, {ok, #auth_reply{code = 1, message = Message, repository_url = RepositoryUrl}}} -> lager:debug("[efka_agent] auth result: ~p, repository_url: ~p", [Message, RepositoryUrl]), {noreply, State#state{transport_pid = TransportPid, status = ?STATE_ACTIVATED}}; diff --git a/apps/efka/src/efka_transport.erl b/apps/efka/src/efka_transport.erl index dc48df4..2456dc5 100644 --- a/apps/efka/src/efka_transport.erl +++ b/apps/efka/src/efka_transport.erl @@ -120,12 +120,11 @@ handle_cast({auth_request, ReceiverPid, Ref, Timeout}, State = #state{socket = S %% 需要等待auth返回的结果 receive {ssl, Socket, <>} -> - lager:debug("call me here auth reply"), ReceiverPid ! {auth_reply, Ref, {ok, message_pb:decode_msg(ReplyBin, auth_reply)}}, {noreply, State#state{packet_id = PacketId + 1}} after Timeout -> ReceiverPid ! {auth_reply, Ref, {error, timeout}}, - {noreply, State} + {stop, normal, State} end; handle_cast({send, Method, Packet}, State = #state{socket = Socket}) ->