diff --git a/core/src/main/scala/spark/BitTorrentBroadcast.scala b/core/src/main/scala/spark/BitTorrentBroadcast.scala index dba9d39abfae7b49b1ee604fd76cd31de264643d..887f6e51786a39afb68f55f997b7ecaa17aae4bd 100644 --- a/core/src/main/scala/spark/BitTorrentBroadcast.scala +++ b/core/src/main/scala/spark/BitTorrentBroadcast.scala @@ -113,7 +113,7 @@ extends Broadcast[T] with Logging { } // In the beginning, this is the only known source to Guide - listOfSources = listOfSources + masterSource + listOfSources += masterSource // Register with the Tracker BitTorrentBroadcast.registerValue (uuid, @@ -268,7 +268,7 @@ extends Broadcast[T] with Logging { if (listOfSources.contains(newSourceInfo)) { listOfSources = listOfSources - newSourceInfo } - listOfSources = listOfSources + newSourceInfo + listOfSources += newSourceInfo } } @@ -446,7 +446,7 @@ extends Broadcast[T] with Logging { // Add to peersNowTalking. Remove in the thread. We have to do this // ASAP, otherwise pickPeerToTalkTo picks the same peer more than once peersNowTalking.synchronized { - peersNowTalking = peersNowTalking + peerToTalkTo + peersNowTalking += peerToTalkTo } } @@ -878,7 +878,7 @@ extends Broadcast[T] with Logging { i = i - 1 } - selectedSources = selectedSources + curPeer + selectedSources += curPeer alreadyPicked.set (i) picksLeft = picksLeft - 1