so apparently that never happens on prod

roundTrouper
Thibault Duplessis 2018-12-10 11:29:14 +07:00
parent 336200a517
commit 30e109ec2e
2 changed files with 1 additions and 6 deletions

View File

@ -292,7 +292,6 @@ object mon {
val site = rec("socket.count.site")
}
def queueSize(name: String) = rec(s"socket.queue_size.$name")
def pushChannelClosed = inc("socket.push.channel_closed")
}
object trouper {
def queueSize(name: String) = rec(s"trouper.queue_size.$name")

View File

@ -10,11 +10,7 @@ trait SocketMember {
def isAuth = userId.isDefined
def push(msg: JsValue) = try {
channel push msg
} catch {
case _: java.nio.channels.ClosedChannelException => lila.mon.socket.pushChannelClosed()
}
def push(msg: JsValue) = channel push msg
def end = channel.end
}