diff options
| author | Alvaro Videla <videlalvaro@gmail.com> | 2015-10-13 21:25:10 +0200 |
|---|---|---|
| committer | Alvaro Videla <videlalvaro@gmail.com> | 2015-10-13 21:25:10 +0200 |
| commit | a647ec7a7e2199cf1d1165b8a813badeca220876 (patch) | |
| tree | eccf431479ba6f41d98e28ceea2e6c5c1f0987f5 /src | |
| parent | 587c66a1c16f221feee3c8134627257892e16430 (diff) | |
| download | rabbitmq-server-git-a647ec7a7e2199cf1d1165b8a813badeca220876.tar.gz | |
fixes in_r/2 implementation for lazy queues
Diffstat (limited to 'src')
| -rw-r--r-- | src/rabbit_variable_queue.erl | 3 |
1 files changed, 2 insertions, 1 deletions
diff --git a/src/rabbit_variable_queue.erl b/src/rabbit_variable_queue.erl index 6745621964..dfcfc8b3db 100644 --- a/src/rabbit_variable_queue.erl +++ b/src/rabbit_variable_queue.erl @@ -1357,7 +1357,8 @@ in_r(MsgStatus = #msg_status { seq_id = SeqId }, State = #vqstate { mode = lazy, q3 = Q3, delta = Delta}) -> case ?QUEUE:is_empty(Q3) of true -> - State1 = maybe_write_to_disk(true, true, MsgStatus, State), + {_MsgStatus1, State1} = + maybe_write_to_disk(true, true, MsgStatus, State), State2 = stats(ready0, {MsgStatus, none}, State1), Delta1 = expand_delta(SeqId, Delta), State2 #vqstate{ delta = Delta1 }; |