ResourceCache.cpp 28 KB

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