#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. More... | |
| void | disconnect () |
| Send disconnect_XXX_supplier() to all connected consumers. More... | |
| void | reincarnate (const PersistNode &node) |
| Populate this servant from log information. More... | |
| void | output (ostream &os) |
| Save this object's state to a stream. More... | |
 Public Member Functions inherited from OmniEvents::Servant | |
| 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. More... | |
| pair< unsigned long, unsigned long > | _nextPull |
| Next time to retry pull (sec,nsec). More... | |
Additional Inherited Members | |
| Protected Member Functions inherited from OmniEvents::Servant | |
| Servant (PortableServer::POA_ptr poa) | |
| void | activateObjectWithId (const char *oidStr) |
| Calls activate_object_with_id() to activate this servant in its POA. More... | |
| void | deactivateObject () |
| Calls deactivate_object() to deactivate this servant in its POA. More... | |
| Protected Attributes inherited from OmniEvents::Servant | |
| PortableServer::POA_var | _poa |
Detailed Description
Definition at line 53 of file SupplierAdmin.h.
Constructor & Destructor Documentation
◆ SupplierAdmin_i()
| 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().
◆ ~SupplierAdmin_i()
|
virtual |
Definition at line 83 of file SupplierAdmin.cc.
References _pullConsumer, _pushConsumer, _queue, and DB.
Member Function Documentation
◆ collect()
| 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, collect(), and MILLION.
Referenced by collect(), and OmniEvents::EventChannel_i::mainLoop().
◆ disconnect()
| 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().
◆ obtain_pull_consumer()
| 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().
◆ obtain_push_consumer()
| CosEventChannelAdmin::ProxyPushConsumer_ptr OmniEvents::SupplierAdmin_i::obtain_push_consumer | ( | ) |
Definition at line 38 of file SupplierAdmin.cc.
References _pushConsumer, and OmniEvents::ProxyPushConsumer_i::createObject().
◆ output()
| 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().
◆ reincarnate()
| 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
◆ _channel
|
private |
Definition at line 80 of file SupplierAdmin.h.
Referenced by 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().
◆ _pullConsumer
|
private |
Definition at line 82 of file SupplierAdmin.h.
Referenced by disconnect(), obtain_pull_consumer(), output(), reincarnate(), and ~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().
◆ _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:
