diff --git a/src/scala/spark/BitTorrentBroadcast.scala b/src/scala/spark/BitTorrentBroadcast.scala index 77b16a73b441ed3cdad250fb5eaff980bee4b391..6945cb743f63178da4f8a68b0b3653f9bdc8d9bf 100644 --- a/src/scala/spark/BitTorrentBroadcast.scala +++ b/src/scala/spark/BitTorrentBroadcast.scala @@ -591,8 +591,8 @@ extends Broadcast[T] with Logging { // Update the hasBlocksBitVector first hasBlocksBitVector.synchronized { hasBlocksBitVector.set (bcBlock.blockID) + hasBlocks += 1 } - hasBlocks += 1 rxSpeeds.addDataPoint (peerToTalkTo, receptionTime)