diff options
Diffstat (limited to 'src/gm.erl')
| -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; |
