ODIn/spark-instrumented-optimizer
1
0
Fork 0
Code Issues Pull requests Projects Releases Wiki Activity

Removed some deprecated speed related code.

Browse source
This commit is contained in:
Mosharaf Chowdhury 2010-10-28 14:40:49 -07:00
parent bcc7d38ace
commit 681dba1373
1 changed files with 0 additions and 15 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

15
src/scala/spark/Broadcast.scala
View file

@ -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