diff options
| author | Loïc Hoguin <lhoguin@vmware.com> | 2022-09-08 15:41:01 +0200 |
|---|---|---|
| committer | Loïc Hoguin <lhoguin@vmware.com> | 2022-09-27 12:00:09 +0200 |
| commit | 1d7ce62f4bd74925f8bfad6ae5567e7d6e56944a (patch) | |
| tree | e8d6853141d64cb08bc3fdfad749cf32b05b6a62 | |
| parent | f1ae0074558d449c405406d2eadca0eca920a7e9 (diff) | |
| download | rabbitmq-server-git-1d7ce62f4bd74925f8bfad6ae5567e7d6e56944a.tar.gz | |
CQ: Remove a couple more unneded callbacks
This callback was removed in a previous commit and was only
used for bump_reduce_memory_use.
| -rw-r--r-- | deps/rabbit/src/rabbit_mirror_queue_master.erl | 6 | ||||
| -rw-r--r-- | deps/rabbit/src/rabbit_priority_queue.erl | 7 |
2 files changed, 2 insertions, 11 deletions
diff --git a/deps/rabbit/src/rabbit_mirror_queue_master.erl b/deps/rabbit/src/rabbit_mirror_queue_master.erl index bf26eb8dea..e7ef264a10 100644 --- a/deps/rabbit/src/rabbit_mirror_queue_master.erl +++ b/deps/rabbit/src/rabbit_mirror_queue_master.erl @@ -16,7 +16,7 @@ needs_timeout/1, timeout/1, handle_pre_hibernate/1, resume/1, msg_rates/1, info/2, invoke/3, is_duplicate/2, set_queue_mode/2, set_queue_version/2, - zip_msgs_and_acks/4, handle_info/2]). + zip_msgs_and_acks/4]). -export([start/2, stop/1, delete_crashed/1]). @@ -418,10 +418,6 @@ handle_pre_hibernate(State = #state { backing_queue = BQ, backing_queue_state = BQS }) -> State #state { backing_queue_state = BQ:handle_pre_hibernate(BQS) }. -handle_info(Msg, State = #state { backing_queue = BQ, - backing_queue_state = BQS }) -> - State #state { backing_queue_state = BQ:handle_info(Msg, BQS) }. - resume(State = #state { backing_queue = BQ, backing_queue_state = BQS }) -> State #state { backing_queue_state = BQ:resume(BQS) }. diff --git a/deps/rabbit/src/rabbit_priority_queue.erl b/deps/rabbit/src/rabbit_priority_queue.erl index be2310d174..d5f2cf0f53 100644 --- a/deps/rabbit/src/rabbit_priority_queue.erl +++ b/deps/rabbit/src/rabbit_priority_queue.erl @@ -35,7 +35,7 @@ handle_pre_hibernate/1, resume/1, msg_rates/1, info/2, invoke/3, is_duplicate/2, set_queue_mode/2, set_queue_version/2, - zip_msgs_and_acks/4, handle_info/2]). + zip_msgs_and_acks/4]). -record(state, {bq, bqss, max_priority}). -record(passthrough, {bq, bqs}). @@ -395,11 +395,6 @@ handle_pre_hibernate(State = #state{bq = BQ}) -> handle_pre_hibernate(State = #passthrough{bq = BQ, bqs = BQS}) -> ?passthrough1(handle_pre_hibernate(BQS)). -handle_info(Msg, State = #state{bq = BQ}) -> - foreach1(fun (_P, BQSN) -> BQ:handle_info(Msg, BQSN) end, State); -handle_info(Msg, State = #passthrough{bq = BQ, bqs = BQS}) -> - ?passthrough1(handle_info(Msg, BQS)). - resume(State = #state{bq = BQ}) -> foreach1(fun (_P, BQSN) -> BQ:resume(BQSN) end, State); resume(State = #passthrough{bq = BQ, bqs = BQS}) -> |