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 }