OmniEvents
|
#include <SupplierAdmin.h>
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. | |
![]() | |
virtual PortableServer::POA_ptr | _default_POA () |
virtual | ~Servant () |
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). | |
Additional Inherited Members | |
![]() | |
Servant (PortableServer::POA_ptr poa) | |
void | activateObjectWithId (const char *oidStr) |
Calls activate_object_with_id() to activate this servant in its POA. | |
void | deactivateObject () |
Calls deactivate_object() to deactivate this servant in its POA. | |
![]() | |
PortableServer::POA_var | _poa |
Definition at line 53 of file SupplierAdmin.h.
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().
|
virtual |
Definition at line 83 of file SupplierAdmin.cc.
References _pullConsumer, _pushConsumer, _queue, OmniEvents::createNarrowedReference(), and DB.
Collects all events that have arrived since the last call.
Definition at line 104 of file SupplierAdmin.cc.
References BILLION, collect(), OmniEvents::createNarrowedReference(), and MILLION.
Referenced by collect(), and 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().
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::Servant::_poa, _pullConsumer, _pushConsumer, _queue, OmniEvents::PersistNode::child(), OmniEvents::createNarrowedReference(), OmniEvents::ProxyManager::reincarnate(), and OmniEvents::ProxyPushConsumer_i::reincarnate().
Referenced by OmniEvents::EventChannel_i::activate().
|
private |
Definition at line 80 of file SupplierAdmin.h.
Referenced by SupplierAdmin_i().
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().
|
private |
Definition at line 82 of file SupplierAdmin.h.
Referenced by disconnect(), obtain_pull_consumer(), output(), reincarnate(), and ~SupplierAdmin_i().
|
private |
Definition at line 81 of file SupplierAdmin.h.
Referenced by disconnect(), obtain_push_consumer(), output(), reincarnate(), SupplierAdmin_i(), and ~SupplierAdmin_i().
|
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().