Removed some unnecessary stuff.

1 files changed, 1 insertions, 13 deletions

diff --git a/src/scala/spark/Broadcast.scala b/src/scala/spark/Broadcast.scala
index 476426b674..1e7a32eba1 100644
--- a/src/scala/spark/Broadcast.scala
+++ b/src/scala/spark/Broadcast.scala
@@ -1262,17 +1262,7 @@ extends Logging {
 
   class TrackMultipleValues
   extends Thread with Logging {
-    var stopTracker = false
-    
     override def run = {
-      var myThreadFactory = new ThreadFactory {
-        def newThread(r: Runnable): Thread = {
-          var t = Executors.defaultThreadFactory.newThread(r)
-          t.setDaemon(true)
-          return t
-        }
-      }
-    
       var threadPool = BroadcastBT.newDaemonCachedThreadPool
       var serverSocket: ServerSocket = null
       
@@ -1280,16 +1270,14 @@ extends Logging {
       logInfo ("TrackMultipleValues" + serverSocket)
       
       try {
-        while (!stopTracker) {
+        while (true) {
           var clientSocket: Socket = null
           try {
-            // TODO: 
             serverSocket.setSoTimeout (TrackerSocketTimeout)
             clientSocket = serverSocket.accept
           } catch {
             case e: Exception => {
               logInfo ("TrackMultipleValues Timeout. Stopping listening...") 
-              stopTracker = true 
             }
           }