From d0c0f3ea3901c48cda6bbacd876b7d3f6a4eb381 Mon Sep 17 00:00:00 2001 From: Vitaliy Filippov Date: Mon, 11 May 2026 13:17:36 +0300 Subject: [PATCH] Do not ignore cur_primary change on PG state validation errors --- src/client/etcd_state_client.cpp | 2 -- 1 file changed, 2 deletions(-) diff --git a/src/client/etcd_state_client.cpp b/src/client/etcd_state_client.cpp index bacf348d..6e4a7da1 100644 --- a/src/client/etcd_state_client.cpp +++ b/src/client/etcd_state_client.cpp @@ -1185,7 +1185,6 @@ void etcd_state_client_t::parse_state(const etcd_kv_t & kv) if (i >= pg_state_bit_count) { fprintf(stderr, "Unexpected pool %u PG %u state keyword in etcd: %s\n", pool_id, pg_num, e.dump().c_str()); - return; } } if (!cur_primary || !value["state"].is_array() || !state || @@ -1194,7 +1193,6 @@ void etcd_state_client_t::parse_state(const etcd_kv_t & kv) (state & PG_INCOMPLETE) && state != PG_INCOMPLETE && state != (PG_INCOMPLETE|PG_HAS_INVALID)) { fprintf(stderr, "Unexpected pool %u PG %u state in etcd: primary=%ju, state=%s\n", pool_id, pg_num, cur_primary, value["state"].dump().c_str()); - return; } pg_cfg.cur_primary = cur_primary; pg_cfg.cur_state = state;