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

fix

Browse Source
This commit is contained in:
anlicheng 2024-08-01 11:48:31 +08:00
parent e1e2a09b21
commit ba9320fb19
1 changed files with 1 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
apps/iot/src/endpoint/iot_zd_endpoint.erl
View File

@ -98,7 +98,7 @@ callback_mode() ->
handle_event(cast, {forward, LocationCode, DynamicLocationCode, Fields, Timestamp}, StateName, State = #state{is_busy = IsBusy, iot_queue = Q}) -> handle_event(cast, {forward, LocationCode, DynamicLocationCode, Fields, Timestamp}, StateName, State = #state{is_busy = IsBusy, iot_queue = Q}) ->
case iot_queue:is_full(Q) of case iot_queue:is_full(Q) of
true -> true ->
lager:debug("[iot_zd_endpoint] queue is full discard data: ~p", [{LocationCode, DynamicLocationCode, Fields, Timestamp}]), lager:notice("[iot_zd_endpoint] queue is full discard data: ~p", [{LocationCode, DynamicLocationCode, Fields, Timestamp}]),
{keep_state, State}; {keep_state, State};
false -> false ->
case format_data(LocationCode, DynamicLocationCode, Fields, Timestamp) of case format_data(LocationCode, DynamicLocationCode, Fields, Timestamp) of