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 2026-07-07 13:01:26 +08:00
parent 6e67df6f82
commit 9dae7b5b60
2 changed files with 3 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
apps/efka/src/iot/efka_iot_client.erl
View File

@ -452,8 +452,8 @@ handle_container_command(Ref, Request, Socket) ->
ok. ok.
-spec handle_stream_frame(term(), term(), #state{}) -> gen_statem:event_handler_result(atom(), #state{}). -spec handle_stream_frame(term(), term(), #state{}) -> gen_statem:event_handler_result(atom(), #state{}).
handle_stream_frame(StreamId, <<"open">>, State = #state{streams = Streams}) handle_stream_frame(StreamId, {<<"open">>, Params}, State = #state{streams = Streams})
when is_integer(StreamId), StreamId > 0 -> when is_integer(StreamId), StreamId > 0, is_map(Params) ->
case valid_iot_stream_id(StreamId) andalso not maps:is_key(StreamId, Streams) of case valid_iot_stream_id(StreamId) andalso not maps:is_key(StreamId, Streams) of
true -> true ->
{ok, {WorkerPid, MonitorRef}} = efka_iot_stream:start_stream(StreamId), {ok, {WorkerPid, MonitorRef}} = efka_iot_stream:start_stream(StreamId),

2
config/sys.config.src
View File

@ -17,7 +17,7 @@
{stream_target, [ {stream_target, [
{host, "127.0.0.1"}, {host, "127.0.0.1"},
{port, 18091}, {port, 81},
{connect_timeout, 3000}, {connect_timeout, 3000},
{idle_timeout, 120000} {idle_timeout, 120000}
]}, ]},