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

Removed some commented sort/compare funtions from SourceInfo

Browse source
This commit is contained in:
Mosharaf Chowdhury 2010-10-19 15:31:27 -07:00
parent 5deb23df96
commit 4ad6c5218e
1 changed files with 1 additions and 18 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

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

@ -669,24 +669,7 @@ case class SourceInfo (val hostAddress: String, val listenPort: Int,
var MBps: Double = BroadcastCS.MaxMBps
// Ascending sort based on leecher count
def compareTo (o: SourceInfo): Int = (currentLeechers - o.currentLeechers)
// Descending sort based on speed
// def compareTo (o: SourceInfo): Int = {
// if (MBps > o.MBps) -1
// else if (MBps < o.MBps) 1
// else 0
// }
// Descending sort based on globally stored speed
// def compareTo (o: SourceInfo): Int = {
// val mySpeed = BroadcastCS.getSourceSpeed (hostAddress)
// val urSpeed = BroadcastCS.getSourceSpeed (o.hostAddress)
// if (mySpeed > urSpeed) -1
// else if (mySpeed < urSpeed) 1
// else 0
// }
def compareTo (o: SourceInfo): Int = (currentLeechers - o.currentLeechers)
}
@serializable