This commit is contained in:
anlicheng 2023-06-14 19:45:05 +08:00
parent 360d47d60c
commit 2ca7d23a8c

View File

@ -313,10 +313,10 @@ handle_message(#{<<"method">> := <<"ping">>, <<"params">> := CipherMetric}, Stat
handle_message(Msg = #{<<"code">> := _Code, <<"assoc">> := Assoc}, State = #state{assoc_map = AssocMap}) -> handle_message(Msg = #{<<"code">> := _Code, <<"assoc">> := Assoc}, State = #state{assoc_map = AssocMap}) ->
case maps:take(Assoc, AssocMap) of case maps:take(Assoc, AssocMap) of
error -> error ->
{noreply, State}; State;
{ReceiverPid, NAssocMap} -> {ReceiverPid, NAssocMap} ->
ReceiverPid ! {host_reply, Assoc, Msg}, ReceiverPid ! {host_reply, Assoc, Msg},
{noreply, State#state{assoc_map = NAssocMap}} State#state{assoc_map = NAssocMap}
end; end;
handle_message(Message, State = #state{uuid = UUID, has_session = HasSession}) -> handle_message(Message, State = #state{uuid = UUID, has_session = HasSession}) ->