deepcrayon/lila
deepcrayon/lila
1
0
Fork 0
Code Releases Activity

temporary disable scheduler

Browse source
This commit is contained in:
Thibault Duplessis 2013-05-10 10:41:22 -03:00
parent edaff6b8ea
commit 1f7e087c95
2 changed files with 6 additions and 8 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

11
app/controllers/Round.scala
View file

@ -20,7 +20,6 @@ object Round extends LilaController with TheftPrevention with RoundEventPerforme
private def bookmarkApi = Env.bookmark.api
private def analyser = Env.analyse.analyser
// private def tournamentRepo = Env.tournament.repo
private def gameJs = Env.game.gameJs
def websocketWatcher(gameId: String, color: String) = Socket[JsValue] { implicit ctx ⇒
(get("sri") |@| getInt("version")).tupled zmap {
@ -28,16 +27,14 @@ object Round extends LilaController with TheftPrevention with RoundEventPerforme
}
}
def websocketPlayer(fullId: String) = WebSocket.async[JsValue] { implicit req ⇒
reqToCtx(req) flatMap { implicit ctx ⇒
(get("sri") |@| getInt("version") |@| get("tk2")).tupled zmap {
case (uid, version, token) ⇒ env.socketHandler.player(fullId, version, uid, token, ctx)
}
def websocketPlayer(fullId: String) = Socket[JsValue] { implicit ctx ⇒
(get("sri") |@| getInt("version") |@| get("tk2")).tupled zmap {
case (uid, version, token) ⇒ env.socketHandler.player(fullId, version, uid, token, ctx)
}
}
def signedJs(gameId: String) = OpenNoCtx { req ⇒
JsOk(GameRepo token gameId map gameJs.sign, CACHE_CONTROL -> "max-age=3600")
JsOk(GameRepo token gameId map Env.game.gameJs.sign, CACHE_CONTROL -> "max-age=3600")
}
def player(fullId: String) = Open { implicit ctx ⇒

3
modules/common/src/main/PlayApp.scala
View file

@ -16,7 +16,8 @@ object PlayApp {
play.api.libs.concurrent.Akka.system
}
def scheduler = new Scheduler(system, enabled = isServer)
private def enableScheduler = false // isServer
def scheduler = new Scheduler(system, enabled = enableScheduler)
def isDev = isMode(_.Dev)
def isTest = isMode(_.Test)