diff options
author | Johnny Willemsen <jwillemsen@remedy.nl> | 2005-08-19 08:02:52 +0000 |
---|---|---|
committer | Johnny Willemsen <jwillemsen@remedy.nl> | 2005-08-19 08:02:52 +0000 |
commit | d9e7859115ef1d5ec0f1c0a829b697354990a8a4 (patch) | |
tree | 384c03f0891bbd738983cd5477ac803253f7aaee /TAO/tao/Messaging | |
parent | 03b65689794604a55162d73e8a5a4ccb5827b307 (diff) | |
download | ATCD-d9e7859115ef1d5ec0f1c0a829b697354990a8a4.tar.gz |
ChangeLogTag Fri Aug 19 07:56:12 UTC 2005 Johnny Willemsen <jwillemsen@remedy.nl>
Diffstat (limited to 'TAO/tao/Messaging')
-rw-r--r-- | TAO/tao/Messaging/Connection_Timeout_Policy_i.cpp | 2 | ||||
-rw-r--r-- | TAO/tao/Messaging/Messaging.cpp | 5 | ||||
-rw-r--r-- | TAO/tao/Messaging/MessagingA.cpp | 25 | ||||
-rw-r--r-- | TAO/tao/Messaging/MessagingC.cpp | 36 | ||||
-rw-r--r-- | TAO/tao/Messaging/MessagingS.cpp | 176 | ||||
-rw-r--r-- | TAO/tao/Messaging/Messaging_No_ImplA.cpp | 84 | ||||
-rw-r--r-- | TAO/tao/Messaging/Messaging_PolicyFactory.cpp | 26 | ||||
-rw-r--r-- | TAO/tao/Messaging/Messaging_PolicyFactory.h | 4 | ||||
-rw-r--r-- | TAO/tao/Messaging/Messaging_Policy_i.cpp | 1 | ||||
-rw-r--r-- | TAO/tao/Messaging/Messaging_RT_PolicyA.cpp | 19 | ||||
-rw-r--r-- | TAO/tao/Messaging/Messaging_SyncScope_PolicyA.cpp | 16 | ||||
-rw-r--r-- | TAO/tao/Messaging/PollableC.cpp | 56 | ||||
-rw-r--r-- | TAO/tao/Messaging/TAO_ExtA.cpp | 16 |
13 files changed, 246 insertions, 220 deletions
diff --git a/TAO/tao/Messaging/Connection_Timeout_Policy_i.cpp b/TAO/tao/Messaging/Connection_Timeout_Policy_i.cpp index 56a75c6984d..df49288c887 100644 --- a/TAO/tao/Messaging/Connection_Timeout_Policy_i.cpp +++ b/TAO/tao/Messaging/Connection_Timeout_Policy_i.cpp @@ -3,7 +3,7 @@ #include "tao/ORB_Core.h" #include "tao/Stub.h" #include "tao/debug.h" - +#include "tao/AnyTypeCode/Any.h" ACE_RCSID (Messaging, Connection_Timeout_Policy_i, diff --git a/TAO/tao/Messaging/Messaging.cpp b/TAO/tao/Messaging/Messaging.cpp index f500acc331b..8b245a2ac34 100644 --- a/TAO/tao/Messaging/Messaging.cpp +++ b/TAO/tao/Messaging/Messaging.cpp @@ -54,10 +54,9 @@ exception_holder_raise (TAO::Exception_Data *exception_data, (_tao_in >> completion) == 0) ACE_THROW (CORBA::MARSHAL (TAO::VMCID, CORBA::COMPLETED_MAYBE)); + CORBA::SystemException* exception = - TAO_Exceptions::create_system_exception (type_id.in () - ACE_ENV_ARG_PARAMETER); - ACE_CHECK; + TAO_Exceptions::create_system_exception (type_id.in ()); if (exception == 0) { diff --git a/TAO/tao/Messaging/MessagingA.cpp b/TAO/tao/Messaging/MessagingA.cpp index 3ed9b68a974..4dba22229de 100644 --- a/TAO/tao/Messaging/MessagingA.cpp +++ b/TAO/tao/Messaging/MessagingA.cpp @@ -26,16 +26,17 @@ // http://www.cs.wustl.edu/~schmidt/TAO.html #include "Messaging.h" -#include "tao/Null_RefCount_Policy.h" -#include "tao/TypeCode_Constants.h" -#include "tao/Alias_TypeCode_Static.h" -#include "tao/Objref_TypeCode_Static.h" -#include "tao/Value_TypeCode_Static.h" -#include "tao/TypeCode_Value_Field.h" -#include "tao/Recursive_Type_TypeCode.h" +#include "tao/AnyTypeCode/Null_RefCount_Policy.h" +#include "tao/AnyTypeCode/TypeCode_Constants.h" +#include "tao/AnyTypeCode/Alias_TypeCode_Static.h" +#include "tao/AnyTypeCode/Objref_TypeCode_Static.h" +#include "tao/AnyTypeCode/Value_TypeCode_Static.h" +#include "tao/AnyTypeCode/TypeCode_Value_Field.h" +#include "tao/AnyTypeCode/Recursive_Type_TypeCode.h" #include "tao/CDR.h" -#include "tao/Any.h" -#include "tao/Any_Impl_T.h" +#include "tao/AnyTypeCode/Any.h" +#include "tao/AnyTypeCode/Any_Impl_T.h" +#include "tao/AnyTypeCode/OctetSeqA.h" // TAO_IDL - Generated from // be\be_visitor_typecode/value_typecode.cpp:61 @@ -50,7 +51,7 @@ static TAO::TypeCode::Value_Field<char const *, CORBA::TypeCode_ptr const *> con { "is_system_exception", &CORBA::_tc_boolean, CORBA::PUBLIC_MEMBER }, { "byte_order", &CORBA::_tc_boolean, CORBA::PUBLIC_MEMBER }, { "marshaled_exception", &CORBA::_tc_OctetSeq, CORBA::PUBLIC_MEMBER } - + }; static TAO::TypeCode::Value<char const *, CORBA::TypeCode_ptr const *, @@ -64,7 +65,7 @@ static TAO::TypeCode::Value<char const *, &CORBA::_tc_null, _tao_fields_Messaging_ExceptionHolder, 3); - + namespace Messaging { ::CORBA::TypeCode_ptr const _tc_ExceptionHolder = @@ -82,7 +83,7 @@ static TAO::TypeCode::Objref<char const *, CORBA::tk_objref, "IDL:omg.org/Messaging/ReplyHandler:1.0", "ReplyHandler"); - + namespace Messaging { ::CORBA::TypeCode_ptr const _tc_ReplyHandler = diff --git a/TAO/tao/Messaging/MessagingC.cpp b/TAO/tao/Messaging/MessagingC.cpp index b1d34471827..1fcfb9dc5f4 100644 --- a/TAO/tao/Messaging/MessagingC.cpp +++ b/TAO/tao/Messaging/MessagingC.cpp @@ -126,29 +126,29 @@ CORBA::Boolean Messaging::ExceptionHolder::_tao_unmarshal ( base, ExceptionHolder::_tao_obv_static_repository_id () ); - + if (retval == 0) { return 0; } - + if (factory.in () != 0) { base = factory->create_for_unmarshal (); - + if (base == 0) { return 0; // %! except.? } - + retval = base->_tao_unmarshal_v (strm); - + if (retval == 0) { return 0; } } - + // Now base must be null or point to the unmarshaled object. // Align the pointer to the right subobject. new_object = ExceptionHolder::_downcast (base); @@ -172,7 +172,7 @@ Messaging::ExceptionHolder_init::_downcast (CORBA::ValueFactoryBase *v) return dynamic_cast< ::Messaging::ExceptionHolder_init * > (v); } -const char* +const char* Messaging::ExceptionHolder_init::tao_repository_id (void) { return ::Messaging::ExceptionHolder::_tao_obv_static_repository_id (); @@ -227,7 +227,7 @@ TAO::Objref_Traits<Messaging::ReplyHandler>::marshal ( } // Function pointer for collocation factory initialization. -TAO::Collocation_Proxy_Broker * +TAO::Collocation_Proxy_Broker * (*Messaging__TAO_ReplyHandler_Proxy_Broker_Factory_function_pointer) ( CORBA::Object_ptr obj ) = 0; @@ -251,7 +251,7 @@ Messaging::ReplyHandler::Messaging_ReplyHandler_setup_collocation () Messaging::ReplyHandler::~ReplyHandler (void) {} -void +void Messaging::ReplyHandler::_tao_any_destructor (void *_tao_void_pointer) { ReplyHandler *_tao_tmp_pointer = @@ -296,7 +296,7 @@ Messaging::ReplyHandler::_duplicate (ReplyHandler_ptr obj) { obj->_add_ref (); } - + return obj; } @@ -480,8 +480,8 @@ CORBA::Boolean OBV_Messaging::ExceptionHolder::_tao_marshal_state (TAO_OutputCDR &strm) const { return ( - (strm << CORBA::Any::from_boolean (_pd_is_system_exception)) && - (strm << CORBA::Any::from_boolean (_pd_byte_order)) && + (strm << ACE_OutputCDR::from_boolean (_pd_is_system_exception)) && + (strm << ACE_OutputCDR::from_boolean (_pd_byte_order)) && (strm << _pd_marshaled_exception) ); } @@ -490,8 +490,8 @@ CORBA::Boolean OBV_Messaging::ExceptionHolder::_tao_unmarshal_state (TAO_InputCDR &strm) { return ( - (strm >> CORBA::Any::to_boolean (_pd_is_system_exception)) && - (strm >> CORBA::Any::to_boolean (_pd_byte_order)) && + (strm >> ACE_InputCDR::to_boolean (_pd_is_system_exception)) && + (strm >> ACE_InputCDR::to_boolean (_pd_byte_order)) && (strm >> _pd_marshaled_exception) ); } @@ -514,20 +514,20 @@ CORBA::Boolean operator>> ( ) { CORBA::Object_var obj; - + if (!(strm >> obj.inout ())) { return false; } - + typedef ::Messaging::ReplyHandler RHS_SCOPED_NAME; - + // Narrow to the right type. _tao_objref = TAO::Narrow_Utils<RHS_SCOPED_NAME>::unchecked_narrow ( obj.in (), Messaging__TAO_ReplyHandler_Proxy_Broker_Factory_function_pointer ); - + return 1; } diff --git a/TAO/tao/Messaging/MessagingS.cpp b/TAO/tao/Messaging/MessagingS.cpp index 26e5e5b1124..8ee0e3c16c5 100644 --- a/TAO/tao/Messaging/MessagingS.cpp +++ b/TAO/tao/Messaging/MessagingS.cpp @@ -26,7 +26,7 @@ // http://www.cs.wustl.edu/~schmidt/TAO.html -// TAO_IDL - Generated from +// TAO_IDL - Generated from // be\be_codegen.cpp:599 #ifndef _TAO_IDL_ORIG_MESSAGINGS_CPP_ @@ -52,8 +52,8 @@ #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/AnyTypeCode/TypeCode.h" +#include "tao/AnyTypeCode/DynamicC.h" #include "tao/CDR.h" #include "tao/operation_details.h" #include "tao/PortableInterceptor.h" @@ -203,7 +203,7 @@ POA_Messaging::_TAO_ReplyHandler_Strategized_Proxy_Broker::the_TAO_ReplyHandler_ { static POA_Messaging::_TAO_ReplyHandler_Strategized_Proxy_Broker strategized_proxy_broker; - + return &strategized_proxy_broker; } @@ -225,7 +225,7 @@ POA_Messaging::_TAO_ReplyHandler_Strategized_Proxy_Broker::get_strategy ( TAO::Collocation_Strategy strategy = TAO_ORB_Core::collocation_strategy (obj ACE_ENV_ARG_PARAMETER); ACE_CHECK_RETURN (TAO::TAO_CS_REMOTE_STRATEGY); - + return strategy; } @@ -244,13 +244,13 @@ POA_Messaging::_TAO_ReplyHandler_Strategized_Proxy_Broker::dispatch ( { TAO::Direct_Collocation_Upcall_Wrapper collocation_upcall_wrapper; collocation_upcall_wrapper.upcall ( - obj, - forward_obj, - args, - num_args, - op, - op_len, - strategy + obj, + forward_obj, + args, + num_args, + op, + op_len, + strategy ACE_ENV_ARG_PARAMETER); } @@ -271,9 +271,9 @@ Messaging__TAO_ReplyHandler_Proxy_Broker_Factory_function (CORBA::Object_ptr) int Messaging__TAO_ReplyHandler_Proxy_Broker_Factory_Initializer (size_t) { - 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; } @@ -301,7 +301,7 @@ POA_Messaging::_TAO_ReplyHandler_Direct_Proxy_Impl::~_TAO_ReplyHandler_Direct_Pr // End Direct Proxy Implementation /////////////////////////////////////////////////////////////////////// -// TAO_IDL - Generated from +// TAO_IDL - Generated from // be\be_visitor_interface/interface_ss.cpp:103 POA_Messaging::ReplyHandler::ReplyHandler (void) @@ -320,16 +320,16 @@ POA_Messaging::ReplyHandler::~ReplyHandler (void) { } -// TAO_IDL - Generated from +// TAO_IDL - Generated from // be\be_visitor_interface/interface_ss.cpp:169 namespace POA_Messaging { - - + + // TAO_IDL - Generated from // be\be_visitor_operation/upcall_command_ss.cpp:127 - + class _is_a_ReplyHandler_Upcall_Command : public TAO::Upcall_Command { @@ -343,68 +343,68 @@ namespace POA_Messaging , 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_Messaging::ReplyHandler * const servant_; TAO_Operation_Details const * const operation_details_; TAO::Argument * const * const args_; }; - + } void POA_Messaging::ReplyHandler::_is_a_skel ( - TAO_ServerRequest & server_request, + 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_Messaging::ReplyHandler * const impl = static_cast<POA_Messaging::ReplyHandler *> (servant); - + _is_a_ReplyHandler_Upcall_Command command ( impl, server_request.operation_details (), args); - + TAO::Upcall_Wrapper upcall_wrapper; upcall_wrapper.upcall (server_request , args @@ -417,16 +417,16 @@ void POA_Messaging::ReplyHandler::_is_a_skel ( #endif /* TAO_HAS_INTERCEPTORS == 1 */ ACE_ENV_ARG_PARAMETER); ACE_CHECK; - + } namespace POA_Messaging { - - + + // TAO_IDL - Generated from // be\be_visitor_operation/upcall_command_ss.cpp:127 - + class _non_existent_ReplyHandler_Upcall_Command : public TAO::Upcall_Command { @@ -440,59 +440,59 @@ namespace POA_Messaging , 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_Messaging::ReplyHandler * const servant_; TAO_Operation_Details const * const operation_details_; TAO::Argument * const * const args_; }; - + } void POA_Messaging::ReplyHandler::_non_existent_skel ( - TAO_ServerRequest & server_request, + 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_Messaging::ReplyHandler * const impl = static_cast<POA_Messaging::ReplyHandler *> (servant); - + _non_existent_ReplyHandler_Upcall_Command command ( impl, server_request.operation_details (), args); - + TAO::Upcall_Wrapper upcall_wrapper; upcall_wrapper.upcall (server_request , args @@ -505,18 +505,18 @@ void POA_Messaging::ReplyHandler::_non_existent_skel ( #endif /* TAO_HAS_INTERCEPTORS == 1 */ ACE_ENV_ARG_PARAMETER); ACE_CHECK; - + } -// TAO_IDL - Generated from +// TAO_IDL - Generated from // be\be_visitor_interface/interface_ss.cpp:393 void POA_Messaging::ReplyHandler::_interface_skel ( - TAO_ServerRequest & server_request, + TAO_ServerRequest & server_request, void * /* servant_upcall */, void * servant ACE_ENV_ARG_DECL @@ -526,30 +526,30 @@ void POA_Messaging::ReplyHandler::_interface_skel ( ACE_Dynamic_Service<TAO_IFR_Client_Adapter>::instance ( TAO_ORB_Core::ifr_client_adapter_name () ); - + if (_tao_adapter == 0) { ACE_THROW (CORBA::INTF_REPOS (CORBA::OMGVMCID | 1, CORBA::COMPLETED_NO)); } - + POA_Messaging::ReplyHandler * const impl = static_cast<POA_Messaging::ReplyHandler *> (servant); - CORBA::InterfaceDef_ptr _tao_retval = + 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 ()); @@ -558,11 +558,11 @@ void POA_Messaging::ReplyHandler::_interface_skel ( namespace POA_Messaging { - - + + // TAO_IDL - Generated from // be\be_visitor_operation/upcall_command_ss.cpp:127 - + class _get_component_ReplyHandler_Upcall_Command : public TAO::Upcall_Command { @@ -576,59 +576,59 @@ namespace POA_Messaging , 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_Messaging::ReplyHandler * const servant_; TAO_Operation_Details const * const operation_details_; TAO::Argument * const * const args_; }; - + } void POA_Messaging::ReplyHandler::_component_skel ( - TAO_ServerRequest & server_request, + 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_Messaging::ReplyHandler * const impl = static_cast<POA_Messaging::ReplyHandler *> (servant); - + _get_component_ReplyHandler_Upcall_Command command ( impl, server_request.operation_details (), args); - + TAO::Upcall_Wrapper upcall_wrapper; upcall_wrapper.upcall (server_request , args @@ -641,7 +641,7 @@ void POA_Messaging::ReplyHandler::_component_skel ( #endif /* TAO_HAS_INTERCEPTORS == 1 */ ACE_ENV_ARG_PARAMETER); ACE_CHECK; - + } CORBA::Boolean POA_Messaging::ReplyHandler::_is_a ( @@ -690,22 +690,22 @@ 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 (); - + 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 ::Messaging::ReplyHandler STUB_SCOPED_NAME; return TAO::Narrow_Utils<STUB_SCOPED_NAME>::unchecked_narrow ( diff --git a/TAO/tao/Messaging/Messaging_No_ImplA.cpp b/TAO/tao/Messaging/Messaging_No_ImplA.cpp index cb99e224ed5..4d9d4e4736f 100644 --- a/TAO/tao/Messaging/Messaging_No_ImplA.cpp +++ b/TAO/tao/Messaging/Messaging_No_ImplA.cpp @@ -26,17 +26,17 @@ // http://www.cs.wustl.edu/~schmidt/TAO.html #include "Messaging_No_ImplC.h" -#include "tao/Null_RefCount_Policy.h" -#include "tao/TypeCode_Constants.h" -#include "tao/Alias_TypeCode_Static.h" -#include "tao/Objref_TypeCode_Static.h" -#include "tao/Struct_TypeCode_Static.h" -#include "tao/TypeCode_Struct_Field.h" -#include "tao/Recursive_Type_TypeCode.h" +#include "tao/AnyTypeCode/Null_RefCount_Policy.h" +#include "tao/AnyTypeCode/TypeCode_Constants.h" +#include "tao/AnyTypeCode/Alias_TypeCode_Static.h" +#include "tao/AnyTypeCode/Objref_TypeCode_Static.h" +#include "tao/AnyTypeCode/Struct_TypeCode_Static.h" +#include "tao/AnyTypeCode/TypeCode_Struct_Field.h" +#include "tao/AnyTypeCode/Recursive_Type_TypeCode.h" #include "tao/CDR.h" -#include "tao/Any.h" -#include "tao/Any_Impl_T.h" -#include "tao/Any_Dual_Impl_T.h" +#include "tao/AnyTypeCode/Any.h" +#include "tao/AnyTypeCode/Any_Impl_T.h" +#include "tao/AnyTypeCode/Any_Dual_Impl_T.h" // TAO_IDL - Generated from // be\be_visitor_typecode/alias_typecode.cpp:50 @@ -49,7 +49,7 @@ static TAO::TypeCode::Alias<char const *, "IDL:omg.org/Messaging/Priority:1.0", "Priority", &CORBA::_tc_short); - + namespace Messaging { ::CORBA::TypeCode_ptr const _tc_Priority = @@ -69,7 +69,7 @@ static TAO::TypeCode::Alias<char const *, "IDL:omg.org/Messaging/RebindMode:1.0", "RebindMode", &CORBA::_tc_short); - + namespace Messaging { ::CORBA::TypeCode_ptr const _tc_RebindMode = @@ -89,7 +89,7 @@ static TAO::TypeCode::Alias<char const *, "IDL:omg.org/Messaging/RoutingType:1.0", "RoutingType", &CORBA::_tc_short); - + namespace Messaging { ::CORBA::TypeCode_ptr const _tc_RoutingType = @@ -109,7 +109,7 @@ static TAO::TypeCode::Alias<char const *, "IDL:omg.org/Messaging/Ordering:1.0", "Ordering", &CORBA::_tc_ushort); - + namespace Messaging { ::CORBA::TypeCode_ptr const _tc_Ordering = @@ -127,7 +127,7 @@ static TAO::TypeCode::Objref<char const *, CORBA::tk_local_interface, "IDL:omg.org/Messaging/RebindPolicy:1.0", "RebindPolicy"); - + namespace Messaging { ::CORBA::TypeCode_ptr const _tc_RebindPolicy = @@ -143,7 +143,7 @@ static TAO::TypeCode::Struct_Field<char const *, CORBA::TypeCode_ptr const *> co { { "min", &Messaging::_tc_Priority }, { "max", &Messaging::_tc_Priority } - + }; static TAO::TypeCode::Struct<char const *, CORBA::TypeCode_ptr const *, @@ -155,7 +155,7 @@ static TAO::TypeCode::Struct<char const *, "PriorityRange", _tao_fields_Messaging_PriorityRange, 2); - + namespace Messaging { ::CORBA::TypeCode_ptr const _tc_PriorityRange = @@ -173,7 +173,7 @@ static TAO::TypeCode::Objref<char const *, CORBA::tk_local_interface, "IDL:omg.org/Messaging/RequestPriorityPolicy:1.0", "RequestPriorityPolicy"); - + namespace Messaging { ::CORBA::TypeCode_ptr const _tc_RequestPriorityPolicy = @@ -191,7 +191,7 @@ static TAO::TypeCode::Objref<char const *, CORBA::tk_local_interface, "IDL:omg.org/Messaging/ReplyPriorityPolicy:1.0", "ReplyPriorityPolicy"); - + namespace Messaging { ::CORBA::TypeCode_ptr const _tc_ReplyPriorityPolicy = @@ -209,7 +209,7 @@ static TAO::TypeCode::Objref<char const *, CORBA::tk_local_interface, "IDL:omg.org/Messaging/RequestStartTimePolicy:1.0", "RequestStartTimePolicy"); - + namespace Messaging { ::CORBA::TypeCode_ptr const _tc_RequestStartTimePolicy = @@ -227,7 +227,7 @@ static TAO::TypeCode::Objref<char const *, CORBA::tk_local_interface, "IDL:omg.org/Messaging/RequestEndTimePolicy:1.0", "RequestEndTimePolicy"); - + namespace Messaging { ::CORBA::TypeCode_ptr const _tc_RequestEndTimePolicy = @@ -245,7 +245,7 @@ static TAO::TypeCode::Objref<char const *, CORBA::tk_local_interface, "IDL:omg.org/Messaging/ReplyStartTimePolicy:1.0", "ReplyStartTimePolicy"); - + namespace Messaging { ::CORBA::TypeCode_ptr const _tc_ReplyStartTimePolicy = @@ -263,7 +263,7 @@ static TAO::TypeCode::Objref<char const *, CORBA::tk_local_interface, "IDL:omg.org/Messaging/ReplyEndTimePolicy:1.0", "ReplyEndTimePolicy"); - + namespace Messaging { ::CORBA::TypeCode_ptr const _tc_ReplyEndTimePolicy = @@ -281,7 +281,7 @@ static TAO::TypeCode::Objref<char const *, CORBA::tk_local_interface, "IDL:omg.org/Messaging/RelativeRequestTimeoutPolicy:1.0", "RelativeRequestTimeoutPolicy"); - + namespace Messaging { ::CORBA::TypeCode_ptr const _tc_RelativeRequestTimeoutPolicy = @@ -297,7 +297,7 @@ static TAO::TypeCode::Struct_Field<char const *, CORBA::TypeCode_ptr const *> co { { "min", &Messaging::_tc_RoutingType }, { "max", &Messaging::_tc_RoutingType } - + }; static TAO::TypeCode::Struct<char const *, CORBA::TypeCode_ptr const *, @@ -309,7 +309,7 @@ static TAO::TypeCode::Struct<char const *, "RoutingTypeRange", _tao_fields_Messaging_RoutingTypeRange, 2); - + namespace Messaging { ::CORBA::TypeCode_ptr const _tc_RoutingTypeRange = @@ -327,7 +327,7 @@ static TAO::TypeCode::Objref<char const *, CORBA::tk_local_interface, "IDL:omg.org/Messaging/RoutingPolicy:1.0", "RoutingPolicy"); - + namespace Messaging { ::CORBA::TypeCode_ptr const _tc_RoutingPolicy = @@ -345,7 +345,7 @@ static TAO::TypeCode::Objref<char const *, CORBA::tk_local_interface, "IDL:omg.org/Messaging/MaxHopsPolicy:1.0", "MaxHopsPolicy"); - + namespace Messaging { ::CORBA::TypeCode_ptr const _tc_MaxHopsPolicy = @@ -363,7 +363,7 @@ static TAO::TypeCode::Objref<char const *, CORBA::tk_local_interface, "IDL:omg.org/Messaging/QueueOrderPolicy:1.0", "QueueOrderPolicy"); - + namespace Messaging { ::CORBA::TypeCode_ptr const _tc_QueueOrderPolicy = @@ -396,7 +396,7 @@ namespace TAO { return false; } - + template<> CORBA::Boolean Any_Impl_T<Messaging::RebindPolicy>::demarshal_value (TAO_InputCDR &) @@ -447,7 +447,7 @@ operator>>= ( ); } -// TAO_IDL - Generated from +// TAO_IDL - Generated from // be\be_visitor_structure/any_op_cs.cpp:54 // Copying insertion. @@ -529,7 +529,7 @@ namespace TAO { return false; } - + template<> CORBA::Boolean Any_Impl_T<Messaging::RequestPriorityPolicy>::demarshal_value (TAO_InputCDR &) @@ -604,7 +604,7 @@ namespace TAO { return false; } - + template<> CORBA::Boolean Any_Impl_T<Messaging::ReplyPriorityPolicy>::demarshal_value (TAO_InputCDR &) @@ -679,7 +679,7 @@ namespace TAO { return false; } - + template<> CORBA::Boolean Any_Impl_T<Messaging::RequestStartTimePolicy>::demarshal_value (TAO_InputCDR &) @@ -754,7 +754,7 @@ namespace TAO { return false; } - + template<> CORBA::Boolean Any_Impl_T<Messaging::RequestEndTimePolicy>::demarshal_value (TAO_InputCDR &) @@ -829,7 +829,7 @@ namespace TAO { return false; } - + template<> CORBA::Boolean Any_Impl_T<Messaging::ReplyStartTimePolicy>::demarshal_value (TAO_InputCDR &) @@ -904,7 +904,7 @@ namespace TAO { return false; } - + template<> CORBA::Boolean Any_Impl_T<Messaging::ReplyEndTimePolicy>::demarshal_value (TAO_InputCDR &) @@ -979,7 +979,7 @@ namespace TAO { return false; } - + template<> CORBA::Boolean Any_Impl_T<Messaging::RelativeRequestTimeoutPolicy>::demarshal_value (TAO_InputCDR &) @@ -1030,7 +1030,7 @@ operator>>= ( ); } -// TAO_IDL - Generated from +// TAO_IDL - Generated from // be\be_visitor_structure/any_op_cs.cpp:54 // Copying insertion. @@ -1112,7 +1112,7 @@ namespace TAO { return false; } - + template<> CORBA::Boolean Any_Impl_T<Messaging::RoutingPolicy>::demarshal_value (TAO_InputCDR &) @@ -1187,7 +1187,7 @@ namespace TAO { return false; } - + template<> CORBA::Boolean Any_Impl_T<Messaging::MaxHopsPolicy>::demarshal_value (TAO_InputCDR &) @@ -1262,7 +1262,7 @@ namespace TAO { return false; } - + template<> CORBA::Boolean Any_Impl_T<Messaging::QueueOrderPolicy>::demarshal_value (TAO_InputCDR &) diff --git a/TAO/tao/Messaging/Messaging_PolicyFactory.cpp b/TAO/tao/Messaging/Messaging_PolicyFactory.cpp index 2897a284bd5..d93b65c098c 100644 --- a/TAO/tao/Messaging/Messaging_PolicyFactory.cpp +++ b/TAO/tao/Messaging/Messaging_PolicyFactory.cpp @@ -9,7 +9,27 @@ ACE_RCSID (Messaging, #include "tao/PolicyC.h" #include "tao/Buffering_Constraint_Policy.h" -#include "tao/Any.h" +#include "tao/AnyTypeCode/TAOA.h" +#include "tao/AnyTypeCode/Any.h" + +CORBA::Policy_ptr +TAO_Messaging_PolicyFactory::create_buffering_constraint_policy ( + const CORBA::Any& val + ACE_ENV_ARG_DECL) +{ + TAO::BufferingConstraint *buffering_constraint = 0; + if ((val >>= buffering_constraint) == 0) + ACE_THROW_RETURN (CORBA::PolicyError (CORBA::BAD_POLICY_VALUE), + CORBA::Policy::_nil ()); + + TAO_Buffering_Constraint_Policy *servant = 0; + ACE_NEW_THROW_EX (servant, + TAO_Buffering_Constraint_Policy (*buffering_constraint), + CORBA::NO_MEMORY ()); + ACE_CHECK_RETURN (CORBA::Policy::_nil ()); + + return servant; +} CORBA::Policy_ptr TAO_Messaging_PolicyFactory::create_policy ( @@ -39,8 +59,8 @@ TAO_Messaging_PolicyFactory::create_policy ( #if (TAO_HAS_BUFFERING_CONSTRAINT_POLICY == 1) if (type == TAO::BUFFERING_CONSTRAINT_POLICY_TYPE) - return TAO_Buffering_Constraint_Policy::create (value - ACE_ENV_ARG_PARAMETER); + return this->create_buffering_constraint_policy (value + ACE_ENV_ARG_PARAMETER); #endif /* TAO_HAS_BUFFERING_CONSTRAINT_POLICY == 1 */ if ( diff --git a/TAO/tao/Messaging/Messaging_PolicyFactory.h b/TAO/tao/Messaging/Messaging_PolicyFactory.h index 286acf3d7dc..2a76ceb3993 100644 --- a/TAO/tao/Messaging/Messaging_PolicyFactory.h +++ b/TAO/tao/Messaging/Messaging_PolicyFactory.h @@ -45,6 +45,10 @@ public: ACE_ENV_ARG_DECL_WITH_DEFAULTS) ACE_THROW_SPEC ((CORBA::SystemException, CORBA::PolicyError)); +private: + CORBA::Policy_ptr + create_buffering_constraint_policy (const CORBA::Any& val + ACE_ENV_ARG_DECL_WITH_DEFAULTS); }; diff --git a/TAO/tao/Messaging/Messaging_Policy_i.cpp b/TAO/tao/Messaging/Messaging_Policy_i.cpp index ede4f4ec4bd..f4e244a8696 100644 --- a/TAO/tao/Messaging/Messaging_Policy_i.cpp +++ b/TAO/tao/Messaging/Messaging_Policy_i.cpp @@ -3,6 +3,7 @@ #include "tao/Stub.h" #include "tao/ORB_Core.h" #include "tao/debug.h" +#include "tao/AnyTypeCode/Any.h" #if ! defined (__ACE_INLINE__) #include "Messaging_Policy_i.i" diff --git a/TAO/tao/Messaging/Messaging_RT_PolicyA.cpp b/TAO/tao/Messaging/Messaging_RT_PolicyA.cpp index 22f0f631301..3d7726af4df 100644 --- a/TAO/tao/Messaging/Messaging_RT_PolicyA.cpp +++ b/TAO/tao/Messaging/Messaging_RT_PolicyA.cpp @@ -26,13 +26,14 @@ // http://www.cs.wustl.edu/~schmidt/TAO.html #include "Messaging_RT_PolicyC.h" -#include "tao/Null_RefCount_Policy.h" -#include "tao/TypeCode_Constants.h" -#include "tao/Alias_TypeCode_Static.h" -#include "tao/Objref_TypeCode_Static.h" +#include "tao/AnyTypeCode/Null_RefCount_Policy.h" +#include "tao/AnyTypeCode/TypeCode_Constants.h" +#include "tao/AnyTypeCode/Alias_TypeCode_Static.h" +#include "tao/AnyTypeCode/Objref_TypeCode_Static.h" #include "tao/CDR.h" -#include "tao/Any.h" -#include "tao/Any_Impl_T.h" +#include "tao/AnyTypeCode/Any.h" +#include "tao/AnyTypeCode/Any_Impl_T.h" +#include "tao/AnyTypeCode/TimeBaseA.h" // TAO_IDL - Generated from // be\be_visitor_typecode/alias_typecode.cpp:50 @@ -45,7 +46,7 @@ static TAO::TypeCode::Alias<char const *, "IDL:omg.org/Messaging/Timeout:1.0", "Timeout", &TimeBase::_tc_TimeT); - + namespace Messaging { ::CORBA::TypeCode_ptr const _tc_Timeout = @@ -63,7 +64,7 @@ static TAO::TypeCode::Objref<char const *, CORBA::tk_local_interface, "IDL:omg.org/Messaging/RelativeRoundtripTimeoutPolicy:1.0", "RelativeRoundtripTimeoutPolicy"); - + namespace Messaging { ::CORBA::TypeCode_ptr const _tc_RelativeRoundtripTimeoutPolicy = @@ -96,7 +97,7 @@ namespace TAO { return false; } - + template<> CORBA::Boolean Any_Impl_T<Messaging::RelativeRoundtripTimeoutPolicy>::demarshal_value (TAO_InputCDR &) diff --git a/TAO/tao/Messaging/Messaging_SyncScope_PolicyA.cpp b/TAO/tao/Messaging/Messaging_SyncScope_PolicyA.cpp index a14bdb23202..2e1c5244428 100644 --- a/TAO/tao/Messaging/Messaging_SyncScope_PolicyA.cpp +++ b/TAO/tao/Messaging/Messaging_SyncScope_PolicyA.cpp @@ -26,13 +26,13 @@ // http://www.cs.wustl.edu/~schmidt/TAO.html #include "Messaging_SyncScope_PolicyC.h" -#include "tao/Null_RefCount_Policy.h" -#include "tao/TypeCode_Constants.h" -#include "tao/Alias_TypeCode_Static.h" -#include "tao/Objref_TypeCode_Static.h" +#include "tao/AnyTypeCode/Null_RefCount_Policy.h" +#include "tao/AnyTypeCode/TypeCode_Constants.h" +#include "tao/AnyTypeCode/Alias_TypeCode_Static.h" +#include "tao/AnyTypeCode/Objref_TypeCode_Static.h" #include "tao/CDR.h" -#include "tao/Any.h" -#include "tao/Any_Impl_T.h" +#include "tao/AnyTypeCode/Any.h" +#include "tao/AnyTypeCode/Any_Impl_T.h" // TAO_IDL - Generated from // be\be_visitor_typecode/objref_typecode.cpp:76 @@ -43,7 +43,7 @@ static TAO::TypeCode::Objref<char const *, CORBA::tk_local_interface, "IDL:omg.org/Messaging/SyncScopePolicy:1.0", "SyncScopePolicy"); - + namespace Messaging { ::CORBA::TypeCode_ptr const _tc_SyncScopePolicy = @@ -76,7 +76,7 @@ namespace TAO { return false; } - + template<> CORBA::Boolean Any_Impl_T<Messaging::SyncScopePolicy>::demarshal_value (TAO_InputCDR &) diff --git a/TAO/tao/Messaging/PollableC.cpp b/TAO/tao/Messaging/PollableC.cpp index 6811a0edd6d..a99b058b3dd 100644 --- a/TAO/tao/Messaging/PollableC.cpp +++ b/TAO/tao/Messaging/PollableC.cpp @@ -31,14 +31,14 @@ #include "PollableC.h" #include "tao/CDR.h" -#include "tao/Null_RefCount_Policy.h" -#include "tao/TypeCode_Constants.h" -#include "tao/Alias_TypeCode_Static.h" -#include "tao/Objref_TypeCode_Static.h" -#include "tao/Struct_TypeCode_Static.h" -#include "tao/TypeCode_Struct_Field.h" -#include "tao/Any_Impl_T.h" -#include "tao/Any_Dual_Impl_T.h" +#include "tao/AnyTypeCode/Null_RefCount_Policy.h" +#include "tao/AnyTypeCode/TypeCode_Constants.h" +#include "tao/AnyTypeCode/Alias_TypeCode_Static.h" +#include "tao/AnyTypeCode/Objref_TypeCode_Static.h" +#include "tao/AnyTypeCode/Struct_TypeCode_Static.h" +#include "tao/AnyTypeCode/TypeCode_Struct_Field.h" +#include "tao/AnyTypeCode/Any_Impl_T.h" +#include "tao/AnyTypeCode/Any_Dual_Impl_T.h" #include "ace/OS_NS_string.h" #if defined (__BORLANDC__) @@ -96,7 +96,7 @@ CORBA::Pollable::Pollable (void) CORBA::Pollable::~Pollable (void) {} -void +void CORBA::Pollable::_tao_any_destructor (void *_tao_void_pointer) { Pollable *_tao_tmp_pointer = @@ -133,7 +133,7 @@ CORBA::Pollable::_duplicate (Pollable_ptr obj) { obj->_add_ref (); } - + return obj; } @@ -192,7 +192,7 @@ static TAO::TypeCode::Objref<char const *, CORBA::tk_local_interface, "IDL:omg.org/CORBA/Pollable:1.0", "Pollable"); - + namespace CORBA { ::CORBA::TypeCode_ptr const _tc_Pollable = @@ -243,7 +243,7 @@ CORBA::DIIPollable::DIIPollable (void) CORBA::DIIPollable::~DIIPollable (void) {} -void +void CORBA::DIIPollable::_tao_any_destructor (void *_tao_void_pointer) { DIIPollable *_tao_tmp_pointer = @@ -280,7 +280,7 @@ CORBA::DIIPollable::_duplicate (DIIPollable_ptr obj) { obj->_add_ref (); } - + return obj; } @@ -343,7 +343,7 @@ static TAO::TypeCode::Objref<char const *, CORBA::tk_local_interface, "IDL:omg.org/CORBA/DIIPollable:1.0", "DIIPollable"); - + namespace CORBA { ::CORBA::TypeCode_ptr const _tc_DIIPollable = @@ -388,7 +388,7 @@ TAO::Objref_Traits<CORBA::PollableSet>::marshal ( return CORBA::Object::marshal (p, cdr); } -// TAO_IDL - Generated from +// TAO_IDL - Generated from // be\be_visitor_exception/exception_cs.cpp:63 CORBA::PollableSet::NoPossiblePollable::NoPossiblePollable (void) @@ -497,11 +497,11 @@ static TAO::TypeCode::Struct<char const *, "NoPossiblePollable", _tao_fields_CORBA_PollableSet_NoPossiblePollable, 0); - + ::CORBA::TypeCode_ptr const CORBA::PollableSet::_tc_NoPossiblePollable = &_tao_tc_CORBA_PollableSet_NoPossiblePollable; -// TAO_IDL - Generated from +// TAO_IDL - Generated from // be\be_visitor_exception/exception_cs.cpp:63 CORBA::PollableSet::UnknownPollable::UnknownPollable (void) @@ -610,7 +610,7 @@ static TAO::TypeCode::Struct<char const *, "UnknownPollable", _tao_fields_CORBA_PollableSet_UnknownPollable, 0); - + ::CORBA::TypeCode_ptr const CORBA::PollableSet::_tc_UnknownPollable = &_tao_tc_CORBA_PollableSet_UnknownPollable; @@ -620,7 +620,7 @@ CORBA::PollableSet::PollableSet (void) CORBA::PollableSet::~PollableSet (void) {} -void +void CORBA::PollableSet::_tao_any_destructor (void *_tao_void_pointer) { PollableSet *_tao_tmp_pointer = @@ -657,7 +657,7 @@ CORBA::PollableSet::_duplicate (PollableSet_ptr obj) { obj->_add_ref (); } - + return obj; } @@ -716,7 +716,7 @@ static TAO::TypeCode::Objref<char const *, CORBA::tk_local_interface, "IDL:omg.org/CORBA/PollableSet:1.0", "PollableSet"); - + namespace CORBA { ::CORBA::TypeCode_ptr const _tc_PollableSet = @@ -749,7 +749,7 @@ namespace TAO { return false; } - + template<> CORBA::Boolean Any_Impl_T<CORBA::Pollable>::demarshal_value (TAO_InputCDR &) @@ -824,7 +824,7 @@ namespace TAO { return false; } - + template<> CORBA::Boolean Any_Impl_T<CORBA::DIIPollable>::demarshal_value (TAO_InputCDR &) @@ -899,7 +899,7 @@ namespace TAO { return false; } - + template<> CORBA::Boolean Any_Impl_T<CORBA::PollableSet>::demarshal_value (TAO_InputCDR &) @@ -950,7 +950,7 @@ operator>>= ( ); } -// TAO_IDL - Generated from +// TAO_IDL - Generated from // be\be_visitor_exception/any_op_cs.cpp:50 namespace TAO @@ -961,7 +961,7 @@ namespace TAO { return false; } - + template<> CORBA::Boolean Any_Dual_Impl_T<CORBA::PollableSet::NoPossiblePollable>::demarshal_value (TAO_InputCDR &) @@ -1025,7 +1025,7 @@ CORBA::Boolean operator>>= ( ); } -// TAO_IDL - Generated from +// TAO_IDL - Generated from // be\be_visitor_exception/any_op_cs.cpp:50 namespace TAO @@ -1036,7 +1036,7 @@ namespace TAO { return false; } - + template<> CORBA::Boolean Any_Dual_Impl_T<CORBA::PollableSet::UnknownPollable>::demarshal_value (TAO_InputCDR &) diff --git a/TAO/tao/Messaging/TAO_ExtA.cpp b/TAO/tao/Messaging/TAO_ExtA.cpp index 6b1f475f8f8..3bce6d7972b 100644 --- a/TAO/tao/Messaging/TAO_ExtA.cpp +++ b/TAO/tao/Messaging/TAO_ExtA.cpp @@ -26,13 +26,13 @@ // http://www.cs.wustl.edu/~schmidt/TAO.html #include "TAO_ExtC.h" -#include "tao/Null_RefCount_Policy.h" -#include "tao/TypeCode_Constants.h" -#include "tao/Alias_TypeCode_Static.h" -#include "tao/Objref_TypeCode_Static.h" +#include "tao/AnyTypeCode/Null_RefCount_Policy.h" +#include "tao/AnyTypeCode/TypeCode_Constants.h" +#include "tao/AnyTypeCode/Alias_TypeCode_Static.h" +#include "tao/AnyTypeCode/Objref_TypeCode_Static.h" #include "tao/CDR.h" -#include "tao/Any.h" -#include "tao/Any_Impl_T.h" +#include "tao/AnyTypeCode/Any.h" +#include "tao/AnyTypeCode/Any_Impl_T.h" // TAO_IDL - Generated from // be\be_visitor_typecode/objref_typecode.cpp:76 @@ -43,7 +43,7 @@ static TAO::TypeCode::Objref<char const *, CORBA::tk_local_interface, "IDL:tao/TAO/ConnectionTimeoutPolicy:1.0", "ConnectionTimeoutPolicy"); - + namespace TAO { ::CORBA::TypeCode_ptr const _tc_ConnectionTimeoutPolicy = @@ -76,7 +76,7 @@ namespace TAO { return false; } - + template<> CORBA::Boolean Any_Impl_T<TAO::ConnectionTimeoutPolicy>::demarshal_value (TAO_InputCDR &) |