+// 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() {}
+