From aaea5e59710fa852bf7369a810e4b0435260c4d1 Mon Sep 17 00:00:00 2001 From: Mika Laitio Date: Mon, 4 Oct 2010 17:07:51 +0300 Subject: [PATCH] dropped duplicate version from the RequestResponseBus* sources generated in src/idl directory. --- src/Makefile.am | 2 +- src/plpbus/RequestResponseBus.hh | 625 ----------------- src/plpbus/RequestResponseBusSK.cc | 1012 ---------------------------- src_test/Makefile.am | 2 +- 4 files changed, 2 insertions(+), 1639 deletions(-) delete mode 100644 src/plpbus/RequestResponseBus.hh delete mode 100644 src/plpbus/RequestResponseBusSK.cc diff --git a/src/Makefile.am b/src/Makefile.am index 70f07a4..7e26785 100644 --- a/src/Makefile.am +++ b/src/Makefile.am @@ -10,7 +10,7 @@ libplpbus_la_SOURCES = \ plpbus/IClientListener.hh \ plpbus/IServerListener.hh libplpbus_la_LDFLAGS = $(SRC_LIBS) $(all_libraries) -version-info 1:0:0 -no-undefined -AM_CPPFLAGS = $(SRC_CFLAGS) +AM_CPPFLAGS = $(SRC_CFLAGS) -Iidl DISTCLEANFILES = Makefile.in diff --git a/src/plpbus/RequestResponseBus.hh b/src/plpbus/RequestResponseBus.hh deleted file mode 100644 index ddebb17..0000000 --- a/src/plpbus/RequestResponseBus.hh +++ /dev/null @@ -1,625 +0,0 @@ -// This file is generated by omniidl (C++ backend)- omniORB_4_1. Do not edit. -#ifndef __RequestResponseBus_hh__ -#define __RequestResponseBus_hh__ - -#ifndef __CORBA_H_EXTERNAL_GUARD__ -#include -#endif - -#ifndef USE_stub_in_nt_dll -# define USE_stub_in_nt_dll_NOT_DEFINED_RequestResponseBus -#endif -#ifndef USE_core_stub_in_nt_dll -# define USE_core_stub_in_nt_dll_NOT_DEFINED_RequestResponseBus -#endif -#ifndef USE_dyn_stub_in_nt_dll -# define USE_dyn_stub_in_nt_dll_NOT_DEFINED_RequestResponseBus -#endif - - - - - - -#ifdef USE_stub_in_nt_dll -# ifndef USE_core_stub_in_nt_dll -# define USE_core_stub_in_nt_dll -# endif -# ifndef USE_dyn_stub_in_nt_dll -# define USE_dyn_stub_in_nt_dll -# endif -#endif - -#ifdef _core_attr -# error "A local CPP macro _core_attr has already been defined." -#else -# ifdef USE_core_stub_in_nt_dll -# define _core_attr _OMNIORB_NTDLL_IMPORT -# else -# define _core_attr -# endif -#endif - -#ifdef _dyn_attr -# error "A local CPP macro _dyn_attr has already been defined." -#else -# ifdef USE_dyn_stub_in_nt_dll -# define _dyn_attr _OMNIORB_NTDLL_IMPORT -# else -# define _dyn_attr -# endif -#endif - - - - - -_CORBA_MODULE plpbus_orb - -_CORBA_MODULE_BEG - - struct DataItem { - typedef _CORBA_ConstrType_Variable_Var _var_type; - - - ::CORBA::String_member name; - - ::CORBA::Any value; - - - - void operator>>= (cdrStream &) const; - void operator<<= (cdrStream &); - }; - - typedef DataItem::_var_type DataItem_var; - - typedef _CORBA_ConstrType_Variable_OUT_arg< DataItem,DataItem_var > DataItem_out; - - _CORBA_MODULE_VAR _dyn_attr const ::CORBA::TypeCode_ptr _tc_DataItem; - - _CORBA_MODULE_VAR _dyn_attr const ::CORBA::TypeCode_ptr _tc_DataItemSequence; - - class DataItemSequence_var; - - class DataItemSequence : public _CORBA_Unbounded_Sequence< DataItem > { - public: - typedef DataItemSequence_var _var_type; - inline DataItemSequence() {} - inline DataItemSequence(const DataItemSequence& _s) - : _CORBA_Unbounded_Sequence< DataItem > (_s) {} - - inline DataItemSequence(_CORBA_ULong _max) - : _CORBA_Unbounded_Sequence< DataItem > (_max) {} - inline DataItemSequence(_CORBA_ULong _max, _CORBA_ULong _len, DataItem* _val, _CORBA_Boolean _rel=0) - : _CORBA_Unbounded_Sequence< DataItem > (_max, _len, _val, _rel) {} - - - - inline DataItemSequence& operator = (const DataItemSequence& _s) { - _CORBA_Unbounded_Sequence< DataItem > ::operator=(_s); - return *this; - } - }; - - class DataItemSequence_out; - - class DataItemSequence_var { - public: - inline DataItemSequence_var() : _pd_seq(0) {} - inline DataItemSequence_var(DataItemSequence* _s) : _pd_seq(_s) {} - inline DataItemSequence_var(const DataItemSequence_var& _s) { - if( _s._pd_seq ) _pd_seq = new DataItemSequence(*_s._pd_seq); - else _pd_seq = 0; - } - inline ~DataItemSequence_var() { if( _pd_seq ) delete _pd_seq; } - - inline DataItemSequence_var& operator = (DataItemSequence* _s) { - if( _pd_seq ) delete _pd_seq; - _pd_seq = _s; - return *this; - } - inline DataItemSequence_var& operator = (const DataItemSequence_var& _s) { - if( _s._pd_seq ) { - if( !_pd_seq ) _pd_seq = new DataItemSequence; - *_pd_seq = *_s._pd_seq; - } else if( _pd_seq ) { - delete _pd_seq; - _pd_seq = 0; - } - return *this; - } - inline DataItem& operator [] (_CORBA_ULong _s) { - return (*_pd_seq)[_s]; - } - - - - inline DataItemSequence* operator -> () { return _pd_seq; } - inline const DataItemSequence* operator -> () const { return _pd_seq; } -#if defined(__GNUG__) - inline operator DataItemSequence& () const { return *_pd_seq; } -#else - inline operator const DataItemSequence& () const { return *_pd_seq; } - inline operator DataItemSequence& () { return *_pd_seq; } -#endif - - inline const DataItemSequence& in() const { return *_pd_seq; } - inline DataItemSequence& inout() { return *_pd_seq; } - inline DataItemSequence*& out() { - if( _pd_seq ) { delete _pd_seq; _pd_seq = 0; } - return _pd_seq; - } - inline DataItemSequence* _retn() { DataItemSequence* tmp = _pd_seq; _pd_seq = 0; return tmp; } - - friend class DataItemSequence_out; - - private: - DataItemSequence* _pd_seq; - }; - - class DataItemSequence_out { - public: - inline DataItemSequence_out(DataItemSequence*& _s) : _data(_s) { _data = 0; } - inline DataItemSequence_out(DataItemSequence_var& _s) - : _data(_s._pd_seq) { _s = (DataItemSequence*) 0; } - inline DataItemSequence_out(const DataItemSequence_out& _s) : _data(_s._data) {} - inline DataItemSequence_out& operator = (const DataItemSequence_out& _s) { - _data = _s._data; - return *this; - } - inline DataItemSequence_out& operator = (DataItemSequence* _s) { - _data = _s; - return *this; - } - inline operator DataItemSequence*&() { return _data; } - inline DataItemSequence*& ptr() { return _data; } - inline DataItemSequence* operator->() { return _data; } - - inline DataItem& operator [] (_CORBA_ULong _i) { - return (*_data)[_i]; - } - - - - DataItemSequence*& _data; - - private: - DataItemSequence_out(); - DataItemSequence_out& operator=(const DataItemSequence_var&); - }; - -#ifndef __plpbus__orb_mOrbClient__ -#define __plpbus__orb_mOrbClient__ - - class OrbClient; - class _objref_OrbClient; - class _impl_OrbClient; - - typedef _objref_OrbClient* OrbClient_ptr; - typedef OrbClient_ptr OrbClientRef; - - class OrbClient_Helper { - public: - typedef OrbClient_ptr _ptr_type; - - static _ptr_type _nil(); - static _CORBA_Boolean is_nil(_ptr_type); - static void release(_ptr_type); - static void duplicate(_ptr_type); - static void marshalObjRef(_ptr_type, cdrStream&); - static _ptr_type unmarshalObjRef(cdrStream&); - }; - - typedef _CORBA_ObjRef_Var<_objref_OrbClient, OrbClient_Helper> OrbClient_var; - typedef _CORBA_ObjRef_OUT_arg<_objref_OrbClient,OrbClient_Helper > OrbClient_out; - -#endif - - // interface OrbClient - class OrbClient { - public: - // Declarations for this interface type. - typedef OrbClient_ptr _ptr_type; - typedef OrbClient_var _var_type; - - static _ptr_type _duplicate(_ptr_type); - static _ptr_type _narrow(::CORBA::Object_ptr); - static _ptr_type _unchecked_narrow(::CORBA::Object_ptr); - - static _ptr_type _nil(); - - static inline void _marshalObjRef(_ptr_type, cdrStream&); - - static inline _ptr_type _unmarshalObjRef(cdrStream& s) { - omniObjRef* o = omniObjRef::_unMarshal(_PD_repoId,s); - if (o) - return (_ptr_type) o->_ptrToObjRef(_PD_repoId); - else - return _nil(); - } - - static _core_attr const char* _PD_repoId; - - // Other IDL defined within this scope. - - }; - - class _objref_OrbClient : - public virtual ::CORBA::Object, - public virtual omniObjRef - { - public: - void receive_event_message(const char* event_param); - void receive_event_dataitem_sequence(const ::plpbus_orb::DataItemSequence& event_param); - void receive_response_message(const char* msg_rsp_param); - void receive_response_dataitem_sequence(const ::plpbus_orb::DataItemSequence& msg_rsp_param); - - inline _objref_OrbClient() { _PR_setobj(0); } // nil - _objref_OrbClient(omniIOR*, omniIdentity*); - - protected: - virtual ~_objref_OrbClient(); - - - private: - virtual void* _ptrToObjRef(const char*); - - _objref_OrbClient(const _objref_OrbClient&); - _objref_OrbClient& operator = (const _objref_OrbClient&); - // not implemented - - friend class OrbClient; - }; - - class _pof_OrbClient : public _OMNI_NS(proxyObjectFactory) { - public: - inline _pof_OrbClient() : _OMNI_NS(proxyObjectFactory)(OrbClient::_PD_repoId) {} - virtual ~_pof_OrbClient(); - - virtual omniObjRef* newObjRef(omniIOR*,omniIdentity*); - virtual _CORBA_Boolean is_a(const char*) const; - }; - - class _impl_OrbClient : - public virtual omniServant - { - public: - virtual ~_impl_OrbClient(); - - virtual void receive_event_message(const char* event_param) = 0; - virtual void receive_event_dataitem_sequence(const ::plpbus_orb::DataItemSequence& event_param) = 0; - virtual void receive_response_message(const char* msg_rsp_param) = 0; - virtual void receive_response_dataitem_sequence(const ::plpbus_orb::DataItemSequence& msg_rsp_param) = 0; - - public: // Really protected, workaround for xlC - virtual _CORBA_Boolean _dispatch(omniCallHandle&); - - private: - virtual void* _ptrToInterface(const char*); - virtual const char* _mostDerivedRepoId(); - - }; - - - _CORBA_MODULE_VAR _dyn_attr const ::CORBA::TypeCode_ptr _tc_OrbClient; - -#ifndef __plpbus__orb_mOrbServer__ -#define __plpbus__orb_mOrbServer__ - - class OrbServer; - class _objref_OrbServer; - class _impl_OrbServer; - - typedef _objref_OrbServer* OrbServer_ptr; - typedef OrbServer_ptr OrbServerRef; - - class OrbServer_Helper { - public: - typedef OrbServer_ptr _ptr_type; - - static _ptr_type _nil(); - static _CORBA_Boolean is_nil(_ptr_type); - static void release(_ptr_type); - static void duplicate(_ptr_type); - static void marshalObjRef(_ptr_type, cdrStream&); - static _ptr_type unmarshalObjRef(cdrStream&); - }; - - typedef _CORBA_ObjRef_Var<_objref_OrbServer, OrbServer_Helper> OrbServer_var; - typedef _CORBA_ObjRef_OUT_arg<_objref_OrbServer,OrbServer_Helper > OrbServer_out; - -#endif - - // interface OrbServer - class OrbServer { - public: - // Declarations for this interface type. - typedef OrbServer_ptr _ptr_type; - typedef OrbServer_var _var_type; - - static _ptr_type _duplicate(_ptr_type); - static _ptr_type _narrow(::CORBA::Object_ptr); - static _ptr_type _unchecked_narrow(::CORBA::Object_ptr); - - static _ptr_type _nil(); - - static inline void _marshalObjRef(_ptr_type, cdrStream&); - - static inline _ptr_type _unmarshalObjRef(cdrStream& s) { - omniObjRef* o = omniObjRef::_unMarshal(_PD_repoId,s); - if (o) - return (_ptr_type) o->_ptrToObjRef(_PD_repoId); - else - return _nil(); - } - - static _core_attr const char* _PD_repoId; - - // Other IDL defined within this scope. - - }; - - class _objref_OrbServer : - public virtual ::CORBA::Object, - public virtual omniObjRef - { - public: - void send_message_and_request_response(::plpbus_orb::OrbClient_ptr response_listener_param, const char* msg_param); - void send_dataitem_message_and_request_response(::plpbus_orb::OrbClient_ptr response_listener_param, const ::plpbus_orb::DataItemSequence& req_seq_param); - char* send_message_and_wait_response(const char* msg_req_param, ::CORBA::Long& err_flg); - ::CORBA::Long send_dataitem_message_and_wait_response(const ::plpbus_orb::DataItemSequence& req_seq_param, ::plpbus_orb::DataItemSequence_out rsp_seq_param); - void add_event_listener(::plpbus_orb::OrbClient_ptr callback_client_param, const char* msg_param, ::CORBA::UShort period_secs); - void shutdown(); - - inline _objref_OrbServer() { _PR_setobj(0); } // nil - _objref_OrbServer(omniIOR*, omniIdentity*); - - protected: - virtual ~_objref_OrbServer(); - - - private: - virtual void* _ptrToObjRef(const char*); - - _objref_OrbServer(const _objref_OrbServer&); - _objref_OrbServer& operator = (const _objref_OrbServer&); - // not implemented - - friend class OrbServer; - }; - - class _pof_OrbServer : public _OMNI_NS(proxyObjectFactory) { - public: - inline _pof_OrbServer() : _OMNI_NS(proxyObjectFactory)(OrbServer::_PD_repoId) {} - virtual ~_pof_OrbServer(); - - virtual omniObjRef* newObjRef(omniIOR*,omniIdentity*); - virtual _CORBA_Boolean is_a(const char*) const; - }; - - class _impl_OrbServer : - public virtual omniServant - { - public: - virtual ~_impl_OrbServer(); - - virtual void send_message_and_request_response(::plpbus_orb::OrbClient_ptr response_listener_param, const char* msg_param) = 0; - virtual void send_dataitem_message_and_request_response(::plpbus_orb::OrbClient_ptr response_listener_param, const ::plpbus_orb::DataItemSequence& req_seq_param) = 0; - virtual char* send_message_and_wait_response(const char* msg_req_param, ::CORBA::Long& err_flg) = 0; - virtual ::CORBA::Long send_dataitem_message_and_wait_response(const ::plpbus_orb::DataItemSequence& req_seq_param, ::plpbus_orb::DataItemSequence_out rsp_seq_param) = 0; - virtual void add_event_listener(::plpbus_orb::OrbClient_ptr callback_client_param, const char* msg_param, ::CORBA::UShort period_secs) = 0; - virtual void shutdown() = 0; - - public: // Really protected, workaround for xlC - virtual _CORBA_Boolean _dispatch(omniCallHandle&); - - private: - virtual void* _ptrToInterface(const char*); - virtual const char* _mostDerivedRepoId(); - - }; - - - _CORBA_MODULE_VAR _dyn_attr const ::CORBA::TypeCode_ptr _tc_OrbServer; - -_CORBA_MODULE_END - - - -_CORBA_MODULE POA_plpbus_orb -_CORBA_MODULE_BEG - - class OrbClient : - public virtual plpbus_orb::_impl_OrbClient, - public virtual ::PortableServer::ServantBase - { - public: - virtual ~OrbClient(); - - inline ::plpbus_orb::OrbClient_ptr _this() { - return (::plpbus_orb::OrbClient_ptr) _do_this(::plpbus_orb::OrbClient::_PD_repoId); - } - }; - - template - class OrbClient_tie : public virtual OrbClient - { - public: - OrbClient_tie(_omniT& t) - : pd_obj(&t), pd_poa(0), pd_rel(0) {} - OrbClient_tie(_omniT& t, ::PortableServer::POA_ptr p) - : pd_obj(&t), pd_poa(p), pd_rel(0) {} - OrbClient_tie(_omniT* t, _CORBA_Boolean r=1) - : pd_obj(t), pd_poa(0), pd_rel(r) {} - OrbClient_tie(_omniT* t, ::PortableServer::POA_ptr p,_CORBA_Boolean r=1) - : pd_obj(t), pd_poa(p), pd_rel(r) {} - ~OrbClient_tie() { - if( pd_poa ) ::CORBA::release(pd_poa); - if( pd_rel ) delete pd_obj; - } - - _omniT* _tied_object() { return pd_obj; } - - void _tied_object(_omniT& t) { - if( pd_rel ) delete pd_obj; - pd_obj = &t; - pd_rel = 0; - } - - void _tied_object(_omniT* t, _CORBA_Boolean r=1) { - if( pd_rel ) delete pd_obj; - pd_obj = t; - pd_rel = r; - } - - _CORBA_Boolean _is_owner() { return pd_rel; } - void _is_owner(_CORBA_Boolean io) { pd_rel = io; } - - ::PortableServer::POA_ptr _default_POA() { - if( !pd_poa ) return ::PortableServer::POA::_the_root_poa(); - else return ::PortableServer::POA::_duplicate(pd_poa); - } - - void receive_event_message(const char* event_param) { pd_obj->receive_event_message(event_param); } - void receive_event_dataitem_sequence(const plpbus_orb::DataItemSequence& event_param) { pd_obj->receive_event_dataitem_sequence(event_param); } - void receive_response_message(const char* msg_rsp_param) { pd_obj->receive_response_message(msg_rsp_param); } - void receive_response_dataitem_sequence(const plpbus_orb::DataItemSequence& msg_rsp_param) { pd_obj->receive_response_dataitem_sequence(msg_rsp_param); } - - - private: - _omniT* pd_obj; - ::PortableServer::POA_ptr pd_poa; - _CORBA_Boolean pd_rel; - }; - - class OrbServer : - public virtual plpbus_orb::_impl_OrbServer, - public virtual ::PortableServer::ServantBase - { - public: - virtual ~OrbServer(); - - inline ::plpbus_orb::OrbServer_ptr _this() { - return (::plpbus_orb::OrbServer_ptr) _do_this(::plpbus_orb::OrbServer::_PD_repoId); - } - }; - - template - class OrbServer_tie : public virtual OrbServer - { - public: - OrbServer_tie(_omniT& t) - : pd_obj(&t), pd_poa(0), pd_rel(0) {} - OrbServer_tie(_omniT& t, ::PortableServer::POA_ptr p) - : pd_obj(&t), pd_poa(p), pd_rel(0) {} - OrbServer_tie(_omniT* t, _CORBA_Boolean r=1) - : pd_obj(t), pd_poa(0), pd_rel(r) {} - OrbServer_tie(_omniT* t, ::PortableServer::POA_ptr p,_CORBA_Boolean r=1) - : pd_obj(t), pd_poa(p), pd_rel(r) {} - ~OrbServer_tie() { - if( pd_poa ) ::CORBA::release(pd_poa); - if( pd_rel ) delete pd_obj; - } - - _omniT* _tied_object() { return pd_obj; } - - void _tied_object(_omniT& t) { - if( pd_rel ) delete pd_obj; - pd_obj = &t; - pd_rel = 0; - } - - void _tied_object(_omniT* t, _CORBA_Boolean r=1) { - if( pd_rel ) delete pd_obj; - pd_obj = t; - pd_rel = r; - } - - _CORBA_Boolean _is_owner() { return pd_rel; } - void _is_owner(_CORBA_Boolean io) { pd_rel = io; } - - ::PortableServer::POA_ptr _default_POA() { - if( !pd_poa ) return ::PortableServer::POA::_the_root_poa(); - else return ::PortableServer::POA::_duplicate(pd_poa); - } - - void send_message_and_request_response(plpbus_orb::OrbClient_ptr response_listener_param, const char* msg_param) { pd_obj->send_message_and_request_response(response_listener_param, msg_param); } - void send_dataitem_message_and_request_response(plpbus_orb::OrbClient_ptr response_listener_param, const plpbus_orb::DataItemSequence& req_seq_param) { pd_obj->send_dataitem_message_and_request_response(response_listener_param, req_seq_param); } - char* send_message_and_wait_response(const char* msg_req_param, ::CORBA::Long& err_flg) { return pd_obj->send_message_and_wait_response(msg_req_param, err_flg); } - ::CORBA::Long send_dataitem_message_and_wait_response(const plpbus_orb::DataItemSequence& req_seq_param, plpbus_orb::DataItemSequence_out rsp_seq_param) { return pd_obj->send_dataitem_message_and_wait_response(req_seq_param, rsp_seq_param); } - void add_event_listener(plpbus_orb::OrbClient_ptr callback_client_param, const char* msg_param, ::CORBA::UShort period_secs) { pd_obj->add_event_listener(callback_client_param, msg_param, period_secs); } - void shutdown() { pd_obj->shutdown(); } - - - private: - _omniT* pd_obj; - ::PortableServer::POA_ptr pd_poa; - _CORBA_Boolean pd_rel; - }; - -_CORBA_MODULE_END - - - -_CORBA_MODULE OBV_plpbus_orb -_CORBA_MODULE_BEG - -_CORBA_MODULE_END - - - - - -#undef _core_attr -#undef _dyn_attr - -extern void operator<<=(::CORBA::Any& _a, const plpbus_orb::DataItem& _s); -extern void operator<<=(::CORBA::Any& _a, plpbus_orb::DataItem* _sp); -extern _CORBA_Boolean operator>>=(const ::CORBA::Any& _a, plpbus_orb::DataItem*& _sp); -extern _CORBA_Boolean operator>>=(const ::CORBA::Any& _a, const plpbus_orb::DataItem*& _sp); - -void operator<<=(::CORBA::Any& _a, const plpbus_orb::DataItemSequence& _s); -void operator<<=(::CORBA::Any& _a, plpbus_orb::DataItemSequence* _sp); -_CORBA_Boolean operator>>=(const ::CORBA::Any& _a, plpbus_orb::DataItemSequence*& _sp); -_CORBA_Boolean operator>>=(const ::CORBA::Any& _a, const plpbus_orb::DataItemSequence*& _sp); - -void operator<<=(::CORBA::Any& _a, plpbus_orb::OrbClient_ptr _s); -void operator<<=(::CORBA::Any& _a, plpbus_orb::OrbClient_ptr* _s); -_CORBA_Boolean operator>>=(const ::CORBA::Any& _a, plpbus_orb::OrbClient_ptr& _s); - -void operator<<=(::CORBA::Any& _a, plpbus_orb::OrbServer_ptr _s); -void operator<<=(::CORBA::Any& _a, plpbus_orb::OrbServer_ptr* _s); -_CORBA_Boolean operator>>=(const ::CORBA::Any& _a, plpbus_orb::OrbServer_ptr& _s); - - - -inline void -plpbus_orb::OrbClient::_marshalObjRef(::plpbus_orb::OrbClient_ptr obj, cdrStream& s) { - omniObjRef::_marshal(obj->_PR_getobj(),s); -} - - -inline void -plpbus_orb::OrbServer::_marshalObjRef(::plpbus_orb::OrbServer_ptr obj, cdrStream& s) { - omniObjRef::_marshal(obj->_PR_getobj(),s); -} - - - - -#ifdef USE_stub_in_nt_dll_NOT_DEFINED_RequestResponseBus -# undef USE_stub_in_nt_dll -# undef USE_stub_in_nt_dll_NOT_DEFINED_RequestResponseBus -#endif -#ifdef USE_core_stub_in_nt_dll_NOT_DEFINED_RequestResponseBus -# undef USE_core_stub_in_nt_dll -# undef USE_core_stub_in_nt_dll_NOT_DEFINED_RequestResponseBus -#endif -#ifdef USE_dyn_stub_in_nt_dll_NOT_DEFINED_RequestResponseBus -# undef USE_dyn_stub_in_nt_dll -# undef USE_dyn_stub_in_nt_dll_NOT_DEFINED_RequestResponseBus -#endif - -#endif // __RequestResponseBus_hh__ - diff --git a/src/plpbus/RequestResponseBusSK.cc b/src/plpbus/RequestResponseBusSK.cc deleted file mode 100644 index 9877936..0000000 --- a/src/plpbus/RequestResponseBusSK.cc +++ /dev/null @@ -1,1012 +0,0 @@ -// This file is generated by omniidl (C++ backend)- omniORB_4_1. Do not edit. - -#include "RequestResponseBus.hh" -#include -#include -#include -#include -#include - - -OMNI_USING_NAMESPACE(omni) - -static const char* _0RL_library_version = omniORB_4_1; - - - -void -plpbus_orb::DataItem::operator>>= (cdrStream &_n) const -{ - _n.marshalString(name,0); - (const ::CORBA::Any&) value >>= _n; - -} - -void -plpbus_orb::DataItem::operator<<= (cdrStream &_n) -{ - name = _n.unmarshalString(0); - (::CORBA::Any&)value <<= _n; - -} - -plpbus_orb::OrbClient_ptr plpbus_orb::OrbClient_Helper::_nil() { - return ::plpbus_orb::OrbClient::_nil(); -} - -::CORBA::Boolean plpbus_orb::OrbClient_Helper::is_nil(::plpbus_orb::OrbClient_ptr p) { - return ::CORBA::is_nil(p); - -} - -void plpbus_orb::OrbClient_Helper::release(::plpbus_orb::OrbClient_ptr p) { - ::CORBA::release(p); -} - -void plpbus_orb::OrbClient_Helper::marshalObjRef(::plpbus_orb::OrbClient_ptr obj, cdrStream& s) { - ::plpbus_orb::OrbClient::_marshalObjRef(obj, s); -} - -plpbus_orb::OrbClient_ptr plpbus_orb::OrbClient_Helper::unmarshalObjRef(cdrStream& s) { - return ::plpbus_orb::OrbClient::_unmarshalObjRef(s); -} - -void plpbus_orb::OrbClient_Helper::duplicate(::plpbus_orb::OrbClient_ptr obj) { - if( obj && !obj->_NP_is_nil() ) omni::duplicateObjRef(obj); -} - -plpbus_orb::OrbClient_ptr -plpbus_orb::OrbClient::_duplicate(::plpbus_orb::OrbClient_ptr obj) -{ - if( obj && !obj->_NP_is_nil() ) omni::duplicateObjRef(obj); - return obj; -} - -plpbus_orb::OrbClient_ptr -plpbus_orb::OrbClient::_narrow(::CORBA::Object_ptr obj) -{ - if( !obj || obj->_NP_is_nil() || obj->_NP_is_pseudo() ) return _nil(); - _ptr_type e = (_ptr_type) obj->_PR_getobj()->_realNarrow(_PD_repoId); - return e ? e : _nil(); -} - - -plpbus_orb::OrbClient_ptr -plpbus_orb::OrbClient::_unchecked_narrow(::CORBA::Object_ptr obj) -{ - if( !obj || obj->_NP_is_nil() || obj->_NP_is_pseudo() ) return _nil(); - _ptr_type e = (_ptr_type) obj->_PR_getobj()->_uncheckedNarrow(_PD_repoId); - return e ? e : _nil(); -} - -plpbus_orb::OrbClient_ptr -plpbus_orb::OrbClient::_nil() -{ -#ifdef OMNI_UNLOADABLE_STUBS - static _objref_OrbClient _the_nil_obj; - return &_the_nil_obj; -#else - static _objref_OrbClient* _the_nil_ptr = 0; - if( !_the_nil_ptr ) { - omni::nilRefLock().lock(); - if( !_the_nil_ptr ) { - _the_nil_ptr = new _objref_OrbClient; - registerNilCorbaObject(_the_nil_ptr); - } - omni::nilRefLock().unlock(); - } - return _the_nil_ptr; -#endif -} - -const char* plpbus_orb::OrbClient::_PD_repoId = "IDL:plpbus_orb/OrbClient:1.0"; - - -plpbus_orb::_objref_OrbClient::~_objref_OrbClient() { - -} - - -plpbus_orb::_objref_OrbClient::_objref_OrbClient(omniIOR* ior, omniIdentity* id) : - omniObjRef(::plpbus_orb::OrbClient::_PD_repoId, ior, id, 1) - - -{ - _PR_setobj(this); -} - -void* -plpbus_orb::_objref_OrbClient::_ptrToObjRef(const char* id) -{ - if( id == ::plpbus_orb::OrbClient::_PD_repoId ) - return (::plpbus_orb::OrbClient_ptr) this; - - if( id == ::CORBA::Object::_PD_repoId ) - return (::CORBA::Object_ptr) this; - - if( omni::strMatch(id, ::plpbus_orb::OrbClient::_PD_repoId) ) - return (::plpbus_orb::OrbClient_ptr) this; - - if( omni::strMatch(id, ::CORBA::Object::_PD_repoId) ) - return (::CORBA::Object_ptr) this; - - return 0; -} - -// Proxy call descriptor class. Mangled signature: -// void_i_cstring -class _0RL_cd_00d6793dc2c2a80c_00000000 - : public omniCallDescriptor -{ -public: - inline _0RL_cd_00d6793dc2c2a80c_00000000(LocalCallFn lcfn,const char* op_,size_t oplen,_CORBA_Boolean upcall=0): - omniCallDescriptor(lcfn, op_, oplen, 0, _user_exns, 0, upcall) - { - - } - - void marshalArguments(cdrStream&); - void unmarshalArguments(cdrStream&); - - - - static const char* const _user_exns[]; - - ::CORBA::String_var arg_0_; - const char* arg_0; -}; - -void _0RL_cd_00d6793dc2c2a80c_00000000::marshalArguments(cdrStream& _n) -{ - _n.marshalString(arg_0,0); - -} - -void _0RL_cd_00d6793dc2c2a80c_00000000::unmarshalArguments(cdrStream& _n) -{ - arg_0_ = _n.unmarshalString(0); - arg_0 = arg_0_.in(); - -} - -const char* const _0RL_cd_00d6793dc2c2a80c_00000000::_user_exns[] = { - 0 -}; - -// Local call call-back function. -static void -_0RL_lcfn_00d6793dc2c2a80c_10000000(omniCallDescriptor* cd, omniServant* svnt) -{ - _0RL_cd_00d6793dc2c2a80c_00000000* tcd = (_0RL_cd_00d6793dc2c2a80c_00000000*)cd; - plpbus_orb::_impl_OrbClient* impl = (plpbus_orb::_impl_OrbClient*) svnt->_ptrToInterface(plpbus_orb::OrbClient::_PD_repoId); - impl->receive_event_message(tcd->arg_0); - - -} - -void plpbus_orb::_objref_OrbClient::receive_event_message(const char* event_param) -{ - _0RL_cd_00d6793dc2c2a80c_00000000 _call_desc(_0RL_lcfn_00d6793dc2c2a80c_10000000, "receive_event_message", 22); - _call_desc.arg_0 = event_param; - - _invoke(_call_desc); - - - -} -// Proxy call descriptor class. Mangled signature: -// void_i_cplpbus__orb_mDataItemSequence -class _0RL_cd_00d6793dc2c2a80c_20000000 - : public omniCallDescriptor -{ -public: - inline _0RL_cd_00d6793dc2c2a80c_20000000(LocalCallFn lcfn,const char* op_,size_t oplen,_CORBA_Boolean upcall=0): - omniCallDescriptor(lcfn, op_, oplen, 0, _user_exns, 0, upcall) - { - - } - - void marshalArguments(cdrStream&); - void unmarshalArguments(cdrStream&); - - - - static const char* const _user_exns[]; - - plpbus_orb::DataItemSequence_var arg_0_; - const plpbus_orb::DataItemSequence* arg_0; -}; - -void _0RL_cd_00d6793dc2c2a80c_20000000::marshalArguments(cdrStream& _n) -{ - (const plpbus_orb::DataItemSequence&) *arg_0 >>= _n; - -} - -void _0RL_cd_00d6793dc2c2a80c_20000000::unmarshalArguments(cdrStream& _n) -{ - arg_0_ = new plpbus_orb::DataItemSequence; - (plpbus_orb::DataItemSequence&)arg_0_ <<= _n; - arg_0 = &arg_0_.in(); - -} - -const char* const _0RL_cd_00d6793dc2c2a80c_20000000::_user_exns[] = { - 0 -}; - -// Local call call-back function. -static void -_0RL_lcfn_00d6793dc2c2a80c_30000000(omniCallDescriptor* cd, omniServant* svnt) -{ - _0RL_cd_00d6793dc2c2a80c_20000000* tcd = (_0RL_cd_00d6793dc2c2a80c_20000000*)cd; - plpbus_orb::_impl_OrbClient* impl = (plpbus_orb::_impl_OrbClient*) svnt->_ptrToInterface(plpbus_orb::OrbClient::_PD_repoId); - impl->receive_event_dataitem_sequence(*tcd->arg_0); - - -} - -void plpbus_orb::_objref_OrbClient::receive_event_dataitem_sequence(const ::plpbus_orb::DataItemSequence& event_param) -{ - _0RL_cd_00d6793dc2c2a80c_20000000 _call_desc(_0RL_lcfn_00d6793dc2c2a80c_30000000, "receive_event_dataitem_sequence", 32); - _call_desc.arg_0 = &(::plpbus_orb::DataItemSequence&) event_param; - - _invoke(_call_desc); - - - -} -// Local call call-back function. -static void -_0RL_lcfn_00d6793dc2c2a80c_40000000(omniCallDescriptor* cd, omniServant* svnt) -{ - _0RL_cd_00d6793dc2c2a80c_00000000* tcd = (_0RL_cd_00d6793dc2c2a80c_00000000*)cd; - plpbus_orb::_impl_OrbClient* impl = (plpbus_orb::_impl_OrbClient*) svnt->_ptrToInterface(plpbus_orb::OrbClient::_PD_repoId); - impl->receive_response_message(tcd->arg_0); - - -} - -void plpbus_orb::_objref_OrbClient::receive_response_message(const char* msg_rsp_param) -{ - _0RL_cd_00d6793dc2c2a80c_00000000 _call_desc(_0RL_lcfn_00d6793dc2c2a80c_40000000, "receive_response_message", 25); - _call_desc.arg_0 = msg_rsp_param; - - _invoke(_call_desc); - - - -} -// Local call call-back function. -static void -_0RL_lcfn_00d6793dc2c2a80c_50000000(omniCallDescriptor* cd, omniServant* svnt) -{ - _0RL_cd_00d6793dc2c2a80c_20000000* tcd = (_0RL_cd_00d6793dc2c2a80c_20000000*)cd; - plpbus_orb::_impl_OrbClient* impl = (plpbus_orb::_impl_OrbClient*) svnt->_ptrToInterface(plpbus_orb::OrbClient::_PD_repoId); - impl->receive_response_dataitem_sequence(*tcd->arg_0); - - -} - -void plpbus_orb::_objref_OrbClient::receive_response_dataitem_sequence(const ::plpbus_orb::DataItemSequence& msg_rsp_param) -{ - _0RL_cd_00d6793dc2c2a80c_20000000 _call_desc(_0RL_lcfn_00d6793dc2c2a80c_50000000, "receive_response_dataitem_sequence", 35); - _call_desc.arg_0 = &(::plpbus_orb::DataItemSequence&) msg_rsp_param; - - _invoke(_call_desc); - - - -} -plpbus_orb::_pof_OrbClient::~_pof_OrbClient() {} - - -omniObjRef* -plpbus_orb::_pof_OrbClient::newObjRef(omniIOR* ior, omniIdentity* id) -{ - return new ::plpbus_orb::_objref_OrbClient(ior, id); -} - - -::CORBA::Boolean -plpbus_orb::_pof_OrbClient::is_a(const char* id) const -{ - if( omni::ptrStrMatch(id, ::plpbus_orb::OrbClient::_PD_repoId) ) - return 1; - - return 0; -} - -const plpbus_orb::_pof_OrbClient _the_pof_plpbus__orb_mOrbClient; - -plpbus_orb::_impl_OrbClient::~_impl_OrbClient() {} - - -::CORBA::Boolean -plpbus_orb::_impl_OrbClient::_dispatch(omniCallHandle& _handle) -{ - const char* op = _handle.operation_name(); - - if( omni::strMatch(op, "receive_event_message") ) { - - _0RL_cd_00d6793dc2c2a80c_00000000 _call_desc(_0RL_lcfn_00d6793dc2c2a80c_10000000, "receive_event_message", 22, 1); - - _handle.upcall(this,_call_desc); - return 1; - } - - if( omni::strMatch(op, "receive_event_dataitem_sequence") ) { - - _0RL_cd_00d6793dc2c2a80c_20000000 _call_desc(_0RL_lcfn_00d6793dc2c2a80c_30000000, "receive_event_dataitem_sequence", 32, 1); - - _handle.upcall(this,_call_desc); - return 1; - } - - if( omni::strMatch(op, "receive_response_message") ) { - - _0RL_cd_00d6793dc2c2a80c_00000000 _call_desc(_0RL_lcfn_00d6793dc2c2a80c_40000000, "receive_response_message", 25, 1); - - _handle.upcall(this,_call_desc); - return 1; - } - - if( omni::strMatch(op, "receive_response_dataitem_sequence") ) { - - _0RL_cd_00d6793dc2c2a80c_20000000 _call_desc(_0RL_lcfn_00d6793dc2c2a80c_50000000, "receive_response_dataitem_sequence", 35, 1); - - _handle.upcall(this,_call_desc); - return 1; - } - - - return 0; -} - -void* -plpbus_orb::_impl_OrbClient::_ptrToInterface(const char* id) -{ - if( id == ::plpbus_orb::OrbClient::_PD_repoId ) - return (::plpbus_orb::_impl_OrbClient*) this; - - if( id == ::CORBA::Object::_PD_repoId ) - return (void*) 1; - - if( omni::strMatch(id, ::plpbus_orb::OrbClient::_PD_repoId) ) - return (::plpbus_orb::_impl_OrbClient*) this; - - if( omni::strMatch(id, ::CORBA::Object::_PD_repoId) ) - return (void*) 1; - return 0; -} - -const char* -plpbus_orb::_impl_OrbClient::_mostDerivedRepoId() -{ - return ::plpbus_orb::OrbClient::_PD_repoId; -} - -plpbus_orb::OrbServer_ptr plpbus_orb::OrbServer_Helper::_nil() { - return ::plpbus_orb::OrbServer::_nil(); -} - -::CORBA::Boolean plpbus_orb::OrbServer_Helper::is_nil(::plpbus_orb::OrbServer_ptr p) { - return ::CORBA::is_nil(p); - -} - -void plpbus_orb::OrbServer_Helper::release(::plpbus_orb::OrbServer_ptr p) { - ::CORBA::release(p); -} - -void plpbus_orb::OrbServer_Helper::marshalObjRef(::plpbus_orb::OrbServer_ptr obj, cdrStream& s) { - ::plpbus_orb::OrbServer::_marshalObjRef(obj, s); -} - -plpbus_orb::OrbServer_ptr plpbus_orb::OrbServer_Helper::unmarshalObjRef(cdrStream& s) { - return ::plpbus_orb::OrbServer::_unmarshalObjRef(s); -} - -void plpbus_orb::OrbServer_Helper::duplicate(::plpbus_orb::OrbServer_ptr obj) { - if( obj && !obj->_NP_is_nil() ) omni::duplicateObjRef(obj); -} - -plpbus_orb::OrbServer_ptr -plpbus_orb::OrbServer::_duplicate(::plpbus_orb::OrbServer_ptr obj) -{ - if( obj && !obj->_NP_is_nil() ) omni::duplicateObjRef(obj); - return obj; -} - -plpbus_orb::OrbServer_ptr -plpbus_orb::OrbServer::_narrow(::CORBA::Object_ptr obj) -{ - if( !obj || obj->_NP_is_nil() || obj->_NP_is_pseudo() ) return _nil(); - _ptr_type e = (_ptr_type) obj->_PR_getobj()->_realNarrow(_PD_repoId); - return e ? e : _nil(); -} - - -plpbus_orb::OrbServer_ptr -plpbus_orb::OrbServer::_unchecked_narrow(::CORBA::Object_ptr obj) -{ - if( !obj || obj->_NP_is_nil() || obj->_NP_is_pseudo() ) return _nil(); - _ptr_type e = (_ptr_type) obj->_PR_getobj()->_uncheckedNarrow(_PD_repoId); - return e ? e : _nil(); -} - -plpbus_orb::OrbServer_ptr -plpbus_orb::OrbServer::_nil() -{ -#ifdef OMNI_UNLOADABLE_STUBS - static _objref_OrbServer _the_nil_obj; - return &_the_nil_obj; -#else - static _objref_OrbServer* _the_nil_ptr = 0; - if( !_the_nil_ptr ) { - omni::nilRefLock().lock(); - if( !_the_nil_ptr ) { - _the_nil_ptr = new _objref_OrbServer; - registerNilCorbaObject(_the_nil_ptr); - } - omni::nilRefLock().unlock(); - } - return _the_nil_ptr; -#endif -} - -const char* plpbus_orb::OrbServer::_PD_repoId = "IDL:plpbus_orb/OrbServer:1.0"; - - -plpbus_orb::_objref_OrbServer::~_objref_OrbServer() { - -} - - -plpbus_orb::_objref_OrbServer::_objref_OrbServer(omniIOR* ior, omniIdentity* id) : - omniObjRef(::plpbus_orb::OrbServer::_PD_repoId, ior, id, 1) - - -{ - _PR_setobj(this); -} - -void* -plpbus_orb::_objref_OrbServer::_ptrToObjRef(const char* id) -{ - if( id == ::plpbus_orb::OrbServer::_PD_repoId ) - return (::plpbus_orb::OrbServer_ptr) this; - - if( id == ::CORBA::Object::_PD_repoId ) - return (::CORBA::Object_ptr) this; - - if( omni::strMatch(id, ::plpbus_orb::OrbServer::_PD_repoId) ) - return (::plpbus_orb::OrbServer_ptr) this; - - if( omni::strMatch(id, ::CORBA::Object::_PD_repoId) ) - return (::CORBA::Object_ptr) this; - - return 0; -} - -// Proxy call descriptor class. Mangled signature: -// void_i_cplpbus__orb_mOrbClient_i_cstring -class _0RL_cd_00d6793dc2c2a80c_60000000 - : public omniCallDescriptor -{ -public: - inline _0RL_cd_00d6793dc2c2a80c_60000000(LocalCallFn lcfn,const char* op_,size_t oplen,_CORBA_Boolean upcall=0): - omniCallDescriptor(lcfn, op_, oplen, 0, _user_exns, 0, upcall) - { - - } - - void marshalArguments(cdrStream&); - void unmarshalArguments(cdrStream&); - - - - static const char* const _user_exns[]; - - plpbus_orb::OrbClient_var arg_0_; - plpbus_orb::OrbClient_ptr arg_0; - ::CORBA::String_var arg_1_; - const char* arg_1; -}; - -void _0RL_cd_00d6793dc2c2a80c_60000000::marshalArguments(cdrStream& _n) -{ - plpbus_orb::OrbClient::_marshalObjRef(arg_0,_n); - _n.marshalString(arg_1,0); - -} - -void _0RL_cd_00d6793dc2c2a80c_60000000::unmarshalArguments(cdrStream& _n) -{ - arg_0_ = plpbus_orb::OrbClient::_unmarshalObjRef(_n); - arg_0 = arg_0_.in(); - arg_1_ = _n.unmarshalString(0); - arg_1 = arg_1_.in(); - -} - -const char* const _0RL_cd_00d6793dc2c2a80c_60000000::_user_exns[] = { - 0 -}; - -// Local call call-back function. -static void -_0RL_lcfn_00d6793dc2c2a80c_70000000(omniCallDescriptor* cd, omniServant* svnt) -{ - _0RL_cd_00d6793dc2c2a80c_60000000* tcd = (_0RL_cd_00d6793dc2c2a80c_60000000*)cd; - plpbus_orb::_impl_OrbServer* impl = (plpbus_orb::_impl_OrbServer*) svnt->_ptrToInterface(plpbus_orb::OrbServer::_PD_repoId); - impl->send_message_and_request_response(tcd->arg_0, tcd->arg_1); - - -} - -void plpbus_orb::_objref_OrbServer::send_message_and_request_response(::plpbus_orb::OrbClient_ptr response_listener_param, const char* msg_param) -{ - _0RL_cd_00d6793dc2c2a80c_60000000 _call_desc(_0RL_lcfn_00d6793dc2c2a80c_70000000, "send_message_and_request_response", 34); - _call_desc.arg_0 = response_listener_param; - _call_desc.arg_1 = msg_param; - - _invoke(_call_desc); - - - -} -// Proxy call descriptor class. Mangled signature: -// void_i_cplpbus__orb_mOrbClient_i_cplpbus__orb_mDataItemSequence -class _0RL_cd_00d6793dc2c2a80c_80000000 - : public omniCallDescriptor -{ -public: - inline _0RL_cd_00d6793dc2c2a80c_80000000(LocalCallFn lcfn,const char* op_,size_t oplen,_CORBA_Boolean upcall=0): - omniCallDescriptor(lcfn, op_, oplen, 0, _user_exns, 0, upcall) - { - - } - - void marshalArguments(cdrStream&); - void unmarshalArguments(cdrStream&); - - - - static const char* const _user_exns[]; - - plpbus_orb::OrbClient_var arg_0_; - plpbus_orb::OrbClient_ptr arg_0; - plpbus_orb::DataItemSequence_var arg_1_; - const plpbus_orb::DataItemSequence* arg_1; -}; - -void _0RL_cd_00d6793dc2c2a80c_80000000::marshalArguments(cdrStream& _n) -{ - plpbus_orb::OrbClient::_marshalObjRef(arg_0,_n); - (const plpbus_orb::DataItemSequence&) *arg_1 >>= _n; - -} - -void _0RL_cd_00d6793dc2c2a80c_80000000::unmarshalArguments(cdrStream& _n) -{ - arg_0_ = plpbus_orb::OrbClient::_unmarshalObjRef(_n); - arg_0 = arg_0_.in(); - arg_1_ = new plpbus_orb::DataItemSequence; - (plpbus_orb::DataItemSequence&)arg_1_ <<= _n; - arg_1 = &arg_1_.in(); - -} - -const char* const _0RL_cd_00d6793dc2c2a80c_80000000::_user_exns[] = { - 0 -}; - -// Local call call-back function. -static void -_0RL_lcfn_00d6793dc2c2a80c_90000000(omniCallDescriptor* cd, omniServant* svnt) -{ - _0RL_cd_00d6793dc2c2a80c_80000000* tcd = (_0RL_cd_00d6793dc2c2a80c_80000000*)cd; - plpbus_orb::_impl_OrbServer* impl = (plpbus_orb::_impl_OrbServer*) svnt->_ptrToInterface(plpbus_orb::OrbServer::_PD_repoId); - impl->send_dataitem_message_and_request_response(tcd->arg_0, *tcd->arg_1); - - -} - -void plpbus_orb::_objref_OrbServer::send_dataitem_message_and_request_response(::plpbus_orb::OrbClient_ptr response_listener_param, const ::plpbus_orb::DataItemSequence& req_seq_param) -{ - _0RL_cd_00d6793dc2c2a80c_80000000 _call_desc(_0RL_lcfn_00d6793dc2c2a80c_90000000, "send_dataitem_message_and_request_response", 43); - _call_desc.arg_0 = response_listener_param; - _call_desc.arg_1 = &(::plpbus_orb::DataItemSequence&) req_seq_param; - - _invoke(_call_desc); - - - -} -// Proxy call descriptor class. Mangled signature: -// _cstring_i_cstring_o_clong -class _0RL_cd_00d6793dc2c2a80c_a0000000 - : public omniCallDescriptor -{ -public: - inline _0RL_cd_00d6793dc2c2a80c_a0000000(LocalCallFn lcfn,const char* op_,size_t oplen,_CORBA_Boolean upcall=0): - omniCallDescriptor(lcfn, op_, oplen, 0, _user_exns, 0, upcall) - { - - } - - void marshalArguments(cdrStream&); - void unmarshalArguments(cdrStream&); - - void unmarshalReturnedValues(cdrStream&); - void marshalReturnedValues(cdrStream&); - - - static const char* const _user_exns[]; - - ::CORBA::String_var arg_0_; - const char* arg_0; - ::CORBA::Long arg_1; - ::CORBA::String_var result; -}; - -void _0RL_cd_00d6793dc2c2a80c_a0000000::marshalArguments(cdrStream& _n) -{ - _n.marshalString(arg_0,0); - -} - -void _0RL_cd_00d6793dc2c2a80c_a0000000::unmarshalArguments(cdrStream& _n) -{ - arg_0_ = _n.unmarshalString(0); - arg_0 = arg_0_.in(); - -} - -void _0RL_cd_00d6793dc2c2a80c_a0000000::marshalReturnedValues(cdrStream& _n) -{ - _n.marshalString(result,0); - arg_1 >>= _n; - -} - -void _0RL_cd_00d6793dc2c2a80c_a0000000::unmarshalReturnedValues(cdrStream& _n) -{ - result = _n.unmarshalString(0); - (::CORBA::Long&)arg_1 <<= _n; - -} - -const char* const _0RL_cd_00d6793dc2c2a80c_a0000000::_user_exns[] = { - 0 -}; - -// Local call call-back function. -static void -_0RL_lcfn_00d6793dc2c2a80c_b0000000(omniCallDescriptor* cd, omniServant* svnt) -{ - _0RL_cd_00d6793dc2c2a80c_a0000000* tcd = (_0RL_cd_00d6793dc2c2a80c_a0000000*)cd; - plpbus_orb::_impl_OrbServer* impl = (plpbus_orb::_impl_OrbServer*) svnt->_ptrToInterface(plpbus_orb::OrbServer::_PD_repoId); - tcd->result = impl->send_message_and_wait_response(tcd->arg_0, tcd->arg_1); - - -} - -char* plpbus_orb::_objref_OrbServer::send_message_and_wait_response(const char* msg_req_param, ::CORBA::Long& err_flg) -{ - _0RL_cd_00d6793dc2c2a80c_a0000000 _call_desc(_0RL_lcfn_00d6793dc2c2a80c_b0000000, "send_message_and_wait_response", 31); - _call_desc.arg_0 = msg_req_param; - - _invoke(_call_desc); - err_flg = _call_desc.arg_1; - return _call_desc.result._retn(); - - -} -// Proxy call descriptor class. Mangled signature: -// _clong_i_cplpbus__orb_mDataItemSequence_o_cplpbus__orb_mDataItemSequence -class _0RL_cd_00d6793dc2c2a80c_c0000000 - : public omniCallDescriptor -{ -public: - inline _0RL_cd_00d6793dc2c2a80c_c0000000(LocalCallFn lcfn,const char* op_,size_t oplen,_CORBA_Boolean upcall=0): - omniCallDescriptor(lcfn, op_, oplen, 0, _user_exns, 0, upcall) - { - - } - - void marshalArguments(cdrStream&); - void unmarshalArguments(cdrStream&); - - void unmarshalReturnedValues(cdrStream&); - void marshalReturnedValues(cdrStream&); - - - static const char* const _user_exns[]; - - plpbus_orb::DataItemSequence_var arg_0_; - const plpbus_orb::DataItemSequence* arg_0; - plpbus_orb::DataItemSequence_var arg_1; - ::CORBA::Long result; -}; - -void _0RL_cd_00d6793dc2c2a80c_c0000000::marshalArguments(cdrStream& _n) -{ - (const plpbus_orb::DataItemSequence&) *arg_0 >>= _n; - -} - -void _0RL_cd_00d6793dc2c2a80c_c0000000::unmarshalArguments(cdrStream& _n) -{ - arg_0_ = new plpbus_orb::DataItemSequence; - (plpbus_orb::DataItemSequence&)arg_0_ <<= _n; - arg_0 = &arg_0_.in(); - -} - -void _0RL_cd_00d6793dc2c2a80c_c0000000::marshalReturnedValues(cdrStream& _n) -{ - result >>= _n; - (const plpbus_orb::DataItemSequence&) arg_1 >>= _n; - -} - -void _0RL_cd_00d6793dc2c2a80c_c0000000::unmarshalReturnedValues(cdrStream& _n) -{ - (::CORBA::Long&)result <<= _n; - arg_1 = new plpbus_orb::DataItemSequence; - (plpbus_orb::DataItemSequence&)arg_1 <<= _n; - -} - -const char* const _0RL_cd_00d6793dc2c2a80c_c0000000::_user_exns[] = { - 0 -}; - -// Local call call-back function. -static void -_0RL_lcfn_00d6793dc2c2a80c_d0000000(omniCallDescriptor* cd, omniServant* svnt) -{ - _0RL_cd_00d6793dc2c2a80c_c0000000* tcd = (_0RL_cd_00d6793dc2c2a80c_c0000000*)cd; - plpbus_orb::_impl_OrbServer* impl = (plpbus_orb::_impl_OrbServer*) svnt->_ptrToInterface(plpbus_orb::OrbServer::_PD_repoId); - tcd->result = impl->send_dataitem_message_and_wait_response(*tcd->arg_0, tcd->arg_1.out()); - - -} - -::CORBA::Long plpbus_orb::_objref_OrbServer::send_dataitem_message_and_wait_response(const ::plpbus_orb::DataItemSequence& req_seq_param, ::plpbus_orb::DataItemSequence_out rsp_seq_param) -{ - _0RL_cd_00d6793dc2c2a80c_c0000000 _call_desc(_0RL_lcfn_00d6793dc2c2a80c_d0000000, "send_dataitem_message_and_wait_response", 40); - _call_desc.arg_0 = &(::plpbus_orb::DataItemSequence&) req_seq_param; - - _invoke(_call_desc); - rsp_seq_param = _call_desc.arg_1._retn(); - return _call_desc.result; - - -} -// Proxy call descriptor class. Mangled signature: -// void_i_cplpbus__orb_mOrbClient_i_cstring_i_cunsigned_pshort -class _0RL_cd_00d6793dc2c2a80c_e0000000 - : public omniCallDescriptor -{ -public: - inline _0RL_cd_00d6793dc2c2a80c_e0000000(LocalCallFn lcfn,const char* op_,size_t oplen,_CORBA_Boolean upcall=0): - omniCallDescriptor(lcfn, op_, oplen, 0, _user_exns, 0, upcall) - { - - } - - void marshalArguments(cdrStream&); - void unmarshalArguments(cdrStream&); - - - - static const char* const _user_exns[]; - - plpbus_orb::OrbClient_var arg_0_; - plpbus_orb::OrbClient_ptr arg_0; - ::CORBA::String_var arg_1_; - const char* arg_1; - ::CORBA::UShort arg_2; -}; - -void _0RL_cd_00d6793dc2c2a80c_e0000000::marshalArguments(cdrStream& _n) -{ - plpbus_orb::OrbClient::_marshalObjRef(arg_0,_n); - _n.marshalString(arg_1,0); - arg_2 >>= _n; - -} - -void _0RL_cd_00d6793dc2c2a80c_e0000000::unmarshalArguments(cdrStream& _n) -{ - arg_0_ = plpbus_orb::OrbClient::_unmarshalObjRef(_n); - arg_0 = arg_0_.in(); - arg_1_ = _n.unmarshalString(0); - arg_1 = arg_1_.in(); - (::CORBA::UShort&)arg_2 <<= _n; - -} - -const char* const _0RL_cd_00d6793dc2c2a80c_e0000000::_user_exns[] = { - 0 -}; - -// Local call call-back function. -static void -_0RL_lcfn_00d6793dc2c2a80c_f0000000(omniCallDescriptor* cd, omniServant* svnt) -{ - _0RL_cd_00d6793dc2c2a80c_e0000000* tcd = (_0RL_cd_00d6793dc2c2a80c_e0000000*)cd; - plpbus_orb::_impl_OrbServer* impl = (plpbus_orb::_impl_OrbServer*) svnt->_ptrToInterface(plpbus_orb::OrbServer::_PD_repoId); - impl->add_event_listener(tcd->arg_0, tcd->arg_1, tcd->arg_2); - - -} - -void plpbus_orb::_objref_OrbServer::add_event_listener(::plpbus_orb::OrbClient_ptr callback_client_param, const char* msg_param, ::CORBA::UShort period_secs) -{ - _0RL_cd_00d6793dc2c2a80c_e0000000 _call_desc(_0RL_lcfn_00d6793dc2c2a80c_f0000000, "add_event_listener", 19); - _call_desc.arg_0 = callback_client_param; - _call_desc.arg_1 = msg_param; - _call_desc.arg_2 = period_secs; - - _invoke(_call_desc); - - - -} -// Proxy call descriptor class. Mangled signature: -// void -class _0RL_cd_00d6793dc2c2a80c_01000000 - : public omniCallDescriptor -{ -public: - inline _0RL_cd_00d6793dc2c2a80c_01000000(LocalCallFn lcfn,const char* op_,size_t oplen,_CORBA_Boolean upcall=0): - omniCallDescriptor(lcfn, op_, oplen, 0, _user_exns, 0, upcall) - { - - } - - - - - static const char* const _user_exns[]; - - -}; - -const char* const _0RL_cd_00d6793dc2c2a80c_01000000::_user_exns[] = { - 0 -}; - -// Local call call-back function. -static void -_0RL_lcfn_00d6793dc2c2a80c_11000000(omniCallDescriptor*, omniServant* svnt) -{ - - plpbus_orb::_impl_OrbServer* impl = (plpbus_orb::_impl_OrbServer*) svnt->_ptrToInterface(plpbus_orb::OrbServer::_PD_repoId); - impl->shutdown(); - - -} - -void plpbus_orb::_objref_OrbServer::shutdown() -{ - _0RL_cd_00d6793dc2c2a80c_01000000 _call_desc(_0RL_lcfn_00d6793dc2c2a80c_11000000, "shutdown", 9); - - - _invoke(_call_desc); - - - -} -plpbus_orb::_pof_OrbServer::~_pof_OrbServer() {} - - -omniObjRef* -plpbus_orb::_pof_OrbServer::newObjRef(omniIOR* ior, omniIdentity* id) -{ - return new ::plpbus_orb::_objref_OrbServer(ior, id); -} - - -::CORBA::Boolean -plpbus_orb::_pof_OrbServer::is_a(const char* id) const -{ - if( omni::ptrStrMatch(id, ::plpbus_orb::OrbServer::_PD_repoId) ) - return 1; - - return 0; -} - -const plpbus_orb::_pof_OrbServer _the_pof_plpbus__orb_mOrbServer; - -plpbus_orb::_impl_OrbServer::~_impl_OrbServer() {} - - -::CORBA::Boolean -plpbus_orb::_impl_OrbServer::_dispatch(omniCallHandle& _handle) -{ - const char* op = _handle.operation_name(); - - if( omni::strMatch(op, "send_message_and_request_response") ) { - - _0RL_cd_00d6793dc2c2a80c_60000000 _call_desc(_0RL_lcfn_00d6793dc2c2a80c_70000000, "send_message_and_request_response", 34, 1); - - _handle.upcall(this,_call_desc); - return 1; - } - - if( omni::strMatch(op, "send_dataitem_message_and_request_response") ) { - - _0RL_cd_00d6793dc2c2a80c_80000000 _call_desc(_0RL_lcfn_00d6793dc2c2a80c_90000000, "send_dataitem_message_and_request_response", 43, 1); - - _handle.upcall(this,_call_desc); - return 1; - } - - if( omni::strMatch(op, "send_message_and_wait_response") ) { - - _0RL_cd_00d6793dc2c2a80c_a0000000 _call_desc(_0RL_lcfn_00d6793dc2c2a80c_b0000000, "send_message_and_wait_response", 31, 1); - - _handle.upcall(this,_call_desc); - return 1; - } - - if( omni::strMatch(op, "send_dataitem_message_and_wait_response") ) { - - _0RL_cd_00d6793dc2c2a80c_c0000000 _call_desc(_0RL_lcfn_00d6793dc2c2a80c_d0000000, "send_dataitem_message_and_wait_response", 40, 1); - - _handle.upcall(this,_call_desc); - return 1; - } - - if( omni::strMatch(op, "add_event_listener") ) { - - _0RL_cd_00d6793dc2c2a80c_e0000000 _call_desc(_0RL_lcfn_00d6793dc2c2a80c_f0000000, "add_event_listener", 19, 1); - - _handle.upcall(this,_call_desc); - return 1; - } - - if( omni::strMatch(op, "shutdown") ) { - - _0RL_cd_00d6793dc2c2a80c_01000000 _call_desc(_0RL_lcfn_00d6793dc2c2a80c_11000000, "shutdown", 9, 1); - - _handle.upcall(this,_call_desc); - return 1; - } - - - return 0; -} - -void* -plpbus_orb::_impl_OrbServer::_ptrToInterface(const char* id) -{ - if( id == ::plpbus_orb::OrbServer::_PD_repoId ) - return (::plpbus_orb::_impl_OrbServer*) this; - - if( id == ::CORBA::Object::_PD_repoId ) - return (void*) 1; - - if( omni::strMatch(id, ::plpbus_orb::OrbServer::_PD_repoId) ) - return (::plpbus_orb::_impl_OrbServer*) this; - - if( omni::strMatch(id, ::CORBA::Object::_PD_repoId) ) - return (void*) 1; - return 0; -} - -const char* -plpbus_orb::_impl_OrbServer::_mostDerivedRepoId() -{ - return ::plpbus_orb::OrbServer::_PD_repoId; -} - -POA_plpbus_orb::OrbClient::~OrbClient() {} - -POA_plpbus_orb::OrbServer::~OrbServer() {} - diff --git a/src_test/Makefile.am b/src_test/Makefile.am index 51f1019..9a93bc5 100644 --- a/src_test/Makefile.am +++ b/src_test/Makefile.am @@ -11,6 +11,6 @@ test_client_LDADD = $(SRC_LIBS) ../src/.libs/libplpbus.a test_server_SOURCES = test_server.cc test_server_LDADD = $(SRC_LIBS) ../src/.libs/libplpbus.a -AM_CPPFLAGS = $(SRC_CFLAGS) -I../src +AM_CPPFLAGS = $(SRC_CFLAGS) -I../src -I../src/idl DISTCLEANFILES = Makefile.in \ No newline at end of file -- 2.41.1