diff options
| author | Alexandru Scvortov <alexandru@rabbitmq.com> | 2010-11-24 14:02:54 +0000 |
|---|---|---|
| committer | Alexandru Scvortov <alexandru@rabbitmq.com> | 2010-11-24 14:02:54 +0000 |
| commit | d5f9803e4389abb922a211e5577c1b728bef1a19 (patch) | |
| tree | 9d91d83833bb29be9e6ca1bef0b0747d65d1a937 | |
| parent | 51a2041df7647cc91ffc6ae8a84eb063279de4d9 (diff) | |
| download | rabbitmq-server-d5f9803e4389abb922a211e5577c1b728bef1a19.tar.gz | |
change order of tuple elements
| -rw-r--r-- | src/rabbit_amqqueue.erl | 4 | ||||
| -rw-r--r-- | src/rabbit_amqqueue_process.erl | 2 | ||||
| -rw-r--r-- | src/rabbit_variable_queue.erl | 2 |
3 files changed, 4 insertions, 4 deletions
diff --git a/src/rabbit_amqqueue.erl b/src/rabbit_amqqueue.erl index 0872a048..88ad5f06 100644 --- a/src/rabbit_amqqueue.erl +++ b/src/rabbit_amqqueue.erl @@ -157,9 +157,9 @@ (name()) -> rabbit_types:ok_or_error('not_found') | rabbit_types:connection_exit()). -spec(maybe_run_queue_via_backing_queue/2 :: - (pid(), (fun ((A) -> A))) -> 'ok'). + (pid(), (fun ((A) -> A | {any(), A}))) -> 'ok'). -spec(maybe_run_queue_via_backing_queue_async/2 :: - (pid(), (fun ((A) -> A))) -> 'ok'). + (pid(), (fun ((A) -> A | {any(), A}))) -> 'ok'). -spec(update_ram_duration/1 :: (pid()) -> 'ok'). -spec(set_ram_duration_target/2 :: (pid(), number() | 'infinity') -> 'ok'). -spec(set_maximum_since_use/2 :: (pid(), non_neg_integer()) -> 'ok'). diff --git a/src/rabbit_amqqueue_process.erl b/src/rabbit_amqqueue_process.erl index bb98fe31..4672e339 100644 --- a/src/rabbit_amqqueue_process.erl +++ b/src/rabbit_amqqueue_process.erl @@ -623,7 +623,7 @@ qname(#q{q = #amqqueue{name = QName}}) -> QName. maybe_run_queue_via_backing_queue(Fun, State = #q{backing_queue_state = BQS}) -> {BQS2, State1} = case Fun(BQS) of - {BQS1, {confirm, Guids}} -> {BQS1, confirm_messages(Guids, State)}; + {{confirm, Guids}, BQS1} -> {BQS1, confirm_messages(Guids, State)}; BQS1 -> {BQS1, State} end, run_message_queue(State1#q{backing_queue_state = BQS2}). diff --git a/src/rabbit_variable_queue.erl b/src/rabbit_variable_queue.erl index 47a894a8..0e5675f3 100644 --- a/src/rabbit_variable_queue.erl +++ b/src/rabbit_variable_queue.erl @@ -1308,7 +1308,7 @@ remove_confirms(GuidSet, State = #vqstate { msgs_on_disk = MOD, unconfirmed = gb_sets:difference(UC, GuidSet) }. msgs_confirmed(GuidSet, State) -> - {remove_confirms(GuidSet, State), {confirm, gb_sets:to_list(GuidSet)}}. + {{confirm, gb_sets:to_list(GuidSet)}, remove_confirms(GuidSet, State)}. msgs_written_to_disk(QPid, GuidSet) -> rabbit_amqqueue:maybe_run_queue_via_backing_queue_async( |