aboutsummaryrefslogtreecommitdiff
diff options
context:
space:
mode:
authorMosharaf Chowdhury <mosharaf@mosharaf-ubuntu.(none)>2010-11-25 23:49:57 -0800
committerMosharaf Chowdhury <mosharaf@mosharaf-ubuntu.(none)>2010-11-25 23:49:57 -0800
commit830496b901d0abd99f6413015e8ad1d70efb724e (patch)
treeb402aba0f0b53e5ee700339b3afca3a5d4fd1790
parent2de1664214001e916fa2d10d5a9cd153cc1392ff (diff)
downloadspark-830496b901d0abd99f6413015e8ad1d70efb724e.tar.gz
spark-830496b901d0abd99f6413015e8ad1d70efb724e.tar.bz2
spark-830496b901d0abd99f6413015e8ad1d70efb724e.zip
Updated some comments.
-rw-r--r--src/scala/spark/Broadcast.scala5
1 files changed, 1 insertions, 4 deletions
diff --git a/src/scala/spark/Broadcast.scala b/src/scala/spark/Broadcast.scala
index de4ea3aa4b..432fc5bb4c 100644
--- a/src/scala/spark/Broadcast.scala
+++ b/src/scala/spark/Broadcast.scala
@@ -866,9 +866,7 @@ extends BroadcastRecipe with Logging {
}
}
- // TODO: Randomly select some sources to send back.
- // Right now just rolls over the listOfSources to send back
- // BroadcastBT.MaxPeersInGuideResponse number of possible sources
+ // Randomly select some sources to send back
private def selectSuitableSources(skipSourceInfo: SourceInfo): ListBuffer[SourceInfo] = {
var selectedSources = ListBuffer[SourceInfo] ()
@@ -1218,7 +1216,6 @@ extends Logging {
// var sourceToSpeedMap = Map[String, Double] ()
// Random number generator
- // TODO: Need a better seed than the default System.currentTimeInMillis?
var ranGen = new Random
private var initialized = false