OmniEvents
|
#include <ProxyPushSupplier.h>
Public Member Functions | |
void | connect_push_consumer (CosEventComm::PushConsumer_ptr pushConsumer) |
void | disconnect_push_supplier () |
ProxyPushSupplier_i (PortableServer::POA_ptr poa, EventQueue &q) | |
~ProxyPushSupplier_i () | |
OMNIEVENTS__DEBUG_REF_COUNTS__DECL void | trigger (bool &busy, bool &waiting) |
Sets 'busy' if some work was done. | |
void | callback (CORBA::Request_ptr req) |
Sets _targetIsProxy, if it is. | |
void | reincarnate (const string &oid, const PersistNode &node) |
Re-create a servant from information saved in the log file. | |
void | output (ostream &os) |
Save this object's state to a stream. | |
![]() | |
virtual | ~Proxy () |
![]() | |
virtual PortableServer::POA_ptr | _default_POA () |
virtual | ~Servant () |
![]() | |
Reader (EventQueue &eventQueue) | |
bool | moreEvents () const |
CORBA::Any * | nextEvent () |
![]() | |
Callback () | |
virtual | ~Callback () |
Private Attributes | |
CosEventComm::PushConsumer_var | _target |
bool | _targetIsProxy |
TRUE if _target is a ProxyPushConsumer. | |
Additional Inherited Members | |
![]() | |
Proxy (PortableServer::POA_ptr poa) | |
void | keyOutput (ostream &os, const char *name) |
Helper method for constructing persistency output. | |
void | eraseKey (const char *name) |
Helper method for constructing persistency output. | |
void | basicOutput (ostream &os, const char *name, CORBA::Object_ptr target=CORBA::Object::_nil(), const char *extraAttributes=NULL) |
Helper method for constructing persistency output. | |
![]() | |
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. | |
![]() | |
CORBA::Request_var | _req |
![]() | |
PortableServer::POA_var | _poa |
Definition at line 101 of file ProxyPushSupplier.h.
OmniEvents::ProxyPushSupplier_i::ProxyPushSupplier_i | ( | PortableServer::POA_ptr | poa, |
EventQueue & | q | ||
) |
Definition at line 296 of file ProxyPushSupplier.cc.
OmniEvents::ProxyPushSupplier_i::~ProxyPushSupplier_i | ( | ) |
Definition at line 308 of file ProxyPushSupplier.cc.
References DB.
|
virtual |
Sets _targetIsProxy, if it is.
Implements OmniEvents::Callback.
Definition at line 353 of file ProxyPushSupplier.cc.
References _targetIsProxy, OmniEvents::createNarrowedReference(), DB, OmniEvents::omniEventsLog::exists(), OmniEvents::WriteLock::os, and output().
void OmniEvents::ProxyPushSupplier_i::connect_push_consumer | ( | CosEventComm::PushConsumer_ptr | pushConsumer | ) |
Definition at line 249 of file ProxyPushSupplier.cc.
References OmniEvents::Proxy::_req, _target, OmniEvents::createNarrowedReference(), OmniEvents::Orb::deferredRequest(), OmniEvents::omniEventsLog::exists(), OmniEvents::Orb::inst(), OmniEvents::WriteLock::os, and output().
void OmniEvents::ProxyPushSupplier_i::disconnect_push_supplier | ( | ) |
Definition at line 274 of file ProxyPushSupplier.cc.
References _target, OmniEvents::createNarrowedReference(), DB, OmniEvents::Servant::deactivateObject(), OmniEvents::Orb::deferredRequest(), OmniEvents::Proxy::eraseKey(), IFELSE_OMNIORB4, and OmniEvents::Orb::inst().
Referenced by OmniEvents::ProxyPushSupplierManager::disconnect().
Save this object's state to a stream.
Implements OmniEvents::Proxy.
Definition at line 423 of file ProxyPushSupplier.cc.
References _target, _targetIsProxy, OmniEvents::Proxy::basicOutput(), and OmniEvents::createNarrowedReference().
Referenced by callback(), and connect_push_consumer().
|
virtual |
Re-create a servant from information saved in the log file.
Implements OmniEvents::Proxy.
Definition at line 378 of file ProxyPushSupplier.cc.
References _target, _targetIsProxy, OmniEvents::Servant::activateObjectWithId(), OmniEvents::createNarrowedReference(), and DB.
Sets 'busy' if some work was done.
Sets 'waiting' if there is an outstanding request.
Definition at line 315 of file ProxyPushSupplier.cc.
References OmniEvents::createNarrowedReference(), DB, OmniEvents::Orb::deferredRequest(), HERE, IF_OMNIORB4, OmniEvents::Orb::inst(), and OmniEvents::Orb::reportObjectFailure().
Referenced by OmniEvents::ProxyPushSupplierManager::run_undetached().
|
private |
Definition at line 125 of file ProxyPushSupplier.h.
Referenced by connect_push_consumer(), disconnect_push_supplier(), output(), and reincarnate().
|
private |
TRUE if _target is a ProxyPushConsumer.
Definition at line 126 of file ProxyPushSupplier.h.
Referenced by callback(), output(), and reincarnate().