diff options
Diffstat (limited to 'TAO/CIAO/DAnCE/RepositoryManager/RepositoryManager_Impl.cpp')
| -rw-r--r-- | TAO/CIAO/DAnCE/RepositoryManager/RepositoryManager_Impl.cpp | 1215 |
1 files changed, 145 insertions, 1070 deletions
diff --git a/TAO/CIAO/DAnCE/RepositoryManager/RepositoryManager_Impl.cpp b/TAO/CIAO/DAnCE/RepositoryManager/RepositoryManager_Impl.cpp index a529c07f84a..da85e59cf55 100644 --- a/TAO/CIAO/DAnCE/RepositoryManager/RepositoryManager_Impl.cpp +++ b/TAO/CIAO/DAnCE/RepositoryManager/RepositoryManager_Impl.cpp @@ -1,1130 +1,205 @@ +/* -*- C++ -*- */ // $Id$ -//==================================================================== -/** - * @file RepositoryManager_Impl.cpp - * - * $Id$ - * - * Description: Actial implementation of the RepoMan - * - * @author Stoyan Paunov - */ -//==================================================================== - #include "RepositoryManager_Impl.h" +#include "Repository_Manager_conf.h" +#include "Old_Config_Handlers/TPD_Handler.h" +#include "Old_Config_Handlers/DnC_Dump.h" -#include "ace/OS_NS_fcntl.h" //for open -#include "ace/OS_NS_unistd.h" //for close -#include "ace/OS_NS_sys_stat.h" //for filesize and fstat and mkdir -#include "ace/OS_NS_string.h" //for ACE_CString -#include "ace/OS_Memory.h" //for ACE_NEW* macros - - -//to remove a file or dir from the local filesystem need remove () from stdio.h -// ---> need to include ace/OS_NS_stdio.h which would include the correct file for any OS! -#include "ace/OS_NS_stdio.h" - -#include "ZIP_Wrapper.h" //Wrapper around zzip -#include "ace/Containers_T.h" //for ACE_Double_Linked_List -#include "ace/Malloc_Allocator.h" //for ACE_New_Allocator - -//for the PackageConfiguration parsing -#include "Config_Handlers/STD_PC_Intf.h" -#include "ciao/Deployment_DataC.h" -#include "ciao/Packaging_DataC.h" -#include "Config_Handlers/Utils/XML_Helper.h" -#include "xercesc/dom/DOM.hpp" - -#include "RM_Helper.h" //to be able to externalize/internalize a PackageConfiguration -#include "ace/Message_Block.h" //for ACE_Message_Block - -#include "ace/Thread.h" //for obtaining the ID of the current thread -#include "ace/OS_NS_stdlib.h" //for itoa () - -#include "URL_Parser.h" //for parsing the URL -#include "HTTP_Client.h" //the HTTP client class to downloading packages - -#include "PC_Updater.h" //A visitor class to walk through the elements of the PC - -#include <iostream> -using namespace std; - -//----------------------------------------------------------------- -//Constructor -// -//----------------------------------------------------------------- - -CIAO_RepositoryManagerDaemon_i::CIAO_RepositoryManagerDaemon_i (CORBA::ORB_ptr the_orb, const char* server) - : the_orb_ (CORBA::ORB::_duplicate (the_orb)), - install_root_ (""), - HTTP_server_ (server) +CIAO::RepositoryManager_Impl::RepositoryManager_Impl + (CORBA::ORB_ptr orb, + PortableServer::POA_ptr poa) + : orb_ (CORBA::ORB::_duplicate (orb)), + poa_ (PortableServer::POA::_duplicate (poa)), + pc_table_ (MAX_PACKAGES) { - //create directory in which the packages will be stored - - ACE_OS::mkdir(INSTALL_PATH); - //if dir already exists a -1 is returned - //we ignore this, just need to make sure the directory exists - - ACE_OS::getcwd (this->cwd_, TEMP_LEN); - - this->install_root_ = this->cwd_; - this->install_root_ += "/"; - this->install_root_ += INSTALL_PATH; } -//----------------------------------------------------------------- -//Destructor -// -//----------------------------------------------------------------- - -CIAO_RepositoryManagerDaemon_i::~CIAO_RepositoryManagerDaemon_i (void) +CIAO::RepositoryManager_Impl::RepositoryManager_Impl () + : pc_table_ (MAX_PACKAGES) { - this->names_.unbind_all (); - this->uuids_.unbind_all (); } -//----------------------------------------------------------------- -//shutdown -// -//----------------------------------------------------------------- - -void CIAO_RepositoryManagerDaemon_i::shutdown () - - ACE_THROW_SPEC (( - CORBA::SystemException - )) +CIAO::RepositoryManager_Impl::~RepositoryManager_Impl () { - - this->names_.unbind_all (); - this->uuids_.unbind_all (); - - this->the_orb_->shutdown (0); } - -//----------------------------------------------------------------- -//installPackage -// -//----------------------------------------------------------------- - -void CIAO_RepositoryManagerDaemon_i::installPackage ( - const char * installationName, - const char * location - ) - ACE_THROW_SPEC (( - CORBA::SystemException, - ::Deployment::NameExists, - ::Deployment::PackageError - )) +void +CIAO::RepositoryManager_Impl:: +installPackage (const char* installation_name, + const char* location + ACE_ENV_ARG_DECL) + ACE_THROW_SPEC ((CORBA::SystemException, + Deployment::NameExists, + Deployment::PackageError)) { - - PCEntry *entry = 0; - - if (this->names_.find (ACE_CString (installationName), entry) == 0) - ACE_THROW (Deployment::NameExists ()); - - //Now lets form the path for the local file - //NOTE: I need the absolute path because I will change to a subdirectory - //when I am parsing the descriptors - - ACE_CString path (this->install_root_); - path += "/"; - path += installationName; - - ACE_CString package_path (path); - package_path += ".cpk"; //package extension - - ACE_CString pc_path (path); - pc_path += PC_EXTENSION; //external PackageConfiguration extension - - - ACE_CString descriptor_dir (path); - descriptor_dir += "/descriptors/"; //location of the descriptor directory - - - //check if URL or local file - //download or load into memory - - size_t length = 0; - - if (ACE_OS::strstr (location, "http://")) + try { - - //TODO: how can I incorporate a Auto_Ptr is explicit release is needed - ACE_Message_Block* mb; - ACE_NEW_THROW_EX (mb, ACE_Message_Block (), CORBA::INTERNAL ()); - ACE_CHECK_RETURN (0); - - //get the remote file - if (!HTTP_Get (location, *mb)) - { - mb->release (); - ACE_THROW (CORBA::INTERNAL ()); - } - - // Write file to designated location on disk - if (!RM_Helper::write_to_disk (package_path.c_str (), *mb)) - { - mb->release (); - ACE_THROW (CORBA::INTERNAL ()); - } - - mb->release (); + xercesc::XMLPlatformUtils::Initialize(); } - else - { - CORBA::Octet* file = 0; - - //read the package from disk and store in the RM directory - //see if you can substiture this with a memory mapped file - //for better perofrmance (mimic zero copy here) - file = RM_Helper::read_from_disk (location, length); - - if (!file) - ACE_THROW (CORBA::INTERNAL ()); - - //Store the package in the local RM dir for future retrieval - if (!RM_Helper::write_to_disk (package_path.c_str (), file, length)) + catch (const XMLException& xml_e) { - delete file; - ACE_THROW (CORBA::INTERNAL ()); - } - - //NOTE: MEMORY LEAK UNLESS delete file; change to Auto_Ptr - delete file; + char* message = XMLString::transcode (xml_e.getMessage()); + ACE_Auto_Basic_Array_Ptr<char> cleanup_message (message); + ACE_DEBUG ((LM_DEBUG, "Error during initialization : %s\n", message)); + return; } - - - ZIP_Wrapper::uncompress (const_cast<char*> (package_path.c_str ()), - const_cast<char*> (this->install_root_.c_str ()), - false //not verbose - ); - - //Start the parsing - - ACE_CString pc_name; - - this->find_PC_name (const_cast<char*> (package_path.c_str ()), pc_name); - - //if the PackageConfiguration name cannot be found, then there is nothing to install - if (pc_name == "") - ACE_THROW (Deployment::PackageError ()); - - - //TODO: move exception throwing out of this func. User boolean error handling!!! - //TODO: check for errors! - Deployment::PackageConfiguration_var pc; - pc = this->retrieve_PC_from_descriptors (const_cast<char*> (pc_name.c_str ()), - descriptor_dir.c_str ()); - - - //forming the server path info - ACE_CString server_path (this->HTTP_server_); - server_path += installationName; - server_path += "/implementations/"; - - //NOTE: ComponentPackageReferences are currently NOT supported - if (!(pc->basePackage.length () > 0)) - ACE_THROW (CORBA::NO_IMPLEMENT ()); - - PC_Updater updater (server_path, package_path); - - if (!updater.update (pc)) + try { - ACE_DEBUG ((LM_ERROR, "[RM] problem updating the PackageConfiguration!\n")); - remove_extracted_package (package_path.c_str (), path.c_str ()); - remove (package_path.c_str ()); - ACE_THROW (Deployment::PackageError ()); - } - - - //now lets externalize the PackageConfiguration, so that we can access it later on - //without having to do the whole parsing again. - //NOTE: Order here is important. Do not populate maps before the externalization! - RM_Helper::externalize (pc, pc_path.c_str ()); - - //insert the package into the database - if (this->names_.bind (ACE_CString (installationName), path) == -1) - { - ACE_DEBUG ((LM_ERROR, - "[RM] could not bind %s.\n", - installationName)); - - //clean the extracted files - remove_extracted_package (package_path.c_str (), path.c_str ()); - //remove the package - remove (package_path.c_str ()); - //remove the PackageConfiguration externalization - remove (pc_path.c_str ()); - - //throw exception - ACE_THROW (CORBA::INTERNAL ()); - } - - //ALSO NEED THE UUID here - if (this->uuids_.bind (ACE_CString (pc->UUID), path) == -1) - { - ACE_DEBUG ((LM_ERROR, - "[RM] could not bind %s.\n", - pc->UUID)); - - //unbind the name - this->names_.unbind (installationName); - - //clean the extracted files - remove_extracted_package (package_path.c_str (), path.c_str ()); - //remove the package - remove (package_path.c_str ()); - //remove the PackageConfiguration externalization - remove (pc_path.c_str ()); - - //throw exception - ACE_THROW (CORBA::INTERNAL ()); - } - -#if defined ASSEMBLY_INTERFACE_SUPPORT - //now add the type interface - //TODO: CHECK if successful - if(!this->add_type (pc, installationName)) - ACE_DEBUG ((LM_ERROR, "Failed to add the type\n")); -#endif - - this->dump (); - - ACE_DEBUG ((LM_INFO, - "Installed PackageConfiguration \n\tname: %s \n\tuuid: %s\n", - installationName, pc->UUID)); -} - + CIAO::Config_Handler::Config_Error_Handler tpd_err_handler; + CIAO::Config_Handler::Config_Error_Handler pc_err_handler; + auto_ptr<DOMBuilder> tpd_parser (CIAO::Config_Handler::Utils:: + create_parser ()); + tpd_parser->setErrorHandler(&tpd_err_handler); + DOMDocument* tpd_doc = tpd_parser->parseURI (location); -//----------------------------------------------------------------- -//createPackage -// -//----------------------------------------------------------------- - -void CIAO_RepositoryManagerDaemon_i::createPackage ( - const char * installationName, - const ::Deployment::PackageConfiguration & package, - const char * baseLocation, - ::CORBA::Boolean replace - ) - ACE_THROW_SPEC (( - CORBA::SystemException, - ::Deployment::NameExists, - ::Deployment::PackageError - )) -{ - ACE_THROW (CORBA::NO_IMPLEMENT ()); -} - - -//----------------------------------------------------------------- -//findPackageByName -// -//----------------------------------------------------------------- - -::Deployment::PackageConfiguration* -CIAO_RepositoryManagerDaemon_i::findPackageByName (const char * name) - - ACE_THROW_SPEC (( - CORBA::SystemException, - ::Deployment::NoSuchName - )) -{ - // Find out if the PackageConfiguration was installed in the repository, - // return it if found or throw and exception otherwise - - PCEntry *entry = 0; - - if (this->names_.find (ACE_CString (name), entry) != 0) - ACE_THROW (Deployment::NoSuchName ()); - //PackageConfiguration was not found - - ACE_CString pc_path (entry->int_id_.c_str ()); - pc_path += PC_EXTENSION; - - Deployment::PackageConfiguration_var pc; - ACE_NEW_THROW_EX (pc, - Deployment::PackageConfiguration (), - CORBA::INTERNAL ()); - - ACE_CHECK_RETURN (0); - - if(!RM_Helper::reincarnate (pc, pc_path.c_str ())) - ACE_THROW_RETURN (CORBA::INTERNAL (), 0); - - ACE_DEBUG ((LM_INFO, "Successfully looked up \'%s\'.\n", name)); - - return pc._retn (); -} - - -//----------------------------------------------------------------- -//findPackageByUUID -// -//----------------------------------------------------------------- - -::Deployment::PackageConfiguration* -CIAO_RepositoryManagerDaemon_i::findPackageByUUID (const char * UUID) - - ACE_THROW_SPEC (( - CORBA::SystemException, - ::Deployment::NoSuchName - )) -{ - // Find out if the PackageConfiguration was installed in the repository, - // return it if found or throw and exception otherwise - - PCEntry *entry = 0; - - if (this->uuids_.find (ACE_CString (UUID), entry) != 0) - ACE_THROW (Deployment::NoSuchName ()); - //PackageConfiguration was not found - - ACE_CString pc_path (entry->int_id_.c_str ()); - pc_path += PC_EXTENSION; - - Deployment::PackageConfiguration_var pc; - ACE_NEW_THROW_EX (pc, - Deployment::PackageConfiguration (), - CORBA::INTERNAL ()); - - ACE_CHECK_RETURN (0); - - if(!RM_Helper::reincarnate (pc, pc_path.c_str ())) - ACE_THROW_RETURN (CORBA::INTERNAL (), 0); - - ACE_DEBUG ((LM_INFO, "Successfully looked up %s.\n", UUID)); - - return pc._retn (); -} - -//----------------------------------------------------------------- -//findPackageByType -// -//----------------------------------------------------------------- - -::CORBA::StringSeq * CIAO_RepositoryManagerDaemon_i::findNamesByType ( - const char * type - ) - ACE_THROW_SPEC (( - CORBA::SystemException - )) -{ - -#if !defined ASSEMBLY_INTERFACE_SUPPORT - ACE_THROW (CORBA::NO_IMPLEMENT ()); -#endif - -#if defined ASSEMBLY_INTERFACE_SUPPORT - - CIEntry *entry = 0; - - //find the type in the interface map - if (!this->types_.find (ACE_CString (type), entry)) - { - //return an empty sequence - CORBA::StringSeq_var seq; - ACE_NEW_THROW_EX (seq, CORBA::StringSeq (0), CORBA::INTERNAL ()); - ACE_CHECK_RETURN (0); - return seq._retn (); - } - else - { - //The CORBA::StringSeq is implemented as an array and growing - //one at a time on demand is very inefficient due to the - //deallocations and reallocations. This is why we figure out the - //number of elements in advance and then create a CORBA::StringSeq - //of the right length - - CIBucket_Iterator counter (this->types_, type); - - CIBucket_Iterator end (this->types_, - type, - 1 /*tail = true*/); + if (tpd_err_handler.getErrors()) + { + throw Deployment::PackageError (); + } - //count the number of components implementing this type - CORBA::ULong num_entries = 0; - for (; - counter != end; - ++counter) - ++num_entries; + CIAO::Config_Handler::TPD_Handler top_pc_handler + (tpd_doc, + DOMNodeFilter::SHOW_ELEMENT | + DOMNodeFilter::SHOW_TEXT); + ACE_TString package_location = top_pc_handler. + process_TopLevelPackageDescription (); - //allocate a sequence of the right length - CORBA::StringSeq_var seq; - ACE_NEW_THROW_EX (seq, - CORBA::StringSeq (num_entries), - CORBA::INTERNAL ()); + auto_ptr<DOMBuilder> pc_parser (CIAO::Config_Handler::Utils:: + create_parser ()); + pc_parser->setErrorHandler(&pc_err_handler); + DOMDocument* pc_doc = pc_parser->parseURI (package_location.c_str()); - ACE_CHECK_RETURN (0); + if (pc_err_handler.getErrors()) + { + throw Deployment::PackageError (); + } - //store the elements in the string sequence - CIBucket_Iterator iter (this->types_, type); - CORBA::ULong index = 0; - for (; - iter != end && index < num_entries; - ++iter, ++index) - { - CIEntry& element = *iter; - seq[index] = CORBA::string_dup (element.int_id_.c_str ()); + CIAO::Config_Handler::PC_Handler pc_handler (pc_doc, + DOMNodeFilter::SHOW_ELEMENT | + DOMNodeFilter::SHOW_TEXT); + Deployment::PackageConfiguration pc; + pc_handler.process_PackageConfiguration (pc); + //Deployment::DnC_Dump::dump (pc); + this->pc_table_.bind (installation_name, (pc)); + //Deployment::DnC_Dump::dump (*(&pc)); } - - return seq._retn (); - } - -#endif -} - - -//----------------------------------------------------------------- -//getAllNames -// -//----------------------------------------------------------------- - -::CORBA::StringSeq* -CIAO_RepositoryManagerDaemon_i::getAllNames () - - ACE_THROW_SPEC (( - CORBA::SystemException - )) -{ - //Map.current_size () gives you the current number with the duplicates - //Map.total_size () gives you the allocated space + the empty slots - //Apparently the only way to figure out the number of keys is to - //count them with an iterator. - - CORBA::ULong num_entries = 0; - - for (PCMap_Iterator i = this->names_.begin (); - i != this->names_.end (); - ++i) - ++num_entries; - - CORBA::StringSeq_var seq; - ACE_NEW_THROW_EX (seq, CORBA::StringSeq (num_entries), CORBA::INTERNAL ()); - - ACE_CHECK_RETURN (0); - - seq->length (num_entries); - - CORBA::ULong index = 0; - for (PCMap_Iterator iter = this->names_.begin (); - iter != this->names_.end () && index < num_entries; - ++iter, ++index) - { - CIEntry& element = *iter; - seq[index] = CORBA::string_dup (element.ext_id_.c_str ()); - } - - ACE_DEBUG ((LM_INFO, "Current # packages [ %d ]\n", seq->length ())); - - return seq._retn (); //release the underlying CORBA::StringSeq -} - - -//----------------------------------------------------------------- -//getAllTypes -// -//----------------------------------------------------------------- - -::CORBA::StringSeq * CIAO_RepositoryManagerDaemon_i::getAllTypes ( - - ) - ACE_THROW_SPEC (( - CORBA::SystemException - )) -{ - -#if !defined ASSEMBLY_INTERFACE_SUPPORT - ACE_THROW (CORBA::NO_IMPLEMENT ()); -#endif - -#if defined ASSEMBLY_INTERFACE_SUPPORT - - //Map.current_size () gives you the current number with the duplicates - //Map.total_size () gives you the allocated space + the empty slots - //Apparently the only way to figure out the number of keys is to - //count them with an iterator. - - CORBA::ULong num_entries = 0; - - for (PCMap_Iterator i = this->names_.begin (); - i != this->names_.end (); - ++i) - ++num_entries; - - ACE_DEBUG ((LM_DEBUG, "# names: %d\n", num_entries)); - - - CORBA::StringSeq_var seq; - ACE_NEW_THROW_EX (seq, - CORBA::StringSeq (num_entries), - CORBA::INTERNAL ()); - - ACE_CHECK_RETURN (0); - - seq->length (num_entries); - - CORBA::ULong index = 0; - for (CIMap_Iterator iter = this->types_.begin (); - iter != this->types_.end () && index < num_entries; - ++iter, ++index) - - { - CIEntry& element = *iter; - seq[index] = CORBA::string_dup (element.int_id_.c_str ()); - } - - return seq._retn (); //release the underlying CORBA::StringSeq - -#endif -} - - -//----------------------------------------------------------------- -//DeletePackage -// -//----------------------------------------------------------------- - -void CIAO_RepositoryManagerDaemon_i::deletePackage ( - const char * installationName - ) - ACE_THROW_SPEC (( - CORBA::SystemException, - ::Deployment::NoSuchName - )) -{ - bool internal_err = false; - - PCEntry *entry = 0; - - if (this->names_.find (ACE_CString (installationName), entry) != 0) - ACE_THROW (Deployment::NoSuchName ()); - - //cache the package path - ACE_CString path (entry->int_id_.c_str ()); - - //remove the name association - if (this->names_.unbind (installationName) == -1) - { - ACE_DEBUG ((LM_ERROR, - "Unable to unbind %s.\n", - installationName)); - internal_err = true; - } - - //the package location - ACE_CString package_path (path); - package_path += ".cpk"; //package extension - - //the PackageConfiguration externalization location - ACE_CString pc_path (path); - pc_path += PC_EXTENSION; //external PackageConfiguration extension - - Deployment::PackageConfiguration_var pc; - ACE_NEW_THROW_EX (pc, - Deployment::PackageConfiguration (), - CORBA::INTERNAL ()); - - ACE_CHECK_RETURN (0); - - if(!RM_Helper::reincarnate (pc, pc_path.c_str ())) - { - ACE_DEBUG ((LM_ERROR, "Could not reincarnate PC\n")); - internal_err = true; - } - - //if (this->uuids_.find (ACE_CString (pc->UUID), entry) != 0) - //{ - // ACE_DEBUG ((LM_ERROR, "Could not remove UUID\n")); - // internal_err = true; - //} - //else - // //remove the UUID association - // this->uuids_.unbind (entry->int_id_.c_str ()); - - if (this->uuids_.unbind (ACE_CString (pc->UUID)) == -1) - { - ACE_DEBUG ((LM_ERROR, "Could not remove UUID\n")); - internal_err = true; - } - -#if defined ASSEMBLY_INTERFACE_SUPPORT - //remove the type from the interface map - if (!this->remove_type (pc, installationName)) - { - ACE_DEBUG ((LM_ERROR, "Could not remove type\n")); - internal_err = true; - } -#endif - - //actually delete the package here! - - //clean the extracted files - remove_extracted_package (package_path.c_str (), path.c_str ()); - //remove the package - remove (package_path.c_str ()); - //remove the PackageConfiguration externalization - remove (pc_path.c_str ()); - - this->dump (); - - if (internal_err) - ACE_THROW (CORBA::INTERNAL ()); - else - ACE_DEBUG ((LM_INFO, "Successfully deleting \'%s\'\n", installationName)); - -} - - - - - -//==========================================HELPER METHODS================================================== - -Deployment::PackageConfiguration* -CIAO_RepositoryManagerDaemon_i::retrieve_PC_from_package (char* package) -{ - char temp[128]; - // ACE_thread_t thread_id = ACE_Thread::self (); - char* PID = ACE_OS::itoa (ACE_OS::getpid (), temp, 10); - - ACE_OS::mkdir(PID); - //if dir already exists a -1 is returned - //we ignore this, just need to make sure the directory exists - - //change the working dir - ACE_OS::chdir (PID); - - ACE_CString pcd_name; - //extract the necessary descriptors - if (extract_descriptor_files (package, - pcd_name) < 0) + catch (CORBA::Exception& ex) { - ACE_OS::chdir (this->cwd_); - ACE_ERROR ((LM_ERROR, - "(%P|%t) RepositoryManager: error extracting necessary files\n")); - ACE_THROW (CORBA::INTERNAL ()); + ACE_PRINT_EXCEPTION (ex, "Caught CORBA Exception: "); + return; } - - Deployment::PackageConfiguration_var pc; - //parse the PCD to make sure that there are no package errors - ACE_TRY + catch (const DOMException& e) { - CIAO::Config_Handlers::STD_PC_Intf intf (pcd_name.c_str ()); + const unsigned int maxChars = 2047; + XMLCh errText[maxChars + 1]; - pc = intf.get_PC (); + ACE_ERROR ((LM_ERROR, "\nException occured while parsing %s: \ + \n",location)); + ACE_ERROR ((LM_ERROR, "DOMException code: %d\n ", e.code)); + if (DOMImplementation::loadDOMExceptionMsg (e.code, errText, maxChars)) + { + char* message = XMLString::transcode (errText); + ACE_Auto_Basic_Array_Ptr<char> cleanup_message (message); + ACE_ERROR ((LM_ERROR, "Message is: %s\n", message)); + } + ACE_ERROR ((LM_ERROR, "Caught DOM exception\n")); + return; } - ACE_CATCHALL + catch (...) { - ACE_ERROR ((LM_ERROR, - "(%P|%t) RepositoryManager: Error parsing the PCD\n")); - - //change back the the old working dir - ACE_OS::chdir (this->cwd_); - ACE_THROW (Deployment::PackageError ()); + ACE_ERROR ((LM_ERROR, "Caught unknown exception\n")); + return; } - ACE_ENDTRY; - //able to parse the PC. So lets install the package in the repo - - //we no longer need the descriptors, so lets erase them! - remove_descriptor_files (package); - - //change back the the old working dir - ACE_OS::chdir (this->cwd_); - - //now lets erase the directory! - ACE_OS::rmdir (PID); - //the ACE_OS::rmdir does not work. Possibly because we need to delete - //the contents first. I will look into it more closely when I am back. - - return pc._retn (); } - -//function to retvieve a file via HTTP -//stores the file in the passed preallocated ACE_Message_Block -//returns 1 on success -// 0 on error - -int CIAO_RepositoryManagerDaemon_i::HTTP_Get (const char* URL, ACE_Message_Block &mb) +void +CIAO::RepositoryManager_Impl:: +createPackage (const char*, + const Deployment::PackageConfiguration&, + const char*, + CORBA::Boolean + ACE_ENV_ARG_DECL) + ACE_THROW_SPEC ((CORBA::SystemException, + Deployment::NameExists, + Deployment::PackageError)) { - URL_Parser *parser = TheURL_Parser::instance (); - if (!parser->parseURL (const_cast<char*> (URL))) - return 0; - - // Create a client - HTTP_Client client; - - // Open the client - if (client.open (parser->filename_, - parser->hostname_, - parser->port_) == -1) - { - client.close (); - return 0; - } - - // Read from it - if (client.read (&mb) <= 0) - { - client.close (); - return 0; - } - - return 1; + ACE_THROW (CORBA::NO_IMPLEMENT ()); } - - -//function to parse and return the PackageConfiguration from the already -//extracted descriptor files Deployment::PackageConfiguration* -CIAO_RepositoryManagerDaemon_i::retrieve_PC_from_descriptors (const char* pc_name, - const char* descriptor_dir) -{ - //change the working dir - ACE_OS::chdir (descriptor_dir); - - Deployment::PackageConfiguration_var pc; - //parse the PCD to make sure that there are no package errors - ACE_TRY - { - CIAO::Config_Handlers::STD_PC_Intf intf (pc_name); - - pc = intf.get_PC (); +CIAO::RepositoryManager_Impl::findPackageByName (const char* name + ACE_ENV_ARG_DECL) + ACE_THROW_SPEC ((CORBA::SystemException, + Deployment::NoSuchName)) +{ + Deployment::PackageConfiguration pc; + if (pc_table_.find (name, pc) == 0) + { + //Deployment::PackageConfiguration* dup_pc = pc; + //Deployment::DnC_Dump::dump (*pc); + //return dup_pc; + Deployment::PackageConfiguration_var pc_var = 0; + ACE_NEW_THROW_EX (pc_var, + Deployment::PackageConfiguration (pc), + CORBA::NO_MEMORY ()); + //Deployment::DnC_Dump::dump (*pc_var); + return pc_var._retn (); } - ACE_CATCHALL - { - ACE_ERROR ((LM_ERROR, - "(%P|%t) [RM::retrieve_PC_from_descriptors] Error parsing the PCD\n")); - - //change back the the old working dir - ACE_OS::chdir (this->cwd_); - ACE_THROW (Deployment::PackageError ()); - } - ACE_ENDTRY; - //able to parse the PC. So lets install the package in the repo - - //change back the the old working dir - ACE_OS::chdir (this->cwd_); - - return pc._retn (); -} - - -//find out what the name of the PackageConfiguration file is -void CIAO_RepositoryManagerDaemon_i::find_PC_name (char* package, ACE_CString& pcd_name) -{ - pcd_name = ""; //empty the contents of the ACE_CString - - //create a doubly link list - ACE_New_Allocator allocator; - ACE_Double_Linked_List<ZIP_File_Info> list (&allocator); - - //get the list of files in the package and figure out the names of all necessary files - if (!(ZIP_Wrapper::file_list_info (package, list))) - return; - - size_t skip_len = ACE_OS::strlen ("descriptors") + 1; - - while (!list.is_empty ()) + else { - ZIP_File_Info* inf = list.delete_head (); - - if (ACE_OS::strstr (inf->name_.c_str (), "descriptors")) - if (ACE_OS::strstr (inf->name_.c_str (), ".pcd")) - pcd_name = inf->name_.c_str () + skip_len; - - //deallocate the head of the filename list - delete inf; + ACE_THROW_RETURN (Deployment::NoSuchName (), 0); } } - -//We are using Xercesc in the Config_Handlers and unfortunately its API only -//takes a file in the local file system as an argument, thus need to -//write out the contents of the deployent plan to a file -//in the current directory. I use the thread id to guarrantee -//lack of race conditions if multithreading is enabled - -int CIAO_RepositoryManagerDaemon_i::extract_descriptor_files (char* package, ACE_CString& pcd_name) +Deployment::PackageConfiguration* +CIAO::RepositoryManager_Impl:: +findPackageByUUID (const char* + ACE_ENV_ARG_DECL) + ACE_THROW_SPEC ((CORBA::SystemException, + Deployment::NoSuchName)) { - //create a doubly link list - ACE_New_Allocator allocator; - ACE_Double_Linked_List<ZIP_File_Info> list (&allocator); - - //get the list of files in the package and figure out the names of all necessary files - if (!(ZIP_Wrapper::file_list_info (package, list))) - return 0; - - size_t skip_len = ACE_OS::strlen ("descriptors") + 1; - - while (!list.is_empty ()) - { - ZIP_File_Info* inf = list.delete_head (); - ACE_Message_Block* file = 0; - if (ACE_OS::strstr (inf->name_.c_str (), "descriptors")) - { - if (ACE_OS::strstr (inf->name_.c_str (), ".pcd")) - pcd_name = inf->name_.c_str () + skip_len; - - //extract the descriptor from the package - ACE_NEW_RETURN (file, ACE_Message_Block (0,0), 0); - if (!ZIP_Wrapper::get_file(const_cast<char*> (package), - const_cast<char*> (inf->name_.c_str ()), - *file)) - { - ACE_ERROR ((LM_ERROR, - "[RM::extract_descriptor_files] Unable to retrieve file!\n")); - //release the message block chain - file->release (); - return 0; - } - - - //write the file to disk - if(!RM_Helper::write_to_disk (inf->name_.c_str () + skip_len, *file)) - { - ACE_ERROR ((LM_ERROR, - "[RM::extract_descriptor_files] Unable to write out descriptor to disk!\n")); - //release the message block chain - file->release (); - return 0; - } - - //release the message block chain - file->release (); - } - - //deallocate the head of the filename list - delete inf; - } - - return 1; + ACE_THROW_RETURN (CORBA::NO_IMPLEMENT (), 0); } -int CIAO_RepositoryManagerDaemon_i::remove_descriptor_files (char* package) +CORBA::StringSeq* +CIAO::RepositoryManager_Impl:: +findNamesByType (const char* + ACE_ENV_ARG_DECL) + ACE_THROW_SPEC ((CORBA::SystemException)) { - int return_code = 1; - - //create a doubly link list - ACE_New_Allocator allocator; - ACE_Double_Linked_List<ZIP_File_Info> list (&allocator); - - //get the list of files in the package and figure out the names of all necessary files - if (!(ZIP_Wrapper::file_list_info (package, list))) - return 0; - - size_t skip_len = ACE_OS::strlen ("descriptors") + 1; - - while (!list.is_empty ()) - { - ZIP_File_Info* inf = list.delete_head (); - if (ACE_OS::strstr (inf->name_.c_str (), "descriptors")) - { - //delete disk - if(remove (inf->name_.c_str () + skip_len)) - { - ACE_ERROR ((LM_ERROR, - "[RM::remove_descriptor_files] Unable to write out descriptor to disk!\n")); - return_code = 0; - } - } - //deallocate the head of the filename list - delete inf; - } - - return return_code; + ACE_THROW_RETURN (CORBA::NO_IMPLEMENT (), 0); } -//function to remove the files extracted from the package upon istallation -//It reads the names of the files from the package. They correspond to the -//names on disk. It deletes each file, then it deletes the directories that -//contain them. -//return 1 on success -// 0 on error - -int CIAO_RepositoryManagerDaemon_i::remove_extracted_package -(const char* package_path, - const char* extraction_location) +CORBA::StringSeq* +CIAO::RepositoryManager_Impl:: +getAllNames (ACE_ENV_ARG_DECL) + ACE_THROW_SPEC ((CORBA::SystemException)) { - //change the working dir - if (ACE_OS::chdir (extraction_location) == -1) - ACE_ERROR_RETURN ((LM_ERROR, - "[RM::remove_extracted_package] Unable to chdir to doomed directory!\n"), - 0); - - int return_code = 1; - - //create a doubly link list - ACE_New_Allocator allocator; - ACE_Double_Linked_List<ZIP_File_Info> list (&allocator); - - //get the list of files in the package and figure out the names of all necessary files - if (!(ZIP_Wrapper::file_list_info (const_cast <char*> (package_path), list))) - { - //change back the the old working dir - ACE_OS::chdir (this->cwd_); - return 0; - } - - while (!list.is_empty ()) - { - ZIP_File_Info* inf = list.delete_head (); - - //delete file from disk - if(remove (inf->name_.c_str ())) - { - ACE_ERROR ((LM_ERROR, - "[RM::remove_extracted files] Unable to delete %s!\n", inf->name_.c_str ())); - return_code = 0; - } - - //deallocate the head of the filename list - delete inf; - } - - //now remove the descriptors and implementations directories. - ACE_OS::rmdir ("descriptors"); - ACE_OS::rmdir ("implementations"); - - //now go one directory up and delete the extraction directory - ACE_OS::chdir (this->install_root_.c_str ()); - ACE_OS::rmdir (extraction_location); - - //change back the the old working dir - ACE_OS::chdir (this->cwd_); - - return return_code; + ACE_THROW_RETURN (CORBA::NO_IMPLEMENT (), 0); } -#if defined ASSEMBLY_INTERFACE_SUPPORT - -//function to extract the type of the component from -//the PackageConfiguration and update the interface map -//returns 1 on success -// 0 on error - -int CIAO_RepositoryManagerDaemon_i::add_type (Deployment::PackageConfiguration& pc, - const char* name) +CORBA::StringSeq* +CIAO::RepositoryManager_Impl:: +getAllTypes (ACE_ENV_ARG_DECL) + ACE_THROW_SPEC ((CORBA::SystemException)) { - const char* ifaceUUID = 0; - // - if (pc.basePackage.length () > 0) - { - ifaceUUID = pc.basePackage[0] - .implementation[0] - .referencedImplementation - .implements - .specificType.in (); - //.UUID.in (); - - ACE_DEBUG ((LM_DEBUG, "storing under: %s\n", ifaceUUID)); - - CIEntry *entry = 0; - - //create an entry for this interface type - if (this->types_.bind (ACE_CString (ifaceUUID), - ACE_CString (name)/*pc.label.in ()*/ ) != 0) - return 0; - - } - else //ComponentPackageReference - { - //not implemented yet - return 0; - } - - return 1; + ACE_THROW_RETURN (CORBA::NO_IMPLEMENT (), 0); } - - -//function to remove the interface type of the component -//being removed from the interface map -//returns 1 on success -// 0 on error - -int CIAO_RepositoryManagerDaemon_i::remove_type (Deployment::PackageConfiguration& pc, - const char* name) +void +CIAO::RepositoryManager_Impl:: +deletePackage (const char* + ACE_ENV_ARG_DECL) + ACE_THROW_SPEC ((CORBA::SystemException, + Deployment::NoSuchName)) { - const char* ifaceUUID = 0; - // - if (pc.basePackage.length () > 0) - { - ifaceUUID = pc.basePackage[0] - .implementation[0] - .referencedImplementation - .implements - .specificType.in (); - //.UUID.in (); - - ACE_DEBUG ((LM_DEBUG, "removing by: %s\n", ifaceUUID)); - - CIEntry *entry = 0; - - //find the type in the interface map - if (this->types_.find (ACE_CString (ifaceUUID), entry) == 0) - { - ACE_DEBUG ((LM_DEBUG, "Type to be removed: ", - "KEY: %s", entry->ext_id_.c_str (), - " VAL: %s\n", entry->int_id_.c_str ())); - } - else - ACE_DEBUG ((LM_DEBUG, "Could not find type!\n")); - - ACE_DEBUG ((LM_DEBUG, "Attempting to remove: %s\n", ifaceUUID)); - CIBucket_Iterator iter (this->types_, ACE_CString (ifaceUUID)); - - CIBucket_Iterator end (this->types_, - ACE_CString (ifaceUUID), - 1 /*tail = true*/); - for (; - iter != end; - ++iter) - { - CIEntry& element = *iter; - - if(!(strcmp (element.int_id_.c_str (), name /*pc.label.in ()*/))) - { - //clashes are not allowed so this must be the ONLY - //element that we are interested in - - //lets remove this element - this->types_.unbind (&element); - return 1; - } - } - - } - else //ComponentPackageReference - { - //not implemented yet - return 0; - } - - return 1; + ACE_THROW (CORBA::NO_IMPLEMENT ()); } -#endif //for has ASSEMBLY_INTERFACE_SUPPORT - -//function to dump the state of the RepositoryManager -void CIAO_RepositoryManagerDaemon_i::dump (void) +void +CIAO::RepositoryManager_Impl::shutdown (ACE_ENV_SINGLE_ARG_DECL) + ACE_THROW_SPEC ((CORBA::SystemException)) { -#if defined (ACE_HAS_DUMP) - - ACE_DEBUG(LM_DEBUG, "NAMES:\n"); - this->names_.dump (); - ACE_DEBUG(LM_DEBUG, "UUIDs:\n"); - this->uuids_.dump (); - -#if defined ASSEMBLY_INTERFACE_SUPPORT - ACE_DEBUG (LM_DEBUG, "Component Interface Types:\n"); - this->types_.dump (); -#endif - -#endif /* ACE_HAS_DUMP */ + this->orb_->shutdown (1 ACE_ENV_SINGLE_ARG_PARAMETER); } - |