diff options
Diffstat (limited to 'TAO/orbsvcs/orbsvcs/Trader/Service_Type_Map.cpp')
| -rw-r--r-- | TAO/orbsvcs/orbsvcs/Trader/Service_Type_Map.cpp | 340 |
1 files changed, 0 insertions, 340 deletions
diff --git a/TAO/orbsvcs/orbsvcs/Trader/Service_Type_Map.cpp b/TAO/orbsvcs/orbsvcs/Trader/Service_Type_Map.cpp deleted file mode 100644 index 307edfa60a7..00000000000 --- a/TAO/orbsvcs/orbsvcs/Trader/Service_Type_Map.cpp +++ /dev/null @@ -1,340 +0,0 @@ -// $Id$ -#ifndef TAO_SERVICE_TYPE_MAP_C -#define TAO_SERVICE_TYPE_MAP_C - -#include "Service_Type_Map.h" -#include "Offer_Id_Iterator.h" - -template <class LOCK_TYPE> -TAO_Service_Type_Map<LOCK_TYPE>::TAO_Service_Type_Map (void) -{ -} - -template <class LOCK_TYPE> -TAO_Service_Type_Map<LOCK_TYPE>::~TAO_Service_Type_Map (void) -{ - ACE_WRITE_GUARD (LOCK_TYPE, ace_mon, this->db_lock_); - - for (Offer_Database::iterator type_iter (this->offer_db_); - ! type_iter.done (); - type_iter++) - { - Offer_Map_Entry& offer_map_entry = (*type_iter).int_id_; - - ACE_WRITE_GUARD (LOCK_TYPE, ace_mon, offer_map_entry.lock_); - delete offer_map_entry.offer_map_; - } -} - -template <class LOCK_TYPE> CosTrading::OfferId -TAO_Service_Type_Map<LOCK_TYPE>:: -insert_offer (const char* type, - const CosTrading::Offer& offer) -{ - CosTrading::OfferId return_value = 0; - Offer_Database::ENTRY* database_entry = 0; - TAO_String_Hash_Key service_type (type); - - ACE_READ_GUARD_RETURN (LOCK_TYPE, ace_mon, this->db_lock_, 0); - - if (this->offer_db_.find (service_type, database_entry) == -1) - { - // If there's no entry for the service type, create one. - - Offer_Map_Entry new_offer_map_entry; - ACE_NEW_RETURN (new_offer_map_entry.offer_map_, Offer_Map, 0); - new_offer_map_entry.counter_ = 1; - - this->db_lock_.release (); - { - // Add the new entry; upgrade lock. - ACE_WRITE_GUARD_RETURN (LOCK_TYPE, ace_mon, this->db_lock_, 0); - this->offer_db_.bind (service_type, new_offer_map_entry, database_entry); - } - this->db_lock_.acquire_read (); - } - - Offer_Map_Entry& offer_map_entry = database_entry->int_id_; - ACE_WRITE_GUARD_RETURN (LOCK_TYPE, ace_mon2, offer_map_entry.lock_, 0); - - // Add the offer to the service offer table for this service type. - offer_map_entry.offer_map_->bind (offer_map_entry.counter_, offer); - return_value = this->generate_offer_id (type, offer_map_entry.counter_); - offer_map_entry.counter_++; - - return return_value; -} - -template <class LOCK_TYPE> int -TAO_Service_Type_Map<LOCK_TYPE>:: -remove_offer (const char* type, CORBA::ULong id) -{ - if (this->db_lock_.acquire_read ()) - return -1; - - int return_value = -1; - Offer_Database::ENTRY* db_entry = 0; - TAO_String_Hash_Key service_type (type); - - if (this->offer_db_.find (service_type, db_entry) == 0) - { - Offer_Map_Entry& offer_map_entry = db_entry->int_id_; - ACE_WRITE_GUARD_RETURN (LOCK_TYPE, ace_mon, offer_map_entry.lock_, -1); - return_value = offer_map_entry.offer_map_->unbind (id); - } - - return return_value; -} - -template <class LOCK_TYPE> int -TAO_Service_Type_Map<LOCK_TYPE>:: -remove_offer (const CosTrading::OfferId offer_id, - CORBA::Environment& _env) - TAO_THROW_SPEC ((CosTrading::IllegalOfferId, - CosTrading::UnknownOfferId)) -{ - char* stype = 0; - CORBA::ULong index; - - this->parse_offer_id (offer_id, stype, index, _env); - TAO_CHECK_ENV_RETURN (_env, -1); - - if (this->remove_offer (stype, index) == -1) - TAO_THROW_RETURN (CosTrading::UnknownOfferId (offer_id), -1); - - return 0; -} - -template <class LOCK_TYPE> CosTrading::Offer* -TAO_Service_Type_Map<LOCK_TYPE>:: -lookup_offer (const CosTrading::OfferId offer_id, - char*& type_name, - CORBA::Environment& _env) - TAO_THROW_SPEC ((CosTrading::IllegalOfferId, - CosTrading::UnknownOfferId)) -{ - CORBA::ULong index; - CosTrading::Offer* offer = 0; - this->parse_offer_id (offer_id, type_name, index, _env); - TAO_CHECK_ENV_RETURN (_env, offer); - - if ((offer = this->lookup_offer (type_name, index)) == 0) - TAO_THROW_RETURN (CosTrading::UnknownOfferId (offer_id), offer); - - return offer; -} - - -template <class LOCK_TYPE> CosTrading::Offer* -TAO_Service_Type_Map<LOCK_TYPE>:: -lookup_offer (const CosTrading::OfferId offer_id, - CORBA::Environment& _env) - TAO_THROW_SPEC ((CosTrading::IllegalOfferId, - CosTrading::UnknownOfferId)) -{ - char* type_name; - CORBA::ULong index; - CosTrading::Offer* offer = 0; - - this->parse_offer_id (offer_id, type_name, index, _env); - TAO_CHECK_ENV_RETURN (_env, offer); - - if ((offer = this->lookup_offer (type_name, index)) == 0) - TAO_THROW_RETURN (CosTrading::UnknownOfferId (offer_id), offer); - - return offer; -} - -template <class LOCK_TYPE> CosTrading::Offer* -TAO_Service_Type_Map<LOCK_TYPE>:: -lookup_offer (const char* type, CORBA::ULong id) -{ - ACE_READ_GUARD_RETURN (LOCK_TYPE, ace_mon, this->db_lock_, 0); - - CosTrading::Offer* return_value = 0; - Offer_Database::ENTRY* db_entry = 0; - TAO_String_Hash_Key service_type (type); - - if (this->offer_db_.find (service_type, db_entry) == 0) - { - Offer_Map_Entry& offer_map_entry = db_entry->int_id_; - ACE_READ_GUARD_RETURN (LOCK_TYPE, ace_mon, offer_map_entry.lock_, 0); - - Offer_Map::ENTRY* offer_entry_ptr = 0; - offer_map_entry.offer_map_->find (id, offer_entry_ptr); - - return_value = &offer_entry_ptr->int_id_; - } - - return return_value; -} - -template <class LOCK_TYPE> TAO_Offer_Id_Iterator* -TAO_Service_Type_Map<LOCK_TYPE>::retrieve_all_offer_ids (void) -{ - // Fill an TAO_Offer_Id_Iterator with the offer_ids of all offers - // exported to the TAO_Service_Type_Map. Iterates through the entire - // map, cramming offer_id strings into a newly constructed - // TAO_Offer_Id_Iterator. - TAO_Offer_Id_Iterator* id_iterator = new TAO_Offer_Id_Iterator (); - ACE_READ_GUARD_RETURN (LOCK_TYPE, ace_mon, this->db_lock_, 0); - - for (Offer_Database::iterator type_iter (this->offer_db_); - ! type_iter.done (); - type_iter++) - { - const char* type_name = (*type_iter).ext_id_; - Offer_Map_Entry& offer_map_entry = (*type_iter).int_id_; - - ACE_READ_GUARD_RETURN (LOCK_TYPE, ace_mon, offer_map_entry.lock_, 0); - - for (Offer_Map::iterator offer_iter (*offer_map_entry.offer_map_); - ! offer_iter.done (); - offer_iter++) - { - CORBA::ULong offer_index = (*offer_iter).ext_id_; - CosTrading::OfferId offer_id = - this->generate_offer_id (type_name, offer_index); - - id_iterator->insert_id (offer_id); - } - } - - return id_iterator; -} - -template <class LOCK_TYPE> void -TAO_Service_Type_Map<LOCK_TYPE>:: -parse_offer_id (const CosTrading::OfferId offer_id, - char*&service_type, - CORBA::ULong& id, - CORBA::Environment& _env) - TAO_THROW_SPEC ((CosTrading::IllegalOfferId)) -{ - // Get service type: it is everything from 17th character to the end. - service_type = (char *) offer_id + 16; - - // Get id: temporarily put the end of string character where the service - // type starts, convert to number, replace the character back. - char &start_of_type = (char) *(offer_id + 16); - char temp = start_of_type; - start_of_type = '\0'; - id = ACE_OS::atoi (offer_id); - - start_of_type = temp; - - if (! TAO_Trader_Base::is_valid_identifier_name (service_type)) - TAO_THROW (CosTrading::IllegalOfferId (offer_id)); -} - -template <class LOCK_TYPE> CosTrading::OfferId -TAO_Service_Type_Map<LOCK_TYPE>:: -generate_offer_id (const char *service_type_name, CORBA::ULong id) -{ - // holds final id string. - int total_size = 16 + ACE_OS::strlen (service_type_name); - - // hold portions of id string. - CosTrading::OfferId offer_id = CORBA::string_alloc (total_size); - char* return_value = 0; - ACE_OS::sprintf (offer_id, "%016u%s", (CORBA::ULong) id, service_type_name); - - return_value = CORBA::string_dup (offer_id); - delete [] offer_id; - - return return_value; -} - - -template <class LOCK_TYPE> -TAO_Service_Offer_Iterator<LOCK_TYPE>:: -TAO_Service_Offer_Iterator (const char* type, - TAO_Service_Type_Map<LOCK_TYPE>& offer_database) - : stm_ (offer_database), - entry_ (0), - offer_iter_ (0), - type_ (type) -{ - TAO_String_Hash_Key service_type (type); - - if (this->stm_.db_lock_.acquire_read () == -1) - ; - - Service_Type_Map::Offer_Database::ENTRY* db_entry; - if (this->stm_.offer_db_.find (service_type, db_entry) == -1) - return; - else - { - this->entry_ = &db_entry->int_id_; - if (this->entry_->lock_.acquire_read () == -1) - ; - - ACE_NEW (offer_iter_, - Service_Type_Map::Offer_Map::iterator (*this->entry_->offer_map_)); - } -} - -template <class LOCK_TYPE> -TAO_Service_Offer_Iterator<LOCK_TYPE>::~TAO_Service_Offer_Iterator (void) -{ - if (this->stm_.db_lock_.release () == -1) - ; - - if (this->entry_ != 0) - { - if (this->entry_->lock_.release () == -1) - ; - - delete this->offer_iter_; - } -} - -template <class LOCK_TYPE> CosTrading::OfferId -TAO_Service_Offer_Iterator<LOCK_TYPE>::get_id (void) -{ - return (this->offer_iter_ != 0) - ? TAO_Service_Type_Map<LOCK_TYPE>::generate_offer_id (this->type_, (**this->offer_iter_).ext_id_) - : 0; -} - -template <class LOCK_TYPE> int -TAO_Service_Offer_Iterator<LOCK_TYPE>::has_more_offers (void) -{ - return (this->offer_iter_ != 0) ? ! this->offer_iter_->done () : 0; -} - - -template <class LOCK_TYPE> CosTrading::Offer* -TAO_Service_Offer_Iterator<LOCK_TYPE>::get_offer (void) -{ - return (this->offer_iter_ != 0) ? &(**this->offer_iter_).int_id_ : 0; -} - -template <class LOCK_TYPE> void -TAO_Service_Offer_Iterator<LOCK_TYPE>::next_offer (void) -{ - if (this->offer_iter_ != 0) - this->offer_iter_->advance (); -} - -/* -ACE_Hash_Map_Entry<CORBA::ULong, CosTrading::Offer>:: -ACE_Hash_Map_Entry (ACE_Hash_Map_Entry<CORBA::ULong, CosTrading::Offer> *next, - ACE_Hash_Map_Entry<CORBA::ULong, CosTrading::Offer> *prev) - : ext_id_ (0), - next_ (next), - prev_ (prev) -{ -} - -u_long -ACE_Hash_Map_Manager<CORBA::ULong, CosTrading::Offer, ACE_Null_Mutex>:: -hash (const CORBA::ULong &ext_id) -{ - return ext_id; - //return 0; -} -*/ - -#endif /* TAO_SERVICE_TYPE_MAP_C */ - |