diff options
Diffstat (limited to 'TAO/examples/Callback_Quoter/Supplier_i.cpp')
| -rw-r--r-- | TAO/examples/Callback_Quoter/Supplier_i.cpp | 181 |
1 files changed, 0 insertions, 181 deletions
diff --git a/TAO/examples/Callback_Quoter/Supplier_i.cpp b/TAO/examples/Callback_Quoter/Supplier_i.cpp deleted file mode 100644 index b895269fb52..00000000000 --- a/TAO/examples/Callback_Quoter/Supplier_i.cpp +++ /dev/null @@ -1,181 +0,0 @@ -// $Id$ - -// =========================================================== -// -// = LIBRARY -// TAO/examples/Callback_Quoter -// -// = FILENAME -// Supplier_i.cpp -// -// = DESCRIPTION -// Implementation of the Supplier_i class. This class is the servant -// object for the callback quoter server. -// -// = AUTHOR -// Kirthika Parameswaran <kirthika@cs.wustl.edu> -// -// =========================================================== - -#include "Supplier_i.h" - -Supplier_i::Supplier_i (void) -{ - // No-op -} - -Supplier_i::~Supplier_i (void) -{ - // No-op -} - -// Register a distributed callback handler that is invoked when the -// given stock reaches the desired threshold value. - -void -Supplier_i::register_callback (const char *stock_name, - CORBA::Long threshold_value, - Callback_Quoter::Consumer_ptr consumer_handler, - CORBA::Environment &TAO_TRY_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; - - if (this->consumer_map_.find (stock_name, consumers) == 0) - { - consumers->insert (consumer_data); - } - else - { - consumers = new CONSUMERS; - consumers->insert (consumer_data); - this->consumer_map_.bind (stock_name, consumers); - } -} - -void -Supplier_i::orb (CORBA::ORB_ptr orb) -{ - this->orb_ = orb; -} - -// Remove the client handler. - -void -Supplier_i::unregister_callback (Callback_Quoter::Consumer_ptr consumer, - CORBA::Environment &TAO_TRY_ENV) -{ - - - 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); - - (*iter).int_id_->remove (consumer_to_remove); - // 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. - - } - -} - -// gets the market status and sends the information to -// the consumer who is interested in it. - -void -Supplier_i::market_status (const char *stock_name, - CORBA::Long stock_value, - CORBA::Environment &TAO_TRY_ENV) -{ - ACE_DEBUG ((LM_DEBUG, - "Supplier:: The stockname is %s with price %d\n", - stock_name, - stock_value)); - - // Go through the list of <Consumer_Data> to find which registered - // client wants to be notified. - - CONSUMERS *consumers; - if (this->consumer_map_.find (stock_name, consumers) == 0) - { - 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; - - (*iter).consumer_->push (interested_consumer_data); - } - } - } -} - -void -Supplier_i::shutdown (CORBA::Environment &) -{ - ACE_DEBUG ((LM_DEBUG, - "\n%s\n", - "The Callback Quoter server is shutting down")); - - // Instruct the ORB to shutdown. - this->orb_->shutdown (); -} - -int -Supplier_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<Supplier_i::Consumer_Data>; -template class ACE_Unbounded_Set<Supplier_i::Consumer_Data>; -template class ACE_Unbounded_Set_Iterator<Supplier_i::Consumer_Data>; - -template class ACE_Hash_Map_Entry<ACE_CString,ACE_Unbounded_Set<Supplier_i::Consumer_Data>*>; -template class ACE_Hash_Map_Manager<ACE_CString,ACE_Unbounded_Set<Supplier_i::Consumer_Data>*,ACE_Null_Mutex>; -template class ACE_Hash_Map_Iterator_Base<ACE_CString,ACE_Unbounded_Set<Supplier_i::Consumer_Data>*,ACE_Null_Mutex>; -template class ACE_Hash_Map_Iterator<ACE_CString,ACE_Unbounded_Set<Supplier_i::Consumer_Data>*,ACE_Null_Mutex>; -template class ACE_Hash_Map_Reverse_Iterator<ACE_CString,ACE_Unbounded_Set<Supplier_i::Consumer_Data>*,ACE_Null_Mutex>; - -#elif defined(ACE_HAS_TEMPLATE_INSTANTIATION_PRAGMA) - -#pragma instantiate ACE_Node<Supplier_i::Consumer_Data> -#pragma instantiate ACE_Unbounded_Set<Supplier_i::Consumer_Data> -#pragma instantiate ACE_Unbounded_Set_Iterator<Supplier_i::Consumer_Data> - -#pragma instantiate ACE_Hash_Map_Entry<ACE_CString,ACE_Unbounded_Set<Supplier_i::Consumer_Data>*> -#pragma instantiate ACE_Hash_Map_Manager<ACE_CString,ACE_Unbounded_Set<Supplier_i::Consumer_Data>*,ACE_Null_Mutex> -#pragma instantiate ACE_Hash_Map_Iterator_Base<ACE_CString,ACE_Unbounded_Set<Supplier_i::Consumer_Data>*,ACE_Null_Mutex> -#pragma instantiate ACE_Hash_Map_Iterator<ACE_CString,ACE_Unbounded_Set<Supplier_i::Consumer_Data>*,ACE_Null_Mutex> -#pragma instantiate ACE_Hash_Map_Reverse_Iterator<ACE_CString,ACE_Unbounded_Set<Supplier_i::Consumer_Data>*,ACE_Null_Mutex> - -#endif /* ACE_HAS_EXPLICIT_TEMPLATE_INSTANTIATION */ |