summaryrefslogtreecommitdiff
path: root/TAO/tao/Messaging/MessagingS.cpp
diff options
context:
space:
mode:
authorparsons <parsons@ae88bc3d-4319-0410-8dbf-d08b4c9d3795>2003-03-12 16:18:58 +0000
committerparsons <parsons@ae88bc3d-4319-0410-8dbf-d08b4c9d3795>2003-03-12 16:18:58 +0000
commit311d9d74b593b8b8856151e3e1358df3f00feb0f (patch)
treebf1c5cdcd20e3d61ed9d590adfaef8b5fce061df /TAO/tao/Messaging/MessagingS.cpp
parentf5bacbe21762d818bb4e4f70961040e26061e840 (diff)
downloadATCD-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.cpp134
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 */