Method ProcessRequests

Network/NetClient.cpp:138–206

ProcessRequests - reads packet sent from the server in a loop */

	ProcessRequests - reads packet sent from the server in a loop
*/
void NetClient::ProcessRequests(__in LPVOID Param)
{
	if (Param == nullptr)
	{
		Logger::logf(Info, "NetClient class pointer was nullptr @ ProcessRequests");
		return;
	}

	bool receiving = true;
	const int ms_between_loops = 1000;
	unsigned char recvBuf[DEFAULT_RECV_LENGTH] = { 0 };

	Logger::logf(Info, "Started thread on NetClient::ProcessRequests with id: %d", GetCurrentThreadId());

	NetClient* Client = reinterpret_cast<NetClient*>(Param);

	if (Client == nullptr)
	{
		Logger::logf(Err, "Client was NULL @ NetClient::ProcessRequests");
		receiving = false; //todo: send signals to rest of anticheat to shutdown
		goto end;
	}

	while (receiving)
	{
		if (Client->GetRecvThread()->IsShutdownSignalled())
		{
			goto end;
		}

		SOCKET s = Client->GetClientSocket();

		if (s)
		{
			int bytesIn = 0;

			{
				std::lock_guard<std::mutex> lock(Client->RecvPacketMutex);
				bytesIn = recv(s, (char*)recvBuf, DEFAULT_RECV_LENGTH, 0);
			}

			if (bytesIn == 0)
				continue;

			if (bytesIn != SOCKET_ERROR)
			{
				Client->CipherData(recvBuf, bytesIn); //decrypt buffer

				PacketReader* p = new PacketReader(recvBuf, bytesIn);
				Client->HandleInboundPacket(p);
				delete p;
			}
			else
				receiving = false;
		}
		else if(s == SOCKET_ERROR)
		{
			Logger::logf(Err, "Socket error @  NetClient::ProcessRequests");