diff options
author | parsons <parsons@ae88bc3d-4319-0410-8dbf-d08b4c9d3795> | 2003-03-12 16:18:58 +0000 |
---|---|---|
committer | parsons <parsons@ae88bc3d-4319-0410-8dbf-d08b4c9d3795> | 2003-03-12 16:18:58 +0000 |
commit | 311d9d74b593b8b8856151e3e1358df3f00feb0f (patch) | |
tree | bf1c5cdcd20e3d61ed9d590adfaef8b5fce061df /TAO/tao/Messaging/MessagingS.cpp | |
parent | f5bacbe21762d818bb4e4f70961040e26061e840 (diff) | |
download | ATCD-311d9d74b593b8b8856151e3e1358df3f00feb0f.tar.gz |
ChangeLogTag: Wed Mar 12 09:49:00 2003 Jeff Parsons <j.parsons@vanderbilt.edu>
Diffstat (limited to 'TAO/tao/Messaging/MessagingS.cpp')
-rw-r--r-- | TAO/tao/Messaging/MessagingS.cpp | 134 |
1 files changed, 67 insertions, 67 deletions
diff --git a/TAO/tao/Messaging/MessagingS.cpp b/TAO/tao/Messaging/MessagingS.cpp index cb0d3d1370a..c20d9a19c09 100644 --- a/TAO/tao/Messaging/MessagingS.cpp +++ b/TAO/tao/Messaging/MessagingS.cpp @@ -20,12 +20,13 @@ // http://www.cs.wustl.edu/~schmidt/TAO.html -// TAO_IDL - Generated from -// be/be_codegen.cpp:663 +// TAO_IDL - Generated from +// W:\ACE_wrappers\TAO\TAO_IDL\be\be_codegen.cpp:670 #ifndef _TAO_IDL_ORIG_MESSAGINGS_CPP_ #define _TAO_IDL_ORIG_MESSAGINGS_CPP_ + #include "MessagingS.h" #include "tao/PortableServer/Object_Adapter.h" #include "tao/PortableServer/Operation_Table.h" @@ -34,7 +35,6 @@ #include "tao/Stub.h" #include "tao/IFR_Client_Adapter.h" #include "tao/PortableInterceptor.h" - #if TAO_HAS_INTERCEPTORS == 1 #include "tao/RequestInfo_Util.h" #include "tao/PICurrent.h" @@ -43,6 +43,7 @@ #endif /* TAO_HAS_INTERCEPTORS == 1 */ #include "ace/Dynamic_Service.h" + #if defined (__BORLANDC__) #pragma option -w-rvl -w-rch -w-ccc -w-aus #endif /* __BORLANDC__ */ @@ -51,8 +52,10 @@ #include "MessagingS.i" #endif /* !defined INLINE */ + + // TAO_IDL - Generated from -// be/be_interface.cpp:1694 +// W:\ACE_wrappers\TAO\TAO_IDL\be\be_interface.cpp:1731 class TAO_Messaging_ReplyHandler_Perfect_Hash_OpTable : public TAO_Perfect_Hash_OpTable { @@ -61,8 +64,9 @@ private: public: const TAO_operation_db_entry * lookup (const char *str, unsigned int len); }; + /* C++ code produced by gperf version 2.8 (ACE version) */ -/* Command-line: /project/taotmp/bala/work/ACE+TAO/temp/ACE_wrappers/bin/gperf -m -M -J -c -C -D -E -T -f 0 -F 0 -a -o -t -p -K opname_ -L C++ -Z TAO_Messaging_ReplyHandler_Perfect_Hash_OpTable -N lookup */ +/* Command-line: gperf -m -M -J -c -C -D -E -T -f 0 -F 0 -a -o -t -p -K opname_ -L C++ -Z TAO_Messaging_ReplyHandler_Perfect_Hash_OpTable -N lookup */ unsigned int TAO_Messaging_ReplyHandler_Perfect_Hash_OpTable::hash (const char *str, unsigned int len) { @@ -157,9 +161,10 @@ TAO_Messaging_ReplyHandler_Perfect_Hash_OpTable::lookup (const char *str, unsign static TAO_Messaging_ReplyHandler_Perfect_Hash_OpTable tao_Messaging_ReplyHandler_optable; // TAO_IDL - Generated from -// be/be_visitor_interface/interceptors_ss.cpp:52 +// W:\ACE_wrappers\TAO\TAO_IDL\be\be_visitor_interface/interceptors_ss.cpp:52 #if (TAO_HAS_INTERCEPTORS == 1) + #endif /* TAO_HAS_INTERCEPTORS */ /////////////////////////////////////////////////////////////////////// @@ -167,7 +172,7 @@ static TAO_Messaging_ReplyHandler_Perfect_Hash_OpTable tao_Messaging_ReplyHandle // // TAO_IDL - Generated from -// be/be_visitor_interface/strategized_proxy_broker_ss.cpp:40 +// W:\ACE_wrappers\TAO\TAO_IDL\be\be_visitor_interface/strategized_proxy_broker_ss.cpp:40 // Factory function Implementation. POA_Messaging::_TAO_ReplyHandler_Strategized_Proxy_Broker *POA_Messaging::_TAO_ReplyHandler_Strategized_Proxy_Broker::the_TAO_ReplyHandler_Strategized_Proxy_Broker (void) @@ -179,8 +184,9 @@ POA_Messaging::_TAO_ReplyHandler_Strategized_Proxy_Broker *POA_Messaging::_TAO_R POA_Messaging::_TAO_ReplyHandler_Strategized_Proxy_Broker::_TAO_ReplyHandler_Strategized_Proxy_Broker (void) { for (int i = 0; i < TAO_Collocation_Strategies::CS_LAST; ++i) - this->proxy_cache_[i] = 0; - + { + this->proxy_cache_[i] = 0; + } } POA_Messaging::_TAO_ReplyHandler_Strategized_Proxy_Broker::~_TAO_ReplyHandler_Strategized_Proxy_Broker (void) @@ -188,12 +194,11 @@ POA_Messaging::_TAO_ReplyHandler_Strategized_Proxy_Broker::~_TAO_ReplyHandler_St for (int i = 0; i < TAO_Collocation_Strategies::CS_LAST; ++i) { delete this->proxy_cache_[i]; - + // Hack to prevent bug mentioned in 1204. Refer to 1204 // for details.. this->proxy_cache_[i] = 0; } - } Messaging::_TAO_ReplyHandler_Proxy_Impl& @@ -204,26 +209,27 @@ POA_Messaging::_TAO_ReplyHandler_Strategized_Proxy_Broker::select_proxy ( { int strategy = TAO_ORB_Core::collocation_strategy (object ACE_ENV_ARG_PARAMETER); - ACE_CHECK_RETURN (*this->proxy_cache_[strategy]); - + ACE_CHECK_RETURN (*this->proxy_cache_[strategy]); + if (this->proxy_cache_[strategy] != 0) - return *this->proxy_cache_[strategy]; - + { + return *this->proxy_cache_[strategy]; + } + this->create_proxy (strategy ACE_ENV_ARG_PARAMETER); ACE_CHECK_RETURN (*this->proxy_cache_[strategy]); - + return *this->proxy_cache_[strategy]; - } -void +void POA_Messaging::_TAO_ReplyHandler_Strategized_Proxy_Broker::create_proxy ( int strategy ACE_ENV_ARG_DECL ) { ACE_GUARD (TAO_SYNCH_MUTEX, guard, this->mutex_); - + if (this->proxy_cache_[strategy] == 0) { switch (strategy) @@ -236,7 +242,7 @@ POA_Messaging::_TAO_ReplyHandler_Strategized_Proxy_Broker::create_proxy ( ); ACE_CHECK; break; - + case TAO_Collocation_Strategies::CS_DIRECT_STRATEGY: ACE_NEW_THROW_EX ( this->proxy_cache_[strategy], @@ -245,7 +251,7 @@ POA_Messaging::_TAO_ReplyHandler_Strategized_Proxy_Broker::create_proxy ( ); ACE_CHECK; break; - + case TAO_Collocation_Strategies::CS_REMOTE_STRATEGY: default: ACE_NEW_THROW_EX ( @@ -255,20 +261,16 @@ POA_Messaging::_TAO_ReplyHandler_Strategized_Proxy_Broker::create_proxy ( ); ACE_CHECK; break; - - } - - } + } + } } - // // End Strategized Proxy Broker Implementation /////////////////////////////////////////////////////////////////////// - // TAO_IDL - Generated from -// be/be_visitor_interface/interface_ss.cpp:599 +// W:\ACE_wrappers\TAO\TAO_IDL\be\be_visitor_interface/interface_ss.cpp:598 Messaging::_TAO_ReplyHandler_Proxy_Broker * Messaging__TAO_ReplyHandler_Proxy_Broker_Factory_function (CORBA::Object_ptr obj) @@ -280,13 +282,13 @@ Messaging__TAO_ReplyHandler_Proxy_Broker_Factory_function (CORBA::Object_ptr obj int Messaging__TAO_ReplyHandler_Proxy_Broker_Factory_Initializer (long) { - Messaging__TAO_ReplyHandler_Proxy_Broker_Factory_function_pointer = + Messaging__TAO_ReplyHandler_Proxy_Broker_Factory_function_pointer = Messaging__TAO_ReplyHandler_Proxy_Broker_Factory_function; - + return 0; } -static int Messaging__TAO_ReplyHandler_Proxy_Broker_Stub_Factory_Initializer_Scarecrow = +static int Messaging__TAO_ReplyHandler_Proxy_Broker_Stub_Factory_Initializer_Scarecrow = Messaging__TAO_ReplyHandler_Proxy_Broker_Factory_Initializer (ACE_reinterpret_cast (long, Messaging__TAO_ReplyHandler_Proxy_Broker_Factory_Initializer)); @@ -295,18 +297,14 @@ static int Messaging__TAO_ReplyHandler_Proxy_Broker_Stub_Factory_Initializer_Sca // // TAO_IDL - Generated from -// be/be_visitor_interface/thru_poa_proxy_impl_ss.cpp:37 +// W:\ACE_wrappers\TAO\TAO_IDL\be\be_visitor_interface/thru_poa_proxy_impl_ss.cpp:37 POA_Messaging::_TAO_ReplyHandler_ThruPOA_Proxy_Impl::_TAO_ReplyHandler_ThruPOA_Proxy_Impl (void) {} -// ThruPOA Implementation of the IDL interface methods - -// +// ThruPOA Implementation of the IDL interface methods// // End ThruPOA Proxy Implementation /////////////////////////////////////////////////////////////////////// - - /////////////////////////////////////////////////////////////////////// // Direct Proxy Implementation // @@ -319,8 +317,9 @@ POA_Messaging::_TAO_ReplyHandler_Direct_Proxy_Impl::_TAO_ReplyHandler_Direct_Pro // End Direct Proxy Implementation /////////////////////////////////////////////////////////////////////// -// TAO_IDL - Generated from -// be/be_visitor_interface/interface_ss.cpp:98 + +// TAO_IDL - Generated from +// W:\ACE_wrappers\TAO\TAO_IDL\be\be_visitor_interface/interface_ss.cpp:98 POA_Messaging::ReplyHandler::ReplyHandler (void) { @@ -335,11 +334,11 @@ POA_Messaging::ReplyHandler::~ReplyHandler (void) { } -// TAO_IDL - Generated from -// be/be_visitor_interface/interface_ss.cpp:163 +// TAO_IDL - Generated from +// W:\ACE_wrappers\TAO\TAO_IDL\be\be_visitor_interface/interface_ss.cpp:163 void POA_Messaging::ReplyHandler::_is_a_skel ( - TAO_ServerRequest &_tao_server_request, + TAO_ServerRequest &_tao_server_request, void * _tao_servant, void * /* Servant_Upcall */ ACE_ENV_ARG_DECL @@ -349,20 +348,22 @@ void POA_Messaging::ReplyHandler::_is_a_skel ( POA_Messaging::ReplyHandler *_tao_impl = (POA_Messaging::ReplyHandler *) _tao_servant; CORBA::Boolean _tao_retval = 0; CORBA::String_var value; + if (!(_tao_in >> value.out ())) ACE_THROW (CORBA::MARSHAL ()); - + _tao_retval = _tao_impl->_is_a (value.in () ACE_ENV_ARG_PARAMETER); ACE_CHECK; - + _tao_server_request.init_reply (); TAO_OutputCDR &_tao_out = _tao_server_request.outgoing (); + if (!(_tao_out << CORBA::Any::from_boolean (_tao_retval))) ACE_THROW (CORBA::MARSHAL ()); } void POA_Messaging::ReplyHandler::_non_existent_skel ( - TAO_ServerRequest &_tao_server_request, + TAO_ServerRequest &_tao_server_request, void * _tao_servant, void * /* Servant_Upcall */ ACE_ENV_ARG_DECL @@ -372,15 +373,16 @@ void POA_Messaging::ReplyHandler::_non_existent_skel ( CORBA::Boolean _tao_retval = _tao_impl->_non_existent (ACE_ENV_SINGLE_ARG_PARAMETER); ACE_CHECK; - + _tao_server_request.init_reply (); TAO_OutputCDR &_tao_out = _tao_server_request.outgoing (); + if (!(_tao_out << CORBA::Any::from_boolean (_tao_retval))) ACE_THROW (CORBA::MARSHAL ()); } void POA_Messaging::ReplyHandler::_interface_skel ( - TAO_ServerRequest &_tao_server_request, + TAO_ServerRequest &_tao_server_request, void * _tao_servant, void * /* Servant_Upcall */ ACE_ENV_ARG_DECL @@ -389,27 +391,27 @@ void POA_Messaging::ReplyHandler::_interface_skel ( POA_Messaging::ReplyHandler *_tao_impl = (POA_Messaging::ReplyHandler *) _tao_servant; CORBA::InterfaceDef_ptr _tao_retval = 0; CORBA::Boolean _tao_result = 0; - + TAO_IFR_Client_Adapter *_tao_adapter = ACE_Dynamic_Service<TAO_IFR_Client_Adapter>::instance ( TAO_ORB_Core::ifr_client_adapter_name () ); - + if (_tao_adapter == 0) { ACE_THROW (CORBA::INTF_REPOS ()); } - + ACE_TRY { - _tao_retval = + _tao_retval = _tao_impl->_get_interface (ACE_ENV_SINGLE_ARG_PARAMETER); ACE_TRY_CHECK; - + _tao_server_request.init_reply (); - + TAO_OutputCDR &_tao_out = _tao_server_request.outgoing (); - + _tao_result = _tao_adapter->interfacedef_cdr_insert ( _tao_out, @@ -421,7 +423,7 @@ void POA_Messaging::ReplyHandler::_interface_skel ( _tao_adapter->dispose (_tao_retval); } ACE_ENDTRY; - + if (_tao_result == 0) { ACE_THROW (CORBA::MARSHAL ()); @@ -429,7 +431,7 @@ void POA_Messaging::ReplyHandler::_interface_skel ( } void POA_Messaging::ReplyHandler::_component_skel ( - TAO_ServerRequest &_tao_server_request, + TAO_ServerRequest &_tao_server_request, void * _tao_object_reference, void * /* Servant_Upcall */ ACE_ENV_ARG_DECL @@ -439,9 +441,10 @@ void POA_Messaging::ReplyHandler::_component_skel ( CORBA::Object_var _tao_retval = _tao_impl->_get_component (ACE_ENV_SINGLE_ARG_PARAMETER); ACE_CHECK; - + _tao_server_request.init_reply (); TAO_OutputCDR &_tao_out = _tao_server_request.outgoing (); + if (!(_tao_out << _tao_retval._retn ())) ACE_THROW (CORBA::MARSHAL ()); } @@ -479,13 +482,13 @@ void* POA_Messaging::ReplyHandler::_downcast ( { return ACE_static_cast (POA_Messaging::ReplyHandler_ptr, this); } - + if (ACE_OS::strcmp (logical_type_id, "IDL:omg.org/CORBA/Object:1.0") == 0) { return ACE_static_cast(PortableServer::Servant, this); } - + return 0; } @@ -495,7 +498,7 @@ const char* POA_Messaging::ReplyHandler::_interface_repository_id (void) const } // TAO_IDL - Generated from -// be/be_visitor_interface/interface_ss.cpp:533 +// W:\ACE_wrappers\TAO\TAO_IDL\be\be_visitor_interface/interface_ss.cpp:532 void POA_Messaging::ReplyHandler::_dispatch ( TAO_ServerRequest &req, @@ -510,17 +513,17 @@ void POA_Messaging::ReplyHandler::_dispatch ( } // TAO_IDL - Generated from -// be/be_visitor_interface/interface_ss.cpp:479 +// W:\ACE_wrappers\TAO\TAO_IDL\be\be_visitor_interface/interface_ss.cpp:478 Messaging::ReplyHandler * POA_Messaging::ReplyHandler::_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 (); - + if (stub->servant_orb_var ()->orb_core ()->optimize_collocation_objects ()) { ACE_NEW_RETURN ( @@ -545,12 +548,9 @@ POA_Messaging::ReplyHandler::_this (ACE_ENV_SINGLE_ARG_DECL) 0 ); } - + CORBA::Object_var obj = tmp; (void) safe_stub.release (); return ::Messaging::ReplyHandler::_unchecked_narrow (obj.in ()); } - - - #endif /* ifndef */ |