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

make reporting requests parallel

Browse source
This commit is contained in:
Thibault Duplessis 2013-06-12 02:26:01 +02:00
parent 85d3cd89c2
commit 1744bef350
1 changed files with 6 additions and 7 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

13
modules/monitor/src/main/Reporting.scala
View file

@ -67,14 +67,13 @@ private[monitor] final class Reporting(
val before = nowMillis
MongoStatus(db.db)(mongoStatus) zip
(hub.actor.ai ? lila.hub.actorApi.ai.GetLoad).mapTo[Option[Int]] zip
List((hub.socket.site ? GetNbMembers),
(hub.socket.lobby ? GetNbMembers),
(hub.socket.round ? Size),
(hub.socket.round ? GetNbMembers),
(hub.actor.game ? lila.hub.actorApi.game.Count)
).map(_.mapTo[Int]).sequenceFu onComplete {
(hub.socket.site ? GetNbMembers).mapTo[Int] zip
(hub.socket.lobby ? GetNbMembers).mapTo[Int] zip
(hub.socket.round ? Size).mapTo[Int] zip
(hub.socket.round ? GetNbMembers).mapTo[Int] zip
(hub.actor.game ? lila.hub.actorApi.game.Count).mapTo[Int] onComplete {
case Failure(e) ⇒ logwarn("[reporting] " + e.getMessage)
case Success(((mongoS, aiL), List(siteMembers, lobbyMembers, gameHubs, gameMembers, games))) ⇒ {
case Success(((((((mongoS, aiL), siteMembers), lobbyMembers), gameHubs), gameMembers), games)) ⇒ {
latency = (nowMillis - before).toInt
site = SiteSocket(siteMembers)
lobby = LobbySocket(lobbyMembers)