diff options
author | msmit <msmit@remedy.nl> | 2009-11-18 14:00:33 +0000 |
---|---|---|
committer | msmit <msmit@remedy.nl> | 2009-11-18 14:00:33 +0000 |
commit | 10604fa901e99d3bae280cdf650faeadc9c82077 (patch) | |
tree | 3dd0b9955d53d71370bd5a1521b64d3decb7556f /CIAO/connectors/dds4ccm/tests/Get_Connection_Test/Receiver/Get_Connection_Test_Receiver_exec.h | |
parent | 00e4997825543bd196c5bae6f2c3deed62ac9029 (diff) | |
download | ATCD-10604fa901e99d3bae280cdf650faeadc9c82077.tar.gz |
Wed Nov 18 13:58:28 UTC 2009 Marcel Smit <msmit@remedy.nl>
* DAnCE/NodeApplication/NodeApplication_Impl.cpp:
Resolved minor typo.
* bin/ciao_tests.lst:
* connectors/dds4ccm/tests/Get_Connection_Test:
* connectors/dds4ccm/tests/Get_Connection_Test/Base:
* connectors/dds4ccm/tests/Get_Connection_Test/Base/Get_Connection_Test_Base.idl:
* connectors/dds4ccm/tests/Get_Connection_Test/Base/Get_Connection_Test_Base.mpc:
* connectors/dds4ccm/tests/Get_Connection_Test/Connector:
* connectors/dds4ccm/tests/Get_Connection_Test/Connector/Get_Connection_Test_Connector.idl:
* connectors/dds4ccm/tests/Get_Connection_Test/Connector/Get_Connection_Test_Connector.mpc:
* connectors/dds4ccm/tests/Get_Connection_Test/Connector/Get_Connection_Test_Connector_exec.h:
* connectors/dds4ccm/tests/Get_Connection_Test/Connector/Get_Connection_Test_Connector_exec.cpp:
* connectors/dds4ccm/tests/Get_Connection_Test/Receiver:
* connectors/dds4ccm/tests/Get_Connection_Test/Receiver/Get_Connection_Test_Receiver.idl:
* connectors/dds4ccm/tests/Get_Connection_Test/Receiver/Get_Connection_Test_Receiver.mpc:
* connectors/dds4ccm/tests/Get_Connection_Test/Receiver/Get_Connection_Test_Receiver_exec.h:
* connectors/dds4ccm/tests/Get_Connection_Test/Receiver/Get_Connection_Test_Receiver_exec.cpp:
* connectors/dds4ccm/tests/Get_Connection_Test/Sender:
* connectors/dds4ccm/tests/Get_Connection_Test/Sender/Get_Connection_Test_Sender.idl:
* connectors/dds4ccm/tests/Get_Connection_Test/Sender/Get_Connection_Test_Sender.mpc:
* connectors/dds4ccm/tests/Get_Connection_Test/Sender/Get_Connection_Test_Sender_exec.h:
* connectors/dds4ccm/tests/Get_Connection_Test/Sender/Get_Connection_Test_Sender_exec.cpp:
* connectors/dds4ccm/tests/Get_Connection_Test/descriptors:
* connectors/dds4ccm/tests/Get_Connection_Test/descriptors/Plan.cdp:
* connectors/dds4ccm/tests/Get_Connection_Test/descriptors/USER_QOS_PROFILES.xml:
* connectors/dds4ccm/tests/Get_Connection_Test/descriptors/run_test.pl:
Added test to test connections within DDS4CCM.
* connectors/dds4ccm/tests/KeyedSamples/descriptors/Plan.cdp:
* connectors/dds4ccm/tests/UnkeyedSamples/descriptors/Plan.cdp:
Changed naming of topics.
Diffstat (limited to 'CIAO/connectors/dds4ccm/tests/Get_Connection_Test/Receiver/Get_Connection_Test_Receiver_exec.h')
-rw-r--r-- | CIAO/connectors/dds4ccm/tests/Get_Connection_Test/Receiver/Get_Connection_Test_Receiver_exec.h | 110 |
1 files changed, 110 insertions, 0 deletions
diff --git a/CIAO/connectors/dds4ccm/tests/Get_Connection_Test/Receiver/Get_Connection_Test_Receiver_exec.h b/CIAO/connectors/dds4ccm/tests/Get_Connection_Test/Receiver/Get_Connection_Test_Receiver_exec.h new file mode 100644 index 00000000000..4e36374c4e0 --- /dev/null +++ b/CIAO/connectors/dds4ccm/tests/Get_Connection_Test/Receiver/Get_Connection_Test_Receiver_exec.h @@ -0,0 +1,110 @@ +// -*- C++ -*- +// $Id$ + +#ifndef CIAO_RECEIVER_EXEC_H_ +#define CIAO_RECEIVER_EXEC_H_ + +#include "Get_Connection_Test_ReceiverEC.h" + +#include /**/ "Receiver_exec_export.h" + +#if !defined (ACE_LACKS_PRAGMA_ONCE) +# pragma once +#endif /* ACE_LACKS_PRAGMA_ONCE */ + +#include "tao/LocalObject.h" +#include "ace/Task.h" +#include "ace/Reactor.h" + +namespace CIAO_Get_Connection_Test_Receiver_Impl +{ + class RECEIVER_EXEC_Export Get_ConnectionTest_Listener_exec_i + : public virtual ::CCM_DDS::Get_ConnectionTest::CCM_Listener, + public virtual ::CORBA::LocalObject + { + public: + Get_ConnectionTest_Listener_exec_i (); + virtual ~Get_ConnectionTest_Listener_exec_i (void); + + virtual void + on_one_data ( + const Get_ConnectionTest & an_instance, + const ::CCM_DDS::ReadInfo & info); + virtual void + on_many_data ( + const Get_ConnectionTest_Seq & an_instance, + const ::CCM_DDS::ReadInfoSeq & info); + private: + }; + + class RECEIVER_EXEC_Export PortStatusListener_exec_i + : public virtual ::CCM_DDS::CCM_PortStatusListener, + public virtual ::CORBA::LocalObject + { + public: + PortStatusListener_exec_i (void); + virtual ~PortStatusListener_exec_i (void); + + virtual void + on_requested_deadline_missed ( + ::DDS::DataReader_ptr the_reader, + const ::DDS::RequestedDeadlineMissedStatus & status); + + virtual void + on_sample_lost ( + ::DDS::DataReader_ptr the_reader, + const ::DDS::SampleLostStatus & status); + }; + + class RECEIVER_EXEC_Export Receiver_exec_i + : public virtual Receiver_Exec, + public virtual ::CORBA::LocalObject + { + public: + Receiver_exec_i (void); + virtual ~Receiver_exec_i (void); + + // Port operations. + virtual ::CCM_DDS::Get_ConnectionTest::CCM_Listener_ptr + get_info_listen_data_listener (void); + + virtual ::CCM_DDS::CCM_PortStatusListener_ptr + get_info_listen_status (void); + + virtual ::CCM_DDS::CCM_PortStatusListener_ptr + get_info_get_status (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: + ::Get_Connection_Test::CCM_Receiver_Context_var context_; + ::CCM_DDS::Get_ConnectionTest::Reader_var reader_; + ::CCM_DDS::Get_ConnectionTest::Getter_var getter_; + ::CCM_DDS::Get_ConnectionTest::Reader_var reader_listen_; + ::DDS::DataReader_var dds_data_reader_; + ::DDS::DataReader_var dds_data_reader_listen_; + + bool getter_ok_; + bool reader_listen_ok_; + bool dds_data_reader_listen_ok_; + bool data_listener_control_ok_; + bool raw_listener_created_; + bool listen_port_status_created_; + bool get_port_status_created_; + }; + + extern "C" RECEIVER_EXEC_Export ::Components::EnterpriseComponent_ptr + create_Get_Connection_Test_Receiver_Impl (void); +} + +#endif /* ifndef */ + |