X-Git-Url: http://git.tdb.fi/?a=blobdiff_plain;f=source%2Fresources%2Fresourcemanager.cpp;h=c72b361ce1f41ae9ec69d73d69a7d0e7307fcb21;hb=e70662d7812464159f2e47f4bebb69d88f89ae93;hp=91acb3d0baf623e89fea7777cd022006ec847401;hpb=5b311d10d50aa1fe0eb4ed4b8e41f0c58e9e7cbf;p=libs%2Fgl.git

diff --git a/source/resources/resourcemanager.cpp b/source/resources/resourcemanager.cpp
index 91acb3d0..c72b361c 100644
--- a/source/resources/resourcemanager.cpp
+++ b/source/resources/resourcemanager.cpp
@@ -3,6 +3,7 @@
 #include <msp/debug/demangle.h>
 #include <msp/strings/format.h>
 #include <msp/time/utils.h>
+#include "error.h"
 #include "resourcemanager.h"
 #include "resources.h"
 #include "resourceobserver.h"
@@ -21,17 +22,6 @@ resource_load_error::resource_load_error(const string &name, const exception &ex
 { }
 
 
-ResourceManager::ResourceManager():
-	policy(LOAD_ON_DEMAND),
-	async_loads(true),
-	total_data_size(0),
-	size_limit(0),
-	frame(0),
-	min_retain_frames(30),
-	max_retain_frames(0),
-	next_unload(0)
-{ }
-
 ResourceManager::~ResourceManager()
 {
 	thread.terminate();
@@ -50,7 +40,7 @@ void ResourceManager::set_async_loads(bool a)
 	async_loads = a;
 }
 
-void ResourceManager::set_size_limit(UInt64 s)
+void ResourceManager::set_size_limit(uint64_t s)
 {
 	size_limit = s;
 }
@@ -67,10 +57,22 @@ void ResourceManager::set_max_retain_frames(unsigned f)
 
 void ResourceManager::add_resource(Resource &r)
 {
+	if(r.get_manager()!=this)
+		throw invalid_operation("ResourceManager::add_resource");
 	MutexLock lock(map_mutex);
 	insert_unique(resources, &r, ManagedResource(r));
 }
 
+void ResourceManager::move_resource(Resource &from, Resource &to)
+{
+	if(to.get_manager()!=this || from.get_manager_data()!=to.get_manager_data())
+		throw invalid_operation("ResourceManager::move_resource");
+	ManagedResource *managed = reinterpret_cast<ManagedResource *>(to.get_manager_data());
+	MutexLock lock(map_mutex);
+	insert_unique(resources, &to, *managed);
+	resources.erase(&from);
+}
+
 const ResourceManager::ManagedResource &ResourceManager::get_managed_resource(const Resource &r) const
 {
 	MutexLock lock(map_mutex);
@@ -251,11 +253,11 @@ void ResourceManager::unload_by_size()
 	while(total_data_size>size_limit)
 	{
 		ManagedResource *best = 0;
-		UInt64 best_impact = 0;
+		uint64_t best_impact = 0;
 		for(auto &kvp: resources)
 			if(kvp.second.state==ManagedResource::LOADED && kvp.second.last_used<unload_limit)
 			{
-				UInt64 impact = kvp.second.data_size*(frame-kvp.second.last_used);
+				uint64_t impact = kvp.second.data_size*(frame-kvp.second.last_used);
 				if(!best || impact>best_impact)
 				{
 					best = &kvp.second;
@@ -530,10 +532,10 @@ bool ResourceManager::LoadingThread::sync()
 	return any_finished;
 }
 
-UInt64 ResourceManager::LoadingThread::get_and_reset_loaded_data_size()
+uint64_t ResourceManager::LoadingThread::get_and_reset_loaded_data_size()
 {
 	MutexLock lock(data_size_mutex);
-	UInt64 result = loaded_data_size;
+	uint64_t result = loaded_data_size;
 	loaded_data_size = 0;
 	return result;
 }