Method SendQueue

src/ServerUDPSocket.cpp:414–484

void CServerUDPSocket::SendQueue()
{
	while (!m_queue.empty()) {
		ServerUDPPacket item = m_queue.front();
		CPacket* packet = item.packet;

		// Do we need to do a DNS lookup before sending?
		wxASSERT(item.ip || !item.addr.IsEmpty());
		if (!item.addr.IsEmpty()) {
			// This not an ip but a hostname. Resolve it.
			CServer* update = theApp->serverlist->GetServerByAddress(item.addr, item.port);
			if (update) {
				const uint64 now = ::GetTickCount64();
				if (update->GetLastDNSSolve() + DNS_SOLVE_TIME < now) {
					// Its time for a new check.
					CAsyncDNS* dns = new CAsyncDNS(item.addr, DNS_UDP, theApp, this);
					if ((dns->Create() != wxTHREAD_NO_ERROR) || (dns->Run() != wxTHREAD_NO_ERROR)) {
						// Not much we can do here, just drop the packet.
						dns->Delete();
						m_queue.pop_front();
						continue;
					}
					update->SetDNSError(false);
					update->SetLastDNSSolve(now);
					// Wait for the DNS query to be resolved
					return;
				} else {
					// It has been checked recently, don't re-check yet.
					if (update->GetDNSError()) {
						// Drop the packet, dns failed last time
						AddDebugLogLineN(logServerUDP, "Trying to send a UDP packet to a server host that failed DNS: "+item.addr);
						m_queue.pop_front();
						continue;
					} else {
						// It has been solved or is solving.
						if (update->GetIP()) {
							// It has been solved and ok
							AddDebugLogLineN(logServerUDP, "Sending a UDP packet to a resolved DNS server host: "+item.addr);
							// Update the item IP
							item.ip = update->GetIP();
							// It'll fallback to the sending.
						} else {
							AddDebugLogLineN(logServerUDP, "Trying to send a UDP packet to a server host that is checking DNS: "+item.addr);
							// Let the packet queued, and wait for resolution
							// Meanwhile, send other packets.
							m_queue.pop_front();
							m_queue.push_back(item);
							return;
						}
					}
				}
			} else {
				AddDebugLogLineN(logServerUDP, "Trying to send a UDP packet to a server host that is not on serverlist");
				// Not much we can do here, just drop the packet.
				m_queue.pop_front();
				continue;
			}
		}