From 30e109ec2e09dc8575e489fddf3faf697c6fddb3 Mon Sep 17 00:00:00 2001 From: Thibault Duplessis Date: Mon, 10 Dec 2018 11:29:14 +0700 Subject: [PATCH] so apparently that never happens on prod --- modules/common/src/main/mon.scala | 1 - modules/socket/src/main/SocketMember.scala | 6 +----- 2 files changed, 1 insertion(+), 6 deletions(-) diff --git a/modules/common/src/main/mon.scala b/modules/common/src/main/mon.scala index 5c03e2cd4b..4bbb3ef692 100644 --- a/modules/common/src/main/mon.scala +++ b/modules/common/src/main/mon.scala @@ -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") diff --git a/modules/socket/src/main/SocketMember.scala b/modules/socket/src/main/SocketMember.scala index dfc4fedd89..f7be9968b6 100644 --- a/modules/socket/src/main/SocketMember.scala +++ b/modules/socket/src/main/SocketMember.scala @@ -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 }