@@ -1372,22 +1372,20 @@ impl Downstairs {
1372
1372
up_state : & UpstairsState ,
1373
1373
) {
1374
1374
let extent_count = self . ddef . unwrap ( ) . extent_count ( ) ;
1375
- // Load a partially valid repair state (`min_id` and `state` are bogus);
1376
- // `state` will be updated in `send_live_repair_jobs`, and `min_jobs`
1377
- // will be set once we know the close job ID.
1375
+ // Load a partially valid repair state, with a dummy `state` (to be
1376
+ // updated in `send_live_repair_jobs`).
1378
1377
self . repair = Some ( LiveRepairData {
1379
1378
id : Uuid :: new_v4 ( ) ,
1380
1379
extent_count,
1381
1380
repair_downstairs : repair_downstairs. to_vec ( ) ,
1382
1381
source_downstairs,
1383
1382
aborting_repair : false ,
1384
1383
active_extent : ExtentId ( 0 ) ,
1385
- min_id : JobId ( 0 ) , // fixed below
1384
+ min_id : self . peek_next_id ( ) , // upcoming close_id
1386
1385
repair_job_ids : BTreeMap :: new ( ) ,
1387
1386
state : LiveRepairState :: dummy ( ) , // fixed when sending jobs
1388
1387
} ) ;
1389
- let extent_repair_ids = self . send_live_repair_jobs ( up_state) ;
1390
- self . repair . as_mut ( ) . unwrap ( ) . min_id = extent_repair_ids. close_id ;
1388
+ self . send_live_repair_jobs ( up_state) ;
1391
1389
}
1392
1390
1393
1391
/// Increments `self.repair.active_extent` and sends new jobs
@@ -1413,10 +1411,7 @@ impl Downstairs {
1413
1411
/// aborting the repair but either (1) the source downstairs is not
1414
1412
/// `DsState::Active`, or (2) the repair downstairs are not all
1415
1413
/// `DsState::LiveRepair`.
1416
- fn send_live_repair_jobs (
1417
- & mut self ,
1418
- up_state : & UpstairsState ,
1419
- ) -> ExtentRepairIDs {
1414
+ fn send_live_repair_jobs ( & mut self , up_state : & UpstairsState ) {
1420
1415
// Keep going!
1421
1416
let repair = self . repair . as_mut ( ) . unwrap ( ) ;
1422
1417
@@ -1488,7 +1483,6 @@ impl Downstairs {
1488
1483
& repair_downstairs,
1489
1484
)
1490
1485
} ;
1491
- extent_repair_ids
1492
1486
}
1493
1487
1494
1488
/// Creates a [DownstairsIO] job for an [IOop::ExtentLiveReopen], and
0 commit comments