@@ -247,8 +247,9 @@ impl<'db, BS: Blockstore> ExpirationQueue<'db, BS> {
247
247
let groups = self . find_sectors_by_expiration ( sector_size, sectors) ?;
248
248
249
249
// Group sectors by their target expiration, then remove from existing queue entries according to those groups.
250
+ let new_quantized_expiration = self . quant . quantize_up ( new_expiration) ;
250
251
for mut group in groups {
251
- if group. sector_epoch_set . epoch <= self . quant . quantize_up ( new_expiration ) {
252
+ if group. sector_epoch_set . epoch <= new_quantized_expiration {
252
253
// Don't reschedule sectors that are already due to expire on-time before the fault-driven expiration,
253
254
// but do represent their power as now faulty.
254
255
// Their pledge remains as "on-time".
@@ -297,10 +298,11 @@ impl<'db, BS: Blockstore> ExpirationQueue<'db, BS> {
297
298
298
299
let mut mutated_expiration_sets = Vec :: < ( ChainEpoch , ExpirationSet ) > :: new ( ) ;
299
300
301
+ let quantized_fault_expiration = self . quant . quantize_up ( fault_expiration) ;
300
302
self . amt . for_each ( |e, expiration_set| {
301
303
let epoch: ChainEpoch = e. try_into ( ) ?;
302
304
303
- if epoch <= self . quant . quantize_up ( fault_expiration ) {
305
+ if epoch <= quantized_fault_expiration {
304
306
let mut expiration_set = expiration_set. clone ( ) ;
305
307
306
308
// Regardless of whether the sectors were expiring on-time or early, all the power is now faulty.
0 commit comments