Method OnClientWsThread

Sources/Jazz2/Multiplayer/NetworkManagerBase.cpp:1340–1416

	}

	void NetworkManagerBase::OnClientWsThread(void* param)
	{
		Thread::SetCurrentName("Multiplayer WebSocket client");

		NetworkManagerBase* _this = static_cast<NetworkManagerBase*>(param);
		INetworkHandler* handler = _this->_handler;

		bool wasConnected = false;
		ix::WebSocket* serverPeer = nullptr;
		Reason disconnectReason = Reason::ConnectionTimedOut;
		_this->_wsPingLastTime = 0;

		while (_this->_state != NetworkState::None) {
			Thread::Sleep(ProcessingIntervalMs);

			SmallVector<WsQueuedEvent, 0> pending;
			{
				std::unique_lock<Spinlock> lock(_this->_wsLock);
				std::swap(pending, _this->_wsPendingEvents);
			}

			for (auto& ev : pending) {
				switch (ev.type) {
					case WsQueuedEvent::Type::Open: {
						wasConnected = true;
						serverPeer = ev.peer;
						disconnectReason = Reason::Unknown;
						_this->_state = NetworkState::Connected;
						_this->_wsPingLastTime = GetCurrentTimeMs();
						Peer connectedPeer = Peer::FromWebSocket(ev.peer);
						{
							std::unique_lock lock(_this->_lock);
							_this->_connectedPeers.push_back(connectedPeer);
						}
						ConnectionResult result = _this->OnPeerConnected(connectedPeer, ev.clientData);
						if (!result.IsSuccessful()) {
							ev.peer->close(ReasonToWsCloseCode(result.FailureReason), ReasonToString(result.FailureReason));
						}
						break;
					}
					case WsQueuedEvent::Type::Close: {
						disconnectReason = WsCloseCodeToReason(ev.closeCode, wasConnected);
						_this->_state = NetworkState::None;
						break;
					}
					case WsQueuedEvent::Type::Message: {
						if (ev.data.size() >= 1) {
							std::uint8_t pktType = (std::uint8_t)ev.data[0];
							if DEATH_UNLIKELY(pktType == (std::uint8_t)ServerPacketType::Pong && ev.data.size() >= 1 + 8) {
								// Intercept Pong: compute RTT from echoed timestamp
								std::uint64_t sentTime;
								std::memcpy(&sentTime, ev.data.data() + 1, 8);
								std::uint64_t rtt = GetCurrentTimeMs() - sentTime;
								_this->_wsRtt.store((std::uint32_t)rtt, std::memory_order_relaxed);
							} else {
								handler->OnPacketReceived(Peer::FromWebSocket(ev.peer), 0,
									pktType, arrayView((const std::uint8_t*)ev.data.data() + 1, ev.data.size() - 1));
							}