add validationComplete event notifying

mpetazzoni · Dec 6, 2018 · 7078339 · 7078339
1 parent 4dc7603
commit 7078339
Showing 1 changed file with 5 additions and 1 deletion.
diff --git a/ttorrent-client/src/main/java/com/turn/ttorrent/client/CommunicationManager.java b/ttorrent-client/src/main/java/com/turn/ttorrent/client/CommunicationManager.java
@@ -41,7 +41,10 @@
 import java.nio.ByteBuffer;
 import java.nio.channels.ByteChannel;
 import java.util.*;
-import java.util.concurrent.*;
+import java.util.concurrent.ExecutorService;
+import java.util.concurrent.Future;
+import java.util.concurrent.RejectedExecutionException;
+import java.util.concurrent.TimeUnit;
 import java.util.concurrent.atomic.AtomicBoolean;
 import java.util.concurrent.atomic.AtomicInteger;
 
@@ -219,6 +222,7 @@ public TorrentManager addTorrent(TorrentMetadataProvider metadataProvider,
       long left = calculateLeft(pieceStorage, torrentMetadata);
       loadedTorrent.getTorrentStatistic().setLeft(left);
     }
+    eventDispatcher.multicaster().validationComplete(pieceStorage.getAvailablePieces().cardinality(), torrentMetadata.getPiecesCount());
 
     this.torrentsStorage.addTorrent(loadedTorrent.getTorrentHash().getHexInfoHash(), loadedTorrent);
     forceAnnounceAndLogError(loadedTorrent, pieceStorage.isFinished() ? COMPLETED : STARTED);