defer t.cl.unlock()
log.Printf("AllowDataDownload")
t.dataDownloadDisallowed = false
- for c := range t.conns {
+ t.iterPeers(func(c *peer) {
c.updateRequests()
- }
-
+ })
}
+func (t *Torrent) AllowDataUpload() {
+ t.cl.lock()
+ defer t.cl.unlock()
+ log.Printf("AllowDataUpload")
+ t.dataUploadDisallowed = false
+ for c := range t.conns {
+ c.updateRequests()
+ }
+}
+
+func (t *Torrent) DisallowDataUpload() {
+ t.cl.lock()
+ defer t.cl.unlock()
+ log.Printf("DisallowDataUpload")
+ t.dataUploadDisallowed = true
+ for c := range t.conns {
+ c.updateRequests()
+ }
+}
+
func (t *Torrent) SetOnWriteChunkError(f func(error)) {
t.cl.lock()
defer t.cl.unlock()