24 #ifndef OMNIEVENTS__PROXYPULLSUPPLIER_H 25 #define OMNIEVENTS__PROXYPULLSUPPLIER_H 34 # include <iostream.h> 40 #include "CosEventChannelAdmin.hh" 42 #ifdef HAVE_STD_IOSTREAM 52 public PortableServer::RefCountServantBase
55 PortableServer::Servant incarnate(
56 const PortableServer::ObjectId& oid,
57 PortableServer::POA_ptr poa
62 PortableServer::POA_ptr parentPoa,
67 CosEventChannelAdmin::ProxyPullSupplier_ptr createObject();
85 :
public virtual POA_CosEventChannelAdmin::ProxyPullSupplier,
90 void connect_pull_consumer(CosEventComm::PullConsumer_ptr pullConsumer);
91 void disconnect_pull_supplier();
93 CORBA::Any* try_pull(CORBA::Boolean& has_event);
97 void reincarnate(
const string& oid,
const PersistNode& node);
98 void output(ostream& os);
99 inline unsigned long timestamp()
const {
return _timestamp;}
115 #endif // OMNIEVENTS__PROXYPULLSUPPLIER_H Base class for three of the four Proxy servants.
The EventQueue is a circular buffer, that contains _size-1 events.
const EventChannel_i & _channel
unsigned long timestamp() const
Base class for ServantActivator classes that manage Proxy servants.
bool _connected
Can't use _target to keep track of whether this object is connected, because it is legal to connect w...
CosEventComm::PullConsumer_var _target
#define OMNIEVENTS__DEBUG_REF_COUNTS__DECL
Declares debug versions of _add/remove_ref().
Servant for ProxyPullSupplier interface.
unsigned long _timestamp
Keep track of when this proxy was last contacted.
int _maxNumProxies
Upper limit on number of proxies.
EventQueue & _queue
Reference to queue shared with ProxyPushSuppliers.
Servant for CosEventChannelAdmin::EventChannel objects, also inherits from omni_thread.