#include <SupplierAdmin.h>
Inheritance diagram for OmniEvents::SupplierAdmin_i:
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 () |
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). |
Definition at line 53 of file SupplierAdmin.h.
|
|
Definition at line 84 of file SupplierAdmin.cc. References _pushConsumer, _queue, and DB. |
|
Collects all events that have arrived since the last call.
Definition at line 97 of file SupplierAdmin.cc. References _channel, _nextPull, _pullConsumer, _pushConsumer, _queue, BILLION, OmniEvents::ProxyPullConsumerManager::collect(), MILLION, OmniEvents::EventChannel_i::pullRetryPeriod_ms(), OmniEvents::ProxyPushConsumer_i::trigger(), and OmniEvents::ProxyPullConsumerManager::triggerRequest(). Referenced by OmniEvents::EventChannel_i::mainLoop(). |
|
Send disconnect_XXX_supplier() to all connected consumers.
Definition at line 130 of file SupplierAdmin.cc. References _pullConsumer, _pushConsumer, OmniEvents::ProxyPullConsumerManager::disconnect(), and OmniEvents::ProxyPushConsumer_i::disconnect(). Referenced by OmniEvents::EventChannel_i::destroy(). |
|
Definition at line 45 of file SupplierAdmin.cc. References OmniEvents::Servant::_poa, _pullConsumer, _queue, and OmniEvents::ProxyPullConsumerManager::createObject(). |
|
Definition at line 38 of file SupplierAdmin.cc. References _pushConsumer, and OmniEvents::ProxyPushConsumer_i::createObject(). |
|
Save this object's state to a stream.
Definition at line 160 of file SupplierAdmin.cc. References _pullConsumer, _pushConsumer, OmniEvents::ProxyManager::output(), and OmniEvents::ProxyPushConsumer_i::output(). Referenced by OmniEvents::EventChannel_i::output(). |
|
Populate this servant from log information.
Definition at line 139 of file SupplierAdmin.cc. References OmniEvents::PersistNode::_child, _pushConsumer, OmniEvents::PersistNode::child(), and OmniEvents::ProxyPushConsumer_i::reincarnate(). Referenced by OmniEvents::EventChannel_i::activate(). |
|
Definition at line 79 of file SupplierAdmin.h. Referenced by collect(), and SupplierAdmin_i(). |
|
Next time to retry pull (sec,nsec). Set to (0,0) when we should pull every cycle. Definition at line 86 of file SupplierAdmin.h. Referenced by collect(), and SupplierAdmin_i(). |
|
Definition at line 81 of file SupplierAdmin.h. Referenced by collect(), disconnect(), obtain_pull_consumer(), and output(). |
|
Definition at line 80 of file SupplierAdmin.h. Referenced by collect(), disconnect(), obtain_push_consumer(), output(), reincarnate(), SupplierAdmin_i(), and ~SupplierAdmin_i(). |
|
Incoming queue for the PushConsumer.
Definition at line 82 of file SupplierAdmin.h. Referenced by collect(), obtain_pull_consumer(), SupplierAdmin_i(), and ~SupplierAdmin_i(). |