AvatarButton/holder, rename ThumbnailBroker for more general purposes

1 files changed, 0 insertions, 392 deletions

diff --git a/src/client/ThumbnailBroker.cpp b/src/client/ThumbnailBroker.cpp
deleted file mode 100644
index 85fee3a..0000000
--- a/src/client/ThumbnailBroker.cpp
+++ /dev/null
@@ -1,392 +0,0 @@
-#include <algorithm>
-#include <iostream>
-#include <typeinfo>
-#include <time.h>
-#include "ThumbnailBroker.h"
-#include "ThumbnailListener.h"
-#include "Client.h"
-#include "HTTP.h"
-#include "GameSave.h"
-#include "search/Thumbnail.h"
-#include "simulation/SaveRenderer.h"
-
-//Asynchronous Thumbnail render & request processing
-
-ThumbnailBroker::ThumbnailBroker()
-{
-	thumbnailQueueRunning = false;
-	//thumbnailQueueMutex = PTHREAD_MUTEX_INITIALIZER;
-	pthread_mutex_init (&thumbnailQueueMutex, NULL);
-
-	//listenersMutex = PTHREAD_MUTEX_INITIALIZER;
-	pthread_mutex_init (&listenersMutex, NULL);
-
-
-	pthread_mutex_init (&runningMutex, NULL);
-}
-
-ThumbnailBroker::~ThumbnailBroker()
-{
-
-}
-
-void ThumbnailBroker::assureRunning()
-{
-	pthread_mutex_lock(&runningMutex);
-	bool running = thumbnailQueueRunning;
-	thumbnailQueueRunning = true;
-	pthread_mutex_unlock(&runningMutex);
-
-	if(!running)
-	{
-#ifdef DEBUG
-		std::cout << typeid(*this).name() << " Starting background thread for new " << __FUNCTION__ << " request" << std::endl;
-#endif
-		pthread_create(&thumbnailQueueThread, 0, &ThumbnailBroker::thumbnailQueueProcessHelper, this);
-	}
-}
-
-void ThumbnailBroker::Shutdown()
-{
-	pthread_mutex_lock(&runningMutex);
-	if(thumbnailQueueRunning)
-	{
-		thumbnailQueueRunning = false;
-		pthread_mutex_unlock(&runningMutex);
-		pthread_join(thumbnailQueueThread, NULL);
-	}
-	else
-		pthread_mutex_unlock(&runningMutex);
-
-
-	for (std::list<ThumbnailRequest>::iterator iter = currentRequests.begin(), end = currentRequests.end(); iter != end; ++iter)
-	{
-		ThumbnailRequest req = *iter;
-		if(req.HTTPContext)
-		{
-			http_async_req_close(req.HTTPContext);
-		}
-	}
-}
-
-void ThumbnailBroker::RenderThumbnail(GameSave * gameSave, int width, int height, ThumbnailListener * tListener)
-{
-	RenderThumbnail(gameSave, true, true, width, height, tListener);
-}
-
-void ThumbnailBroker::RenderThumbnail(GameSave * gameSave, bool decorations, bool fire, int width, int height, ThumbnailListener * tListener)
-{
-	AttachThumbnailListener(tListener);
-	pthread_mutex_lock(&thumbnailQueueMutex);
-	renderRequests.push_back(ThumbRenderRequest(new GameSave(*gameSave), decorations, fire, width, height, ListenerHandle(tListener->ListenerRand, tListener)));
-	pthread_mutex_unlock(&thumbnailQueueMutex);
-	
-	assureRunning();
-}
-
-void ThumbnailBroker::RetrieveThumbnail(int saveID, int saveDate, int width, int height, ThumbnailListener * tListener)
-{
-	AttachThumbnailListener(tListener);
-	pthread_mutex_lock(&thumbnailQueueMutex);
-	thumbnailRequests.push_back(ThumbnailRequest(saveID, saveDate, width, height, ListenerHandle(tListener->ListenerRand, tListener)));
-	pthread_mutex_unlock(&thumbnailQueueMutex);
-
-	assureRunning();
-}
-
-void * ThumbnailBroker::thumbnailQueueProcessHelper(void * ref)
-{
-	((ThumbnailBroker*)ref)->thumbnailQueueProcessTH();
-	return NULL;
-}
-
-void ThumbnailBroker::FlushThumbQueue()
-{
-	pthread_mutex_lock(&thumbnailQueueMutex);
-	while(thumbnailComplete.size())
-	{
-		if(CheckThumbnailListener(thumbnailComplete.front().first))
-		{
-			thumbnailComplete.front().first.second->OnThumbnailReady(thumbnailComplete.front().second);
-		}
-		else
-		{
-#ifdef DEBUG
-			std::cout << typeid(*this).name() << " Listener lost, discarding request" << std::endl;
-#endif
-			delete thumbnailComplete.front().second;
-		}
-		thumbnailComplete.pop_front();
-	}	
-	pthread_mutex_unlock(&thumbnailQueueMutex);
-}
-
-void ThumbnailBroker::thumbnailQueueProcessTH()
-{
-	time_t lastAction = time(NULL);
-	pthread_mutex_lock(&runningMutex);
-	thumbnailQueueRunning = true;
-	pthread_mutex_unlock(&runningMutex);
-	while(true)
-	{
-		//Shutdown after 2 seconds of idle
-		if(time(NULL) - lastAction > 2)
-		{
-#ifdef DEBUG
-			std::cout << typeid(*this).name() << " Idle shutdown" << std::endl;
-#endif
-			break;
-		}
-
-
-		pthread_mutex_lock(&runningMutex);
-		bool running = thumbnailQueueRunning;
-		pthread_mutex_unlock(&runningMutex);
-		if(!running)
-		{
-#ifdef DEBUG
-			std::cout << typeid(*this).name() << " Requested shutdown" << std::endl;
-#endif
-			break;
-		}
-
-
-		//Renderer
-		pthread_mutex_lock(&thumbnailQueueMutex);
-		if(renderRequests.size())
-		{
-			lastAction = time(NULL);
-			ThumbRenderRequest req;
-			req = renderRequests.front();
-			renderRequests.pop_front();
-			pthread_mutex_unlock(&thumbnailQueueMutex);
-
-#ifdef DEBUG
-			std::cout << typeid(*this).name() << " Processing render request" << std::endl;
-#endif
-
-			Thumbnail * thumbnail = SaveRenderer::Ref().Render(req.Save, req.Decorations, req.Fire);
-			delete req.Save;
-
-			if(thumbnail)
-			{
-				thumbnail->Resize(req.Width, req.Height);
-
-				pthread_mutex_lock(&thumbnailQueueMutex);
-				thumbnailComplete.push_back(std::pair<ListenerHandle, Thumbnail*>(req.CompletedListener, thumbnail));
-				pthread_mutex_unlock(&thumbnailQueueMutex);	
-			}
-		}
-		else
-		{
-			pthread_mutex_unlock(&thumbnailQueueMutex);
-		}
-
-		//Renderer
-		pthread_mutex_lock(&thumbnailQueueMutex);
-		if(thumbnailRequests.size())
-		{
-			lastAction = time(NULL);
-			Thumbnail * thumbnail = NULL;
-
-			ThumbnailRequest req;
-			req = thumbnailRequests.front();
-
-			//Check the cache
-			for(std::deque<std::pair<ThumbnailID, Thumbnail*> >::iterator iter = thumbnailCache.begin(), end = thumbnailCache.end(); iter != end; ++iter)
-			{
-				if((*iter).first == req.ID)
-				{
-					thumbnail = (*iter).second;
-#ifdef DEBUG
-					std::cout << typeid(*this).name() << " " << req.ID.SaveID << ":" << req.ID.SaveDate << " found in cache" << std::endl;
-#endif
-				}
-			}
-
-			if(thumbnail)
-			{
-				//Got thumbnail from cache
-				thumbnailRequests.pop_front();
-				pthread_mutex_unlock(&thumbnailQueueMutex);
-
-				for(std::vector<ThumbnailSpec>::iterator specIter = req.SubRequests.begin(), specEnd = req.SubRequests.end(); specIter != specEnd; ++specIter)
-				{
-					Thumbnail * tempThumbnail = new Thumbnail(*thumbnail);
-					tempThumbnail->Resize((*specIter).Width, (*specIter).Height);
-
-					pthread_mutex_lock(&thumbnailQueueMutex);
-					thumbnailComplete.push_back(std::pair<ListenerHandle, Thumbnail*>((*specIter).CompletedListener, tempThumbnail));
-					pthread_mutex_unlock(&thumbnailQueueMutex);	
-				}
-			}
-			else
-			{
-				//Check for ongoing requests
-				bool requested = false;
-				for(std::list<ThumbnailRequest>::iterator iter = currentRequests.begin(), end = currentRequests.end(); iter != end; ++iter)
-				{
-					if((*iter).ID == req.ID)
-					{
-						requested = true;
-						
-#ifdef DEBUG
-						std::cout << typeid(*this).name() << " Request for " << req.ID.SaveID << ":" << req.ID.SaveDate << " found, appending." << std::endl;
-#endif
-
-						//Add the current listener to the item already being requested
-						(*iter).SubRequests.push_back(req.SubRequests.front());
-					}
-				}
-
-				if(requested)
-				{
-					//Already requested
-					thumbnailRequests.pop_front();
-					pthread_mutex_unlock(&thumbnailQueueMutex);
-				}
-				else if(currentRequests.size() < IMGCONNS) //If it's not already being requested and we still have more space for a new connection, request it
-				{
-					thumbnailRequests.pop_front();
-					pthread_mutex_unlock(&thumbnailQueueMutex);
-
-					//If it's not already being requested, request it
-					std::stringstream urlStream;
-					urlStream << "http://" << STATICSERVER << "/" << req.ID.SaveID;
-					if(req.ID.SaveDate)
-					{
-						urlStream << "_" << req.ID.SaveDate;
-					}
-					urlStream << "_small.pti";
-
-#ifdef DEBUG
-					std::cout << typeid(*this).name() << " Creating new request for " << req.ID.SaveID << ":" << req.ID.SaveDate << std::endl;
-#endif
-
-					req.HTTPContext = http_async_req_start(NULL, (char *)urlStream.str().c_str(), NULL, 0, 0);
-					req.RequestTime = time(NULL);
-					currentRequests.push_back(req);
-				}
-				else
-				{
-					//Already full of requests
-					pthread_mutex_unlock(&thumbnailQueueMutex);
-
-				}
-			}
-		}
-		else
-		{
-			pthread_mutex_unlock(&thumbnailQueueMutex);
-		}
-
-		std::list<ThumbnailRequest>::iterator iter = currentRequests.begin();
-		while (iter != currentRequests.end())
-		{
-			lastAction = time(NULL);
-
-			ThumbnailRequest req = *iter;
-			Thumbnail * thumbnail = NULL;
-
-			if(http_async_req_status(req.HTTPContext))
-			{
-
-				pixel * thumbData;
-				char * data;
-				int status, data_size, imgw, imgh;
-				data = http_async_req_stop(req.HTTPContext, &status, &data_size);
-
-				if (status == 200 && data)
-				{
-					thumbData = Graphics::ptif_unpack(data, data_size, &imgw, &imgh);
-					free(data);
-
-					if(thumbData)
-					{
-						thumbnail = new Thumbnail(req.ID.SaveID, req.ID.SaveID, thumbData, ui::Point(imgw, imgh));
-						free(thumbData);
-					}
-					else
-					{
-						//Error thumbnail
-						VideoBuffer errorThumb(128, 128);
-						errorThumb.SetCharacter(64, 64, 'x', 255, 255, 255, 255);
-
-						thumbnail = new Thumbnail(req.ID.SaveID, req.ID.SaveID, errorThumb.Buffer, ui::Point(errorThumb.Width, errorThumb.Height));
-					}
-
-					if(thumbnailCache.size() >= THUMB_CACHE_SIZE)
-					{
-						delete thumbnailCache.front().second;
-						thumbnailCache.pop_front();
-					}
-					thumbnailCache.push_back(std::pair<ThumbnailID, Thumbnail*>(req.ID, thumbnail));
-
-					for(std::vector<ThumbnailSpec>::iterator specIter = req.SubRequests.begin(), specEnd = req.SubRequests.end(); specIter != specEnd; ++specIter)
-					{
-						Thumbnail * tempThumbnail = new Thumbnail(*thumbnail);
-						tempThumbnail->Resize((*specIter).Width, (*specIter).Height);
-
-						pthread_mutex_lock(&thumbnailQueueMutex);
-						thumbnailComplete.push_back(std::pair<ListenerHandle, Thumbnail*>((*specIter).CompletedListener, tempThumbnail));
-						pthread_mutex_unlock(&thumbnailQueueMutex);	
-					}
-				}
-				else
-				{
-#ifdef DEBUG
-					std::cout << typeid(*this).name() << " Request for " << req.ID.SaveID << ":" << req.ID.SaveDate << " failed with status " << status << std::endl;
-#endif	
-					if(data)
-						free(data);
-				}
-				iter = currentRequests.erase(iter);
-			}
-			else
-			{
-				++iter;
-			}
-		}
-
-	}
-	pthread_mutex_lock(&runningMutex);
-	thumbnailQueueRunning = false;
-	pthread_mutex_unlock(&runningMutex);
-}
-
-void ThumbnailBroker::RetrieveThumbnail(int saveID, int width, int height, ThumbnailListener * tListener)
-{
-	RetrieveThumbnail(saveID, 0, width, height, tListener);
-}
-
-bool ThumbnailBroker::CheckThumbnailListener(ListenerHandle handle)
-{
-	pthread_mutex_lock(&listenersMutex);
-	int count = std::count(validListeners.begin(), validListeners.end(), handle);
-	pthread_mutex_unlock(&listenersMutex);
-
-	return count;
-}
-
-void ThumbnailBroker::AttachThumbnailListener(ThumbnailListener * tListener)
-{
-	pthread_mutex_lock(&listenersMutex);
-	validListeners.push_back(ListenerHandle(tListener->ListenerRand, tListener));
-	pthread_mutex_unlock(&listenersMutex);
-}
-
-void ThumbnailBroker::DetachThumbnailListener(ThumbnailListener * tListener)
-{
-	pthread_mutex_lock(&listenersMutex);
-
-	std::vector<ListenerHandle>::iterator iter = validListeners.begin();
-	while (iter != validListeners.end())
-	{
-		if(*iter == ListenerHandle(tListener->ListenerRand, tListener))
-			iter = validListeners.erase(iter);
-		else
-			++iter;
-	}
-
-	pthread_mutex_unlock(&listenersMutex);
-}
\ No newline at end of file