ResourceCache.cpp 26 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694695696697698699700701702703704705706707708709710711712713714715716717718719720721722723724725726727728729730731732733734735736737738739740741742743744745746747748749750751752753754755756757758759760761762763764765766767768769770771772773774775776777778779780781782783784785786787788789790791792793794795796797798799800801802
  1. //
  2. // Copyright (c) 2008-2013 the Urho3D project.
  3. //
  4. // Permission is hereby granted, free of charge, to any person obtaining a copy
  5. // of this software and associated documentation files (the "Software"), to deal
  6. // in the Software without restriction, including without limitation the rights
  7. // to use, copy, modify, merge, publish, distribute, sublicense, and/or sell
  8. // copies of the Software, and to permit persons to whom the Software is
  9. // furnished to do so, subject to the following conditions:
  10. //
  11. // The above copyright notice and this permission notice shall be included in
  12. // all copies or substantial portions of the Software.
  13. //
  14. // THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS OR
  15. // IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF MERCHANTABILITY,
  16. // FITNESS FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT. IN NO EVENT SHALL THE
  17. // AUTHORS OR COPYRIGHT HOLDERS BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER
  18. // LIABILITY, WHETHER IN AN ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING FROM,
  19. // OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN
  20. // THE SOFTWARE.
  21. //
  22. #include "Precompiled.h"
  23. #include "Context.h"
  24. #include "CoreEvents.h"
  25. #include "FileSystem.h"
  26. #include "FileWatcher.h"
  27. #include "Image.h"
  28. #include "Log.h"
  29. #include "PackageFile.h"
  30. #include "ResourceCache.h"
  31. #include "ResourceEvents.h"
  32. #include "XMLFile.h"
  33. #include "DebugNew.h"
  34. namespace Urho3D
  35. {
  36. static const char* checkDirs[] = {
  37. "Fonts",
  38. "Materials",
  39. "Models",
  40. "Music",
  41. "Objects",
  42. "Particle",
  43. "PostProcess",
  44. "RenderPaths",
  45. "Scenes",
  46. "Scripts",
  47. "Sounds",
  48. "Shaders",
  49. "Techniques",
  50. "Textures",
  51. "UI",
  52. 0
  53. };
  54. static const SharedPtr<Resource> noResource;
  55. ResourceCache::ResourceCache(Context* context) :
  56. Object(context),
  57. autoReloadResources_(false)
  58. {
  59. // Register Resource library object factories
  60. RegisterResourceLibrary(context_);
  61. }
  62. ResourceCache::~ResourceCache()
  63. {
  64. }
  65. bool ResourceCache::AddResourceDir(const String& pathName)
  66. {
  67. FileSystem* fileSystem = GetSubsystem<FileSystem>();
  68. if (!fileSystem || !fileSystem->DirExists(pathName))
  69. {
  70. LOGERROR("Could not open directory " + pathName);
  71. return false;
  72. }
  73. String fixedPath = AddTrailingSlash(pathName);
  74. // Check that the same path does not already exist
  75. for (unsigned i = 0; i < resourceDirs_.Size(); ++i)
  76. {
  77. if (!resourceDirs_[i].Compare(fixedPath, false))
  78. return true;
  79. }
  80. resourceDirs_.Push(fixedPath);
  81. // Scan the path for files recursively and add their hash-to-name mappings
  82. Vector<String> fileNames;
  83. fileSystem->ScanDir(fileNames, fixedPath, "*.*", SCAN_FILES, true);
  84. for (unsigned i = 0; i < fileNames.Size(); ++i)
  85. StoreNameHash(fileNames[i]);
  86. // If resource auto-reloading active, create a file watcher for the directory
  87. if (autoReloadResources_)
  88. {
  89. SharedPtr<FileWatcher> watcher(new FileWatcher(context_));
  90. watcher->StartWatching(fixedPath, true);
  91. fileWatchers_.Push(watcher);
  92. }
  93. LOGINFO("Added resource path " + fixedPath);
  94. return true;
  95. }
  96. void ResourceCache::AddPackageFile(PackageFile* package, bool addAsFirst)
  97. {
  98. // Do not add packages that failed to load
  99. if (!package || !package->GetNumFiles())
  100. return;
  101. if (addAsFirst)
  102. packages_.Insert(packages_.Begin(), SharedPtr<PackageFile>(package));
  103. else
  104. packages_.Push(SharedPtr<PackageFile>(package));
  105. // Scan the package for files and add their hash-to-name mappings
  106. const HashMap<String, PackageEntry>& entries = package->GetEntries();
  107. for (HashMap<String, PackageEntry>::ConstIterator i = entries.Begin(); i != entries.End(); ++i)
  108. StoreNameHash(i->first_);
  109. LOGINFO("Added resource package " + package->GetName());
  110. }
  111. bool ResourceCache::AddManualResource(Resource* resource)
  112. {
  113. if (!resource)
  114. {
  115. LOGERROR("Null manual resource");
  116. return false;
  117. }
  118. const String& name = resource->GetName();
  119. if (name.Empty())
  120. {
  121. LOGERROR("Manual resource with empty name, can not add");
  122. return false;
  123. }
  124. StoreNameHash(name);
  125. resource->ResetUseTimer();
  126. resourceGroups_[resource->GetType()].resources_[resource->GetNameHash()] = resource;
  127. UpdateResourceGroup(resource->GetType());
  128. return true;
  129. }
  130. void ResourceCache::RemoveResourceDir(const String& path)
  131. {
  132. String fixedPath = AddTrailingSlash(path);
  133. for (unsigned i = 0; i < resourceDirs_.Size(); ++i)
  134. {
  135. if (!resourceDirs_[i].Compare(path, false))
  136. {
  137. resourceDirs_.Erase(i);
  138. if (fileWatchers_.Size() > i)
  139. fileWatchers_.Erase(i);
  140. LOGINFO("Removed resource path " + fixedPath);
  141. return;
  142. }
  143. }
  144. }
  145. void ResourceCache::RemovePackageFile(PackageFile* package, bool releaseResources, bool forceRelease)
  146. {
  147. for (Vector<SharedPtr<PackageFile> >::Iterator i = packages_.Begin(); i != packages_.End(); ++i)
  148. {
  149. if (*i == package)
  150. {
  151. if (releaseResources)
  152. ReleasePackageResources(*i, forceRelease);
  153. LOGINFO("Removed resource package " + (*i)->GetName());
  154. packages_.Erase(i);
  155. return;
  156. }
  157. }
  158. }
  159. void ResourceCache::RemovePackageFile(const String& fileName, bool releaseResources, bool forceRelease)
  160. {
  161. // Compare the name and extension only, not the path
  162. String fileNameNoPath = GetFileNameAndExtension(fileName);
  163. for (Vector<SharedPtr<PackageFile> >::Iterator i = packages_.Begin(); i != packages_.End(); ++i)
  164. {
  165. if (!GetFileNameAndExtension((*i)->GetName()).Compare(fileNameNoPath, false))
  166. {
  167. if (releaseResources)
  168. ReleasePackageResources(*i, forceRelease);
  169. LOGINFO("Removed resource package " + (*i)->GetName());
  170. packages_.Erase(i);
  171. return;
  172. }
  173. }
  174. }
  175. void ResourceCache::ReleaseResource(ShortStringHash type, const String& name, bool force)
  176. {
  177. ReleaseResource(type, StringHash(name), force);
  178. }
  179. void ResourceCache::ReleaseResource(ShortStringHash type, StringHash nameHash, bool force)
  180. {
  181. const SharedPtr<Resource>& existingRes = FindResource(type, nameHash);
  182. if (!existingRes)
  183. return;
  184. // If other references exist, do not release, unless forced
  185. if (existingRes.Refs() == 1 || force)
  186. {
  187. resourceGroups_[type].resources_.Erase(nameHash);
  188. UpdateResourceGroup(type);
  189. }
  190. }
  191. void ResourceCache::ReleaseResources(ShortStringHash type, bool force)
  192. {
  193. bool released = false;
  194. HashMap<ShortStringHash, ResourceGroup>::Iterator i = resourceGroups_.Find(type);
  195. if (i != resourceGroups_.End())
  196. {
  197. for (HashMap<StringHash, SharedPtr<Resource> >::Iterator j = i->second_.resources_.Begin();
  198. j != i->second_.resources_.End();)
  199. {
  200. HashMap<StringHash, SharedPtr<Resource> >::Iterator current = j++;
  201. // If other references exist, do not release, unless forced
  202. if (current->second_.Refs() == 1 || force)
  203. {
  204. i->second_.resources_.Erase(current);
  205. released = true;
  206. }
  207. }
  208. }
  209. if (released)
  210. UpdateResourceGroup(type);
  211. }
  212. void ResourceCache::ReleaseResources(ShortStringHash type, const String& partialName, bool force)
  213. {
  214. bool released = false;
  215. HashMap<ShortStringHash, ResourceGroup>::Iterator i = resourceGroups_.Find(type);
  216. if (i != resourceGroups_.End())
  217. {
  218. for (HashMap<StringHash, SharedPtr<Resource> >::Iterator j = i->second_.resources_.Begin();
  219. j != i->second_.resources_.End();)
  220. {
  221. HashMap<StringHash, SharedPtr<Resource> >::Iterator current = j++;
  222. if (current->second_->GetName().Contains(partialName))
  223. {
  224. // If other references exist, do not release, unless forced
  225. if (current->second_.Refs() == 1 || force)
  226. {
  227. i->second_.resources_.Erase(current);
  228. released = true;
  229. }
  230. }
  231. }
  232. }
  233. if (released)
  234. UpdateResourceGroup(type);
  235. }
  236. void ResourceCache::ReleaseAllResources(bool force)
  237. {
  238. for (HashMap<ShortStringHash, ResourceGroup>::Iterator i = resourceGroups_.Begin();
  239. i != resourceGroups_.End(); ++i)
  240. {
  241. bool released = false;
  242. for (HashMap<StringHash, SharedPtr<Resource> >::Iterator j = i->second_.resources_.Begin();
  243. j != i->second_.resources_.End();)
  244. {
  245. HashMap<StringHash, SharedPtr<Resource> >::Iterator current = j++;
  246. // If other references exist, do not release, unless forced
  247. if ((current->second_.Refs() == 1 && current->second_.WeakRefs() == 0) || force)
  248. {
  249. i->second_.resources_.Erase(current);
  250. released = true;
  251. }
  252. }
  253. if (released)
  254. UpdateResourceGroup(i->first_);
  255. }
  256. }
  257. bool ResourceCache::ReloadResource(Resource* resource)
  258. {
  259. if (!resource)
  260. return false;
  261. resource->SendEvent(E_RELOADSTARTED);
  262. bool success = false;
  263. SharedPtr<File> file = GetFile(resource->GetName());
  264. if (file)
  265. success = resource->Load(*(file.Get()));
  266. if (success)
  267. {
  268. resource->ResetUseTimer();
  269. UpdateResourceGroup(resource->GetType());
  270. resource->SendEvent(E_RELOADFINISHED);
  271. return true;
  272. }
  273. // If reloading failed, do not remove the resource from cache, to allow for a new live edit to
  274. // attempt loading again
  275. resource->SendEvent(E_RELOADFAILED);
  276. return false;
  277. }
  278. void ResourceCache::SetMemoryBudget(ShortStringHash type, unsigned budget)
  279. {
  280. resourceGroups_[type].memoryBudget_ = budget;
  281. }
  282. void ResourceCache::SetAutoReloadResources(bool enable)
  283. {
  284. if (enable != autoReloadResources_)
  285. {
  286. if (enable)
  287. {
  288. for (unsigned i = 0; i < resourceDirs_.Size(); ++i)
  289. {
  290. SharedPtr<FileWatcher> watcher(new FileWatcher(context_));
  291. watcher->StartWatching(resourceDirs_[i], true);
  292. fileWatchers_.Push(watcher);
  293. }
  294. SubscribeToEvent(E_BEGINFRAME, HANDLER(ResourceCache, HandleBeginFrame));
  295. }
  296. else
  297. {
  298. UnsubscribeFromEvent(E_BEGINFRAME);
  299. fileWatchers_.Clear();
  300. }
  301. autoReloadResources_ = enable;
  302. }
  303. }
  304. SharedPtr<File> ResourceCache::GetFile(const String& nameIn)
  305. {
  306. String name = SanitateResourceName(nameIn);
  307. // Check first the packages
  308. for (unsigned i = 0; i < packages_.Size(); ++i)
  309. {
  310. if (packages_[i]->Exists(name))
  311. return SharedPtr<File>(new File(context_, packages_[i], name));
  312. }
  313. // Then the filesystem
  314. FileSystem* fileSystem = GetSubsystem<FileSystem>();
  315. if (fileSystem)
  316. {
  317. for (unsigned i = 0; i < resourceDirs_.Size(); ++i)
  318. {
  319. if (fileSystem->FileExists(resourceDirs_[i] + name))
  320. {
  321. // Construct the file first with full path, then rename it to not contain the resource path,
  322. // so that the file's name can be used in further GetFile() calls (for example over the network)
  323. SharedPtr<File> file(new File(context_, resourceDirs_[i] + name));
  324. file->SetName(name);
  325. return file;
  326. }
  327. }
  328. // Fallback using absolute path
  329. if (fileSystem->FileExists(name))
  330. return SharedPtr<File>(new File(context_, name));
  331. }
  332. LOGERROR("Could not find resource " + name);
  333. return SharedPtr<File>();
  334. }
  335. Resource* ResourceCache::GetResource(ShortStringHash type, const String& nameIn)
  336. {
  337. String name = SanitateResourceName(nameIn);
  338. // Add the name to the hash map, so if this is an unknown resource, the error will not be unintelligible
  339. StoreNameHash(name);
  340. return GetResource(type, StringHash(name));
  341. }
  342. Resource* ResourceCache::GetResource(ShortStringHash type, const char* name)
  343. {
  344. return GetResource(type, String(name));
  345. }
  346. Resource* ResourceCache::GetResource(ShortStringHash type, StringHash nameHash)
  347. {
  348. // If null hash, return null pointer immediately
  349. if (!nameHash)
  350. return 0;
  351. const SharedPtr<Resource>& existing = FindResource(type, nameHash);
  352. if (existing)
  353. return existing;
  354. SharedPtr<Resource> resource;
  355. const String& name = GetResourceName(nameHash);
  356. if (name.Empty())
  357. {
  358. LOGERROR("Could not load unknown resource " + String(nameHash));
  359. return 0;
  360. }
  361. // Make sure the pointer is non-null and is a Resource subclass
  362. resource = DynamicCast<Resource>(context_->CreateObject(type));
  363. if (!resource)
  364. {
  365. LOGERROR("Could not load unknown resource type " + String(type));
  366. return 0;
  367. }
  368. // Attempt to load the resource
  369. SharedPtr<File> file = GetFile(name);
  370. if (!file)
  371. return 0;
  372. LOGDEBUG("Loading resource " + name);
  373. resource->SetName(file->GetName());
  374. if (!resource->Load(*(file.Get())))
  375. return 0;
  376. // Store to cache
  377. resource->ResetUseTimer();
  378. resourceGroups_[type].resources_[nameHash] = resource;
  379. UpdateResourceGroup(type);
  380. return resource;
  381. }
  382. void ResourceCache::GetResources(PODVector<Resource*>& result, ShortStringHash type) const
  383. {
  384. result.Clear();
  385. HashMap<ShortStringHash, ResourceGroup>::ConstIterator i = resourceGroups_.Find(type);
  386. if (i != resourceGroups_.End())
  387. {
  388. for (HashMap<StringHash, SharedPtr<Resource> >::ConstIterator j = i->second_.resources_.Begin();
  389. j != i->second_.resources_.End(); ++j)
  390. result.Push(j->second_);
  391. }
  392. }
  393. bool ResourceCache::Exists(const String& nameIn) const
  394. {
  395. String name = SanitateResourceName(nameIn);
  396. for (unsigned i = 0; i < packages_.Size(); ++i)
  397. {
  398. if (packages_[i]->Exists(name))
  399. return true;
  400. }
  401. FileSystem* fileSystem = GetSubsystem<FileSystem>();
  402. if (fileSystem)
  403. {
  404. for (unsigned i = 0; i < resourceDirs_.Size(); ++i)
  405. {
  406. if (fileSystem->FileExists(resourceDirs_[i] + name))
  407. return true;
  408. }
  409. // Fallback using absolute path
  410. if (fileSystem->FileExists(name))
  411. return true;
  412. }
  413. return false;
  414. }
  415. bool ResourceCache::Exists(StringHash nameHash) const
  416. {
  417. return Exists(GetResourceName(nameHash));
  418. }
  419. unsigned ResourceCache::GetMemoryBudget(ShortStringHash type) const
  420. {
  421. HashMap<ShortStringHash, ResourceGroup>::ConstIterator i = resourceGroups_.Find(type);
  422. if (i != resourceGroups_.End())
  423. return i->second_.memoryBudget_;
  424. else
  425. return 0;
  426. }
  427. unsigned ResourceCache::GetMemoryUse(ShortStringHash type) const
  428. {
  429. HashMap<ShortStringHash, ResourceGroup>::ConstIterator i = resourceGroups_.Find(type);
  430. if (i != resourceGroups_.End())
  431. return i->second_.memoryUse_;
  432. else
  433. return 0;
  434. }
  435. unsigned ResourceCache::GetTotalMemoryUse() const
  436. {
  437. unsigned total = 0;
  438. for (HashMap<ShortStringHash, ResourceGroup>::ConstIterator i = resourceGroups_.Begin(); i != resourceGroups_.End(); ++i)
  439. total += i->second_.memoryUse_;
  440. return total;
  441. }
  442. const String& ResourceCache::GetResourceName(StringHash nameHash) const
  443. {
  444. HashMap<StringHash, String>::ConstIterator i = hashToName_.Find(nameHash);
  445. if (i == hashToName_.End())
  446. return String::EMPTY;
  447. else
  448. return i->second_;
  449. }
  450. String ResourceCache::GetResourceFileName(const String& name) const
  451. {
  452. FileSystem* fileSystem = GetSubsystem<FileSystem>();
  453. if (fileSystem)
  454. {
  455. for (unsigned i = 0; i < resourceDirs_.Size(); ++i)
  456. {
  457. if (fileSystem->FileExists(resourceDirs_[i] + name))
  458. return resourceDirs_[i] + name;
  459. }
  460. }
  461. return String();
  462. }
  463. String ResourceCache::GetPreferredResourceDir(const String& path) const
  464. {
  465. String fixedPath = AddTrailingSlash(path);
  466. bool pathHasKnownDirs = false;
  467. bool parentHasKnownDirs = false;
  468. FileSystem* fileSystem = GetSubsystem<FileSystem>();
  469. // If no filesystem, can not check directory existence, so just return the original path
  470. if (!fileSystem)
  471. return fixedPath;
  472. for (unsigned i = 0; checkDirs[i] != 0; ++i)
  473. {
  474. if (fileSystem->DirExists(fixedPath + checkDirs[i]))
  475. {
  476. pathHasKnownDirs = true;
  477. break;
  478. }
  479. }
  480. if (!pathHasKnownDirs)
  481. {
  482. String parentPath = GetParentPath(fixedPath);
  483. for (unsigned i = 0; checkDirs[i] != 0; ++i)
  484. {
  485. if (fileSystem->DirExists(parentPath + checkDirs[i]))
  486. {
  487. parentHasKnownDirs = true;
  488. break;
  489. }
  490. }
  491. // If path does not have known subdirectories, but the parent path has, use the parent instead
  492. if (parentHasKnownDirs)
  493. fixedPath = parentPath;
  494. }
  495. return fixedPath;
  496. }
  497. String ResourceCache::SanitateResourceName(const String& nameIn) const
  498. {
  499. // Sanitate unsupported constructs from the resource name
  500. String name = GetInternalPath(nameIn);
  501. name.Replace("../", "");
  502. name.Replace("./", "");
  503. // If the path refers to one of the resource directories, normalize the resource name
  504. FileSystem* fileSystem = GetSubsystem<FileSystem>();
  505. if (fileSystem && resourceDirs_.Size())
  506. {
  507. String namePath = GetPath(name);
  508. String exePath = fileSystem->GetProgramDir();
  509. for (unsigned i = 0; i < resourceDirs_.Size(); ++i)
  510. {
  511. String relativeResourcePath = resourceDirs_[i];
  512. if (relativeResourcePath.StartsWith(exePath))
  513. relativeResourcePath = relativeResourcePath.Substring(exePath.Length());
  514. if (namePath.StartsWith(resourceDirs_[i], false))
  515. namePath = namePath.Substring(resourceDirs_[i].Length());
  516. else if (namePath.StartsWith(relativeResourcePath, false))
  517. namePath = namePath.Substring(relativeResourcePath.Length());
  518. }
  519. name = namePath + GetFileNameAndExtension(name);
  520. }
  521. return name;
  522. }
  523. void ResourceCache::StoreNameHash(const String& name)
  524. {
  525. if (name.Empty())
  526. return;
  527. StringHash hash(name);
  528. // If entry exists, check for difference (collision)
  529. HashMap<StringHash, String>::Iterator i = hashToName_.Find(hash);
  530. if (i != hashToName_.End())
  531. {
  532. if (i->second_.Compare(name, false))
  533. LOGERROR("Resource hash collision " + i->second_ + " vs " + name);
  534. i->second_ = name;
  535. }
  536. else
  537. hashToName_[hash] = name;
  538. }
  539. void ResourceCache::StoreResourceDependency(Resource* resource, const String& dependency)
  540. {
  541. // If resource reloading is not on, do not create the dependency data structure (saves memory)
  542. if (!resource || !autoReloadResources_)
  543. return;
  544. StringHash nameHash(resource->GetName());
  545. HashSet<StringHash>& dependents = dependentResources_[dependency];
  546. dependents.Insert(nameHash);
  547. }
  548. void ResourceCache::ResetDependencies(Resource* resource)
  549. {
  550. if (!resource || !autoReloadResources_)
  551. return;
  552. StringHash nameHash(resource->GetName());
  553. for (HashMap<StringHash, HashSet<StringHash> >::Iterator i = dependentResources_.Begin(); i !=
  554. dependentResources_.End();)
  555. {
  556. HashSet<StringHash>& dependents = i->second_;
  557. dependents.Erase(nameHash);
  558. if (dependents.Empty())
  559. i = dependentResources_.Erase(i);
  560. else
  561. ++i;
  562. }
  563. }
  564. const SharedPtr<Resource>& ResourceCache::FindResource(ShortStringHash type, StringHash nameHash)
  565. {
  566. HashMap<ShortStringHash, ResourceGroup>::Iterator i = resourceGroups_.Find(type);
  567. if (i == resourceGroups_.End())
  568. return noResource;
  569. HashMap<StringHash, SharedPtr<Resource> >::Iterator j = i->second_.resources_.Find(nameHash);
  570. if (j == i->second_.resources_.End())
  571. return noResource;
  572. return j->second_;
  573. }
  574. const SharedPtr<Resource>& ResourceCache::FindResource(StringHash nameHash)
  575. {
  576. for (HashMap<ShortStringHash, ResourceGroup>::Iterator i = resourceGroups_.Begin(); i != resourceGroups_.End(); ++i)
  577. {
  578. HashMap<StringHash, SharedPtr<Resource> >::Iterator j = i->second_.resources_.Find(nameHash);
  579. if (j != i->second_.resources_.End())
  580. return j->second_;
  581. }
  582. return noResource;
  583. }
  584. void ResourceCache::ReleasePackageResources(PackageFile* package, bool force)
  585. {
  586. HashSet<ShortStringHash> affectedGroups;
  587. const HashMap<String, PackageEntry>& entries = package->GetEntries();
  588. for (HashMap<String, PackageEntry>::ConstIterator i = entries.Begin(); i != entries.End(); ++i)
  589. {
  590. StringHash nameHash(i->first_);
  591. // We do not know the actual resource type, so search all type containers
  592. for (HashMap<ShortStringHash, ResourceGroup>::Iterator j = resourceGroups_.Begin();
  593. j != resourceGroups_.End(); ++j)
  594. {
  595. HashMap<StringHash, SharedPtr<Resource> >::Iterator k = j->second_.resources_.Find(nameHash);
  596. if (k != j->second_.resources_.End())
  597. {
  598. // If other references exist, do not release, unless forced
  599. if (k->second_.Refs() == 1 || force)
  600. {
  601. j->second_.resources_.Erase(k);
  602. affectedGroups.Insert(j->first_);
  603. }
  604. break;
  605. }
  606. }
  607. }
  608. for (HashSet<ShortStringHash>::Iterator i = affectedGroups.Begin(); i != affectedGroups.End(); ++i)
  609. UpdateResourceGroup(*i);
  610. }
  611. void ResourceCache::UpdateResourceGroup(ShortStringHash type)
  612. {
  613. HashMap<ShortStringHash, ResourceGroup>::Iterator i = resourceGroups_.Find(type);
  614. if (i == resourceGroups_.End())
  615. return;
  616. for (;;)
  617. {
  618. unsigned totalSize = 0;
  619. unsigned oldestTimer = 0;
  620. HashMap<StringHash, SharedPtr<Resource> >::Iterator oldestResource = i->second_.resources_.End();
  621. for (HashMap<StringHash, SharedPtr<Resource> >::Iterator j = i->second_.resources_.Begin();
  622. j != i->second_.resources_.End(); ++j)
  623. {
  624. totalSize += j->second_->GetMemoryUse();
  625. unsigned useTimer = j->second_->GetUseTimer();
  626. if (useTimer > oldestTimer)
  627. {
  628. oldestTimer = useTimer;
  629. oldestResource = j;
  630. }
  631. }
  632. i->second_.memoryUse_ = totalSize;
  633. // If memory budget defined and is exceeded, remove the oldest resource and loop again
  634. // (resources in use always return a zero timer and can not be removed)
  635. if (i->second_.memoryBudget_ && i->second_.memoryUse_ > i->second_.memoryBudget_ &&
  636. oldestResource != i->second_.resources_.End())
  637. {
  638. LOGDEBUG("Resource group " + oldestResource->second_->GetTypeName() + " over memory budget, releasing resource " +
  639. oldestResource->second_->GetName());
  640. i->second_.resources_.Erase(oldestResource);
  641. }
  642. else
  643. break;
  644. }
  645. }
  646. void ResourceCache::HandleBeginFrame(StringHash eventType, VariantMap& eventData)
  647. {
  648. for (unsigned i = 0; i < fileWatchers_.Size(); ++i)
  649. {
  650. String fileName;
  651. while (fileWatchers_[i]->GetNextChange(fileName))
  652. {
  653. StringHash fileNameHash(fileName);
  654. // If the filename is a resource we keep track of, reload it
  655. const SharedPtr<Resource>& resource = FindResource(fileNameHash);
  656. if (resource)
  657. {
  658. LOGDEBUG("Reloading changed resource " + fileName);
  659. ReloadResource(resource);
  660. }
  661. else
  662. {
  663. // Check if this is a dependency resource, reload dependents
  664. HashMap<StringHash, HashSet<StringHash> >::ConstIterator j = dependentResources_.Find(fileNameHash);
  665. if (j != dependentResources_.End())
  666. {
  667. // Reloading a resource may modify the dependency tracking structure. Therefore collect the
  668. // resources we need to reload first
  669. Vector<SharedPtr<Resource> > dependents;
  670. for (HashSet<StringHash>::ConstIterator k = j->second_.Begin(); k != j->second_.End(); ++k)
  671. {
  672. const SharedPtr<Resource>& dependent = FindResource(*k);
  673. if (dependent)
  674. dependents.Push(dependent);
  675. }
  676. for (unsigned k = 0; k < dependents.Size(); ++k)
  677. {
  678. LOGDEBUG("Reloading resource " + dependents[k]->GetName() + " depending on " + fileName);
  679. ReloadResource(dependents[k]);
  680. }
  681. }
  682. }
  683. }
  684. }
  685. }
  686. void RegisterResourceLibrary(Context* context)
  687. {
  688. Image::RegisterObject(context);
  689. XMLFile::RegisterObject(context);
  690. }
  691. }