OmniEvents::SupplierAdmin_i Class Reference

#include <SupplierAdmin.h>

Inheritance diagram for OmniEvents::SupplierAdmin_i:

[legend]Collaboration diagram for OmniEvents::SupplierAdmin_i:

[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 )

Definition at line 53 of file SupplierAdmin.cc. References _channel, _nextPull, OmniEvents::Servant::_poa, _pushConsumer, _queue, OmniEvents::Servant::activateObjectWithId(), OmniEvents::EventChannel_i::consumerAdmin(), OmniEvents::EventChannel_i::cyclePeriod_ns(), MILLION, and OmniEvents::EventChannel_i::pullRetryPeriod_ms().

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 (   )

Definition at line 45 of file SupplierAdmin.cc. References OmniEvents::Servant::_poa, _pullConsumer, _queue, and OmniEvents::ProxyPullConsumerManager::createObject().

CosEventChannelAdmin::ProxyPushConsumer_ptr OmniEvents::SupplierAdmin_i::obtain_push_consumer (   )

Definition at line 38 of file SupplierAdmin.cc. References _pushConsumer, and OmniEvents::ProxyPushConsumer_i::createObject().

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  )

Populate this servant from log information. Definition at line 146 of file SupplierAdmin.cc. References OmniEvents::PersistNode::_child, OmniEvents::Servant::_poa, _pullConsumer, _pushConsumer, _queue, OmniEvents::PersistNode::child(), OmniEvents::ProxyManager::reincarnate(), and OmniEvents::ProxyPushConsumer_i::reincarnate(). Referenced by OmniEvents::EventChannel_i::activate().

---

Member Data Documentation

const EventChannel_i& OmniEvents::SupplierAdmin_i::_channel [private]

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().

ProxyPullConsumerManager* OmniEvents::SupplierAdmin_i::_pullConsumer [private]

Definition at line 82 of file SupplierAdmin.h. Referenced by disconnect(), obtain_pull_consumer(), output(), reincarnate(), and ~SupplierAdmin_i().

ProxyPushConsumer_i* OmniEvents::SupplierAdmin_i::_pushConsumer [private]

Definition at line 81 of file SupplierAdmin.h. Referenced by disconnect(), obtain_push_consumer(), output(), reincarnate(), SupplierAdmin_i(), and ~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:

• SupplierAdmin.h
• SupplierAdmin.cc

---