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:


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_

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.i.
References TAO_EC_Basic_ObserverStrategy::Headers.

00068 : headers_ (h) 00069 { 00070 }

void TAO_EC_Accumulate_Supplier_Headers::work ( TAO_EC_ProxyPushSupplier * supplier ) [virtual]

Implements TAO_ESF_Worker< TAO_EC_ProxyPushSupplier >.
Definition at line 475 of file EC_ObserverStrategy.cpp.
References ACE_ES_EVENT_UNDEFINED, RtecEventChannelAdmin::ConsumerQOS::dependencies, RtecEventComm::Event::header, headers_, ACE_RB_Tree< EXT_ID, INT_ID, COMPARE_KEYS, ACE_LOCK >::insert(), and RtecEventChannelAdmin::ConsumerQOS::is_gateway.

00477 { 00478 const RtecEventChannelAdmin::ConsumerQOS& sub = 00479 supplier->subscriptions (); 00480 if (sub.is_gateway) 00481 return; 00482 for (CORBA::ULong j = 0; j < sub.dependencies.length (); ++j) 00483 { 00484 const RtecEventComm::Event& event = 00485 sub.dependencies[j].event; 00486 RtecEventComm::EventType type = event.header.type; 00487 00488 if (0 < type && type < ACE_ES_EVENT_UNDEFINED) 00489 continue; 00490 this->headers_.insert (event.header, 1); 00491 } 00492 }

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

Generated on Thu Nov 9 13:14:19 2006 for TAO_RTEvent by

1.3.6