24 #ifndef OMNIEVENTS__PROXYPUSHSUPPLIER_H
25 #define OMNIEVENTS__PROXYPUSHSUPPLIER_H
34 # include <iostream.h>
41 #include "CosEventChannelAdmin.hh"
43 #ifdef HAVE_STD_IOSTREAM
54 PortableServer::Servant incarnate(
55 const PortableServer::ObjectId& oid,
56 PortableServer::POA_ptr poa
60 const PortableServer::ObjectId& oid,
61 PortableServer::POA_ptr adapter,
62 PortableServer::Servant serv,
63 CORBA::Boolean cleanup_in_progress,
64 CORBA::Boolean remaining_activations
69 CosEventChannelAdmin::ProxyPushSupplier_ptr createObject();
74 void* run_undetached(
void*);
102 :
public virtual POA_CosEventChannelAdmin::ProxyPushSupplier,
108 void connect_push_consumer(CosEventComm::PushConsumer_ptr pushConsumer);
109 void disconnect_push_supplier();
118 inline void trigger(
bool& busy,
bool& waiting);
121 void callback(CORBA::Request_ptr req);
122 void reincarnate(
const string& oid,
const PersistNode& node);
123 void output(ostream &os);
134 inline ProxyPushSupplierManager::PauseThenWake::PauseThenWake(
147 _p->_condition.signal();
#define OMNIEVENTS__DEBUG_REF_COUNTS__DECL
Declares debug versions of _add/remove_ref().
Interface for classes that wish to receive callbacks from deferred requests.
The EventQueue is a circular buffer, that contains _size-1 events.
Base class for ServantActivator classes that manage Proxy servants.
Base class for three of the four Proxy servants.
omni_condition _condition
Helper class that locks ProxyPushSupplier upon construction, and wakes it up on destruction.
PauseThenWake(const PauseThenWake &)
Dummy, no implementation.
ProxyPushSupplierManager * _p
PauseThenWake()
Dummy, no implementation.
CosEventComm::PushConsumer_var _target
bool _targetIsProxy
TRUE if _target is a ProxyPushConsumer.