diff --git a/apps/emqx_psk/src/emqx_psk.app.src b/apps/emqx_psk/src/emqx_psk.app.src index 4b405dd08..c3786bcc0 100644 --- a/apps/emqx_psk/src/emqx_psk.app.src +++ b/apps/emqx_psk/src/emqx_psk.app.src @@ -2,7 +2,7 @@ {application, emqx_psk, [ {description, "EMQX PSK"}, % strict semver, bump manually! - {vsn, "5.0.0"}, + {vsn, "5.0.1"}, {modules, []}, {registered, [emqx_psk_sup]}, {applications, [kernel, stdlib]}, diff --git a/apps/emqx_psk/src/emqx_psk.erl b/apps/emqx_psk/src/emqx_psk.erl index 99354d230..3a9406fdb 100644 --- a/apps/emqx_psk/src/emqx_psk.erl +++ b/apps/emqx_psk/src/emqx_psk.erl @@ -43,6 +43,11 @@ code_change/3 ]). +%% Internal exports (RPC) +-export([ + insert_psks/1 +]). + -record(psk_entry, { psk_id :: binary(), shared_secret :: binary(), @@ -199,10 +204,10 @@ import_psks(SrcFile) -> import_psks(Io, Delimiter, ChunkSize, NChunk) -> case get_psks(Io, Delimiter, ChunkSize) of {ok, Entries} -> - _ = trans(fun insert_psks/1, [Entries]), + _ = trans(fun ?MODULE:insert_psks/1, [Entries]), import_psks(Io, Delimiter, ChunkSize, NChunk + 1); {eof, Entries} -> - _ = trans(fun insert_psks/1, [Entries]), + _ = trans(fun ?MODULE:insert_psks/1, [Entries]), ok; {error, {bad_format, {line, N}}} -> {error, {bad_format, {line, NChunk * ChunkSize + N}}};