TAO_EC_Reactive_ObserverStrategy Class Reference

A reactive observer strategy. More...

#include <EC_ObserverStrategy.h>

Inheritance diagram for TAO_EC_Reactive_ObserverStrategy:

[legend]Collaboration diagram for TAO_EC_Reactive_ObserverStrategy:

[legend]List of all members.

Public Member Functions
	TAO_EC_Reactive_ObserverStrategy (TAO_EC_Event_Channel_Base *ec, ACE_Lock *lock)
	Constructor.
virtual	~TAO_EC_Reactive_ObserverStrategy (void)
	Destructor.
Protected Member Functions
virtual void	consumer_qos_update (TAO_EC_ProxyPushSupplier *supplier)
	Recompute EC consumer subscriptions and send them out to all observers.
virtual void	supplier_qos_update (TAO_EC_ProxyPushConsumer *consumer)
	Recompute EC supplier publications and send them out to all observers.
int	create_observer_map (Observer_Map &map)
void	observer_not_exists (Observer_Entry &observer)
	The observer doesn't exist anymore.

---

Detailed Description

A reactive observer strategy.

This class simply keeps the information about the current list of observers, whenever the list of consumers and/or suppliers changes in queries the EC, computes the global subscription and/or publication list and sends the update message to all the observers. When an observer isn't reachable it is removed from the observer list.

Memory Management

It assumes ownership of the <lock>, but not of the Event_Channel.

Definition at line 239 of file EC_ObserverStrategy.h.

---

Constructor & Destructor Documentation

ACE_INLINE TAO_EC_Reactive_ObserverStrategy::TAO_EC_Reactive_ObserverStrategy	(	TAO_EC_Event_Channel_Base *	ec,
		ACE_Lock *	lock
	)

Constructor.

Definition at line 57 of file EC_ObserverStrategy.inl.

  :  TAO_EC_Basic_ObserverStrategy (ec, lock)
{
}

TAO_EC_Reactive_ObserverStrategy::~TAO_EC_Reactive_ObserverStrategy

(

void

)

[virtual]

Destructor.

Definition at line 267 of file EC_ObserverStrategy.cpp.

{
}

---

Member Function Documentation

void TAO_EC_Reactive_ObserverStrategy::consumer_qos_update

(

TAO_EC_ProxyPushSupplier *

supplier

)

[protected, virtual]

Recompute EC consumer subscriptions and send them out to all observers.

Reimplemented from TAO_EC_Basic_ObserverStrategy.

Definition at line 314 of file EC_ObserverStrategy.cpp.

References create_observer_map(), TAO_EC_Basic_ObserverStrategy::fill_qos(), RtecEventChannelAdmin::ConsumerQOS::is_gateway, observer_not_exists(), and TAO_EC_ProxyPushSupplier::subscriptions().

{
  if (supplier->subscriptions ().is_gateway)
    return;

  RtecEventChannelAdmin::ConsumerQOS c_qos;
  this->fill_qos (c_qos);

  Observer_Map copy;
  this->create_observer_map (copy);

  Observer_Map_Iterator end = copy.end ();
  for (Observer_Map_Iterator i  = copy.begin ();
       i != end;
       ++i)
    {
      Observer_Entry& entry = (*i).int_id_;
      try
        {
          entry.observer->update_consumer (c_qos);
        }
      catch (const CORBA::OBJECT_NOT_EXIST&)
        {
          // Exception occured while updating observer, so remove it from the
          // observer list
          this->observer_not_exists (entry);
        }
      catch (const CORBA::TRANSIENT&)
        {
          // Exception occured while updating observer, so remove it from the
          // observer list
          this->observer_not_exists (entry);
        }
      catch (const CORBA::Exception&)
        {
          // Ignore all exceptions
        }
    }
}

int TAO_EC_Reactive_ObserverStrategy::create_observer_map

(

Observer_Map &

map

)

[protected]

Copies all current observers into a map and passes it back to the caller through map.

Returns:

Returns the size of the map.

Definition at line 356 of file EC_ObserverStrategy.cpp.

References ACE_GUARD_THROW_EX, and TAO_EC_Basic_ObserverStrategy::observers_.

Referenced by consumer_qos_update(), and supplier_qos_update().

{
  ACE_GUARD_THROW_EX (ACE_Lock, ace_mon, *this->lock_,
                 RtecEventChannelAdmin::EventChannel::SYNCHRONIZATION_ERROR());

  Observer_Map_Iterator end = this->observers_.end ();
  for (Observer_Map_Iterator i  = this->observers_.begin ();
       i != end;
       ++i)
    {
      Observer_Entry& entry = (*i).int_id_;
      Observer_Entry copy (entry.handle,
                            RtecEventChannelAdmin::Observer::_duplicate (entry.observer.in ()));
      if (map.bind (copy.handle, copy) == -1)
      {
        map.unbind_all();
        return 0;
      }
    }

  return map.current_size();
}

void TAO_EC_Reactive_ObserverStrategy::observer_not_exists

(

Observer_Entry &

observer

)

[protected]

The observer doesn't exist anymore.

Definition at line 380 of file EC_ObserverStrategy.cpp.

References TAO_EC_Basic_ObserverStrategy::remove_observer().

Referenced by consumer_qos_update(), and supplier_qos_update().

{
  try
    {
      this->remove_observer(observer.handle);
    }
  catch (const CORBA::Exception&)
    {
      // Ignore exceptions
    }
}

void TAO_EC_Reactive_ObserverStrategy::supplier_qos_update

(

TAO_EC_ProxyPushConsumer *

consumer

)

[protected, virtual]

Recompute EC supplier publications and send them out to all observers.

Reimplemented from TAO_EC_Basic_ObserverStrategy.

Definition at line 272 of file EC_ObserverStrategy.cpp.

References create_observer_map(), TAO_EC_Basic_ObserverStrategy::fill_qos(), RtecEventChannelAdmin::SupplierQOS::is_gateway, observer_not_exists(), and TAO_EC_ProxyPushConsumer::publications().

{
  if (consumer->publications ().is_gateway)
    return;

  RtecEventChannelAdmin::SupplierQOS s_qos;
  this->fill_qos (s_qos);

  Observer_Map copy;
  this->create_observer_map (copy);

  Observer_Map_Iterator end = copy.end ();
  for (Observer_Map_Iterator i  = copy.begin ();
       i != end;
       ++i)
    {
      Observer_Entry& entry = (*i).int_id_;
      try
        {
          entry.observer->update_supplier (s_qos);
        }
      catch (const CORBA::OBJECT_NOT_EXIST&)
        {
          // Exception occured while updating observer, so remove it from the
          // observer list
          this->observer_not_exists (entry);
        }
      catch (const CORBA::TRANSIENT&)
        {
          // Exception occured while updating observer, so remove it from the
          // observer list
          this->observer_not_exists (entry);
        }
      catch (const CORBA::Exception&)
        {
          // Ignore all exceptions
        }
    }
}

---

The documentation for this class was generated from the following files:

• EC_ObserverStrategy.h
• EC_ObserverStrategy.cpp
• EC_ObserverStrategy.inl

---