count open site websockets

pull/4722/head
Thibault Duplessis 2018-11-27 11:11:49 +07:00
parent e43b7e2b8b
commit 044c14c0f4
3 changed files with 6 additions and 2 deletions

View File

@ -26,7 +26,7 @@ private final class KamonPusher(
def receive = { def receive = {
case NbMembers(nb) => case NbMembers(nb) =>
lila.mon.socket.member(nb) lila.mon.socket.count.all(nb)
case NbRounds(nb) => case NbRounds(nb) =>
lila.mon.round.actor.count(nb) lila.mon.round.actor.count(nb)

View File

@ -273,11 +273,14 @@ object mon {
} }
} }
object socket { object socket {
val member = rec("socket.count")
val open = inc("socket.open") val open = inc("socket.open")
val close = inc("socket.close") val close = inc("socket.close")
def eject(userId: String) = inc(s"socket.eject.user.$userId") def eject(userId: String) = inc(s"socket.eject.user.$userId")
val ejectAll = inc(s"socket.eject.all") val ejectAll = inc(s"socket.eject.all")
object count {
val all = rec("socket.count")
val site = rec("socket.count.site")
}
} }
object mod { object mod {
object report { object report {

View File

@ -40,6 +40,7 @@ private[site] final class Socket(timeout: Duration) extends SocketActor[Member](
members foreach { members foreach {
case (uid, member) => if (!aliveUids.get(uid) && !member.isApi) ejectUidString(uid) case (uid, member) => if (!aliveUids.get(uid) && !member.isApi) ejectUidString(uid)
} }
lila.mon.socket.count.site(members.size)
} }
override def quit(uid: Socket.Uid): Unit = { override def quit(uid: Socket.Uid): Unit = {