Method ProcessWsQueue

Sources/Jazz2/Multiplayer/NetworkManagerBase.cpp:1264–1318

	}

	void NetworkManagerBase::ProcessWsQueue(INetworkHandler* handler)
	{
		SmallVector<WsQueuedEvent, 0> pending;
		{
			std::unique_lock<Spinlock> lock(_wsLock);
			std::swap(pending, _wsPendingEvents);
		}

		for (auto& ev : pending) {
			switch (ev.type) {
				case WsQueuedEvent::Type::Open: {
					Peer wsPeer = Peer::FromWebSocket(ev.peer);
					ConnectionResult result = OnPeerConnected(wsPeer, ev.clientData);
					if (result.IsSuccessful()) {
						std::unique_lock lock(_lock);
						_connectedPeers.push_back(wsPeer);
					} else {
						// Reject the connection
						ev.peer->close(ReasonToWsCloseCode(result.FailureReason), ReasonToString(result.FailureReason));
					}
					break;
				}
				case WsQueuedEvent::Type::Close: {
					OnPeerDisconnected(Peer::FromWebSocket(ev.peer), WsCloseCodeToReason(ev.closeCode, true));
					break;
				}
				case WsQueuedEvent::Type::Message: {
					if DEATH_LIKELY(ev.data.size() >= 1) {
						std::uint8_t pktType = (std::uint8_t)ev.data[0];
						if DEATH_UNLIKELY(pktType == (std::uint8_t)ClientPacketType::Ping && ev.data.size() >= 1 + 8 + 4) {
							// Intercept Ping: read timestamp + reported RTT, update per-peer RTT, echo Pong
							std::uint64_t timestamp;
							std::uint32_t reportedRtt;
							std::memcpy(&timestamp, ev.data.data() + 1, 8);
							std::memcpy(&reportedRtt, ev.data.data() + 9, 4);
							{
								std::unique_lock<Spinlock> lock(_wsLock);
								auto it = _wsPeers.find(ev.peer);
								if DEATH_LIKELY(it != _wsPeers.end()) {
									it->second.rtt = reportedRtt;
								}
							}
							// Echo timestamp back as Pong
							std::uint8_t pong[1 + 8];
							pong[0] = (std::uint8_t)ServerPacketType::Pong;
							std::memcpy(pong + 1, &timestamp, 8);
							ev.peer->sendBinary(std::string(reinterpret_cast<const char*>(pong), sizeof(pong)));
						} else {
							handler->OnPacketReceived(Peer::FromWebSocket(ev.peer), 0,
								pktType, arrayView((const std::uint8_t*)ev.data.data() + 1, ev.data.size() - 1));
						}
					}
					break;
				}
			}
		}
	}