1 // This file is generated by omniidl (C++ backend)- omniORB_4_1. Do not edit.
3 #include "RequestResponseBus.hh"
4 #include <omniORB4/IOP_S.h>
5 #include <omniORB4/IOP_C.h>
6 #include <omniORB4/callDescriptor.h>
7 #include <omniORB4/callHandle.h>
8 #include <omniORB4/objTracker.h>
11 OMNI_USING_NAMESPACE(omni)
13 static const char* _0RL_library_version = omniORB_4_1;
18 plpbus_orb::DataItem::operator>>= (cdrStream &_n) const
20 _n.marshalString(name,0);
21 (const ::CORBA::Any&) value >>= _n;
26 plpbus_orb::DataItem::operator<<= (cdrStream &_n)
28 name = _n.unmarshalString(0);
29 (::CORBA::Any&)value <<= _n;
33 plpbus_orb::OrbClient_ptr plpbus_orb::OrbClient_Helper::_nil() {
34 return ::plpbus_orb::OrbClient::_nil();
37 ::CORBA::Boolean plpbus_orb::OrbClient_Helper::is_nil(::plpbus_orb::OrbClient_ptr p) {
38 return ::CORBA::is_nil(p);
42 void plpbus_orb::OrbClient_Helper::release(::plpbus_orb::OrbClient_ptr p) {
46 void plpbus_orb::OrbClient_Helper::marshalObjRef(::plpbus_orb::OrbClient_ptr obj, cdrStream& s) {
47 ::plpbus_orb::OrbClient::_marshalObjRef(obj, s);
50 plpbus_orb::OrbClient_ptr plpbus_orb::OrbClient_Helper::unmarshalObjRef(cdrStream& s) {
51 return ::plpbus_orb::OrbClient::_unmarshalObjRef(s);
54 void plpbus_orb::OrbClient_Helper::duplicate(::plpbus_orb::OrbClient_ptr obj) {
55 if( obj && !obj->_NP_is_nil() ) omni::duplicateObjRef(obj);
58 plpbus_orb::OrbClient_ptr
59 plpbus_orb::OrbClient::_duplicate(::plpbus_orb::OrbClient_ptr obj)
61 if( obj && !obj->_NP_is_nil() ) omni::duplicateObjRef(obj);
65 plpbus_orb::OrbClient_ptr
66 plpbus_orb::OrbClient::_narrow(::CORBA::Object_ptr obj)
68 if( !obj || obj->_NP_is_nil() || obj->_NP_is_pseudo() ) return _nil();
69 _ptr_type e = (_ptr_type) obj->_PR_getobj()->_realNarrow(_PD_repoId);
70 return e ? e : _nil();
74 plpbus_orb::OrbClient_ptr
75 plpbus_orb::OrbClient::_unchecked_narrow(::CORBA::Object_ptr obj)
77 if( !obj || obj->_NP_is_nil() || obj->_NP_is_pseudo() ) return _nil();
78 _ptr_type e = (_ptr_type) obj->_PR_getobj()->_uncheckedNarrow(_PD_repoId);
79 return e ? e : _nil();
82 plpbus_orb::OrbClient_ptr
83 plpbus_orb::OrbClient::_nil()
85 #ifdef OMNI_UNLOADABLE_STUBS
86 static _objref_OrbClient _the_nil_obj;
89 static _objref_OrbClient* _the_nil_ptr = 0;
91 omni::nilRefLock().lock();
93 _the_nil_ptr = new _objref_OrbClient;
94 registerNilCorbaObject(_the_nil_ptr);
96 omni::nilRefLock().unlock();
102 const char* plpbus_orb::OrbClient::_PD_repoId = "IDL:plpbus_orb/OrbClient:1.0";
105 plpbus_orb::_objref_OrbClient::~_objref_OrbClient() {
110 plpbus_orb::_objref_OrbClient::_objref_OrbClient(omniIOR* ior, omniIdentity* id) :
111 omniObjRef(::plpbus_orb::OrbClient::_PD_repoId, ior, id, 1)
119 plpbus_orb::_objref_OrbClient::_ptrToObjRef(const char* id)
121 if( id == ::plpbus_orb::OrbClient::_PD_repoId )
122 return (::plpbus_orb::OrbClient_ptr) this;
124 if( id == ::CORBA::Object::_PD_repoId )
125 return (::CORBA::Object_ptr) this;
127 if( omni::strMatch(id, ::plpbus_orb::OrbClient::_PD_repoId) )
128 return (::plpbus_orb::OrbClient_ptr) this;
130 if( omni::strMatch(id, ::CORBA::Object::_PD_repoId) )
131 return (::CORBA::Object_ptr) this;
136 // Proxy call descriptor class. Mangled signature:
138 class _0RL_cd_00d6793dc2c2a80c_00000000
139 : public omniCallDescriptor
142 inline _0RL_cd_00d6793dc2c2a80c_00000000(LocalCallFn lcfn,const char* op_,size_t oplen,_CORBA_Boolean upcall=0):
143 omniCallDescriptor(lcfn, op_, oplen, 0, _user_exns, 0, upcall)
148 void marshalArguments(cdrStream&);
149 void unmarshalArguments(cdrStream&);
153 static const char* const _user_exns[];
155 ::CORBA::String_var arg_0_;
159 void _0RL_cd_00d6793dc2c2a80c_00000000::marshalArguments(cdrStream& _n)
161 _n.marshalString(arg_0,0);
165 void _0RL_cd_00d6793dc2c2a80c_00000000::unmarshalArguments(cdrStream& _n)
167 arg_0_ = _n.unmarshalString(0);
172 const char* const _0RL_cd_00d6793dc2c2a80c_00000000::_user_exns[] = {
176 // Local call call-back function.
178 _0RL_lcfn_00d6793dc2c2a80c_10000000(omniCallDescriptor* cd, omniServant* svnt)
180 _0RL_cd_00d6793dc2c2a80c_00000000* tcd = (_0RL_cd_00d6793dc2c2a80c_00000000*)cd;
181 plpbus_orb::_impl_OrbClient* impl = (plpbus_orb::_impl_OrbClient*) svnt->_ptrToInterface(plpbus_orb::OrbClient::_PD_repoId);
182 impl->receive_event_message(tcd->arg_0);
187 void plpbus_orb::_objref_OrbClient::receive_event_message(const char* event_param)
189 _0RL_cd_00d6793dc2c2a80c_00000000 _call_desc(_0RL_lcfn_00d6793dc2c2a80c_10000000, "receive_event_message", 22);
190 _call_desc.arg_0 = event_param;
197 // Proxy call descriptor class. Mangled signature:
198 // void_i_cplpbus__orb_mDataItemSequence
199 class _0RL_cd_00d6793dc2c2a80c_20000000
200 : public omniCallDescriptor
203 inline _0RL_cd_00d6793dc2c2a80c_20000000(LocalCallFn lcfn,const char* op_,size_t oplen,_CORBA_Boolean upcall=0):
204 omniCallDescriptor(lcfn, op_, oplen, 0, _user_exns, 0, upcall)
209 void marshalArguments(cdrStream&);
210 void unmarshalArguments(cdrStream&);
214 static const char* const _user_exns[];
216 plpbus_orb::DataItemSequence_var arg_0_;
217 const plpbus_orb::DataItemSequence* arg_0;
220 void _0RL_cd_00d6793dc2c2a80c_20000000::marshalArguments(cdrStream& _n)
222 (const plpbus_orb::DataItemSequence&) *arg_0 >>= _n;
226 void _0RL_cd_00d6793dc2c2a80c_20000000::unmarshalArguments(cdrStream& _n)
228 arg_0_ = new plpbus_orb::DataItemSequence;
229 (plpbus_orb::DataItemSequence&)arg_0_ <<= _n;
230 arg_0 = &arg_0_.in();
234 const char* const _0RL_cd_00d6793dc2c2a80c_20000000::_user_exns[] = {
238 // Local call call-back function.
240 _0RL_lcfn_00d6793dc2c2a80c_30000000(omniCallDescriptor* cd, omniServant* svnt)
242 _0RL_cd_00d6793dc2c2a80c_20000000* tcd = (_0RL_cd_00d6793dc2c2a80c_20000000*)cd;
243 plpbus_orb::_impl_OrbClient* impl = (plpbus_orb::_impl_OrbClient*) svnt->_ptrToInterface(plpbus_orb::OrbClient::_PD_repoId);
244 impl->receive_event_dataitem_sequence(*tcd->arg_0);
249 void plpbus_orb::_objref_OrbClient::receive_event_dataitem_sequence(const ::plpbus_orb::DataItemSequence& event_param)
251 _0RL_cd_00d6793dc2c2a80c_20000000 _call_desc(_0RL_lcfn_00d6793dc2c2a80c_30000000, "receive_event_dataitem_sequence", 32);
252 _call_desc.arg_0 = &(::plpbus_orb::DataItemSequence&) event_param;
259 // Local call call-back function.
261 _0RL_lcfn_00d6793dc2c2a80c_40000000(omniCallDescriptor* cd, omniServant* svnt)
263 _0RL_cd_00d6793dc2c2a80c_00000000* tcd = (_0RL_cd_00d6793dc2c2a80c_00000000*)cd;
264 plpbus_orb::_impl_OrbClient* impl = (plpbus_orb::_impl_OrbClient*) svnt->_ptrToInterface(plpbus_orb::OrbClient::_PD_repoId);
265 impl->receive_response_message(tcd->arg_0);
270 void plpbus_orb::_objref_OrbClient::receive_response_message(const char* msg_rsp_param)
272 _0RL_cd_00d6793dc2c2a80c_00000000 _call_desc(_0RL_lcfn_00d6793dc2c2a80c_40000000, "receive_response_message", 25);
273 _call_desc.arg_0 = msg_rsp_param;
280 // Local call call-back function.
282 _0RL_lcfn_00d6793dc2c2a80c_50000000(omniCallDescriptor* cd, omniServant* svnt)
284 _0RL_cd_00d6793dc2c2a80c_20000000* tcd = (_0RL_cd_00d6793dc2c2a80c_20000000*)cd;
285 plpbus_orb::_impl_OrbClient* impl = (plpbus_orb::_impl_OrbClient*) svnt->_ptrToInterface(plpbus_orb::OrbClient::_PD_repoId);
286 impl->receive_response_dataitem_sequence(*tcd->arg_0);
291 void plpbus_orb::_objref_OrbClient::receive_response_dataitem_sequence(const ::plpbus_orb::DataItemSequence& msg_rsp_param)
293 _0RL_cd_00d6793dc2c2a80c_20000000 _call_desc(_0RL_lcfn_00d6793dc2c2a80c_50000000, "receive_response_dataitem_sequence", 35);
294 _call_desc.arg_0 = &(::plpbus_orb::DataItemSequence&) msg_rsp_param;
301 plpbus_orb::_pof_OrbClient::~_pof_OrbClient() {}
305 plpbus_orb::_pof_OrbClient::newObjRef(omniIOR* ior, omniIdentity* id)
307 return new ::plpbus_orb::_objref_OrbClient(ior, id);
312 plpbus_orb::_pof_OrbClient::is_a(const char* id) const
314 if( omni::ptrStrMatch(id, ::plpbus_orb::OrbClient::_PD_repoId) )
320 const plpbus_orb::_pof_OrbClient _the_pof_plpbus__orb_mOrbClient;
322 plpbus_orb::_impl_OrbClient::~_impl_OrbClient() {}
326 plpbus_orb::_impl_OrbClient::_dispatch(omniCallHandle& _handle)
328 const char* op = _handle.operation_name();
330 if( omni::strMatch(op, "receive_event_message") ) {
332 _0RL_cd_00d6793dc2c2a80c_00000000 _call_desc(_0RL_lcfn_00d6793dc2c2a80c_10000000, "receive_event_message", 22, 1);
334 _handle.upcall(this,_call_desc);
338 if( omni::strMatch(op, "receive_event_dataitem_sequence") ) {
340 _0RL_cd_00d6793dc2c2a80c_20000000 _call_desc(_0RL_lcfn_00d6793dc2c2a80c_30000000, "receive_event_dataitem_sequence", 32, 1);
342 _handle.upcall(this,_call_desc);
346 if( omni::strMatch(op, "receive_response_message") ) {
348 _0RL_cd_00d6793dc2c2a80c_00000000 _call_desc(_0RL_lcfn_00d6793dc2c2a80c_40000000, "receive_response_message", 25, 1);
350 _handle.upcall(this,_call_desc);
354 if( omni::strMatch(op, "receive_response_dataitem_sequence") ) {
356 _0RL_cd_00d6793dc2c2a80c_20000000 _call_desc(_0RL_lcfn_00d6793dc2c2a80c_50000000, "receive_response_dataitem_sequence", 35, 1);
358 _handle.upcall(this,_call_desc);
367 plpbus_orb::_impl_OrbClient::_ptrToInterface(const char* id)
369 if( id == ::plpbus_orb::OrbClient::_PD_repoId )
370 return (::plpbus_orb::_impl_OrbClient*) this;
372 if( id == ::CORBA::Object::_PD_repoId )
375 if( omni::strMatch(id, ::plpbus_orb::OrbClient::_PD_repoId) )
376 return (::plpbus_orb::_impl_OrbClient*) this;
378 if( omni::strMatch(id, ::CORBA::Object::_PD_repoId) )
384 plpbus_orb::_impl_OrbClient::_mostDerivedRepoId()
386 return ::plpbus_orb::OrbClient::_PD_repoId;
389 plpbus_orb::OrbServer_ptr plpbus_orb::OrbServer_Helper::_nil() {
390 return ::plpbus_orb::OrbServer::_nil();
393 ::CORBA::Boolean plpbus_orb::OrbServer_Helper::is_nil(::plpbus_orb::OrbServer_ptr p) {
394 return ::CORBA::is_nil(p);
398 void plpbus_orb::OrbServer_Helper::release(::plpbus_orb::OrbServer_ptr p) {
402 void plpbus_orb::OrbServer_Helper::marshalObjRef(::plpbus_orb::OrbServer_ptr obj, cdrStream& s) {
403 ::plpbus_orb::OrbServer::_marshalObjRef(obj, s);
406 plpbus_orb::OrbServer_ptr plpbus_orb::OrbServer_Helper::unmarshalObjRef(cdrStream& s) {
407 return ::plpbus_orb::OrbServer::_unmarshalObjRef(s);
410 void plpbus_orb::OrbServer_Helper::duplicate(::plpbus_orb::OrbServer_ptr obj) {
411 if( obj && !obj->_NP_is_nil() ) omni::duplicateObjRef(obj);
414 plpbus_orb::OrbServer_ptr
415 plpbus_orb::OrbServer::_duplicate(::plpbus_orb::OrbServer_ptr obj)
417 if( obj && !obj->_NP_is_nil() ) omni::duplicateObjRef(obj);
421 plpbus_orb::OrbServer_ptr
422 plpbus_orb::OrbServer::_narrow(::CORBA::Object_ptr obj)
424 if( !obj || obj->_NP_is_nil() || obj->_NP_is_pseudo() ) return _nil();
425 _ptr_type e = (_ptr_type) obj->_PR_getobj()->_realNarrow(_PD_repoId);
426 return e ? e : _nil();
430 plpbus_orb::OrbServer_ptr
431 plpbus_orb::OrbServer::_unchecked_narrow(::CORBA::Object_ptr obj)
433 if( !obj || obj->_NP_is_nil() || obj->_NP_is_pseudo() ) return _nil();
434 _ptr_type e = (_ptr_type) obj->_PR_getobj()->_uncheckedNarrow(_PD_repoId);
435 return e ? e : _nil();
438 plpbus_orb::OrbServer_ptr
439 plpbus_orb::OrbServer::_nil()
441 #ifdef OMNI_UNLOADABLE_STUBS
442 static _objref_OrbServer _the_nil_obj;
443 return &_the_nil_obj;
445 static _objref_OrbServer* _the_nil_ptr = 0;
446 if( !_the_nil_ptr ) {
447 omni::nilRefLock().lock();
448 if( !_the_nil_ptr ) {
449 _the_nil_ptr = new _objref_OrbServer;
450 registerNilCorbaObject(_the_nil_ptr);
452 omni::nilRefLock().unlock();
458 const char* plpbus_orb::OrbServer::_PD_repoId = "IDL:plpbus_orb/OrbServer:1.0";
461 plpbus_orb::_objref_OrbServer::~_objref_OrbServer() {
466 plpbus_orb::_objref_OrbServer::_objref_OrbServer(omniIOR* ior, omniIdentity* id) :
467 omniObjRef(::plpbus_orb::OrbServer::_PD_repoId, ior, id, 1)
475 plpbus_orb::_objref_OrbServer::_ptrToObjRef(const char* id)
477 if( id == ::plpbus_orb::OrbServer::_PD_repoId )
478 return (::plpbus_orb::OrbServer_ptr) this;
480 if( id == ::CORBA::Object::_PD_repoId )
481 return (::CORBA::Object_ptr) this;
483 if( omni::strMatch(id, ::plpbus_orb::OrbServer::_PD_repoId) )
484 return (::plpbus_orb::OrbServer_ptr) this;
486 if( omni::strMatch(id, ::CORBA::Object::_PD_repoId) )
487 return (::CORBA::Object_ptr) this;
492 // Proxy call descriptor class. Mangled signature:
493 // void_i_cplpbus__orb_mOrbClient_i_cstring
494 class _0RL_cd_00d6793dc2c2a80c_60000000
495 : public omniCallDescriptor
498 inline _0RL_cd_00d6793dc2c2a80c_60000000(LocalCallFn lcfn,const char* op_,size_t oplen,_CORBA_Boolean upcall=0):
499 omniCallDescriptor(lcfn, op_, oplen, 0, _user_exns, 0, upcall)
504 void marshalArguments(cdrStream&);
505 void unmarshalArguments(cdrStream&);
509 static const char* const _user_exns[];
511 plpbus_orb::OrbClient_var arg_0_;
512 plpbus_orb::OrbClient_ptr arg_0;
513 ::CORBA::String_var arg_1_;
517 void _0RL_cd_00d6793dc2c2a80c_60000000::marshalArguments(cdrStream& _n)
519 plpbus_orb::OrbClient::_marshalObjRef(arg_0,_n);
520 _n.marshalString(arg_1,0);
524 void _0RL_cd_00d6793dc2c2a80c_60000000::unmarshalArguments(cdrStream& _n)
526 arg_0_ = plpbus_orb::OrbClient::_unmarshalObjRef(_n);
528 arg_1_ = _n.unmarshalString(0);
533 const char* const _0RL_cd_00d6793dc2c2a80c_60000000::_user_exns[] = {
537 // Local call call-back function.
539 _0RL_lcfn_00d6793dc2c2a80c_70000000(omniCallDescriptor* cd, omniServant* svnt)
541 _0RL_cd_00d6793dc2c2a80c_60000000* tcd = (_0RL_cd_00d6793dc2c2a80c_60000000*)cd;
542 plpbus_orb::_impl_OrbServer* impl = (plpbus_orb::_impl_OrbServer*) svnt->_ptrToInterface(plpbus_orb::OrbServer::_PD_repoId);
543 impl->send_message_and_request_response(tcd->arg_0, tcd->arg_1);
548 void plpbus_orb::_objref_OrbServer::send_message_and_request_response(::plpbus_orb::OrbClient_ptr response_listener_param, const char* msg_param)
550 _0RL_cd_00d6793dc2c2a80c_60000000 _call_desc(_0RL_lcfn_00d6793dc2c2a80c_70000000, "send_message_and_request_response", 34);
551 _call_desc.arg_0 = response_listener_param;
552 _call_desc.arg_1 = msg_param;
559 // Proxy call descriptor class. Mangled signature:
560 // void_i_cplpbus__orb_mOrbClient_i_cplpbus__orb_mDataItemSequence
561 class _0RL_cd_00d6793dc2c2a80c_80000000
562 : public omniCallDescriptor
565 inline _0RL_cd_00d6793dc2c2a80c_80000000(LocalCallFn lcfn,const char* op_,size_t oplen,_CORBA_Boolean upcall=0):
566 omniCallDescriptor(lcfn, op_, oplen, 0, _user_exns, 0, upcall)
571 void marshalArguments(cdrStream&);
572 void unmarshalArguments(cdrStream&);
576 static const char* const _user_exns[];
578 plpbus_orb::OrbClient_var arg_0_;
579 plpbus_orb::OrbClient_ptr arg_0;
580 plpbus_orb::DataItemSequence_var arg_1_;
581 const plpbus_orb::DataItemSequence* arg_1;
584 void _0RL_cd_00d6793dc2c2a80c_80000000::marshalArguments(cdrStream& _n)
586 plpbus_orb::OrbClient::_marshalObjRef(arg_0,_n);
587 (const plpbus_orb::DataItemSequence&) *arg_1 >>= _n;
591 void _0RL_cd_00d6793dc2c2a80c_80000000::unmarshalArguments(cdrStream& _n)
593 arg_0_ = plpbus_orb::OrbClient::_unmarshalObjRef(_n);
595 arg_1_ = new plpbus_orb::DataItemSequence;
596 (plpbus_orb::DataItemSequence&)arg_1_ <<= _n;
597 arg_1 = &arg_1_.in();
601 const char* const _0RL_cd_00d6793dc2c2a80c_80000000::_user_exns[] = {
605 // Local call call-back function.
607 _0RL_lcfn_00d6793dc2c2a80c_90000000(omniCallDescriptor* cd, omniServant* svnt)
609 _0RL_cd_00d6793dc2c2a80c_80000000* tcd = (_0RL_cd_00d6793dc2c2a80c_80000000*)cd;
610 plpbus_orb::_impl_OrbServer* impl = (plpbus_orb::_impl_OrbServer*) svnt->_ptrToInterface(plpbus_orb::OrbServer::_PD_repoId);
611 impl->send_dataitem_message_and_request_response(tcd->arg_0, *tcd->arg_1);
616 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)
618 _0RL_cd_00d6793dc2c2a80c_80000000 _call_desc(_0RL_lcfn_00d6793dc2c2a80c_90000000, "send_dataitem_message_and_request_response", 43);
619 _call_desc.arg_0 = response_listener_param;
620 _call_desc.arg_1 = &(::plpbus_orb::DataItemSequence&) req_seq_param;
627 // Proxy call descriptor class. Mangled signature:
628 // _cstring_i_cstring_o_clong
629 class _0RL_cd_00d6793dc2c2a80c_a0000000
630 : public omniCallDescriptor
633 inline _0RL_cd_00d6793dc2c2a80c_a0000000(LocalCallFn lcfn,const char* op_,size_t oplen,_CORBA_Boolean upcall=0):
634 omniCallDescriptor(lcfn, op_, oplen, 0, _user_exns, 0, upcall)
639 void marshalArguments(cdrStream&);
640 void unmarshalArguments(cdrStream&);
642 void unmarshalReturnedValues(cdrStream&);
643 void marshalReturnedValues(cdrStream&);
646 static const char* const _user_exns[];
648 ::CORBA::String_var arg_0_;
651 ::CORBA::String_var result;
654 void _0RL_cd_00d6793dc2c2a80c_a0000000::marshalArguments(cdrStream& _n)
656 _n.marshalString(arg_0,0);
660 void _0RL_cd_00d6793dc2c2a80c_a0000000::unmarshalArguments(cdrStream& _n)
662 arg_0_ = _n.unmarshalString(0);
667 void _0RL_cd_00d6793dc2c2a80c_a0000000::marshalReturnedValues(cdrStream& _n)
669 _n.marshalString(result,0);
674 void _0RL_cd_00d6793dc2c2a80c_a0000000::unmarshalReturnedValues(cdrStream& _n)
676 result = _n.unmarshalString(0);
677 (::CORBA::Long&)arg_1 <<= _n;
681 const char* const _0RL_cd_00d6793dc2c2a80c_a0000000::_user_exns[] = {
685 // Local call call-back function.
687 _0RL_lcfn_00d6793dc2c2a80c_b0000000(omniCallDescriptor* cd, omniServant* svnt)
689 _0RL_cd_00d6793dc2c2a80c_a0000000* tcd = (_0RL_cd_00d6793dc2c2a80c_a0000000*)cd;
690 plpbus_orb::_impl_OrbServer* impl = (plpbus_orb::_impl_OrbServer*) svnt->_ptrToInterface(plpbus_orb::OrbServer::_PD_repoId);
691 tcd->result = impl->send_message_and_wait_response(tcd->arg_0, tcd->arg_1);
696 char* plpbus_orb::_objref_OrbServer::send_message_and_wait_response(const char* msg_req_param, ::CORBA::Long& err_flg)
698 _0RL_cd_00d6793dc2c2a80c_a0000000 _call_desc(_0RL_lcfn_00d6793dc2c2a80c_b0000000, "send_message_and_wait_response", 31);
699 _call_desc.arg_0 = msg_req_param;
702 err_flg = _call_desc.arg_1;
703 return _call_desc.result._retn();
707 // Proxy call descriptor class. Mangled signature:
708 // _clong_i_cplpbus__orb_mDataItemSequence_o_cplpbus__orb_mDataItemSequence
709 class _0RL_cd_00d6793dc2c2a80c_c0000000
710 : public omniCallDescriptor
713 inline _0RL_cd_00d6793dc2c2a80c_c0000000(LocalCallFn lcfn,const char* op_,size_t oplen,_CORBA_Boolean upcall=0):
714 omniCallDescriptor(lcfn, op_, oplen, 0, _user_exns, 0, upcall)
719 void marshalArguments(cdrStream&);
720 void unmarshalArguments(cdrStream&);
722 void unmarshalReturnedValues(cdrStream&);
723 void marshalReturnedValues(cdrStream&);
726 static const char* const _user_exns[];
728 plpbus_orb::DataItemSequence_var arg_0_;
729 const plpbus_orb::DataItemSequence* arg_0;
730 plpbus_orb::DataItemSequence_var arg_1;
731 ::CORBA::Long result;
734 void _0RL_cd_00d6793dc2c2a80c_c0000000::marshalArguments(cdrStream& _n)
736 (const plpbus_orb::DataItemSequence&) *arg_0 >>= _n;
740 void _0RL_cd_00d6793dc2c2a80c_c0000000::unmarshalArguments(cdrStream& _n)
742 arg_0_ = new plpbus_orb::DataItemSequence;
743 (plpbus_orb::DataItemSequence&)arg_0_ <<= _n;
744 arg_0 = &arg_0_.in();
748 void _0RL_cd_00d6793dc2c2a80c_c0000000::marshalReturnedValues(cdrStream& _n)
751 (const plpbus_orb::DataItemSequence&) arg_1 >>= _n;
755 void _0RL_cd_00d6793dc2c2a80c_c0000000::unmarshalReturnedValues(cdrStream& _n)
757 (::CORBA::Long&)result <<= _n;
758 arg_1 = new plpbus_orb::DataItemSequence;
759 (plpbus_orb::DataItemSequence&)arg_1 <<= _n;
763 const char* const _0RL_cd_00d6793dc2c2a80c_c0000000::_user_exns[] = {
767 // Local call call-back function.
769 _0RL_lcfn_00d6793dc2c2a80c_d0000000(omniCallDescriptor* cd, omniServant* svnt)
771 _0RL_cd_00d6793dc2c2a80c_c0000000* tcd = (_0RL_cd_00d6793dc2c2a80c_c0000000*)cd;
772 plpbus_orb::_impl_OrbServer* impl = (plpbus_orb::_impl_OrbServer*) svnt->_ptrToInterface(plpbus_orb::OrbServer::_PD_repoId);
773 tcd->result = impl->send_dataitem_message_and_wait_response(*tcd->arg_0, tcd->arg_1.out());
778 ::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)
780 _0RL_cd_00d6793dc2c2a80c_c0000000 _call_desc(_0RL_lcfn_00d6793dc2c2a80c_d0000000, "send_dataitem_message_and_wait_response", 40);
781 _call_desc.arg_0 = &(::plpbus_orb::DataItemSequence&) req_seq_param;
784 rsp_seq_param = _call_desc.arg_1._retn();
785 return _call_desc.result;
789 // Proxy call descriptor class. Mangled signature:
790 // void_i_cplpbus__orb_mOrbClient_i_cstring_i_cunsigned_pshort
791 class _0RL_cd_00d6793dc2c2a80c_e0000000
792 : public omniCallDescriptor
795 inline _0RL_cd_00d6793dc2c2a80c_e0000000(LocalCallFn lcfn,const char* op_,size_t oplen,_CORBA_Boolean upcall=0):
796 omniCallDescriptor(lcfn, op_, oplen, 0, _user_exns, 0, upcall)
801 void marshalArguments(cdrStream&);
802 void unmarshalArguments(cdrStream&);
806 static const char* const _user_exns[];
808 plpbus_orb::OrbClient_var arg_0_;
809 plpbus_orb::OrbClient_ptr arg_0;
810 ::CORBA::String_var arg_1_;
812 ::CORBA::UShort arg_2;
815 void _0RL_cd_00d6793dc2c2a80c_e0000000::marshalArguments(cdrStream& _n)
817 plpbus_orb::OrbClient::_marshalObjRef(arg_0,_n);
818 _n.marshalString(arg_1,0);
823 void _0RL_cd_00d6793dc2c2a80c_e0000000::unmarshalArguments(cdrStream& _n)
825 arg_0_ = plpbus_orb::OrbClient::_unmarshalObjRef(_n);
827 arg_1_ = _n.unmarshalString(0);
829 (::CORBA::UShort&)arg_2 <<= _n;
833 const char* const _0RL_cd_00d6793dc2c2a80c_e0000000::_user_exns[] = {
837 // Local call call-back function.
839 _0RL_lcfn_00d6793dc2c2a80c_f0000000(omniCallDescriptor* cd, omniServant* svnt)
841 _0RL_cd_00d6793dc2c2a80c_e0000000* tcd = (_0RL_cd_00d6793dc2c2a80c_e0000000*)cd;
842 plpbus_orb::_impl_OrbServer* impl = (plpbus_orb::_impl_OrbServer*) svnt->_ptrToInterface(plpbus_orb::OrbServer::_PD_repoId);
843 impl->add_event_listener(tcd->arg_0, tcd->arg_1, tcd->arg_2);
848 void plpbus_orb::_objref_OrbServer::add_event_listener(::plpbus_orb::OrbClient_ptr callback_client_param, const char* msg_param, ::CORBA::UShort period_secs)
850 _0RL_cd_00d6793dc2c2a80c_e0000000 _call_desc(_0RL_lcfn_00d6793dc2c2a80c_f0000000, "add_event_listener", 19);
851 _call_desc.arg_0 = callback_client_param;
852 _call_desc.arg_1 = msg_param;
853 _call_desc.arg_2 = period_secs;
860 // Proxy call descriptor class. Mangled signature:
862 class _0RL_cd_00d6793dc2c2a80c_01000000
863 : public omniCallDescriptor
866 inline _0RL_cd_00d6793dc2c2a80c_01000000(LocalCallFn lcfn,const char* op_,size_t oplen,_CORBA_Boolean upcall=0):
867 omniCallDescriptor(lcfn, op_, oplen, 0, _user_exns, 0, upcall)
875 static const char* const _user_exns[];
880 const char* const _0RL_cd_00d6793dc2c2a80c_01000000::_user_exns[] = {
884 // Local call call-back function.
886 _0RL_lcfn_00d6793dc2c2a80c_11000000(omniCallDescriptor*, omniServant* svnt)
889 plpbus_orb::_impl_OrbServer* impl = (plpbus_orb::_impl_OrbServer*) svnt->_ptrToInterface(plpbus_orb::OrbServer::_PD_repoId);
895 void plpbus_orb::_objref_OrbServer::shutdown()
897 _0RL_cd_00d6793dc2c2a80c_01000000 _call_desc(_0RL_lcfn_00d6793dc2c2a80c_11000000, "shutdown", 9);
905 plpbus_orb::_pof_OrbServer::~_pof_OrbServer() {}
909 plpbus_orb::_pof_OrbServer::newObjRef(omniIOR* ior, omniIdentity* id)
911 return new ::plpbus_orb::_objref_OrbServer(ior, id);
916 plpbus_orb::_pof_OrbServer::is_a(const char* id) const
918 if( omni::ptrStrMatch(id, ::plpbus_orb::OrbServer::_PD_repoId) )
924 const plpbus_orb::_pof_OrbServer _the_pof_plpbus__orb_mOrbServer;
926 plpbus_orb::_impl_OrbServer::~_impl_OrbServer() {}
930 plpbus_orb::_impl_OrbServer::_dispatch(omniCallHandle& _handle)
932 const char* op = _handle.operation_name();
934 if( omni::strMatch(op, "send_message_and_request_response") ) {
936 _0RL_cd_00d6793dc2c2a80c_60000000 _call_desc(_0RL_lcfn_00d6793dc2c2a80c_70000000, "send_message_and_request_response", 34, 1);
938 _handle.upcall(this,_call_desc);
942 if( omni::strMatch(op, "send_dataitem_message_and_request_response") ) {
944 _0RL_cd_00d6793dc2c2a80c_80000000 _call_desc(_0RL_lcfn_00d6793dc2c2a80c_90000000, "send_dataitem_message_and_request_response", 43, 1);
946 _handle.upcall(this,_call_desc);
950 if( omni::strMatch(op, "send_message_and_wait_response") ) {
952 _0RL_cd_00d6793dc2c2a80c_a0000000 _call_desc(_0RL_lcfn_00d6793dc2c2a80c_b0000000, "send_message_and_wait_response", 31, 1);
954 _handle.upcall(this,_call_desc);
958 if( omni::strMatch(op, "send_dataitem_message_and_wait_response") ) {
960 _0RL_cd_00d6793dc2c2a80c_c0000000 _call_desc(_0RL_lcfn_00d6793dc2c2a80c_d0000000, "send_dataitem_message_and_wait_response", 40, 1);
962 _handle.upcall(this,_call_desc);
966 if( omni::strMatch(op, "add_event_listener") ) {
968 _0RL_cd_00d6793dc2c2a80c_e0000000 _call_desc(_0RL_lcfn_00d6793dc2c2a80c_f0000000, "add_event_listener", 19, 1);
970 _handle.upcall(this,_call_desc);
974 if( omni::strMatch(op, "shutdown") ) {
976 _0RL_cd_00d6793dc2c2a80c_01000000 _call_desc(_0RL_lcfn_00d6793dc2c2a80c_11000000, "shutdown", 9, 1);
978 _handle.upcall(this,_call_desc);
987 plpbus_orb::_impl_OrbServer::_ptrToInterface(const char* id)
989 if( id == ::plpbus_orb::OrbServer::_PD_repoId )
990 return (::plpbus_orb::_impl_OrbServer*) this;
992 if( id == ::CORBA::Object::_PD_repoId )
995 if( omni::strMatch(id, ::plpbus_orb::OrbServer::_PD_repoId) )
996 return (::plpbus_orb::_impl_OrbServer*) this;
998 if( omni::strMatch(id, ::CORBA::Object::_PD_repoId) )
1004 plpbus_orb::_impl_OrbServer::_mostDerivedRepoId()
1006 return ::plpbus_orb::OrbServer::_PD_repoId;
1009 POA_plpbus_orb::OrbClient::~OrbClient() {}
1011 POA_plpbus_orb::OrbServer::~OrbServer() {}