From 3a9c539c1be801e6bb1f740f0d1d5bb87caf81e5 Mon Sep 17 00:00:00 2001 From: Thibault Duplessis Date: Tue, 10 Dec 2024 20:06:11 +0100 Subject: [PATCH] Revert "keep track of hot rooms, with unusual number of members" This reverts commit 4cf7a07ed745422c69d1934dabd575763e2a0cb2. No use for it just yet --- src/main/scala/RoomCrowd.scala | 16 +--------------- 1 file changed, 1 insertion(+), 15 deletions(-) diff --git a/src/main/scala/RoomCrowd.scala b/src/main/scala/RoomCrowd.scala index 43232ca7..a3a4b872 100644 --- a/src/main/scala/RoomCrowd.scala +++ b/src/main/scala/RoomCrowd.scala @@ -1,7 +1,6 @@ package lila.ws import java.util.concurrent.ConcurrentHashMap -import com.github.blemale.scaffeine.Scaffeine import ipc.* @@ -50,7 +49,6 @@ final class RoomCrowd(json: CrowdJson, groupedWithin: util.GroupedWithin)(using crowds.updated(crowd.roomId, crowd) .values lastPerRoomId.foreach: output => - RoomCrowd.hot.put(output.roomId, output.members) json .room(output) .foreach: @@ -60,11 +58,9 @@ final class RoomCrowd(json: CrowdJson, groupedWithin: util.GroupedWithin)(using object RoomCrowd: - type Members = Int - case class Output( roomId: RoomId, - members: Members, + members: Int, users: Iterable[User.Id], anons: Int ) @@ -91,13 +87,3 @@ object RoomCrowd: def disconnect(user: Option[User.Id]) = user.fold(copy(anons = anons - 1)): u => copy(users = users.updatedWith(u)(_.map(_ - 1).filter(_ > 0))) - - // rooms that have an abnormal amount of members - object hot: - private val rooms = Scaffeine() - .expireAfterWrite(1.minute) - .build[RoomId, Members]() - def get(roomId: RoomId) = rooms.getIfPresent(roomId) - def put(roomId: RoomId, nb: Members) = - println(s"hot room put $roomId $nb") - if nb > 1000 then rooms.put(roomId, nb)