From f34a7c6a10786a9d0b86f7b1d305dec79cb3231d Mon Sep 17 00:00:00 2001 From: "William R. Otte" Date: Sun, 23 Aug 2009 04:25:58 +0000 Subject: Sun Aug 23 04:24:04 UTC 2009 William R. Otte --- modules/CIAO/ChangeLog | 21 +- .../dds4ccm/examples/Quoter/Base/Quoter_Base.mpc | 27 +- .../Quoter/Connector/Quoter_Connector.idl3 | 81 ++++ .../Quoter/Connector/Quoter_Connector.idl3p | 25 ++ .../examples/Quoter/Connector/Quoter_Connector.mpc | 140 +++++++ .../Quoter/Connector/Quoter_Connector_exec.cpp | 444 +++++++++++++++++++++ .../Quoter/Connector/Quoter_Connector_exec.h | 372 +++++++++++++++++ .../dds4ccm/idl/dds4ccm_Port_RawListen.idl3p | 4 +- 8 files changed, 1098 insertions(+), 16 deletions(-) create mode 100644 modules/CIAO/connectors/dds4ccm/examples/Quoter/Connector/Quoter_Connector.idl3 create mode 100644 modules/CIAO/connectors/dds4ccm/examples/Quoter/Connector/Quoter_Connector.idl3p create mode 100644 modules/CIAO/connectors/dds4ccm/examples/Quoter/Connector/Quoter_Connector.mpc create mode 100644 modules/CIAO/connectors/dds4ccm/examples/Quoter/Connector/Quoter_Connector_exec.cpp create mode 100644 modules/CIAO/connectors/dds4ccm/examples/Quoter/Connector/Quoter_Connector_exec.h (limited to 'modules') 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 + + * 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 @@ -5,7 +24,7 @@ Sat Aug 22 18:33:49 UTC 2009 William R. Otte * 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 + * + * by-hand translation of the idl3p. + */ + +#include +#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 from DDS_RawListen for Quoter::Stock_Info + interface Stock_Info_Reader + { + typedef sequence 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 + * + * IDL3P description of the quoter connector. + */ + +#include +#include +#include + +module Quoter +{ + connector Quoter_Connector : CCM_DDS::DDS_TopicBase + { + mirrorport CCM_DDS::DDS_Write info_in; + mirrorport CCM_DDS::DDS_RawListen 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 { -- cgit v1.2.1