| 159 | } |
| 160 | |
| 161 | void SystemWorldServerThread::pushIncomingPacket(ConnectionId clientId, PacketPtr packet) { |
| 162 | WriteLocker locker(m_queueMutex); |
| 163 | m_incomingPacketQueue.append({std::move(clientId), std::move(packet)}); |
| 164 | } |
| 165 | |
| 166 | List<PacketPtr> SystemWorldServerThread::pullOutgoingPackets(ConnectionId clientId) { |
| 167 | WriteLocker locker(m_queueMutex); |