use correct expiration in precommit (#99)

filecoin-project · Jul 17, 2024 · fadcde3 · fadcde3
1 parent 24b4c11
commit fadcde3
Showing 1 changed file with 6 additions and 2 deletions.
diff --git a/tasks/seal/task_submit_precommit.go b/tasks/seal/task_submit_precommit.go
@@ -158,6 +158,7 @@ func (s *SubmitPrecommitTask) Do(taskID harmonytask.TaskID, stillOwned func() bo
 		}
 
 		if len(pieces) > 0 {
+			var endEpoch abi.ChainEpoch
 			params.Sectors[0].UnsealedCid = &unsealedCID
 			for _, p := range pieces {
 				if p.DealStartEpoch > 0 && abi.ChainEpoch(p.DealStartEpoch) < head.Height() {
@@ -170,10 +171,13 @@ func (s *SubmitPrecommitTask) Do(taskID harmonytask.TaskID, stillOwned func() bo
 					}
 					return true, xerrors.Errorf("deal start epoch is in the past")
 				}
-				if p.DealEndEpoch > 0 && abi.ChainEpoch(p.DealEndEpoch) > params.Sectors[0].Expiration {
-					params.Sectors[0].Expiration = abi.ChainEpoch(p.DealEndEpoch)
+				if p.DealEndEpoch > 0 && abi.ChainEpoch(p.DealEndEpoch) > endEpoch {
+					endEpoch = abi.ChainEpoch(p.DealEndEpoch)
 				}
 			}
+			if endEpoch != params.Sectors[0].Expiration {
+				params.Sectors[0].Expiration = endEpoch
+			}
 		}
 	}