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

fix

Browse Source
This commit is contained in:
anlicheng 2025-05-06 11:24:56 +08:00
parent 6375eaefe1
commit 11ecea63b7
1 changed files with 21 additions and 27 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

48
apps/efka/src/efka_agent.erl
View File

@ -127,34 +127,28 @@ handle_info({connect_reply, Reply}, State = #state{status = ?STATE_CONNECTING, t
end; end;
handle_info({auth_reply, {ok, ReplyBin}}, State = #state{status = ?STATE_AUTH, transport_pid = TransportPid}) -> handle_info({auth_reply, {ok, ReplyBin}}, State = #state{status = ?STATE_AUTH, transport_pid = TransportPid}) ->
try message_pb:decode_msg(ReplyBin, auth_reply) of #auth_reply{code = Code, message = Message, repository_url = RepositoryUrl} = message_pb:decode_msg(ReplyBin, auth_reply),
#auth_reply{code = Code, message = Message, repository_url = RepositoryUrl} -> case Code of
case Code of 0 ->
0 -> lager:debug("[efka_agent] auth failed, message: ~p, repository_url: ~p", [Message, RepositoryUrl]),
lager:debug("[efka_agent] auth failed, message: ~p, repository_url: ~p", [Message, RepositoryUrl]), {noreply, State#state{status = ?STATE_ACTIVATED}};
{noreply, State#state{status = ?STATE_ACTIVATED}}; 1 ->
1 -> %% 主机在后台的授权未通过；此时agent不能推送数据给云端服务器，但是云端服务器可以推送命令给agent
%% 主机在后台的授权未通过；此时agent不能推送数据给云端服务器，但是云端服务器可以推送命令给agent %% socket的连接状态需要维持
%% socket的连接状态需要维持 lager:debug("[efka_agent] auth denied, message: ~p", [Message]),
lager:debug("[efka_agent] auth denied, message: ~p", [Message]), {noreply, State#state{status = ?STATE_RESTRICTED}};
{noreply, State#state{status = ?STATE_RESTRICTED}}; 2 ->
2 -> % 其他类型的错误，需要间隔时间重试
% 其他类型的错误，需要间隔时间重试 efka_logger:debug("[efka_agent] auth failed, message: ~p", [Message]),
efka_logger:debug("[efka_agent] auth failed, message: ~p", [Message]), efka_transport:stop(TransportPid),
efka_transport:stop(TransportPid), {noreply, State#state{transport_pid = undefined, status = ?STATE_DENIED}};
{noreply, State#state{transport_pid = undefined, status = ?STATE_DENIED}}; _ ->
_ -> % 其他类型的错误，需要间隔时间重试
% 其他类型的错误，需要间隔时间重试 lager:debug("[efka_agent] auth failed, invalid message"),
lager:debug("[efka_agent] auth failed, invalid message"), efka_transport:stop(TransportPid),
efka_transport:stop(TransportPid), {noreply, State#state{transport_pid = undefined, status = ?STATE_DENIED}}
{noreply, State#state{transport_pid = undefined, status = ?STATE_DENIED}}
end
catch _:Reason ->
% 其他类型的错误，需要间隔时间重试
lager:debug("[efka_agent] auth decode bin get error: ~p", [Reason]),
efka_transport:stop(TransportPid),
{noreply, State#state{transport_pid = undefined, status = ?STATE_DENIED}}
end; end;
handle_info({auth_reply, {error, Reason}}, State = #state{transport_pid = TransportPid, status = ?STATE_AUTH}) -> handle_info({auth_reply, {error, Reason}}, State = #state{transport_pid = TransportPid, status = ?STATE_AUTH}) ->
lager:debug("[efka_agent] auth_request failed, error: ~p", [Reason]), lager:debug("[efka_agent] auth_request failed, error: ~p", [Reason]),
efka_transport:stop(TransportPid), efka_transport:stop(TransportPid),