// -*- C++ -*- // // $Id$ // **** Code generated by the The ACE ORB (TAO) IDL Compiler **** // 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:588 #ifndef _TAO_IDL_RECEIVERS_CPP_ #define _TAO_IDL_RECEIVERS_CPP_ #include "ReceiverS.h" #include "tao/PortableServer/Operation_Table_Dynamic_Hash.h" #include "tao/PortableServer/Upcall_Command.h" #include "tao/PortableServer/Upcall_Wrapper.h" #include "tao/PortableServer/Basic_SArguments.h" #include "tao/PortableServer/Object_SArgument_T.h" #include "tao/PortableServer/Special_Basic_SArguments.h" #include "tao/PortableServer/UB_String_SArguments.h" #include "tao/PortableServer/TypeCode_SArg_Traits.h" #include "tao/PortableServer/Object_SArg_Traits.h" #include "tao/PortableServer/get_arg.h" #include "tao/Special_Basic_Arguments.h" #include "tao/UB_String_Arguments.h" #include "tao/TAO_Server_Request.h" #include "tao/ORB_Core.h" #include "tao/Profile.h" #include "tao/Stub.h" #include "tao/IFR_Client_Adapter.h" #include "tao/Object_T.h" #include "tao/Typecode.h" #include "tao/DynamicC.h" #include "tao/CDR.h" #include "tao/operation_details.h" #include "tao/PortableInterceptor.h" #include "tao/Basic_Arguments.h" #include "ace/Dynamic_Service.h" #include "ace/Malloc_Allocator.h" #if defined (__BORLANDC__) #pragma option -w-rvl -w-rch -w-ccc -w-aus #endif /* __BORLANDC__ */ #if !defined (__ACE_INLINE__) #include "ReceiverS.inl" #endif /* !defined INLINE */ // TAO_IDL - Generated from // be/be_visitor_arg_traits.cpp:68 // Arg traits specializations. namespace TAO { } // TAO_IDL - Generated from // be/be_visitor_arg_traits.cpp:68 // Arg traits specializations. namespace TAO { } static const TAO_operation_db_entry Receiver_Put_operations [] = { {"connect", &POA_Receiver::Put::connect_skel, 0}, {"onePort", &POA_Receiver::Put::onePort_skel, 0}, {"allPorts", &POA_Receiver::Put::allPorts_skel, 0}, {"_is_a", &POA_Receiver::Put::_is_a_skel, 0}, {"_non_existent", &POA_Receiver::Put::_non_existent_skel, 0}, {"_component", &POA_Receiver::Put::_component_skel, 0}, {"_interface", &POA_Receiver::Put::_interface_skel, 0} }; static const CORBA::Long _tao_Receiver_Put_optable_size = sizeof (ACE_Hash_Map_Entry) * (21); static char _tao_Receiver_Put_optable_pool [_tao_Receiver_Put_optable_size]; static ACE_Static_Allocator_Base _tao_Receiver_Put_allocator (_tao_Receiver_Put_optable_pool, _tao_Receiver_Put_optable_size); static TAO_Dynamic_Hash_OpTable tao_Receiver_Put_optable ( Receiver_Put_operations, 7, 14, &_tao_Receiver_Put_allocator ); // TAO_IDL - Generated from // be/be_visitor_interface/interface_ss.cpp:853 TAO::Collocation_Proxy_Broker * Receiver__TAO_Put_Proxy_Broker_Factory_function (CORBA::Object_ptr) { return reinterpret_cast (0xdead); // Dummy } int Receiver__TAO_Put_Proxy_Broker_Factory_Initializer (size_t) { Receiver__TAO_Put_Proxy_Broker_Factory_function_pointer = Receiver__TAO_Put_Proxy_Broker_Factory_function; return 0; } static int Receiver__TAO_Put_Proxy_Broker_Stub_Factory_Initializer_Scarecrow = Receiver__TAO_Put_Proxy_Broker_Factory_Initializer ( reinterpret_cast (Receiver__TAO_Put_Proxy_Broker_Factory_Initializer) ); // TAO_IDL - Generated from // be/be_visitor_interface/interface_ss.cpp:103 POA_Receiver::Put::Put (void) : TAO_ServantBase () { this->optable_ = &tao_Receiver_Put_optable; } POA_Receiver::Put::Put (const Put& rhs) : TAO_Abstract_ServantBase (rhs), TAO_ServantBase (rhs) { } POA_Receiver::Put::~Put (void) { } namespace POA_Receiver { // TAO_IDL - Generated from // be/be_visitor_operation/upcall_command_ss.cpp:127 class connect_Put : public TAO::Upcall_Command { public: inline connect_Put ( POA_Receiver::Put * servant) : servant_ (servant) { } virtual void execute (ACE_ENV_SINGLE_ARG_DECL) { this->servant_->connect ( ACE_ENV_SINGLE_ARG_PARAMETER); } private: POA_Receiver::Put * const servant_; }; } // TAO_IDL - Generated from // be/be_visitor_operation/operation_ss.cpp:192 void POA_Receiver::Put::connect_skel ( TAO_ServerRequest & server_request, void * TAO_INTERCEPTOR (servant_upcall), void * servant ACE_ENV_ARG_DECL ) { #if TAO_HAS_INTERCEPTORS == 1 static CORBA::TypeCode_ptr const exceptions[] = { Receiver::_tc_invalidRequest }; static size_t const nexceptions = 1; #endif /* TAO_HAS_INTERCEPTORS */ TAO::SArg_Traits< void>::ret_val retval; TAO::Argument * const args[] = { &retval }; static size_t const nargs = 1; POA_Receiver::Put * const impl = static_cast (servant); connect_Put command ( impl); TAO::Upcall_Wrapper upcall_wrapper; upcall_wrapper.upcall (server_request , args , nargs , command #if TAO_HAS_INTERCEPTORS == 1 , servant_upcall , exceptions , nexceptions #endif /* TAO_HAS_INTERCEPTORS == 1 */ ACE_ENV_ARG_PARAMETER); ACE_CHECK; } namespace POA_Receiver { // TAO_IDL - Generated from // be/be_visitor_operation/upcall_command_ss.cpp:127 class onePort_Put : public TAO::Upcall_Command { public: inline onePort_Put ( POA_Receiver::Put * servant, TAO_Operation_Details const * operation_details, TAO::Argument * const args[]) : servant_ (servant) , operation_details_ (operation_details) , args_ (args) { } virtual void execute (ACE_ENV_SINGLE_ARG_DECL) { TAO::SArg_Traits< ::CORBA::Short>::in_arg_type arg_1 = TAO::Portable_Server::get_in_arg< ::CORBA::Short, TAO::SArg_Traits< ::CORBA::Short>::in_arg_type> ( this->operation_details_, this->args_, 1); TAO::SArg_Traits< ::CORBA::Short>::in_arg_type arg_2 = TAO::Portable_Server::get_in_arg< ::CORBA::Short, TAO::SArg_Traits< ::CORBA::Short>::in_arg_type> ( this->operation_details_, this->args_, 2); this->servant_->onePort ( arg_1 , arg_2 ACE_ENV_ARG_PARAMETER); } private: POA_Receiver::Put * const servant_; TAO_Operation_Details const * const operation_details_; TAO::Argument * const * const args_; }; } // TAO_IDL - Generated from // be/be_visitor_operation/operation_ss.cpp:192 void POA_Receiver::Put::onePort_skel ( TAO_ServerRequest & server_request, void * TAO_INTERCEPTOR (servant_upcall), void * servant ACE_ENV_ARG_DECL ) { #if TAO_HAS_INTERCEPTORS == 1 static CORBA::TypeCode_ptr const exceptions[] = { Receiver::_tc_invalidRequest }; static size_t const nexceptions = 1; #endif /* TAO_HAS_INTERCEPTORS */ TAO::SArg_Traits< void>::ret_val retval; TAO::SArg_Traits< ::CORBA::Short>::in_arg_val _tao_portNo; TAO::SArg_Traits< ::CORBA::Short>::in_arg_val _tao_value; TAO::Argument * const args[] = { &retval, &_tao_portNo, &_tao_value }; static size_t const nargs = 3; POA_Receiver::Put * const impl = static_cast (servant); onePort_Put command ( impl, server_request.operation_details (), args); TAO::Upcall_Wrapper upcall_wrapper; upcall_wrapper.upcall (server_request , args , nargs , command #if TAO_HAS_INTERCEPTORS == 1 , servant_upcall , exceptions , nexceptions #endif /* TAO_HAS_INTERCEPTORS == 1 */ ACE_ENV_ARG_PARAMETER); ACE_CHECK; } namespace POA_Receiver { // TAO_IDL - Generated from // be/be_visitor_operation/upcall_command_ss.cpp:127 class allPorts_Put : public TAO::Upcall_Command { public: inline allPorts_Put ( POA_Receiver::Put * servant, TAO_Operation_Details const * operation_details, TAO::Argument * const args[]) : servant_ (servant) , operation_details_ (operation_details) , args_ (args) { } virtual void execute (ACE_ENV_SINGLE_ARG_DECL) { TAO::SArg_Traits< ::CORBA::Short>::in_arg_type arg_1 = TAO::Portable_Server::get_in_arg< ::CORBA::Short, TAO::SArg_Traits< ::CORBA::Short>::in_arg_type> ( this->operation_details_, this->args_, 1); TAO::SArg_Traits< ::CORBA::Short>::in_arg_type arg_2 = TAO::Portable_Server::get_in_arg< ::CORBA::Short, TAO::SArg_Traits< ::CORBA::Short>::in_arg_type> ( this->operation_details_, this->args_, 2); TAO::SArg_Traits< ::CORBA::Short>::in_arg_type arg_3 = TAO::Portable_Server::get_in_arg< ::CORBA::Short, TAO::SArg_Traits< ::CORBA::Short>::in_arg_type> ( this->operation_details_, this->args_, 3); this->servant_->allPorts ( arg_1 , arg_2 , arg_3 ACE_ENV_ARG_PARAMETER); } private: POA_Receiver::Put * const servant_; TAO_Operation_Details const * const operation_details_; TAO::Argument * const * const args_; }; } // TAO_IDL - Generated from // be/be_visitor_operation/operation_ss.cpp:192 void POA_Receiver::Put::allPorts_skel ( TAO_ServerRequest & server_request, void * TAO_INTERCEPTOR (servant_upcall), void * servant ACE_ENV_ARG_DECL ) { #if TAO_HAS_INTERCEPTORS == 1 static CORBA::TypeCode_ptr const exceptions[] = { Receiver::_tc_invalidRequest }; static size_t const nexceptions = 1; #endif /* TAO_HAS_INTERCEPTORS */ TAO::SArg_Traits< void>::ret_val retval; TAO::SArg_Traits< ::CORBA::Short>::in_arg_val _tao_valPort1; TAO::SArg_Traits< ::CORBA::Short>::in_arg_val _tao_valPort2; TAO::SArg_Traits< ::CORBA::Short>::in_arg_val _tao_valPort3; TAO::Argument * const args[] = { &retval, &_tao_valPort1, &_tao_valPort2, &_tao_valPort3 }; static size_t const nargs = 4; POA_Receiver::Put * const impl = static_cast (servant); allPorts_Put command ( impl, server_request.operation_details (), args); TAO::Upcall_Wrapper upcall_wrapper; upcall_wrapper.upcall (server_request , args , nargs , command #if TAO_HAS_INTERCEPTORS == 1 , servant_upcall , exceptions , nexceptions #endif /* TAO_HAS_INTERCEPTORS == 1 */ ACE_ENV_ARG_PARAMETER); ACE_CHECK; } // TAO_IDL - Generated from // be/be_visitor_interface/interface_ss.cpp:169 namespace POA_Receiver { // TAO_IDL - Generated from // be/be_visitor_operation/upcall_command_ss.cpp:127 class _is_a_Put_Upcall_Command : public TAO::Upcall_Command { public: inline _is_a_Put_Upcall_Command ( POA_Receiver::Put * servant, TAO_Operation_Details const * operation_details, TAO::Argument * const args[]) : servant_ (servant) , operation_details_ (operation_details) , args_ (args) { } virtual void execute (ACE_ENV_SINGLE_ARG_DECL) { TAO::SArg_Traits< ::ACE_InputCDR::to_boolean>::ret_arg_type retval = TAO::Portable_Server::get_ret_arg< ::ACE_InputCDR::to_boolean, TAO::SArg_Traits< ::ACE_InputCDR::to_boolean>::ret_arg_type> ( this->operation_details_, this->args_); TAO::SArg_Traits< CORBA::Char *>::in_arg_type arg_1 = TAO::Portable_Server::get_in_arg< CORBA::Char *, TAO::SArg_Traits< CORBA::Char *>::in_arg_type> ( this->operation_details_, this->args_, 1); retval = this->servant_-> _is_a ( arg_1 ACE_ENV_ARG_PARAMETER); } private: POA_Receiver::Put * const servant_; TAO_Operation_Details const * const operation_details_; TAO::Argument * const * const args_; }; } void POA_Receiver::Put::_is_a_skel ( TAO_ServerRequest & server_request, void * TAO_INTERCEPTOR (servant_upcall), void * servant ACE_ENV_ARG_DECL ) { #if TAO_HAS_INTERCEPTORS == 1 static CORBA::TypeCode_ptr const * const exceptions = 0; static size_t const nexceptions = 0; #endif /* TAO_HAS_INTERCEPTORS */ TAO::SArg_Traits< ::ACE_InputCDR::to_boolean>::ret_val retval; TAO::SArg_Traits< CORBA::Char *>::in_arg_val _tao_repository_id; TAO::Argument * const args[] = { &retval, &_tao_repository_id }; static size_t const nargs = 2; POA_Receiver::Put * const impl = static_cast (servant); _is_a_Put_Upcall_Command command ( impl, server_request.operation_details (), args); TAO::Upcall_Wrapper upcall_wrapper; upcall_wrapper.upcall (server_request , args , nargs , command #if TAO_HAS_INTERCEPTORS == 1 , servant_upcall , exceptions , nexceptions #endif /* TAO_HAS_INTERCEPTORS == 1 */ ACE_ENV_ARG_PARAMETER); ACE_CHECK; } namespace POA_Receiver { // TAO_IDL - Generated from // be/be_visitor_operation/upcall_command_ss.cpp:127 class _non_existent_Put_Upcall_Command : public TAO::Upcall_Command { public: inline _non_existent_Put_Upcall_Command ( POA_Receiver::Put * servant, TAO_Operation_Details const * operation_details, TAO::Argument * const args[]) : servant_ (servant) , operation_details_ (operation_details) , args_ (args) { } virtual void execute (ACE_ENV_SINGLE_ARG_DECL) { TAO::SArg_Traits< ::ACE_InputCDR::to_boolean>::ret_arg_type retval = TAO::Portable_Server::get_ret_arg< ::ACE_InputCDR::to_boolean, TAO::SArg_Traits< ::ACE_InputCDR::to_boolean>::ret_arg_type> ( this->operation_details_, this->args_); retval = this->servant_-> _non_existent ( ACE_ENV_SINGLE_ARG_PARAMETER); } private: POA_Receiver::Put * const servant_; TAO_Operation_Details const * const operation_details_; TAO::Argument * const * const args_; }; } void POA_Receiver::Put::_non_existent_skel ( TAO_ServerRequest & server_request, void * TAO_INTERCEPTOR (servant_upcall), void * servant ACE_ENV_ARG_DECL ) { #if TAO_HAS_INTERCEPTORS == 1 static CORBA::TypeCode_ptr const * const exceptions = 0; static size_t const nexceptions = 0; #endif /* TAO_HAS_INTERCEPTORS */ TAO::SArg_Traits< ::ACE_InputCDR::to_boolean>::ret_val retval; TAO::Argument * const args[] = { &retval }; static size_t const nargs = 1; POA_Receiver::Put * const impl = static_cast (servant); _non_existent_Put_Upcall_Command command ( impl, server_request.operation_details (), args); TAO::Upcall_Wrapper upcall_wrapper; upcall_wrapper.upcall (server_request , args , nargs , command #if TAO_HAS_INTERCEPTORS == 1 , servant_upcall , exceptions , nexceptions #endif /* TAO_HAS_INTERCEPTORS == 1 */ ACE_ENV_ARG_PARAMETER); ACE_CHECK; } // TAO_IDL - Generated from // be/be_visitor_interface/interface_ss.cpp:393 void POA_Receiver::Put::_interface_skel ( TAO_ServerRequest & server_request, void * /* servant_upcall */, void * servant ACE_ENV_ARG_DECL ) { TAO_IFR_Client_Adapter *_tao_adapter = ACE_Dynamic_Service::instance ( TAO_ORB_Core::ifr_client_adapter_name () ); if (_tao_adapter == 0) { ACE_THROW (CORBA::INTF_REPOS (CORBA::OMGVMCID | 1, CORBA::COMPLETED_NO)); } POA_Receiver::Put * const impl = static_cast (servant); CORBA::InterfaceDef_ptr _tao_retval = impl->_get_interface (ACE_ENV_SINGLE_ARG_PARAMETER); ACE_CHECK; server_request.init_reply (); TAO_OutputCDR &_tao_out = *server_request.outgoing (); CORBA::Boolean const _tao_result = _tao_adapter->interfacedef_cdr_insert ( _tao_out, _tao_retval ); _tao_adapter->dispose (_tao_retval); if (_tao_result == 0) { ACE_THROW (CORBA::MARSHAL ()); } } namespace POA_Receiver { // TAO_IDL - Generated from // be/be_visitor_operation/upcall_command_ss.cpp:127 class _get_component_Put_Upcall_Command : public TAO::Upcall_Command { public: inline _get_component_Put_Upcall_Command ( POA_Receiver::Put * servant, TAO_Operation_Details const * operation_details, TAO::Argument * const args[]) : servant_ (servant) , operation_details_ (operation_details) , args_ (args) { } virtual void execute (ACE_ENV_SINGLE_ARG_DECL) { TAO::SArg_Traits< ::CORBA::Object>::ret_arg_type retval = TAO::Portable_Server::get_ret_arg< ::CORBA::Object, TAO::SArg_Traits< ::CORBA::Object>::ret_arg_type> ( this->operation_details_, this->args_); retval = this->servant_-> _get_component ( ACE_ENV_SINGLE_ARG_PARAMETER); } private: POA_Receiver::Put * const servant_; TAO_Operation_Details const * const operation_details_; TAO::Argument * const * const args_; }; } void POA_Receiver::Put::_component_skel ( TAO_ServerRequest & server_request, void * TAO_INTERCEPTOR (servant_upcall), void * servant ACE_ENV_ARG_DECL ) { #if TAO_HAS_INTERCEPTORS == 1 static CORBA::TypeCode_ptr const * const exceptions = 0; static size_t const nexceptions = 0; #endif /* TAO_HAS_INTERCEPTORS */ TAO::SArg_Traits< ::CORBA::Object>::ret_val retval; TAO::Argument * const args[] = { &retval }; static size_t const nargs = 1; POA_Receiver::Put * const impl = static_cast (servant); _get_component_Put_Upcall_Command command ( impl, server_request.operation_details (), args); TAO::Upcall_Wrapper upcall_wrapper; upcall_wrapper.upcall (server_request , args , nargs , command #if TAO_HAS_INTERCEPTORS == 1 , servant_upcall , exceptions , nexceptions #endif /* TAO_HAS_INTERCEPTORS == 1 */ ACE_ENV_ARG_PARAMETER); ACE_CHECK; } CORBA::Boolean POA_Receiver::Put::_is_a ( const char* value ACE_ENV_ARG_DECL_NOT_USED ) { return ( !ACE_OS::strcmp ( value, "IDL:Receiver/Put:1.0" ) || !ACE_OS::strcmp ( value, "IDL:omg.org/CORBA/Object:1.0" ) ); } const char* POA_Receiver::Put::_interface_repository_id (void) const { return "IDL:Receiver/Put:1.0"; } // TAO_IDL - Generated from // be/be_visitor_interface/interface_ss.cpp:794 void POA_Receiver::Put::_dispatch ( TAO_ServerRequest & req, void * servant_upcall ACE_ENV_ARG_DECL ) { this->synchronous_upcall_dispatch (req, servant_upcall, this ACE_ENV_ARG_PARAMETER); } // TAO_IDL - Generated from // be/be_visitor_interface/interface_ss.cpp:745 Receiver::Put * POA_Receiver::Put::_this (ACE_ENV_SINGLE_ARG_DECL) { TAO_Stub *stub = this->_create_stub (ACE_ENV_SINGLE_ARG_PARAMETER); ACE_CHECK_RETURN (0); TAO_Stub_Auto_Ptr safe_stub (stub); CORBA::Object_ptr tmp = CORBA::Object::_nil (); CORBA::Boolean _tao_opt_colloc = stub->servant_orb_var ()->orb_core ()->optimize_collocation_objects (); ACE_NEW_RETURN ( tmp, CORBA::Object (stub, _tao_opt_colloc, this), 0 ); CORBA::Object_var obj = tmp; (void) safe_stub.release (); typedef ::Receiver::Put STUB_SCOPED_NAME; return TAO::Narrow_Utils::unchecked_narrow ( obj.in (), Receiver__TAO_Put_Proxy_Broker_Factory_function_pointer ); } #endif /* ifndef */