summaryrefslogtreecommitdiff
path: root/TAO/examples/Simulator/Event_Supplier/DOVE_Supplier.h
diff options
context:
space:
mode:
Diffstat (limited to 'TAO/examples/Simulator/Event_Supplier/DOVE_Supplier.h')
-rw-r--r--TAO/examples/Simulator/Event_Supplier/DOVE_Supplier.h140
1 files changed, 0 insertions, 140 deletions
diff --git a/TAO/examples/Simulator/Event_Supplier/DOVE_Supplier.h b/TAO/examples/Simulator/Event_Supplier/DOVE_Supplier.h
deleted file mode 100644
index 05c1d68dd39..00000000000
--- a/TAO/examples/Simulator/Event_Supplier/DOVE_Supplier.h
+++ /dev/null
@@ -1,140 +0,0 @@
-// $Id$
-
-// ============================================================================
-//
-// = FILENAME
-// DOVE_Supplier.h
-//
-// = DESCRIPTION
-// A wrapper around the event service initialization and marshalling.
-//
-// = AUTHORS
-// Michael Kircher (mk1@cs.wustl.edu)
-// Chris Gill (cdgill@cs.wustl.edu)
-// ============================================================================
-
-#include "ace/OS.h"
-
-#if !defined (ACE_LACKS_PRAGMA_ONCE)
-# pragma once
-#endif /* ACE_LACKS_PRAGMA_ONCE */
-
-#include "tao/corba.h"
-#include "orbsvcs/RtecEventChannelAdminC.h"
-#include "orbsvcs/RtecEventCommS.h"
-#include "orbsvcs/Event_Utilities.h"
-#include "orbsvcs/Event_Service_Constants.h"
-#include "orbsvcs/Scheduler_Factory.h"
-
-
-#ifndef DOVE_SUPPLIER_H
-#define DOVE_SUPPLIER_H
-
-#define SOURCE_ID 123
-
-class DOVE_Supplier
-{
-public:
-
- DOVE_Supplier ();
- // Constructor.
-
- ~DOVE_Supplier (void);
- // Destructor.
-
- int init (void);
- // Initialize the ORB and the connection to the Name Service
-
- int connect (const char * MIB_name = 0,
- const char* es_name = 0,
- const char * ss_name = 0,
- ACE_Scheduler_Factory::POD_RT_Info * pod_rt_info = 0);
- // Connect to the event service.
-
- void connected ();
- // Perform all post-connection-establishment processing.
-
- void disconnect ();
- // Disconnect from the event service.
-
- void notify (CORBA::Any& message);
- // Notify the consumer proxy that we have events
-
- void use_next_connection ();
- // Use the next connection in the list of established connections.
-
- void use_prev_connection ();
- // Use the previous connection in the list of established connections.
-
-private:
-
- // The following Supplier is needed because DOVE_Supplier has not
- // inherited from PushSupplier.
-
- class Internal_DOVE_Supplier : public POA_RtecEventComm::PushSupplier
- {
- friend class DOVE_Supplier;
-
- public:
-
- virtual void disconnect_push_supplier (CORBA::Environment &)
- {
- }
-
- private:
-
- Internal_DOVE_Supplier (DOVE_Supplier* impl_ptr);
-
- DOVE_Supplier* impl_ptr_;
- };
-
-private:
-
- struct Connection_Params
- {
- const char * es_name_;
- const char * ss_name_;
- RtecEventChannelAdmin::EventChannel_var eventChannel_var_;
- RtecEventChannelAdmin::SupplierAdmin_var supplierAdmin_var_;
- RtecEventChannelAdmin::ProxyPushConsumer_var proxyPushConsumer_var_;
- RtecScheduler::Scheduler_var scheduler_var_;
- RtecScheduler::handle_t rt_info_;
- ACE_Scheduler_Factory::POD_RT_Info pod_rt_info_;
- };
-
- int get_EventChannel ();
- // Get the event channel reference.
-
- int get_Scheduler ();
- // Get the scheduler reference.
-
- int connect_Supplier ();
- // Connect the the supplier with the event channel.
-
- static ACE_Scheduler_Factory::POD_RT_Info * pod_rt_info_instance ();
- // Access the default rt_info singleton.
-
- static ACE_Scheduler_Factory::POD_RT_Info * pod_rt_info_instance_;
-
- // Object initialization flags
- int initialized_;
- int connected_;
-
- Connection_Params ** connection_params_list_;
- Connection_Params * current_connection_params_;
- int connection_count_;
- int current_connection_index_;
-
- // = ORB, ORB Services adminstration references.
- CosNaming::NamingContext_var namingContext_var_;
- PortableServer::POA_var root_POA_var_;
- PortableServer::POAManager_var poa_manager_;
-
- Internal_DOVE_Supplier* internal_DOVE_Supplier_ptr_;
-
- const char * MIB_name_;
- // Keep the name of the MIB around.
-};
-
-#endif /* DOVE_SUPPLIER_H */
-