Merge pull request #240 from CortexFoundation/dev

torrent/client | path management of already existing ones

Author: ucwong

torrentfs/torrentClient.go

@@ -827,12 +827,42 @@ func (tm *TorrentManager) listenTorrentProgress() {
 
 				if t.Finished() {
 					tm.lock.Lock()
-					err := os.Symlink(
-						path.Join(defaultTmpFilePath, t.InfoHash()),
-						path.Join(tm.DataDir, t.InfoHash()),
-					)
+					if _, err := os.Stat(path.Join(tm.DataDir, t.InfoHash())); err == nil {
+						log.Debug("Path exist", "hash", t.Torrent.InfoHash(), "path", path.Join(tm.DataDir, t.InfoHash()))
+						delete(tm.activeTorrents, ih)
+						tm.seedingTorrents[ih] = t
+						t.Seed()
+						t.loop = defaultSeedInterval / queryTimeInterval
+						total_size += uint64(t.bytesCompleted)
+						current_size += uint64(t.bytesCompleted)
+					} else {
+						//log.Info("Path not exist", "hash", t.Torrent.InfoHash(), "path", path.Join(tm.DataDir, t.InfoHash()))
+						err := os.Symlink(
+							path.Join(defaultTmpFilePath, t.InfoHash()),
+							path.Join(tm.DataDir, t.InfoHash()),
+						)
 
-					if err != nil {
+						if err != nil {
+							//log.Warn("Seeding path error", "hash", t.Torrent.InfoHash(), "size", t.bytesCompleted, "miss", t.bytesMissing, "loop", log_counter)
+							err = os.Remove(
+								path.Join(tm.DataDir, t.InfoHash()),
+							)
+							if err != nil {
+								//      log.Warn("Fix path error", "hash", t.Torrent.InfoHash(), "size", t.bytesCompleted, "miss", t.bytesMissing, "loop", log_counter)
+							} else {
+								log.Debug("Fix path success", "hash", t.Torrent.InfoHash(), "size", t.bytesCompleted, "miss", t.bytesMissing, "loop", log_counter)
+							}
+						} else {
+							delete(tm.activeTorrents, ih)
+							tm.seedingTorrents[ih] = t
+							t.Seed()
+							t.loop = defaultSeedInterval / queryTimeInterval
+							total_size += uint64(t.bytesCompleted)
+							current_size += uint64(t.bytesCompleted)
+						}
+					}
+
+					/*if err != nil {
 						//log.Warn("Seeding path error", "hash", t.Torrent.InfoHash(), "size", t.bytesCompleted, "miss", t.bytesMissing, "loop", log_counter)
 						err = os.Remove(
 							path.Join(tm.DataDir, t.InfoHash()),
@@ -849,7 +879,7 @@ func (tm *TorrentManager) listenTorrentProgress() {
 						t.loop = defaultSeedInterval / queryTimeInterval
 						total_size += uint64(t.bytesCompleted)
 						current_size += uint64(t.bytesCompleted)
-					}
+					}*/
 					tm.lock.Unlock()
 					continue
 				}