diff --git a/apps/emqx_plugin_libs/src/emqx_trace/emqx_trace_api.erl b/apps/emqx_plugin_libs/src/emqx_trace/emqx_trace_api.erl index 49321086b..4fbec0091 100644 --- a/apps/emqx_plugin_libs/src/emqx_trace/emqx_trace_api.erl +++ b/apps/emqx_plugin_libs/src/emqx_trace/emqx_trace_api.erl @@ -145,6 +145,8 @@ stream_log_file(#{name := Name}, Params) -> {eof, Size} -> Meta = #{<<"position">> => Size, <<"bytes">> => Bytes}, {ok, #{meta => Meta, items => <<"">>}}; + {error, trace_disabled} -> + {error, io_lib:format("trace_disable_on_~s", [Node0])}; {error, Reason} -> logger:log(error, "read_file_failed ~p", [{Node, Name, Reason, Position, Bytes}]), {error, Reason}; @@ -194,6 +196,11 @@ read_file(Path, Offset, Bytes) -> after file:close(IoDevice) end; + {error, enoent} -> + case emqx_trace:is_enable() of + false -> {error, trace_disabled}; + true -> {error, enoent} + end; {error, Reason} -> {error, Reason} end.