+++ /dev/null
-// 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 <omniORB4/CORBA.h>
-#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<DataItem> _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 _omniT>
- 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 _omniT>
- 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__
-
+++ /dev/null
-// This file is generated by omniidl (C++ backend)- omniORB_4_1. Do not edit.
-
-#include "RequestResponseBus.hh"
-#include <omniORB4/IOP_S.h>
-#include <omniORB4/IOP_C.h>
-#include <omniORB4/callDescriptor.h>
-#include <omniORB4/callHandle.h>
-#include <omniORB4/objTracker.h>
-
-
-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() {}
-
projects / libplpbus.git / commitdiff