OmniEvents
|
#include <ProxyPullConsumer.h>
Public Member Functions | |
PortableServer::Servant | incarnate (const PortableServer::ObjectId &oid, PortableServer::POA_ptr poa) |
ProxyPullConsumerManager (PortableServer::POA_ptr parentPoa, list< CORBA::Any * > &q) | |
~ProxyPullConsumerManager () | |
OMNIEVENTS__DEBUG_REF_COUNTS__DECL CosEventChannelAdmin::ProxyPullConsumer_ptr | createObject () |
void | collect () |
Collects events that have arrived at connected proxies. | |
void | triggerRequest () |
For each connected proxy, if there is no request in progress, send a new request to the current operation (pull or try_pull). | |
void | disconnect () |
Send disconnect_pull_supplier() to all connected PullSuppliers. | |
Private Attributes | |
list< CORBA::Any * > & | _queue |
Definition at line 49 of file ProxyPullConsumer.h.
OmniEvents::ProxyPullConsumerManager::ProxyPullConsumerManager | ( | PortableServer::POA_ptr | parentPoa, |
list< CORBA::Any * > & | q | ||
) |
Definition at line 49 of file ProxyPullConsumer.cc.
References OmniEvents::ProxyManager::activate().
OmniEvents::ProxyPullConsumerManager::~ProxyPullConsumerManager | ( | ) |
Definition at line 59 of file ProxyPullConsumer.cc.
References DB.
void OmniEvents::ProxyPullConsumerManager::collect | ( | ) |
Collects events that have arrived at connected proxies.
For each proxy:
Should be called BEFORE triggerRequest().
Definition at line 75 of file ProxyPullConsumer.cc.
References OmniEvents::ProxyManager::_servants, and OmniEvents::ProxyPullConsumer_i::collect().
CosEventChannelAdmin::ProxyPullConsumer_ptr OmniEvents::ProxyPullConsumerManager::createObject | ( | ) |
Definition at line 67 of file ProxyPullConsumer.cc.
Referenced by OmniEvents::SupplierAdmin_i::obtain_pull_consumer().
void OmniEvents::ProxyPullConsumerManager::disconnect | ( | ) |
Send disconnect_pull_supplier() to all connected PullSuppliers.
Definition at line 95 of file ProxyPullConsumer.cc.
References OmniEvents::ProxyManager::_servants, and OmniEvents::ProxyPullConsumer_i::disconnect_pull_consumer().
Referenced by OmniEvents::SupplierAdmin_i::disconnect().
build buildd omnievents src ProxyPullConsumer cc PortableServer::Servant OmniEvents::ProxyPullConsumerManager::incarnate | ( | const PortableServer::ObjectId & | oid, |
PortableServer::POA_ptr | poa | ||
) |
Definition at line 38 of file ProxyPullConsumer.cc.
References OmniEvents::ProxyManager::_managedPoa, _queue, OmniEvents::ProxyManager::_servants, and DB.
void OmniEvents::ProxyPullConsumerManager::triggerRequest | ( | ) |
For each connected proxy, if there is no request in progress, send a new request to the current operation (pull or try_pull).
Should be called AFTER collect().
Definition at line 85 of file ProxyPullConsumer.cc.
References OmniEvents::ProxyManager::_servants, and OmniEvents::ProxyPullConsumer_i::triggerRequest().
list<CORBA::Any*>& OmniEvents::ProxyPullConsumerManager::_queue [private] |
Definition at line 89 of file ProxyPullConsumer.h.
Referenced by incarnate().