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

faster maintenance tasks

Browse source
This commit is contained in:
Thibault Duplessis 2013-09-25 18:52:56 +02:00
parent a925edf069
commit 51b0f46641
1 changed files with 3 additions and 3 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

6
modules/round/src/main/Titivate.scala
View file

@ -20,15 +20,15 @@ private[round] final class Titivate(
scheduler: Scheduler) {
def finishByClock: Funit =
$primitive(Query.candidatesToAutofinish, "_id")(_.asOpt[String]) addEffect { ids ⇒
$primitive(Query.candidatesToAutofinish, "_id", max = 5000.some)(_.asOpt[String]) addEffect { ids ⇒
println("[titivate] Finish %d games by clock" format ids.size)
delayBatch(ids, 300.millis) { id ⇒ roundMap ! Tell(id, Outoftime).pp }
delayBatch(ids, 100.millis) { id ⇒ roundMap ! Tell(id, Outoftime) }
} void
def finishAbandoned: Funit =
$primitive(Query.abandoned, "_id", max = 5000.some)(_.asOpt[String]) addEffect { ids ⇒
println("[titivate] Finish %d abandoned games" format ids.size)
delayBatch(ids, 200.millis) { id ⇒ roundMap ! Tell(id, Abandon).pp }
delayBatch(ids, 100.millis) { id ⇒ roundMap ! Tell(id, Abandon) }
} void
private def delayBatch[A](batch: Seq[A], duration: FiniteDuration)(op: A ⇒ Unit) {