diff options
Diffstat (limited to 'TAO/orbsvcs/orbsvcs/AV/Flows_T.cpp')
-rw-r--r-- | TAO/orbsvcs/orbsvcs/AV/Flows_T.cpp | 252 |
1 files changed, 0 insertions, 252 deletions
diff --git a/TAO/orbsvcs/orbsvcs/AV/Flows_T.cpp b/TAO/orbsvcs/orbsvcs/AV/Flows_T.cpp deleted file mode 100644 index c2e6683d223..00000000000 --- a/TAO/orbsvcs/orbsvcs/AV/Flows_T.cpp +++ /dev/null @@ -1,252 +0,0 @@ -//$Id$ - -#ifndef TAO_AV_FLOWS_T_CPP -#define TAO_AV_FLOWS_T_CPP - -#include "orbsvcs/AV/Flows_T.h" -#include "tao/debug.h" - -TAO_BEGIN_VERSIONED_NAMESPACE_DECL - -// ------------------------------------------------------------ -// TAO_FDev -// ------------------------------------------------------------ - -// default constructor -template <class T_Producer, class T_Consumer> -TAO_FDev<T_Producer, T_Consumer>::TAO_FDev (void) -{ -} - -template <class T_Producer, class T_Consumer> -TAO_FDev<T_Producer, T_Consumer>::TAO_FDev (const char *flowname) - :flowname_ (flowname) -{ - ACE_DECLARE_NEW_CORBA_ENV; - ACE_TRY - { - CORBA::Any flowname_any; - flowname_any <<= flowname; - this->define_property ("Flow", - flowname_any - ACE_ENV_ARG_PARAMETER); - ACE_TRY_CHECK; - } - ACE_CATCHANY - { - ACE_PRINT_EXCEPTION (ACE_ANY_EXCEPTION,"TAO_FDev::TAO_FDev"); - } - ACE_ENDTRY; - ACE_CHECK; -} - -template <class T_Producer, class T_Consumer> -TAO_FDev<T_Producer, T_Consumer>::~TAO_FDev (void) -{ - //no-op -} - -template <class T_Producer, class T_Consumer> -const char * -TAO_FDev<T_Producer, T_Consumer>::flowname (void) -{ - return this->flowname_.in (); -} - -template <class T_Producer, class T_Consumer> -void -TAO_FDev<T_Producer, T_Consumer>::flowname (const char *flow_name) -{ - ACE_DECLARE_NEW_CORBA_ENV; - ACE_TRY - { - CORBA::Any flowname_any; - flowname_any <<= flow_name; - this->define_property ("Flow", - flowname_any - ACE_ENV_ARG_PARAMETER); - ACE_TRY_CHECK; - } - ACE_CATCHANY - { - ACE_PRINT_EXCEPTION (ACE_ANY_EXCEPTION,"TAO_FDev::flowname"); - } - ACE_ENDTRY; - ACE_CHECK; - this->flowname_ = flow_name; -} - -template <class T_Producer, class T_Consumer> -AVStreams::FlowProducer_ptr -TAO_FDev<T_Producer, T_Consumer>::create_producer (AVStreams::FlowConnection_ptr the_requester, - AVStreams::QoS & the_qos, - CORBA::Boolean_out met_qos, - char *& named_fdev - ACE_ENV_ARG_DECL) - ACE_THROW_SPEC ((CORBA::SystemException, - AVStreams::streamOpFailed, - AVStreams::streamOpDenied, - AVStreams::notSupported, - AVStreams::QoSRequestFailed)) -{ - // call the bridge method. - return this->make_producer (the_requester, - the_qos, - met_qos, - named_fdev - ACE_ENV_ARG_PARAMETER); -} - -template <class T_Producer, class T_Consumer> -// hook for the applications to override the creation process. -AVStreams::FlowProducer_ptr -TAO_FDev<T_Producer, T_Consumer>::make_producer (AVStreams::FlowConnection_ptr /* the_requester */, - AVStreams::QoS & /* the_qos */, - CORBA::Boolean_out /* met_qos */, - char *& /* named_fdev */ - ACE_ENV_ARG_DECL) -{ - AVStreams::FlowProducer_ptr producer = AVStreams::FlowProducer::_nil (); - ACE_TRY - { - // Activate the producer implementation under the Root POA. - T_Producer *producer_i; - ACE_NEW_RETURN (producer_i, T_Producer, 0); - this->producer_list_.insert_tail (producer_i); - producer = producer_i->_this (ACE_ENV_SINGLE_ARG_PARAMETER); - ACE_TRY_CHECK; - } - ACE_CATCHANY - { - ACE_PRINT_EXCEPTION (ACE_ANY_EXCEPTION,"TAO_FDev::make_producer"); - return producer; - } - ACE_ENDTRY; - ACE_CHECK_RETURN (producer); - return producer; -} - -template <class T_Producer, class T_Consumer> -// hook for the applications to override the consumer creation. -AVStreams::FlowConsumer_ptr -TAO_FDev<T_Producer, T_Consumer>::make_consumer (AVStreams::FlowConnection_ptr /* the_requester */, - AVStreams::QoS & /* the_qos */, - CORBA::Boolean_out /* met_qos */, - char *& /* named_fdev */ - ACE_ENV_ARG_DECL) -{ - AVStreams::FlowConsumer_ptr consumer = AVStreams::FlowConsumer::_nil (); - ACE_TRY - { - // Activate the consumer implementation under the Root POA. - T_Consumer *consumer_i; - ACE_NEW_RETURN (consumer_i, T_Consumer, 0 ); - - this->consumer_list_.insert_tail (consumer_i); - consumer = consumer_i->_this (ACE_ENV_SINGLE_ARG_PARAMETER); - ACE_TRY_CHECK; - } - ACE_CATCHANY - { - ACE_PRINT_EXCEPTION (ACE_ANY_EXCEPTION,"TAO_FDev::make_consumer"); - return consumer; - } - ACE_ENDTRY; - ACE_CHECK_RETURN (consumer); - return consumer; -} - -template <class T_Producer, class T_Consumer> -AVStreams::FlowConsumer_ptr -TAO_FDev<T_Producer, T_Consumer>::create_consumer (AVStreams::FlowConnection_ptr the_requester, - AVStreams::QoS & the_qos, - CORBA::Boolean_out met_qos, - char *& named_fdev - ACE_ENV_ARG_DECL) - ACE_THROW_SPEC ((CORBA::SystemException, - AVStreams::streamOpFailed, - AVStreams::streamOpDenied, - AVStreams::notSupported, - AVStreams::QoSRequestFailed)) -{ - return this->make_consumer (the_requester, - the_qos, - met_qos, - named_fdev - ACE_ENV_ARG_PARAMETER); -} - -template <class T_Producer, class T_Consumer> -// not implemented yet. -AVStreams::FlowConnection_ptr -TAO_FDev<T_Producer, T_Consumer>::bind (AVStreams::FDev_ptr peer_device, - AVStreams::QoS & the_qos, - CORBA::Boolean_out is_met - ACE_ENV_ARG_DECL) - ACE_THROW_SPEC ((CORBA::SystemException, - AVStreams::streamOpFailed, - AVStreams::QoSRequestFailed)) -{ - ACE_UNUSED_ARG (peer_device); - ACE_UNUSED_ARG (the_qos); - ACE_UNUSED_ARG (is_met); - ACE_CHECK_RETURN (0); - return 0; -} - -template <class T_Producer, class T_Consumer> -// multicast is not supported yet. -AVStreams::FlowConnection_ptr -TAO_FDev<T_Producer, T_Consumer>::bind_mcast (AVStreams::FDev_ptr first_peer, - AVStreams::QoS & the_qos, - CORBA::Boolean_out is_met - ACE_ENV_ARG_DECL) - ACE_THROW_SPEC ((CORBA::SystemException, - AVStreams::streamOpFailed, - AVStreams::QoSRequestFailed)) -{ - ACE_UNUSED_ARG (first_peer); - ACE_UNUSED_ARG (the_qos); - ACE_UNUSED_ARG (is_met); - ACE_CHECK_RETURN (0); - return 0; -} - -template <class T_Producer, class T_Consumer> -void -TAO_FDev<T_Producer, T_Consumer>::destroy (AVStreams::FlowEndPoint_ptr /* the_ep */, - const char * /* fdev_name */ - ACE_ENV_ARG_DECL_NOT_USED) - ACE_THROW_SPEC ((CORBA::SystemException, - AVStreams::notSupported)) -{ - // @@ Shouldn't the parameters be made use of! - // Destroy/delete all the producers and consumers. - - TAO_FlowProducer *producer_i; - - for (PRODUCER_LIST_ITERATOR producer_list_iterator (this->producer_list_); - (producer_i = producer_list_iterator.next ()) != 0; - producer_list_iterator.advance ()) - { - TAO_AV_Core::deactivate_servant (producer_i); - delete producer_i; - } - - TAO_FlowConsumer *consumer_i; - - for (CONSUMER_LIST_ITERATOR consumer_list_iterator (this->consumer_list_); - (consumer_i = consumer_list_iterator.next ()) != 0; - consumer_list_iterator.advance ()) - { - TAO_AV_Core::deactivate_servant (consumer_i); - delete consumer_i; - } - int result = TAO_AV_Core::deactivate_servant (this); - if (result < 0) - if (TAO_debug_level > 0) ACE_DEBUG ((LM_DEBUG,"TAO_StreamEndPoint::destroy failed\n")); -} - -TAO_END_VERSIONED_NAMESPACE_DECL - -#endif /* TAO_AV_FLOWS_T_CPP */ |