#include <ProxyPushSupplier.h>
Inheritance diagram for OmniEvents::ProxyPushSupplier_i:
Public Methods | |
void | connect_push_consumer (CosEventComm::PushConsumer_ptr pushConsumer) |
void | disconnect_push_supplier () |
ProxyPushSupplier_i (PortableServer::POA_ptr poa, EventQueue &q) | |
~ProxyPushSupplier_i () | |
void | trigger (bool &busy, bool &waiting) |
Sets 'busy' if some work was done. More... | |
void | callback (CORBA::Request_ptr req) |
Sets _targetIsProxy, if it is. More... | |
void | reincarnate (const string &oid, const PersistNode &node) |
Re-create a servant from information saved in the log file. More... | |
void | output (ostream &os) |
Save this object's state to a stream. More... | |
Private Attributes | |
CosEventComm::PushConsumer::_var_type | _target |
bool | _targetIsProxy |
TRUE if _target is a ProxyPushConsumer. More... |
|
Definition at line 263 of file ProxyPushSupplier.cc. |
|
Definition at line 275 of file ProxyPushSupplier.cc. References DB. |
|
Sets _targetIsProxy, if it is.
Implements OmniEvents::Callback. Definition at line 318 of file ProxyPushSupplier.cc. References _targetIsProxy, DB, and output(). |
|
Definition at line 220 of file ProxyPushSupplier.cc. References OmniEvents::Proxy::_req, _target, and output(). |
|
Definition at line 241 of file ProxyPushSupplier.cc. References _target, DB, OmniEvents::Servant::deactivateObject(), OmniEvents::Proxy::eraseKey(), and IFELSE_OMNIORB4. Referenced by OmniEvents::ProxyPushSupplierManager::disconnect(). |
|
Save this object's state to a stream.
Implements OmniEvents::Proxy. Definition at line 386 of file ProxyPushSupplier.cc. References _target, _targetIsProxy, and OmniEvents::Proxy::basicOutput(). Referenced by callback(), and connect_push_consumer(). |
|
Re-create a servant from information saved in the log file.
Implements OmniEvents::Proxy. Definition at line 342 of file ProxyPushSupplier.cc. References _target, _targetIsProxy, OmniEvents::Servant::activateObjectWithId(), OmniEvents::PersistNode::attrLong(), OmniEvents::PersistNode::attrString(), and DB. |
|
Sets 'busy' if some work was done. Sets 'waiting' if there is an outstanding request. Definition at line 280 of file ProxyPushSupplier.cc. References OmniEvents::Proxy::_req, _target, DB, OmniEvents::Servant::deactivateObject(), OmniEvents::Proxy::eraseKey(), IF_OMNIORB4, OmniEvents::EventQueue::Reader::moreEvents(), and OmniEvents::EventQueue::Reader::nextEvent(). Referenced by OmniEvents::ProxyPushSupplierManager::run(). |
|
Definition at line 124 of file ProxyPushSupplier.h. Referenced by connect_push_consumer(), disconnect_push_supplier(), output(), reincarnate(), and trigger(). |
|
TRUE if _target is a ProxyPushConsumer.
Definition at line 125 of file ProxyPushSupplier.h. Referenced by callback(), output(), and reincarnate(). |