chore: rename `message_queue_too_long` error reason to `mailbox_overflow`

`mailbox_overflow` is consistent with the corresponding config parameter:
 'force_shutdown.max_mailbox_size'
This commit is contained in:
Serge Tupchii 2024-03-22 12:12:37 +02:00
parent ea917d6b2b
commit 906a77d167
4 changed files with 6 additions and 3 deletions

View File

@ -2,7 +2,7 @@
{application, emqx_utils, [ {application, emqx_utils, [
{description, "Miscellaneous utilities for EMQX apps"}, {description, "Miscellaneous utilities for EMQX apps"},
% strict semver, bump manually! % strict semver, bump manually!
{vsn, "5.1.0"}, {vsn, "5.1.1"},
{modules, [ {modules, [
emqx_utils, emqx_utils,
emqx_utils_api, emqx_utils_api,

View File

@ -261,7 +261,7 @@ check_oom(Pid, #{
ok; ok;
[{message_queue_len, QLen}, {total_heap_size, HeapSize}] -> [{message_queue_len, QLen}, {total_heap_size, HeapSize}] ->
do_check_oom([ do_check_oom([
{QLen, MaxQLen, message_queue_too_long}, {QLen, MaxQLen, mailbox_overflow},
{HeapSize, MaxHeapSize, proc_heap_too_large} {HeapSize, MaxHeapSize, proc_heap_too_large}
]) ])
end. end.

View File

@ -150,7 +150,7 @@ t_check(_) ->
?assertEqual(ok, emqx_utils:check_oom(Policy)), ?assertEqual(ok, emqx_utils:check_oom(Policy)),
[self() ! {msg, I} || I <- lists:seq(1, 6)], [self() ! {msg, I} || I <- lists:seq(1, 6)],
?assertEqual( ?assertEqual(
{shutdown, #{reason => message_queue_too_long, value => 11, max => 10}}, {shutdown, #{reason => mailbox_overflow, value => 11, max => 10}},
emqx_utils:check_oom(Policy) emqx_utils:check_oom(Policy)
). ).

View File

@ -0,0 +1,3 @@
Rename `message_queue_too_long` error reason to `mailbox_overflow`
`mailbox_overflow` is consistent with the corresponding config parameter: `force_shutdown.max_mailbox_size`.