ResourceCache.cpp 26 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694695696697698699700701702703704705706707708709710711712713714715716717718719720721722723724725726727728729730731732733734735736737738739740741742743744745746747748749750751752753754755756757758759760761762763764765766767768769770771772773774775776777778779780781782783784785786787788789790791792793794795796797798799800801802803804805806807808809810811812813814815
  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. searchPackagesFirst_(true)
  59. {
  60. // Register Resource library object factories
  61. RegisterResourceLibrary(context_);
  62. }
  63. ResourceCache::~ResourceCache()
  64. {
  65. }
  66. bool ResourceCache::AddResourceDir(const String& pathName, unsigned int priority)
  67. {
  68. FileSystem* fileSystem = GetSubsystem<FileSystem>();
  69. if (!fileSystem || !fileSystem->DirExists(pathName))
  70. {
  71. LOGERROR("Could not open directory " + pathName);
  72. return false;
  73. }
  74. // Convert path to absolute
  75. String fixedPath = AddTrailingSlash(pathName);
  76. if (!IsAbsolutePath(fixedPath))
  77. fixedPath = fileSystem->GetCurrentDir() + fixedPath;
  78. // Sanitate away /./ construct
  79. fixedPath.Replace("/./", "/");
  80. // Check that the same path does not already exist
  81. for (unsigned i = 0; i < resourceDirs_.Size(); ++i)
  82. {
  83. if (!resourceDirs_[i].Compare(fixedPath, false))
  84. return true;
  85. }
  86. // If the priority isn't last or greater than size insert at position otherwise push.
  87. if (priority > PRIORITY_LAST && priority < resourceDirs_.Size())
  88. resourceDirs_.Insert(priority, fixedPath);
  89. else
  90. resourceDirs_.Push(fixedPath);
  91. // If resource auto-reloading active, create a file watcher for the directory
  92. if (autoReloadResources_)
  93. {
  94. SharedPtr<FileWatcher> watcher(new FileWatcher(context_));
  95. watcher->StartWatching(fixedPath, true);
  96. fileWatchers_.Push(watcher);
  97. }
  98. LOGINFO("Added resource path " + fixedPath);
  99. return true;
  100. }
  101. void ResourceCache::AddPackageFile(PackageFile* package, unsigned int priority)
  102. {
  103. // Do not add packages that failed to load
  104. if (!package || !package->GetNumFiles())
  105. return;
  106. // If the priority isn't last or greater than size insert at position otherwise push.
  107. if (priority > PRIORITY_LAST && priority < packages_.Size())
  108. packages_.Insert(priority, SharedPtr<PackageFile>(package));
  109. else
  110. packages_.Push(SharedPtr<PackageFile>(package));
  111. LOGINFO("Added resource package " + package->GetName());
  112. }
  113. bool ResourceCache::AddManualResource(Resource* resource)
  114. {
  115. if (!resource)
  116. {
  117. LOGERROR("Null manual resource");
  118. return false;
  119. }
  120. const String& name = resource->GetName();
  121. if (name.Empty())
  122. {
  123. LOGERROR("Manual resource with empty name, can not add");
  124. return false;
  125. }
  126. resource->ResetUseTimer();
  127. resourceGroups_[resource->GetType()].resources_[resource->GetNameHash()] = resource;
  128. UpdateResourceGroup(resource->GetType());
  129. return true;
  130. }
  131. void ResourceCache::RemoveResourceDir(const String& path)
  132. {
  133. String fixedPath = AddTrailingSlash(path);
  134. for (unsigned i = 0; i < resourceDirs_.Size(); ++i)
  135. {
  136. if (!resourceDirs_[i].Compare(path, false))
  137. {
  138. resourceDirs_.Erase(i);
  139. if (fileWatchers_.Size() > i)
  140. fileWatchers_.Erase(i);
  141. LOGINFO("Removed resource path " + fixedPath);
  142. return;
  143. }
  144. }
  145. }
  146. void ResourceCache::RemovePackageFile(PackageFile* package, bool releaseResources, bool forceRelease)
  147. {
  148. for (Vector<SharedPtr<PackageFile> >::Iterator i = packages_.Begin(); i != packages_.End(); ++i)
  149. {
  150. if (*i == package)
  151. {
  152. if (releaseResources)
  153. ReleasePackageResources(*i, forceRelease);
  154. LOGINFO("Removed resource package " + (*i)->GetName());
  155. packages_.Erase(i);
  156. return;
  157. }
  158. }
  159. }
  160. void ResourceCache::RemovePackageFile(const String& fileName, bool releaseResources, bool forceRelease)
  161. {
  162. // Compare the name and extension only, not the path
  163. String fileNameNoPath = GetFileNameAndExtension(fileName);
  164. for (Vector<SharedPtr<PackageFile> >::Iterator i = packages_.Begin(); i != packages_.End(); ++i)
  165. {
  166. if (!GetFileNameAndExtension((*i)->GetName()).Compare(fileNameNoPath, false))
  167. {
  168. if (releaseResources)
  169. ReleasePackageResources(*i, forceRelease);
  170. LOGINFO("Removed resource package " + (*i)->GetName());
  171. packages_.Erase(i);
  172. return;
  173. }
  174. }
  175. }
  176. void ResourceCache::ReleaseResource(ShortStringHash type, const String& name, bool force)
  177. {
  178. StringHash nameHash(name);
  179. const SharedPtr<Resource>& existingRes = FindResource(type, nameHash);
  180. if (!existingRes)
  181. return;
  182. // If other references exist, do not release, unless forced
  183. if ((existingRes.Refs() == 1 && existingRes.WeakRefs() == 0) || force)
  184. {
  185. resourceGroups_[type].resources_.Erase(nameHash);
  186. UpdateResourceGroup(type);
  187. }
  188. }
  189. void ResourceCache::ReleaseResources(ShortStringHash type, bool force)
  190. {
  191. bool released = false;
  192. HashMap<ShortStringHash, ResourceGroup>::Iterator i = resourceGroups_.Find(type);
  193. if (i != resourceGroups_.End())
  194. {
  195. for (HashMap<StringHash, SharedPtr<Resource> >::Iterator j = i->second_.resources_.Begin();
  196. j != i->second_.resources_.End();)
  197. {
  198. HashMap<StringHash, SharedPtr<Resource> >::Iterator current = j++;
  199. // If other references exist, do not release, unless forced
  200. if ((current->second_.Refs() == 1 && current->second_.WeakRefs() == 0) || force)
  201. {
  202. i->second_.resources_.Erase(current);
  203. released = true;
  204. }
  205. }
  206. }
  207. if (released)
  208. UpdateResourceGroup(type);
  209. }
  210. void ResourceCache::ReleaseResources(ShortStringHash type, const String& partialName, bool force)
  211. {
  212. bool released = false;
  213. HashMap<ShortStringHash, ResourceGroup>::Iterator i = resourceGroups_.Find(type);
  214. if (i != resourceGroups_.End())
  215. {
  216. for (HashMap<StringHash, SharedPtr<Resource> >::Iterator j = i->second_.resources_.Begin();
  217. j != i->second_.resources_.End();)
  218. {
  219. HashMap<StringHash, SharedPtr<Resource> >::Iterator current = j++;
  220. if (current->second_->GetName().Contains(partialName))
  221. {
  222. // If other references exist, do not release, unless forced
  223. if ((current->second_.Refs() == 1 && current->second_.WeakRefs() == 0) || force)
  224. {
  225. i->second_.resources_.Erase(current);
  226. released = true;
  227. }
  228. }
  229. }
  230. }
  231. if (released)
  232. UpdateResourceGroup(type);
  233. }
  234. void ResourceCache::ReleaseResources(const String& partialName, bool force)
  235. {
  236. // Some resources refer to others, like materials to textures. Release twice to ensure these get released.
  237. // This is not necessary if forcing release
  238. unsigned repeat = force ? 1 : 2;
  239. while (repeat--)
  240. {
  241. for (HashMap<ShortStringHash, ResourceGroup>::Iterator i = resourceGroups_.Begin(); i != resourceGroups_.End(); ++i)
  242. {
  243. bool released = false;
  244. for (HashMap<StringHash, SharedPtr<Resource> >::Iterator j = i->second_.resources_.Begin();
  245. j != i->second_.resources_.End();)
  246. {
  247. HashMap<StringHash, SharedPtr<Resource> >::Iterator current = j++;
  248. if (current->second_->GetName().Contains(partialName))
  249. {
  250. // If other references exist, do not release, unless forced
  251. if ((current->second_.Refs() == 1 && current->second_.WeakRefs() == 0) || force)
  252. {
  253. i->second_.resources_.Erase(current);
  254. released = true;
  255. }
  256. }
  257. }
  258. if (released)
  259. UpdateResourceGroup(i->first_);
  260. }
  261. }
  262. }
  263. void ResourceCache::ReleaseAllResources(bool force)
  264. {
  265. unsigned repeat = force ? 1 : 2;
  266. while (repeat--)
  267. {
  268. for (HashMap<ShortStringHash, ResourceGroup>::Iterator i = resourceGroups_.Begin();
  269. i != resourceGroups_.End(); ++i)
  270. {
  271. bool released = false;
  272. for (HashMap<StringHash, SharedPtr<Resource> >::Iterator j = i->second_.resources_.Begin();
  273. j != i->second_.resources_.End();)
  274. {
  275. HashMap<StringHash, SharedPtr<Resource> >::Iterator current = j++;
  276. // If other references exist, do not release, unless forced
  277. if ((current->second_.Refs() == 1 && current->second_.WeakRefs() == 0) || force)
  278. {
  279. i->second_.resources_.Erase(current);
  280. released = true;
  281. }
  282. }
  283. if (released)
  284. UpdateResourceGroup(i->first_);
  285. }
  286. }
  287. }
  288. bool ResourceCache::ReloadResource(Resource* resource)
  289. {
  290. if (!resource)
  291. return false;
  292. resource->SendEvent(E_RELOADSTARTED);
  293. bool success = false;
  294. SharedPtr<File> file = GetFile(resource->GetName());
  295. if (file)
  296. success = resource->Load(*(file.Get()));
  297. if (success)
  298. {
  299. resource->ResetUseTimer();
  300. UpdateResourceGroup(resource->GetType());
  301. resource->SendEvent(E_RELOADFINISHED);
  302. return true;
  303. }
  304. // If reloading failed, do not remove the resource from cache, to allow for a new live edit to
  305. // attempt loading again
  306. resource->SendEvent(E_RELOADFAILED);
  307. return false;
  308. }
  309. void ResourceCache::SetMemoryBudget(ShortStringHash type, unsigned budget)
  310. {
  311. resourceGroups_[type].memoryBudget_ = budget;
  312. }
  313. void ResourceCache::SetAutoReloadResources(bool enable)
  314. {
  315. if (enable != autoReloadResources_)
  316. {
  317. if (enable)
  318. {
  319. for (unsigned i = 0; i < resourceDirs_.Size(); ++i)
  320. {
  321. SharedPtr<FileWatcher> watcher(new FileWatcher(context_));
  322. watcher->StartWatching(resourceDirs_[i], true);
  323. fileWatchers_.Push(watcher);
  324. }
  325. SubscribeToEvent(E_BEGINFRAME, HANDLER(ResourceCache, HandleBeginFrame));
  326. }
  327. else
  328. {
  329. UnsubscribeFromEvent(E_BEGINFRAME);
  330. fileWatchers_.Clear();
  331. }
  332. autoReloadResources_ = enable;
  333. }
  334. }
  335. SharedPtr<File> ResourceCache::GetFile(const String& nameIn)
  336. {
  337. String name = SanitateResourceName(nameIn);
  338. File* file = 0;
  339. if (searchPackagesFirst_)
  340. {
  341. file = SearchPackages(name);
  342. if (!file)
  343. file = SearchResourceDirs(name);
  344. }
  345. else
  346. {
  347. file = SearchResourceDirs(name);
  348. if (!file)
  349. file = SearchPackages(name);
  350. }
  351. if (file)
  352. return SharedPtr<File>(file);
  353. LOGERROR("Could not find resource " + name);
  354. return SharedPtr<File>();
  355. }
  356. Resource* ResourceCache::GetResource(ShortStringHash type, const char* name)
  357. {
  358. return GetResource(type, String(name));
  359. }
  360. Resource* ResourceCache::GetResource(ShortStringHash type, const String& nameIn)
  361. {
  362. String name = SanitateResourceName(nameIn);
  363. // If empty name, return null pointer immediately
  364. if (name.Empty())
  365. return 0;
  366. StringHash nameHash(name);
  367. const SharedPtr<Resource>& existing = FindResource(type, nameHash);
  368. if (existing)
  369. return existing;
  370. SharedPtr<Resource> resource;
  371. // Make sure the pointer is non-null and is a Resource subclass
  372. resource = DynamicCast<Resource>(context_->CreateObject(type));
  373. if (!resource)
  374. {
  375. LOGERROR("Could not load unknown resource type " + String(type));
  376. return 0;
  377. }
  378. // Attempt to load the resource
  379. SharedPtr<File> file = GetFile(name);
  380. if (!file)
  381. return 0;
  382. LOGDEBUG("Loading resource " + name);
  383. resource->SetName(file->GetName());
  384. if (!resource->Load(*(file.Get())))
  385. return 0;
  386. // Store to cache
  387. resource->ResetUseTimer();
  388. resourceGroups_[type].resources_[nameHash] = resource;
  389. UpdateResourceGroup(type);
  390. return resource;
  391. }
  392. void ResourceCache::GetResources(PODVector<Resource*>& result, ShortStringHash type) const
  393. {
  394. result.Clear();
  395. HashMap<ShortStringHash, ResourceGroup>::ConstIterator i = resourceGroups_.Find(type);
  396. if (i != resourceGroups_.End())
  397. {
  398. for (HashMap<StringHash, SharedPtr<Resource> >::ConstIterator j = i->second_.resources_.Begin();
  399. j != i->second_.resources_.End(); ++j)
  400. result.Push(j->second_);
  401. }
  402. }
  403. bool ResourceCache::Exists(const String& nameIn) const
  404. {
  405. String name = SanitateResourceName(nameIn);
  406. for (unsigned i = 0; i < packages_.Size(); ++i)
  407. {
  408. if (packages_[i]->Exists(name))
  409. return true;
  410. }
  411. FileSystem* fileSystem = GetSubsystem<FileSystem>();
  412. if (fileSystem)
  413. {
  414. for (unsigned i = 0; i < resourceDirs_.Size(); ++i)
  415. {
  416. if (fileSystem->FileExists(resourceDirs_[i] + name))
  417. return true;
  418. }
  419. // Fallback using absolute path
  420. if (fileSystem->FileExists(name))
  421. return true;
  422. }
  423. return false;
  424. }
  425. unsigned ResourceCache::GetMemoryBudget(ShortStringHash type) const
  426. {
  427. HashMap<ShortStringHash, ResourceGroup>::ConstIterator i = resourceGroups_.Find(type);
  428. if (i != resourceGroups_.End())
  429. return i->second_.memoryBudget_;
  430. else
  431. return 0;
  432. }
  433. unsigned ResourceCache::GetMemoryUse(ShortStringHash type) const
  434. {
  435. HashMap<ShortStringHash, ResourceGroup>::ConstIterator i = resourceGroups_.Find(type);
  436. if (i != resourceGroups_.End())
  437. return i->second_.memoryUse_;
  438. else
  439. return 0;
  440. }
  441. unsigned ResourceCache::GetTotalMemoryUse() const
  442. {
  443. unsigned total = 0;
  444. for (HashMap<ShortStringHash, ResourceGroup>::ConstIterator i = resourceGroups_.Begin(); i != resourceGroups_.End(); ++i)
  445. total += i->second_.memoryUse_;
  446. return total;
  447. }
  448. String ResourceCache::GetResourceFileName(const String& name) const
  449. {
  450. FileSystem* fileSystem = GetSubsystem<FileSystem>();
  451. if (fileSystem)
  452. {
  453. for (unsigned i = 0; i < resourceDirs_.Size(); ++i)
  454. {
  455. if (fileSystem->FileExists(resourceDirs_[i] + name))
  456. return resourceDirs_[i] + name;
  457. }
  458. }
  459. return String();
  460. }
  461. String ResourceCache::GetPreferredResourceDir(const String& path) const
  462. {
  463. String fixedPath = AddTrailingSlash(path);
  464. bool pathHasKnownDirs = false;
  465. bool parentHasKnownDirs = false;
  466. FileSystem* fileSystem = GetSubsystem<FileSystem>();
  467. // If no filesystem, can not check directory existence, so just return the original path
  468. if (!fileSystem)
  469. return fixedPath;
  470. for (unsigned i = 0; checkDirs[i] != 0; ++i)
  471. {
  472. if (fileSystem->DirExists(fixedPath + checkDirs[i]))
  473. {
  474. pathHasKnownDirs = true;
  475. break;
  476. }
  477. }
  478. if (!pathHasKnownDirs)
  479. {
  480. String parentPath = GetParentPath(fixedPath);
  481. for (unsigned i = 0; checkDirs[i] != 0; ++i)
  482. {
  483. if (fileSystem->DirExists(parentPath + checkDirs[i]))
  484. {
  485. parentHasKnownDirs = true;
  486. break;
  487. }
  488. }
  489. // If path does not have known subdirectories, but the parent path has, use the parent instead
  490. if (parentHasKnownDirs)
  491. fixedPath = parentPath;
  492. }
  493. return fixedPath;
  494. }
  495. String ResourceCache::SanitateResourceName(const String& nameIn) const
  496. {
  497. // Sanitate unsupported constructs from the resource name
  498. String name = GetInternalPath(nameIn);
  499. name.Replace("../", "");
  500. name.Replace("./", "");
  501. // If the path refers to one of the resource directories, normalize the resource name
  502. FileSystem* fileSystem = GetSubsystem<FileSystem>();
  503. if (fileSystem && resourceDirs_.Size())
  504. {
  505. String namePath = GetPath(name);
  506. String exePath = fileSystem->GetProgramDir();
  507. for (unsigned i = 0; i < resourceDirs_.Size(); ++i)
  508. {
  509. String relativeResourcePath = resourceDirs_[i];
  510. if (relativeResourcePath.StartsWith(exePath))
  511. relativeResourcePath = relativeResourcePath.Substring(exePath.Length());
  512. if (namePath.StartsWith(resourceDirs_[i], false))
  513. namePath = namePath.Substring(resourceDirs_[i].Length());
  514. else if (namePath.StartsWith(relativeResourcePath, false))
  515. namePath = namePath.Substring(relativeResourcePath.Length());
  516. }
  517. name = namePath + GetFileNameAndExtension(name);
  518. }
  519. return name.Trimmed();
  520. }
  521. void ResourceCache::StoreResourceDependency(Resource* resource, const String& dependency)
  522. {
  523. // If resource reloading is not on, do not create the dependency data structure (saves memory)
  524. if (!resource || !autoReloadResources_)
  525. return;
  526. StringHash nameHash(resource->GetName());
  527. HashSet<StringHash>& dependents = dependentResources_[dependency];
  528. dependents.Insert(nameHash);
  529. }
  530. void ResourceCache::ResetDependencies(Resource* resource)
  531. {
  532. if (!resource || !autoReloadResources_)
  533. return;
  534. StringHash nameHash(resource->GetName());
  535. for (HashMap<StringHash, HashSet<StringHash> >::Iterator i = dependentResources_.Begin(); i !=
  536. dependentResources_.End();)
  537. {
  538. HashSet<StringHash>& dependents = i->second_;
  539. dependents.Erase(nameHash);
  540. if (dependents.Empty())
  541. i = dependentResources_.Erase(i);
  542. else
  543. ++i;
  544. }
  545. }
  546. const SharedPtr<Resource>& ResourceCache::FindResource(ShortStringHash type, StringHash nameHash)
  547. {
  548. HashMap<ShortStringHash, ResourceGroup>::Iterator i = resourceGroups_.Find(type);
  549. if (i == resourceGroups_.End())
  550. return noResource;
  551. HashMap<StringHash, SharedPtr<Resource> >::Iterator j = i->second_.resources_.Find(nameHash);
  552. if (j == i->second_.resources_.End())
  553. return noResource;
  554. return j->second_;
  555. }
  556. const SharedPtr<Resource>& ResourceCache::FindResource(StringHash nameHash)
  557. {
  558. for (HashMap<ShortStringHash, ResourceGroup>::Iterator i = resourceGroups_.Begin(); i != resourceGroups_.End(); ++i)
  559. {
  560. HashMap<StringHash, SharedPtr<Resource> >::Iterator j = i->second_.resources_.Find(nameHash);
  561. if (j != i->second_.resources_.End())
  562. return j->second_;
  563. }
  564. return noResource;
  565. }
  566. void ResourceCache::ReleasePackageResources(PackageFile* package, bool force)
  567. {
  568. HashSet<ShortStringHash> affectedGroups;
  569. const HashMap<String, PackageEntry>& entries = package->GetEntries();
  570. for (HashMap<String, PackageEntry>::ConstIterator i = entries.Begin(); i != entries.End(); ++i)
  571. {
  572. StringHash nameHash(i->first_);
  573. // We do not know the actual resource type, so search all type containers
  574. for (HashMap<ShortStringHash, ResourceGroup>::Iterator j = resourceGroups_.Begin();
  575. j != resourceGroups_.End(); ++j)
  576. {
  577. HashMap<StringHash, SharedPtr<Resource> >::Iterator k = j->second_.resources_.Find(nameHash);
  578. if (k != j->second_.resources_.End())
  579. {
  580. // If other references exist, do not release, unless forced
  581. if ((k->second_.Refs() == 1 && k->second_.WeakRefs() == 0) || force)
  582. {
  583. j->second_.resources_.Erase(k);
  584. affectedGroups.Insert(j->first_);
  585. }
  586. break;
  587. }
  588. }
  589. }
  590. for (HashSet<ShortStringHash>::Iterator i = affectedGroups.Begin(); i != affectedGroups.End(); ++i)
  591. UpdateResourceGroup(*i);
  592. }
  593. void ResourceCache::UpdateResourceGroup(ShortStringHash type)
  594. {
  595. HashMap<ShortStringHash, ResourceGroup>::Iterator i = resourceGroups_.Find(type);
  596. if (i == resourceGroups_.End())
  597. return;
  598. for (;;)
  599. {
  600. unsigned totalSize = 0;
  601. unsigned oldestTimer = 0;
  602. HashMap<StringHash, SharedPtr<Resource> >::Iterator oldestResource = i->second_.resources_.End();
  603. for (HashMap<StringHash, SharedPtr<Resource> >::Iterator j = i->second_.resources_.Begin();
  604. j != i->second_.resources_.End(); ++j)
  605. {
  606. totalSize += j->second_->GetMemoryUse();
  607. unsigned useTimer = j->second_->GetUseTimer();
  608. if (useTimer > oldestTimer)
  609. {
  610. oldestTimer = useTimer;
  611. oldestResource = j;
  612. }
  613. }
  614. i->second_.memoryUse_ = totalSize;
  615. // If memory budget defined and is exceeded, remove the oldest resource and loop again
  616. // (resources in use always return a zero timer and can not be removed)
  617. if (i->second_.memoryBudget_ && i->second_.memoryUse_ > i->second_.memoryBudget_ &&
  618. oldestResource != i->second_.resources_.End())
  619. {
  620. LOGDEBUG("Resource group " + oldestResource->second_->GetTypeName() + " over memory budget, releasing resource " +
  621. oldestResource->second_->GetName());
  622. i->second_.resources_.Erase(oldestResource);
  623. }
  624. else
  625. break;
  626. }
  627. }
  628. void ResourceCache::HandleBeginFrame(StringHash eventType, VariantMap& eventData)
  629. {
  630. for (unsigned i = 0; i < fileWatchers_.Size(); ++i)
  631. {
  632. String fileName;
  633. while (fileWatchers_[i]->GetNextChange(fileName))
  634. {
  635. StringHash fileNameHash(fileName);
  636. // If the filename is a resource we keep track of, reload it
  637. const SharedPtr<Resource>& resource = FindResource(fileNameHash);
  638. if (resource)
  639. {
  640. LOGDEBUG("Reloading changed resource " + fileName);
  641. ReloadResource(resource);
  642. }
  643. else
  644. {
  645. // Check if this is a dependency resource, reload dependents
  646. HashMap<StringHash, HashSet<StringHash> >::ConstIterator j = dependentResources_.Find(fileNameHash);
  647. if (j != dependentResources_.End())
  648. {
  649. // Reloading a resource may modify the dependency tracking structure. Therefore collect the
  650. // resources we need to reload first
  651. Vector<SharedPtr<Resource> > dependents;
  652. for (HashSet<StringHash>::ConstIterator k = j->second_.Begin(); k != j->second_.End(); ++k)
  653. {
  654. const SharedPtr<Resource>& dependent = FindResource(*k);
  655. if (dependent)
  656. dependents.Push(dependent);
  657. }
  658. for (unsigned k = 0; k < dependents.Size(); ++k)
  659. {
  660. LOGDEBUG("Reloading resource " + dependents[k]->GetName() + " depending on " + fileName);
  661. ReloadResource(dependents[k]);
  662. }
  663. }
  664. }
  665. }
  666. }
  667. }
  668. File* ResourceCache::SearchResourceDirs(const String& nameIn)
  669. {
  670. // Then the filesystem
  671. FileSystem* fileSystem = GetSubsystem<FileSystem>();
  672. if (fileSystem)
  673. {
  674. for (unsigned i = 0; i < resourceDirs_.Size(); ++i)
  675. {
  676. if (fileSystem->FileExists(resourceDirs_[i] + nameIn))
  677. {
  678. // Construct the file first with full path, then rename it to not contain the resource path,
  679. // so that the file's name can be used in further GetFile() calls (for example over the network)
  680. File* file(new File(context_, resourceDirs_[i] + nameIn));
  681. file->SetName(nameIn);
  682. return file;
  683. }
  684. }
  685. // Fallback using absolute path
  686. if (fileSystem->FileExists(nameIn))
  687. return new File(context_, nameIn);
  688. }
  689. return 0;
  690. }
  691. File* ResourceCache::SearchPackages(const String& nameIn)
  692. {
  693. // Check first the packages
  694. for (unsigned i = 0; i < packages_.Size(); ++i)
  695. {
  696. if (packages_[i]->Exists(nameIn))
  697. return new File(context_, packages_[i], nameIn);
  698. }
  699. return 0;
  700. }
  701. void RegisterResourceLibrary(Context* context)
  702. {
  703. Image::RegisterObject(context);
  704. XMLFile::RegisterObject(context);
  705. }
  706. }