summaryrefslogtreecommitdiff
path: root/src/gm.erl
diff options
context:
space:
mode:
Diffstat (limited to 'src/gm.erl')
-rw-r--r--src/gm.erl7
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;