OmniEvents
OmniEvents::ProxyPushSupplier_i Class Reference

#include <ProxyPushSupplier.h>

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

List of all members.

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.

Private Attributes

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

Detailed Description

Definition at line 101 of file ProxyPushSupplier.h.


Constructor & Destructor Documentation

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.


Member Function Documentation

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

Sets _targetIsProxy, if it is.

Implements OmniEvents::Callback.

Definition at line 353 of file ProxyPushSupplier.cc.

References _targetIsProxy, DB, OmniEvents::omniEventsLog::exists(), OmniEvents::WriteLock::os, and output().

void OmniEvents::ProxyPushSupplier_i::connect_push_consumer ( CosEventComm::PushConsumer_ptr  pushConsumer)
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, and OmniEvents::Proxy::basicOutput().

Referenced by callback(), and connect_push_consumer().

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::PersistNode::attrLong(), OmniEvents::PersistNode::attrString(), and DB.

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 DB, OmniEvents::Orb::deferredRequest(), HERE, IF_OMNIORB4, OmniEvents::Orb::inst(), and OmniEvents::Orb::reportObjectFailure().

Referenced by OmniEvents::ProxyPushSupplierManager::run_undetached().


Member Data Documentation

CosEventComm::PushConsumer_var OmniEvents::ProxyPushSupplier_i::_target [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: