diff options
| author | Daniil Fedotov <hairyhum@gmail.com> | 2017-11-22 17:37:29 +0000 |
|---|---|---|
| committer | GitHub <noreply@github.com> | 2017-11-22 17:37:29 +0000 |
| commit | 51586b343bcd3b9bb2e3138e9f3a35d997d6fc1d (patch) | |
| tree | e493c68d589f490a8884766dd88f1b1e875f8fe9 /src | |
| parent | 0d576e23bc83d8c8047ed7d90737fc5e720bf6e3 (diff) | |
| parent | f10b71c140ceed8af9fbe43a1d4b8222a889bd88 (diff) | |
| download | rabbitmq-server-git-51586b343bcd3b9bb2e3138e9f3a35d997d6fc1d.tar.gz | |
Merge pull request #1428 from rabbitmq/rabbitmq-server-1427
gm: adapt has_pending_messages/1 for maps
Diffstat (limited to 'src')
| -rw-r--r-- | src/gm.erl | 7 |
1 files changed, 4 insertions, 3 deletions
diff --git a/src/gm.erl b/src/gm.erl index c53e9bb007..6ac0884081 100644 --- a/src/gm.erl +++ b/src/gm.erl @@ -1559,9 +1559,10 @@ has_pending_messages(#state{ broadcast_buffer = Buffer }) when Buffer =/= [] -> true; has_pending_messages(#state{ members_state = MembersState }) -> - [] =/= [M || {_, #member{last_pub = LP, last_ack = LA} = M} - <- MembersState, - LP =/= LA]. + MembersWithPubAckMismatches = maps:filter(fun(_Id, #member{last_pub = LP, last_ack = LA}) -> + LP =/= LA + end, MembersState), + 0 =/= maps:size(MembersWithPubAckMismatches). maybe_confirm(_Self, _Id, Confirms, []) -> Confirms; |