yuanbiao
/
emqx
1
0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

refactor: use 'bufs' for resource worker replayq dir

This commit is contained in:
Zaiming (Stone) Shi 2023-01-12 18:26:38 +01:00 committed by Thales Macedo Garitezi
parent af6807e863
commit 249c4c1c79
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/emqx_resource/src/emqx_resource_worker.erl
View File

@ -1021,7 +1021,7 @@ queue_count(Q) ->
disk_queue_dir(Id, Index) ->
QDir0 = binary_to_list(Id) ++ "_" ++ integer_to_list(Index),
QDir = sanitizy_file_path(QDir0),
filename:join([emqx:data_dir(), "resource_worker", node(), QDir]).
filename:join([emqx:data_dir(), "bufs", node(), QDir]).
sanitizy_file_path(Filepath) ->
iolist_to_binary(string:replace(Filepath, ":", "_", all)).