blob: 65b81c0ca174dd8b8bf2b28468d48007d2f36bbf (
plain) (
blame)
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
|
/*
* @author Stephane Micheloud
*/
import java.io._
import scala.compat.Platform.currentTime
import scala.remoting.Debug, Debug._
trait ServerConsole extends Thread {
private val startTime = currentTime
start()
private var isTerminated = false
def terminate() { isTerminated = true }
protected def loop(block: => Unit) {
while (!isTerminated) {
try {
block
}
catch {
case e: ObjectStreamException =>
trace("Object stream error ("+e.getMessage+")")
case e: EOFException =>
trace("Connection lost")
case e: ClassNotFoundException =>
trace("Class not found")
case e =>
trace("Server error: "+e)
}
}
}
override def run() {
val in = new BufferedReader(new InputStreamReader(System.in))
var quit = false
while (!quit) {
val args = getArgs(in)
if (args contains "quit")
quit = true
if (args contains "cls") {
println(ERASE_SCREEN)
println(CURSOR_HOME)
}
if (args contains "warning")
Debug.level = Level.WARNING
if (args contains "info")
Debug.level = Level.INFO
if (args contains "silent")
Debug.level = Level.SILENT
}
terminate()
println("Server exited ("+mkTimeString(currentTime - startTime)+")")
exit(0)
}
protected def trace(msg: String) {
Debug.info("[ServerConsole.trace] "+msg)
}
private def getArgs(in: BufferedReader): List[String] = {
print("> ")
val input = try { in.readLine() } catch { case _ => null }
if (input != null) (input.trim split "\\s+").toList else Nil
}
private def mkTimeString(time: Long): String = {
def twoDigits(i: Long) = (if (i < 10) "0" else "")+i
val sec = time / 1000
val min = sec / 60
val h = min / 60
twoDigits(h) +":"+
twoDigits(min - h * 60)+":"+
twoDigits(sec - min * 60)
}
private val ERASE_SCREEN = "\033[2J"
private val CURSOR_HOME = "\033[H"
}
|
