aboutsummaryrefslogtreecommitdiff
diff options
context:
space:
mode:
authorMosharaf Chowdhury <mosharaf@mosharaf-ubuntu.(none)>2010-11-30 18:45:04 -0800
committerMosharaf Chowdhury <mosharaf@mosharaf-ubuntu.(none)>2010-11-30 18:45:04 -0800
commita69638d98da27151086f85b2e0476ee4c2f92b4b (patch)
treefa49f3cf6987086ec43b33a87341455f992dbbc0
parentb7dda4c5bcec5c018fa145516b4e26f072862bf6 (diff)
downloadspark-a69638d98da27151086f85b2e0476ee4c2f92b4b.tar.gz
spark-a69638d98da27151086f85b2e0476ee4c2f92b4b.tar.bz2
spark-a69638d98da27151086f85b2e0476ee4c2f92b4b.zip
Removed deprecated repl file ClassServer.scala
-rw-r--r--src/scala/spark/repl/ClassServer.scala77
1 files changed, 0 insertions, 77 deletions
diff --git a/src/scala/spark/repl/ClassServer.scala b/src/scala/spark/repl/ClassServer.scala
deleted file mode 100644
index 6a40d92765..0000000000
--- a/src/scala/spark/repl/ClassServer.scala
+++ /dev/null
@@ -1,77 +0,0 @@
-package spark.repl
-
-import java.io.File
-import java.net.InetAddress
-
-import org.eclipse.jetty.server.Server
-import org.eclipse.jetty.server.handler.DefaultHandler
-import org.eclipse.jetty.server.handler.HandlerList
-import org.eclipse.jetty.server.handler.ResourceHandler
-
-import spark.Logging
-
-
-/**
- * Exception type thrown by ClassServer when it is in the wrong state
- * for an operation.
- */
-class ServerStateException(message: String) extends Exception(message)
-
-
-/**
- * An HTTP server used by the interpreter to allow worker nodes to access
- * class files created as the user types in lines of code. This is just a
- * wrapper around a Jetty embedded HTTP server.
- */
-class ClassServer(classDir: File) extends Logging {
- private var server: Server = null
- private var port: Int = -1
-
- def start() {
- if (server != null) {
- throw new ServerStateException("Server is already started")
- } else {
- server = new Server(0)
- val resHandler = new ResourceHandler
- resHandler.setResourceBase(classDir.getAbsolutePath)
- val handlerList = new HandlerList
- handlerList.setHandlers(Array(resHandler, new DefaultHandler))
- server.setHandler(handlerList)
- server.start()
- port = server.getConnectors()(0).getLocalPort()
- logDebug("ClassServer started at " + uri)
- }
- }
-
- def stop() {
- if (server == null) {
- throw new ServerStateException("Server is already stopped")
- } else {
- server.stop()
- port = -1
- server = null
- }
- }
-
- /**
- * Get the URI of this HTTP server (http://host:port)
- */
- def uri: String = {
- if (server == null) {
- throw new ServerStateException("Server is not started")
- } else {
- return "http://" + getLocalIpAddress + ":" + port
- }
- }
-
- /**
- * Get the local host's IP address in dotted-quad format (e.g. 1.2.3.4)
- */
- private def getLocalIpAddress: String = {
- // Get local IP as an array of four bytes
- val bytes = InetAddress.getLocalHost().getAddress()
- // Convert the bytes to ints (keeping in mind that they may be negative)
- // and join them into a string
- return bytes.map(b => (b.toInt + 256) % 256).mkString(".")
- }
-}