Peernet-Archive/core
1
0
Fork 0
mirror of https://github.com/PeernetOfficial/core.git synced 2026-07-19 03:27:50 +01:00
Code Issues Packages Projects Releases Wiki Activity

Fix bug in transfer code. A wrong transfer size was returned when an offset was used.

Browse Source
This commit is contained in:
Kleissner
2021-11-03 21:02:00 +01:00
parent 4bb8ac7adf
commit 451aac9c47
1 changed files with 2 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

3
Transfer UDT.go
View File

@@ -48,6 +48,7 @@ func (peer *PeerInfo) startFileTransferUDT(hash []byte, fileSize uint64, offset,
udtConfig.MaxPacketSize = protocol.TransferMaxEmbedSize
// start UDT sender
// Set streaming to true, otherwise udtSocket.Read returns the error "Message truncated" in case the reader has a smaller buffer.
udtConn, err := udt.DialUDT(udtConfig, virtualConnection, virtualConnection.incomingData, virtualConnection.outgoingData, virtualConnection.terminateChan, true)
if err != nil {
return err
@@ -58,7 +59,7 @@ func (peer *PeerInfo) startFileTransferUDT(hash []byte, fileSize uint64, offset,
// Start by sending the header: Total File Size and Transfer Size.
header := make([]byte, 16)
binary.LittleEndian.PutUint64(header[0:8], fileSize)
binary.LittleEndian.PutUint64(header[8:16], limit-offset)
binary.LittleEndian.PutUint64(header[8:16], limit)
if n, err := udtConn.Write(header); err != nil {
return err
} else if n != len(header) {