tgdrive/teldrive
1
1
Fork 0
mirror of https://github.com/tgdrive/teldrive.git synced 2025-09-12 09:25:37 +08:00
Code Issues Projects Releases Packages Wiki Activity Actions

fixed total parts calculation

Browse source
This commit is contained in:
divyam234 2023-09-05 00:06:52 +05:30
parent 2b08b57ebf
commit 73bd58d81a
1 changed files with 1 additions and 13 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

14
services/file.service.go
View file

@ -513,25 +513,13 @@ func chunk(ctx context.Context, tgClient *telegram.Client, part *types.Part, off
} }
} }
func totalParts(start, end, chunkSize int64) int {
totalBytes := end - start + 1
parts := totalBytes / chunkSize
if totalBytes%chunkSize != 0 {
parts++
}
return int(parts)
}
func streamFilePart(ctx context.Context, tgClient *telegram.Client, writer *io.PipeWriter, part *types.Part, start, end, chunkSize int64) error { func streamFilePart(ctx context.Context, tgClient *telegram.Client, writer *io.PipeWriter, part *types.Part, start, end, chunkSize int64) error {
offset := start - (start % chunkSize) offset := start - (start % chunkSize)
firstPartCut := start - offset firstPartCut := start - offset
lastPartCut := (end % chunkSize) + 1 lastPartCut := (end % chunkSize) + 1
partCount := totalParts(start, end, chunkSize) partCount := int(math.Ceil(float64(end+1)/float64(chunkSize))) - int(math.Floor(float64(offset)/float64(chunkSize)))
currentPart := 1 currentPart := 1