diff options
| author | Alvaro Videla <videlalvaro@gmail.com> | 2015-10-17 14:04:33 +0200 |
|---|---|---|
| committer | Alvaro Videla <videlalvaro@gmail.com> | 2015-10-17 14:04:33 +0200 |
| commit | 9d7d38b11a01d51c0fdcacbcd82b4bf2c75e6aaf (patch) | |
| tree | 5eb49d1cd4f18a3b5de96fd1d5d9898523f145e3 /src | |
| parent | 0803568fdd84add533156001fef09e3c63727823 (diff) | |
| download | rabbitmq-server-git-9d7d38b11a01d51c0fdcacbcd82b4bf2c75e6aaf.tar.gz | |
renames according to priority queue internal API
Diffstat (limited to 'src')
| -rw-r--r-- | src/rabbit_mirror_queue_sync.erl | 2 | ||||
| -rw-r--r-- | src/rabbit_priority_queue.erl | 16 |
2 files changed, 9 insertions, 9 deletions
diff --git a/src/rabbit_mirror_queue_sync.erl b/src/rabbit_mirror_queue_sync.erl index 678ac0d3ab..62fc718f79 100644 --- a/src/rabbit_mirror_queue_sync.erl +++ b/src/rabbit_mirror_queue_sync.erl @@ -381,7 +381,7 @@ batch_publish_delivered(Batch, MA, BQ, BQS) -> {MA1, BQS1}. batch_by_priority(Batch) -> - rabbit_priority_queue:publish_delivered_batch_by_priority(Batch). + rabbit_priority_queue:partition_publish_delivered_batch(Batch). zip_msgs_and_tags(Pubs, AckTags) -> lists:zipwith( diff --git a/src/rabbit_priority_queue.erl b/src/rabbit_priority_queue.erl index 6ec018dba3..4d638b334a 100644 --- a/src/rabbit_priority_queue.erl +++ b/src/rabbit_priority_queue.erl @@ -43,7 +43,7 @@ info/2, invoke/3, is_duplicate/2]). %% for rabbit_mirror_queue_sync. --export([publish_delivered_batch_by_priority/1]). +-export([partition_publish_delivered_batch/1]). -record(state, {bq, bqss}). -record(passthrough, {bq, bqs}). @@ -208,7 +208,7 @@ publish(Msg, MsgProps, IsDelivered, ChPid, Flow, ?passthrough1(publish(Msg, MsgProps, IsDelivered, ChPid, Flow, BQS)). batch_publish(Publishes, ChPid, Flow, State = #state{bq = BQ}) -> - PubDict = publish_batch_by_priority(Publishes), + PubDict = partition_publish_batch(Publishes), lists:foldl( fun ({Priority, Pubs}, St) -> pick1(fun (_P, BQSN) -> @@ -230,7 +230,7 @@ publish_delivered(Msg, MsgProps, ChPid, Flow, ?passthrough2(publish_delivered(Msg, MsgProps, ChPid, Flow, BQS)). batch_publish_delivered(Publishes, ChPid, Flow, State = #state{bq = BQ}) -> - PubDict = publish_delivered_batch_by_priority(Publishes), + PubDict = partition_publish_delivered_batch(Publishes), {PrioritiesAndAcks, State1} = lists:foldl( fun ({Priority, Pubs}, {PriosAndAcks, St}) -> @@ -567,15 +567,15 @@ a(State = #state{bqss = BQSs}) -> end. %%---------------------------------------------------------------------------- -publish_batch_by_priority(Publishes) -> - publishes_by_priority( +partition_publish_batch(Publishes) -> + partition_publishes( Publishes, fun ({Msg, _, _}) -> Msg end). -publish_delivered_batch_by_priority(Publishes) -> - publishes_by_priority( +partition_publish_delivered_batch(Publishes) -> + partition_publishes( Publishes, fun ({Msg, _}) -> Msg end). -publishes_by_priority(Publishes, ExtractMsg) -> +partition_publishes(Publishes, ExtractMsg) -> lists:foldl(fun (Pub, Dict) -> Msg = ExtractMsg(Pub), rabbit_misc:orddict_cons(priority2(Msg), Pub, Dict) |