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:


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_

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

00077 : headers_ (h) 00078 { 00079 }

void TAO_EC_Accumulate_Consumer_Headers::work ( TAO_EC_ProxyPushConsumer * consumer ) [virtual]

Implements TAO_ESF_Worker< TAO_EC_ProxyPushConsumer >.
Definition at line 497 of file EC_ObserverStrategy.cpp.
References ACE_ES_EVENT_UNDEFINED, RtecEventComm::Event::header, ACE_RB_Tree< EXT_ID, INT_ID, COMPARE_KEYS, ACE_LOCK >::insert(), RtecEventChannelAdmin::SupplierQOS::is_gateway, and RtecEventChannelAdmin::SupplierQOS::publications.

00499 { 00500 const RtecEventChannelAdmin::SupplierQOS& pub = 00501 consumer->publications (); 00502 if (pub.is_gateway) 00503 return; 00504 for (CORBA::ULong j = 0; j < pub.publications.length (); ++j) 00505 { 00506 const RtecEventComm::Event& event = 00507 pub.publications[j].event; 00508 RtecEventComm::EventType type = event.header.type; 00509 00510 if (0 < type && type < ACE_ES_EVENT_UNDEFINED) 00511 continue; 00512 this->headers_.insert (event.header, 1); 00513 } 00514 }

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

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

1.3.6