From 681dba1373c9cf6ab2cc7ff9d6f467b49238ff0d Mon Sep 17 00:00:00 2001
From: Mosharaf Chowdhury <mosharaf@mosharaf-ubuntu.(none)>
Date: Thu, 28 Oct 2010 14:40:49 -0700
Subject: [PATCH] Removed some deprecated speed related code.

---
 src/scala/spark/Broadcast.scala | 15 ---------------
 1 file changed, 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