Merge pull request #121 from 0chain/fix/op-batch

set multi op batch size
0chain · Jan 1, 2024 · c74bbb3 · c74bbb3
2 parents aba2629 + 2f4c462
commit c74bbb3
Show file tree

Hide file tree

Showing 2 changed files with 2 additions and 2 deletions.
diff --git a/cmd/migrate.go b/cmd/migrate.go
@@ -70,7 +70,7 @@ func init() {
 	migrateCmd.Flags().StringVar(&olderThanStr, "older-than", "", "eg; 7d10h --> migrate objects that is older than 7 days 10 hours")
 	migrateCmd.Flags().Int64Var(&chunkSize, "chunk-size", 50*1024*1024, "chunk size in bytes")
 	migrateCmd.Flags().IntVar(&chunkNumber, "chunk-number", 250, "number of chunks to upload")
-	migrateCmd.Flags().IntVar(&batchSize, "batch-size", 30, "number of files to upload in a batch")
+	migrateCmd.Flags().IntVar(&batchSize, "batch-size", 20, "number of files to upload in a batch")
 
 }
 

diff --git a/dstorage/dstorage.go b/dstorage/dstorage.go
@@ -174,7 +174,7 @@ func (d *DStorageService) GetTotalSpace() int64 {
 
 func GetDStorageService(allocationID, migrateTo, duplicateSuffix, workDir string, encrypt bool, chunkNumber, batchSize int) (*DStorageService, error) {
 	allocation, err := sdk.GetAllocation(allocationID)
-	sdk.BatchSize = batchSize
+	sdk.MultiOpBatchSize = batchSize
 	if err != nil {
 		return nil, err
 	}