diff options
| author | kjnilsson <knilsson@pivotal.io> | 2019-10-11 09:26:42 +0100 |
|---|---|---|
| committer | kjnilsson <knilsson@pivotal.io> | 2019-10-11 12:04:47 +0100 |
| commit | 851244f0fb6d4e264b660da340447914f459265a (patch) | |
| tree | 6d3459b93dac0cc594e9644ecf405f866235afc6 /test | |
| parent | 2cbbcdbb48b5b8b87bb19bc0e08669987dc9f5d0 (diff) | |
| download | rabbitmq-server-git-851244f0fb6d4e264b660da340447914f459265a.tar.gz | |
Optimise QQ memory use
Take fewer release cursor snapshots points as the message backlog grows.
Also introduces a compacted form of the internal message header map
where initially it is only an integer representing the size of the
message body. Later when additional keys need to be added it is expanded
into a full map. This avoid creating and holding many individial maps
with just a size element.
[#169064158]
Diffstat (limited to 'test')
| -rw-r--r-- | test/rabbit_fifo_SUITE.erl | 8 |
1 files changed, 4 insertions, 4 deletions
diff --git a/test/rabbit_fifo_SUITE.erl b/test/rabbit_fifo_SUITE.erl index 0a0ac94e63..0d9acfa1fa 100644 --- a/test/rabbit_fifo_SUITE.erl +++ b/test/rabbit_fifo_SUITE.erl @@ -444,12 +444,12 @@ discarded_message_without_dead_letter_handler_is_removed_test(_) -> {State0, [_, _]} = enq(1, 1, first, test_init(test)), {State1, Effects1} = check_n(Cid, 2, 10, State0), ?ASSERT_EFF({send_msg, _, - {delivery, _, [{0, {#{}, first}}]}, _}, + {delivery, _, [{0, {_, first}}]}, _}, Effects1), {_State2, _, Effects2} = apply(meta(1), rabbit_fifo:make_discard(Cid, [0]), State1), ?assertNoEffect({send_msg, _, - {delivery, _, [{0, {#{}, first}}]}, _}, + {delivery, _, [{0, {_, first}}]}, _}, Effects2), ok. @@ -462,7 +462,7 @@ discarded_message_with_dead_letter_handler_emits_mod_call_effect_test(_) -> {State0, [_, _]} = enq(1, 1, first, State00), {State1, Effects1} = check_n(Cid, 2, 10, State0), ?ASSERT_EFF({send_msg, _, - {delivery, _, [{0, {#{}, first}}]}, _}, + {delivery, _, [{0, {_, first}}]}, _}, Effects1), {_State2, _, Effects2} = apply(meta(1), rabbit_fifo:make_discard(Cid, [0]), State1), % assert mod call effect with appended reason and message @@ -502,7 +502,7 @@ delivery_query_returns_deliveries_test(_) -> Entries = lists:zip(Indexes, Commands), {State, _Effects} = run_log(test_init(help), Entries), % 3 deliveries are returned - [{0, {#{}, one}}] = rabbit_fifo:get_checked_out(Cid, 0, 0, State), + [{0, {_, one}}] = rabbit_fifo:get_checked_out(Cid, 0, 0, State), [_, _, _] = rabbit_fifo:get_checked_out(Cid, 1, 3, State), ok. |