diff options
| author | Mosharaf Chowdhury <mosharaf@mosharaf-ubuntu.(none)> | 2010-10-28 14:40:49 -0700 |
|---|---|---|
| committer | Mosharaf Chowdhury <mosharaf@mosharaf-ubuntu.(none)> | 2010-10-28 14:40:49 -0700 |
| commit | 681dba1373c9cf6ab2cc7ff9d6f467b49238ff0d (patch) | |
| tree | 5ede2632fa0297bdc58f7077a8c4902656a1ab46 | |
| parent | bcc7d38acee1e58d0b20996868f74427cea827f3 (diff) | |
| download | spark-681dba1373c9cf6ab2cc7ff9d6f467b49238ff0d.tar.gz spark-681dba1373c9cf6ab2cc7ff9d6f467b49238ff0d.tar.bz2 spark-681dba1373c9cf6ab2cc7ff9d6f467b49238ff0d.zip | |
Removed some deprecated speed related code.
| -rw-r--r-- | src/scala/spark/Broadcast.scala | 15 |
1 files changed, 0 insertions, 15 deletions
diff --git a/src/scala/spark/Broadcast.scala b/src/scala/spark/Broadcast.scala index 460d06d17d..78aa1601fc 100644 --- a/src/scala/spark/Broadcast.scala +++ b/src/scala/spark/Broadcast.scala @@ -928,7 +928,6 @@ case class SourceInfo (val hostAddress: String, val listenPort: Int, var currentLeechers = 0 var receptionFailed = false - var MBps: Double = BroadcastBT.MaxMBps var hasBlocksBitVector: BitSet = new BitSet (totalBlocks) } @@ -1129,20 +1128,6 @@ extends Logging { // def startMultiTracker // def stopMultiTracker -// def getSourceSpeed (hostAddress: String): Double = { -// sourceToSpeedMap.synchronized { -// sourceToSpeedMap.getOrElseUpdate(hostAddress, MaxMBps) -// } -// } - -// def setSourceSpeed (hostAddress: String, MBps: Double) = { -// sourceToSpeedMap.synchronized { -// var oldSpeed = sourceToSpeedMap.getOrElseUpdate(hostAddress, MaxMBps) -// var newSpeed = ALPHA * oldSpeed + (1 - ALPHA) * MBps -// sourceToSpeedMap.update (hostAddress, newSpeed) -// } -// } - class TrackMultipleValues extends Thread with Logging { var keepAccepting = true |