//----------------------------------------------------------------------------- // Copyright (c) 2013 GarageGames, LLC // // Permission is hereby granted, free of charge, to any person obtaining a copy // of this software and associated documentation files (the "Software"), to // deal in the Software without restriction, including without limitation the // rights to use, copy, modify, merge, publish, distribute, sublicense, and/or // sell copies of the Software, and to permit persons to whom the Software is // furnished to do so, subject to the following conditions: // // The above copyright notice and this permission notice shall be included in // all copies or substantial portions of the Software. // // THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS OR // IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF MERCHANTABILITY, // FITNESS FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT. IN NO EVENT SHALL THE // AUTHORS OR COPYRIGHT HOLDERS BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER // LIABILITY, WHETHER IN AN ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING // FROM, OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS // IN THE SOFTWARE. //----------------------------------------------------------------------------- #include "moduleManager.h" #ifndef _MODULE_MERGE_DEFINITION_H #include "moduleMergeDefinition.h" #endif #ifndef _TAML_MODULE_ID_UPDATE_VISITOR_H_ #include "tamlModuleIdUpdateVisitor.h" #endif #ifndef _MODULE_CALLBACKS_H_ #include "moduleCallbacks.h" #endif #ifndef _CONSOLETYPES_H_ #include "console/consoleTypes.h" #endif #include "cinterface/cinterface.h" #ifndef _MODULE_DEFINITION_H #include "module/moduleDefinition.h" #endif #ifndef _STRINGFUNCTIONS_H_ #include "core/strings/stringFunctions.h" #endif // Script bindings. #include "moduleManager_ScriptBinding.h" //----------------------------------------------------------------------------- IMPLEMENT_CONOBJECT( ModuleManager ); //----------------------------------------------------------------------------- ModuleManager ModuleDatabase; //----------------------------------------------------------------------------- S32 QSORT_CALLBACK moduleDefinitionVersionIdSort( const void* a, const void* b ) { // Fetch module definitions. ModuleDefinition* pDefinition1 = *(ModuleDefinition**)a; ModuleDefinition* pDefinition2 = *(ModuleDefinition**)b; // Fetch version Ids. const U32 versionId1 = pDefinition1->getVersionId(); const U32 versionId2 = pDefinition2->getVersionId(); // We sort higher version Id first. return versionId1 > versionId2 ? -1 : versionId1 < versionId2 ? 1 : 0; } S32 QSORT_CALLBACK moduleDependencySort(const void* a, const void* b) { // Fetch module definitions. ModuleDefinition* pDefinition1 = *(ModuleDefinition * *)a; ModuleDefinition* pDefinition2 = *(ModuleDefinition * *)b; // Fetch version Ids. ModuleDefinition::typeModuleDependencyVector moduleDependencies = pDefinition1->getDependencies(); bool foundDependant = false; for (ModuleDefinition::typeModuleDependencyVector::const_iterator dependencyItr = moduleDependencies.begin(); dependencyItr != moduleDependencies.end(); ++dependencyItr) { if (String::compare(dependencyItr->mModuleId, pDefinition2->getModuleId()) && (dependencyItr->mVersionId == pDefinition2->getVersionId())) foundDependant = true; } return foundDependant ? 1 : -1; } //----------------------------------------------------------------------------- ModuleManager::ModuleManager() : mEnforceDependencies(true), mEchoInfo(false), mDatabaseLocks( 0 ), mIgnoreLoadedGroups(false) { // Set module extension. dStrcpy( mModuleExtension, MODULE_MANAGER_MODULE_DEFINITION_EXTENSION, 256 ); } //----------------------------------------------------------------------------- bool ModuleManager::onAdd() { if( !Parent::onAdd() ) return false; // Register listeners. mNotificationListeners.registerObject(); return true; } //----------------------------------------------------------------------------- void ModuleManager::onRemove() { // Clear database. clearDatabase(); // Unregister object. mNotificationListeners.unregisterObject(); // Call parent. Parent::onRemove(); } //----------------------------------------------------------------------------- void ModuleManager::initPersistFields() { // Call parent. Parent::initPersistFields(); addField( "EnforceDependencies", TypeBool, Offset(mEnforceDependencies, ModuleManager), "Whether the module manager enforces any dependencies on module definitions it discovers or not." ); addField( "EchoInfo", TypeBool, Offset(mEchoInfo, ModuleManager), "Whether the module manager echos extra information to the console or not." ); } //----------------------------------------------------------------------------- void ModuleManager::onDeleteNotify( SimObject *object ) { // Cast to a module definition. ModuleDefinition* pModuleDefinition = dynamic_cast( object ); // Ignore if not appropriate. if ( pModuleDefinition == NULL ) return; // Warn. Con::warnf( "Module Manager::onDeleteNotify() - Notified of a module definition deletion for module Id '%s' of version Id '%d' however this should not happen and can cause module database corruption.", pModuleDefinition->getModuleId(), pModuleDefinition->getVersionId() ); } //----------------------------------------------------------------------------- bool ModuleManager::setModuleExtension( const char* pExtension ) { // Sanity! AssertFatal( pExtension != NULL, "Cannot set module extension with NULL extension." ); // Did we find an extension period? if ( *pExtension == '.' ) { // Yes, so warn. Con::warnf("Module Manager: Failed to set extension as supplied extension contains an initial period: '%s'.", pExtension ); return false; } // Is the extension too large? if ( dStrlen( pExtension ) > sizeof( mModuleExtension ) ) { // Yes, so warn. Con::warnf("Module Manager: Failed to set extension as supplied extension is too large: '%s'.", pExtension ); return false; } // Set module extension. dStrcpy( mModuleExtension, pExtension, 256 ); return true; } //----------------------------------------------------------------------------- bool ModuleManager::scanModules( const char* pPath, const bool rootOnly ) { // Lock database. LockDatabase( this ); // Sanity! AssertFatal( pPath != NULL, "Cannot scan module with NULL path." ); String relBasePath = Platform::makeRelativePathName(pPath, NULL); // Info. if ( mEchoInfo ) { Con::printSeparator(); Con::printf("Module Manager: Started scanning '%s'...", relBasePath.c_str()); } String pattern = "*."; pattern += mModuleExtension; Torque::Path scanPath = Torque::FS::GetCwd(); scanPath.setPath(relBasePath); Vector fileList; S32 numModules = Torque::FS::FindByPattern(scanPath, pattern, !rootOnly, fileList, true); for (S32 i = 0; i < numModules; ++i) { Torque::Path modulePath = fileList[i]; registerModule(modulePath.getPath(), modulePath.getFullFileName()); } // Info. if ( mEchoInfo ) { Con::printf("Module Manager: Finished scanning '%s'.", relBasePath.c_str()); } return true; } //----------------------------------------------------------------------------- bool ModuleManager::loadModuleGroup( const char* pModuleGroup ) { // Lock database. LockDatabase( this ); // Sanity! AssertFatal( pModuleGroup != NULL, "Cannot load module group with NULL group name." ); typeModuleLoadEntryVector moduleResolvingQueue; typeModuleLoadEntryVector moduleReadyQueue; // Fetch module group. StringTableEntry moduleGroup = StringTable->insert( pModuleGroup ); // Info. if ( mEchoInfo ) { Con::printSeparator(); Con::printf( "Module Manager: Loading group '%s':" ,moduleGroup ); } // Is the module group already loaded? if ( findGroupLoaded( moduleGroup ) != NULL ) { // Yes, so warn. Con::warnf( "Module Manager: Cannot load group '%s' as it is already loaded.", moduleGroup ); return false; } // Find module group. typeGroupModuleHash::iterator moduleGroupItr = mGroupModules.find( moduleGroup ); // Did we find the module group? if ( moduleGroupItr == mGroupModules.end() ) { // No, so info. if ( mEchoInfo ) { Con::printf( "Module Manager: No modules found for module group '%s'.", moduleGroup ); } return true; } // Yes, so fetch the module Ids. typeModuleIdVector* pModuleIds = moduleGroupItr->value; // Iterate module groups. for( typeModuleIdVector::iterator moduleIdItr = pModuleIds->begin(); moduleIdItr != pModuleIds->end(); ++moduleIdItr ) { // Fetch module Id. StringTableEntry moduleId = *moduleIdItr; // Finish if we could not resolve the dependencies for module Id (of any version Id). if ( !resolveModuleDependencies( moduleId, 0, moduleGroup, false, moduleResolvingQueue, moduleReadyQueue ) ) return false; } // Check the modules we want to load to ensure that we do not have incompatible modules loaded already. for ( typeModuleLoadEntryVector::iterator moduleReadyItr = moduleReadyQueue.begin(); moduleReadyItr != moduleReadyQueue.end(); ++moduleReadyItr ) { // Fetch load ready module definition. ModuleDefinition* pLoadReadyModuleDefinition = moduleReadyItr->mpModuleDefinition;; // Fetch the module Id loaded entry. ModuleLoadEntry* pLoadedModuleEntry = findModuleLoaded( pLoadReadyModuleDefinition->getModuleId() ); // Did we find a loaded entry? if ( pLoadedModuleEntry != NULL ) { // Yes, so is it the one we need to load? if ( pLoadedModuleEntry->mpModuleDefinition != pLoadReadyModuleDefinition ) { // Yes, so warn. Con::warnf( "Module Manager: Cannot load module group '%s' as the module Id '%s' at version Id '%d' is required but the module Id is already loaded but at version Id '%d'.", moduleGroup, pLoadReadyModuleDefinition->getModuleId(), pLoadReadyModuleDefinition->getVersionId(), pLoadedModuleEntry->mpModuleDefinition->getVersionId() ); return false; } } } // Info. if ( mEchoInfo ) { // Info. Con::printf( "Module Manager: Group '%s' and its dependencies is comprised of the following '%d' module(s):", moduleGroup, moduleReadyQueue.size() ); // Iterate the modules echoing them. for ( typeModuleLoadEntryVector::iterator moduleReadyItr = moduleReadyQueue.begin(); moduleReadyItr != moduleReadyQueue.end(); ++moduleReadyItr ) { // Fetch the ready entry. ModuleDefinition* pModuleDefinition = moduleReadyItr->mpModuleDefinition; // Info. Con::printf( "> module Id '%s' at version Id '%d':", pModuleDefinition->getModuleId(), pModuleDefinition->getVersionId() ); } } // Add module group. mGroupsLoaded.push_back( moduleGroup ); // Reset modules loaded count. U32 modulesLoadedCount = 0; // Iterate the modules, executing their script files and call their create function. for ( typeModuleLoadEntryVector::iterator moduleReadyItr = moduleReadyQueue.begin(); moduleReadyItr != moduleReadyQueue.end(); ++moduleReadyItr ) { // Fetch the ready entry. ModuleLoadEntry* pReadyEntry = moduleReadyItr; // Fetch load ready module definition. ModuleDefinition* pLoadReadyModuleDefinition = pReadyEntry->mpModuleDefinition; // Fetch any loaded entry for the module Id. ModuleLoadEntry* pLoadedEntry = findModuleLoaded( pLoadReadyModuleDefinition->getModuleId() ); // Is the module already loaded. if ( pLoadedEntry != NULL ) { // Yes, so increase load count. pLoadedEntry->mpModuleDefinition->increaseLoadCount(); // Skip. continue; } // No, so info. if ( mEchoInfo ) { Con::printSeparator(); Con::printf( "Module Manager: Loading group '%s' : module Id '%s' at version Id '%d' in group '%s' using the script file '%s'.", moduleGroup, pLoadReadyModuleDefinition->getModuleId(), pLoadReadyModuleDefinition->getVersionId(), pLoadReadyModuleDefinition->getModuleGroup(), pLoadReadyModuleDefinition->getModuleScriptFilePath() ); } // Is the module deprecated? if ( pLoadReadyModuleDefinition->getDeprecated() ) { // Yes, so warn. Con::warnf( "Module Manager: Caution: module Id '%s' at version Id '%d' in group '%s' is deprecated. You should use a newer version!", pLoadReadyModuleDefinition->getModuleId(), pLoadReadyModuleDefinition->getVersionId(), pLoadReadyModuleDefinition->getModuleGroup() ); } // Add the path expando for module. Con::addPathExpando( pLoadReadyModuleDefinition->getModuleId(), pLoadReadyModuleDefinition->getModulePath() ); // Create a scope set. SimSet* pScopeSet = new SimSet; pScopeSet->registerObject( pLoadReadyModuleDefinition->getModuleId() ); pReadyEntry->mpModuleDefinition->mScopeSet = pScopeSet->getId(); // Increase load count. pReadyEntry->mpModuleDefinition->increaseLoadCount(); // Queue module loaded. mModulesLoaded.push_back( *pReadyEntry ); // Bump modules loaded count. modulesLoadedCount++; // Raise notifications. raiseModulePreLoadNotifications( pLoadReadyModuleDefinition ); // Do we have a script file-path specified? if ( pLoadReadyModuleDefinition->getModuleScriptFilePath() != StringTable->EmptyString() ) { // Yes, so execute the script file. ConsoleValue cValue = Con::executef("exec", pLoadReadyModuleDefinition->getModuleScriptFilePath()); const bool scriptFileExecuted = cValue.getBool(); // Did we execute the script file? if ( scriptFileExecuted ) { // Yes, so is the create method available? if ( pScopeSet->isMethod( pLoadReadyModuleDefinition->getCreateFunction() ) ) { // Yes, so call the create method. //But first, check if we're overriding objects, and if so, set our console var to make that happen while we exec our create function if (pLoadReadyModuleDefinition->getOverrideExistingObjects()) { String redefineBehaviorPrev = Con::getVariable("$Con::redefineBehavior"); Con::setVariable("$Con::redefineBehavior", "replaceExisting"); Con::executef(pScopeSet, pLoadReadyModuleDefinition->getCreateFunction()); //And now that we've executed, switch back to the prior behavior Con::setVariable("$Con::redefineBehavior", redefineBehaviorPrev.c_str()); } else { //Nothing to do, just run the create function Con::executef(pScopeSet, pLoadReadyModuleDefinition->getCreateFunction()); } } } else { // No, so warn. Con::errorf( "Module Manager: Cannot load module group '%s' as the module Id '%s' at version Id '%d' as it failed to have the script file '%s' loaded.", moduleGroup, pLoadReadyModuleDefinition->getModuleId(), pLoadReadyModuleDefinition->getVersionId(), pLoadReadyModuleDefinition->getModuleScriptFilePath() ); } } else { // Is the create method available? if (pScopeSet->isMethod(pLoadReadyModuleDefinition->getCreateFunction())) { // Yes, so call the create method. Con::executef(pScopeSet, pLoadReadyModuleDefinition->getCreateFunction()); } } // Raise notifications. raiseModulePostLoadNotifications( pLoadReadyModuleDefinition ); } // Info. if ( mEchoInfo ) { Con::printSeparator(); Con::printf( "Module Manager: Finish loading '%d' module(s) for group '%s'.", modulesLoadedCount, moduleGroup ); Con::printSeparator(); } return true; } //----------------------------------------------------------------------------- bool ModuleManager::unloadModuleGroup( const char* pModuleGroup ) { // Lock database. LockDatabase( this ); // Sanity! AssertFatal( pModuleGroup != NULL, "Cannot unload module group with NULL group name." ); typeModuleLoadEntryVector moduleResolvingQueue; typeModuleLoadEntryVector moduleReadyQueue; // Fetch module group. StringTableEntry moduleGroup = StringTable->insert( pModuleGroup ); // Info. if ( mEchoInfo ) { Con::printSeparator(); Con::printf( "Module Manager: Unloading group '%s':" , moduleGroup ); } // Find the group loaded iterator. typeGroupVector::iterator groupLoadedItr = findGroupLoaded( moduleGroup ); // Is the module group already unloaded? if ( groupLoadedItr == NULL ) { // No, so warn. Con::warnf( "Module Manager: Cannot unload group '%s' as it is not loaded.", moduleGroup ); return false; } // Find module group. typeGroupModuleHash::iterator moduleGroupItr = mGroupModules.find( moduleGroup ); // Did we find the module group? if ( moduleGroupItr == mGroupModules.end() ) { // No, so info. if ( mEchoInfo ) { Con::printf( "Module Manager: No modules found for module group '%s'.", moduleGroup ); return true; } } // Yes, so fetch the module Ids. typeModuleIdVector* pModuleIds = moduleGroupItr->value; // Iterate module groups. for( typeModuleIdVector::iterator moduleIdItr = pModuleIds->begin(); moduleIdItr != pModuleIds->end(); ++moduleIdItr ) { // Fetch module Id. StringTableEntry moduleId = *moduleIdItr; // Finish if we could not resolve the dependencies for module Id (of any version Id). if ( !resolveModuleDependencies( moduleId, 0, moduleGroup, false, moduleResolvingQueue, moduleReadyQueue ) ) return false; } // Check the modules we want to load to ensure that we do not have incompatible modules loaded already. for ( typeModuleLoadEntryVector::iterator moduleReadyItr = moduleReadyQueue.begin(); moduleReadyItr != moduleReadyQueue.end(); ++moduleReadyItr ) { // Fetch load ready module definition. ModuleDefinition* pLoadReadyModuleDefinition = moduleReadyItr->mpModuleDefinition;; // Fetch the module Id loaded entry. ModuleLoadEntry* pLoadedModuleEntry = findModuleLoaded( pLoadReadyModuleDefinition->getModuleId() ); // Did we find a loaded entry? if ( pLoadedModuleEntry != NULL ) { // Yes, so is it the one we need to load? if ( pLoadedModuleEntry->mpModuleDefinition != pLoadReadyModuleDefinition ) { // Yes, so warn. Con::warnf( "Module Manager: Cannot unload module group '%s' as the module Id '%s' at version Id '%d' is required but the module Id is loaded but at version Id '%d'.", moduleGroup, pLoadReadyModuleDefinition->getModuleId(), pLoadReadyModuleDefinition->getVersionId(), pLoadedModuleEntry->mpModuleDefinition->getVersionId() ); return false; } } } // Remove module group. mGroupsLoaded.erase_fast( groupLoadedItr ); // Reset modules unloaded count. U32 modulesUnloadedCount = 0; // Iterate the modules in reverse order calling their destroy function. for ( typeModuleLoadEntryVector::iterator moduleReadyItr = moduleReadyQueue.end()-1; moduleReadyItr >= moduleReadyQueue.begin(); --moduleReadyItr ) { // Fetch the ready entry. ModuleLoadEntry* pReadyEntry = moduleReadyItr; // Fetch load ready module definition. ModuleDefinition* pLoadReadyModuleDefinition = pReadyEntry->mpModuleDefinition;; // Fetch any loaded entry for the module Id. ModuleLoadEntry* pLoadedEntry = findModuleLoaded( pLoadReadyModuleDefinition->getModuleId() ); // Is the module loaded. if ( pLoadedEntry == NULL ) { // No, so warn. if ( mEchoInfo ) { Con::printf( "Module Manager: Unloading group '%s' but could not unload module Id '%s' at version Id '%d'.", moduleGroup, pLoadReadyModuleDefinition->getModuleId(), pLoadReadyModuleDefinition->getVersionId()); } // Skip. continue; } // Reduce load count. pLoadedEntry->mpModuleDefinition->reduceLoadCount(); // Sanity! AssertFatal( pLoadedEntry->mpModuleDefinition->getLoadCount() >= 0, "ModuleManager::unloadModuleGroup() - Encountered an invalid load count." ); // Do we need to unload? if ( pLoadedEntry->mpModuleDefinition->getLoadCount() == 0 ) { // Yes, so info. if ( mEchoInfo ) { Con::printSeparator(); Con::printf( "Module Manager: Unload group '%s' with module Id '%s' at version Id '%d' in group '%s'.", moduleGroup, pLoadReadyModuleDefinition->getModuleId(), pLoadReadyModuleDefinition->getVersionId(), pLoadReadyModuleDefinition->getModuleGroup() ); } // Raise notifications. raiseModulePreUnloadNotifications( pLoadReadyModuleDefinition ); // Fetch the module Id loaded entry. typeModuleLoadEntryVector::iterator moduleLoadedItr = findModuleLoaded( pLoadReadyModuleDefinition->getModuleId() ); // Sanity! AssertFatal( moduleLoadedItr != NULL, "ModuleManager::unloadModuleGroup() - Cannot find module to unload it." ); // Dequeue module loaded. mModulesLoaded.erase_fast( moduleLoadedItr ); // Fetch scope set. SimSet* pScopeSet = dynamic_cast(Sim::findObject(pLoadReadyModuleDefinition->mScopeSet)); // Is the destroy method available? if ( pScopeSet->isMethod( pLoadReadyModuleDefinition->getDestroyFunction() ) ) { // Yes, so call the destroy method. Con::executef( pScopeSet, pLoadReadyModuleDefinition->getDestroyFunction() ); } // Remove scope set. pScopeSet->deleteAllObjects(); pScopeSet->unregisterObject(); pLoadReadyModuleDefinition->mScopeSet = 0; // Remove path expando for module. Con::removePathExpando( pLoadReadyModuleDefinition->getModuleId() ); // Bump modules unloaded count. modulesUnloadedCount++; // Raise notifications. raiseModulePostUnloadNotifications( pLoadReadyModuleDefinition ); } } // Info. if ( mEchoInfo ) { Con::printSeparator(); Con::printf( "Module Manager: Finish unloading '%d' module(s) for group '%s'.", modulesUnloadedCount, moduleGroup ); Con::printSeparator(); } return true; } //----------------------------------------------------------------------------- bool ModuleManager::loadModuleExplicit( const char* pModuleId, const U32 versionId ) { // Lock database. LockDatabase( this ); // Sanity! AssertFatal( pModuleId != NULL, "Cannot load explicit module Id with NULL module Id." ); typeModuleLoadEntryVector moduleResolvingQueue; typeModuleLoadEntryVector moduleReadyQueue; // Fetch module Id. StringTableEntry moduleId = StringTable->insert( pModuleId ); // Fetch modules definitions. ModuleDefinitionEntry* pDefinitions = findModuleId( moduleId ); // Did we find the module Id? if ( pDefinitions == NULL ) { // No, so warn. Con::warnf( "Module Manager: Cannot load explicit module Id '%s' as it does not exist.", moduleId ); return false; } // Fetch module group. StringTableEntry moduleGroup = pDefinitions->mModuleGroup; // Info. if ( mEchoInfo ) { Con::printSeparator(); Con::printf( "Module Manager: Loading explicit module Id '%s' at version Id '%d':", moduleId, versionId ); } // Finish if we could not resolve the dependencies for module Id (of any version Id). if ( !resolveModuleDependencies( moduleId, versionId, moduleGroup, false, moduleResolvingQueue, moduleReadyQueue ) ) return false; // Check the modules we want to load to ensure that we do not have incompatible modules loaded already. for ( typeModuleLoadEntryVector::iterator moduleReadyItr = moduleReadyQueue.begin(); moduleReadyItr != moduleReadyQueue.end(); ++moduleReadyItr ) { // Fetch load ready module definition. ModuleDefinition* pLoadReadyModuleDefinition = moduleReadyItr->mpModuleDefinition; // Fetch the module Id loaded entry. ModuleLoadEntry* pLoadedModuleEntry = findModuleLoaded( pLoadReadyModuleDefinition->getModuleId() ); // Did we find a loaded entry? if ( pLoadedModuleEntry != NULL ) { // Yes, so is it the one we need to load? if ( pLoadedModuleEntry->mpModuleDefinition != pLoadReadyModuleDefinition ) { // Yes, so warn. Con::warnf( "Module Manager: Cannot load explicit module Id '%s' at version Id '%d' as the module Id is already loaded but at version Id '%d'.", pLoadReadyModuleDefinition->getModuleId(), pLoadReadyModuleDefinition->getVersionId(), pLoadedModuleEntry->mpModuleDefinition->getVersionId() ); return false; } } } // Info. if ( mEchoInfo ) { // Info. Con::printf( "Module Manager: Explicit load of module Id '%s' at version Id '%d' and its dependencies is comprised of the following '%d' module(s):", moduleId, versionId, moduleReadyQueue.size() ); // Iterate the modules echoing them. for ( typeModuleLoadEntryVector::iterator moduleReadyItr = moduleReadyQueue.begin(); moduleReadyItr != moduleReadyQueue.end(); ++moduleReadyItr ) { // Fetch the ready entry. ModuleDefinition* pModuleDefinition = moduleReadyItr->mpModuleDefinition; // Info. Con::printf( "> module Id '%s' at version Id '%d'", pModuleDefinition->getModuleId(), pModuleDefinition->getVersionId() ); } } // Reset modules loaded count. U32 modulesLoadedCount = 0; // Iterate the modules, executing their script files and call their create function. for ( typeModuleLoadEntryVector::iterator moduleReadyItr = moduleReadyQueue.begin(); moduleReadyItr != moduleReadyQueue.end(); ++moduleReadyItr ) { // Fetch the ready entry. ModuleLoadEntry* pReadyEntry = moduleReadyItr; // Fetch load ready module definition. ModuleDefinition* pLoadReadyModuleDefinition = pReadyEntry->mpModuleDefinition; // Fetch any loaded entry for the module Id. ModuleLoadEntry* pLoadedEntry = findModuleLoaded( pLoadReadyModuleDefinition->getModuleId() ); // Is the module already loaded. if ( pLoadedEntry != NULL ) { // Yes, so increase load count. pLoadedEntry->mpModuleDefinition->increaseLoadCount(); // Skip. continue; } // No, so info. if ( mEchoInfo ) { Con::printSeparator(); Con::printf( "Module Manager: Loading explicit module Id '%s' at version Id '%d' using the script file '%s'.", pLoadReadyModuleDefinition->getModuleId(), pLoadReadyModuleDefinition->getVersionId(), pLoadReadyModuleDefinition->getModuleScriptFilePath() ); } // Is the module deprecated? if ( pLoadReadyModuleDefinition->getDeprecated() ) { // Yes, so warn. Con::warnf( "Module Manager: Caution: module Id '%s' at version Id '%d' is deprecated, You should use a newer version!", pLoadReadyModuleDefinition->getModuleId(), pLoadReadyModuleDefinition->getVersionId() ); } // Add the path expando for module. Con::addPathExpando( pLoadReadyModuleDefinition->getModuleId(), pLoadReadyModuleDefinition->getModulePath() ); // Create a scope set. SimSet* pScopeSet = new SimSet; pScopeSet->registerObject( pLoadReadyModuleDefinition->getModuleId() ); pReadyEntry->mpModuleDefinition->mScopeSet = pScopeSet->getId(); // Increase load count. pReadyEntry->mpModuleDefinition->increaseLoadCount(); // Queue module loaded. mModulesLoaded.push_back( *pReadyEntry ); // Bump modules loaded count. modulesLoadedCount++; // Raise notifications. raiseModulePreLoadNotifications( pLoadReadyModuleDefinition ); // Do we have a script file-path specified? if ( pLoadReadyModuleDefinition->getModuleScriptFilePath() != StringTable->EmptyString() ) { // Yes, so execute the script file. ConsoleValue cValue = Con::executef("exec", pLoadReadyModuleDefinition->getModuleScriptFilePath()); const bool scriptFileExecuted = cValue.getBool(); // Did we execute the script file? if ( !scriptFileExecuted ) { // No, so warn. Con::errorf( "Module Manager: Cannot load explicit module Id '%s' at version Id '%d' as it failed to have the script file '%s' loaded.", pLoadReadyModuleDefinition->getModuleId(), pLoadReadyModuleDefinition->getVersionId(), pLoadReadyModuleDefinition->getModuleScriptFilePath() ); } } // Is the create method available? if (pScopeSet->isMethod(pLoadReadyModuleDefinition->getCreateFunction())) { // Yes, so call the create method. Con::executef(pScopeSet, pLoadReadyModuleDefinition->getCreateFunction()); } // Raise notifications. raiseModulePostLoadNotifications( pLoadReadyModuleDefinition ); } // Info. if ( mEchoInfo ) { Con::printSeparator(); Con::printf( "Module Manager: Finish loading '%d' explicit module(s).", modulesLoadedCount ); Con::printSeparator(); } return true; } //----------------------------------------------------------------------------- bool ModuleManager::unloadModuleExplicit( const char* pModuleId ) { // Lock database. LockDatabase( this ); // Sanity! AssertFatal( pModuleId != NULL, "Cannot unload explicit module Id with NULL module Id." ); typeModuleLoadEntryVector moduleResolvingQueue; typeModuleLoadEntryVector moduleReadyQueue; // Fetch module Id. StringTableEntry moduleId = StringTable->insert( pModuleId ); // Fetch modules definitions. ModuleDefinitionEntry* pDefinitions = findModuleId( moduleId ); // Did we find the module Id? if ( pDefinitions == NULL ) { // No, so warn. Con::warnf( "Module Manager: Cannot unload explicit module Id '%s' as it does not exist.", moduleId ); return false; } // Find if the module is actually loaded. ModuleDefinition* pLoadedModule = findLoadedModule( moduleId ); // Is the module loaded? if ( pLoadedModule == NULL ) { // No, so warn. Con::warnf( "Module Manager: Cannot unload explicit module Id '%s' as it is not loaded.", moduleId ); return false; } // Fetch module group. StringTableEntry moduleGroup = pDefinitions->mModuleGroup; // Info. if ( mEchoInfo ) { Con::printSeparator(); Con::printf( "Module Manager: Unloading explicit module Id '%s':" , moduleId ); } // Finish if we could not resolve the dependencies for module Id (of any version Id). if ( !resolveModuleDependencies( moduleId, pLoadedModule->getVersionId(), moduleGroup, false, moduleResolvingQueue, moduleReadyQueue ) ) return false; // Check the modules we want to unload to ensure that we do not have incompatible modules loaded already. for ( typeModuleLoadEntryVector::iterator moduleReadyItr = moduleReadyQueue.begin(); moduleReadyItr != moduleReadyQueue.end(); ++moduleReadyItr ) { // Fetch load ready module definition. ModuleDefinition* pLoadReadyModuleDefinition = moduleReadyItr->mpModuleDefinition;; // Fetch the module Id loaded entry. ModuleLoadEntry* pLoadedModuleEntry = findModuleLoaded( pLoadReadyModuleDefinition->getModuleId() ); // Did we find a loaded entry? if ( pLoadedModuleEntry != NULL ) { // Yes, so is it the one we need to load? if ( pLoadedModuleEntry->mpModuleDefinition != pLoadReadyModuleDefinition ) { // Yes, so warn. Con::warnf( "Module Manager: Cannot unload explicit module Id '%s' at version Id '%d' as the module Id is loaded but at version Id '%d'.", pLoadReadyModuleDefinition->getModuleId(), pLoadReadyModuleDefinition->getVersionId(), pLoadedModuleEntry->mpModuleDefinition->getVersionId() ); return false; } } } // Reset modules unloaded count. U32 modulesUnloadedCount = 0; // Iterate the modules in reverse order calling their destroy function. for ( typeModuleLoadEntryVector::iterator moduleReadyItr = moduleReadyQueue.end()-1; moduleReadyItr >= moduleReadyQueue.begin(); --moduleReadyItr ) { // Fetch the ready entry. ModuleLoadEntry* pReadyEntry = moduleReadyItr; // Fetch load ready module definition. ModuleDefinition* pLoadReadyModuleDefinition = pReadyEntry->mpModuleDefinition;; // Fetch any loaded entry for the module Id. ModuleLoadEntry* pLoadedEntry = findModuleLoaded( pLoadReadyModuleDefinition->getModuleId() ); // Is the module loaded. if ( pLoadedEntry == NULL ) { // No, so warn. if ( mEchoInfo ) { Con::printf( "Module Manager: Unloading explicit module Id '%s' at version Id '%d' but ignoring as it is not loaded.", pLoadReadyModuleDefinition->getModuleId(), pLoadReadyModuleDefinition->getVersionId() ); } // Skip. continue; } // Reduce load count. pLoadedEntry->mpModuleDefinition->reduceLoadCount(); // Sanity! AssertFatal( pLoadedEntry->mpModuleDefinition->getLoadCount() >= 0, "ModuleManager::unloadModuleGroup() - Encountered an invalid load count." ); // Do we need to unload? if ( pLoadedEntry->mpModuleDefinition->getLoadCount() == 0 ) { // Yes, so info. if ( mEchoInfo ) { Con::printSeparator(); Con::printf( "Module Manager: Unload explicit module Id '%s' at version Id '%d'.", pLoadReadyModuleDefinition->getModuleId(), pLoadReadyModuleDefinition->getVersionId() ); } // Raise notifications. raiseModulePreUnloadNotifications( pLoadReadyModuleDefinition ); // Fetch the module Id loaded entry. typeModuleLoadEntryVector::iterator moduleLoadedItr = findModuleLoaded( pLoadReadyModuleDefinition->getModuleId() ); // Sanity! AssertFatal( moduleLoadedItr != NULL, "ModuleManager::unloadModuleExplicit() - Cannot find module to unload it." ); // Dequeue module loaded. mModulesLoaded.erase_fast( moduleLoadedItr ); // Fetch scope set. SimSet* pScopeSet = dynamic_cast(Sim::findObject(pLoadReadyModuleDefinition->mScopeSet)); // Is the destroy method available? if ( pScopeSet->isMethod( pLoadReadyModuleDefinition->getDestroyFunction() ) ) { // Yes, so call the destroy method. Con::executef( pScopeSet, pLoadReadyModuleDefinition->getDestroyFunction() ); } // Remove scope set. pScopeSet->deleteAllObjects(); pScopeSet->unregisterObject(); pLoadReadyModuleDefinition->mScopeSet = 0; // Remove path expando for module. Con::removePathExpando( pLoadReadyModuleDefinition->getModuleId() ); // Bump modules unloaded count. modulesUnloadedCount++; // Raise notifications. raiseModulePostUnloadNotifications( pLoadReadyModuleDefinition ); } } // Info. if ( mEchoInfo ) { Con::printSeparator(); Con::printf( "Module Manager: Finish unloading '%d' explicit module(s).", modulesUnloadedCount ); Con::printSeparator(); } return true; } //----------------------------------------------------------------------------- ModuleDefinition* ModuleManager::findModule( const char* pModuleId, const U32 versionId ) { // Sanity! AssertFatal( pModuleId != NULL, "Cannot find module with NULL module Id." ); // Find module definition. ModuleDefinitionEntry::iterator moduleItr = findModuleDefinition( StringTable->insert( pModuleId ), versionId ); // Finish if module was not found. if ( moduleItr == NULL ) return NULL; return *moduleItr; } //----------------------------------------------------------------------------- ModuleDefinition* ModuleManager::findModuleByFilePath(StringTableEntry filePath) { // Sanity! AssertFatal(filePath != StringTable->EmptyString(), "Cannot find module with an empty filePath."); String desiredPath = filePath; StringTableEntry coreModuleId = StringTable->insert("CoreModule"); for (typeModuleIdDatabaseHash::iterator moduleIdItr = mModuleIdDatabase.begin(); moduleIdItr != mModuleIdDatabase.end(); ++moduleIdItr) { // Fetch module definition entry. ModuleDefinitionEntry* pModuleDefinitionEntry = moduleIdItr->value; for (typeModuleDefinitionVector::iterator moduleDefinitionItr = pModuleDefinitionEntry->begin(); moduleDefinitionItr != pModuleDefinitionEntry->end(); ++moduleDefinitionItr) { // Fetch module definition. ModuleDefinition* pModuleDefinition = *moduleDefinitionItr; Torque::Path modulePath = pModuleDefinition->getModulePath(); StringTableEntry asdasd = StringTable->insert(modulePath.getFullPath()); //We don't deal with CoreModule or ToolsModule having assets for now if (desiredPath.startsWith(asdasd) && pModuleDefinition->mModuleId != coreModuleId) { return pModuleDefinition; } } } return nullptr; } //----------------------------------------------------------------------------- ModuleDefinition* ModuleManager::findLoadedModule( const char* pModuleId ) { // Sanity! AssertFatal( pModuleId != NULL, "Cannot find module with NULL module Id." ); // Fetch module Id. StringTableEntry moduleId = StringTable->insert( pModuleId ); // Iterate loaded modules. for ( typeModuleLoadEntryVector::iterator loadedModuleItr = mModulesLoaded.begin(); loadedModuleItr != mModulesLoaded.end(); ++loadedModuleItr ) { // Skip if not the module. if ( loadedModuleItr->mpModuleDefinition->getModuleId() != moduleId ) continue; return loadedModuleItr->mpModuleDefinition; } return NULL; } //----------------------------------------------------------------------------- void ModuleManager::findModules( const bool loadedOnly, typeConstModuleDefinitionVector& moduleDefinitions ) { // Iterate module Ids. for( typeModuleIdDatabaseHash::iterator moduleIdItr = mModuleIdDatabase.begin(); moduleIdItr != mModuleIdDatabase.end(); ++moduleIdItr ) { // Fetch module definition entry. ModuleDefinitionEntry* pModuleDefinitionEntry = moduleIdItr->value; // Iterate module definitions. for ( typeModuleDefinitionVector::iterator moduleDefinitionItr = pModuleDefinitionEntry->begin(); moduleDefinitionItr != pModuleDefinitionEntry->end(); ++moduleDefinitionItr ) { // Fetch module definition. ModuleDefinition* pModuleDefinition = *moduleDefinitionItr; // Are we searching for loaded modules only? if ( loadedOnly ) { // Yes, so skip if the module is not loaded. if ( pModuleDefinition->getLoadCount() == 0 ) continue; // Use module definition. moduleDefinitions.push_back( pModuleDefinition ); // Finish iterating module definitions as only a single module in this entry can be loaded concurrently. break; } // use module definition. moduleDefinitions.push_back( pModuleDefinition ); } } dQsort(moduleDefinitions.address(), moduleDefinitions.size(), sizeof(ModuleDefinition*), moduleDependencySort); } //----------------------------------------------------------------------------- void ModuleManager::findModuleTypes( const char* pModuleType, const bool loadedOnly, typeConstModuleDefinitionVector& moduleDefinitions ) { // Fetch module type. StringTableEntry moduleType = StringTable->insert( pModuleType ); // Iterate module Ids. for( typeModuleIdDatabaseHash::iterator moduleIdItr = mModuleIdDatabase.begin(); moduleIdItr != mModuleIdDatabase.end(); ++moduleIdItr ) { // Fetch module definition entry. ModuleDefinitionEntry* pModuleDefinitionEntry = moduleIdItr->value; // Skip if note the module type we're searching for. if ( pModuleDefinitionEntry->mModuleType != moduleType ) continue; // Iterate module definitions. for ( typeModuleDefinitionVector::iterator moduleDefinitionItr = pModuleDefinitionEntry->begin(); moduleDefinitionItr != pModuleDefinitionEntry->end(); ++moduleDefinitionItr ) { // Fetch module definition. ModuleDefinition* pModuleDefinition = *moduleDefinitionItr; // Are we searching for loaded modules only? if ( loadedOnly ) { // Yes, so skip if the module is not loaded. if ( pModuleDefinition->getLoadCount() == 0 ) continue; // Use module definition. moduleDefinitions.push_back( pModuleDefinition ); // Finish iterating module definitions as only a single module in this entry can be loaded concurrently. break; } // use module definition. moduleDefinitions.push_back( pModuleDefinition ); } } } //----------------------------------------------------------------------------- StringTableEntry ModuleManager::copyModule( ModuleDefinition* pSourceModuleDefinition, const char* pTargetModuleId, const char* pTargetPath, const bool useVersionPathing ) { // Sanity! AssertFatal( pSourceModuleDefinition != NULL, "Cannot copy module using a NULL source module definition." ); AssertFatal( pTargetModuleId != NULL, "Cannot copy module using a NULL target module Id." ); AssertFatal( pTargetPath != NULL, "Cannot copy module using a NULL target path." ); // Fetch the source module Id. StringTableEntry sourceModuleId = pSourceModuleDefinition->getModuleId(); // Is the source module definition registered with this module manager? if ( pSourceModuleDefinition->getModuleManager() != this ) { // No, so warn. Con::warnf("Module Manager: Cannot copy module Id '%s' as it is not registered with this module manager.", sourceModuleId ); return StringTable->EmptyString(); } // Fetch the target module Id. StringTableEntry targetModuleId = StringTable->insert( pTargetModuleId ); // Extend moduleId/VersionId pathing. char versionPathBuffer[1024]; // Are we using version pathing? if ( useVersionPathing ) { // Yes, so format it. dSprintf( versionPathBuffer, sizeof(versionPathBuffer), "%s/%s/%d", pTargetPath, targetModuleId, pSourceModuleDefinition->getVersionId() ); } else { // No, so a straight copy. dSprintf( versionPathBuffer, sizeof(versionPathBuffer), "%s", pTargetPath ); } // Expand the path. char targetPathBuffer[1024]; Con::expandPath( targetPathBuffer, sizeof(targetPathBuffer), versionPathBuffer ); pTargetPath = targetPathBuffer; // Info. if ( mEchoInfo ) { Con::printf( "Module Manager: Started copying module Id '%s' to target directory '%s'.", sourceModuleId, pTargetPath ); } // Is the target folder a directory? if ( !Platform::isDirectory( pTargetPath ) ) { // No, so we have to ensure that there is a trailing slash as that indicates a folder (not a file) when creating a path in the platform code. char createDirectoryBuffer[1024]; Con::expandPath( createDirectoryBuffer, sizeof(createDirectoryBuffer), pTargetPath, NULL, true ); // No, so can we create it? if ( !Platform::createPath( createDirectoryBuffer ) ) { // No, so warn. Con::warnf("Module Manager: Cannot copy module Id '%s' using target directory '%s' as directory was not found and could not be created.", sourceModuleId, pTargetPath ); return StringTable->EmptyString(); } } // Copy the source module to the target folder. if ( !dPathCopy( pSourceModuleDefinition->getModulePath(), pTargetPath, false ) ) { // Warn. Con::warnf("Module Manager: Cannot copy module Id '%s' using target directory '%s' as directory copy failed.", sourceModuleId, pTargetPath ); return StringTable->EmptyString(); } // Format the new source module definition file-path. char newModuleDefinitionSourceFileBuffer[1024]; dSprintf( newModuleDefinitionSourceFileBuffer, sizeof(newModuleDefinitionSourceFileBuffer), "%s/%s", pTargetPath, pSourceModuleDefinition->getModuleFile() ); // Finish if source/target module Ids are identical. if ( sourceModuleId == targetModuleId ) return StringTable->insert( newModuleDefinitionSourceFileBuffer ); // Format the new target module definition file-path. char newModuleDefinitionTargetFileBuffer[1024]; dSprintf( newModuleDefinitionTargetFileBuffer, sizeof(newModuleDefinitionTargetFileBuffer), "%s/%s.%s", pTargetPath, targetModuleId, MODULE_MANAGER_MODULE_DEFINITION_EXTENSION ); // Rename the module definition. if ( !dFileRename( newModuleDefinitionSourceFileBuffer, newModuleDefinitionTargetFileBuffer ) ) { // Warn. Con::warnf("Module Manager: Cannot copy module Id '%s' using target directory '%s' as renaming the module from '%s' to '%s' failed.", sourceModuleId, pTargetPath, newModuleDefinitionSourceFileBuffer, newModuleDefinitionTargetFileBuffer ); return StringTable->EmptyString(); } Vector directories; // Find directories. if ( !Platform::dumpDirectories( pTargetPath, directories, -1 ) ) { // Warn. Con::warnf("Module Manager: Cannot copy module Id '%s' using target directory '%s' as sub-folder scanning/renaming failed.", sourceModuleId, pTargetPath ); return StringTable->EmptyString(); } TamlModuleIdUpdateVisitor moduleIdUpdateVisitor; moduleIdUpdateVisitor.setModuleIdFrom( sourceModuleId ); moduleIdUpdateVisitor.setModuleIdTo( targetModuleId ); Vector files; const char* pExtension = (const char*)"Taml"; const U32 extensionLength = dStrlen(pExtension); // Iterate directories. for( Vector::iterator basePathItr = directories.begin(); basePathItr != directories.end(); ++basePathItr ) { // Fetch base path. StringTableEntry basePath = *basePathItr; // Find files. files.clear(); if ( !Platform::dumpPath( basePath, files, 0 ) ) { // Warn. Con::warnf("Module Manager: Cannot copy module Id '%s' using target directory '%s' as sub-folder scanning/renaming failed.", sourceModuleId, pTargetPath ); return StringTable->EmptyString(); } // Iterate files. for ( Vector::iterator fileItr = files.begin(); fileItr != files.end(); ++fileItr ) { // Fetch file info. Platform::FileInfo* pFileInfo = fileItr; // Fetch filename. const char* pFilename = pFileInfo->pFileName; // Find filename length. const U32 filenameLength = dStrlen( pFilename ); // Skip if extension is longer than filename. if ( extensionLength >= filenameLength ) continue; // Skip if extension not found. if ( dStricmp( pFilename + filenameLength - extensionLength, pExtension ) != 0 ) continue; char parseFileBuffer[1024]; dSprintf( parseFileBuffer, sizeof(parseFileBuffer), "%s/%s", pFileInfo->pFullPath, pFilename ); // Parse file. if ( !mTaml.parse( parseFileBuffer, moduleIdUpdateVisitor ) ) { // Warn. Con::warnf("Module Manager: Failed to parse file '%s' whilst copying module Id '%s' using target directory '%s'.", parseFileBuffer, sourceModuleId, pTargetPath ); return StringTable->EmptyString(); } } } // Info. if ( mEchoInfo ) { Con::printf( "Module Manager: Finished copying module Id '%s' to target directory '%s'.", sourceModuleId, pTargetPath ); } return StringTable->insert( newModuleDefinitionTargetFileBuffer ); } //----------------------------------------------------------------------------- bool ModuleManager::renameModule(ModuleDefinition* pSourceModuleDefinition, const char* pNewModuleName) { // Sanity! AssertFatal(pSourceModuleDefinition != NULL, "Cannot copy module using a NULL source module definition."); AssertFatal(pNewModuleName != NULL, "Cannot rename a module using a NULL module name."); // Fetch the source module Id. StringTableEntry sourceModuleId = pSourceModuleDefinition->getModuleId(); // Is the source module definition registered with this module manager? if (pSourceModuleDefinition->getModuleManager() != this) { // No, so warn. Con::warnf("Module Manager: Cannot rename module Id '%s' as it is not registered with this module manager.", sourceModuleId); return StringTable->EmptyString(); } TamlModuleIdUpdateVisitor moduleIdUpdateVisitor; moduleIdUpdateVisitor.setModuleIdFrom(sourceModuleId); moduleIdUpdateVisitor.setModuleIdTo(pNewModuleName); Vector files; const char* pExtension = (const char*)"Taml"; const U32 extensionLength = dStrlen(pExtension); Vector directories; StringTableEntry modulePath = pSourceModuleDefinition->getModulePath(); // Find directories. if (!Platform::dumpDirectories(modulePath, directories, -1)) { // Warn. Con::warnf("Module Manager: Cannot rename module Id '%s' in directory '%s' as sub-folder scanning/renaming failed.", sourceModuleId, modulePath); return false; } // Iterate directories. for (Vector::iterator basePathItr = directories.begin(); basePathItr != directories.end(); ++basePathItr) { // Fetch base path. StringTableEntry basePath = *basePathItr; // Find files. files.clear(); if (!Platform::dumpPath(basePath, files, 0)) { // Warn. Con::warnf("Module Manager: Cannot rename module Id '%s' in directory '%s' as sub-folder scanning/renaming failed.", sourceModuleId, modulePath); return false; } // Iterate files. for (Vector::iterator fileItr = files.begin(); fileItr != files.end(); ++fileItr) { // Fetch file info. Platform::FileInfo* pFileInfo = fileItr; // Fetch filename. const char* pFilename = pFileInfo->pFileName; // Find filename length. const U32 filenameLength = dStrlen(pFilename); // Skip if extension is longer than filename. if (extensionLength >= filenameLength) continue; // Skip if extension not found. if (dStricmp(pFilename + filenameLength - extensionLength, pExtension) != 0) continue; char parseFileBuffer[1024]; dSprintf(parseFileBuffer, sizeof(parseFileBuffer), "%s/%s", pFileInfo->pFullPath, pFilename); // Parse file. if (!mTaml.parse(parseFileBuffer, moduleIdUpdateVisitor)) { // Warn. Con::warnf("Module Manager: Failed to parse file '%s' whilst renaming module Id '%s' in directory '%s'.", parseFileBuffer, sourceModuleId, modulePath); return false; } } } // Info. if (mEchoInfo) { Con::printf("Module Manager: Finished renaming module Id '%s' to '%s'.", sourceModuleId, pNewModuleName); } return true; } //----------------------------------------------------------------------------- bool ModuleManager::synchronizeDependencies( ModuleDefinition* pRootModuleDefinition, const char* pTargetDependencyPath ) { // Sanity! AssertFatal( pRootModuleDefinition != NULL, "Cannot synchronize dependencies with NULL root module definition." ); AssertFatal( pTargetDependencyPath != NULL, "Cannot synchronize dependencies with NULL target dependency path." ); // Fetch the root module Id. StringTableEntry rootModuleId = pRootModuleDefinition->getModuleId(); // Is the root module definition registered with this module manager? if ( pRootModuleDefinition->getModuleManager() != this ) { // No, so warn. Con::warnf("Cannot synchronize dependencies for module Id '%s' as it is not registered with this module manager.", rootModuleId ); return false; } // Expand the path. char targetPathBuffer[1024]; Con::expandPath( targetPathBuffer, sizeof(targetPathBuffer), pTargetDependencyPath ); pTargetDependencyPath = targetPathBuffer; // Is the target dependency folder a directory? if ( !Platform::isDirectory( pTargetDependencyPath ) ) { // No, so we have to ensure that there is a trailing slash as that indicates a folder (not a file) when creating a path in the platform code. char createDirectoryBuffer[1024]; Con::expandPath( createDirectoryBuffer, sizeof(createDirectoryBuffer), pTargetDependencyPath, NULL, true ); // No, so can we create it? if ( !Platform::createPath( createDirectoryBuffer ) ) { // No, so warn. Con::warnf("Cannot synchronize dependencies for module Id '%s' using target directory '%s' as directory was not found and could not be created.", rootModuleId, pTargetDependencyPath ); return false; } } typeModuleLoadEntryVector resolvingQueue; typeModuleLoadEntryVector sourceModulesNeeded; // Could we resolve source dependencies? if ( !resolveModuleDependencies( rootModuleId, pRootModuleDefinition->getVersionId(), pRootModuleDefinition->getModuleGroup(), true, resolvingQueue, sourceModulesNeeded ) ) { // No, so warn. Con::warnf("Cannot synchronize dependencies for root module Id '%s' as its dependencies could not be resolved.", rootModuleId ); return false; } // Sanity! AssertFatal( sourceModulesNeeded.size() > 0, "Cannot synchronize dependencies as no modules were returned." ); // Remove the root module definition. sourceModulesNeeded.pop_back(); // Initialize the target module manager and scan the target folder for modules. ModuleManager targetModuleManager; targetModuleManager.mEnforceDependencies = true; targetModuleManager.mEchoInfo = false; targetModuleManager.scanModules( pTargetDependencyPath ); char targetFolderGenerateBuffer[1024]; // Iterate module definitions. for ( typeModuleLoadEntryVector::iterator sourceModuleItr = sourceModulesNeeded.begin(); sourceModuleItr != sourceModulesNeeded.end(); ++sourceModuleItr ) { // Fetch module definition. ModuleDefinition* pSourceModuleDefinition = sourceModuleItr->mpModuleDefinition; // Fetch the source module Id, StringTableEntry sourceModuleId = pSourceModuleDefinition->getModuleId(); // Fetch the source module version Id. const U32 sourceVersionId = pSourceModuleDefinition->getVersionId(); // Fetch the source module build Id. const U32 sourceBuildId = pSourceModuleDefinition->getBuildId(); // Fetch module definition entry for this module Id in the target. ModuleDefinitionEntry* pDefinitions = targetModuleManager.findModuleId( sourceModuleId ); // Is the module Id present in the target? if ( pDefinitions == NULL ) { // No, so format module Id folder path. dSprintf( targetFolderGenerateBuffer, sizeof(targetFolderGenerateBuffer), "%s/%s/", pTargetDependencyPath, sourceModuleId ); // Create module Id folder. if ( !Platform::createPath( targetFolderGenerateBuffer ) ) { // Warn. Con::warnf("Cannot synchronize dependencies for module Id '%s' as the target directory '%s' could not be created.", sourceModuleId, targetFolderGenerateBuffer ); return false; } } else { // Yes, so fetch the module definition for this module Id and version Id in the target. ModuleDefinitionEntry::iterator definitionItr = targetModuleManager.findModuleDefinition( sourceModuleId, sourceVersionId ); // Is the specific module definition present in the target? if ( definitionItr != NULL ) { // Yes, so fetch the module definition. ModuleDefinition* pTargetModuleDefinition = *definitionItr; // Fetch the target module build Id. const U32 targetBuildId = pTargetModuleDefinition->getBuildId(); // Fetch the target module path. StringTableEntry targetModulePath = pTargetModuleDefinition->getModulePath(); // Remove the target module definition from the database. targetModuleManager.removeModuleDefinition( pTargetModuleDefinition ); // Skip if the target definition is the same build Id. if ( targetBuildId == sourceBuildId ) continue; // Delete the target module definition folder. if ( !Platform::deleteDirectory( targetModulePath ) ) { // Warn. Con::warnf("Cannot synchronize dependencies for module Id '%s' at version Id '%d' as the old module at '%s' could not be deleted.", sourceModuleId, sourceVersionId, targetModulePath ); return false; } } } // Format source module path. char sourceFolderPath[1024]; Con::expandPath( sourceFolderPath, sizeof(sourceFolderPath), pSourceModuleDefinition->getModulePath() ); // Format target module path. dSprintf( targetFolderGenerateBuffer, sizeof(targetFolderGenerateBuffer), "%s/%s/%d", pTargetDependencyPath, sourceModuleId, sourceVersionId ); // Copy the source module to the target folder. if (!dPathCopy(sourceFolderPath, targetFolderGenerateBuffer, false)) { // Warn. Con::warnf("Cannot synchronize dependencies for module Id '%s' at version Id '%d' as the module could not be copied to '%s'.", sourceModuleId, sourceVersionId, targetFolderGenerateBuffer ); return false; } } // Find any target modules left, These are orphaned modules not depended upon by any other module. typeConstModuleDefinitionVector orphanedTargetModules; targetModuleManager.findModules( false, orphanedTargetModules ); // Iterate module definitions. for ( typeConstModuleDefinitionVector::const_iterator moduleDefinitionItr = orphanedTargetModules.begin(); moduleDefinitionItr != orphanedTargetModules.end(); ++moduleDefinitionItr ) { // Fetch orphaned module definition. const ModuleDefinition* pOrphanedModuleDefinition = *moduleDefinitionItr; // Delete the target module definition folder. if ( !Platform::deleteDirectory( pOrphanedModuleDefinition->getModulePath() ) ) { // Warn. Con::warnf("Cannot delete orphaned module Id '%s' at version Id '%d' from '%s'.", pOrphanedModuleDefinition->getModuleId(), pOrphanedModuleDefinition->getVersionId(), pOrphanedModuleDefinition->getModulePath() ); } } return true; } //----------------------------------------------------------------------------- bool ModuleManager::canMergeModules( const char* pMergeSourcePath ) { // Sanity! AssertFatal( pMergeSourcePath != NULL, "Cannot check merge modules with NULL source path." ); // Expand the source path. char sourcePathBuffer[1024]; Con::expandPath( sourcePathBuffer, sizeof(sourcePathBuffer), pMergeSourcePath ); pMergeSourcePath = sourcePathBuffer; // Is the path a valid directory? if ( !Platform::isDirectory( sourcePathBuffer ) ) { // No, so warn. Con::warnf( "Cannot check merge modules as path is invalid '%s'.", sourcePathBuffer ); return false; } // Initialize the source module manager and scan the source folder for modules. ModuleManager mergeModuleManager; mergeModuleManager.mEnforceDependencies = false; mergeModuleManager.mEchoInfo = false; mergeModuleManager.scanModules( pMergeSourcePath ); // Find all the merge modules. typeConstModuleDefinitionVector mergeModules; mergeModuleManager.findModules( false, mergeModules ); // Iterate found merge module definitions. for ( typeConstModuleDefinitionVector::const_iterator mergeModuleItr = mergeModules.begin(); mergeModuleItr != mergeModules.end(); ++mergeModuleItr ) { // Fetch module definition. const ModuleDefinition* pMergeModuleDefinition = *mergeModuleItr; // Fetch module Id. StringTableEntry moduleId = pMergeModuleDefinition->getModuleId(); // Fetch version Id. const U32 versionId = pMergeModuleDefinition->getVersionId(); // Fetch module group. StringTableEntry moduleGroup = pMergeModuleDefinition->getModuleGroup(); // Cannot merge if module already exists. if ( findModuleDefinition( moduleId, versionId ) != NULL ) return false; // Cannot merge if module is part of a loaded group. if ( findGroupLoaded( moduleGroup ) != NULL ) return false; } // Can merge modules. return true; } //----------------------------------------------------------------------------- bool ModuleManager::mergeModules( const char* pMergeTargetPath, const bool removeMergeDefinition, const bool registerNewModules ) { // Sanity! AssertFatal( pMergeTargetPath != NULL, "Cannot merge modules with a target path of NULL." ); // Is a module merge available? if ( !isModuleMergeAvailable() ) { // No, so warn. Con::warnf( "Cannot merge modules as a module merge is not available." ); return false; } // Expand the target path. char targetPathBuffer[1024]; Con::expandPath( targetPathBuffer, sizeof(targetPathBuffer), pMergeTargetPath ); pMergeTargetPath = targetPathBuffer; // Fetch module merge file path. StringTableEntry moduleMergeFilePath = getModuleMergeFilePath(); // Read module merge definition. Taml taml; ModuleMergeDefinition* pModuleMergeDefinition = taml.read( moduleMergeFilePath ); // Do we have a module merge definition. if ( pModuleMergeDefinition == NULL ) { // No, so warn. Con::warnf( "Cannot merge modules as the module merge definition file failed to load '%s'.", moduleMergeFilePath ); return false; } // Fetch the merge source path. StringTableEntry mergeSourcePath = pModuleMergeDefinition->getModuleMergePath(); // Remove the module merge definition. pModuleMergeDefinition->deleteObject(); pModuleMergeDefinition = NULL; // If we cannot merge the modules then we only process modules flagged as critical merge. const bool criticalMergeOnly = !canMergeModules( mergeSourcePath ); // Initialize the target module manager and scan the target folder for modules. ModuleManager targetModuleManager; targetModuleManager.mEnforceDependencies = false; targetModuleManager.mEchoInfo = false; targetModuleManager.scanModules( pMergeTargetPath ); // Initialize the source module manager and scan the source folder for modules. ModuleManager sourceModuleManager; sourceModuleManager.mEnforceDependencies = false; sourceModuleManager.mEchoInfo = false; sourceModuleManager.scanModules( mergeSourcePath ); // Find all the source modules. typeConstModuleDefinitionVector sourceModules; sourceModuleManager.findModules( false, sourceModules ); // Iterate found merge module definitions. for ( typeConstModuleDefinitionVector::const_iterator sourceModuleItr = sourceModules.begin(); sourceModuleItr != sourceModules.end(); ++sourceModuleItr ) { // Fetch the source module definition. const ModuleDefinition* pSourceModuleDefinition = *sourceModuleItr; // Skip if we're performing a critical merge only and the module is not flagged as critical merge. if ( criticalMergeOnly && pSourceModuleDefinition->getCriticalMerge() ) continue; // Fetch source module Id. const StringTableEntry sourceModuleId = pSourceModuleDefinition->getModuleId(); // Fetch source version Id. const U32 sourceVersionId = pSourceModuleDefinition->getVersionId(); // Fetch source build Id. const U32 sourceBuildId = pSourceModuleDefinition->getBuildId(); // Format module Id folder path. char targetModuleIdBuffer[1024]; dSprintf( targetModuleIdBuffer, sizeof(targetModuleIdBuffer), "%s/%s/", pMergeTargetPath, sourceModuleId ); // Flag to indicate if the merged module needs registering. bool shouldRegisterModule; // Does the module Id exist? if ( targetModuleManager.findModuleId( sourceModuleId ) == NULL ) { // No, so create module Id folder. if ( !Platform::createPath( targetModuleIdBuffer ) ) { // Warn. Con::warnf("Cannot merge modules for module '%s' as the path '%s' could not be created.", sourceModuleId, targetModuleIdBuffer ); return false; } // Module Should be registered. shouldRegisterModule = true; } else { // Yes, so find the target module definition that matches the source module definition. ModuleDefinitionEntry::iterator targetModuleDefinitionItr = targetModuleManager.findModuleDefinition( sourceModuleId, sourceVersionId ); // Is there an existing target module definition entry? if ( targetModuleDefinitionItr != NULL ) { // Yes, so fetch the target module definition. const ModuleDefinition* pTargetModuleDefinition = *targetModuleDefinitionItr; // Fetch target module path. StringTableEntry targetModulePath = pTargetModuleDefinition->getModulePath(); // Yes, so we have to remove it first. if ( !Platform::deleteDirectory( targetModulePath ) ) { // Module was not deleted so warn. Con::warnf( "Failed to remove module folder located at '%s'. Module will be copied over.", targetModulePath ); } // Is the build Id being downgraded? if ( sourceBuildId < pTargetModuleDefinition->getBuildId() ) { // Yes, so warn. Con::warnf( "Encountered a downgraded build Id for module Id '%s' at version Id '%d'.", sourceModuleId, sourceBuildId ); } // Module should not be registered. shouldRegisterModule = false; } else { // Module Should be registered. shouldRegisterModule = true; } } // Fetch source module path. StringTableEntry sourceModulePath = pSourceModuleDefinition->getModulePath(); // Format target version Id folder path. char targetVersionIdBuffer[1024]; dSprintf( targetVersionIdBuffer, sizeof(targetVersionIdBuffer), "%s%d", targetModuleIdBuffer, sourceVersionId ); // Copy module (allow overwrites as we may have failed to remove the old folder in which case this is likely to fail as well). if (!dPathCopy(sourceModulePath, targetVersionIdBuffer, false)) { // Failed to copy module. Con::warnf( "Failed to copy module folder located at '%s' to location '%s'. The modules may now be corrupted.", sourceModulePath, targetVersionIdBuffer ); } // Are we registering new modules and the module needs registering? if ( registerNewModules && shouldRegisterModule ) { // Yes, so scan module. scanModules( targetVersionIdBuffer, true ); } // Is the module part of a critical merge? if ( criticalMergeOnly ) { // Yes, so we need to remove the source module definition. if ( !Platform::deleteDirectory( sourceModulePath ) ) { // Module was not deleted so warn. Con::warnf( "Failed to remove CRITICAL merge module folder located at '%s'. Module will be copied over.", sourceModulePath ); } } } // Do we need to remove the module merge definition file? if ( removeMergeDefinition ) { // Yes, so remove it. dFileDelete( moduleMergeFilePath ); } return true; } //----------------------------------------------------------------------------- void ModuleManager::addListener( SimObject* pListener ) { // Sanity! AssertFatal( pListener != NULL, "Cannot add notifications to a NULL object." ); // Ignore if already added. if (mNotificationListeners.find( pListener) != mNotificationListeners.end()) return; // Add as a listener. mNotificationListeners.addObject( pListener ); } //----------------------------------------------------------------------------- void ModuleManager::removeListener( SimObject* pListener ) { // Sanity! AssertFatal( pListener != NULL, "Cannot remove notifications from a NULL object." ); // Remove as a listener. mNotificationListeners.removeObject( pListener ); } //----------------------------------------------------------------------------- void ModuleManager::clearDatabase( void ) { // Lock database. AssertFatal( mDatabaseLocks == 0, "Cannot clear database if database is locked." ); // Iterate groups loaded. while ( mGroupsLoaded.size() > 0 ) { // Unload module group. unloadModuleGroup( *mGroupsLoaded.begin() ); } // Iterate any other explicit modules that are loaded. while ( mModulesLoaded.size() > 0 ) { // Fetch module definition. ModuleDefinition* pModuleDefinition = mModulesLoaded.begin()->mpModuleDefinition; // Unload explicit module. unloadModuleExplicit( pModuleDefinition->getModuleId() ); } // Iterate modules to delete module definitions. for ( typeModuleIdDatabaseHash::iterator moduleItr = mModuleIdDatabase.begin(); moduleItr != mModuleIdDatabase.end(); ++moduleItr ) { // Fetch modules definitions. ModuleDefinitionEntry* pDefinitions = moduleItr->value; // Iterate module definitions. for ( ModuleDefinitionEntry::iterator definitionItr = pDefinitions->begin(); definitionItr != pDefinitions->end(); ++definitionItr ) { // Fetch module definition. ModuleDefinition* pModuleDefinition = *definitionItr; // Remove notification before we delete it. clearNotify( pModuleDefinition ); // Delete module definition. pModuleDefinition->deleteObject(); } // Clear definitions. delete pDefinitions; } // Clear database. mModuleIdDatabase.clear(); // Iterate module groups. for ( typeGroupModuleHash::iterator moduleGroupItr = mGroupModules.begin(); moduleGroupItr != mGroupModules.end(); ++moduleGroupItr ) { // Delete module group vector. delete moduleGroupItr->value; } // Clear module groups. mGroupModules.clear(); } //----------------------------------------------------------------------------- bool ModuleManager::removeModuleDefinition( ModuleDefinition* pModuleDefinition ) { // Sanity! AssertFatal( pModuleDefinition != NULL, "Cannot remove module definition if it is NULL." ); // Fetch module Id. StringTableEntry moduleId = pModuleDefinition->getModuleId(); // Is the module definition registered with this module manager? if ( pModuleDefinition->getModuleManager() != this ) { // No, so warn. Con::warnf("Cannot remove module definition '%s' as it is not registered with this module manager.", moduleId ); return false; } // Is the module definition loaded? if ( pModuleDefinition->getLoadCount() > 0 ) { // No, so warn. Con::warnf("Cannot remove module definition '%s' as it is loaded.", moduleId ); return false; } // Find module Id. typeModuleIdDatabaseHash::iterator moduleItr = mModuleIdDatabase.find( moduleId ); // Sanity! AssertFatal( moduleItr != mModuleIdDatabase.end(), "Failed to find module definition." ); // Fetch modules definitions. ModuleDefinitionEntry* pDefinitions = moduleItr->value; // Fetch version Id. const U32 versionId = pModuleDefinition->getVersionId(); // Iterate module definitions. for ( ModuleDefinitionEntry::iterator definitionItr = pDefinitions->begin(); definitionItr != pDefinitions->end(); ++definitionItr ) { // Skip if this isn't the version Id we're searching for. if ( versionId != (*definitionItr)->getVersionId() ) continue; // Remove definition entry. pDefinitions->erase( definitionItr ); // Remove notification before we delete it. clearNotify( pModuleDefinition ); // Delete module definition. pModuleDefinition->deleteObject(); // Are there any modules left for this module Id? if ( findModuleId( moduleId ) == NULL ) { bool moduleIdFound = false; // No, so remove from groups. for( typeGroupModuleHash::iterator moduleGroupItr = mGroupModules.begin(); moduleGroupItr != mGroupModules.end(); ++moduleGroupItr ) { // Fetch module Ids. typeModuleIdVector* pModuleIds = moduleGroupItr->value; // Iterate module Id. for( typeModuleIdVector::iterator moduleIdItr = pModuleIds->begin(); moduleIdItr != pModuleIds->end(); ++moduleIdItr ) { // Skip if this isn't the Id. if ( *moduleIdItr != moduleId ) continue; // Remove the module Id. pModuleIds->erase( moduleIdItr ); // Flag as found. moduleIdFound = true; break; } // Finish if found. if ( moduleIdFound ) break; } } return true; } // Sanity! AssertFatal( false, "Failed to find module definition." ); return false; } //----------------------------------------------------------------------------- bool ModuleManager::registerModule( const char* pModulePath, const char* pModuleFile ) { // Sanity! AssertFatal( pModulePath != NULL, "Cannot scan module with NULL module path." ); AssertFatal( pModuleFile != NULL, "Cannot scan module with NULL module file." ); char formatBuffer[1024]; // Fetch module path trail character. char modulePathTrail = pModulePath[dStrlen(pModulePath) - 1]; // Format module file-path. dSprintf( formatBuffer, sizeof(formatBuffer), modulePathTrail == '/' ? "%s%s" : "%s/%s", pModulePath, pModuleFile ); // Read the module file. ModuleDefinition* pModuleDefinition = mTaml.read( formatBuffer ); // Did we read a module definition? if ( pModuleDefinition == NULL ) { // No, so warn. Con::warnf( "Module Manager: Failed to read module definition in file '%s'.", formatBuffer ); return false; } // Set the module manager. pModuleDefinition->setModuleManager( this ); // Set module definition path. pModuleDefinition->setModulePath( pModulePath ); // Set module file. pModuleDefinition->setModuleFile( pModuleFile ); // Set module file-path. pModuleDefinition->setModuleFilePath( formatBuffer ); // Fetch module Id. StringTableEntry moduleId = pModuleDefinition->getModuleId(); // Fetch module version Id. const U32 versionId = pModuleDefinition->getVersionId(); // Fetch module group. StringTableEntry moduleGroup = pModuleDefinition->getModuleGroup(); // Fetch module type. StringTableEntry moduleType = pModuleDefinition->getModuleType(); // Is the module enabled? if ( !pModuleDefinition->getEnabled() ) { // No, so warn. Con::warnf( "Module Manager: Found module: '%s' but it is disabled.", pModuleDefinition->getModuleFilePath() ); // Destroy module definition and finish. pModuleDefinition->deleteObject(); return false; } // Is the module Id valid? if (moduleId == StringTable->EmptyString()) { // No, so warn. Con::warnf( "Module Manager: Found module: '%s' but it has an unspecified module Id.", pModuleDefinition->getModuleFilePath() ); // Destroy module definition and finish. pModuleDefinition->deleteObject(); return false; } // Is the module version Id valid? if ( versionId == 0 ) { // No, so warn. Con::warnf( "Module Manager: Found Manager: Registering module: '%s' but it has an invalid Version Id of '0'.", pModuleDefinition->getModuleFilePath() ); // Destroy module definition and finish. pModuleDefinition->deleteObject(); return false; } // Is the module group already loaded? if ( findGroupLoaded( moduleGroup ) != NULL && !mIgnoreLoadedGroups) { // Yes, so warn. Con::warnf( "Module Manager: Found module: '%s' but it is in a module group '%s' which has already been loaded.", pModuleDefinition->getModuleFilePath(), moduleGroup ); // Destroy module definition and finish. pModuleDefinition->deleteObject(); return false; } // Was a script-file specified? if ( pModuleDefinition->getScriptFile() != StringTable->EmptyString() ) { // Yes, so format module script file-path. dSprintf( formatBuffer, sizeof(formatBuffer), modulePathTrail == '/' ? "%s%s" : "%s/%s", pModulePath, pModuleDefinition->getScriptFile() ); pModuleDefinition->setModuleScriptFilePath( formatBuffer ); } // Format module signature, dSprintf( formatBuffer, sizeof(formatBuffer), "%s_%d_%d", moduleId, versionId, pModuleDefinition->getBuildId() ); pModuleDefinition->setSignature( formatBuffer ); // Locked the module definition. pModuleDefinition->setModuleLocked( true ); // Fetch modules definitions. ModuleDefinitionEntry* pDefinitions = findModuleId( moduleId ); // Did we find the module Id? if ( pDefinitions != NULL ) { // Yes, so find the module definition. ModuleDefinitionEntry::iterator definitionItr = findModuleDefinition( moduleId, versionId ); // Does this version Id already exist? if ( definitionItr != NULL ) { // Yes, so warn. Con::warnf( "Module Manager: Found module: '%s' but it is already registered as module Id '%s' at version Id '%d'.", pModuleDefinition->getModuleFilePath(), moduleId, versionId ); // Destroy module definition and finish. pModuleDefinition->deleteObject(); return false; } // Is the module group the same as the module definitions we already have? if ( moduleGroup != pDefinitions->mModuleGroup ) { // No, so warn. Con::warnf( "Module Manager: Found module: '%s' but its module group '%s' is not the same as other module definitions of the same module Id.", pModuleDefinition->getModuleFilePath(), moduleGroup ); // Destroy module definition and finish. pModuleDefinition->deleteObject(); return false; } // Is the module type the same as the module definitions we already have? if ( moduleType != pDefinitions->mModuleType ) { // No, so warn. Con::warnf( "Module Manager: Found module: '%s' but its module type '%s' is not the same as other module definitions of the same module Id.", pModuleDefinition->getModuleFilePath(), moduleGroup ); // Destroy module definition and finish. pModuleDefinition->deleteObject(); return false; } } else { // No, so create a vector of definitions. pDefinitions = new ModuleDefinitionEntry( moduleId, moduleGroup, moduleType ); // Insert module Id definitions. mModuleIdDatabase.insert( moduleId, pDefinitions ); } // Add module definition. pDefinitions->push_back( pModuleDefinition ); // Sort module definitions by version Id so that higher versions appear first. dQsort( pDefinitions->address(), pDefinitions->size(), sizeof(ModuleDefinition*), moduleDefinitionVersionIdSort ); // Find module group. typeGroupModuleHash::iterator moduleGroupItr = mGroupModules.find( moduleGroup ); // Did we find the module group? if ( moduleGroupItr != mGroupModules.end() ) { // Yes, so fetch module Ids. typeModuleIdVector* pModuleIds = moduleGroupItr->value; // Is the module Id already present? bool moduleIdFound = false; for( typeModuleIdVector::iterator moduleIdItr = pModuleIds->begin(); moduleIdItr != pModuleIds->end(); ++moduleIdItr ) { // Skip if this isn't the Id. if ( *moduleIdItr != moduleId ) continue; // Flag as found. moduleIdFound = true; break; } // Add if module Id was not found. if ( !moduleIdFound ) pModuleIds->push_back( moduleId ); } else { // No, so insert a module Id vector. moduleGroupItr = mGroupModules.insert( pModuleDefinition->getModuleGroup(), new typeModuleIdVector() ); // Add module Id. moduleGroupItr->value->push_back( moduleId ); } // Notify if the module definition is destroyed. deleteNotify( pModuleDefinition ); // Info. if ( mEchoInfo ) { #if 1 Con::printf( "Module Manager: Registering: '%s' [ ID='%s', VersionId='%d', BuildId='%d', Description='%s' ].", pModuleDefinition->getModuleFilePath(), pModuleDefinition->getModuleId(), pModuleDefinition->getVersionId(), pModuleDefinition->getBuildId(), pModuleDefinition->getModuleDescription() ); #else Con::printf( "Module Manager: Registering: '%s' [ ID='%s', VersionId='%d', BuildId='%d', Description='%s', Group='%s', Dependencies='%s', ScriptFile='%s', CreateFunction='%s', DestroyFunction='%s' ].", pModuleDefinition->getModuleFilePath(), pModuleDefinition->getModuleId(), pModuleDefinition->getVersionId(), pModuleDefinition->getBuildId(), pModuleDefinition->getModuleDescription(), pModuleDefinition->getModuleGroup(), pModuleDefinition->getDataField( StringTable->insert("Dependencies"), NULL ), pModuleDefinition->getScriptFile(), pModuleDefinition->getCreateFunction(), pModuleDefinition->getDestroyFunction() ); #endif } // Emit notifications. for( SimSet::iterator notifyItr = mNotificationListeners.begin(); notifyItr != mNotificationListeners.end(); ++notifyItr ) { Con::executef( *notifyItr, "onModuleRegister", pModuleDefinition->getIdString() ); } return true; } //----------------------------------------------------------------------------- bool ModuleManager::unregisterModule( const char* pModuleId, const U32 versionId ) { // Sanity! AssertFatal( pModuleId != NULL, "A module Id cannot be NULL." ); // Fetch module Id. StringTableEntry moduleId = StringTable->insert( pModuleId ); // Find the module definition. ModuleDefinition* pModuleDefinition = findModule( pModuleId, versionId ); // Did we find the module definition? if ( pModuleDefinition == NULL ) { // No, so warn. Con::warnf( "Module Manager: Cannot unregister module Id '%s' as it is not registered.", moduleId ); return false; } // Remove the module definition. return removeModuleDefinition( pModuleDefinition ); } //----------------------------------------------------------------------------- void ModuleManager::raiseModulePreLoadNotifications( ModuleDefinition* pModuleDefinition ) { // Raise notifications. for( SimSet::iterator notifyItr = mNotificationListeners.begin(); notifyItr != mNotificationListeners.end(); ++notifyItr ) { // Fetch listener object. SimObject* pListener = *notifyItr; // Perform object callback. ModuleCallbacks* pCallbacks = dynamic_cast( pListener ); if ( pCallbacks != NULL ) pCallbacks->onModulePreLoad( pModuleDefinition ); // Perform script callback. if ( pListener->isMethod( "onModulePreLoad" ) ) Con::executef( pListener, "onModulePreLoad", pModuleDefinition->getIdString() ); } } //----------------------------------------------------------------------------- void ModuleManager::raiseModulePostLoadNotifications( ModuleDefinition* pModuleDefinition ) { // Raise notifications. for( SimSet::iterator notifyItr = mNotificationListeners.begin(); notifyItr != mNotificationListeners.end(); ++notifyItr ) { // Fetch listener object. SimObject* pListener = *notifyItr; // Perform object callback. ModuleCallbacks* pCallbacks = dynamic_cast( pListener ); if ( pCallbacks != NULL ) pCallbacks->onModulePostLoad( pModuleDefinition ); // Perform script callback. if ( pListener->isMethod( "onModulePostLoad" ) ) Con::executef( pListener, "onModulePostLoad", pModuleDefinition->getIdString() ); } } //----------------------------------------------------------------------------- void ModuleManager::raiseModulePreUnloadNotifications( ModuleDefinition* pModuleDefinition ) { // Raise notifications. for( SimSet::iterator notifyItr = mNotificationListeners.begin(); notifyItr != mNotificationListeners.end(); ++notifyItr ) { // Fetch listener object. SimObject* pListener = *notifyItr; // Perform object callback. ModuleCallbacks* pCallbacks = dynamic_cast( pListener ); if ( pCallbacks != NULL ) pCallbacks->onModulePreUnload( pModuleDefinition ); // Perform script callback. if ( pListener->isMethod( "onModulePreUnload" ) ) Con::executef( pListener, "onModulePreUnload", pModuleDefinition->getIdString() ); } } //----------------------------------------------------------------------------- void ModuleManager::raiseModulePostUnloadNotifications( ModuleDefinition* pModuleDefinition ) { // Raise notifications. for( SimSet::iterator notifyItr = mNotificationListeners.begin(); notifyItr != mNotificationListeners.end(); ++notifyItr ) { // Fetch listener object. SimObject* pListener = *notifyItr; // Perform object callback. ModuleCallbacks* pCallbacks = dynamic_cast( pListener ); if ( pCallbacks != NULL ) pCallbacks->onModulePostUnload( pModuleDefinition ); // Perform script callback. if ( pListener->isMethod( "onModulePostUnload" ) ) Con::executef( pListener, "onModulePostUnload", pModuleDefinition->getIdString() ); } } //----------------------------------------------------------------------------- ModuleManager::ModuleDefinitionEntry* ModuleManager::findModuleId( StringTableEntry moduleId ) { // Sanity! AssertFatal( moduleId != NULL, "A module Id cannot be NULL." ); // Is the module Id valid? if ( moduleId == StringTable->EmptyString() ) { // No, so warn. Con::warnf( "Module Manager: Invalid Module Id." ); return NULL; } // Find module Id. typeModuleIdDatabaseHash::iterator moduleItr = mModuleIdDatabase.find( moduleId ); // Return appropriately. return moduleItr != mModuleIdDatabase.end() ? moduleItr->value : NULL; } //----------------------------------------------------------------------------- ModuleManager::ModuleDefinitionEntry::iterator ModuleManager::findModuleDefinition( StringTableEntry moduleId, const U32 versionId ) { // Fetch modules definitions. ModuleDefinitionEntry* pDefinitions = findModuleId( moduleId ); // Finish if no module definitions for the module Id. if ( pDefinitions == NULL ) return NULL; // Iterate module definitions. for ( ModuleDefinitionEntry::iterator definitionItr = pDefinitions->begin(); definitionItr != pDefinitions->end(); ++definitionItr ) { // Skip if this isn't the version Id we're searching for. if ( versionId != (*definitionItr)->getVersionId() ) continue; // Return module definition iterator. return definitionItr; } // Not found. return NULL; } //----------------------------------------------------------------------------- bool ModuleManager::resolveModuleDependencies( StringTableEntry moduleId, const U32 versionId, StringTableEntry moduleGroup, bool synchronizedOnly, typeModuleLoadEntryVector& moduleResolvingQueue, typeModuleLoadEntryVector& moduleReadyQueue ) { // Fetch the module Id ready entry. ModuleLoadEntry* pLoadReadyEntry = findModuleReady( moduleId, moduleReadyQueue ); // Is there a load entry? if ( pLoadReadyEntry ) { // Yes, so finish if the version Id is not important, if ( versionId == 0 ) return true; // Finish if the version Id are compatible. if ( versionId == pLoadReadyEntry->mpModuleDefinition->getVersionId() ) return true; // Is it a strict version Id? if ( pLoadReadyEntry->mStrictVersionId ) { // Yes, so warn. Con::warnf( "Module Manager: A module dependency was detected loading module Id '%s' at version Id '%d' in group '%s' but an version Id '%d' is also required.", moduleId, versionId, pLoadReadyEntry->mpModuleDefinition->getVersionId(), moduleGroup ); return false; } // No, so find the required module version Id. ModuleDefinitionEntry::iterator definitionItr = findModuleDefinition( moduleId, versionId ); // Did we find the requested module definition. if ( definitionItr == NULL ) { // No, so we can safely ignore the missing dependency if we're not enforcing dependencies. if ( !mEnforceDependencies ) return true; // Warn! Con::warnf( "Module Manager: A missing module dependency was detected loading module Id '%s' at version Id '%d' in group '%s'.", moduleId, versionId, moduleGroup ); return false; } // Set the new module definition. pLoadReadyEntry->mpModuleDefinition = *definitionItr; // Set strict version Id. pLoadReadyEntry->mStrictVersionId = true; return true; } // Is the module Id load resolving? if ( findModuleResolving( moduleId, moduleResolvingQueue ) != NULL ) { // Yes, so a cycle has been detected so warn. Con::warnf( "Module Manager: A cyclic dependency was detected resolving module Id '%s' at version Id '%d' in group '%s'.", moduleId, versionId, moduleGroup ); return false; } // Reset selected module definition. ModuleDefinition* pSelectedModuleDefinition = NULL; // Do we want the latest version Id? if ( versionId == 0 ) { // Yes, so find the module Id. typeModuleIdDatabaseHash::iterator moduleIdItr = mModuleIdDatabase.find( moduleId ); // Did we find the module Id? if ( moduleIdItr == mModuleIdDatabase.end() ) { // No, so we can safely ignore the missing dependency if we're not enforcing dependencies. if ( !mEnforceDependencies ) return true; // Warn! Con::warnf( "Module Manager: A missing module dependency was detected loading module Id '%s' at version Id '%d' in group '%s'.", moduleId, versionId, moduleGroup ); return false; } // Fetch first module definition which should be the highest version Id. pSelectedModuleDefinition = (*moduleIdItr->value)[0]; } else { // No, so find the module Id at the specific version Id. ModuleDefinitionEntry::iterator definitionItr = findModuleDefinition( moduleId, versionId ); // Did we find the module definition? if ( definitionItr == NULL ) { // No, so we can safely ignore the missing dependency if we're not enforcing dependencies. if ( !mEnforceDependencies ) return true; // Warn! Con::warnf( "Module Manager: A missing module dependency was detected loading module Id '%s' at version Id '%d' in group '%s'.", moduleId, versionId, moduleGroup ); return false; } // Select the module definition. pSelectedModuleDefinition = *definitionItr; } // If we're only resolving synchronized modules and the module is not synchronized then finish. if ( synchronizedOnly && !pSelectedModuleDefinition->getSynchronized() ) return true; // Create a load entry. ModuleLoadEntry loadEntry( pSelectedModuleDefinition, false ); // Fetch module dependencies. const ModuleDefinition::typeModuleDependencyVector& moduleDependencies = pSelectedModuleDefinition->getDependencies(); // Do we have any module dependencies? if ( moduleDependencies.size() > 0 ) { // Yes, so queue this module as resolving. moduleResolvingQueue.push_back( loadEntry ); // Iterate module dependencies. for( ModuleDefinition::typeModuleDependencyVector::const_iterator dependencyItr = moduleDependencies.begin(); dependencyItr != moduleDependencies.end(); ++dependencyItr ) { // Finish if we could not the dependent module Id at the version Id. if ( !resolveModuleDependencies( dependencyItr->mModuleId, dependencyItr->mVersionId, moduleGroup, synchronizedOnly, moduleResolvingQueue, moduleReadyQueue ) ) return false; } // Remove module as resolving. moduleResolvingQueue.pop_back(); } // Queue module as ready. moduleReadyQueue.push_back( loadEntry ); return true; } //----------------------------------------------------------------------------- ModuleManager::ModuleLoadEntry* ModuleManager::findModuleResolving( StringTableEntry moduleId, typeModuleLoadEntryVector& moduleResolvingQueue ) { // Iterate module load resolving queue. for( typeModuleLoadEntryVector::iterator loadEntryItr = moduleResolvingQueue.begin(); loadEntryItr != moduleResolvingQueue.end(); ++loadEntryItr ) { // Finish if found. if ( moduleId == loadEntryItr->mpModuleDefinition->getModuleId() ) return loadEntryItr; } // Not found. return NULL; } //----------------------------------------------------------------------------- ModuleManager::ModuleLoadEntry* ModuleManager::findModuleReady( StringTableEntry moduleId, typeModuleLoadEntryVector& moduleReadyQueue ) { // Iterate module load ready queue. for( typeModuleLoadEntryVector::iterator loadEntryItr = moduleReadyQueue.begin(); loadEntryItr != moduleReadyQueue.end(); ++loadEntryItr ) { // Finish if found. if ( moduleId == loadEntryItr->mpModuleDefinition->getModuleId() ) return loadEntryItr; } // Not found. return NULL; } //----------------------------------------------------------------------------- ModuleManager::typeModuleLoadEntryVector::iterator ModuleManager::findModuleLoaded( StringTableEntry moduleId, const U32 versionId ) { // Iterate module loaded queue. for( typeModuleLoadEntryVector::iterator loadEntryItr = mModulesLoaded.begin(); loadEntryItr != mModulesLoaded.end(); ++loadEntryItr ) { // Skip if not the module Id we're looking for. if ( moduleId != loadEntryItr->mpModuleDefinition->getModuleId() ) continue; // Skip if we are searching for a specific version and it does not match. if ( versionId != 0 && versionId != loadEntryItr->mpModuleDefinition->getVersionId() ) continue; return loadEntryItr; } // Not found. return NULL; } //----------------------------------------------------------------------------- ModuleManager::typeGroupVector::iterator ModuleManager::findGroupLoaded( StringTableEntry moduleGroup ) { // Iterate groups loaded queue. for( typeGroupVector::iterator groupsLoadedItr = mGroupsLoaded.begin(); groupsLoadedItr != mGroupsLoaded.end(); ++groupsLoadedItr ) { // Finish if found. if ( moduleGroup == *groupsLoadedItr ) return groupsLoadedItr; } // Not found. return NULL; } //----------------------------------------------------------------------------- StringTableEntry ModuleManager::getModuleMergeFilePath( void ) const { // Format merge file path. char filePathBuffer[1024]; dSprintf( filePathBuffer, sizeof(filePathBuffer), "%s/%s", Platform::getExecutablePath(), MODULE_MANAGER_MERGE_FILE ); return StringTable->insert( filePathBuffer ); }