diff options
author | msmit <msmit@remedy.nl> | 2009-12-09 13:57:41 +0000 |
---|---|---|
committer | msmit <msmit@remedy.nl> | 2009-12-09 13:57:41 +0000 |
commit | 29055d889ee7fe491a7c15fd3e17f2fc100b6040 (patch) | |
tree | cbcf8a032ab28820aadd7b7d269a463515ddbc5f | |
parent | e52fdcaa14195297752833257139aa76b1fcd1f8 (diff) | |
download | ATCD-29055d889ee7fe491a7c15fd3e17f2fc100b6040.tar.gz |
Wed Dec 9 13:58:44 UTC 2009 Marcel Smit <msmit@remedy.nl>
* connectors/dds4ccm/tests/Getter/Receiver/Getter_Test_Receiver.idl:
* connectors/dds4ccm/tests/Getter/Receiver/Getter_Test_Receiver_exec.h:
* connectors/dds4ccm/tests/Getter/Receiver/Getter_Test_Receiver_exec.cpp:
* connectors/dds4ccm/tests/Getter/descriptors/Plan.cdp:
Don't need the ConnectorStatusListener anymore.
* connectors/dds4ccm/tests/Getter/Sender/Getter_Test_Sender_exec.cpp:
Print debug message in stead of an error message.
6 files changed, 12 insertions, 112 deletions
diff --git a/CIAO/ChangeLog b/CIAO/ChangeLog index 5a5643348ae..7d9fce65785 100644 --- a/CIAO/ChangeLog +++ b/CIAO/ChangeLog @@ -1,3 +1,14 @@ +Wed Dec 9 13:58:44 UTC 2009 Marcel Smit <msmit@remedy.nl> + + * connectors/dds4ccm/tests/Getter/Receiver/Getter_Test_Receiver.idl: + * connectors/dds4ccm/tests/Getter/Receiver/Getter_Test_Receiver_exec.h: + * connectors/dds4ccm/tests/Getter/Receiver/Getter_Test_Receiver_exec.cpp: + * connectors/dds4ccm/tests/Getter/descriptors/Plan.cdp: + Don't need the ConnectorStatusListener anymore. + + * connectors/dds4ccm/tests/Getter/Sender/Getter_Test_Sender_exec.cpp: + Print debug message in stead of an error message. + Wed Dec 9 13:54:33 UTC 2009 Johnny Willemsen <jwillemsen@remedy.nl> * ciao/Servants/Servant_Impl_Base.cpp (lookup_facet): diff --git a/CIAO/connectors/dds4ccm/tests/Getter/Receiver/Getter_Test_Receiver.idl b/CIAO/connectors/dds4ccm/tests/Getter/Receiver/Getter_Test_Receiver.idl index 2921724b526..70205446f49 100644 --- a/CIAO/connectors/dds4ccm/tests/Getter/Receiver/Getter_Test_Receiver.idl +++ b/CIAO/connectors/dds4ccm/tests/Getter/Receiver/Getter_Test_Receiver.idl @@ -21,7 +21,6 @@ module Getter_Test port CCM_DDS::GetterTest::DDS_Get info_get; provides GetInvoker getter_invoke; - provides CCM_DDS::ConnectorStatusListener info_out_connector_status; }; }; diff --git a/CIAO/connectors/dds4ccm/tests/Getter/Receiver/Getter_Test_Receiver_exec.cpp b/CIAO/connectors/dds4ccm/tests/Getter/Receiver/Getter_Test_Receiver_exec.cpp index b73ae4b7366..fdefe3b5642 100644 --- a/CIAO/connectors/dds4ccm/tests/Getter/Receiver/Getter_Test_Receiver_exec.cpp +++ b/CIAO/connectors/dds4ccm/tests/Getter/Receiver/Getter_Test_Receiver_exec.cpp @@ -10,56 +10,6 @@ namespace CIAO_Getter_Test_Receiver_Impl { //============================================================ - // ConnectorStatusListener_exec_i - //============================================================ - ConnectorStatusListener_exec_i::ConnectorStatusListener_exec_i (Receiver_exec_i &callback) - : callback_ (callback), - has_run_ (false) - { - } - - ConnectorStatusListener_exec_i::~ConnectorStatusListener_exec_i (void) - { - } - - // Operations from ::CCM_DDS::ConnectorStatusListener - void ConnectorStatusListener_exec_i::on_inconsistent_topic( - ::DDS::Topic_ptr , - const DDS::InconsistentTopicStatus & ) - { - } - - void ConnectorStatusListener_exec_i::on_requested_incompatible_qos( - ::DDS::DataReader_ptr , - const DDS::RequestedIncompatibleQosStatus & ) - { - } - - void ConnectorStatusListener_exec_i::on_sample_rejected( - ::DDS::DataReader_ptr , - const DDS::SampleRejectedStatus & ) - { - } - - void ConnectorStatusListener_exec_i::on_offered_deadline_missed( - ::DDS::DataWriter_ptr , - const DDS::OfferedDeadlineMissedStatus & ) - { - } - - void ConnectorStatusListener_exec_i::on_offered_incompatible_qos( - ::DDS::DataWriter_ptr , - const DDS::OfferedIncompatibleQosStatus & ) - { - } - - void ConnectorStatusListener_exec_i::on_unexpected_status( - ::DDS::Entity_ptr , - ::DDS::StatusKind ) - { - } - - //============================================================ // Invoker_exec_i //============================================================ Invoker_exec_i::Invoker_exec_i (Receiver_exec_i & callback) @@ -331,12 +281,6 @@ namespace CIAO_Getter_Test_Receiver_Impl return new Invoker_exec_i (*this); } - ::CCM_DDS::CCM_ConnectorStatusListener_ptr - Receiver_exec_i::get_info_out_connector_status (void) - { - return new ConnectorStatusListener_exec_i (*this); - } - // Operations from Components::SessionComponent. void Receiver_exec_i::set_session_context ( diff --git a/CIAO/connectors/dds4ccm/tests/Getter/Receiver/Getter_Test_Receiver_exec.h b/CIAO/connectors/dds4ccm/tests/Getter/Receiver/Getter_Test_Receiver_exec.h index 1022ff250dc..c7f78dcba39 100644 --- a/CIAO/connectors/dds4ccm/tests/Getter/Receiver/Getter_Test_Receiver_exec.h +++ b/CIAO/connectors/dds4ccm/tests/Getter/Receiver/Getter_Test_Receiver_exec.h @@ -23,41 +23,6 @@ namespace CIAO_Getter_Test_Receiver_Impl class Receiver_exec_i; //============================================================ - // ConnectorStatusListener_exec_i - //============================================================ - class RECEIVER_EXEC_Export ConnectorStatusListener_exec_i - : public virtual ::CCM_DDS::CCM_ConnectorStatusListener, - public virtual ::CORBA::LocalObject - { - public: - ConnectorStatusListener_exec_i (Receiver_exec_i &); - virtual ~ConnectorStatusListener_exec_i (void); - - virtual - void on_inconsistent_topic( ::DDS::Topic_ptr , - const DDS::InconsistentTopicStatus & ); - virtual - void on_requested_incompatible_qos( ::DDS::DataReader_ptr , - const DDS::RequestedIncompatibleQosStatus & ); - virtual - void on_sample_rejected( ::DDS::DataReader_ptr , - const DDS::SampleRejectedStatus & ); - virtual - void on_offered_deadline_missed( ::DDS::DataWriter_ptr , - const DDS::OfferedDeadlineMissedStatus & ); - virtual - void on_offered_incompatible_qos( ::DDS::DataWriter_ptr , - const DDS::OfferedIncompatibleQosStatus & ); - virtual - void on_unexpected_status( ::DDS::Entity_ptr , - ::DDS::StatusKind ); - private: - /// Maintains a handle that actually process the event - Receiver_exec_i &callback_; - bool has_run_; - }; - - //============================================================ // GetOneHandler //============================================================ class GetOneHandler @@ -142,9 +107,6 @@ namespace CIAO_Getter_Test_Receiver_Impl virtual ::CCM_GetInvoker_ptr get_getter_invoke (); - virtual ::CCM_DDS::CCM_ConnectorStatusListener_ptr - get_info_out_connector_status (void); - void get_no_data (); void start_get_one (const char * key, CORBA::Long iteration); diff --git a/CIAO/connectors/dds4ccm/tests/Getter/Sender/Getter_Test_Sender_exec.cpp b/CIAO/connectors/dds4ccm/tests/Getter/Sender/Getter_Test_Sender_exec.cpp index fbc994464c2..3654009ac04 100644 --- a/CIAO/connectors/dds4ccm/tests/Getter/Sender/Getter_Test_Sender_exec.cpp +++ b/CIAO/connectors/dds4ccm/tests/Getter/Sender/Getter_Test_Sender_exec.cpp @@ -124,7 +124,7 @@ namespace CIAO_Getter_Test_Sender_Impl ACE_Time_Value tv (1, 0); ACE_OS::sleep (tv); this->writer_->write_many (write_many); - CIAO_DEBUG ((LM_ERROR, ACE_TEXT ("write_many : written <%u> samples\n"), + CIAO_DEBUG ((LM_DEBUG, ACE_TEXT ("write_many : written <%u> samples\n"), write_many.length ())); } catch (CCM_DDS::InternalError& ex) diff --git a/CIAO/connectors/dds4ccm/tests/Getter/descriptors/Plan.cdp b/CIAO/connectors/dds4ccm/tests/Getter/descriptors/Plan.cdp index 7c662742c6b..7df4852253c 100644 --- a/CIAO/connectors/dds4ccm/tests/Getter/descriptors/Plan.cdp +++ b/CIAO/connectors/dds4ccm/tests/Getter/descriptors/Plan.cdp @@ -250,22 +250,6 @@ </connection> <connection> - <name>info_out_connector_status_rec</name> - <internalEndpoint> - <portName>info_out_connector_status</portName> - <provider>true</provider> - <kind>Facet</kind> - <instance xmi:idref="ReceiverComponentInstance" /> - </internalEndpoint> - <internalEndpoint> - <portName>error_listener</portName> - <provider>false</provider> - <kind>SimplexReceptacle</kind> - <instance xmi:idref="Getter_Test_ConnectorComponentInstance2" /> - </internalEndpoint> - </connection> - - <connection> <name>info_out_connector_status_sender</name> <internalEndpoint> <portName>info_out_connector_status</portName> |