OmniEvents
OmniEvents::SupplierAdmin_i Class Reference

#include <SupplierAdmin.h>

Inheritance diagram for OmniEvents::SupplierAdmin_i:
Collaboration diagram for OmniEvents::SupplierAdmin_i:

Public Member Functions

CosEventChannelAdmin::ProxyPushConsumer_ptr obtain_push_consumer ()
 
CosEventChannelAdmin::ProxyPullConsumer_ptr obtain_pull_consumer ()
 
 SupplierAdmin_i (const EventChannel_i &channel, PortableServer::POA_ptr poa)
 
virtual ~SupplierAdmin_i ()
 
OMNIEVENTS__DEBUG_REF_COUNTS__DECL void collect (list< CORBA::Any * > &events)
 Collects all events that have arrived since the last call.
 
void disconnect ()
 Send disconnect_XXX_supplier() to all connected consumers.
 
void reincarnate (const PersistNode &node)
 Populate this servant from log information.
 
void output (ostream &os)
 Save this object's state to a stream.
 
- Public Member Functions inherited from OmniEvents::Servant
virtual PortableServer::POA_ptr _default_POA ()
 
virtual ~Servant ()
 

Private Attributes

const EventChannel_i_channel
 
ProxyPushConsumer_i_pushConsumer
 
ProxyPullConsumerManager_pullConsumer
 
list< CORBA::Any * > _queue
 Incoming queue for the PushConsumer.
 
pair< unsigned long, unsigned long_nextPull
 Next time to retry pull (sec,nsec).
 

Additional Inherited Members

- 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::Servant
PortableServer::POA_var _poa
 

Detailed Description

Definition at line 53 of file SupplierAdmin.h.

Constructor & Destructor Documentation

◆ SupplierAdmin_i()

◆ ~SupplierAdmin_i()

OmniEvents::SupplierAdmin_i::~SupplierAdmin_i ( )
virtual

Member Function Documentation

◆ collect()

void OmniEvents::SupplierAdmin_i::collect ( list< CORBA::Any * > &  events)

Collects all events that have arrived since the last call.

Definition at line 104 of file SupplierAdmin.cc.

References BILLION, collect(), OmniEvents::createNarrowedReference(), and MILLION.

Referenced by collect(), and OmniEvents::EventChannel_i::mainLoop().

◆ disconnect()

void OmniEvents::SupplierAdmin_i::disconnect ( )

◆ obtain_pull_consumer()

CosEventChannelAdmin::ProxyPullConsumer_ptr OmniEvents::SupplierAdmin_i::obtain_pull_consumer ( )

◆ obtain_push_consumer()

CosEventChannelAdmin::ProxyPushConsumer_ptr OmniEvents::SupplierAdmin_i::obtain_push_consumer ( )

◆ output()

void OmniEvents::SupplierAdmin_i::output ( ostream os)

Save this object's state to a stream.

Definition at line 167 of file SupplierAdmin.cc.

References _pullConsumer, _pushConsumer, OmniEvents::ProxyManager::output(), and OmniEvents::ProxyPushConsumer_i::output().

Referenced by OmniEvents::EventChannel_i::output().

◆ reincarnate()

Member Data Documentation

◆ _channel

const EventChannel_i& OmniEvents::SupplierAdmin_i::_channel
private

Definition at line 80 of file SupplierAdmin.h.

Referenced by SupplierAdmin_i().

◆ _nextPull

pair<unsigned long,unsigned long> OmniEvents::SupplierAdmin_i::_nextPull
private

Next time to retry pull (sec,nsec).

Set to (0,0) when we should pull every cycle.

Definition at line 87 of file SupplierAdmin.h.

Referenced by SupplierAdmin_i().

◆ _pullConsumer

ProxyPullConsumerManager* OmniEvents::SupplierAdmin_i::_pullConsumer
private

◆ _pushConsumer

ProxyPushConsumer_i* OmniEvents::SupplierAdmin_i::_pushConsumer
private

◆ _queue

list<CORBA::Any*> OmniEvents::SupplierAdmin_i::_queue
private

Incoming queue for the PushConsumer.

Definition at line 83 of file SupplierAdmin.h.

Referenced by obtain_pull_consumer(), reincarnate(), SupplierAdmin_i(), and ~SupplierAdmin_i().


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