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;
22 _n.marshalString(str_value,0);
27 plpbus_orb::DataItem::operator<<= (cdrStream &_n)
29 name = _n.unmarshalString(0);
30 (::CORBA::Any&)value <<= _n;
31 str_value = _n.unmarshalString(0);
35 plpbus_orb::OrbClient_ptr plpbus_orb::OrbClient_Helper::_nil() {
36 return ::plpbus_orb::OrbClient::_nil();
39 ::CORBA::Boolean plpbus_orb::OrbClient_Helper::is_nil(::plpbus_orb::OrbClient_ptr p) {
40 return ::CORBA::is_nil(p);
44 void plpbus_orb::OrbClient_Helper::release(::plpbus_orb::OrbClient_ptr p) {
48 void plpbus_orb::OrbClient_Helper::marshalObjRef(::plpbus_orb::OrbClient_ptr obj, cdrStream& s) {
49 ::plpbus_orb::OrbClient::_marshalObjRef(obj, s);
52 plpbus_orb::OrbClient_ptr plpbus_orb::OrbClient_Helper::unmarshalObjRef(cdrStream& s) {
53 return ::plpbus_orb::OrbClient::_unmarshalObjRef(s);
56 void plpbus_orb::OrbClient_Helper::duplicate(::plpbus_orb::OrbClient_ptr obj) {
57 if( obj && !obj->_NP_is_nil() ) omni::duplicateObjRef(obj);
60 plpbus_orb::OrbClient_ptr
61 plpbus_orb::OrbClient::_duplicate(::plpbus_orb::OrbClient_ptr obj)
63 if( obj && !obj->_NP_is_nil() ) omni::duplicateObjRef(obj);
67 plpbus_orb::OrbClient_ptr
68 plpbus_orb::OrbClient::_narrow(::CORBA::Object_ptr obj)
70 if( !obj || obj->_NP_is_nil() || obj->_NP_is_pseudo() ) return _nil();
71 _ptr_type e = (_ptr_type) obj->_PR_getobj()->_realNarrow(_PD_repoId);
72 return e ? e : _nil();
76 plpbus_orb::OrbClient_ptr
77 plpbus_orb::OrbClient::_unchecked_narrow(::CORBA::Object_ptr obj)
79 if( !obj || obj->_NP_is_nil() || obj->_NP_is_pseudo() ) return _nil();
80 _ptr_type e = (_ptr_type) obj->_PR_getobj()->_uncheckedNarrow(_PD_repoId);
81 return e ? e : _nil();
84 plpbus_orb::OrbClient_ptr
85 plpbus_orb::OrbClient::_nil()
87 #ifdef OMNI_UNLOADABLE_STUBS
88 static _objref_OrbClient _the_nil_obj;
91 static _objref_OrbClient* _the_nil_ptr = 0;
93 omni::nilRefLock().lock();
95 _the_nil_ptr = new _objref_OrbClient;
96 registerNilCorbaObject(_the_nil_ptr);
98 omni::nilRefLock().unlock();
104 const char* plpbus_orb::OrbClient::_PD_repoId = "IDL:plpbus_orb/OrbClient:1.0";
107 plpbus_orb::_objref_OrbClient::~_objref_OrbClient() {
112 plpbus_orb::_objref_OrbClient::_objref_OrbClient(omniIOR* ior, omniIdentity* id) :
113 omniObjRef(::plpbus_orb::OrbClient::_PD_repoId, ior, id, 1)
121 plpbus_orb::_objref_OrbClient::_ptrToObjRef(const char* id)
123 if( id == ::plpbus_orb::OrbClient::_PD_repoId )
124 return (::plpbus_orb::OrbClient_ptr) this;
126 if( id == ::CORBA::Object::_PD_repoId )
127 return (::CORBA::Object_ptr) this;
129 if( omni::strMatch(id, ::plpbus_orb::OrbClient::_PD_repoId) )
130 return (::plpbus_orb::OrbClient_ptr) this;
132 if( omni::strMatch(id, ::CORBA::Object::_PD_repoId) )
133 return (::CORBA::Object_ptr) this;
138 // Proxy call descriptor class. Mangled signature:
140 class _0RL_cd_00d6793dc2c2a80c_00000000
141 : public omniCallDescriptor
144 inline _0RL_cd_00d6793dc2c2a80c_00000000(LocalCallFn lcfn,const char* op_,size_t oplen,_CORBA_Boolean upcall=0):
145 omniCallDescriptor(lcfn, op_, oplen, 0, _user_exns, 0, upcall)
150 void marshalArguments(cdrStream&);
151 void unmarshalArguments(cdrStream&);
155 static const char* const _user_exns[];
157 ::CORBA::String_var arg_0_;
161 void _0RL_cd_00d6793dc2c2a80c_00000000::marshalArguments(cdrStream& _n)
163 _n.marshalString(arg_0,0);
167 void _0RL_cd_00d6793dc2c2a80c_00000000::unmarshalArguments(cdrStream& _n)
169 arg_0_ = _n.unmarshalString(0);
174 const char* const _0RL_cd_00d6793dc2c2a80c_00000000::_user_exns[] = {
178 // Local call call-back function.
180 _0RL_lcfn_00d6793dc2c2a80c_10000000(omniCallDescriptor* cd, omniServant* svnt)
182 _0RL_cd_00d6793dc2c2a80c_00000000* tcd = (_0RL_cd_00d6793dc2c2a80c_00000000*)cd;
183 plpbus_orb::_impl_OrbClient* impl = (plpbus_orb::_impl_OrbClient*) svnt->_ptrToInterface(plpbus_orb::OrbClient::_PD_repoId);
184 impl->receive_event_message(tcd->arg_0);
189 void plpbus_orb::_objref_OrbClient::receive_event_message(const char* event_param)
191 _0RL_cd_00d6793dc2c2a80c_00000000 _call_desc(_0RL_lcfn_00d6793dc2c2a80c_10000000, "receive_event_message", 22);
192 _call_desc.arg_0 = event_param;
199 // Proxy call descriptor class. Mangled signature:
200 // void_i_cplpbus__orb_mDataItemSequence
201 class _0RL_cd_00d6793dc2c2a80c_20000000
202 : public omniCallDescriptor
205 inline _0RL_cd_00d6793dc2c2a80c_20000000(LocalCallFn lcfn,const char* op_,size_t oplen,_CORBA_Boolean upcall=0):
206 omniCallDescriptor(lcfn, op_, oplen, 0, _user_exns, 0, upcall)
211 void marshalArguments(cdrStream&);
212 void unmarshalArguments(cdrStream&);
216 static const char* const _user_exns[];
218 plpbus_orb::DataItemSequence_var arg_0_;
219 const plpbus_orb::DataItemSequence* arg_0;
222 void _0RL_cd_00d6793dc2c2a80c_20000000::marshalArguments(cdrStream& _n)
224 (const plpbus_orb::DataItemSequence&) *arg_0 >>= _n;
228 void _0RL_cd_00d6793dc2c2a80c_20000000::unmarshalArguments(cdrStream& _n)
230 arg_0_ = new plpbus_orb::DataItemSequence;
231 (plpbus_orb::DataItemSequence&)arg_0_ <<= _n;
232 arg_0 = &arg_0_.in();
236 const char* const _0RL_cd_00d6793dc2c2a80c_20000000::_user_exns[] = {
240 // Local call call-back function.
242 _0RL_lcfn_00d6793dc2c2a80c_30000000(omniCallDescriptor* cd, omniServant* svnt)
244 _0RL_cd_00d6793dc2c2a80c_20000000* tcd = (_0RL_cd_00d6793dc2c2a80c_20000000*)cd;
245 plpbus_orb::_impl_OrbClient* impl = (plpbus_orb::_impl_OrbClient*) svnt->_ptrToInterface(plpbus_orb::OrbClient::_PD_repoId);
246 impl->receive_event_dataitem_sequence(*tcd->arg_0);
251 void plpbus_orb::_objref_OrbClient::receive_event_dataitem_sequence(const ::plpbus_orb::DataItemSequence& event_param)
253 _0RL_cd_00d6793dc2c2a80c_20000000 _call_desc(_0RL_lcfn_00d6793dc2c2a80c_30000000, "receive_event_dataitem_sequence", 32);
254 _call_desc.arg_0 = &(::plpbus_orb::DataItemSequence&) event_param;
261 // Local call call-back function.
263 _0RL_lcfn_00d6793dc2c2a80c_40000000(omniCallDescriptor* cd, omniServant* svnt)
265 _0RL_cd_00d6793dc2c2a80c_00000000* tcd = (_0RL_cd_00d6793dc2c2a80c_00000000*)cd;
266 plpbus_orb::_impl_OrbClient* impl = (plpbus_orb::_impl_OrbClient*) svnt->_ptrToInterface(plpbus_orb::OrbClient::_PD_repoId);
267 impl->receive_response_message(tcd->arg_0);
272 void plpbus_orb::_objref_OrbClient::receive_response_message(const char* msg_rsp_param)
274 _0RL_cd_00d6793dc2c2a80c_00000000 _call_desc(_0RL_lcfn_00d6793dc2c2a80c_40000000, "receive_response_message", 25);
275 _call_desc.arg_0 = msg_rsp_param;
282 // Local call call-back function.
284 _0RL_lcfn_00d6793dc2c2a80c_50000000(omniCallDescriptor* cd, omniServant* svnt)
286 _0RL_cd_00d6793dc2c2a80c_20000000* tcd = (_0RL_cd_00d6793dc2c2a80c_20000000*)cd;
287 plpbus_orb::_impl_OrbClient* impl = (plpbus_orb::_impl_OrbClient*) svnt->_ptrToInterface(plpbus_orb::OrbClient::_PD_repoId);
288 impl->receive_response_dataitem_sequence(*tcd->arg_0);
293 void plpbus_orb::_objref_OrbClient::receive_response_dataitem_sequence(const ::plpbus_orb::DataItemSequence& msg_rsp_param)
295 _0RL_cd_00d6793dc2c2a80c_20000000 _call_desc(_0RL_lcfn_00d6793dc2c2a80c_50000000, "receive_response_dataitem_sequence", 35);
296 _call_desc.arg_0 = &(::plpbus_orb::DataItemSequence&) msg_rsp_param;
303 plpbus_orb::_pof_OrbClient::~_pof_OrbClient() {}
307 plpbus_orb::_pof_OrbClient::newObjRef(omniIOR* ior, omniIdentity* id)
309 return new ::plpbus_orb::_objref_OrbClient(ior, id);
314 plpbus_orb::_pof_OrbClient::is_a(const char* id) const
316 if( omni::ptrStrMatch(id, ::plpbus_orb::OrbClient::_PD_repoId) )
322 const plpbus_orb::_pof_OrbClient _the_pof_plpbus__orb_mOrbClient;
324 plpbus_orb::_impl_OrbClient::~_impl_OrbClient() {}
328 plpbus_orb::_impl_OrbClient::_dispatch(omniCallHandle& _handle)
330 const char* op = _handle.operation_name();
332 if( omni::strMatch(op, "receive_event_message") ) {
334 _0RL_cd_00d6793dc2c2a80c_00000000 _call_desc(_0RL_lcfn_00d6793dc2c2a80c_10000000, "receive_event_message", 22, 1);
336 _handle.upcall(this,_call_desc);
340 if( omni::strMatch(op, "receive_event_dataitem_sequence") ) {
342 _0RL_cd_00d6793dc2c2a80c_20000000 _call_desc(_0RL_lcfn_00d6793dc2c2a80c_30000000, "receive_event_dataitem_sequence", 32, 1);
344 _handle.upcall(this,_call_desc);
348 if( omni::strMatch(op, "receive_response_message") ) {
350 _0RL_cd_00d6793dc2c2a80c_00000000 _call_desc(_0RL_lcfn_00d6793dc2c2a80c_40000000, "receive_response_message", 25, 1);
352 _handle.upcall(this,_call_desc);
356 if( omni::strMatch(op, "receive_response_dataitem_sequence") ) {
358 _0RL_cd_00d6793dc2c2a80c_20000000 _call_desc(_0RL_lcfn_00d6793dc2c2a80c_50000000, "receive_response_dataitem_sequence", 35, 1);
360 _handle.upcall(this,_call_desc);
369 plpbus_orb::_impl_OrbClient::_ptrToInterface(const char* id)
371 if( id == ::plpbus_orb::OrbClient::_PD_repoId )
372 return (::plpbus_orb::_impl_OrbClient*) this;
374 if( id == ::CORBA::Object::_PD_repoId )
377 if( omni::strMatch(id, ::plpbus_orb::OrbClient::_PD_repoId) )
378 return (::plpbus_orb::_impl_OrbClient*) this;
380 if( omni::strMatch(id, ::CORBA::Object::_PD_repoId) )
386 plpbus_orb::_impl_OrbClient::_mostDerivedRepoId()
388 return ::plpbus_orb::OrbClient::_PD_repoId;
391 plpbus_orb::OrbServer_ptr plpbus_orb::OrbServer_Helper::_nil() {
392 return ::plpbus_orb::OrbServer::_nil();
395 ::CORBA::Boolean plpbus_orb::OrbServer_Helper::is_nil(::plpbus_orb::OrbServer_ptr p) {
396 return ::CORBA::is_nil(p);
400 void plpbus_orb::OrbServer_Helper::release(::plpbus_orb::OrbServer_ptr p) {
404 void plpbus_orb::OrbServer_Helper::marshalObjRef(::plpbus_orb::OrbServer_ptr obj, cdrStream& s) {
405 ::plpbus_orb::OrbServer::_marshalObjRef(obj, s);
408 plpbus_orb::OrbServer_ptr plpbus_orb::OrbServer_Helper::unmarshalObjRef(cdrStream& s) {
409 return ::plpbus_orb::OrbServer::_unmarshalObjRef(s);
412 void plpbus_orb::OrbServer_Helper::duplicate(::plpbus_orb::OrbServer_ptr obj) {
413 if( obj && !obj->_NP_is_nil() ) omni::duplicateObjRef(obj);
416 plpbus_orb::OrbServer_ptr
417 plpbus_orb::OrbServer::_duplicate(::plpbus_orb::OrbServer_ptr obj)
419 if( obj && !obj->_NP_is_nil() ) omni::duplicateObjRef(obj);
423 plpbus_orb::OrbServer_ptr
424 plpbus_orb::OrbServer::_narrow(::CORBA::Object_ptr obj)
426 if( !obj || obj->_NP_is_nil() || obj->_NP_is_pseudo() ) return _nil();
427 _ptr_type e = (_ptr_type) obj->_PR_getobj()->_realNarrow(_PD_repoId);
428 return e ? e : _nil();
432 plpbus_orb::OrbServer_ptr
433 plpbus_orb::OrbServer::_unchecked_narrow(::CORBA::Object_ptr obj)
435 if( !obj || obj->_NP_is_nil() || obj->_NP_is_pseudo() ) return _nil();
436 _ptr_type e = (_ptr_type) obj->_PR_getobj()->_uncheckedNarrow(_PD_repoId);
437 return e ? e : _nil();
440 plpbus_orb::OrbServer_ptr
441 plpbus_orb::OrbServer::_nil()
443 #ifdef OMNI_UNLOADABLE_STUBS
444 static _objref_OrbServer _the_nil_obj;
445 return &_the_nil_obj;
447 static _objref_OrbServer* _the_nil_ptr = 0;
448 if( !_the_nil_ptr ) {
449 omni::nilRefLock().lock();
450 if( !_the_nil_ptr ) {
451 _the_nil_ptr = new _objref_OrbServer;
452 registerNilCorbaObject(_the_nil_ptr);
454 omni::nilRefLock().unlock();
460 const char* plpbus_orb::OrbServer::_PD_repoId = "IDL:plpbus_orb/OrbServer:1.0";
463 plpbus_orb::_objref_OrbServer::~_objref_OrbServer() {
468 plpbus_orb::_objref_OrbServer::_objref_OrbServer(omniIOR* ior, omniIdentity* id) :
469 omniObjRef(::plpbus_orb::OrbServer::_PD_repoId, ior, id, 1)
477 plpbus_orb::_objref_OrbServer::_ptrToObjRef(const char* id)
479 if( id == ::plpbus_orb::OrbServer::_PD_repoId )
480 return (::plpbus_orb::OrbServer_ptr) this;
482 if( id == ::CORBA::Object::_PD_repoId )
483 return (::CORBA::Object_ptr) this;
485 if( omni::strMatch(id, ::plpbus_orb::OrbServer::_PD_repoId) )
486 return (::plpbus_orb::OrbServer_ptr) this;
488 if( omni::strMatch(id, ::CORBA::Object::_PD_repoId) )
489 return (::CORBA::Object_ptr) this;
494 // Proxy call descriptor class. Mangled signature:
495 // void_i_cplpbus__orb_mOrbClient_i_cstring
496 class _0RL_cd_00d6793dc2c2a80c_60000000
497 : public omniCallDescriptor
500 inline _0RL_cd_00d6793dc2c2a80c_60000000(LocalCallFn lcfn,const char* op_,size_t oplen,_CORBA_Boolean upcall=0):
501 omniCallDescriptor(lcfn, op_, oplen, 0, _user_exns, 0, upcall)
506 void marshalArguments(cdrStream&);
507 void unmarshalArguments(cdrStream&);
511 static const char* const _user_exns[];
513 plpbus_orb::OrbClient_var arg_0_;
514 plpbus_orb::OrbClient_ptr arg_0;
515 ::CORBA::String_var arg_1_;
519 void _0RL_cd_00d6793dc2c2a80c_60000000::marshalArguments(cdrStream& _n)
521 plpbus_orb::OrbClient::_marshalObjRef(arg_0,_n);
522 _n.marshalString(arg_1,0);
526 void _0RL_cd_00d6793dc2c2a80c_60000000::unmarshalArguments(cdrStream& _n)
528 arg_0_ = plpbus_orb::OrbClient::_unmarshalObjRef(_n);
530 arg_1_ = _n.unmarshalString(0);
535 const char* const _0RL_cd_00d6793dc2c2a80c_60000000::_user_exns[] = {
539 // Local call call-back function.
541 _0RL_lcfn_00d6793dc2c2a80c_70000000(omniCallDescriptor* cd, omniServant* svnt)
543 _0RL_cd_00d6793dc2c2a80c_60000000* tcd = (_0RL_cd_00d6793dc2c2a80c_60000000*)cd;
544 plpbus_orb::_impl_OrbServer* impl = (plpbus_orb::_impl_OrbServer*) svnt->_ptrToInterface(plpbus_orb::OrbServer::_PD_repoId);
545 impl->send_message_and_request_response(tcd->arg_0, tcd->arg_1);
550 void plpbus_orb::_objref_OrbServer::send_message_and_request_response(::plpbus_orb::OrbClient_ptr response_listener_param, const char* msg_param)
552 _0RL_cd_00d6793dc2c2a80c_60000000 _call_desc(_0RL_lcfn_00d6793dc2c2a80c_70000000, "send_message_and_request_response", 34);
553 _call_desc.arg_0 = response_listener_param;
554 _call_desc.arg_1 = msg_param;
561 // Proxy call descriptor class. Mangled signature:
562 // void_i_cplpbus__orb_mOrbClient_i_cplpbus__orb_mDataItemSequence
563 class _0RL_cd_00d6793dc2c2a80c_80000000
564 : public omniCallDescriptor
567 inline _0RL_cd_00d6793dc2c2a80c_80000000(LocalCallFn lcfn,const char* op_,size_t oplen,_CORBA_Boolean upcall=0):
568 omniCallDescriptor(lcfn, op_, oplen, 0, _user_exns, 0, upcall)
573 void marshalArguments(cdrStream&);
574 void unmarshalArguments(cdrStream&);
578 static const char* const _user_exns[];
580 plpbus_orb::OrbClient_var arg_0_;
581 plpbus_orb::OrbClient_ptr arg_0;
582 plpbus_orb::DataItemSequence_var arg_1_;
583 const plpbus_orb::DataItemSequence* arg_1;
586 void _0RL_cd_00d6793dc2c2a80c_80000000::marshalArguments(cdrStream& _n)
588 plpbus_orb::OrbClient::_marshalObjRef(arg_0,_n);
589 (const plpbus_orb::DataItemSequence&) *arg_1 >>= _n;
593 void _0RL_cd_00d6793dc2c2a80c_80000000::unmarshalArguments(cdrStream& _n)
595 arg_0_ = plpbus_orb::OrbClient::_unmarshalObjRef(_n);
597 arg_1_ = new plpbus_orb::DataItemSequence;
598 (plpbus_orb::DataItemSequence&)arg_1_ <<= _n;
599 arg_1 = &arg_1_.in();
603 const char* const _0RL_cd_00d6793dc2c2a80c_80000000::_user_exns[] = {
607 // Local call call-back function.
609 _0RL_lcfn_00d6793dc2c2a80c_90000000(omniCallDescriptor* cd, omniServant* svnt)
611 _0RL_cd_00d6793dc2c2a80c_80000000* tcd = (_0RL_cd_00d6793dc2c2a80c_80000000*)cd;
612 plpbus_orb::_impl_OrbServer* impl = (plpbus_orb::_impl_OrbServer*) svnt->_ptrToInterface(plpbus_orb::OrbServer::_PD_repoId);
613 impl->send_dataitem_message_and_request_response(tcd->arg_0, *tcd->arg_1);
618 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)
620 _0RL_cd_00d6793dc2c2a80c_80000000 _call_desc(_0RL_lcfn_00d6793dc2c2a80c_90000000, "send_dataitem_message_and_request_response", 43);
621 _call_desc.arg_0 = response_listener_param;
622 _call_desc.arg_1 = &(::plpbus_orb::DataItemSequence&) req_seq_param;
629 // Proxy call descriptor class. Mangled signature:
630 // _cstring_i_cstring_o_clong
631 class _0RL_cd_00d6793dc2c2a80c_a0000000
632 : public omniCallDescriptor
635 inline _0RL_cd_00d6793dc2c2a80c_a0000000(LocalCallFn lcfn,const char* op_,size_t oplen,_CORBA_Boolean upcall=0):
636 omniCallDescriptor(lcfn, op_, oplen, 0, _user_exns, 0, upcall)
641 void marshalArguments(cdrStream&);
642 void unmarshalArguments(cdrStream&);
644 void unmarshalReturnedValues(cdrStream&);
645 void marshalReturnedValues(cdrStream&);
648 static const char* const _user_exns[];
650 ::CORBA::String_var arg_0_;
653 ::CORBA::String_var result;
656 void _0RL_cd_00d6793dc2c2a80c_a0000000::marshalArguments(cdrStream& _n)
658 _n.marshalString(arg_0,0);
662 void _0RL_cd_00d6793dc2c2a80c_a0000000::unmarshalArguments(cdrStream& _n)
664 arg_0_ = _n.unmarshalString(0);
669 void _0RL_cd_00d6793dc2c2a80c_a0000000::marshalReturnedValues(cdrStream& _n)
671 _n.marshalString(result,0);
676 void _0RL_cd_00d6793dc2c2a80c_a0000000::unmarshalReturnedValues(cdrStream& _n)
678 result = _n.unmarshalString(0);
679 (::CORBA::Long&)arg_1 <<= _n;
683 const char* const _0RL_cd_00d6793dc2c2a80c_a0000000::_user_exns[] = {
687 // Local call call-back function.
689 _0RL_lcfn_00d6793dc2c2a80c_b0000000(omniCallDescriptor* cd, omniServant* svnt)
691 _0RL_cd_00d6793dc2c2a80c_a0000000* tcd = (_0RL_cd_00d6793dc2c2a80c_a0000000*)cd;
692 plpbus_orb::_impl_OrbServer* impl = (plpbus_orb::_impl_OrbServer*) svnt->_ptrToInterface(plpbus_orb::OrbServer::_PD_repoId);
693 tcd->result = impl->send_message_and_wait_response(tcd->arg_0, tcd->arg_1);
698 char* plpbus_orb::_objref_OrbServer::send_message_and_wait_response(const char* msg_req_param, ::CORBA::Long& err_flg)
700 _0RL_cd_00d6793dc2c2a80c_a0000000 _call_desc(_0RL_lcfn_00d6793dc2c2a80c_b0000000, "send_message_and_wait_response", 31);
701 _call_desc.arg_0 = msg_req_param;
704 err_flg = _call_desc.arg_1;
705 return _call_desc.result._retn();
709 // Proxy call descriptor class. Mangled signature:
710 // _clong_i_cplpbus__orb_mDataItemSequence_o_cplpbus__orb_mDataItemSequence
711 class _0RL_cd_00d6793dc2c2a80c_c0000000
712 : public omniCallDescriptor
715 inline _0RL_cd_00d6793dc2c2a80c_c0000000(LocalCallFn lcfn,const char* op_,size_t oplen,_CORBA_Boolean upcall=0):
716 omniCallDescriptor(lcfn, op_, oplen, 0, _user_exns, 0, upcall)
721 void marshalArguments(cdrStream&);
722 void unmarshalArguments(cdrStream&);
724 void unmarshalReturnedValues(cdrStream&);
725 void marshalReturnedValues(cdrStream&);
728 static const char* const _user_exns[];
730 plpbus_orb::DataItemSequence_var arg_0_;
731 const plpbus_orb::DataItemSequence* arg_0;
732 plpbus_orb::DataItemSequence_var arg_1;
733 ::CORBA::Long result;
736 void _0RL_cd_00d6793dc2c2a80c_c0000000::marshalArguments(cdrStream& _n)
738 (const plpbus_orb::DataItemSequence&) *arg_0 >>= _n;
742 void _0RL_cd_00d6793dc2c2a80c_c0000000::unmarshalArguments(cdrStream& _n)
744 arg_0_ = new plpbus_orb::DataItemSequence;
745 (plpbus_orb::DataItemSequence&)arg_0_ <<= _n;
746 arg_0 = &arg_0_.in();
750 void _0RL_cd_00d6793dc2c2a80c_c0000000::marshalReturnedValues(cdrStream& _n)
753 (const plpbus_orb::DataItemSequence&) arg_1 >>= _n;
757 void _0RL_cd_00d6793dc2c2a80c_c0000000::unmarshalReturnedValues(cdrStream& _n)
759 (::CORBA::Long&)result <<= _n;
760 arg_1 = new plpbus_orb::DataItemSequence;
761 (plpbus_orb::DataItemSequence&)arg_1 <<= _n;
765 const char* const _0RL_cd_00d6793dc2c2a80c_c0000000::_user_exns[] = {
769 // Local call call-back function.
771 _0RL_lcfn_00d6793dc2c2a80c_d0000000(omniCallDescriptor* cd, omniServant* svnt)
773 _0RL_cd_00d6793dc2c2a80c_c0000000* tcd = (_0RL_cd_00d6793dc2c2a80c_c0000000*)cd;
774 plpbus_orb::_impl_OrbServer* impl = (plpbus_orb::_impl_OrbServer*) svnt->_ptrToInterface(plpbus_orb::OrbServer::_PD_repoId);
775 tcd->result = impl->send_dataitem_message_and_wait_response(*tcd->arg_0, tcd->arg_1.out());
780 ::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)
782 _0RL_cd_00d6793dc2c2a80c_c0000000 _call_desc(_0RL_lcfn_00d6793dc2c2a80c_d0000000, "send_dataitem_message_and_wait_response", 40);
783 _call_desc.arg_0 = &(::plpbus_orb::DataItemSequence&) req_seq_param;
786 rsp_seq_param = _call_desc.arg_1._retn();
787 return _call_desc.result;
791 // Proxy call descriptor class. Mangled signature:
792 // void_i_cplpbus__orb_mOrbClient_i_cstring_i_cunsigned_pshort
793 class _0RL_cd_00d6793dc2c2a80c_e0000000
794 : public omniCallDescriptor
797 inline _0RL_cd_00d6793dc2c2a80c_e0000000(LocalCallFn lcfn,const char* op_,size_t oplen,_CORBA_Boolean upcall=0):
798 omniCallDescriptor(lcfn, op_, oplen, 0, _user_exns, 0, upcall)
803 void marshalArguments(cdrStream&);
804 void unmarshalArguments(cdrStream&);
808 static const char* const _user_exns[];
810 plpbus_orb::OrbClient_var arg_0_;
811 plpbus_orb::OrbClient_ptr arg_0;
812 ::CORBA::String_var arg_1_;
814 ::CORBA::UShort arg_2;
817 void _0RL_cd_00d6793dc2c2a80c_e0000000::marshalArguments(cdrStream& _n)
819 plpbus_orb::OrbClient::_marshalObjRef(arg_0,_n);
820 _n.marshalString(arg_1,0);
825 void _0RL_cd_00d6793dc2c2a80c_e0000000::unmarshalArguments(cdrStream& _n)
827 arg_0_ = plpbus_orb::OrbClient::_unmarshalObjRef(_n);
829 arg_1_ = _n.unmarshalString(0);
831 (::CORBA::UShort&)arg_2 <<= _n;
835 const char* const _0RL_cd_00d6793dc2c2a80c_e0000000::_user_exns[] = {
839 // Local call call-back function.
841 _0RL_lcfn_00d6793dc2c2a80c_f0000000(omniCallDescriptor* cd, omniServant* svnt)
843 _0RL_cd_00d6793dc2c2a80c_e0000000* tcd = (_0RL_cd_00d6793dc2c2a80c_e0000000*)cd;
844 plpbus_orb::_impl_OrbServer* impl = (plpbus_orb::_impl_OrbServer*) svnt->_ptrToInterface(plpbus_orb::OrbServer::_PD_repoId);
845 impl->add_event_listener(tcd->arg_0, tcd->arg_1, tcd->arg_2);
850 void plpbus_orb::_objref_OrbServer::add_event_listener(::plpbus_orb::OrbClient_ptr callback_client_param, const char* msg_param, ::CORBA::UShort period_secs)
852 _0RL_cd_00d6793dc2c2a80c_e0000000 _call_desc(_0RL_lcfn_00d6793dc2c2a80c_f0000000, "add_event_listener", 19);
853 _call_desc.arg_0 = callback_client_param;
854 _call_desc.arg_1 = msg_param;
855 _call_desc.arg_2 = period_secs;
862 // Proxy call descriptor class. Mangled signature:
864 class _0RL_cd_00d6793dc2c2a80c_01000000
865 : public omniCallDescriptor
868 inline _0RL_cd_00d6793dc2c2a80c_01000000(LocalCallFn lcfn,const char* op_,size_t oplen,_CORBA_Boolean upcall=0):
869 omniCallDescriptor(lcfn, op_, oplen, 0, _user_exns, 0, upcall)
877 static const char* const _user_exns[];
882 const char* const _0RL_cd_00d6793dc2c2a80c_01000000::_user_exns[] = {
886 // Local call call-back function.
888 _0RL_lcfn_00d6793dc2c2a80c_11000000(omniCallDescriptor*, omniServant* svnt)
891 plpbus_orb::_impl_OrbServer* impl = (plpbus_orb::_impl_OrbServer*) svnt->_ptrToInterface(plpbus_orb::OrbServer::_PD_repoId);
897 void plpbus_orb::_objref_OrbServer::shutdown()
899 _0RL_cd_00d6793dc2c2a80c_01000000 _call_desc(_0RL_lcfn_00d6793dc2c2a80c_11000000, "shutdown", 9);
907 plpbus_orb::_pof_OrbServer::~_pof_OrbServer() {}
911 plpbus_orb::_pof_OrbServer::newObjRef(omniIOR* ior, omniIdentity* id)
913 return new ::plpbus_orb::_objref_OrbServer(ior, id);
918 plpbus_orb::_pof_OrbServer::is_a(const char* id) const
920 if( omni::ptrStrMatch(id, ::plpbus_orb::OrbServer::_PD_repoId) )
926 const plpbus_orb::_pof_OrbServer _the_pof_plpbus__orb_mOrbServer;
928 plpbus_orb::_impl_OrbServer::~_impl_OrbServer() {}
932 plpbus_orb::_impl_OrbServer::_dispatch(omniCallHandle& _handle)
934 const char* op = _handle.operation_name();
936 if( omni::strMatch(op, "send_message_and_request_response") ) {
938 _0RL_cd_00d6793dc2c2a80c_60000000 _call_desc(_0RL_lcfn_00d6793dc2c2a80c_70000000, "send_message_and_request_response", 34, 1);
940 _handle.upcall(this,_call_desc);
944 if( omni::strMatch(op, "send_dataitem_message_and_request_response") ) {
946 _0RL_cd_00d6793dc2c2a80c_80000000 _call_desc(_0RL_lcfn_00d6793dc2c2a80c_90000000, "send_dataitem_message_and_request_response", 43, 1);
948 _handle.upcall(this,_call_desc);
952 if( omni::strMatch(op, "send_message_and_wait_response") ) {
954 _0RL_cd_00d6793dc2c2a80c_a0000000 _call_desc(_0RL_lcfn_00d6793dc2c2a80c_b0000000, "send_message_and_wait_response", 31, 1);
956 _handle.upcall(this,_call_desc);
960 if( omni::strMatch(op, "send_dataitem_message_and_wait_response") ) {
962 _0RL_cd_00d6793dc2c2a80c_c0000000 _call_desc(_0RL_lcfn_00d6793dc2c2a80c_d0000000, "send_dataitem_message_and_wait_response", 40, 1);
964 _handle.upcall(this,_call_desc);
968 if( omni::strMatch(op, "add_event_listener") ) {
970 _0RL_cd_00d6793dc2c2a80c_e0000000 _call_desc(_0RL_lcfn_00d6793dc2c2a80c_f0000000, "add_event_listener", 19, 1);
972 _handle.upcall(this,_call_desc);
976 if( omni::strMatch(op, "shutdown") ) {
978 _0RL_cd_00d6793dc2c2a80c_01000000 _call_desc(_0RL_lcfn_00d6793dc2c2a80c_11000000, "shutdown", 9, 1);
980 _handle.upcall(this,_call_desc);
989 plpbus_orb::_impl_OrbServer::_ptrToInterface(const char* id)
991 if( id == ::plpbus_orb::OrbServer::_PD_repoId )
992 return (::plpbus_orb::_impl_OrbServer*) this;
994 if( id == ::CORBA::Object::_PD_repoId )
997 if( omni::strMatch(id, ::plpbus_orb::OrbServer::_PD_repoId) )
998 return (::plpbus_orb::_impl_OrbServer*) this;
1000 if( omni::strMatch(id, ::CORBA::Object::_PD_repoId) )
1006 plpbus_orb::_impl_OrbServer::_mostDerivedRepoId()
1008 return ::plpbus_orb::OrbServer::_PD_repoId;
1011 POA_plpbus_orb::OrbClient::~OrbClient() {}
1013 POA_plpbus_orb::OrbServer::~OrbServer() {}