summaryrefslogtreecommitdiff
path: root/TAO/tao/Messaging
diff options
context:
space:
mode:
authorJohnny Willemsen <jwillemsen@remedy.nl>2005-08-19 08:02:52 +0000
committerJohnny Willemsen <jwillemsen@remedy.nl>2005-08-19 08:02:52 +0000
commitd9e7859115ef1d5ec0f1c0a829b697354990a8a4 (patch)
tree384c03f0891bbd738983cd5477ac803253f7aaee /TAO/tao/Messaging
parent03b65689794604a55162d73e8a5a4ccb5827b307 (diff)
downloadATCD-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.cpp2
-rw-r--r--TAO/tao/Messaging/Messaging.cpp5
-rw-r--r--TAO/tao/Messaging/MessagingA.cpp25
-rw-r--r--TAO/tao/Messaging/MessagingC.cpp36
-rw-r--r--TAO/tao/Messaging/MessagingS.cpp176
-rw-r--r--TAO/tao/Messaging/Messaging_No_ImplA.cpp84
-rw-r--r--TAO/tao/Messaging/Messaging_PolicyFactory.cpp26
-rw-r--r--TAO/tao/Messaging/Messaging_PolicyFactory.h4
-rw-r--r--TAO/tao/Messaging/Messaging_Policy_i.cpp1
-rw-r--r--TAO/tao/Messaging/Messaging_RT_PolicyA.cpp19
-rw-r--r--TAO/tao/Messaging/Messaging_SyncScope_PolicyA.cpp16
-rw-r--r--TAO/tao/Messaging/PollableC.cpp56
-rw-r--r--TAO/tao/Messaging/TAO_ExtA.cpp16
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 &)