Method run

src/resource/resource_loader.cpp:78–164

}

s32 ResourceLoader::run()
{
	while (1) {
		_mutex.lock();
		while (!_exit.load() && _requests.empty())
			_requests_condition.wait(_mutex);

		_mutex.unlock();
		if (_exit.load())
			break;

		ResourceRequest rr;
		while (!_exit.load() && _requests.pop(rr)) {
			ResourceId res_id = resource_id(rr.type, rr.name);
			logd(RESOURCE_LOADER, "Load " RESOURCE_ID_FMT, res_id._id);

			TempAllocator128 ta;
			DynamicString path(ta);
			destination_path(path, res_id);

			if (_is_bundle) {
				if (rr.type == RESOURCE_TYPE_PACKAGE || rr.type == RESOURCE_TYPE_CONFIG) {
					File *file = _data_filesystem.open(path.c_str(), FileOpenMode::READ);
					CE_ASSERT(file->is_open(), "Cannot load " RESOURCE_ID_FMT, res_id._id);

					// Load the resource.
					rr.data = rr.load_function(*file, *rr.allocator);

					_data_filesystem.close(*file);
				} else {
					const PackageResource *pkg = rr.package_resource;
					CE_ASSERT(pkg != NULL, "Missing package for bundled resource: " RESOURCE_ID_FMT, res_id._id);

					// Find the resource inside the package.
					for (u32 ii = 0; ii < pkg->num_resources; ++ii) {
						const ResourceOffset *offt = package_resource::resource_offset(pkg, ii);
						if (offt->type == rr.type && offt->name == rr.name) {
							const void *resource_data = package_resource::data(pkg) + offt->offset;

							// Load the resource.
							FileMemory fm(resource_data, offt->size);
							rr.data = rr.load_function(fm, *rr.allocator);
							break;
						}
					}
				}
			} else {
				File *file = _data_filesystem.open(path.c_str(), FileOpenMode::READ);
				if (!file->is_open()) {
					logw(RESOURCE_LOADER, "Cannot load resource: " RESOURCE_ID_FMT ". Falling back...", res_id._id);

					StringId64 fallback_name;
					fallback_name = hash_map::get(_fallback, rr.type, fallback_name);
					CE_ENSURE(fallback_name._id != 0);

					res_id = resource_id(rr.type, fallback_name);
					destination_path(path, res_id);