32 #define MILLION 1000000 33 #define BILLION 1000000000 37 CosEventChannelAdmin::ProxyPushConsumer_ptr
44 CosEventChannelAdmin::ProxyPullConsumer_ptr
55 PortableServer::POA_ptr poa
85 DB(20,
"~SupplierAdmin_i()")
96 for(list<CORBA::Any*>::iterator i=
_queue.begin(); i!=
_queue.end(); ++i)
115 pair<unsigned long,unsigned long> now;
116 omni_thread::get_time(&(now.first),&(now.second));
150 if(pushcNode && !pushcNode->
_child.empty())
158 if(pullcNode && !pullcNode->
_child.empty())
PersistNode * child(const string &key) const
void collect()
Collects events that have arrived at connected proxies.
void reincarnate(const PersistNode &node)
Re-create servants from information saved in the log file.
void output(ostream &os) const
Save this object's state to a stream.
void disconnect()
Send disconnect_XXX_supplier() to all connected consumers.
CosEventChannelAdmin::ProxyPullConsumer_ptr obtain_pull_consumer()
SupplierAdmin_i(const EventChannel_i &channel, PortableServer::POA_ptr poa)
ProxyPushConsumer_i * _pushConsumer
void disconnect()
Send disconnect_pull_supplier() to all connected PullSuppliers.
void output(ostream &os)
Save this object's state to a stream.
const EventChannel_i & _channel
map< string, PersistNode * > _child
ConsumerAdmin_i & consumerAdmin() const
list< CORBA::Any * > _queue
Incoming queue for the PushConsumer.
unsigned long cyclePeriod_ns() const
PortableServer::POA_var _poa
void output(ostream &os)
Save this object's state to a stream.
CosEventChannelAdmin::ProxyPushConsumer_ptr createObject()
Constructs a new object.
void activateObjectWithId(const char *oidStr)
Calls activate_object_with_id() to activate this servant in its POA.
OMNIEVENTS__DEBUG_REF_COUNTS__DECL CosEventChannelAdmin::ProxyPullConsumer_ptr createObject()
void reincarnate(const PersistNode &node)
Re-create all servants from information saved in the log file.
#define OMNIEVENTS__DEBUG_REF_COUNTS__DEFN(C)
Defines debug versions of _add/remove_ref() for class C.
CosEventChannelAdmin::ProxyPushConsumer_ptr obtain_push_consumer()
virtual ~SupplierAdmin_i()
void triggerRequest()
For each connected proxy, if there is no request in progress, send a new request to the current opera...
pair< unsigned long, unsigned long > _nextPull
Next time to retry pull (sec,nsec).
Default servant for ProxyPushConsumer objects.
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_push_supplier() to all connected PushSuppliers.
ProxyPullConsumerManager * _pullConsumer
Servant for CosEventChannelAdmin::EventChannel objects, also inherits from omni_thread.
void reincarnate(const PersistNode &node)
Populate this servant from log information.
CORBA::ULong pullRetryPeriod_ms() const