diff options
| author | Alvaro Videla <videlalvaro@gmail.com> | 2015-09-07 13:52:57 +0200 |
|---|---|---|
| committer | Alvaro Videla <videlalvaro@gmail.com> | 2015-09-07 13:52:57 +0200 |
| commit | 1609fbe3fdf3290e5aecc3acbf08db86931196e3 (patch) | |
| tree | 73e5a32faee145b32b96cecb437b7e2960fa84e0 | |
| parent | 09c2922c4200a3af98a080d8c23bc98c8321bd9d (diff) | |
| download | rabbitmq-server-git-1609fbe3fdf3290e5aecc3acbf08db86931196e3.tar.gz | |
renames wipe_index -> reset_qi_state
| -rw-r--r-- | src/rabbit_variable_queue.erl | 4 |
1 files changed, 2 insertions, 2 deletions
diff --git a/src/rabbit_variable_queue.erl b/src/rabbit_variable_queue.erl index f3c73f49fc..d3720d6712 100644 --- a/src/rabbit_variable_queue.erl +++ b/src/rabbit_variable_queue.erl @@ -1323,7 +1323,7 @@ purge_when_pending_acks(State) -> purge_when_no_pending_acks(State) -> AfterFun = process_delivers_and_acks_fun(none), State1 = purge1(AfterFun, State), - a(wipe_index(State1)). + a(reset_qi_state(State1)). purge1(AfterFun, State = #vqstate { q4 = Q4}) -> State1 = remove_queue_entries(Q4, AfterFun, State), @@ -1335,7 +1335,7 @@ purge1(AfterFun, State = #vqstate { q4 = Q4}) -> a(State3 #vqstate { q1 = ?QUEUE:new() }). -wipe_index(State = #vqstate{index_state = IndexState }) -> +reset_qi_state(State = #vqstate{index_state = IndexState }) -> State #vqstate { index_state = rabbit_queue_index:reset_state(IndexState) }. |