summaryrefslogtreecommitdiff
path: root/modules/CIAO/connectors/dds4ccm/examples/Quoter/Connector/Quoter_Connector_exec.cpp
diff options
context:
space:
mode:
Diffstat (limited to 'modules/CIAO/connectors/dds4ccm/examples/Quoter/Connector/Quoter_Connector_exec.cpp')
-rw-r--r--modules/CIAO/connectors/dds4ccm/examples/Quoter/Connector/Quoter_Connector_exec.cpp444
1 files changed, 444 insertions, 0 deletions
diff --git a/modules/CIAO/connectors/dds4ccm/examples/Quoter/Connector/Quoter_Connector_exec.cpp b/modules/CIAO/connectors/dds4ccm/examples/Quoter/Connector/Quoter_Connector_exec.cpp
new file mode 100644
index 00000000000..4436c483a18
--- /dev/null
+++ b/modules/CIAO/connectors/dds4ccm/examples/Quoter/Connector/Quoter_Connector_exec.cpp
@@ -0,0 +1,444 @@
+// -*- C++ -*-
+//
+// $Id$
+
+/**
+ * Code generated by the The ACE ORB (TAO) IDL Compiler v1.7.2
+ * TAO and the TAO IDL Compiler have been developed by:
+ * Center for Distributed Object Computing
+ * Washington University
+ * St. Louis, MO
+ * USA
+ * http://www.cs.wustl.edu/~schmidt/doc-center.html
+ * and
+ * Distributed Object Computing Laboratory
+ * University of California at Irvine
+ * Irvine, CA
+ * USA
+ * http://doc.ece.uci.edu/
+ * and
+ * Institute for Software Integrated Systems
+ * Vanderbilt University
+ * Nashville, TN
+ * USA
+ * http://www.isis.vanderbilt.edu/
+ *
+ * Information about TAO is available at:
+ * http://www.cs.wustl.edu/~schmidt/TAO.html
+ **/
+
+// TAO_IDL - Generated from
+// be/be_codegen.cpp:1278
+
+#include "Quoter_Connector_exec.h"
+#include "ciao/CIAO_common.h"
+
+namespace CIAO_Quoter_Quoter_Connector_Impl
+{
+ //============================================================
+ // Facet Executor Implementation Class: Stock_Info_Reader_exec_i
+ //============================================================
+
+ Stock_Info_Reader_exec_i::Stock_Info_Reader_exec_i (void)
+ {
+ }
+
+ Stock_Info_Reader_exec_i::~Stock_Info_Reader_exec_i (void)
+ {
+ }
+
+ // Operations from ::CCM_DDS::Stock_Info_Reader
+
+ void
+ Stock_Info_Reader_exec_i::read_all (
+ ::CCM_DDS::Stock_Info_Reader::Stock_InfoSeq_out /* instances */,
+ ::CCM_DDS::ReadInfoSeq_out /* infos */)
+ {
+ /* Your code here. */
+ }
+
+ void
+ Stock_Info_Reader_exec_i::read_all_history (
+ ::CCM_DDS::Stock_Info_Reader::Stock_InfoSeq_out /* instances */,
+ ::CCM_DDS::ReadInfoSeq_out /* infos */)
+ {
+ /* Your code here. */
+ }
+
+ void
+ Stock_Info_Reader_exec_i::read_one (
+ ::Quoter::Stock_Info & /* an_instance */,
+ ::CCM_DDS::ReadInfo_out /* info */)
+ {
+ /* Your code here. */
+ }
+
+ void
+ Stock_Info_Reader_exec_i::read_one_history (
+ const ::Quoter::Stock_Info & /* an_instance */,
+ ::CCM_DDS::Stock_Info_Reader::Stock_InfoSeq_out /* instances */,
+ ::CCM_DDS::ReadInfoSeq_out /* infos */)
+ {
+ /* Your code here. */
+ }
+
+ ::CCM_DDS::QueryFilter *
+ Stock_Info_Reader_exec_i::filter (void)
+ {
+ /* Your code here. */
+ return 0;
+ }
+
+ void
+ Stock_Info_Reader_exec_i::filter (
+ const ::CCM_DDS::QueryFilter & /* filter */)
+ {
+ /* Your code here. */
+ }
+ //============================================================
+ // Facet Executor Implementation Class: ListenerControl_exec_i
+ //============================================================
+
+ ListenerControl_exec_i::ListenerControl_exec_i (void)
+ {
+ }
+
+ ListenerControl_exec_i::~ListenerControl_exec_i (void)
+ {
+ }
+
+ // Operations from ::CCM_DDS::ListenerControl
+
+ ::CORBA::Boolean
+ ListenerControl_exec_i::enabled (void)
+ {
+ /* Your code here. */
+ return false;
+ }
+
+ void
+ ListenerControl_exec_i::enabled (
+ ::CORBA::Boolean /* enabled */)
+ {
+ /* Your code here. */
+ }
+ //============================================================
+ // Facet Executor Implementation Class: DataReader_exec_i
+ //============================================================
+
+ DataReader_exec_i::DataReader_exec_i (void)
+ {
+ }
+
+ DataReader_exec_i::~DataReader_exec_i (void)
+ {
+ }
+
+ // Operations from ::DDS::DataReader
+
+ ::DDS::ReturnCode_t
+ DataReader_exec_i::enable (void)
+ {
+ /* Your code here. */
+ return 0;
+ }
+
+ ::DDS::StatusCondition_ptr
+ DataReader_exec_i::get_statuscondition (void)
+ {
+ /* Your code here. */
+ return ::DDS::StatusCondition::_nil ();
+ }
+
+ ::DDS::StatusMask
+ DataReader_exec_i::get_status_changes (void)
+ {
+ /* Your code here. */
+ return 0;
+ }
+
+ ::DDS::InstanceHandle_t
+ DataReader_exec_i::get_instance_handle (void)
+ {
+ /* Your code here. */
+ return ::DDS::NativeInstanceHandle_t ();
+ }
+
+ ::DDS::ReadCondition_ptr
+ DataReader_exec_i::create_readcondition (
+ ::DDS::SampleStateMask /* sample_states */,
+ ::DDS::ViewStateMask /* view_states */,
+ ::DDS::InstanceStateMask /* instance_states */)
+ {
+ /* Your code here. */
+ return ::DDS::ReadCondition::_nil ();
+ }
+
+ ::DDS::QueryCondition_ptr
+ DataReader_exec_i::create_querycondition (
+ ::DDS::SampleStateMask /* sample_states */,
+ ::DDS::ViewStateMask /* view_states */,
+ ::DDS::InstanceStateMask /* instance_states */,
+ const char * /* query_expression */,
+ const ::DDS::StringSeq & /* query_parameters */)
+ {
+ /* Your code here. */
+ return ::DDS::QueryCondition::_nil ();
+ }
+
+ ::DDS::ReturnCode_t
+ DataReader_exec_i::delete_readcondition (
+ ::DDS::ReadCondition_ptr /* a_condition */)
+ {
+ /* Your code here. */
+ return 0;
+ }
+
+ ::DDS::ReturnCode_t
+ DataReader_exec_i::delete_contained_entities (void)
+ {
+ /* Your code here. */
+ return 0;
+ }
+
+ ::DDS::ReturnCode_t
+ DataReader_exec_i::set_qos (
+ const ::DDS::DataReaderQos & /* qos */)
+ {
+ /* Your code here. */
+ return 0;
+ }
+
+ ::DDS::ReturnCode_t
+ DataReader_exec_i::get_qos (
+ ::DDS::DataReaderQos & /* qos */)
+ {
+ /* Your code here. */
+ return 0;
+ }
+
+ ::DDS::ReturnCode_t
+ DataReader_exec_i::set_listener (
+ ::DDS::DataReaderListener_ptr /* a_listener */,
+ ::DDS::StatusMask /* mask */)
+ {
+ /* Your code here. */
+ return 0;
+ }
+
+ ::DDS::DataReaderListener_ptr
+ DataReader_exec_i::get_listener (void)
+ {
+ /* Your code here. */
+ return ::DDS::DataReaderListener::_nil ();
+ }
+
+ ::DDS::TopicDescription_ptr
+ DataReader_exec_i::get_topicdescription (void)
+ {
+ /* Your code here. */
+ return ::DDS::TopicDescription::_nil ();
+ }
+
+ ::DDS::Subscriber_ptr
+ DataReader_exec_i::get_subscriber (void)
+ {
+ /* Your code here. */
+ return ::DDS::Subscriber::_nil ();
+ }
+
+ ::DDS::ReturnCode_t
+ DataReader_exec_i::get_sample_rejected_status (
+ ::DDS::SampleRejectedStatus & /* status */)
+ {
+ /* Your code here. */
+ return 0;
+ }
+
+ ::DDS::ReturnCode_t
+ DataReader_exec_i::get_liveliness_changed_status (
+ ::DDS::LivelinessChangedStatus & /* status */)
+ {
+ /* Your code here. */
+ return 0;
+ }
+
+ ::DDS::ReturnCode_t
+ DataReader_exec_i::get_requested_deadline_missed_status (
+ ::DDS::RequestedDeadlineMissedStatus & /* status */)
+ {
+ /* Your code here. */
+ return 0;
+ }
+
+ ::DDS::ReturnCode_t
+ DataReader_exec_i::get_requested_incompatible_qos_status (
+ ::DDS::RequestedIncompatibleQosStatus & /* status */)
+ {
+ /* Your code here. */
+ return 0;
+ }
+
+ ::DDS::ReturnCode_t
+ DataReader_exec_i::get_subscription_matched_status (
+ ::DDS::SubscriptionMatchedStatus & /* status */)
+ {
+ /* Your code here. */
+ return 0;
+ }
+
+ ::DDS::ReturnCode_t
+ DataReader_exec_i::get_sample_lost_status (
+ ::DDS::SampleLostStatus & /* status */)
+ {
+ /* Your code here. */
+ return 0;
+ }
+
+ ::DDS::ReturnCode_t
+ DataReader_exec_i::wait_for_historical_data (
+ const ::DDS::Duration_t & /* max_wait */)
+ {
+ /* Your code here. */
+ return 0;
+ }
+
+ ::DDS::ReturnCode_t
+ DataReader_exec_i::get_matched_publications (
+ ::DDS::InstanceHandleSeq & /* publication_handles */)
+ {
+ /* Your code here. */
+ return 0;
+ }
+
+ ::DDS::ReturnCode_t
+ DataReader_exec_i::get_matched_publication_data (
+ ::DDS::PublicationBuiltinTopicData & /* publication_data */,
+ const ::DDS::InstanceHandle_t & /* publication_handle */)
+ {
+ /* Your code here. */
+ return 0;
+ }
+
+ //============================================================
+ // Component Executor Implementation Class: Quoter_Connector_exec_i
+ //============================================================
+
+ Quoter_Connector_exec_i::Quoter_Connector_exec_i (void)
+ {
+ }
+
+ Quoter_Connector_exec_i::~Quoter_Connector_exec_i (void)
+ {
+ }
+
+ // Supported operations and attributes.
+
+ // Component attributes.
+
+ char *
+ Quoter_Connector_exec_i::topic_name (void)
+ {
+ /* Your code here. */
+ return 0;
+ }
+
+ ::DDS::StringSeq *
+ Quoter_Connector_exec_i::key_fields (void)
+ {
+ /* Your code here. */
+ return 0;
+ }
+
+ ::DDS::DomainId_t
+ Quoter_Connector_exec_i::domain_id (void)
+ {
+ /* Your code here. */
+ return 0;
+ }
+
+ char *
+ Quoter_Connector_exec_i::qos_provile (void)
+ {
+ /* Your code here. */
+ return 0;
+ }
+
+ // Port operations.
+
+ ::CCM_DDS::CCM_Stock_Info_Reader_ptr
+ Quoter_Connector_exec_i::get_info_out_data (void)
+ {
+ /* Your code here. */
+ return ::CCM_DDS::CCM_Stock_Info_Reader::_nil ();
+ }
+
+ ::CCM_DDS::CCM_ListenerControl_ptr
+ Quoter_Connector_exec_i::get_info_out_control (void)
+ {
+ /* Your code here. */
+ return ::CCM_DDS::CCM_ListenerControl::_nil ();
+ }
+
+ ::DDS::CCM_DataReader_ptr
+ Quoter_Connector_exec_i::get_info_out_dds_entity (void)
+ {
+ /* Your code here. */
+ return ::DDS::CCM_DataReader::_nil ();
+ }
+
+ // Operations from Components::SessionComponent.
+
+ void
+ Quoter_Connector_exec_i::set_session_context (
+ ::Components::SessionContext_ptr ctx)
+ {
+ ::Quoter::CCM_Quoter_Connector_Context_var lctx =
+ ::Quoter::CCM_Quoter_Connector_Context::_narrow (ctx);
+
+ if ( ::CORBA::is_nil (lctx.in ()))
+ {
+ throw ::CORBA::INTERNAL ();
+ }
+
+ this->context_ = lctx;
+ }
+
+ void
+ Quoter_Connector_exec_i::configuration_complete (void)
+ {
+ /* Your code here. */
+ }
+
+ void
+ Quoter_Connector_exec_i::ccm_activate (void)
+ {
+ /* Your code here. */
+ }
+
+ void
+ Quoter_Connector_exec_i::ccm_passivate (void)
+ {
+ /* Your code here. */
+ }
+
+ void
+ Quoter_Connector_exec_i::ccm_remove (void)
+ {
+ /* Your code here. */
+ }
+
+ extern "C" QUOTER_CONNECTOR_EXEC_Export ::Components::EnterpriseComponent_ptr
+ create_Quoter_Quoter_Connector_Impl (void)
+ {
+ ::Components::EnterpriseComponent_ptr retval =
+ ::Components::EnterpriseComponent::_nil ();
+
+ ACE_NEW_NORETURN (
+ retval,
+ Quoter_Connector_exec_i);
+
+ return retval;
+ }
+}
+