| 127 | |
| 128 | |
| 129 | List<ConnectionId> WorldServerThread::erroredClients() const { |
| 130 | RecursiveMutexLocker locker(m_mutex); |
| 131 | auto unerroredClients = HashSet<ConnectionId>::from(m_worldServer->clientIds()); |
| 132 | return m_clients.difference(unerroredClients).values(); |
| 133 | } |
| 134 | |
| 135 | void WorldServerThread::pushIncomingPackets(ConnectionId clientId, List<PacketPtr> packets) { |
| 136 | RecursiveMutexLocker queueLocker(m_queueMutex); |
no test coverage detected