OmniEvents
OmniEvents::ProxyPushSupplier_i Class Reference

#include <ProxyPushSupplier.h>

Inheritance diagram for OmniEvents::ProxyPushSupplier_i:
Collaboration diagram for OmniEvents::ProxyPushSupplier_i:

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.
 
- Public Member Functions inherited from OmniEvents::Proxy
virtual ~Proxy ()
 
- Public Member Functions inherited from OmniEvents::Servant
virtual PortableServer::POA_ptr _default_POA ()
 
virtual ~Servant ()
 
- Public Member Functions inherited from OmniEvents::EventQueue::Reader
 Reader (EventQueue &eventQueue)
 
bool moreEvents () const
 
CORBA::Any * nextEvent ()
 
- Public Member Functions inherited from OmniEvents::Callback
 Callback ()
 
virtual ~Callback ()
 

Private Attributes

CosEventComm::PushConsumer_var _target
 
bool _targetIsProxy
 TRUE if _target is a ProxyPushConsumer.
 

Additional Inherited Members

- Protected Member Functions inherited from OmniEvents::Proxy
 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.
 
- 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.
 
void deactivateObject ()
 Calls deactivate_object() to deactivate this servant in its POA.
 
- Protected Attributes inherited from OmniEvents::Proxy
CORBA::Request_var _req
 
- Protected Attributes inherited from OmniEvents::Servant
PortableServer::POA_var _poa
 

Detailed Description

Definition at line 101 of file ProxyPushSupplier.h.

Constructor & Destructor Documentation

◆ ProxyPushSupplier_i()

OmniEvents::ProxyPushSupplier_i::ProxyPushSupplier_i ( PortableServer::POA_ptr  poa,
EventQueue q 
)

Definition at line 296 of file ProxyPushSupplier.cc.

◆ ~ProxyPushSupplier_i()

OmniEvents::ProxyPushSupplier_i::~ProxyPushSupplier_i ( )

Definition at line 308 of file ProxyPushSupplier.cc.

References DB.

Member Function Documentation

◆ callback()

void OmniEvents::ProxyPushSupplier_i::callback ( CORBA::Request_ptr  req)
virtual

◆ connect_push_consumer()

void OmniEvents::ProxyPushSupplier_i::connect_push_consumer ( CosEventComm::PushConsumer_ptr  pushConsumer)

◆ disconnect_push_supplier()

◆ output()

void OmniEvents::ProxyPushSupplier_i::output ( ostream os)
virtual

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().

◆ reincarnate()

void OmniEvents::ProxyPushSupplier_i::reincarnate ( const string oid,
const PersistNode node 
)
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.

◆ trigger()

void OmniEvents::ProxyPushSupplier_i::trigger ( bool busy,
bool waiting 
)
inline

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().

Member Data Documentation

◆ _target

CosEventComm::PushConsumer_var OmniEvents::ProxyPushSupplier_i::_target
private

◆ _targetIsProxy

bool OmniEvents::ProxyPushSupplier_i::_targetIsProxy
private

TRUE if _target is a ProxyPushConsumer.

Definition at line 126 of file ProxyPushSupplier.h.

Referenced by callback(), output(), and reincarnate().


The documentation for this class was generated from the following files: