In the PgRecoveryEvent class created a
property call self._start_epoch, basically
the epoch of the current OSD. Then use
that propery in pg_update to only allow the
program to look at PG state only when
PG epoch >= start_epoch.
(cherry picked from commit
d37e8a4d84d873b7df264c63077805be8618ad7a)
Signed-off-by: Kamoltat <ksirivad@redhat.com>
self._progress = 0.0
+ self._start_epoch = _module.get_osdmap().get_epoch()
+
self.id = str(uuid.uuid4())
self._refresh()
complete.add(pg)
continue
# Only checks the state of each PGs when it's epoch >= the OSDMap's epoch
- if int(info['reported_epoch']) < int(start_epoch):
+ if int(info['reported_epoch']) < int(self._start_epoch):
continue
state = info['state']