Skip to content

Commit

Permalink
fix logger usage
Browse files Browse the repository at this point in the history
  • Loading branch information
Rico Schiekel committed Sep 2, 2010
1 parent 3256a03 commit 90712d2
Showing 1 changed file with 2 additions and 2 deletions.
4 changes: 2 additions & 2 deletions src/main/scala/game/PlayerProc.scala
Original file line number Diff line number Diff line change
Expand Up @@ -5,7 +5,7 @@ import se.scalablesolutions.akka.util.Logging
import java.io.{InputStream, BufferedReader, InputStreamReader}
import se.scalablesolutions.akka.actor.ActorRef

class StreamLogger(prefix: String, in: InputStream, logf: (String, Any*) => Unit) extends Thread {
class StreamLogger(prefix: String, in: InputStream, logf: ((=>String) => Unit)) extends Thread {
override def run() {
val reader = new BufferedReader(new InputStreamReader(in))
var line: String = ""
Expand All @@ -20,7 +20,7 @@ class StreamLogger(prefix: String, in: InputStream, logf: (String, Any*) => Unit

class PlayerProc(val player: Player, val game: ActorRef, gamePort: Int) extends Thread with Logging {
val proc = new ProcessBuilder("/opt/scala/bin/scala", "-cp", PlayerProc.cp, "player.RunPlayer", player.port.toString, gamePort.toString).start()
val input = new StreamLogger("player" + player.port, proc.getInputStream(), log.info)
val input = new StreamLogger("player" + player.port, proc.getInputStream(), log.info)
val output = new StreamLogger("player" + player.port, proc.getErrorStream(), log.error)

start()
Expand Down

0 comments on commit 90712d2

Please sign in to comment.