go/torrent-client
1
0
Fork 0
mirror of https://github.com/veggiedefender/torrent-client.git synced 2025-11-06 17:39:54 +02:00
Code Issues Releases Activity

Rename downloadWorker to startDownloadWorker

Browse Source
This commit is contained in:
Jesse
2019-12-29 15:12:20 -05:00
parent 738af57ef1
commit ffa8c82919
1 changed files with 2 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

4
p2p/p2p.go
View File

@@ -124,7 +124,7 @@ func checkIntegrity(pw *pieceWork, buf []byte) error {
return nil
}
func (t *Torrent) downloadWorker(peer Peer, workQueue chan *pieceWork, results chan *pieceResult) {
func (t *Torrent) startDownloadWorker(peer Peer, workQueue chan *pieceWork, results chan *pieceResult) {
c, err := newClient(peer, t.PeerID, t.InfoHash)
if err != nil {
log.Printf("Could not handshake with %s. Disconnecting\n", peer.IP)
@@ -181,7 +181,7 @@ func (t *Torrent) Download() ([]byte, error) {
// Start workers
for _, peer := range t.Peers {
go t.downloadWorker(peer, workQueue, results)
go t.startDownloadWorker(peer, workQueue, results)
}
// Collect results into a buffer until full