diff options
| author | Michael Klishin <mklishin@pivotal.io> | 2015-09-08 19:35:53 +0300 |
|---|---|---|
| committer | Michael Klishin <mklishin@pivotal.io> | 2015-09-08 19:35:53 +0300 |
| commit | 647ae31c0b4cdc2a1ffb19240699017532179226 (patch) | |
| tree | c55b6b68bb4e765d8b59fee192ac21a283604e2d /src | |
| parent | d9c9e16d2e52fe4300af5b7a840c01285face51c (diff) | |
| download | rabbitmq-server-git-647ae31c0b4cdc2a1ffb19240699017532179226.tar.gz | |
Cosmetics
Diffstat (limited to 'src')
| -rw-r--r-- | src/rabbit_variable_queue.erl | 12 |
1 files changed, 6 insertions, 6 deletions
diff --git a/src/rabbit_variable_queue.erl b/src/rabbit_variable_queue.erl index 62fa483056..b3c5baa6c3 100644 --- a/src/rabbit_variable_queue.erl +++ b/src/rabbit_variable_queue.erl @@ -1341,16 +1341,16 @@ purge_and_index_reset(State) -> purge1(AfterFun, State = #vqstate { q4 = Q4}) -> State1 = remove_queue_entries(Q4, AfterFun, State), - State2 = #vqstate { q1 = Q1 } = - purge_betas_and_deltas(AfterFun, State1 #vqstate { q4 = ?QUEUE:new() }), + State2 = #vqstate {q1 = Q1} = + purge_betas_and_deltas(AfterFun, State1#vqstate{q4 = ?QUEUE:new()}), State3 = remove_queue_entries(Q1, AfterFun, State2), - a(State3 #vqstate { q1 = ?QUEUE:new() }). + a(State3#vqstate{q1 = ?QUEUE:new()}). -reset_qi_state(State = #vqstate{index_state = IndexState }) -> - State #vqstate { index_state = - rabbit_queue_index:reset_state(IndexState) }. +reset_qi_state(State = #vqstate{index_state = IndexState}) -> + State#vqstate{index_state = + rabbit_queue_index:reset_state(IndexState)}. is_pending_ack_empty(State) -> count_pending_acks(State) =:= 0. |