fix pdpv0 renames

LexLuthr · LexLuthr · commit 19be79e69eeb · 2026-02-17T20:45:16.000+05:30
diff --git a/cmd/curio/tasks/tasks.go b/cmd/curio/tasks/tasks.go
@@ -44,7 +44,7 @@ import (
 	"github.com/filecoin-project/curio/tasks/message"
 	"github.com/filecoin-project/curio/tasks/metadata"
 	"github.com/filecoin-project/curio/tasks/pay"
-	"github.com/filecoin-project/curio/tasks/pdp"
+	"github.com/filecoin-project/curio/tasks/pdpv0"
 	piece2 "github.com/filecoin-project/curio/tasks/piece"
 	"github.com/filecoin-project/curio/tasks/proofshare"
 	"github.com/filecoin-project/curio/tasks/scrub"
@@ -295,22 +295,22 @@ func StartTasks(ctx context.Context, dependencies *deps.Deps, shutdownChan chan
 			es := getSenderEth()
 			sdeps.EthSender = es
 
-			pdp.NewDataSetWatch(db, must.One(dependencies.EthClient.Val()), chainSched)
+			pdpv0.NewDataSetWatch(db, must.One(dependencies.EthClient.Val()), chainSched)
 
 			pay.NewSettleWatcher(db, must.One(dependencies.EthClient.Val()), chainSched)
-			pdp.NewDataSetDeleteWatcher(db, must.One(dependencies.EthClient.Val()), chainSched)
-			pdp.NewTerminateServiceWatcher(db, must.One(dependencies.EthClient.Val()), chainSched)
-			pdp.NewPieceDeleteWatcher(&cfg.HTTP, db, must.One(dependencies.EthClient.Val()), chainSched, iStore)
-
-			pdpProveTask := pdp.NewProveTask(chainSched, db, must.One(dependencies.EthClient.Val()), dependencies.Chain, es, dependencies.CachedPieceReader)
-			pdpNextProvingPeriodTask := pdp.NewNextProvingPeriodTask(db, must.One(dependencies.EthClient.Val()), dependencies.Chain, chainSched, es)
-			pdpInitProvingPeriodTask := pdp.NewInitProvingPeriodTask(db, must.One(dependencies.EthClient.Val()), dependencies.Chain, chainSched, es)
-			pdpNotifTask := pdp.NewPDPNotifyTask(ctx, db)
-			pdpPullPieceTask := pdp.NewPDPPullPieceTask(ctx, db, lstor, 4)
+			pdpv0.NewDataSetDeleteWatcher(db, must.One(dependencies.EthClient.Val()), chainSched)
+			pdpv0.NewTerminateServiceWatcher(db, must.One(dependencies.EthClient.Val()), chainSched)
+			pdpv0.NewPieceDeleteWatcher(&cfg.HTTP, db, must.One(dependencies.EthClient.Val()), chainSched, iStore)
+
+			pdpProveTask := pdpv0.NewProveTask(chainSched, db, must.One(dependencies.EthClient.Val()), dependencies.Chain, es, dependencies.CachedPieceReader)
+			pdpNextProvingPeriodTask := pdpv0.NewNextProvingPeriodTask(db, must.One(dependencies.EthClient.Val()), dependencies.Chain, chainSched, es)
+			pdpInitProvingPeriodTask := pdpv0.NewInitProvingPeriodTask(db, must.One(dependencies.EthClient.Val()), dependencies.Chain, chainSched, es)
+			pdpNotifTask := pdpv0.NewPDPNotifyTask(ctx, db)
+			pdpPullPieceTask := pdpv0.NewPDPPullPieceTask(ctx, db, lstor, 4)
 			pdpIndexingTask := indexing.NewPDPIndexingTask(db, iStore, dependencies.CachedPieceReader, cfg, idxMax)
 			pdpIpniTask := indexing.NewPDPIPNITask(db, sc, dependencies.CachedPieceReader, cfg, idxMax)
-			pdpTerminate := pdp.NewTerminateServiceTask(db, must.One(dependencies.EthClient.Val()), senderEth)
-			pdpDelete := pdp.NewDeleteDataSetTask(db, must.One(dependencies.EthClient.Val()), senderEth)
+			pdpTerminate := pdpv0.NewTerminateServiceTask(db, must.One(dependencies.EthClient.Val()), senderEth)
+			pdpDelete := pdpv0.NewDeleteDataSetTask(db, must.One(dependencies.EthClient.Val()), senderEth)
 			payTask := pay.NewSettleTask(db, must.One(dependencies.EthClient.Val()), senderEth)
 			activeTasks = append(activeTasks, pdpProveTask, pdpNotifTask, pdpPullPieceTask, pdpNextProvingPeriodTask, pdpInitProvingPeriodTask, pdpIndexingTask, pdpIpniTask, pdpTerminate, pdpDelete, payTask)
 		}
diff --git a/tasks/pdpv0/dataset_watch.go b/tasks/pdpv0/dataset_watch.go
@@ -1,4 +1,4 @@
-package pdp
+package pdpv0
 
 import (
 	"context"
diff --git a/tasks/pdpv0/error_detection.go b/tasks/pdpv0/error_detection.go
@@ -1,4 +1,4 @@
-package pdp
+package pdpv0
 
 import (
 	"strings"
diff --git a/tasks/pdpv0/error_detection_test.go b/tasks/pdpv0/error_detection_test.go
@@ -1,4 +1,4 @@
-package pdp
+package pdpv0
 
 import (
 	"errors"
diff --git a/tasks/pdpv0/failure_handling.go b/tasks/pdpv0/failure_handling.go
@@ -1,4 +1,4 @@
-package pdp
+package pdpv0
 
 import (
 	"context"
diff --git a/tasks/pdpv0/notify_task.go b/tasks/pdpv0/notify_task.go
@@ -1,4 +1,4 @@
-package pdp
+package pdpv0
 
 import (
 	"bytes"
diff --git a/tasks/pdpv0/proofset_addroot_watch.go b/tasks/pdpv0/proofset_addroot_watch.go
@@ -1,4 +1,4 @@
-package pdp
+package pdpv0
 
 import (
 	"context"
diff --git a/tasks/pdpv0/proofset_create_watch.go b/tasks/pdpv0/proofset_create_watch.go
@@ -1,4 +1,4 @@
-package pdp
+package pdpv0
 
 import (
 	"context"
diff --git a/tasks/pdpv0/task_delete_data_set.go b/tasks/pdpv0/task_delete_data_set.go
@@ -1,4 +1,4 @@
-package pdp
+package pdpv0
 
 import (
 	"context"
diff --git a/tasks/pdpv0/task_init_pp.go b/tasks/pdpv0/task_init_pp.go
@@ -1,4 +1,4 @@
-package pdp
+package pdpv0
 
 import (
 	"context"
diff --git a/tasks/pdpv0/task_next_pp.go b/tasks/pdpv0/task_next_pp.go
@@ -1,4 +1,4 @@
-package pdp
+package pdpv0
 
 import (
 	"context"
diff --git a/tasks/pdpv0/task_prove.go b/tasks/pdpv0/task_prove.go
@@ -1,4 +1,4 @@
-package pdp
+package pdpv0
 
 import (
 	"context"
diff --git a/tasks/pdpv0/task_pull_piece.go b/tasks/pdpv0/task_pull_piece.go
@@ -1,4 +1,4 @@
-package pdp
+package pdpv0
 
 import (
 	"context"
diff --git a/tasks/pdpv0/task_terminate_fwss.go b/tasks/pdpv0/task_terminate_fwss.go
@@ -1,4 +1,4 @@
-package pdp
+package pdpv0
 
 import (
 	"context"
diff --git a/tasks/pdpv0/watch_data_set_delete.go b/tasks/pdpv0/watch_data_set_delete.go
@@ -1,4 +1,4 @@
-package pdp
+package pdpv0
 
 import (
 	"context"
diff --git a/tasks/pdpv0/watch_fwss_terminate.go b/tasks/pdpv0/watch_fwss_terminate.go
@@ -1,4 +1,4 @@
-package pdp
+package pdpv0
 
 import (
 	"context"
diff --git a/tasks/pdpv0/watch_piece_delete.go b/tasks/pdpv0/watch_piece_delete.go
@@ -1,4 +1,4 @@
-package pdp
+package pdpv0
 
 import (
 	"context"

Original file line number	Diff line number	Diff line change
`@@ -1,4 +1,4 @@`
`1`		`-package pdp`
	`1`	`+package pdpv0`
`2`	`2`
`3`	`3`	`import (`
`4`	`4`	`"context"`