소스 검색

feat(ft): fix remote reader handling of gen_rpc errors

Ilya Averyanov 3 년 전
부모
커밋
1d48a97fd2
1개의 변경된 파일2개의 추가작업 그리고 2개의 파일을 삭제
  1. 2 2
      apps/emqx_ft/src/emqx_ft_storage_fs_reader.erl

+ 2 - 2
apps/emqx_ft/src/emqx_ft_storage_fs_reader.erl

@@ -59,8 +59,8 @@ table(ReaderPid, Bytes) when is_pid(ReaderPid) andalso is_integer(Bytes) andalso
                 [];
                 [];
             {ok, Data} ->
             {ok, Data} ->
                 [Data] ++ fun() -> NextFun(Pid) end;
                 [Data] ++ fun() -> NextFun(Pid) end;
-            {error, Reason} ->
-                ?SLOG(warning, #{msg => "file_read_error", reason => Reason}),
+            {ErrorKind, Reason} when ErrorKind =:= badrpc; ErrorKind =:= error ->
+                ?SLOG(warning, #{msg => "file_read_error", kind => ErrorKind, reason => Reason}),
                 []
                 []
         end
         end
     end,
     end,