diff --git a/p2p/p2p.go b/p2p/p2p.go index 7baceaa..cf5f450 100644 --- a/p2p/p2p.go +++ b/p2p/p2p.go @@ -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