Function CreateTCPEchoServer

test/clsocket/RecvAsync.cpp:25–53

};

void *CreateTCPEchoServer(void *param)
{
	CPassiveSocket socket;
	CActiveSocket *pClient = NULL;
	struct thread_data *pData = (struct thread_data *)param;
	int nBytesReceived = 0;

	socket.Initialize();
	socket.Listen(pData->pszServerAddr, pData->nPort);

	if ((pClient = socket.Accept()) != NULL)
	{
		while (nBytesReceived != pData->nTotalPayloadSize)
		{
			if (nBytesReceived += pClient->Receive(pData->nNumBytesToReceive))
			{
				pClient->Send((const uint8 *)pClient->GetData(), pClient->GetBytesReceived());
			}
		}

		sleep(100);

		delete pClient;
	}

	socket.Close();

	return NULL;
}

int main(int argc, char **argv)
{