diff options
| author | Emile Joubert <emile@rabbitmq.com> | 2012-04-23 16:04:50 +0100 |
|---|---|---|
| committer | Emile Joubert <emile@rabbitmq.com> | 2012-04-23 16:04:50 +0100 |
| commit | ec82e9b796ad3cbbf25289ebac8bd4b8c2f7d348 (patch) | |
| tree | 803df5e6699ad9c7a9ce5785cdbb3d263ee75041 | |
| parent | 24c18e4d3621efe7f2f348c0572def0509362729 (diff) | |
| download | rabbitmq-server-git-ec82e9b796ad3cbbf25289ebac8bd4b8c2f7d348.tar.gz | |
QuickCheck follows dropwhile API updates
| -rw-r--r-- | src/rabbit_backing_queue_qc.erl | 7 |
1 files changed, 4 insertions, 3 deletions
diff --git a/src/rabbit_backing_queue_qc.erl b/src/rabbit_backing_queue_qc.erl index 78ababe82e..a84800c0ec 100644 --- a/src/rabbit_backing_queue_qc.erl +++ b/src/rabbit_backing_queue_qc.erl @@ -141,7 +141,7 @@ qc_drain_confirmed(#state{bqstate = BQ}) -> {call, ?BQMOD, drain_confirmed, [BQ]}. qc_dropwhile(#state{bqstate = BQ}) -> - {call, ?BQMOD, dropwhile, [fun dropfun/1, true, BQ]}. + {call, ?BQMOD, dropwhile, [fun dropfun/1, false, BQ]}. qc_is_empty(#state{bqstate = BQ}) -> {call, ?BQMOD, is_empty, [BQ]}. @@ -267,10 +267,11 @@ next_state(S, Res, {call, ?BQMOD, drain_confirmed, _Args}) -> BQ1 = {call, erlang, element, [2, Res]}, S#state{bqstate = BQ1}; -next_state(S, BQ1, {call, ?BQMOD, dropwhile, _Args}) -> +next_state(S, Res, {call, ?BQMOD, dropwhile, _Args}) -> + BQ = {call, erlang, element, [2, Res]}, #state{messages = Messages} = S, Msgs1 = drop_messages(Messages), - S#state{bqstate = BQ1, len = gb_trees:size(Msgs1), messages = Msgs1}; + S#state{bqstate = BQ, len = gb_trees:size(Msgs1), messages = Msgs1}; next_state(S, _Res, {call, ?BQMOD, is_empty, _Args}) -> S; |