summaryrefslogtreecommitdiff
diff options
context:
space:
mode:
authorWilliam R. Otte <wotte@dre.vanderbilt.edu>2009-08-23 04:25:58 +0000
committerWilliam R. Otte <wotte@dre.vanderbilt.edu>2009-08-23 04:25:58 +0000
commitf34a7c6a10786a9d0b86f7b1d305dec79cb3231d (patch)
treeae0290a1dae18d5cd166c7a59a4e686f1b47946e
parentc8dcb144de19611ece5e83e727e8463e8efcf777 (diff)
downloadATCD-f34a7c6a10786a9d0b86f7b1d305dec79cb3231d.tar.gz
Sun Aug 23 04:24:04 UTC 2009 William R. Otte <Wotte@dre.vanderbilt.edu>
-rw-r--r--modules/CIAO/ChangeLog21
-rw-r--r--modules/CIAO/connectors/dds4ccm/examples/Quoter/Base/Quoter_Base.mpc27
-rw-r--r--modules/CIAO/connectors/dds4ccm/examples/Quoter/Connector/Quoter_Connector.idl381
-rw-r--r--modules/CIAO/connectors/dds4ccm/examples/Quoter/Connector/Quoter_Connector.idl3p25
-rw-r--r--modules/CIAO/connectors/dds4ccm/examples/Quoter/Connector/Quoter_Connector.mpc140
-rw-r--r--modules/CIAO/connectors/dds4ccm/examples/Quoter/Connector/Quoter_Connector_exec.cpp444
-rw-r--r--modules/CIAO/connectors/dds4ccm/examples/Quoter/Connector/Quoter_Connector_exec.h372
-rw-r--r--modules/CIAO/connectors/dds4ccm/idl/dds4ccm_Port_RawListen.idl3p4
8 files changed, 1098 insertions, 16 deletions
diff --git a/modules/CIAO/ChangeLog b/modules/CIAO/ChangeLog
index b2549928610..3fe3c319b51 100644
--- a/modules/CIAO/ChangeLog
+++ b/modules/CIAO/ChangeLog
@@ -1,3 +1,22 @@
+Sun Aug 23 04:24:04 UTC 2009 William R. Otte <Wotte@dre.vanderbilt.edu>
+
+ * connectors/dds4ccm/examples/Quoter/Base/Quoter_Base.mpc:
+
+ Base project fixes.
+
+ * connectors/dds4ccm/examples/Quoter/Connector:
+ * connectors/dds4ccm/examples/Quoter/Connector/Quoter_Connector.idl3:
+ * connectors/dds4ccm/examples/Quoter/Connector/Quoter_Connector.idl3p:
+ * connectors/dds4ccm/examples/Quoter/Connector/Quoter_Connector.mpc:
+ * connectors/dds4ccm/examples/Quoter/Connector/Quoter_Connector_exec.h:
+ * connectors/dds4ccm/examples/Quoter/Connector/Quoter_Connector_exec.cpp:
+
+ Connector IDL and skeleton exec impl.
+
+ * connectors/dds4ccm/idl/dds4ccm_Port_RawListen.idl3p:
+
+ Fixed includes.
+
Sat Aug 22 18:33:49 UTC 2009 William R. Otte <Wotte@dre.vanderbilt.edu>
@@ -5,7 +24,7 @@ Sat Aug 22 18:33:49 UTC 2009 William R. Otte <Wotte@dre.vanderbilt.edu>
* connectors/dds4ccm/examples/Quoter/Base:
* connectors/dds4ccm/examples/Quoter/Base/Quoter_Base.idl:
* connectors/dds4ccm/examples/Quoter/Base/Quoter_Base.mpc:
-
+
Quoter base project.
diff --git a/modules/CIAO/connectors/dds4ccm/examples/Quoter/Base/Quoter_Base.mpc b/modules/CIAO/connectors/dds4ccm/examples/Quoter/Base/Quoter_Base.mpc
index 165046eef37..c57a9c8951b 100644
--- a/modules/CIAO/connectors/dds4ccm/examples/Quoter/Base/Quoter_Base.mpc
+++ b/modules/CIAO/connectors/dds4ccm/examples/Quoter/Base/Quoter_Base.mpc
@@ -1,7 +1,7 @@
// $Id$
-// This file is generated with "generate_component_mpc.pl -o ../lib -n Quoter_Base"
+// This file is generated with "generate_component_mpc.pl -o ../lib -u DDS -n Quoter_Base"
-project(Quoter_Base_idl_gen) : componentidldefaults {
+project(DDS_Quoter_Base_idl_gen) : componentidldefaults {
custom_only = 1
idlflags += -Wb,stub_export_macro=QUOTER_BASE_STUB_Export \
-Wb,stub_export_include=Quoter_Base_stub_export.h \
@@ -15,7 +15,7 @@ project(Quoter_Base_idl_gen) : componentidldefaults {
}
}
-project(Quoter_Base_ndds_ts_gen) : ndds_ts_defaults {
+project(DDS_Quoter_Base_ndds_ts_gen) : ndds_ts_defaults {
custom_only = 1
NDDSTypeSupport_Files {
@@ -23,11 +23,11 @@ project(Quoter_Base_ndds_ts_gen) : ndds_ts_defaults {
}
}
-project(Quoter_Base_NDDS_TS) : nddslib {
- after += Quoter_Base_ndds_ts_gen
+project(DDS_Quoter_Base_NDDS_TS) : nddslib {
+ after += DDS_Quoter_Base_ndds_ts_gen
libout = ../lib
- sharedname = Quoter_Base_NDDS_TS
+ sharedname = DDS_Quoter_Base_NDDS_TS
Source_Files {
Quoter_Base.cxx
@@ -42,12 +42,13 @@ project(Quoter_Base_NDDS_TS) : nddslib {
}
}
-project(Quoter_Base_stub) : ccm_stub {
- after += Quoter_Base_idl_gen
+
+project(DDS_Quoter_Base_stub) : ccm_stub {
+ after += DDS_Quoter_Base_idl_gen
libs +=
libout = ../lib
- sharedname = Quoter_Base_stub
+ sharedname = DDS_Quoter_Base_stub
dynamicflags = QUOTER_BASE_STUB_BUILD_DLL
IDL_Files {
@@ -68,10 +69,10 @@ project(Quoter_Base_stub) : ccm_stub {
}
-project(Quoter_Base_skel) : ciao_executor {
- after += Quoter_Base_stub Quoter_Base_lem_stub
- sharedname = Quoter_Base_skel
- libs += Quoter_Base_stub
+project(DDS_Quoter_Base_skel) : ciao_executor {
+ after += DDS_Quoter_Base_stub DDS_Quoter_Base_lem_stub
+ sharedname = DDS_Quoter_Base_skel
+ libs += DDS_Quoter_Base_stub
libout = ../lib
diff --git a/modules/CIAO/connectors/dds4ccm/examples/Quoter/Connector/Quoter_Connector.idl3 b/modules/CIAO/connectors/dds4ccm/examples/Quoter/Connector/Quoter_Connector.idl3
new file mode 100644
index 00000000000..0a820fc1994
--- /dev/null
+++ b/modules/CIAO/connectors/dds4ccm/examples/Quoter/Connector/Quoter_Connector.idl3
@@ -0,0 +1,81 @@
+// $Id$
+
+/**
+ * @file Quoter_Connector.idl3
+ * @author William R. Otte <wotte@dre.vanderbilt.edu>
+ *
+ * by-hand translation of the idl3p.
+ */
+
+#include <Components.idl>
+#include "dds4ccm/idl/dds4ccm_ListenerControl.idl3"
+#include "dds4ccm/idl/dds4ccm_PortStatusListener.idl3"
+#include "dds4ccm/idl/dds4ccm_ConnectorStatusListener.idl3"
+#include "dds4ccm/idl/dds4ccm_ListenerControl.idl3"
+#include "Base/Quoter_Base.idl"
+
+module CCM_DDS
+{
+ // @from DDS_Write for Quoter::Stock_Info
+ interface Stock_Info_Writer
+ {
+ void write (in Quoter::Stock_Info an_instance)
+ raises (InternalError);
+ };
+
+ // @from Reader<T> from DDS_RawListen for Quoter::Stock_Info
+ interface Stock_Info_Reader
+ {
+ typedef sequence<Quoter::Stock_Info> Stock_InfoSeq;
+
+ void read_all (out Stock_InfoSeq instances, out ReadInfoSeq infos)
+ raises (InternalError);
+
+ void read_all_history (out Stock_InfoSeq instances, out ReadInfoSeq infos)
+ raises (InternalError);
+
+ void read_one (inout Quoter::Stock_Info an_instance, out ReadInfo info)
+ raises (NonExistent,
+ InternalError);
+
+ void read_one_history (in Quoter::Stock_Info an_instance,
+ out Stock_InfoSeq instances, out ReadInfoSeq infos)
+ raises (NonExistent,
+ InternalError);
+
+ attribute QueryFilter filter
+ setraises (BadParameter);
+ };
+
+ // @from RawListener for Quoter::Stock_Info
+ interface Stock_Info_RawListener
+ {
+ void on_data (in Quoter::Stock_Info an_instance, in ReadInfo info);
+ };
+};
+
+module Quoter
+{
+ component Quoter_Connector //: CCM_DDS::DDS_TopicBase
+ {
+ // @from DDS_TopicBase
+ readonly attribute string topic_name;
+ readonly attribute DDS::StringSeq key_fields;
+
+ // @from DDS_TopicBase : DDS_Base
+ uses CCM_DDS::ConnectorStatusListener error_listener;
+ readonly attribute DDS::DomainId_t domain_id;
+ readonly attribute string qos_provile;
+
+ // @from DDS_Write for Stock_Info
+ uses CCM_DDS::Stock_Info_Writer info_in_data;
+ uses DDS::DataWriter info_in_dds_entity;
+
+ // @from DDS_RawListen for Stock_Info
+ provides CCM_DDS::Stock_Info_Reader info_out_data;
+ provides CCM_DDS::ListenerControl info_out_control;
+ uses CCM_DDS::Stock_Info_RawListener info_out_listener;
+ provides DDS::DataReader info_out_dds_entity;
+ uses CCM_DDS::PortStatusListener info_out_status;
+ };
+};
diff --git a/modules/CIAO/connectors/dds4ccm/examples/Quoter/Connector/Quoter_Connector.idl3p b/modules/CIAO/connectors/dds4ccm/examples/Quoter/Connector/Quoter_Connector.idl3p
new file mode 100644
index 00000000000..64ea5643fb4
--- /dev/null
+++ b/modules/CIAO/connectors/dds4ccm/examples/Quoter/Connector/Quoter_Connector.idl3p
@@ -0,0 +1,25 @@
+// $Id$
+
+/**
+ * @file Quoter_Connector.idl3p
+ * @author William R. Otte <wotte@dre.vanderbilt.edu>
+ *
+ * IDL3P description of the quoter connector.
+ */
+
+#include <dds4ccm/idl/dds4ccm_Connector_Base.idl3p>
+#include <dds4ccm/idl/dds4ccm_Port_RawListen.idl3p>
+#include <dds4ccm/idl/dds4ccm_Port_Port_Write.idl3p>
+
+module Quoter
+{
+ connector Quoter_Connector : CCM_DDS::DDS_TopicBase
+ {
+ mirrorport CCM_DDS::DDS_Write <Stock_Info> info_in;
+ mirrorport CCM_DDS::DDS_RawListen <Stock_Info> info_out;
+ };
+};
+
+
+
+ \ No newline at end of file
diff --git a/modules/CIAO/connectors/dds4ccm/examples/Quoter/Connector/Quoter_Connector.mpc b/modules/CIAO/connectors/dds4ccm/examples/Quoter/Connector/Quoter_Connector.mpc
new file mode 100644
index 00000000000..bd151538f26
--- /dev/null
+++ b/modules/CIAO/connectors/dds4ccm/examples/Quoter/Connector/Quoter_Connector.mpc
@@ -0,0 +1,140 @@
+// $Id$
+// This file is generated with "generate_component_mpc.pl -p DDS_Quoter_Base -l .. -o ../lib -u DDS Quoter_Connector"
+
+project(DDS_Quoter_Connector_idl_gen) : connectoridldefaults {
+ custom_only = 1
+ idlflags += -Wb,stub_export_macro=QUOTER_CONNECTOR_STUB_Export \
+ -Wb,stub_export_include=Quoter_Connector_stub_export.h \
+ -Wb,skel_export_macro=QUOTER_CONNECTOR_SVNT_Export \
+ -Wb,skel_export_include=Quoter_Connector_svnt_export.h \
+ -Wb,exec_export_macro=QUOTER_CONNECTOR_EXEC_Export \
+ -Wb,exec_export_include=Quoter_Connector_exec_export.h \
+ -I ..
+
+ IDL_Files {
+ Quoter_Connector.idl3
+ }
+}
+
+project(DDS_Quoter_Connector_lem_gen) : ciaoidldefaults {
+ after += DDS_Quoter_Connector_idl_gen
+ custom_only = 1
+ idlflags += -Wb,stub_export_macro=QUOTER_CONNECTOR_LEM_STUB_Export \
+ -Wb,stub_export_include=Quoter_Connector_lem_stub_export.h \
+ -SS -Gxhst \
+ -I .. -I $(CIAO_ROOT)/connectors
+
+ IDL_Files {
+ Quoter_ConnectorE.idl
+ }
+}
+
+project(DDS_Quoter_Connector_lem_stub) : ccm_svnt, dds4ccm_base {
+ after += DDS_Quoter_Connector_lem_gen DDS_Quoter_Connector_stub DDS_Quoter_Base_stub
+ libs += DDS_Quoter_Base_stub Quoter_Connector_stub
+ libpaths += ../lib
+ libout = ../lib
+ includes += ..
+ sharedname = Quoter_Connector_lem_stub
+ dynamicflags = QUOTER_CONNECTOR_LEM_STUB_BUILD_DLL
+
+ IDL_Files {
+ }
+
+ Source_Files {
+ Quoter_ConnectorEC.cpp
+ }
+
+ Header_Files {
+ Quoter_ConnectorEC.h
+ Quoter_Connector_lem_stub_export.h
+ }
+
+ Inline_Files {
+ Quoter_ConnectorEC.inl
+ }
+}
+
+project(DDS_Quoter_Connector_stub) : ccm_stub, dds4ccm_base {
+ after += DDS_Quoter_Connector_idl_gen DDS_Quoter_Base_stub
+ libs += DDS_Quoter_Base_stub
+ libpaths += ../lib
+ libout = ../lib
+ includes += ..
+ sharedname = Quoter_Connector_stub
+ dynamicflags = QUOTER_CONNECTOR_STUB_BUILD_DLL
+
+ IDL_Files {
+ }
+
+ Source_Files {
+ Quoter_ConnectorC.cpp
+ }
+
+ Header_Files {
+ Quoter_ConnectorC.h
+ Quoter_Connector_stub_export.h
+ }
+
+ Inline_Files {
+ Quoter_ConnectorC.inl
+ }
+}
+
+project(DDS_Quoter_Connector_exec) : ciao_executor, dds4ccm_base {
+ after += DDS_Quoter_Connector_lem_stub DDS_Quoter_Connector_stub
+ sharedname = Quoter_Connector_exec
+ libs += Quoter_Connector_stub Quoter_Connector_lem_stub DDS_Quoter_Base_stub
+ libpaths += ../lib
+ libout = ../lib
+ includes += ..
+ dynamicflags = QUOTER_CONNECTOR_EXEC_BUILD_DLL
+
+ IDL_Files {
+ }
+
+ Source_Files {
+ Quoter_Connector_exec.cpp
+ }
+
+ Header_Files {
+ Quoter_Connector_exec.h
+ Quoter_Connector_exec_export.h
+ }
+
+ Inline_Files {
+ }
+}
+
+
+project(DDS_Quoter_Connector_svnt) : ciao_servant, dds4ccm_skel {
+ after += DDS_Quoter_Base_skel DDS_Quoter_Connector_lem_stub
+ sharedname = Quoter_Connector_svnt
+ libs += Quoter_Connector_stub Quoter_Connector_lem_stub \
+ DDS_Quoter_Base_skel \
+ DDS_Quoter_Base_stub
+ libpaths += ../lib
+ libout = ../lib
+ includes += ..
+ dynamicflags = QUOTER_CONNECTOR_SVNT_BUILD_DLL
+
+ IDL_Files {
+ }
+
+ Source_Files {
+ Quoter_ConnectorS.cpp
+ Quoter_Connector_svnt.cpp
+ }
+
+ Header_Files {
+ Quoter_ConnectorS.h
+ Quoter_Connector_svnt.h
+ Quoter_Connector_svnt_export.h
+ }
+
+ Inline_Files {
+ Quoter_ConnectorS.inl
+ }
+}
+
+
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;
+ }
+}
+
diff --git a/modules/CIAO/connectors/dds4ccm/examples/Quoter/Connector/Quoter_Connector_exec.h b/modules/CIAO/connectors/dds4ccm/examples/Quoter/Connector/Quoter_Connector_exec.h
new file mode 100644
index 00000000000..1c5ce7c1542
--- /dev/null
+++ b/modules/CIAO/connectors/dds4ccm/examples/Quoter/Connector/Quoter_Connector_exec.h
@@ -0,0 +1,372 @@
+// -*- 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:1217
+
+#ifndef CIAO_QUOTER_CONNECTOR_EXEC_H_
+#define CIAO_QUOTER_CONNECTOR_EXEC_H_
+
+#include /**/ "ace/pre.h"
+
+#include "Quoter_ConnectorEC.h"
+
+#if !defined (ACE_LACKS_PRAGMA_ONCE)
+# pragma once
+#endif /* ACE_LACKS_PRAGMA_ONCE */
+
+#include /**/ "Quoter_Connector_exec_export.h"
+#include "tao/LocalObject.h"
+
+namespace CIAO_Quoter_Quoter_Connector_Impl
+{
+ class QUOTER_CONNECTOR_EXEC_Export Stock_Info_Reader_exec_i
+ : public virtual ::CCM_DDS::CCM_Stock_Info_Reader,
+ public virtual ::CORBA::LocalObject
+ {
+ public:
+ Stock_Info_Reader_exec_i (void);
+ virtual ~Stock_Info_Reader_exec_i (void);
+
+ // Operations and attributes from ::CCM_DDS::Stock_Info_Reader
+
+ // TAO_IDL - Generated from
+ // be/be_visitor_operation/operation_ch.cpp:46
+
+ virtual void
+ read_all (
+ ::CCM_DDS::Stock_Info_Reader::Stock_InfoSeq_out instances,
+ ::CCM_DDS::ReadInfoSeq_out infos);
+
+ // TAO_IDL - Generated from
+ // be/be_visitor_operation/operation_ch.cpp:46
+
+ virtual void
+ read_all_history (
+ ::CCM_DDS::Stock_Info_Reader::Stock_InfoSeq_out instances,
+ ::CCM_DDS::ReadInfoSeq_out infos);
+
+ // TAO_IDL - Generated from
+ // be/be_visitor_operation/operation_ch.cpp:46
+
+ virtual void
+ read_one (
+ ::Quoter::Stock_Info & an_instance,
+ ::CCM_DDS::ReadInfo_out info);
+
+ // TAO_IDL - Generated from
+ // be/be_visitor_operation/operation_ch.cpp:46
+
+ virtual void
+ read_one_history (
+ const ::Quoter::Stock_Info & an_instance,
+ ::CCM_DDS::Stock_Info_Reader::Stock_InfoSeq_out instances,
+ ::CCM_DDS::ReadInfoSeq_out infos);
+
+ // TAO_IDL - Generated from
+ // be/be_visitor_operation/operation_ch.cpp:46
+
+ virtual ::CCM_DDS::QueryFilter *
+ filter (void);
+
+ // TAO_IDL - Generated from
+ // be/be_visitor_operation/operation_ch.cpp:46
+
+ virtual void
+ filter (
+ const ::CCM_DDS::QueryFilter & filter);
+ };
+
+ class QUOTER_CONNECTOR_EXEC_Export ListenerControl_exec_i
+ : public virtual ::CCM_DDS::CCM_ListenerControl,
+ public virtual ::CORBA::LocalObject
+ {
+ public:
+ ListenerControl_exec_i (void);
+ virtual ~ListenerControl_exec_i (void);
+
+ // Operations and attributes from ::CCM_DDS::ListenerControl
+
+ // TAO_IDL - Generated from
+ // be/be_visitor_operation/operation_ch.cpp:46
+
+ virtual ::CORBA::Boolean
+ enabled (void);
+
+ // TAO_IDL - Generated from
+ // be/be_visitor_operation/operation_ch.cpp:46
+
+ virtual void
+ enabled (
+ ::CORBA::Boolean enabled);
+ };
+
+ class QUOTER_CONNECTOR_EXEC_Export DataReader_exec_i
+ : public virtual ::DDS::CCM_DataReader,
+ public virtual ::CORBA::LocalObject
+ {
+ public:
+ DataReader_exec_i (void);
+ virtual ~DataReader_exec_i (void);
+
+ // Operations and attributes from ::DDS::DataReader
+
+ // TAO_IDL - Generated from
+ // be/be_visitor_operation/operation_ch.cpp:46
+
+ virtual ::DDS::ReturnCode_t
+ enable (void);
+
+ // TAO_IDL - Generated from
+ // be/be_visitor_operation/operation_ch.cpp:46
+
+ virtual ::DDS::StatusCondition_ptr
+ get_statuscondition (void);
+
+ // TAO_IDL - Generated from
+ // be/be_visitor_operation/operation_ch.cpp:46
+
+ virtual ::DDS::StatusMask
+ get_status_changes (void);
+
+ // TAO_IDL - Generated from
+ // be/be_visitor_operation/operation_ch.cpp:46
+
+ virtual ::DDS::InstanceHandle_t
+ get_instance_handle (void);
+
+ // TAO_IDL - Generated from
+ // be/be_visitor_operation/operation_ch.cpp:46
+
+ virtual ::DDS::ReadCondition_ptr
+ create_readcondition (
+ ::DDS::SampleStateMask sample_states,
+ ::DDS::ViewStateMask view_states,
+ ::DDS::InstanceStateMask instance_states);
+
+ // TAO_IDL - Generated from
+ // be/be_visitor_operation/operation_ch.cpp:46
+
+ virtual ::DDS::QueryCondition_ptr
+ create_querycondition (
+ ::DDS::SampleStateMask sample_states,
+ ::DDS::ViewStateMask view_states,
+ ::DDS::InstanceStateMask instance_states,
+ const char * query_expression,
+ const ::DDS::StringSeq & query_parameters);
+
+ // TAO_IDL - Generated from
+ // be/be_visitor_operation/operation_ch.cpp:46
+
+ virtual ::DDS::ReturnCode_t
+ delete_readcondition (
+ ::DDS::ReadCondition_ptr a_condition);
+
+ // TAO_IDL - Generated from
+ // be/be_visitor_operation/operation_ch.cpp:46
+
+ virtual ::DDS::ReturnCode_t
+ delete_contained_entities (void);
+
+ // TAO_IDL - Generated from
+ // be/be_visitor_operation/operation_ch.cpp:46
+
+ virtual ::DDS::ReturnCode_t
+ set_qos (
+ const ::DDS::DataReaderQos & qos);
+
+ // TAO_IDL - Generated from
+ // be/be_visitor_operation/operation_ch.cpp:46
+
+ virtual ::DDS::ReturnCode_t
+ get_qos (
+ ::DDS::DataReaderQos & qos);
+
+ // TAO_IDL - Generated from
+ // be/be_visitor_operation/operation_ch.cpp:46
+
+ virtual ::DDS::ReturnCode_t
+ set_listener (
+ ::DDS::DataReaderListener_ptr a_listener,
+ ::DDS::StatusMask mask);
+
+ // TAO_IDL - Generated from
+ // be/be_visitor_operation/operation_ch.cpp:46
+
+ virtual ::DDS::DataReaderListener_ptr
+ get_listener (void);
+
+ // TAO_IDL - Generated from
+ // be/be_visitor_operation/operation_ch.cpp:46
+
+ virtual ::DDS::TopicDescription_ptr
+ get_topicdescription (void);
+
+ // TAO_IDL - Generated from
+ // be/be_visitor_operation/operation_ch.cpp:46
+
+ virtual ::DDS::Subscriber_ptr
+ get_subscriber (void);
+
+ // TAO_IDL - Generated from
+ // be/be_visitor_operation/operation_ch.cpp:46
+
+ virtual ::DDS::ReturnCode_t
+ get_sample_rejected_status (
+ ::DDS::SampleRejectedStatus & status);
+
+ // TAO_IDL - Generated from
+ // be/be_visitor_operation/operation_ch.cpp:46
+
+ virtual ::DDS::ReturnCode_t
+ get_liveliness_changed_status (
+ ::DDS::LivelinessChangedStatus & status);
+
+ // TAO_IDL - Generated from
+ // be/be_visitor_operation/operation_ch.cpp:46
+
+ virtual ::DDS::ReturnCode_t
+ get_requested_deadline_missed_status (
+ ::DDS::RequestedDeadlineMissedStatus & status);
+
+ // TAO_IDL - Generated from
+ // be/be_visitor_operation/operation_ch.cpp:46
+
+ virtual ::DDS::ReturnCode_t
+ get_requested_incompatible_qos_status (
+ ::DDS::RequestedIncompatibleQosStatus & status);
+
+ // TAO_IDL - Generated from
+ // be/be_visitor_operation/operation_ch.cpp:46
+
+ virtual ::DDS::ReturnCode_t
+ get_subscription_matched_status (
+ ::DDS::SubscriptionMatchedStatus & status);
+
+ // TAO_IDL - Generated from
+ // be/be_visitor_operation/operation_ch.cpp:46
+
+ virtual ::DDS::ReturnCode_t
+ get_sample_lost_status (
+ ::DDS::SampleLostStatus & status);
+
+ // TAO_IDL - Generated from
+ // be/be_visitor_operation/operation_ch.cpp:46
+
+ virtual ::DDS::ReturnCode_t
+ wait_for_historical_data (
+ const ::DDS::Duration_t & max_wait);
+
+ // TAO_IDL - Generated from
+ // be/be_visitor_operation/operation_ch.cpp:46
+
+ virtual ::DDS::ReturnCode_t
+ get_matched_publications (
+ ::DDS::InstanceHandleSeq & publication_handles);
+
+ // TAO_IDL - Generated from
+ // be/be_visitor_operation/operation_ch.cpp:46
+
+ virtual ::DDS::ReturnCode_t
+ get_matched_publication_data (
+ ::DDS::PublicationBuiltinTopicData & publication_data,
+ const ::DDS::InstanceHandle_t & publication_handle);
+ };
+
+ class QUOTER_CONNECTOR_EXEC_Export Quoter_Connector_exec_i
+ : public virtual Quoter_Connector_Exec,
+ public virtual ::CORBA::LocalObject
+ {
+ public:
+ Quoter_Connector_exec_i (void);
+ virtual ~Quoter_Connector_exec_i (void);
+
+ // Supported operations and attributes.
+
+ // Component attributes.
+
+ // TAO_IDL - Generated from
+ // be/be_visitor_operation/operation_ch.cpp:46
+
+ virtual char *
+ topic_name (void);
+
+ // TAO_IDL - Generated from
+ // be/be_visitor_operation/operation_ch.cpp:46
+
+ virtual ::DDS::StringSeq *
+ key_fields (void);
+
+ // TAO_IDL - Generated from
+ // be/be_visitor_operation/operation_ch.cpp:46
+
+ virtual ::DDS::DomainId_t
+ domain_id (void);
+
+ // TAO_IDL - Generated from
+ // be/be_visitor_operation/operation_ch.cpp:46
+
+ virtual char *
+ qos_provile (void);
+
+ // Port operations.
+
+ virtual ::CCM_DDS::CCM_Stock_Info_Reader_ptr
+ get_info_out_data (void);
+
+ virtual ::CCM_DDS::CCM_ListenerControl_ptr
+ get_info_out_control (void);
+
+ virtual ::DDS::CCM_DataReader_ptr
+ get_info_out_dds_entity (void);
+
+ // Operations from Components::SessionComponent.
+
+ virtual void
+ set_session_context (
+ ::Components::SessionContext_ptr ctx);
+
+ virtual void configuration_complete (void);
+
+ virtual void ccm_activate (void);
+ virtual void ccm_passivate (void);
+ virtual void ccm_remove (void);
+
+ private:
+ ::Quoter::CCM_Quoter_Connector_Context_var context_;
+ };
+
+ extern "C" QUOTER_CONNECTOR_EXEC_Export ::Components::EnterpriseComponent_ptr
+ create_Quoter_Quoter_Connector_Impl (void);
+}
+
+#include /**/ "ace/post.h"
+
+#endif /* ifndef */
+
diff --git a/modules/CIAO/connectors/dds4ccm/idl/dds4ccm_Port_RawListen.idl3p b/modules/CIAO/connectors/dds4ccm/idl/dds4ccm_Port_RawListen.idl3p
index ce55031fd7e..c715fb7cf27 100644
--- a/modules/CIAO/connectors/dds4ccm/idl/dds4ccm_Port_RawListen.idl3p
+++ b/modules/CIAO/connectors/dds4ccm/idl/dds4ccm_Port_RawListen.idl3p
@@ -7,9 +7,9 @@
#define DDS4CCM_PORT_RAWLISTEN_IDL3P
#include "dds4ccm/idl/dds4ccm_Reader.idl3p"
-#include "dds4ccm/idl/dds4ccm_ListenerControl.idl3p"
+#include "dds4ccm/idl/dds4ccm_ListenerControl.idl3"
#include "dds4ccm/idl/dds4ccm_RawListener.idl3p"
-#include "dds4ccm/idl/dds4ccm_PortStatusListener.idl3p"
+#include "dds4ccm/idl/dds4ccm_PortStatusListener.idl3"
module CCM_DDS
{