summaryrefslogtreecommitdiff
path: root/src
diff options
context:
space:
mode:
authorMatthias Radestock <matthias@rabbitmq.com>2014-01-10 11:33:16 +0000
committerMatthias Radestock <matthias@rabbitmq.com>2014-01-10 11:33:16 +0000
commit2185bebde3722a50499afb612c88b424c32b68e3 (patch)
tree2da96681eeca3cc2bbb1a2a15f5982a48e48ef73 /src
parentfa264cc579d1ab65d81eba07fe1c9ed24e0f8693 (diff)
parenta7ff2227baa6dab919c1529789b771fd8c2e24bd (diff)
downloadrabbitmq-server-git-2185bebde3722a50499afb612c88b424c32b68e3.tar.gz
merge stable into default
Diffstat (limited to 'src')
-rw-r--r--src/gm.erl8
1 files changed, 4 insertions, 4 deletions
diff --git a/src/gm.erl b/src/gm.erl
index 1703864afd..cddb2a3b24 100644
--- a/src/gm.erl
+++ b/src/gm.erl
@@ -898,10 +898,10 @@ internal_broadcast(Msg, From, State = #state { self = Self,
State1 = State #state { pub_count = PubCount1,
confirms = Confirms1,
broadcast_buffer = Buffer1 },
- handle_callback_result(case From of
- none -> {Result, State1};
- _ -> {Result, flush_broadcast_buffer(State1)}
- end).
+ handle_callback_result({Result, case From of
+ none -> State1;
+ _ -> flush_broadcast_buffer(State1)
+ end}).
flush_broadcast_buffer(State = #state { broadcast_buffer = [] }) ->
State;