diff options
| author | Alvaro Videla <videlalvaro@gmail.com> | 2015-09-09 23:57:01 +0200 |
|---|---|---|
| committer | Alvaro Videla <videlalvaro@gmail.com> | 2015-09-09 23:57:01 +0200 |
| commit | 8ed0c81e8d259149fc860ef3831fc32e9bd8632d (patch) | |
| tree | 515ecdece3d555aa1a59a181975c5fc177291b82 | |
| parent | a1ee6baacd270f7666320841b38f4302cf11abcf (diff) | |
| download | rabbitmq-server-git-8ed0c81e8d259149fc860ef3831fc32e9bd8632d.tar.gz | |
unwelps code
| -rw-r--r-- | src/rabbit_variable_queue.erl | 2 |
1 files changed, 1 insertions, 1 deletions
diff --git a/src/rabbit_variable_queue.erl b/src/rabbit_variable_queue.erl index bf4250598e..068adf67bd 100644 --- a/src/rabbit_variable_queue.erl +++ b/src/rabbit_variable_queue.erl @@ -1089,7 +1089,7 @@ betas_from_index_entries(List, TransientThreshold, DelsAndAcksFun, State) -> %% qi_pending_ack, thus it must already have been in RAM. is_msg_in_pending_acks(SeqId, #vqstate { ram_pending_ack = RPA, - disk_write_count = DPA, + disk_pending_ack = DPA, qi_pending_ack = QPA }) -> (gb_trees:is_defined(SeqId, RPA) orelse gb_trees:is_defined(SeqId, DPA) orelse |