diff options
Diffstat (limited to 'TAO/examples/Callback_Quoter/Notifier_i.cpp')
| -rw-r--r-- | TAO/examples/Callback_Quoter/Notifier_i.cpp | 284 |
1 files changed, 0 insertions, 284 deletions
diff --git a/TAO/examples/Callback_Quoter/Notifier_i.cpp b/TAO/examples/Callback_Quoter/Notifier_i.cpp deleted file mode 100644 index cf9bf752b61..00000000000 --- a/TAO/examples/Callback_Quoter/Notifier_i.cpp +++ /dev/null @@ -1,284 +0,0 @@ -// $Id$ - -// =========================================================== -// -// = LIBRARY -// TAO/examples/Callback_Quoter -// -// = FILENAME -// Notifier_i.cpp -// -// = DESCRIPTION -// Implementation of the Notifier_i class. This class is the servant -// object for the callback quoter server. -// -// = AUTHOR -// Kirthika Parameswaran <kirthika@cs.wustl.edu> -// -// =========================================================== - -#include "Notifier_i.h" -#include "ace/OS.h" -#include "tao/Exception.h" -#include "tao/try_macros.h" - - -Notifier_i::Notifier_i (void) - : notifier_exited_(0) -{ - // No-op -} - -Notifier_i::~Notifier_i (void) -{ - // No-op -} - -// Register a distributed callback handler that is invoked when the -// given stock reaches the desired threshold value. - -void -Notifier_i::register_callback (const char *stock_name, - CORBA::Long threshold_value, - Callback_Quoter::Consumer_ptr consumer_handler, - CORBA::Environment &_env) -{ - // Store the client information. - Consumer_Data consumer_data; - - // Necessary to make another copy of the consumer_handler using - // <_duplicate> so that we dont lose the consumer object reference - // after the method invocation is done. - consumer_data.consumer_ = - Callback_Quoter::Consumer::_duplicate (consumer_handler); - - consumer_data.desired_value_= threshold_value; - - CONSUMERS *consumers = 0; - - // The consumer_map consists of the stockname and various consumers - // with their threshold values. To register a consumer into this - // map, first the stockname is matched with an existing one (if any) - // and the consumer and the threshold value is attached. Else, a new - // entry is created for the stockname. - - if (this->consumer_map_.find (stock_name, consumers) == 0) - { - if ( consumers->insert (consumer_data) == -1) - _env.exception (new Callback_Quoter::Invalid_Stock - ("Insertion failed! Invalid Stock!\n")); - else - ACE_DEBUG ((LM_DEBUG, - "Inserted map entry: stockname %s threshold %d", - stock_name, - threshold_value)); - } - else - { - ///*done*/ @@ Make sure to use the ACE_NEW_THROW macro, which works with - // CORBA exceptions... - - - // the unbounded set entry is created. - // NOTE:: its pathetic, but to make this macro call its necessary to name - // your environment variable _env - ACE_NEW_THROW (consumers, CONSUMERS, CORBA::NO_MEMORY (CORBA::COMPLETED_NO)); - - // When a new entry is tried to be inserted into the unbounded set and it - // fails an exception is raised. - if (consumers->insert (consumer_data) == -1) - _env.exception (new Callback_Quoter::Invalid_Stock - ("Insertion failed! Invalid Stock!\n")); - - // The bond between the stockname <hash_key> and the consumers <hash_value> - // is fused. - if (this->consumer_map_.bind (stock_name, consumers) == -1) - ACE_ERROR ((LM_ERROR, - "register_callback: Bind failed!/n")); - else - ACE_DEBUG ((LM_DEBUG, - "new map entry: stockname %s threshold %d\n", - stock_name, - threshold_value)); - - } -} - -// Obtain a pointer to the orb. - -void -Notifier_i::orb (CORBA::ORB_ptr orb) -{ - this->orb_ = orb; -} - -// Remove the client handler. - -void -Notifier_i::unregister_callback (Callback_Quoter::Consumer_ptr consumer, - CORBA::Environment &env) -{ - // The consumer_map consists of a map of stocknames with consumers - // and their threshold values attached to it. To unregister a - // consumer it is necessary to remove that entry from the - // map. Hence, the map is iterated till the consumer entry to be - // removed is found and then removed from the map. - - // Check to see whether the hash_map still exists. Chances are there - // that the notifier has exited closing the hash map. - if (notifier_exited_ == 1) - return; - - for (CONSUMER_MAP::ITERATOR iter = this->consumer_map_.begin (); - iter != this->consumer_map_.end (); - ++iter) - { - // The *iter is nothing but the stockname + unbounded set of - // consumers+threshold values, i.e a ACE_Hash_Map_Entry. - - Consumer_Data consumer_to_remove; - - consumer_to_remove.consumer_ = - Callback_Quoter::Consumer::_duplicate (consumer); - - // int_id is a member of the ACE_Hash_Map_Entry. The remove - // method will do a find internally using operator == which - // will check only the consumer pointers. If match found it - // will be removed from the set. If the consumer cannot be - // removed an exception is raised. - - if ((*iter).int_id_->remove (consumer_to_remove) == -1) - env.exception (new Callback_Quoter::Invalid_Handle - ("Unregistration failed! Invalid Consumer Handle!\n")); - - else - ACE_DEBUG ((LM_DEBUG, - "unregister_callback:consumer removed\n")); - } -} - -// Gets the market status and sends the information to the consumer -// who is interested in it. - -void -Notifier_i::market_status (const char *stock_name, - CORBA::Long stock_value, - CORBA::Environment &env) -{ - ACE_DEBUG ((LM_DEBUG, - "Notifier_i:: The stockname is %s with price %d\n", - stock_name, - stock_value)); - - CONSUMERS *consumers; - - if (this->consumer_map_.find (stock_name, consumers) == 0) - { - // Go through the list of <Consumer_Data> to find which - // registered client wants to be notified. - - for (CONSUMERS::ITERATOR iter = consumers->begin (); - iter != consumers->end (); - ++iter) - { - // Check whether the stockname is equal before proceeding - // further. - if (stock_value >= (*iter).desired_value_) - { - Callback_Quoter::Info interested_consumer_data; - - interested_consumer_data.stock_name = - CORBA::string_dup (stock_name); - interested_consumer_data.value = - stock_value; - - ACE_DEBUG ((LM_DEBUG, - "pushing information to consumer\n")); - - // The status desired by the consumer is then passed to - // it. - (*iter).consumer_->push (interested_consumer_data); - } - } - } - else - ACE_DEBUG ((LM_DEBUG, - " Stock Not Present!\n")); - // Raising an exception caused problems as they were caught by the Market daemon - // who exited prematurely. - - // /*done*/@@ Please add a user defined exception called something like - // NOT_FOUND. - - // Exception is raised when the stock doesnt exist in the Hash_map. - // env.exception (new Callback_Quoter::Invalid_Stock (" Nonexistent Stock")); - // stock_name, - // stock_value); -} - -void -Notifier_i::shutdown (CORBA::Environment &env) -{ - if ( this->consumer_map_.close () > 0) - ACE_ERROR ((LM_ERROR, - "Consumer_map_close error!\n")); - else - // This marks the exit of the notifier. This should be taken care of - // before the consumer tries to unregister after the notifier quits. - notifier_exited_ = 1; - - ACE_DEBUG ((LM_DEBUG, - "The Callback Quoter server is shutting down...\n")); - - - // Instruct the ORB to shutdown. - this->orb_->shutdown (); - -} - -int -Notifier_i::Consumer_Data::operator== (const Consumer_Data &rhs) -{ - // The <_is_equivalent> function checks if the _var and _ptr objects - // are the same. NOTE: this call might not behave well on other - // ORBs since <_is_equivalent> isn't guaranteed to differentiate - // object references. - - return this->consumer_->_is_equivalent (rhs.consumer_.in ()); -} - -#if defined (ACE_HAS_EXPLICIT_TEMPLATE_INSTANTIATION) - -template class ACE_Node<Notifier_i::Consumer_Data>; -template class ACE_Unbounded_Set<Notifier_i::Consumer_Data>; -template class ACE_Unbounded_Set_Iterator<Notifier_i::Consumer_Data>; - -template class ACE_Hash_Map_Entry<ACE_CString,ACE_Unbounded_Set<Notifier_i::Consumer_Data>*>; -template class ACE_Hash<ACE_CString>; -template class ACE_Equal_To<ACE_CString>; -template class ACE_Hash_Map_Manager<ACE_CString,ACE_Unbounded_Set<Notifier_i::Consumer_Data>*,ACE_Null_Mutex>; -template class ACE_Hash_Map_Manager_Ex<ACE_CString, ACE_Unbounded_Set<Notifier_i::Consumer_Data>*, ACE_Hash<ACE_CString>, ACE_Equal_To<ACE_CString>, ACE_Null_Mutex>; -template class ACE_Hash_Map_Iterator_Base_Ex<ACE_CString, ACE_Unbounded_Set<Notifier_i::Consumer_Data>*, ACE_Hash<ACE_CString>, ACE_Equal_To<ACE_CString>, ACE_Null_Mutex>; -template class ACE_Hash_Map_Iterator<ACE_CString,ACE_Unbounded_Set<Notifier_i::Consumer_Data>*,ACE_Null_Mutex>; -template class ACE_Hash_Map_Iterator_Ex<ACE_CString, ACE_Unbounded_Set<Notifier_i::Consumer_Data>*, ACE_Hash<ACE_CString>, ACE_Equal_To<ACE_CString>, ACE_Null_Mutex>; -template class ACE_Hash_Map_Reverse_Iterator<ACE_CString,ACE_Unbounded_Set<Notifier_i::Consumer_Data>*,ACE_Null_Mutex>; -template class ACE_Hash_Map_Reverse_Iterator_Ex<ACE_CString, ACE_Unbounded_Set<Notifier_i::Consumer_Data>*, ACE_Hash<ACE_CString>, ACE_Equal_To<ACE_CString>, ACE_Null_Mutex>; - -#elif defined(ACE_HAS_TEMPLATE_INSTANTIATION_PRAGMA) - -#pragma instantiate ACE_Node<Notifier_i::Consumer_Data> -#pragma instantiate ACE_Unbounded_Set<Notifier_i::Consumer_Data> -#pragma instantiate ACE_Unbounded_Set_Iterator<Notifier_i::Consumer_Data> - -#pragma instantiate ACE_Hash_Map_Entry<ACE_CString,ACE_Unbounded_Set<Notifier_i::Consumer_Data>*> -#pragma instantiate ACE_Hash<ACE_CString> -#pragma instantiate ACE_Equal_To<ACE_CString> -#pragma instantiate ACE_Hash_Map_Manager<ACE_CString,ACE_Unbounded_Set<Notifier_i::Consumer_Data>*,ACE_Null_Mutex> -#pragma instantiate ACE_Hash_Map_Manager_Ex<ACE_CString, ACE_Unbounded_Set<Notifier_i::Consumer_Data>*, ACE_Hash<ACE_CString>, ACE_Equal_To<ACE_CString>, ACE_Null_Mutex> -#pragma instantiate ACE_Hash_Map_Iterator_Base_Ex<ACE_CString, ACE_Unbounded_Set<Notifier_i::Consumer_Data>*, ACE_Hash<ACE_CString>, ACE_Equal_To<ACE_CString>, ACE_Null_Mutex> -#pragma instantiate ACE_Hash_Map_Iterator<ACE_CString,ACE_Unbounded_Set<Notifier_i::Consumer_Data>*,ACE_Null_Mutex> -#pragma instantiate ACE_Hash_Map_Iterator_Ex<ACE_CString, ACE_Unbounded_Set<Notifier_i::Consumer_Data>*, ACE_Hash<ACE_CString>, ACE_Equal_To<ACE_CString>, ACE_Null_Mutex> -#pragma instantiate ACE_Hash_Map_Reverse_Iterator<ACE_CString,ACE_Unbounded_Set<Notifier_i::Consumer_Data>*,ACE_Null_Mutex> -#pragma instantiate ACE_Hash_Map_Reverse_Iterator_Ex<ACE_CString, ACE_Unbounded_Set<Notifier_i::Consumer_Data>*, ACE_Hash<ACE_CString>, ACE_Equal_To<ACE_CString>, ACE_Null_Mutex> - -#endif /* ACE_HAS_EXPLICIT_TEMPLATE_INSTANTIATION */ |