TAO_EC_Accumulate_Consumer_Headers Class Reference

#include <EC_ObserverStrategy.h>

Inheritance diagram for TAO_EC_Accumulate_Consumer_Headers:

[legend]Collaboration diagram for TAO_EC_Accumulate_Consumer_Headers:

[legend]List of all members.

Public Member Functions
	TAO_EC_Accumulate_Consumer_Headers (TAO_EC_Basic_ObserverStrategy::Headers &headers)
	Constructor.
virtual void	work (TAO_EC_ProxyPushConsumer *consumer)
Private Attributes
TAO_EC_Basic_ObserverStrategy::Headers &	headers_

---

Detailed Description

Definition at line 288 of file EC_ObserverStrategy.h.

---

Constructor & Destructor Documentation

ACE_INLINE TAO_EC_Accumulate_Consumer_Headers::TAO_EC_Accumulate_Consumer_Headers

(

TAO_EC_Basic_ObserverStrategy::Headers &

headers

)

Constructor.

Definition at line 76 of file EC_ObserverStrategy.inl.

  : headers_ (h)
{
}

---

Member Function Documentation

void TAO_EC_Accumulate_Consumer_Headers::work

(

TAO_EC_ProxyPushConsumer *

consumer

)

[virtual]

Implements TAO_ESF_Worker< TAO_EC_ProxyPushConsumer >.

Definition at line 416 of file EC_ObserverStrategy.cpp.

References ACE_ES_EVENT_UNDEFINED, headers_, ACE_RB_Tree< EXT_ID, INT_ID, COMPARE_KEYS, ACE_LOCK >::insert(), RtecEventChannelAdmin::SupplierQOS::is_gateway, RtecEventChannelAdmin::SupplierQOS::publications, and TAO_EC_ProxyPushConsumer::publications().

{
  const RtecEventChannelAdmin::SupplierQOS& pub =
    consumer->publications ();
  if (pub.is_gateway)
    return;
  for (CORBA::ULong j = 0; j < pub.publications.length (); ++j)
    {
      const RtecEventComm::Event& event =
        pub.publications[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_Consumer_Headers::headers_ [private]

Definition at line 298 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

---