TAO_EC_Accumulate_Supplier_Headers Class Reference

#include <EC_ObserverStrategy.h>

Inheritance diagram for TAO_EC_Accumulate_Supplier_Headers:

[legend]Collaboration diagram for TAO_EC_Accumulate_Supplier_Headers:

[legend]List of all members.

Public Member Functions
	TAO_EC_Accumulate_Supplier_Headers (TAO_EC_Basic_ObserverStrategy::Headers &headers)
	Constructor.
virtual void	work (TAO_EC_ProxyPushSupplier *supplier)
Private Attributes
TAO_EC_Basic_ObserverStrategy::Headers &	headers_

---

Detailed Description

Definition at line 273 of file EC_ObserverStrategy.h.

---

Constructor & Destructor Documentation

ACE_INLINE TAO_EC_Accumulate_Supplier_Headers::TAO_EC_Accumulate_Supplier_Headers

(

TAO_EC_Basic_ObserverStrategy::Headers &

headers

)

Constructor.

Definition at line 67 of file EC_ObserverStrategy.inl.

  : headers_ (h)
{
}

---

Member Function Documentation

void TAO_EC_Accumulate_Supplier_Headers::work

(

TAO_EC_ProxyPushSupplier *

supplier

)

[virtual]

Implements TAO_ESF_Worker< TAO_EC_ProxyPushSupplier >.

Definition at line 395 of file EC_ObserverStrategy.cpp.

References ACE_ES_EVENT_UNDEFINED, RtecEventChannelAdmin::ConsumerQOS::dependencies, headers_, ACE_RB_Tree< EXT_ID, INT_ID, COMPARE_KEYS, ACE_LOCK >::insert(), RtecEventChannelAdmin::ConsumerQOS::is_gateway, and TAO_EC_ProxyPushSupplier::subscriptions().

{
  const RtecEventChannelAdmin::ConsumerQOS& sub =
    supplier->subscriptions ();
  if (sub.is_gateway)
    return;
  for (CORBA::ULong j = 0; j < sub.dependencies.length (); ++j)
    {
      const RtecEventComm::Event& event =
        sub.dependencies[j].event;
      RtecEventComm::EventType type = event.header.type;

      if (0 < type && type < ACE_ES_EVENT_UNDEFINED)
        continue;
      this->headers_.insert (event.header, 1);
    }
}

---

Member Data Documentation

TAO_EC_Basic_ObserverStrategy::Headers& TAO_EC_Accumulate_Supplier_Headers::headers_ [private]

Definition at line 283 of file EC_ObserverStrategy.h.

Referenced by work().

---

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

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

---