Method HttpThreadProc

cpp/src/Http.cpp:139–203

	return true;
}
void HttpClient::HttpThreadProc
(
		Event* _exitEvent,
		void* _context
)
{
	HttpClient *client = (HttpClient *)_context;
	client->m_httpThreadRunning = true;

	SimpleHTTPClient::InitNetwork();
	bool keepgoing = true;
	while( keepgoing )
	{
		const uint32 count = 2;

		Wait* waitObjects[count];

		int32 timeout = Wait::Timeout_Infinite;
		timeout = 10000;

		waitObjects[0] = client->m_exitEvent;					// Thread must exit.
		waitObjects[1] = client->m_httpDownloadEvent;			// Http Request
		// Wait for something to do

		int32 res = Wait::Multiple( waitObjects, count, timeout );

		switch (res) {
			case -1: /* timeout */
				Log::Write(LogLevel_Info, "HttpThread Exiting. No Transfers in timeout period");
				keepgoing = false;
				break;
			case 0: /* exitEvent */
				Log::Write(LogLevel_Info, "HttpThread Exiting.");
				keepgoing = false;
				break;
			case 1: /* HttpEvent */
				HttpDownload *download;
				{
					LockGuard LG(client->m_httpMutex);
					download = client->m_httpDownlist.front();
					client->m_httpDownlist.pop_front();
					if (client->m_httpDownlist.empty())
						client->m_httpDownloadEvent->Reset();
				}
				Log::Write(LogLevel_Debug, "Download Starting for %s (%s)", download->url.c_str(), download->filename.c_str());
				SimpleHTTPClient::HttpSocket *ht = new SimpleHTTPClient::HttpSocket();
			    ht->SetKeepAlive(0);
			    ht->SetBufsizeIn(64 * 1024);
			    ht->SetDownloadFile(download->filename);
			    ht->Download(download->url);
			    while (ht->isOpen())
			    	ht->update();

			    if (ht->IsSuccess())
			    	download->transferStatus = HttpDownload::Ok;
			    else
			    	download->transferStatus = HttpDownload::Failed;
			    delete ht;