fox accepted chunk size

0chain · Jul 29, 2023 · 2847c53 · 2847c53
1 parent a0ea3af
commit 2847c53
Show file tree

Hide file tree

Showing 2 changed files with 6 additions and 1 deletion.
diff --git a/dstorage/dstorage.go b/dstorage/dstorage.go
@@ -42,6 +42,7 @@ type DStoreI interface {
 	GetAvailableSpace() int64
 	GetTotalSpace() int64
 	UpdateAllocationDetails() error
+	GetChunkWriteSize() int64
 }
 
 type DStorageService struct {
@@ -198,3 +199,7 @@ func GetDStorageService(allocationID, migrateTo, duplicateSuffix, workDir string
 		workDir:         workDir,
 	}, nil
 }
+
+func (d *DStorageService) GetChunkWriteSize() int64 {
+	return d.allocation.GetChunkReadSize(d.encrypt)
+}
diff --git a/migration/migrate.go b/migration/migrate.go
@@ -571,7 +571,7 @@ func (m *Migration) processChunkDownload(ctx context.Context, sw *util.StreamWri
 	migrator.DownloadStart(downloadObjMeta)
 	offset := 0
 	chunkSize := CHUNKSIZE
-	acceptedChunkSize := sdk.DefaultChunkSize
+	acceptedChunkSize := int(m.zStore.GetChunkWriteSize())
 	defer close(sw.DataChan)
 	for {
 		select {