OmniEvents::SupplierAdmin_i Class Reference

#include <SupplierAdmin.h>

Inheritance diagram for OmniEvents::SupplierAdmin_i:
Inheritance graph
[legend]
Collaboration diagram for OmniEvents::SupplierAdmin_i:
Collaboration graph
[legend]

List of all members.

Public Member Functions

CosEventChannelAdmin::ProxyPushConsumer_ptr obtain_push_consumer ()
CosEventChannelAdmin::ProxyPullConsumer_ptr obtain_pull_consumer ()
 SupplierAdmin_i (const EventChannel_i &channel, PortableServer::POA_ptr poa)
virtual ~SupplierAdmin_i ()
OMNIEVENTS__DEBUG_REF_COUNTS__DECL
void 
collect (list< CORBA::Any * > &events)
 Collects all events that have arrived since the last call.
void disconnect ()
 Send disconnect_XXX_supplier() to all connected consumers.
void reincarnate (const PersistNode &node)
 Populate this servant from log information.
void output (ostream &os)
 Save this object's state to a stream.

Private Attributes

const EventChannel_i_channel
ProxyPushConsumer_i_pushConsumer
ProxyPullConsumerManager_pullConsumer
list< CORBA::Any * > _queue
 Incoming queue for the PushConsumer.
pair< unsigned long, unsigned
long > 
_nextPull
 Next time to retry pull (sec,nsec).

Detailed Description

Definition at line 53 of file SupplierAdmin.h.


Constructor & Destructor Documentation

OmniEvents::SupplierAdmin_i::SupplierAdmin_i ( const EventChannel_i channel,
PortableServer::POA_ptr  poa 
)
OmniEvents::SupplierAdmin_i::~SupplierAdmin_i (  )  [virtual]

Definition at line 83 of file SupplierAdmin.cc.

References _pullConsumer, _pushConsumer, _queue, and DB.


Member Function Documentation

void OmniEvents::SupplierAdmin_i::collect ( list< CORBA::Any * > &  events  ) 

Collects all events that have arrived since the last call.

Definition at line 104 of file SupplierAdmin.cc.

References BILLION, and MILLION.

Referenced by OmniEvents::EventChannel_i::mainLoop().

void OmniEvents::SupplierAdmin_i::disconnect (  ) 

Send disconnect_XXX_supplier() to all connected consumers.

Definition at line 137 of file SupplierAdmin.cc.

References _pullConsumer, _pushConsumer, OmniEvents::ProxyPullConsumerManager::disconnect(), and OmniEvents::ProxyPushConsumer_i::disconnect().

Referenced by OmniEvents::EventChannel_i::destroy().

CosEventChannelAdmin::ProxyPullConsumer_ptr OmniEvents::SupplierAdmin_i::obtain_pull_consumer (  ) 
CosEventChannelAdmin::ProxyPushConsumer_ptr OmniEvents::SupplierAdmin_i::obtain_push_consumer (  ) 
void OmniEvents::SupplierAdmin_i::output ( ostream &  os  ) 

Save this object's state to a stream.

Definition at line 167 of file SupplierAdmin.cc.

References _pullConsumer, _pushConsumer, OmniEvents::ProxyManager::output(), and OmniEvents::ProxyPushConsumer_i::output().

Referenced by OmniEvents::EventChannel_i::output().

void OmniEvents::SupplierAdmin_i::reincarnate ( const PersistNode node  ) 

Member Data Documentation

Definition at line 80 of file SupplierAdmin.h.

Referenced by SupplierAdmin_i().

pair<unsigned long,unsigned long> OmniEvents::SupplierAdmin_i::_nextPull [private]

Next time to retry pull (sec,nsec).

Set to (0,0) when we should pull every cycle.

Definition at line 87 of file SupplierAdmin.h.

Referenced by SupplierAdmin_i().

list<CORBA::Any*> OmniEvents::SupplierAdmin_i::_queue [private]

Incoming queue for the PushConsumer.

Definition at line 83 of file SupplierAdmin.h.

Referenced by obtain_pull_consumer(), reincarnate(), SupplierAdmin_i(), and ~SupplierAdmin_i().


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

Generated on Mon Sep 28 05:10:19 2009 for OmniEvents by  doxygen 1.6.1