From cc9cce9351c2d64476dbe2f35c43cde8a3f97ebe Mon Sep 17 00:00:00 2001 From: Emeric Brun Date: Tue, 23 Feb 2021 17:08:08 +0100 Subject: [PATCH] BUG/MEDIUM: peers: reset commitupdate value in new conns The commitupdate value of the table is used to check if the update is still pending for a push for all peers. To be sure to not miss a push we reset it just after a handshake success. This patch should be backported on all supported branches ( >= 1.6 ) --- src/peers.c | 4 ++++ 1 file changed, 4 insertions(+) diff --git a/src/peers.c b/src/peers.c index b473a4ccb..16a2fdb43 100644 --- a/src/peers.c +++ b/src/peers.c @@ -2409,6 +2409,8 @@ static inline void init_accepted_peer(struct peer *peer, struct peers *peers) if ((int)(st->table->localupdate - st->update) < 0) st->update = st->table->localupdate + (2147483648U); st->teaching_origin = st->last_pushed = st->update; + if ((int)(st->last_pushed - st->table->commitupdate) > 0) + st->table->commitupdate = st->last_pushed; HA_SPIN_UNLOCK(STK_TABLE_LOCK, &st->table->lock); } @@ -2459,6 +2461,8 @@ static inline void init_connected_peer(struct peer *peer, struct peers *peers) if ((int)(st->table->localupdate - st->update) < 0) st->update = st->table->localupdate + (2147483648U); st->teaching_origin = st->last_pushed = st->update; + if ((int)(st->last_pushed - st->table->commitupdate) > 0) + st->table->commitupdate = st->last_pushed; HA_SPIN_UNLOCK(STK_TABLE_LOCK, &st->table->lock); }