OmniEvents::ProxyPullConsumer_i Class Reference

Implementation of the ProxyPullConsumer interface. More...

#include <ProxyPullConsumer.h>

Inheritance diagram for OmniEvents::ProxyPullConsumer_i:

[legend]Collaboration diagram for OmniEvents::ProxyPullConsumer_i:

[legend]List of all members.

Public Member Functions
void	connect_pull_supplier (CosEventComm::PullSupplier_ptr pullSupplier)
void	disconnect_pull_consumer ()
	ProxyPullConsumer_i (PortableServer::POA_ptr poa, list< CORBA::Any * > &q)
	~ProxyPullConsumer_i ()
void	collect ()
	Collects responses since the last trigger.
void	triggerRequest ()
	When _req is NIL, sends out a new pull() or try_pull() call.
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 Types
enum	Mode { Pull = 0, TryPull = 1 }
	This proxy can call out in either pull() or try_pull() mode. More...
Private Attributes
CosEventComm::PullSupplier_var	_target
list< CORBA::Any * > &	_queue
Mode	_mode
int	_exceptionCount
	Only when two consecutive exceptions have been received from each mode, do we consider the connection dead.

---

Detailed Description

Implementation of the ProxyPullConsumer interface.

Tries to get messages by using pull() then try_pull() method calls, but prefers pull(). Switches between pull() & try_pull() if it gets an exception. Only gives up when both methods have returned two consecutive exceptions.

Note, our own implementation of ProxyPullSupplier::pull() is very basic.

Definition at line 100 of file ProxyPullConsumer.h.

---

Member Enumeration Documentation

enum OmniEvents::ProxyPullConsumer_i::Mode [private]

This proxy can call out in either pull() or try_pull() mode. Enumerator: Pull  TryPull  Definition at line 123 of file ProxyPullConsumer.h.

---

Constructor & Destructor Documentation

OmniEvents::ProxyPullConsumer_i::ProxyPullConsumer_i (  PortableServer::POA_ptr  poa, list< CORBA::Any * > &  q )

Definition at line 154 of file ProxyPullConsumer.cc.

OmniEvents::ProxyPullConsumer_i::~ProxyPullConsumer_i (   )

Definition at line 165 of file ProxyPullConsumer.cc. References DB.

---

Member Function Documentation

void OmniEvents::ProxyPullConsumer_i::collect (   )

Collects responses since the last trigger. Definition at line 170 of file ProxyPullConsumer.cc. References _exceptionCount, _mode, _queue, OmniEvents::Proxy::_req, _target, DB, OmniEvents::Servant::deactivateObject(), OmniEvents::Orb::deferredRequest(), OmniEvents::Proxy::eraseKey(), HERE, IF_OMNIORB4, OmniEvents::Orb::inst(), Pull, OmniEvents::Orb::reportObjectFailure(), and TryPull. Referenced by OmniEvents::ProxyPullConsumerManager::collect().

void OmniEvents::ProxyPullConsumer_i::connect_pull_supplier (  CosEventComm::PullSupplier_ptr  pullSupplier  )

Definition at line 114 of file ProxyPullConsumer.cc. References OmniEvents::Proxy::_req, _target, OmniEvents::omniEventsLog::exists(), OmniEvents::WriteLock::os, and output(). Referenced by reincarnate().

void OmniEvents::ProxyPullConsumer_i::disconnect_pull_consumer (   )

Definition at line 131 of file ProxyPullConsumer.cc. References _target, DB, OmniEvents::Servant::deactivateObject(), OmniEvents::Orb::deferredRequest(), OmniEvents::Proxy::eraseKey(), IFELSE_OMNIORB4, and OmniEvents::Orb::inst(). Referenced by OmniEvents::ProxyPullConsumerManager::disconnect().

void OmniEvents::ProxyPullConsumer_i::output (  ostream &  os  )  [virtual]

Save this object's state to a stream. Implements OmniEvents::Proxy. Definition at line 274 of file ProxyPullConsumer.cc. References _target, and OmniEvents::Proxy::basicOutput(). Referenced by connect_pull_supplier().

void OmniEvents::ProxyPullConsumer_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 262 of file ProxyPullConsumer.cc. References OmniEvents::Servant::activateObjectWithId(), OmniEvents::PersistNode::attrString(), and connect_pull_supplier().

void OmniEvents::ProxyPullConsumer_i::triggerRequest (   )

When _req is NIL, sends out a new pull() or try_pull() call. Definition at line 241 of file ProxyPullConsumer.cc. References _mode, OmniEvents::Proxy::_req, _target, Pull, and TryPull. Referenced by OmniEvents::ProxyPullConsumerManager::triggerRequest().

---

Member Data Documentation

int OmniEvents::ProxyPullConsumer_i::_exceptionCount [private]

Only when two consecutive exceptions have been received from each mode, do we consider the connection dead. Definition at line 129 of file ProxyPullConsumer.h. Referenced by collect().

Mode OmniEvents::ProxyPullConsumer_i::_mode [private]

Definition at line 124 of file ProxyPullConsumer.h. Referenced by collect(), and triggerRequest().

list<CORBA::Any*>& OmniEvents::ProxyPullConsumer_i::_queue [private]

Definition at line 120 of file ProxyPullConsumer.h. Referenced by collect().

CosEventComm::PullSupplier_var OmniEvents::ProxyPullConsumer_i::_target [private]

Definition at line 119 of file ProxyPullConsumer.h. Referenced by collect(), connect_pull_supplier(), disconnect_pull_consumer(), output(), and triggerRequest().

---

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

• ProxyPullConsumer.h
• ProxyPullConsumer.cc

---