theLink 10.0 NHI1 - theKernel - theLink - theConfig - theSq3Lite - theCompiler - theBrain - theGuard
c - tcl - cs - py - rb - jv - cc
Loading...
Searching...
No Matches
MqContextC_inline_cc.hh
Go to the documentation of this file.
1
12/* LABEL-NO */
13
14#include "MqCall_cc.hh"
15
16namespace ccmqmsgque {
17
19 return new MqContextC(obj);
20 }
21
22 inline void MqContextC::SlaveWorker (const MQ_SLAVE_ID id, MK_STRN fct, const MkBufferListC& args) {
23 MK_BAC args_hdl = MkBufferListC::getBFL(args);
24 MkRtSetup_XN(args_hdl);
25 enum MkErrorE errVal = MqSlaveWorker (reinterpret_cast<MQ_CTX>(hdl), id, fct, args_hdl);
26 ErrorCheck(errVal);
27 }
28
29 // BEGIN-MqContextC - created by 'cc_MqC.tcl -i NHI1_HOME/theLink/c/gen/c_mqmsgque.meta' - DO NOT change
30
34
35 // doc-key: MqContextC,MqContextC-Class-Export,sc_
36
40 MQ_CTX __retVal__L = MqContextHandleResolve(netHdl);
41 return MqContextC::MqContextC_ObjNew(MK_RT_CALL __retVal__L);
42 }
43
44 // doc-key: MqContextC,MqContextC-Class-Export,om_
45
46 // skip class-overload: HandleGet = MqContextHandleGet → MkObjectHandleGet
47
49 // MqContextC_Class_CC_API
50
54
55 // doc-key: MqContextC,MqContextC-Class-Introspection,oc_
56
59 MK_UNUSED auto ctx = getCTX();
60 MkRtSetup_X(ctx);
61 MQ_CTX __retVal__L = MqContextNext(ctx);
62 return MqContextC::MqContextC_ObjNew(MK_RT_CALL __retVal__L);
63 }
64
67 MK_UNUSED auto ctx = getCTX();
68 MkRtSetup_X(ctx);
69 MQ_CTX __retVal__L = MqContextPrev(ctx);
70 return MqContextC::MqContextC_ObjNew(MK_RT_CALL __retVal__L);
71 }
72
73 // doc-key: MqContextC,MqContextC-Class-Introspection,sc_
74
78 MQ_CTX __retVal__L = MqContextInstances();
79 return MqContextC::MqContextC_ObjNew(MK_RT_CALL __retVal__L);
80 }
81
83 // MqContextC_Class_CC_API
84
88
89 // doc-key: MqContextC,MqContextC-Class-Misc,sc_
90
94 MQ_CTX __retVal__L = MqContextGetNull();
95 return MqContextC::MqContextC_ObjNew(MK_RT_CALL __retVal__L);
96 }
97
99 // MqContextC_Class_CC_API
100
104
105 // doc-key: MqContextC,MqContextC-ClassApi-Class,oc_
106
109 MK_UNUSED auto ctx = getCTXN();
110 MkRtSetup_X(ctx);
111 MQ_FCT __retVal__L = MqClassFactoryGet(ctx);
112 return MqFactoryC::MqFactoryC_ObjNew(MK_RT_CALL __retVal__L);
113 }
114
115 // doc-key: MqContextC,MqContextC-ClassApi-Class,om_
116
119 MK_UNUSED auto ctx = getCTX();
120 MkRtSetup_X(ctx);
121 MQ_FCT item_hdl = MqFactoryC::getFCT(item);
122 enum MkErrorE errVal = MqClassFactorySet(ctx, item_hdl);
123 MkErrorC_Check(ctx, errVal);
124 }
125
127 inline void MqContextC::ClassFactorySet (const MqFactoryC& item) {
128 MK_UNUSED auto ctx = getCTX();
129 MkRtSetup_X(ctx);
130 const MQ_FCT item_hdl = MqFactoryC::getFCT(item);
131 enum MkErrorE errVal = MqClassFactorySet(ctx, item_hdl);
132 MkErrorC_Check(ctx, errVal);
133 }
134
137 MK_UNUSED auto ctx = getCTXN();
138 MkRtSetup_X(ctx);
139 MK_STRN __retVal__L = MqClassIdentGet(ctx);
140 return __retVal__L;
141 }
142
144 inline void MqContextC::ClassIdentSet (MK_STRN ident) {
145 MK_UNUSED auto ctx = getCTX();
146 MkRtSetup_X(ctx);
147 enum MkErrorE errVal = MqClassIdentSet(ctx, ident);
148 MkErrorC_Check(ctx, errVal);
149 }
150
152 inline void MqContextC::ClassIdentSet (const std::string& ident) {
153 MK_UNUSED auto ctx = getCTX();
154 MkRtSetup_X(ctx);
155 const MK_STRN ident_hdl = ident.c_str();
156 enum MkErrorE errVal = MqClassIdentSet(ctx, ident_hdl);
157 MkErrorC_Check(ctx, errVal);
158 }
159
162 MK_UNUSED auto ctx = getCTXN();
163 MkRtSetup_X(ctx);
164 MK_STRN __retVal__L = MqClassOriginalIdentGet(ctx);
165 return __retVal__L;
166 }
167
169 // MqContextC_ClassApi_Class_CC_API
170
174
175 // doc-key: MqContextC,MqContextC-ConfigApi-Get,oco
176
179 MK_UNUSED auto ctx = getCTX();
180 MkRtSetup_X(ctx);
181 MK_BFL vals_out;
182 enum MkErrorE errVal = MqConfigGetIoTcpL(ctx, &vals_out);
183 MkErrorC_Check(ctx, errVal);
185 }
186
187 // doc-key: MqContextC,MqContextC-ConfigApi-Get,om_
188
191 MK_UNUSED auto ctx = getCTXN();
192 MkRtSetup_X(ctx);
193 MK_I32 __retVal__L = MqConfigGetBuffersize(ctx);
194 return __retVal__L;
195 }
196
199 MK_UNUSED auto ctx = getCTX();
200 MkRtSetup_X(ctx);
201 enum MqIdentE __retVal__L = MqConfigGetIdentFrom(ctx);
202 return __retVal__L;
203 }
204
207 MK_UNUSED auto ctx = getCTX();
208 MkRtSetup_X(ctx);
209 MQ_SOCK_HDL __retVal__L = MqConfigGetIoPipe(ctx);
210 return __retVal__L;
211 }
212
215 MK_UNUSED auto ctx = getCTXN();
216 MkRtSetup_X(ctx);
217 MK_STRN __retVal__L = MqConfigGetIoUds(ctx);
218 return __retVal__L;
219 }
220
223 MK_UNUSED auto ctx = getCTX();
224 MkRtSetup_X(ctx);
225 MK_BOOL __retVal__L = MqConfigGetIsParent(ctx);
226 return __retVal__L;
227 }
228
231 MK_UNUSED auto ctx = getCTX();
232 MkRtSetup_X(ctx);
233 MK_BOOL __retVal__L = MqConfigGetIsServer(ctx);
234 return __retVal__L;
235 }
236
239 MK_UNUSED auto ctx = getCTX();
240 MkRtSetup_X(ctx);
241 MK_BOOL __retVal__L = MqConfigGetIsString(ctx);
242 return __retVal__L;
243 }
244
247 MK_UNUSED auto ctx = getCTXN();
248 MkRtSetup_X(ctx);
249 MK_STRN __retVal__L = MqConfigGetName(ctx);
250 return __retVal__L;
251 }
252
255 MK_UNUSED auto ctx = getCTXN();
256 MkRtSetup_X(ctx);
257 MK_I32 __retVal__L = MqConfigGetPkgsize(ctx);
258 return __retVal__L;
259 }
260
263 MK_UNUSED auto ctx = getCTXN();
264 MkRtSetup_X(ctx);
265 MK_STRN __retVal__L = MqConfigGetPostfix(ctx);
266 return __retVal__L;
267 }
268
271 MK_UNUSED auto ctx = getCTXN();
272 MkRtSetup_X(ctx);
273 MK_STRN __retVal__L = MqConfigGetPrefix(ctx);
274 return __retVal__L;
275 }
276
279 MK_UNUSED auto ctx = getCTX();
280 MkRtSetup_X(ctx);
281 enum MqStartE __retVal__L = MqConfigGetStartAs(ctx);
282 return __retVal__L;
283 }
284
287 MK_UNUSED auto ctx = getCTX();
288 MkRtSetup_X(ctx);
289 enum MqStatusIsEF __retVal__L = MqConfigGetStatusIs(ctx);
290 return __retVal__L;
291 }
292
295 MK_UNUSED auto ctx = getCTXN();
296 MkRtSetup_X(ctx);
297 MK_STRN __retVal__L = MqConfigGetStorage(ctx);
298 return __retVal__L;
299 }
300
303 MK_UNUSED auto ctx = getCTXN();
304 MkRtSetup_X(ctx);
305 MK_TIME_T __retVal__L = MqConfigGetTimeout(ctx);
306 return __retVal__L;
307 }
308
311 MK_UNUSED auto ctx = getCTX();
312 MkRtSetup_X(ctx);
313 enum MkErrorE errVal = MqConfigSetConfigFile(ctx, filename);
314 MkErrorC_Check(ctx, errVal);
315 }
316
318 inline void MqContextC::ConfigSetConfigFile (const std::string& filename) {
319 MK_UNUSED auto ctx = getCTX();
320 MkRtSetup_X(ctx);
321 const MK_STRN filename_hdl = filename.c_str();
322 enum MkErrorE errVal = MqConfigSetConfigFile(ctx, filename_hdl);
323 MkErrorC_Check(ctx, errVal);
324 }
325
326 // doc-key: MqContextC,MqContextC-ConfigApi-Get,omo
327
329 inline std::tuple<MK_STRN,MK_STRN,MK_STRN,MK_STRN> MqContextC::ConfigGetIoTcp () {
330 MK_UNUSED auto ctx = getCTX();
331 MkRtSetup_X(ctx);
332 MK_STRN host_out;
333 MK_STRN port_out;
334 MK_STRN myhost_out;
335 MK_STRN myport_out;
336 enum MkErrorE errVal = MqConfigGetIoTcp(ctx, &host_out, &port_out, &myhost_out, &myport_out);
337 MkErrorC_Check(ctx, errVal);
338 std::tuple<MK_STRN,MK_STRN,MK_STRN,MK_STRN> __retVal__L = {host_out,port_out,myhost_out,myport_out};
339 return __retVal__L;
340 }
341
343 // MqContextC_ConfigApi_Get_CC_API
344
348
349 // doc-key: MqContextC,MqContextC-ConfigApi-Interface,om_
350
353 MK_UNUSED auto ctx = getCTX();
354 MkRtSetup_X(ctx);
355 auto fCall = MqServiceCallbackC::Call;
356 auto callback_ptr = MqBgErrorCallbackC::Create(MK_RT_CALL callback, this);
357 if (callback_ptr == NULL) fCall = NULL;
359 }
360
363 MK_UNUSED auto ctx = getCTX();
364 MkRtSetup_X(ctx);
365 auto fCall = MqServiceCallbackC::Call;
366 auto callback_ptr = MqBgErrorCallbackC::Create(MK_RT_CALL callback, this);
367 if (callback_ptr == NULL) fCall = NULL;
369 }
370
373 MK_UNUSED auto ctx = getCTX();
374 MkRtSetup_X(ctx);
375 auto fCall = MqServiceCallbackC::Call;
376 auto callback_ptr = MqBgErrorCallbackC::Create(MK_RT_CALL callback, this);
377 if (callback_ptr == NULL) fCall = NULL;
379 }
380
382 inline void MqContextC::ConfigSetEvent (MqEventCCB callback) {
383 MK_UNUSED auto ctx = getCTX();
384 MkRtSetup_X(ctx);
385 auto fCall = MqServiceCallbackC::Call;
386 auto callback_ptr = MqEventCallbackC::Create(MK_RT_CALL callback, this);
387 if (callback_ptr == NULL) fCall = NULL;
389 }
390
392 inline void MqContextC::ConfigSetEvent (MqEventICB callback) {
393 MK_UNUSED auto ctx = getCTX();
394 MkRtSetup_X(ctx);
395 auto fCall = MqServiceCallbackC::Call;
396 auto callback_ptr = MqEventCallbackC::Create(MK_RT_CALL callback, this);
397 if (callback_ptr == NULL) fCall = NULL;
399 }
400
402 inline void MqContextC::ConfigSetEvent (MqEventIF* callback) {
403 MK_UNUSED auto ctx = getCTX();
404 MkRtSetup_X(ctx);
405 auto fCall = MqServiceCallbackC::Call;
406 auto callback_ptr = MqEventCallbackC::Create(MK_RT_CALL callback, this);
407 if (callback_ptr == NULL) fCall = NULL;
409 }
410
413 MK_UNUSED auto ctx = getCTX();
414 MkRtSetup_X(ctx);
415 auto fCall = MqServiceCallbackC::Call;
416 auto callback_ptr = MqServerCleanupCallbackC::Create(MK_RT_CALL callback, this);
417 if (callback_ptr == NULL) fCall = NULL;
419 }
420
423 MK_UNUSED auto ctx = getCTX();
424 MkRtSetup_X(ctx);
425 auto fCall = MqServiceCallbackC::Call;
426 auto callback_ptr = MqServerCleanupCallbackC::Create(MK_RT_CALL callback, this);
427 if (callback_ptr == NULL) fCall = NULL;
429 }
430
433 MK_UNUSED auto ctx = getCTX();
434 MkRtSetup_X(ctx);
435 auto fCall = MqServiceCallbackC::Call;
436 auto callback_ptr = MqServerCleanupCallbackC::Create(MK_RT_CALL callback, this);
437 if (callback_ptr == NULL) fCall = NULL;
439 }
440
443 MK_UNUSED auto ctx = getCTX();
444 MkRtSetup_X(ctx);
445 auto fCall = MqServiceCallbackC::Call;
446 auto callback_ptr = MqServerSetupCallbackC::Create(MK_RT_CALL callback, this);
447 if (callback_ptr == NULL) fCall = NULL;
449 }
450
453 MK_UNUSED auto ctx = getCTX();
454 MkRtSetup_X(ctx);
455 auto fCall = MqServiceCallbackC::Call;
456 auto callback_ptr = MqServerSetupCallbackC::Create(MK_RT_CALL callback, this);
457 if (callback_ptr == NULL) fCall = NULL;
459 }
460
463 MK_UNUSED auto ctx = getCTX();
464 MkRtSetup_X(ctx);
465 auto fCall = MqServiceCallbackC::Call;
466 auto callback_ptr = MqServerSetupCallbackC::Create(MK_RT_CALL callback, this);
467 if (callback_ptr == NULL) fCall = NULL;
469 }
470
472 // MqContextC_ConfigApi_Interface_CC_API
473
477
478 // doc-key: MqContextC,MqContextC-ConfigApi-Misc,om_
479
481 inline void MqContextC::ConfigReset () {
482 MK_UNUSED auto ctx = getCTX();
483 MkRtSetup_X(ctx);
484 MqConfigReset(ctx);
485 }
486
488 // MqContextC_ConfigApi_Misc_CC_API
489
493
494 // doc-key: MqContextC,MqContextC-ConfigApi-Set,om_
495
498 MK_UNUSED auto ctx = getCTX();
499 MkRtSetup_X(ctx);
500 MK_BOOL __retVal__L = MqConfigCheckStartAs(ctx, data);
501 return __retVal__L;
502 }
503
506 MK_UNUSED auto ctx = getCTX();
507 MkRtSetup_X(ctx);
508 enum MkErrorE errVal = MqConfigSetAllDebug(ctx, data);
509 MkErrorC_Check(ctx, errVal);
510 }
511
514 MK_UNUSED auto ctx = getCTX();
515 MkRtSetup_X(ctx);
516 MqConfigSetBuffersize(ctx, data);
517 }
518
520 inline void MqContextC::ConfigSetDaemon (MK_STRN pidfile) {
521 MK_UNUSED auto ctx = getCTX();
522 MkRtSetup_X(ctx);
523 enum MkErrorE errVal = MqConfigSetDaemon(ctx, pidfile);
524 MkErrorC_Check(ctx, errVal);
525 }
526
528 inline void MqContextC::ConfigSetDaemon (const std::string& pidfile) {
529 MK_UNUSED auto ctx = getCTX();
530 MkRtSetup_X(ctx);
531 const MK_STRN pidfile_hdl = pidfile.c_str();
532 enum MkErrorE errVal = MqConfigSetDaemon(ctx, pidfile_hdl);
533 MkErrorC_Check(ctx, errVal);
534 }
535
538 MK_UNUSED auto ctx = getCTX();
539 MkRtSetup_X(ctx);
540 MqConfigSetIdentFrom(ctx, data);
541 }
542
545 MK_UNUSED auto ctx = getCTX();
546 MkRtSetup_X(ctx);
547 MqConfigSetIgnoreExit(ctx, data);
548 }
549
552 MK_UNUSED auto ctx = getCTX();
553 MkRtSetup_X(ctx);
554 enum MkErrorE errVal = MqConfigSetIoPipe(ctx, fh);
555 MkErrorC_Check(ctx, errVal);
556 }
557
559 inline void MqContextC::ConfigSetIoTcp (MK_STRN host, MK_STRN port, MK_STRN myhost, MK_STRN myport) {
560 MK_UNUSED auto ctx = getCTX();
561 MkRtSetup_X(ctx);
562 enum MkErrorE errVal = MqConfigSetIoTcp(ctx, host, port, myhost, myport);
563 MkErrorC_Check(ctx, errVal);
564 }
565
568 MK_UNUSED auto ctx = getCTX();
569 MkRtSetup_X(ctx);
570 MK_BFL vals_hdl = MkBufferListC::getBFL(vals);
571 enum MkErrorE errVal = MqConfigSetIoTcpL(ctx, vals_hdl);
572 MkErrorC_Check(ctx, errVal);
573 }
574
576 inline void MqContextC::ConfigSetIoTcp (const MkBufferListC& vals) {
577 MK_UNUSED auto ctx = getCTX();
578 MkRtSetup_X(ctx);
579 const MK_BFL vals_hdl = MkBufferListC::getBFL(vals);
580 enum MkErrorE errVal = MqConfigSetIoTcpL(ctx, vals_hdl);
581 MkErrorC_Check(ctx, errVal);
582 }
583
586 MK_UNUSED auto ctx = getCTX();
587 MkRtSetup_X(ctx);
588 enum MkErrorE errVal = MqConfigSetIoUds(ctx, file);
589 MkErrorC_Check(ctx, errVal);
590 }
591
593 inline void MqContextC::ConfigSetIoUds (const std::string& file) {
594 MK_UNUSED auto ctx = getCTX();
595 MkRtSetup_X(ctx);
596 const MK_STRN file_hdl = file.c_str();
597 enum MkErrorE errVal = MqConfigSetIoUds(ctx, file_hdl);
598 MkErrorC_Check(ctx, errVal);
599 }
600
603 MK_UNUSED auto ctx = getCTX();
604 MkRtSetup_X(ctx);
605 MqConfigSetIsServer(ctx, data);
606 }
607
610 MK_UNUSED auto ctx = getCTX();
611 MkRtSetup_X(ctx);
612 MqConfigSetIsString(ctx, data);
613 }
614
617 MK_UNUSED auto ctx = getCTX();
618 MkRtSetup_X(ctx);
619 MqConfigSetName(ctx, data);
620 }
621
623 inline void MqContextC::ConfigSetName (const std::string& data) {
624 MK_UNUSED auto ctx = getCTX();
625 MkRtSetup_X(ctx);
626 const MK_STRN data_hdl = data.c_str();
627 MqConfigSetName(ctx, data_hdl);
628 }
629
632 MK_UNUSED auto ctx = getCTX();
633 MkRtSetup_X(ctx);
634 MqConfigSetPkgsize(ctx, data);
635 }
636
639 MK_UNUSED auto ctx = getCTX();
640 MkRtSetup_X(ctx);
641 MqConfigSetPostfix(ctx, data);
642 }
643
645 inline void MqContextC::ConfigSetPostfix (const std::string& data) {
646 MK_UNUSED auto ctx = getCTX();
647 MkRtSetup_X(ctx);
648 const MK_STRN data_hdl = data.c_str();
649 MqConfigSetPostfix(ctx, data_hdl);
650 }
651
654 MK_UNUSED auto ctx = getCTX();
655 MkRtSetup_X(ctx);
656 MqConfigSetPrefix(ctx, data);
657 }
658
660 inline void MqContextC::ConfigSetPrefix (const std::string& data) {
661 MK_UNUSED auto ctx = getCTX();
662 MkRtSetup_X(ctx);
663 const MK_STRN data_hdl = data.c_str();
664 MqConfigSetPrefix(ctx, data_hdl);
665 }
666
669 MK_UNUSED auto ctx = getCTX();
670 MkRtSetup_X(ctx);
671 enum MkErrorE errVal = MqConfigSetStartAs(ctx, data);
672 MkErrorC_Check(ctx, errVal);
673 }
674
677 MK_UNUSED auto ctx = getCTX();
678 MkRtSetup_X(ctx);
679 enum MkErrorE errVal = MqConfigSetStartAsString(ctx, data);
680 MkErrorC_Check(ctx, errVal);
681 }
682
684 inline void MqContextC::ConfigSetStartAsString (const std::string& data) {
685 MK_UNUSED auto ctx = getCTX();
686 MkRtSetup_X(ctx);
687 const MK_STRN data_hdl = data.c_str();
688 enum MkErrorE errVal = MqConfigSetStartAsString(ctx, data_hdl);
689 MkErrorC_Check(ctx, errVal);
690 }
691
694 MK_UNUSED auto ctx = getCTX();
695 MkRtSetup_X(ctx);
696 MqConfigSetStorage(ctx, data);
697 }
698
700 inline void MqContextC::ConfigSetStorage (const std::string& data) {
701 MK_UNUSED auto ctx = getCTX();
702 MkRtSetup_X(ctx);
703 const MK_STRN data_hdl = data.c_str();
704 MqConfigSetStorage(ctx, data_hdl);
705 }
706
709 MK_UNUSED auto ctx = getCTX();
710 MkRtSetup_X(ctx);
711 MqConfigSetTimeout(ctx, data);
712 }
713
715 // MqContextC_ConfigApi_Set_CC_API
716
720
721 // doc-key: MqContextC,MqContextC-EnvApi-Env,om_
722
724 inline void MqContextC::EnvProtect () {
725 MK_UNUSED auto ctx = getCTX();
726 MkRtSetup_X(ctx);
727 MqEnvProtect(ctx);
728 }
729
731 inline void MqContextC::EnvRestore () {
732 MK_UNUSED auto ctx = getCTX();
733 MkRtSetup_X(ctx);
734 MqEnvRestore(ctx);
735 }
736
738 // MqContextC_EnvApi_Env_CC_API
739
743
744 // doc-key: MqContextC,MqContextC-ErrorApi-Error,oc_
745
748 MK_UNUSED auto fmtobj = getCTXN__null_allow();
749 MkRtSetup_X(fmtobj);
750 MK_ERR __retVal__L = MqContextErrorFORMAT(fmtobj);
751 return MkErrorC::MkErrorC_ObjNew(MK_RT_CALL __retVal__L);
752 }
753
754 // doc-key: MqContextC,MqContextC-ErrorApi-Error,om_
755
757 inline MkErrorE MqContextC::ErrorCopy (const MqContextC* sourceCtx) const {
758 MK_UNUSED auto targetCtx = getCTXN();
759 MkRtSetup_X(targetCtx);
760 MQ_CTXN sourceCtx_hdl = MqContextC::getCTXN(sourceCtx);
761 enum MkErrorE errVal = MqContextErrorCopy(targetCtx, sourceCtx_hdl);
762 return errVal;
763 }
764
766 inline MkErrorE MqContextC::ErrorCopy (const MqContextC& sourceCtx) const {
767 MK_UNUSED auto targetCtx = getCTXN();
768 MkRtSetup_X(targetCtx);
769 const MQ_CTXN sourceCtx_hdl = MqContextC::getCTXN(sourceCtx);
770 enum MkErrorE errVal = MqContextErrorCopy(targetCtx, sourceCtx_hdl);
771 return errVal;
772 }
773
775 inline MkErrorE MqContextC::ErrorMove (const MqContextC* sourceCtx) const {
776 MK_UNUSED auto targetCtx = getCTXN();
777 MkRtSetup_X(targetCtx);
778 MQ_CTXN sourceCtx_hdl = MqContextC::getCTXN(sourceCtx);
779 enum MkErrorE errVal = MqContextErrorMove(targetCtx, sourceCtx_hdl);
780 return errVal;
781 }
782
784 inline MkErrorE MqContextC::ErrorMove (const MqContextC& sourceCtx) const {
785 MK_UNUSED auto targetCtx = getCTXN();
786 MkRtSetup_X(targetCtx);
787 const MQ_CTXN sourceCtx_hdl = MqContextC::getCTXN(sourceCtx);
788 enum MkErrorE errVal = MqContextErrorMove(targetCtx, sourceCtx_hdl);
789 return errVal;
790 }
791
793 // MqContextC_ErrorApi_Error_CC_API
794
798
799 // doc-key: MqContextC,MqContextC-HighApi-High,om_
800
802 inline void MqContextC::SendVL2 (MK_STRN cstr, va_list var_list) {
803 MK_UNUSED auto ctx = getCTX();
804 MkRtSetup_X(ctx);
805 enum MkErrorE errVal = MqSendVL2(ctx, cstr, var_list);
806 MkErrorC_Check(ctx, errVal);
807 }
808
810 inline void MqContextC::SendVL2 (const std::string& cstr, va_list var_list) {
811 MK_UNUSED auto ctx = getCTX();
812 MkRtSetup_X(ctx);
813 const MK_STRN cstr_hdl = cstr.c_str();
814 enum MkErrorE errVal = MqSendVL2(ctx, cstr_hdl, var_list);
815 MkErrorC_Check(ctx, errVal);
816 }
817
819 // MqContextC_HighApi_High_CC_API
820
824
825 // doc-key: MqContextC,MqContextC-LinkApi-Link,oc_
826
829 MK_UNUSED auto ctx = getCTX();
830 MkRtSetup_X(ctx);
831 MQ_CTX __retVal__L = MqLinkGetParent(ctx);
832 return MqContextC::MqContextC_ObjNew(MK_RT_CALL __retVal__L);
833 }
834
835 // doc-key: MqContextC,MqContextC-LinkApi-Link,om_
836
838 inline void MqContextC::LinkConnect () {
839 MK_UNUSED auto ctx = getCTX();
840 MkRtSetup_X(ctx);
841 enum MkErrorE errVal = MqLinkConnect(ctx);
842 MkErrorC_Check(ctx, errVal);
843 }
844
847 MK_UNUSED auto ctx = getCTX();
848 MkRtSetup_X(ctx);
850 enum MkErrorE errVal = MqLinkCreate(ctx, args_hdl);
851 MkErrorC_Check(ctx, errVal);
852 }
853
855 inline void MqContextC::LinkCreate (const MkBufferListC& args) {
856 MK_UNUSED auto ctx = getCTX();
857 MkRtSetup_X(ctx);
858 const MK_BAC args_hdl = MkBufferListC::getBFL(args);
859 enum MkErrorE errVal = MqLinkCreate(ctx, args_hdl);
860 MkErrorC_Check(ctx, errVal);
861 }
862
865 MK_UNUSED auto ctx = getCTX();
866 MkRtSetup_X(ctx);
867 MQ_CTX parent_hdl = MqContextC::getCTX(parent);
869 enum MkErrorE errVal = MqLinkCreateChild(ctx, parent_hdl, args_hdl);
870 MkErrorC_Check(ctx, errVal);
871 }
872
874 inline void MqContextC::LinkCreateChild (const MqContextC& parent, const MkBufferListC& args) {
875 MK_UNUSED auto ctx = getCTX();
876 MkRtSetup_X(ctx);
877 const MQ_CTX parent_hdl = MqContextC::getCTX(parent);
878 const MK_BAC args_hdl = MkBufferListC::getBFL(args);
879 enum MkErrorE errVal = MqLinkCreateChild(ctx, parent_hdl, args_hdl);
880 MkErrorC_Check(ctx, errVal);
881 }
882
884 inline void MqContextC::LinkDelete () {
885 MK_UNUSED auto ctx = getCTX();
886 MkRtSetup_X(ctx);
887 MqLinkDelete(ctx);
888 }
889
892 MK_UNUSED auto ctx = getCTX();
893 MkRtSetup_X(ctx);
894 MK_NUM __retVal__L = MqLinkGetCtxId(ctx);
895 return __retVal__L;
896 }
897
900 MK_UNUSED auto ctx = getCTX();
901 MkRtSetup_X(ctx);
902 MK_STRN __retVal__L = MqLinkGetTargetIdent(ctx);
903 return __retVal__L;
904 }
905
908 MK_UNUSED auto ctx = getCTX();
909 MkRtSetup_X(ctx);
910 MK_BOOL __retVal__L = MqLinkIsConnected(ctx);
911 return __retVal__L;
912 }
913
916 MK_UNUSED auto ctx = getCTX();
917 MkRtSetup_X(ctx);
918 MK_BOOL __retVal__L = MqLinkIsParent(ctx);
919 return __retVal__L;
920 }
921
924 MK_UNUSED auto ctx = getCTX();
925 MkRtSetup_X(ctx);
926 enum MkErrorE errVal = MqLinkShutdown(ctx);
927 MkErrorC_Check(ctx, errVal);
928 }
929
931 // MqContextC_LinkApi_Link_CC_API
932
936
937 // doc-key: MqContextC,MqContextC-LogApi-Log,om_
938
939 // skip class-overload: Log = MqContextLog → MkObjectLog
940
941 // skip class-overload: Log = MqContextLog → MkObjectLog
942
944 inline void MqContextC::LogConfig (const MkObjectC* fmtobj, MK_DBG debug, MK_STRN callfunc, MK_I32 lvl) const {
945 MK_UNUSED auto ctx = getCTXN();
946 MkRtSetup_X(ctx);
947 MK_OBJN fmtobj_hdl = MkObjectC::getOBJN__null_allow(fmtobj);
948 if (callfunc == NULL) {callfunc = __builtin_FUNCTION();}
949 if (debug > (MK_DBG)(MkRuntimeGetDebug())) {return;}
950 MqContextLogConfig(ctx, fmtobj_hdl, debug, callfunc, lvl);
951 }
952
954 inline void MqContextC::LogConfig (const MkObjectC& fmtobj, MK_DBG debug, MK_STRN callfunc, MK_I32 lvl) const {
955 MK_UNUSED auto ctx = getCTXN();
956 MkRtSetup_X(ctx);
957 const MK_OBJN fmtobj_hdl = MkObjectC::getOBJN(fmtobj);
958 if (callfunc == NULL) {callfunc = __builtin_FUNCTION();}
959 if (debug > (MK_DBG)(MkRuntimeGetDebug())) {return;}
960 MqContextLogConfig(ctx, fmtobj_hdl, debug, callfunc, lvl);
961 }
962
964 inline void MqContextC::LogEnv (const MkObjectC* fmtobj, MK_DBG debug, MK_STRN callfunc, MK_I32 lvl) const {
965 MK_UNUSED auto ctx = getCTX();
966 MkRtSetup_X(ctx);
967 MK_OBJN fmtobj_hdl = MkObjectC::getOBJN__null_allow(fmtobj);
968 if (callfunc == NULL) {callfunc = __builtin_FUNCTION();}
969 if (debug > (MK_DBG)(MkRuntimeGetDebug())) {return;}
970 MqContextLogEnv(ctx, fmtobj_hdl, debug, callfunc, lvl);
971 }
972
974 inline void MqContextC::LogEnv (const MkObjectC& fmtobj, MK_DBG debug, MK_STRN callfunc, MK_I32 lvl) const {
975 MK_UNUSED auto ctx = getCTX();
976 MkRtSetup_X(ctx);
977 const MK_OBJN fmtobj_hdl = MkObjectC::getOBJN(fmtobj);
978 if (callfunc == NULL) {callfunc = __builtin_FUNCTION();}
979 if (debug > (MK_DBG)(MkRuntimeGetDebug())) {return;}
980 MqContextLogEnv(ctx, fmtobj_hdl, debug, callfunc, lvl);
981 }
982
984 inline void MqContextC::LogLink (const MkObjectC* fmtobj, MK_DBG debug, MK_STRN callfunc, MK_I32 lvl) const {
985 MK_UNUSED auto ctx = getCTXN();
986 MkRtSetup_X(ctx);
987 MK_OBJN fmtobj_hdl = MkObjectC::getOBJN__null_allow(fmtobj);
988 if (callfunc == NULL) {callfunc = __builtin_FUNCTION();}
989 if (debug > (MK_DBG)(MkRuntimeGetDebug())) {return;}
990 MqContextLogLink(ctx, fmtobj_hdl, debug, callfunc, lvl);
991 }
992
994 inline void MqContextC::LogLink (const MkObjectC& fmtobj, MK_DBG debug, MK_STRN callfunc, MK_I32 lvl) const {
995 MK_UNUSED auto ctx = getCTXN();
996 MkRtSetup_X(ctx);
997 const MK_OBJN fmtobj_hdl = MkObjectC::getOBJN(fmtobj);
998 if (callfunc == NULL) {callfunc = __builtin_FUNCTION();}
999 if (debug > (MK_DBG)(MkRuntimeGetDebug())) {return;}
1000 MqContextLogLink(ctx, fmtobj_hdl, debug, callfunc, lvl);
1001 }
1002
1004 inline void MqContextC::LogSetup (const MkObjectC* fmtobj, MK_DBG debug, MK_STRN callfunc, MK_I32 lvl) const {
1005 MK_UNUSED auto ctx = getCTXN();
1006 MkRtSetup_X(ctx);
1007 MK_OBJN fmtobj_hdl = MkObjectC::getOBJN__null_allow(fmtobj);
1008 if (callfunc == NULL) {callfunc = __builtin_FUNCTION();}
1009 if (debug > (MK_DBG)(MkRuntimeGetDebug())) {return;}
1010 MqContextLogSetup(ctx, fmtobj_hdl, debug, callfunc, lvl);
1011 }
1012
1014 inline void MqContextC::LogSetup (const MkObjectC& fmtobj, MK_DBG debug, MK_STRN callfunc, MK_I32 lvl) const {
1015 MK_UNUSED auto ctx = getCTXN();
1016 MkRtSetup_X(ctx);
1017 const MK_OBJN fmtobj_hdl = MkObjectC::getOBJN(fmtobj);
1018 if (callfunc == NULL) {callfunc = __builtin_FUNCTION();}
1019 if (debug > (MK_DBG)(MkRuntimeGetDebug())) {return;}
1020 MqContextLogSetup(ctx, fmtobj_hdl, debug, callfunc, lvl);
1021 }
1022
1024 inline void MqContextC::LogShort (const MkObjectC* fmtobj, MK_DBG debug, MK_STRN callfunc, MK_I32 lvl, MK_STRN label) const {
1025 MK_UNUSED auto ctx = getCTXN();
1026 MkRtSetup_X(ctx);
1027 MK_OBJN fmtobj_hdl = MkObjectC::getOBJN__null_allow(fmtobj);
1028 if (callfunc == NULL) {callfunc = __builtin_FUNCTION();}
1029 if (debug > (MK_DBG)(MkRuntimeGetDebug())) {return;}
1030 MqContextLogShort(ctx, fmtobj_hdl, debug, callfunc, lvl, label);
1031 }
1032
1034 inline void MqContextC::LogShort (const MkObjectC& fmtobj, MK_DBG debug, MK_STRN callfunc, MK_I32 lvl, MK_STRN label) const {
1035 MK_UNUSED auto ctx = getCTXN();
1036 MkRtSetup_X(ctx);
1037 const MK_OBJN fmtobj_hdl = MkObjectC::getOBJN(fmtobj);
1038 if (callfunc == NULL) {callfunc = __builtin_FUNCTION();}
1039 if (debug > (MK_DBG)(MkRuntimeGetDebug())) {return;}
1040 MqContextLogShort(ctx, fmtobj_hdl, debug, callfunc, lvl, label);
1041 }
1042
1044 inline void MqContextC::LogType (const MkObjectC* fmtobj, MK_DBG debug, MK_STRN callfunc, MK_I32 lvl) const {
1045 MK_UNUSED auto ctx = getCTX();
1046 MkRtSetup_X(ctx);
1047 MK_OBJN fmtobj_hdl = MkObjectC::getOBJN__null_allow(fmtobj);
1048 if (callfunc == NULL) {callfunc = __builtin_FUNCTION();}
1049 if (debug > (MK_DBG)(MkRuntimeGetDebug())) {return;}
1050 MqContextLogType(ctx, fmtobj_hdl, debug, callfunc, lvl);
1051 }
1052
1054 inline void MqContextC::LogType (const MkObjectC& fmtobj, MK_DBG debug, MK_STRN callfunc, MK_I32 lvl) const {
1055 MK_UNUSED auto ctx = getCTX();
1056 MkRtSetup_X(ctx);
1057 const MK_OBJN fmtobj_hdl = MkObjectC::getOBJN(fmtobj);
1058 if (callfunc == NULL) {callfunc = __builtin_FUNCTION();}
1059 if (debug > (MK_DBG)(MkRuntimeGetDebug())) {return;}
1060 MqContextLogType(ctx, fmtobj_hdl, debug, callfunc, lvl);
1061 }
1062
1065 MK_UNUSED auto ctx = getCTXN();
1066 MkRtSetup_X(ctx);
1067 MK_STRN __retVal__L = MqLogParentOrChild(ctx);
1068 return __retVal__L;
1069 }
1070
1073 MK_UNUSED auto ctx = getCTXN();
1074 MkRtSetup_X(ctx);
1075 MK_STRN __retVal__L = MqLogServerOrClient(ctx);
1076 return __retVal__L;
1077 }
1078
1080 // MqContextC_LogApi_Log_CC_API
1081
1085
1086 // doc-key: MqContextC,MqContextC-MiscApi-Misc,oc_
1087
1090 MK_UNUSED auto ctx = getCTX();
1091 MkRtSetup_X(ctx);
1092 MK_BUF __retVal__L = MqContextGetBuffer(ctx);
1093 return MkBufferC::MkBufferC_ObjNew(MK_RT_CALL __retVal__L);
1094 }
1095
1098 MK_UNUSED auto ctx = getCTX();
1099 MkRtSetup_X(ctx);
1100 MQ_CTX __retVal__L = MqGetRoot(ctx);
1101 return MqContextC::MqContextC_ObjNew(MK_RT_CALL __retVal__L);
1102 }
1103
1104 // doc-key: MqContextC,MqContextC-MiscApi-Misc,om_
1105
1106 // skip class-overload: ToString = MqContextToString → MkObjectToString
1107
1109 inline void MqContextC::Exit (MK_STRN callfunc, MK_STRN callfile, MK_I32 callline) {
1110 MK_UNUSED auto ctx = getCTX();
1111 MkRtSetup_X(ctx);
1112 if (callline == -1) {callline = __builtin_LINE();}
1113 if (callfile == NULL) {callfile = __builtin_FILE();}
1114 if (callfunc == NULL) {callfunc = __builtin_FUNCTION();}
1115 MqExit(ctx, callfunc, callfile, callline);
1116 }
1117
1120 MK_UNUSED auto ctx = getCTX();
1121 MkRtSetup_X(ctx);
1122 enum MkErrorE errVal = MqProcessEvent(ctx, wait, timeout);
1123 MkErrorC_Check(ctx, errVal);
1124 }
1125
1127 // MqContextC_MiscApi_Misc_CC_API
1128
1132
1133 // doc-key: MqContextC,MqContextC-ProxyApi-Proxy,om_
1134
1136 inline void MqContextC::ProxyForward (MqContextC* targetCtx, MqDumpC* dump, MK_TIME_T timeout) {
1137 MK_UNUSED auto sourceCtx = getCTX();
1138 MkRtSetup_X(sourceCtx);
1139 MQ_CTX targetCtx_hdl = MqContextC::getCTX(targetCtx);
1140 MQ_DMP dump_hdl = MqDumpC::getDMP__null_allow(dump);
1141 enum MkErrorE errVal = MqProxyForward(sourceCtx, targetCtx_hdl, dump_hdl, timeout);
1142 MkErrorC_Check(sourceCtx, errVal);
1143 }
1144
1146 inline void MqContextC::ProxyForward (const MqContextC& targetCtx, const MqDumpC& dump, MK_TIME_T timeout) {
1147 MK_UNUSED auto sourceCtx = getCTX();
1148 MkRtSetup_X(sourceCtx);
1149 const MQ_CTX targetCtx_hdl = MqContextC::getCTX(targetCtx);
1150 const MQ_DMP dump_hdl = MqDumpC::getDMP(dump);
1151 enum MkErrorE errVal = MqProxyForward(sourceCtx, targetCtx_hdl, dump_hdl, timeout);
1152 MkErrorC_Check(sourceCtx, errVal);
1153 }
1154
1156 inline void MqContextC::ProxyItem (MqContextC* targetCtx) {
1157 MK_UNUSED auto sourceCtx = getCTX();
1158 MkRtSetup_X(sourceCtx);
1159 MQ_CTX targetCtx_hdl = MqContextC::getCTX(targetCtx);
1160 enum MkErrorE errVal = MqProxyItem(sourceCtx, targetCtx_hdl);
1161 MkErrorC_Check(sourceCtx, errVal);
1162 }
1163
1165 inline void MqContextC::ProxyItem (const MqContextC& targetCtx) {
1166 MK_UNUSED auto sourceCtx = getCTX();
1167 MkRtSetup_X(sourceCtx);
1168 const MQ_CTX targetCtx_hdl = MqContextC::getCTX(targetCtx);
1169 enum MkErrorE errVal = MqProxyItem(sourceCtx, targetCtx_hdl);
1170 MkErrorC_Check(sourceCtx, errVal);
1171 }
1172
1174 // MqContextC_ProxyApi_Proxy_CC_API
1175
1179
1180 // doc-key: MqContextC,MqContextC-ReadApi-Atom,oci
1181
1184 MK_UNUSED auto ctx = getCTX();
1185 MkRtSetup_X(ctx);
1186 MK_BFL val_inout_hdl = MkBufferListC::getBFL__null_allow(val_inout);
1187 enum MkErrorE errVal = MqReadALL(ctx, &val_inout_hdl);
1188 MkErrorC_Check(ctx, errVal);
1189 return MkBufferListC::MkBufferListC_ObjNew(MK_RT_CALL val_inout_hdl);
1190 }
1191
1192 // doc-key: MqContextC,MqContextC-ReadApi-Atom,oco
1193
1196 MK_UNUSED auto ctx = getCTX();
1197 MkRtSetup_X(ctx);
1198 MK_BFL val_out;
1199 enum MkErrorE errVal = MqReadBFL(ctx, &val_out);
1200 MkErrorC_Check(ctx, errVal);
1202 }
1203
1206 MK_UNUSED auto ctx = getCTX();
1207 MkRtSetup_X(ctx);
1208 MK_BUF val_out;
1209 enum MkErrorE errVal = MqReadBUF(ctx, &val_out);
1210 MkErrorC_Check(ctx, errVal);
1212 }
1213
1214 // doc-key: MqContextC,MqContextC-ReadApi-Atom,omo
1215
1218 MK_UNUSED auto ctx = getCTX();
1219 MkRtSetup_X(ctx);
1220 MkBinaryR val_out_ref;
1221 enum MkErrorE errVal = MqReadBIN(ctx, &val_out_ref);
1222 ErrorCheck(errVal);
1223 MK_BNP val_out = std::make_pair(val_out_ref.size,val_out_ref.data);
1224 return val_out;
1225 }
1226
1229 MK_UNUSED auto ctx = getCTX();
1230 MkRtSetup_X(ctx);
1231 MK_BOL val_out;
1232 enum MkErrorE errVal = MqReadBOL(ctx, &val_out);
1233 MkErrorC_Check(ctx, errVal);
1234 return val_out != 0;
1235 }
1236
1239 MK_UNUSED auto ctx = getCTX();
1240 MkRtSetup_X(ctx);
1241 MkBinaryR val_out_ref;
1242 enum MkErrorE errVal = MqReadBinaryR(ctx, &val_out_ref);
1243 ErrorCheck(errVal);
1244 MK_BNP val_out = std::make_pair(val_out_ref.size,val_out_ref.data);
1245 return val_out;
1246 }
1247
1250 MK_UNUSED auto ctx = getCTX();
1251 MkRtSetup_X(ctx);
1252 MK_DBL val_out;
1253 enum MkErrorE errVal = MqReadDBL(ctx, &val_out);
1254 MkErrorC_Check(ctx, errVal);
1255 return val_out;
1256 }
1257
1260 MK_UNUSED auto ctx = getCTX();
1261 MkRtSetup_X(ctx);
1262 MK_FLT val_out;
1263 enum MkErrorE errVal = MqReadFLT(ctx, &val_out);
1264 MkErrorC_Check(ctx, errVal);
1265 return val_out;
1266 }
1267
1270 MK_UNUSED auto ctx = getCTX();
1271 MkRtSetup_X(ctx);
1272 MK_HDL val_out;
1273 enum MkErrorE errVal = MqReadHDL(ctx, &val_out);
1274 MkErrorC_Check(ctx, errVal);
1275 return val_out;
1276 }
1277
1280 MK_UNUSED auto ctx = getCTX();
1281 MkRtSetup_X(ctx);
1282 MK_I16 val_out;
1283 enum MkErrorE errVal = MqReadI16(ctx, &val_out);
1284 MkErrorC_Check(ctx, errVal);
1285 return val_out;
1286 }
1287
1290 MK_UNUSED auto ctx = getCTX();
1291 MkRtSetup_X(ctx);
1292 MK_I32 val_out;
1293 enum MkErrorE errVal = MqReadI32(ctx, &val_out);
1294 MkErrorC_Check(ctx, errVal);
1295 return val_out;
1296 }
1297
1300 MK_UNUSED auto ctx = getCTX();
1301 MkRtSetup_X(ctx);
1302 MK_I64 val_out;
1303 enum MkErrorE errVal = MqReadI64(ctx, &val_out);
1304 MkErrorC_Check(ctx, errVal);
1305 return val_out;
1306 }
1307
1310 MK_UNUSED auto ctx = getCTX();
1311 MkRtSetup_X(ctx);
1312 MK_I8 val_out;
1313 enum MkErrorE errVal = MqReadI8(ctx, &val_out);
1314 MkErrorC_Check(ctx, errVal);
1315 return (MK_I8)val_out;
1316 }
1317
1320
1323 MK_UNUSED auto ctx = getCTX();
1324 MkRtSetup_X(ctx);
1325 MK_LONG val_out;
1326 enum MkErrorE errVal = MqReadLONG(ctx, &val_out);
1327 MkErrorC_Check(ctx, errVal);
1328 return val_out;
1329 }
1330
1333
1336 MK_UNUSED auto ctx = getCTX();
1337 MkRtSetup_X(ctx);
1338 MK_STRN val_out;
1339 enum MkErrorE errVal = MqReadSTR(ctx, &val_out);
1340 MkErrorC_Check(ctx, errVal);
1341 return val_out;
1342 }
1343
1345 inline std::string MqContextC::ReadStringR () {
1346 MK_UNUSED auto ctx = getCTX();
1347 MkRtSetup_X(ctx);
1348 MkStringR val_out_ref;
1349 enum MkErrorE errVal = MqReadStringR(ctx, &val_out_ref);
1350 ErrorCheck(errVal);
1351 const std::string& val_out = std::string(val_out_ref.ptr,val_out_ref.len);
1352 return val_out;
1353 }
1354
1356 // MqContextC_ReadApi_Atom_CC_API
1357
1361
1362 // doc-key: MqContextC,MqContextC-ReadApi-Block,om_
1363
1365 inline void MqContextC::ReadL_END () {
1366 MK_UNUSED auto ctx = getCTX();
1367 MkRtSetup_X(ctx);
1368 enum MkErrorE errVal = MqReadL_END(ctx);
1369 MkErrorC_Check(ctx, errVal);
1370 }
1371
1374 MK_UNUSED auto ctx = getCTX();
1375 MkRtSetup_X(ctx);
1377 enum MkErrorE errVal = MqReadL_START(ctx, buf_hdl);
1378 MkErrorC_Check(ctx, errVal);
1379 }
1380
1382 inline void MqContextC::ReadL_START (const MkBufferC& buf) {
1383 MK_UNUSED auto ctx = getCTX();
1384 MkRtSetup_X(ctx);
1385 const MK_BUF buf_hdl = MkBufferC::getBUF(buf);
1386 enum MkErrorE errVal = MqReadL_START(ctx, buf_hdl);
1387 MkErrorC_Check(ctx, errVal);
1388 }
1389
1391 inline void MqContextC::ReadT_END () {
1392 MK_UNUSED auto ctx = getCTX();
1393 MkRtSetup_X(ctx);
1394 enum MkErrorE errVal = MqReadT_END(ctx);
1395 MkErrorC_Check(ctx, errVal);
1396 }
1397
1400 MK_UNUSED auto ctx = getCTX();
1401 MkRtSetup_X(ctx);
1402 enum MkErrorE errVal = MqReadT_START(ctx);
1403 MkErrorC_Check(ctx, errVal);
1404 }
1405
1407 // MqContextC_ReadApi_Block_CC_API
1408
1412
1413 // doc-key: MqContextC,MqContextC-ReadApi-Misc,om_
1414
1416 inline void MqContextC::ReadDbg () {
1417 MK_UNUSED auto ctx = getCTX();
1418 MkRtSetup_X(ctx);
1419 MqReadDbg(ctx);
1420 }
1421
1424 MK_UNUSED auto ctx = getCTX();
1425 MkRtSetup_X(ctx);
1426 enum MkTypeE __retVal__L = MqReadGetNextType(ctx);
1427 return __retVal__L;
1428 }
1429
1432 MK_UNUSED auto ctx = getCTX();
1433 MkRtSetup_X(ctx);
1434 MK_NUM __retVal__L = MqReadGetNumItems(ctx);
1435 return __retVal__L;
1436 }
1437
1440 MK_UNUSED auto ctx = getCTX();
1441 MkRtSetup_X(ctx);
1442 MK_BOOL __retVal__L = MqReadItemExists(ctx);
1443 return __retVal__L;
1444 }
1445
1447 inline void MqContextC::ReadUndo () {
1448 MK_UNUSED auto ctx = getCTX();
1449 MkRtSetup_X(ctx);
1450 enum MkErrorE errVal = MqReadUndo(ctx);
1451 MkErrorC_Check(ctx, errVal);
1452 }
1453
1455 // MqContextC_ReadApi_Misc_CC_API
1456
1460
1461 // doc-key: MqContextC,MqContextC-RouteApi-Route,oco
1462
1465 MK_UNUSED auto ctx = getCTX();
1466 MkRtSetup_X(ctx);
1467 MK_BFL treeP_out;
1468 enum MkErrorE errVal = MqRouteGetTree(ctx, &treeP_out);
1469 MkErrorC_Check(ctx, errVal);
1471 }
1472
1473 // doc-key: MqContextC,MqContextC-RouteApi-Route,om_
1474
1476 inline void MqContextC::RouteCreate (MK_STRN route, MK_STRN service, MK_BOOL overwrite) {
1477 MK_UNUSED auto ctx = getCTX();
1478 MkRtSetup_X(ctx);
1479 enum MkErrorE errVal = MqRouteCreate(ctx, route, service, overwrite);
1480 MkErrorC_Check(ctx, errVal);
1481 }
1482
1484 inline void MqContextC::RouteCreate (const std::string& route, const std::string& service, MK_BOOL overwrite) {
1485 MK_UNUSED auto ctx = getCTX();
1486 MkRtSetup_X(ctx);
1487 const MK_STRN route_hdl = route.c_str();
1488 const MK_STRN service_hdl = service.c_str();
1489 enum MkErrorE errVal = MqRouteCreate(ctx, route_hdl, service_hdl, overwrite);
1490 MkErrorC_Check(ctx, errVal);
1491 }
1492
1494 inline void MqContextC::RouteDelete (MK_STRN route, MK_STRN service, MK_BOOL overwrite) {
1495 MK_UNUSED auto ctx = getCTX();
1496 MkRtSetup_X(ctx);
1497 enum MkErrorE errVal = MqRouteDelete(ctx, route, service, overwrite);
1498 MkErrorC_Check(ctx, errVal);
1499 }
1500
1502 inline void MqContextC::RouteDelete (const std::string& route, const std::string& service, MK_BOOL overwrite) {
1503 MK_UNUSED auto ctx = getCTX();
1504 MkRtSetup_X(ctx);
1505 const MK_STRN route_hdl = route.c_str();
1506 const MK_STRN service_hdl = service.c_str();
1507 enum MkErrorE errVal = MqRouteDelete(ctx, route_hdl, service_hdl, overwrite);
1508 MkErrorC_Check(ctx, errVal);
1509 }
1510
1513 MK_UNUSED auto ctx = getCTX();
1514 MkRtSetup_X(ctx);
1515 MQ_CTX_A __retVal__L = MqRouteResolve(ctx, ident, retnum);
1516 static __thread MK_NUM szret = 0;
1517 static __thread MqContextC* *ret = NULL;
1518 if (__retVal__L.size+1 > szret) {
1519 szret=__retVal__L.size*2+1;
1520 ret=(MqContextC**)MkSysRealloc(MK_ERROR_PANIC,ret,szret*sizeof(MqContextC*));
1521 }
1522 MK_NUM num;
1523 for (num=0; num<__retVal__L.size; num++) {
1524 ret[num] = MqContextC::MqContextC_ObjNew(MK_RT_CALL __retVal__L.data[num]);
1525 }
1526 ret[num] = NULL;
1527 return (MqContextC_A) {__retVal__L.size,ret};
1528 }
1529
1531 inline MqContextC_A MqContextC::RouteResolve (const std::string& ident, MK_NUM retnum) {
1532 MK_UNUSED auto ctx = getCTX();
1533 MkRtSetup_X(ctx);
1534 const MK_STRN ident_hdl = ident.c_str();
1535 MQ_CTX_A __retVal__L = MqRouteResolve(ctx, ident_hdl, retnum);
1536 static __thread MK_NUM szret = 0;
1537 static __thread MqContextC* *ret = NULL;
1538 if (__retVal__L.size+1 > szret) {
1539 szret=__retVal__L.size*2+1;
1540 ret=(MqContextC**)MkSysRealloc(MK_ERROR_PANIC,ret,szret*sizeof(MqContextC*));
1541 }
1542 MK_NUM num;
1543 for (num=0; num<__retVal__L.size; num++) {
1544 ret[num] = MqContextC::MqContextC_ObjNew(MK_RT_CALL __retVal__L.data[num]);
1545 }
1546 ret[num] = NULL;
1547 return (MqContextC_A) {__retVal__L.size,ret};
1548 }
1549
1551 inline void MqContextC::RouteTraverse (MK_STRN service, MkBufferListC* args) {
1552 MK_UNUSED auto ctx = getCTX();
1553 MkRtSetup_X(ctx);
1555 enum MkErrorE errVal = MqRouteTraverse(ctx, service, args_hdl);
1556 MkErrorC_Check(ctx, errVal);
1557 }
1558
1560 inline void MqContextC::RouteTraverse (MK_STRN service, const MkBufferListC& args) {
1561 MK_UNUSED auto ctx = getCTX();
1562 MkRtSetup_X(ctx);
1563 const MK_BAC args_hdl = MkBufferListC::getBFL(args);
1564 enum MkErrorE errVal = MqRouteTraverse(ctx, service, args_hdl);
1565 MkErrorC_Check(ctx, errVal);
1566 }
1567
1569 inline void MqContextC::RouteTraverse (const std::string& service, MkBufferListC* args) {
1570 MK_UNUSED auto ctx = getCTX();
1571 MkRtSetup_X(ctx);
1572 const MK_STRN service_hdl = service.c_str();
1574 enum MkErrorE errVal = MqRouteTraverse(ctx, service_hdl, args_hdl);
1575 MkErrorC_Check(ctx, errVal);
1576 }
1577
1579 inline void MqContextC::RouteTraverse (const std::string& service, const MkBufferListC& args) {
1580 MK_UNUSED auto ctx = getCTX();
1581 MkRtSetup_X(ctx);
1582 const MK_STRN service_hdl = service.c_str();
1583 const MK_BAC args_hdl = MkBufferListC::getBFL(args);
1584 enum MkErrorE errVal = MqRouteTraverse(ctx, service_hdl, args_hdl);
1585 MkErrorC_Check(ctx, errVal);
1586 }
1587
1588 // doc-key: MqContextC,MqContextC-RouteApi-Route,omo
1589
1592 MK_UNUSED auto ctx = getCTX();
1593 MkRtSetup_X(ctx);
1594 MK_STRN path_out;
1595 enum MkErrorE errVal = MqRouteGetPath(ctx, &path_out);
1596 MkErrorC_Check(ctx, errVal);
1597 return path_out;
1598 }
1599
1601 // MqContextC_RouteApi_Route_CC_API
1602
1606
1607 // doc-key: MqContextC,MqContextC-SendApi-Atom,om_
1608
1610 inline void MqContextC::SendBFL (const MkBufferListC* val) {
1611 MK_UNUSED auto ctx = getCTX();
1612 MkRtSetup_X(ctx);
1613 MK_BFLN val_hdl = MkBufferListC::getBFLN(val);
1614 enum MkErrorE errVal = MqSendBFL(ctx, val_hdl);
1615 MkErrorC_Check(ctx, errVal);
1616 }
1617
1619 inline void MqContextC::SendBFL (const MkBufferListC& val) {
1620 MK_UNUSED auto ctx = getCTX();
1621 MkRtSetup_X(ctx);
1622 const MK_BFLN val_hdl = MkBufferListC::getBFLN(val);
1623 enum MkErrorE errVal = MqSendBFL(ctx, val_hdl);
1624 MkErrorC_Check(ctx, errVal);
1625 }
1626
1628 inline void MqContextC::SendBIN (MK_BNP val) {
1629 MK_UNUSED auto ctx = getCTX();
1630 MkRtSetup_X(ctx);
1631 const MkBinaryR val_ref = MkBinaryCreate(val.first,val.second);
1632 enum MkErrorE errVal = MqSendBIN(ctx, val_ref);
1633 MkErrorC_Check(ctx, errVal);
1634 }
1635
1637 inline void MqContextC::SendBOL (MK_BOL val) {
1638 MK_UNUSED auto ctx = getCTX();
1639 MkRtSetup_X(ctx);
1640 enum MkErrorE errVal = MqSendBOL(ctx, (MK_BOL)(val?1:0));
1641 MkErrorC_Check(ctx, errVal);
1642 }
1643
1645 inline void MqContextC::SendBUF (const MkBufferC* val) {
1646 MK_UNUSED auto ctx = getCTX();
1647 MkRtSetup_X(ctx);
1648 MK_BUFN val_hdl = MkBufferC::getBUFN(val);
1649 enum MkErrorE errVal = MqSendBUF(ctx, val_hdl);
1650 MkErrorC_Check(ctx, errVal);
1651 }
1652
1654 inline void MqContextC::SendBUF (const MkBufferC& val) {
1655 MK_UNUSED auto ctx = getCTX();
1656 MkRtSetup_X(ctx);
1657 const MK_BUFN val_hdl = MkBufferC::getBUFN(val);
1658 enum MkErrorE errVal = MqSendBUF(ctx, val_hdl);
1659 MkErrorC_Check(ctx, errVal);
1660 }
1661
1664 MK_UNUSED auto ctx = getCTX();
1665 MkRtSetup_X(ctx);
1666 MK_BUSN val_hdl = MkBufferStreamC::getBUSN(val);
1667 enum MkErrorE errVal = MqSendBUS_FLAT(ctx, val_hdl);
1668 MkErrorC_Check(ctx, errVal);
1669 }
1670
1673 MK_UNUSED auto ctx = getCTX();
1674 MkRtSetup_X(ctx);
1675 const MK_BUSN val_hdl = MkBufferStreamC::getBUSN(val);
1676 enum MkErrorE errVal = MqSendBUS_FLAT(ctx, val_hdl);
1677 MkErrorC_Check(ctx, errVal);
1678 }
1679
1682 MK_UNUSED auto ctx = getCTX();
1683 MkRtSetup_X(ctx);
1684 const MkBinaryR val_ref = MkBinaryCreate(val.first,val.second);
1685 enum MkErrorE errVal = MqSendBinaryR(ctx, val_ref);
1686 MkErrorC_Check(ctx, errVal);
1687 }
1688
1690 inline void MqContextC::SendDBL (MK_DBL val) {
1691 MK_UNUSED auto ctx = getCTX();
1692 MkRtSetup_X(ctx);
1693 enum MkErrorE errVal = MqSendDBL(ctx, val);
1694 MkErrorC_Check(ctx, errVal);
1695 }
1696
1698 inline void MqContextC::SendFLT (MK_FLT val) {
1699 MK_UNUSED auto ctx = getCTX();
1700 MkRtSetup_X(ctx);
1701 enum MkErrorE errVal = MqSendFLT(ctx, val);
1702 MkErrorC_Check(ctx, errVal);
1703 }
1704
1706 inline void MqContextC::SendHDL (MK_HDL val) {
1707 MK_UNUSED auto ctx = getCTX();
1708 MkRtSetup_X(ctx);
1709 enum MkErrorE errVal = MqSendHDL(ctx, val);
1710 MkErrorC_Check(ctx, errVal);
1711 }
1712
1714 inline void MqContextC::SendI16 (MK_I16 val) {
1715 MK_UNUSED auto ctx = getCTX();
1716 MkRtSetup_X(ctx);
1717 enum MkErrorE errVal = MqSendI16(ctx, val);
1718 MkErrorC_Check(ctx, errVal);
1719 }
1720
1722 inline void MqContextC::SendI32 (MK_I32 val) {
1723 MK_UNUSED auto ctx = getCTX();
1724 MkRtSetup_X(ctx);
1725 enum MkErrorE errVal = MqSendI32(ctx, val);
1726 MkErrorC_Check(ctx, errVal);
1727 }
1728
1730 inline void MqContextC::SendI64 (MK_I64 val) {
1731 MK_UNUSED auto ctx = getCTX();
1732 MkRtSetup_X(ctx);
1733 enum MkErrorE errVal = MqSendI64(ctx, val);
1734 MkErrorC_Check(ctx, errVal);
1735 }
1736
1738 inline void MqContextC::SendI8 (MK_I8 val) {
1739 MK_UNUSED auto ctx = getCTX();
1740 MkRtSetup_X(ctx);
1741 enum MkErrorE errVal = MqSendI8(ctx, (MK_I8)(val));
1742 MkErrorC_Check(ctx, errVal);
1743 }
1744
1746 inline void MqContextC::SendLONG (MK_LONG val) {
1747 MK_UNUSED auto ctx = getCTX();
1748 MkRtSetup_X(ctx);
1749 enum MkErrorE errVal = MqSendLONG(ctx, val);
1750 MkErrorC_Check(ctx, errVal);
1751 }
1752
1754 inline void MqContextC::SendLTR (MQ_LTR transLId) {
1755 MK_UNUSED auto ctx = getCTX();
1756 MkRtSetup_X(ctx);
1757 enum MkErrorE errVal = MqSendLTR(ctx, transLId);
1758 MkErrorC_Check(ctx, errVal);
1759 }
1760
1762 inline void MqContextC::SendL_FLAT (const MkBufferListC* val) {
1763 MK_UNUSED auto ctx = getCTX();
1764 MkRtSetup_X(ctx);
1765 MK_BFLN val_hdl = MkBufferListC::getBFLN(val);
1766 enum MkErrorE errVal = MqSendL_FLAT(ctx, val_hdl);
1767 MkErrorC_Check(ctx, errVal);
1768 }
1769
1771 inline void MqContextC::SendL_FLAT (const MkBufferListC& val) {
1772 MK_UNUSED auto ctx = getCTX();
1773 MkRtSetup_X(ctx);
1774 const MK_BFLN val_hdl = MkBufferListC::getBFLN(val);
1775 enum MkErrorE errVal = MqSendL_FLAT(ctx, val_hdl);
1776 MkErrorC_Check(ctx, errVal);
1777 }
1778
1780 inline void MqContextC::SendSTR (MK_STRN val) {
1781 MK_UNUSED auto ctx = getCTX();
1782 MkRtSetup_X(ctx);
1783 enum MkErrorE errVal = MqSendSTR(ctx, val);
1784 MkErrorC_Check(ctx, errVal);
1785 }
1786
1788 inline void MqContextC::SendSTR (const std::string& val) {
1789 MK_UNUSED auto ctx = getCTX();
1790 MkRtSetup_X(ctx);
1791 const MK_STRN val_hdl = val.c_str();
1792 enum MkErrorE errVal = MqSendSTR(ctx, val_hdl);
1793 MkErrorC_Check(ctx, errVal);
1794 }
1795
1797 inline void MqContextC::SendStringR (const std::string& val) {
1798 MK_UNUSED auto ctx = getCTX();
1799 MkRtSetup_X(ctx);
1800 const MkStringR val_ref = MkStringCreate((MK_NUM)val.size(),val.c_str());
1801 enum MkErrorE errVal = MqSendStringR(ctx, val_ref);
1802 MkErrorC_Check(ctx, errVal);
1803 }
1804
1806 inline void MqContextC::SendV (MK_FST printfmt, ... ) {
1807 MK_UNUSED auto ctx = getCTX();
1808 MkRtSetup_X(ctx);
1809 va_list ap;
1810 va_start (ap, printfmt);
1811 enum MkErrorE errVal = MqSendVL(ctx, printfmt, ap);
1812 va_end (ap);
1813 MkErrorC_Check(ctx, errVal);
1814 }
1815
1817 inline void MqContextC::SendVL (MK_FST printfmt, va_list var_list) {
1818 MK_UNUSED auto ctx = getCTX();
1819 MkRtSetup_X(ctx);
1820 enum MkErrorE errVal = MqSendVL(ctx, printfmt, var_list);
1821 MkErrorC_Check(ctx, errVal);
1822 }
1823
1825 // MqContextC_SendApi_Atom_CC_API
1826
1830
1831 // doc-key: MqContextC,MqContextC-SendApi-Basics,om_
1832
1834 inline void MqContextC::SendEND (MQ_TOK token, MK_TIME_T timeout) {
1835 MK_UNUSED auto ctx = getCTX();
1836 MkRtSetup_X(ctx);
1837 enum MkErrorE errVal = MqSendEND(ctx, token, timeout);
1838 MkErrorC_Check(ctx, errVal);
1839 }
1840
1842 inline void MqContextC::SendEND (const std::string& token, MK_TIME_T timeout) {
1843 MK_UNUSED auto ctx = getCTX();
1844 MkRtSetup_X(ctx);
1845 const MK_STRN token_hdl = token.c_str();
1846 enum MkErrorE errVal = MqSendEND(ctx, token_hdl, timeout);
1847 MkErrorC_Check(ctx, errVal);
1848 }
1849
1851 inline void MqContextC::SendEND_AND_CALLBACK (MQ_TOK token, MqServiceCCB callback, MK_TIME_T timeout) {
1852 MK_UNUSED auto ctx = getCTX();
1853 MkRtSetup_X(ctx);
1854 auto callback_ptr = MqServiceCallbackC::Create(MK_RT_CALL callback, this);
1855 enum MkErrorE errVal = MqSendEND_AND_CALLBACK(ctx, token, MqServiceCallbackC::Call, callback_ptr, MqServiceCallbackC::Free, timeout);
1856 MkErrorC_Check(ctx, errVal);
1857 }
1858
1860 inline void MqContextC::SendEND_AND_CALLBACK (const std::string& token, MqServiceCCB callback, MK_TIME_T timeout) {
1861 MK_UNUSED auto ctx = getCTX();
1862 MkRtSetup_X(ctx);
1863 const MK_STRN token_hdl = token.c_str();
1864 auto callback_ptr = MqServiceCallbackC::Create(MK_RT_CALL callback, this);
1865 enum MkErrorE errVal = MqSendEND_AND_CALLBACK(ctx, token_hdl, MqServiceCallbackC::Call, callback_ptr, MqServiceCallbackC::Free, timeout);
1866 MkErrorC_Check(ctx, errVal);
1867 }
1868
1870 inline void MqContextC::SendEND_AND_CALLBACK (MQ_TOK token, MqServiceICB callback, MK_TIME_T timeout) {
1871 MK_UNUSED auto ctx = getCTX();
1872 MkRtSetup_X(ctx);
1873 auto callback_ptr = MqServiceCallbackC::Create(MK_RT_CALL callback, this);
1874 enum MkErrorE errVal = MqSendEND_AND_CALLBACK(ctx, token, MqServiceCallbackC::Call, callback_ptr, MqServiceCallbackC::Free, timeout);
1875 MkErrorC_Check(ctx, errVal);
1876 }
1877
1879 inline void MqContextC::SendEND_AND_CALLBACK (const std::string& token, MqServiceICB callback, MK_TIME_T timeout) {
1880 MK_UNUSED auto ctx = getCTX();
1881 MkRtSetup_X(ctx);
1882 const MK_STRN token_hdl = token.c_str();
1883 auto callback_ptr = MqServiceCallbackC::Create(MK_RT_CALL callback, this);
1884 enum MkErrorE errVal = MqSendEND_AND_CALLBACK(ctx, token_hdl, MqServiceCallbackC::Call, callback_ptr, MqServiceCallbackC::Free, timeout);
1885 MkErrorC_Check(ctx, errVal);
1886 }
1887
1889 inline void MqContextC::SendEND_AND_CALLBACK (MQ_TOK token, MqServiceIF* callback, MK_TIME_T timeout) {
1890 MK_UNUSED auto ctx = getCTX();
1891 MkRtSetup_X(ctx);
1892 auto callback_ptr = MqServiceCallbackC::Create(MK_RT_CALL callback, this);
1893 enum MkErrorE errVal = MqSendEND_AND_CALLBACK(ctx, token, MqServiceCallbackC::Call, callback_ptr, MqServiceCallbackC::Free, timeout);
1894 MkErrorC_Check(ctx, errVal);
1895 }
1896
1898 inline void MqContextC::SendEND_AND_CALLBACK (const std::string& token, MqServiceIF* callback, MK_TIME_T timeout) {
1899 MK_UNUSED auto ctx = getCTX();
1900 MkRtSetup_X(ctx);
1901 const MK_STRN token_hdl = token.c_str();
1902 auto callback_ptr = MqServiceCallbackC::Create(MK_RT_CALL callback, this);
1903 enum MkErrorE errVal = MqSendEND_AND_CALLBACK(ctx, token_hdl, MqServiceCallbackC::Call, callback_ptr, MqServiceCallbackC::Free, timeout);
1904 MkErrorC_Check(ctx, errVal);
1905 }
1906
1908 inline void MqContextC::SendEND_AND_SUB (MQ_TOK token, MqServiceCCB callback, MK_TIME_T timeout) {
1909 MK_UNUSED auto ctx = getCTX();
1910 MkRtSetup_X(ctx);
1911 auto callback_ptr = MqServiceCallbackC::Create(MK_RT_CALL callback, this);
1912 enum MkErrorE errVal = MqSendEND_AND_SUB(ctx, token, MqServiceCallbackC::Call, callback_ptr, MqServiceCallbackC::Free, timeout);
1913 MkErrorC_Check(ctx, errVal);
1914 }
1915
1917 inline void MqContextC::SendEND_AND_SUB (const std::string& token, MqServiceCCB callback, MK_TIME_T timeout) {
1918 MK_UNUSED auto ctx = getCTX();
1919 MkRtSetup_X(ctx);
1920 const MK_STRN token_hdl = token.c_str();
1921 auto callback_ptr = MqServiceCallbackC::Create(MK_RT_CALL callback, this);
1922 enum MkErrorE errVal = MqSendEND_AND_SUB(ctx, token_hdl, MqServiceCallbackC::Call, callback_ptr, MqServiceCallbackC::Free, timeout);
1923 MkErrorC_Check(ctx, errVal);
1924 }
1925
1927 inline void MqContextC::SendEND_AND_SUB (MQ_TOK token, MqServiceICB callback, MK_TIME_T timeout) {
1928 MK_UNUSED auto ctx = getCTX();
1929 MkRtSetup_X(ctx);
1930 auto callback_ptr = MqServiceCallbackC::Create(MK_RT_CALL callback, this);
1931 enum MkErrorE errVal = MqSendEND_AND_SUB(ctx, token, MqServiceCallbackC::Call, callback_ptr, MqServiceCallbackC::Free, timeout);
1932 MkErrorC_Check(ctx, errVal);
1933 }
1934
1936 inline void MqContextC::SendEND_AND_SUB (const std::string& token, MqServiceICB callback, MK_TIME_T timeout) {
1937 MK_UNUSED auto ctx = getCTX();
1938 MkRtSetup_X(ctx);
1939 const MK_STRN token_hdl = token.c_str();
1940 auto callback_ptr = MqServiceCallbackC::Create(MK_RT_CALL callback, this);
1941 enum MkErrorE errVal = MqSendEND_AND_SUB(ctx, token_hdl, MqServiceCallbackC::Call, callback_ptr, MqServiceCallbackC::Free, timeout);
1942 MkErrorC_Check(ctx, errVal);
1943 }
1944
1946 inline void MqContextC::SendEND_AND_SUB (MQ_TOK token, MqServiceIF* callback, MK_TIME_T timeout) {
1947 MK_UNUSED auto ctx = getCTX();
1948 MkRtSetup_X(ctx);
1949 auto callback_ptr = MqServiceCallbackC::Create(MK_RT_CALL callback, this);
1950 enum MkErrorE errVal = MqSendEND_AND_SUB(ctx, token, MqServiceCallbackC::Call, callback_ptr, MqServiceCallbackC::Free, timeout);
1951 MkErrorC_Check(ctx, errVal);
1952 }
1953
1955 inline void MqContextC::SendEND_AND_SUB (const std::string& token, MqServiceIF* callback, MK_TIME_T timeout) {
1956 MK_UNUSED auto ctx = getCTX();
1957 MkRtSetup_X(ctx);
1958 const MK_STRN token_hdl = token.c_str();
1959 auto callback_ptr = MqServiceCallbackC::Create(MK_RT_CALL callback, this);
1960 enum MkErrorE errVal = MqSendEND_AND_SUB(ctx, token_hdl, MqServiceCallbackC::Call, callback_ptr, MqServiceCallbackC::Free, timeout);
1961 MkErrorC_Check(ctx, errVal);
1962 }
1963
1965 inline void MqContextC::SendEND_AND_TRANSACTION (MQ_TOK token, MQ_TOK callback, MK_TIME_T timeout) {
1966 MK_UNUSED auto ctx = getCTX();
1967 MkRtSetup_X(ctx);
1968 enum MkErrorE errVal = MqSendEND_AND_TRANSACTION(ctx, token, callback, timeout);
1969 MkErrorC_Check(ctx, errVal);
1970 }
1971
1973 inline void MqContextC::SendEND_AND_TRANSACTION (const std::string& token, const std::string& callback, MK_TIME_T timeout) {
1974 MK_UNUSED auto ctx = getCTX();
1975 MkRtSetup_X(ctx);
1976 const MK_STRN token_hdl = token.c_str();
1977 const MK_STRN callback_hdl = callback.c_str();
1978 enum MkErrorE errVal = MqSendEND_AND_TRANSACTION(ctx, token_hdl, callback_hdl, timeout);
1979 MkErrorC_Check(ctx, errVal);
1980 }
1981
1983 inline void MqContextC::SendEND_AND_WAIT (MQ_TOK token, MK_TIME_T timeout) {
1984 MK_UNUSED auto ctx = getCTX();
1985 MkRtSetup_X(ctx);
1986 enum MkErrorE errVal = MqSendEND_AND_WAIT(ctx, token, timeout);
1987 MkErrorC_Check(ctx, errVal);
1988 }
1989
1991 inline void MqContextC::SendEND_AND_WAIT (const std::string& token, MK_TIME_T timeout) {
1992 MK_UNUSED auto ctx = getCTX();
1993 MkRtSetup_X(ctx);
1994 const MK_STRN token_hdl = token.c_str();
1995 enum MkErrorE errVal = MqSendEND_AND_WAIT(ctx, token_hdl, timeout);
1996 MkErrorC_Check(ctx, errVal);
1997 }
1998
2000 inline void MqContextC::SendSTART () {
2001 MK_UNUSED auto ctx = getCTX();
2002 MkRtSetup_X(ctx);
2003 enum MkErrorE errVal = MqSendSTART(ctx);
2004 MkErrorC_Check(ctx, errVal);
2005 }
2006
2008 inline void MqContextC::SendSYNC () {
2009 MK_UNUSED auto ctx = getCTX();
2010 MkRtSetup_X(ctx);
2011 enum MkErrorE errVal = MqSendSYNC(ctx);
2012 MkErrorC_Check(ctx, errVal);
2013 }
2014
2016 // MqContextC_SendApi_Basics_CC_API
2017
2021
2022 // doc-key: MqContextC,MqContextC-SendApi-Block,om_
2023
2025 inline void MqContextC::SendL_END () {
2026 MK_UNUSED auto ctx = getCTX();
2027 MkRtSetup_X(ctx);
2028 enum MkErrorE errVal = MqSendL_END(ctx);
2029 MkErrorC_Check(ctx, errVal);
2030 }
2031
2034 MK_UNUSED auto ctx = getCTX();
2035 MkRtSetup_X(ctx);
2036 enum MkErrorE errVal = MqSendL_START(ctx);
2037 MkErrorC_Check(ctx, errVal);
2038 }
2039
2041 inline void MqContextC::SendT_END () {
2042 MK_UNUSED auto ctx = getCTX();
2043 MkRtSetup_X(ctx);
2044 enum MkErrorE errVal = MqSendT_END(ctx);
2045 MkErrorC_Check(ctx, errVal);
2046 }
2047
2050 MK_UNUSED auto ctx = getCTX();
2051 MkRtSetup_X(ctx);
2052 enum MkErrorE errVal = MqSendT_START(ctx);
2053 MkErrorC_Check(ctx, errVal);
2054 }
2055
2057 // MqContextC_SendApi_Block_CC_API
2058
2062
2063 // doc-key: MqContextC,MqContextC-SendApi-Return,om_
2064
2066 inline void MqContextC::SendERROR () {
2067 MK_UNUSED auto ctx = getCTX();
2068 MkRtSetup_X(ctx);
2069 enum MkErrorE errVal = MqSendERROR(ctx);
2070 MkErrorC_Check(ctx, errVal);
2071 }
2072
2074 inline void MqContextC::SendRETURN () {
2075 MK_UNUSED auto ctx = getCTX();
2076 MkRtSetup_X(ctx);
2077 enum MkErrorE errVal = MqSendRETURN(ctx);
2078 MkErrorC_Check(ctx, errVal);
2079 }
2080
2083 MK_UNUSED auto ctx = getCTX();
2084 MkRtSetup_X(ctx);
2085 enum MkErrorE errVal = MqSendRETURN_SUB(ctx);
2086 MkErrorC_Check(ctx, errVal);
2087 }
2088
2090 // MqContextC_SendApi_Return_CC_API
2091
2095
2096 // doc-key: MqContextC,MqContextC-ServiceApi-Service,om_
2097
2099 inline void MqContextC::ServiceCreate (MQ_TOK token, MqServiceCCB callback) {
2100 MK_UNUSED auto ctx = getCTX();
2101 MkRtSetup_X(ctx);
2102 auto callback_ptr = MqServiceCallbackC::Create(MK_RT_CALL callback, this);
2103 enum MkErrorE errVal = MqServiceCreate(ctx, token, MqServiceCallbackC::Call, callback_ptr, MqServiceCallbackC::Free, NULL);
2104 MkErrorC_Check(ctx, errVal);
2105 }
2106
2108 inline void MqContextC::ServiceCreate (const std::string& token, MqServiceCCB callback) {
2109 MK_UNUSED auto ctx = getCTX();
2110 MkRtSetup_X(ctx);
2111 const MK_STRN token_hdl = token.c_str();
2112 auto callback_ptr = MqServiceCallbackC::Create(MK_RT_CALL callback, this);
2113 enum MkErrorE errVal = MqServiceCreate(ctx, token_hdl, MqServiceCallbackC::Call, callback_ptr, MqServiceCallbackC::Free, NULL);
2114 MkErrorC_Check(ctx, errVal);
2115 }
2116
2118 inline void MqContextC::ServiceCreate (MQ_TOK token, MqServiceICB callback) {
2119 MK_UNUSED auto ctx = getCTX();
2120 MkRtSetup_X(ctx);
2121 auto callback_ptr = MqServiceCallbackC::Create(MK_RT_CALL callback, this);
2122 enum MkErrorE errVal = MqServiceCreate(ctx, token, MqServiceCallbackC::Call, callback_ptr, MqServiceCallbackC::Free, NULL);
2123 MkErrorC_Check(ctx, errVal);
2124 }
2125
2127 inline void MqContextC::ServiceCreate (const std::string& token, MqServiceICB callback) {
2128 MK_UNUSED auto ctx = getCTX();
2129 MkRtSetup_X(ctx);
2130 const MK_STRN token_hdl = token.c_str();
2131 auto callback_ptr = MqServiceCallbackC::Create(MK_RT_CALL callback, this);
2132 enum MkErrorE errVal = MqServiceCreate(ctx, token_hdl, MqServiceCallbackC::Call, callback_ptr, MqServiceCallbackC::Free, NULL);
2133 MkErrorC_Check(ctx, errVal);
2134 }
2135
2137 inline void MqContextC::ServiceCreate (MQ_TOK token, MqServiceIF* callback) {
2138 MK_UNUSED auto ctx = getCTX();
2139 MkRtSetup_X(ctx);
2140 auto callback_ptr = MqServiceCallbackC::Create(MK_RT_CALL callback, this);
2141 enum MkErrorE errVal = MqServiceCreate(ctx, token, MqServiceCallbackC::Call, callback_ptr, MqServiceCallbackC::Free, NULL);
2142 MkErrorC_Check(ctx, errVal);
2143 }
2144
2146 inline void MqContextC::ServiceCreate (const std::string& token, MqServiceIF* callback) {
2147 MK_UNUSED auto ctx = getCTX();
2148 MkRtSetup_X(ctx);
2149 const MK_STRN token_hdl = token.c_str();
2150 auto callback_ptr = MqServiceCallbackC::Create(MK_RT_CALL callback, this);
2151 enum MkErrorE errVal = MqServiceCreate(ctx, token_hdl, MqServiceCallbackC::Call, callback_ptr, MqServiceCallbackC::Free, NULL);
2152 MkErrorC_Check(ctx, errVal);
2153 }
2154
2156 inline void MqContextC::ServiceDelete (MQ_TOK token) {
2157 MK_UNUSED auto ctx = getCTX();
2158 MkRtSetup_X(ctx);
2159 enum MkErrorE errVal = MqServiceDelete(ctx, token);
2160 MkErrorC_Check(ctx, errVal);
2161 }
2162
2164 inline void MqContextC::ServiceDelete (const std::string& token) {
2165 MK_UNUSED auto ctx = getCTX();
2166 MkRtSetup_X(ctx);
2167 const MK_STRN token_hdl = token.c_str();
2168 enum MkErrorE errVal = MqServiceDelete(ctx, token_hdl);
2169 MkErrorC_Check(ctx, errVal);
2170 }
2171
2174 MK_UNUSED auto ctx = getCTX();
2175 MkRtSetup_X(ctx);
2176 MK_BOOL __retVal__L = MqServiceIsTransaction(ctx);
2177 return __retVal__L;
2178 }
2179
2182 MK_UNUSED auto ctx = getCTX();
2183 MkRtSetup_X(ctx);
2184 enum MkErrorE errVal = MqServiceProxy(ctx, token, id);
2185 MkErrorC_Check(ctx, errVal);
2186 }
2187
2189 inline void MqContextC::ServiceProxy (const std::string& token, MQ_SLAVE_ID id) {
2190 MK_UNUSED auto ctx = getCTX();
2191 MkRtSetup_X(ctx);
2192 const MK_STRN token_hdl = token.c_str();
2193 enum MkErrorE errVal = MqServiceProxy(ctx, token_hdl, id);
2194 MkErrorC_Check(ctx, errVal);
2195 }
2196
2198 inline void MqContextC::ServiceProxyCtx (MQ_TOK token, MqContextC* target) {
2199 MK_UNUSED auto ctx = getCTX();
2200 MkRtSetup_X(ctx);
2201 MQ_CTX target_hdl = MqContextC::getCTX(target);
2202 enum MkErrorE errVal = MqServiceProxyCtx(ctx, token, target_hdl);
2203 MkErrorC_Check(ctx, errVal);
2204 }
2205
2207 inline void MqContextC::ServiceProxyCtx (MQ_TOK token, const MqContextC& target) {
2208 MK_UNUSED auto ctx = getCTX();
2209 MkRtSetup_X(ctx);
2210 const MQ_CTX target_hdl = MqContextC::getCTX(target);
2211 enum MkErrorE errVal = MqServiceProxyCtx(ctx, token, target_hdl);
2212 MkErrorC_Check(ctx, errVal);
2213 }
2214
2216 inline void MqContextC::ServiceProxyCtx (const std::string& token, MqContextC* target) {
2217 MK_UNUSED auto ctx = getCTX();
2218 MkRtSetup_X(ctx);
2219 const MK_STRN token_hdl = token.c_str();
2220 MQ_CTX target_hdl = MqContextC::getCTX(target);
2221 enum MkErrorE errVal = MqServiceProxyCtx(ctx, token_hdl, target_hdl);
2222 MkErrorC_Check(ctx, errVal);
2223 }
2224
2226 inline void MqContextC::ServiceProxyCtx (const std::string& token, const MqContextC& target) {
2227 MK_UNUSED auto ctx = getCTX();
2228 MkRtSetup_X(ctx);
2229 const MK_STRN token_hdl = token.c_str();
2230 const MQ_CTX target_hdl = MqContextC::getCTX(target);
2231 enum MkErrorE errVal = MqServiceProxyCtx(ctx, token_hdl, target_hdl);
2232 MkErrorC_Check(ctx, errVal);
2233 }
2234
2237 MK_UNUSED auto ctx = getCTX();
2238 MkRtSetup_X(ctx);
2239 MQ_CTX target_hdl = MqContextC::getCTX(target);
2240 MK_BOOL __retVal__L = MqServiceProxyCtxExists(ctx, token, target_hdl);
2241 return __retVal__L;
2242 }
2243
2246 MK_UNUSED auto ctx = getCTX();
2247 MkRtSetup_X(ctx);
2248 const MQ_CTX target_hdl = MqContextC::getCTX(target);
2249 MK_BOOL __retVal__L = MqServiceProxyCtxExists(ctx, token, target_hdl);
2250 return __retVal__L;
2251 }
2252
2254 inline MK_BOOL MqContextC::ServiceProxyCtxExists (const std::string& token, MqContextC* target) {
2255 MK_UNUSED auto ctx = getCTX();
2256 MkRtSetup_X(ctx);
2257 const MK_STRN token_hdl = token.c_str();
2258 MQ_CTX target_hdl = MqContextC::getCTX(target);
2259 MK_BOOL __retVal__L = MqServiceProxyCtxExists(ctx, token_hdl, target_hdl);
2260 return __retVal__L;
2261 }
2262
2264 inline MK_BOOL MqContextC::ServiceProxyCtxExists (const std::string& token, const MqContextC& target) {
2265 MK_UNUSED auto ctx = getCTX();
2266 MkRtSetup_X(ctx);
2267 const MK_STRN token_hdl = token.c_str();
2268 const MQ_CTX target_hdl = MqContextC::getCTX(target);
2269 MK_BOOL __retVal__L = MqServiceProxyCtxExists(ctx, token_hdl, target_hdl);
2270 return __retVal__L;
2271 }
2272
2275 MK_UNUSED auto ctx = getCTX();
2276 MkRtSetup_X(ctx);
2277 enum MkErrorE errVal = MqServiceProxyRoundRobin(ctx, token, ident);
2278 MkErrorC_Check(ctx, errVal);
2279 }
2280
2282 inline void MqContextC::ServiceProxyRoundRobin (const std::string& token, const std::string& ident) {
2283 MK_UNUSED auto ctx = getCTX();
2284 MkRtSetup_X(ctx);
2285 const MK_STRN token_hdl = token.c_str();
2286 const MK_STRN ident_hdl = ident.c_str();
2287 enum MkErrorE errVal = MqServiceProxyRoundRobin(ctx, token_hdl, ident_hdl);
2288 MkErrorC_Check(ctx, errVal);
2289 }
2290
2293 MK_UNUSED auto ctx = getCTX();
2294 MkRtSetup_X(ctx);
2295 enum MkErrorE errVal = MqServiceStorage(ctx, token);
2296 MkErrorC_Check(ctx, errVal);
2297 }
2298
2300 inline void MqContextC::ServiceStorage (const std::string& token) {
2301 MK_UNUSED auto ctx = getCTX();
2302 MkRtSetup_X(ctx);
2303 const MK_STRN token_hdl = token.c_str();
2304 enum MkErrorE errVal = MqServiceStorage(ctx, token_hdl);
2305 MkErrorC_Check(ctx, errVal);
2306 }
2307
2310 MK_UNUSED auto ctx = getCTX();
2311 MkRtSetup_X(ctx);
2312 MK_BOOL __retVal__L = MqServiceTokenCheck(ctx, token);
2313 return __retVal__L;
2314 }
2315
2317 inline MK_BOOL MqContextC::ServiceTokenCheck (const std::string& token) {
2318 MK_UNUSED auto ctx = getCTX();
2319 MkRtSetup_X(ctx);
2320 const MK_STRN token_hdl = token.c_str();
2321 MK_BOOL __retVal__L = MqServiceTokenCheck(ctx, token_hdl);
2322 return __retVal__L;
2323 }
2324
2327 MK_UNUSED auto ctx = getCTX();
2328 MkRtSetup_X(ctx);
2329 MK_BOOL __retVal__L = MqServiceTokenExists(ctx, token);
2330 return __retVal__L;
2331 }
2332
2334 inline MK_BOOL MqContextC::ServiceTokenExists (const std::string& token) {
2335 MK_UNUSED auto ctx = getCTX();
2336 MkRtSetup_X(ctx);
2337 const MK_STRN token_hdl = token.c_str();
2338 MK_BOOL __retVal__L = MqServiceTokenExists(ctx, token_hdl);
2339 return __retVal__L;
2340 }
2341
2344 MK_UNUSED auto ctx = getCTX();
2345 MkRtSetup_X(ctx);
2346 MQ_TOK __retVal__L = MqServiceTokenGet(ctx);
2347 return __retVal__L;
2348 }
2349
2351 // MqContextC_ServiceApi_Service_CC_API
2352
2356
2357 // doc-key: MqContextC,MqContextC-SlaveApi-Slave,oc_
2358
2361 MK_UNUSED auto ctx = getCTX();
2362 MkRtSetup_X(ctx);
2363 MQ_CTX __retVal__L = MqSlaveGetMaster(ctx);
2364 return MqContextC::MqContextC_ObjNew(MK_RT_CALL __retVal__L);
2365 }
2366
2367 // doc-key: MqContextC,MqContextC-SlaveApi-Slave,oco
2368
2371 MK_UNUSED auto ctx = getCTX();
2372 MkRtSetup_X(ctx);
2373 MQ_CTX ctx_out;
2374 enum MkErrorE errVal = MqSlaveGet(ctx, id, &ctx_out);
2375 MkErrorC_Check(ctx, errVal);
2377 }
2378
2381 MK_UNUSED auto ctx = getCTX();
2382 MkRtSetup_X(ctx);
2383 MQ_CTX ctx_out;
2384 enum MkErrorE errVal = MqSlaveGetFilter(ctx, &ctx_out);
2385 MkErrorC_Check(ctx, errVal);
2387 }
2388
2391 MK_UNUSED auto ctx = getCTX();
2392 MkRtSetup_X(ctx);
2393 MQ_CTX ctx_out;
2394 enum MkErrorE errVal = MqSlaveGetProxy(ctx, id, &ctx_out);
2395 MkErrorC_Check(ctx, errVal);
2397 }
2398
2399 // doc-key: MqContextC,MqContextC-SlaveApi-Slave,om_
2400
2403 MK_UNUSED auto ctx = getCTXN();
2404 MkRtSetup_X(ctx);
2405 MK_BOOL __retVal__L = MqSlaveCheck(ctx, id);
2406 return __retVal__L;
2407 }
2408
2411 MK_UNUSED auto ctx = getCTX();
2412 MkRtSetup_X(ctx);
2413 MQ_CTX slave_hdl = MqContextC::getCTX(slave);
2414 enum MkErrorE errVal = MqSlaveCreate(ctx, id, slave_hdl);
2415 MkErrorC_Check(ctx, errVal);
2416 }
2417
2419 inline void MqContextC::SlaveCreate (MQ_SLAVE_ID id, const MqContextC& slave) {
2420 MK_UNUSED auto ctx = getCTX();
2421 MkRtSetup_X(ctx);
2422 const MQ_CTX slave_hdl = MqContextC::getCTX(slave);
2423 enum MkErrorE errVal = MqSlaveCreate(ctx, id, slave_hdl);
2424 MkErrorC_Check(ctx, errVal);
2425 }
2426
2429 MK_UNUSED auto ctx = getCTX();
2430 MkRtSetup_X(ctx);
2431 enum MkErrorE errVal = MqSlaveDelete(ctx, id);
2432 MkErrorC_Check(ctx, errVal);
2433 }
2434
2437 MK_UNUSED auto ctx = getCTXN();
2438 MkRtSetup_X(ctx);
2439 MK_BOOL __retVal__L = MqSlaveIs(ctx);
2440 return __retVal__L;
2441 }
2442
2445 MK_UNUSED auto ctx = getCTX();
2446 MkRtSetup_X(ctx);
2448 enum MkErrorE errVal = MqSlaveWorker(ctx, id, fct, args_hdl);
2449 MkErrorC_Check(ctx, errVal);
2450 }
2451
2453 // MqContextC_SlaveApi_Slave_CC_API
2454
2458
2459 // doc-key: MqContextC,MqContextC-StorageApi-Storage,oci
2460
2462 inline MQ_LTR MqContextC::StorageDelete (MQ_LTR *transLIdP_inout) {
2463 MK_UNUSED auto ctx = getCTX();
2464 MkRtSetup_X(ctx);
2465 MQ_LTR transLIdP_inout_val = transLIdP_inout == NULL ? 0 : (MQ_LTR)(*transLIdP_inout);
2466 enum MkErrorE errVal = MqStorageDelete(ctx, &transLIdP_inout_val);
2467 if (transLIdP_inout != NULL) {*transLIdP_inout = (MQ_LTR)(transLIdP_inout_val);}
2468 MkErrorC_Check(ctx, errVal);
2469 return transLIdP_inout_val;
2470 }
2471
2473 inline MQ_LTR MqContextC::StorageImport (MQ_LTR *transLIdP_inout) {
2474 MK_UNUSED auto ctx = getCTX();
2475 MkRtSetup_X(ctx);
2476 MQ_LTR transLIdP_inout_val = transLIdP_inout == NULL ? 0 : (MQ_LTR)(*transLIdP_inout);
2477 enum MkErrorE errVal = MqStorageImport(ctx, &transLIdP_inout_val);
2478 if (transLIdP_inout != NULL) {*transLIdP_inout = (MQ_LTR)(transLIdP_inout_val);}
2479 MkErrorC_Check(ctx, errVal);
2480 return transLIdP_inout_val;
2481 }
2482
2483 // doc-key: MqContextC,MqContextC-StorageApi-Storage,om_
2484
2487 MK_UNUSED auto ctx = getCTX();
2488 MkRtSetup_X(ctx);
2489 enum MkErrorE errVal = MqStorageClose(ctx);
2490 MkErrorC_Check(ctx, errVal);
2491 }
2492
2494 inline void MqContextC::StorageDecrRef (MQ_LTR transLId) {
2495 MK_UNUSED auto ctx = getCTX();
2496 MkRtSetup_X(ctx);
2497 enum MkErrorE errVal = MqStorageDecrRef(ctx, transLId);
2498 MkErrorC_Check(ctx, errVal);
2499 }
2500
2502 inline void MqContextC::StorageIncrRef (MQ_LTR transLId) {
2503 MK_UNUSED auto ctx = getCTX();
2504 MkRtSetup_X(ctx);
2505 enum MkErrorE errVal = MqStorageIncrRef(ctx, transLId);
2506 MkErrorC_Check(ctx, errVal);
2507 }
2508
2510 inline void MqContextC::StorageLog (MK_STRN callfunc) {
2511 MK_UNUSED auto ctx = getCTX();
2512 MkRtSetup_X(ctx);
2513 if (callfunc == NULL) {callfunc = __builtin_FUNCTION();}
2514 enum MkErrorE errVal = MqStorageLog(ctx, callfunc);
2515 MkErrorC_Check(ctx, errVal);
2516 }
2517
2519 inline void MqContextC::StorageOpen (MK_STRN storageFile) {
2520 MK_UNUSED auto ctx = getCTX();
2521 MkRtSetup_X(ctx);
2522 enum MkErrorE errVal = MqStorageOpen(ctx, storageFile);
2523 MkErrorC_Check(ctx, errVal);
2524 }
2525
2527 inline void MqContextC::StorageOpen (const std::string& storageFile) {
2528 MK_UNUSED auto ctx = getCTX();
2529 MkRtSetup_X(ctx);
2530 const MK_STRN storageFile_hdl = storageFile.c_str();
2531 enum MkErrorE errVal = MqStorageOpen(ctx, storageFile_hdl);
2532 MkErrorC_Check(ctx, errVal);
2533 }
2534
2535 // doc-key: MqContextC,MqContextC-StorageApi-Storage,omo
2536
2539 MK_UNUSED auto ctx = getCTX();
2540 MkRtSetup_X(ctx);
2541 MQ_LTR cnt_out;
2542 enum MkErrorE errVal = MqStorageCount(ctx, &cnt_out);
2543 MkErrorC_Check(ctx, errVal);
2544 return cnt_out;
2545 }
2546
2549 MK_UNUSED auto ctx = getCTX();
2550 MkRtSetup_X(ctx);
2551 MK_I32 cnt_out;
2552 enum MkErrorE errVal = MqStorageErrCnt(ctx, transLId, &cnt_out);
2553 MkErrorC_Check(ctx, errVal);
2554 return cnt_out;
2555 }
2556
2559 MK_UNUSED auto ctx = getCTX();
2560 MkRtSetup_X(ctx);
2561 MQ_LTR ltid_out;
2562 enum MkErrorE errVal = MqStorageExport(ctx, &ltid_out);
2563 MkErrorC_Check(ctx, errVal);
2564 return ltid_out;
2565 }
2566
2568 inline std::tuple<MqContextC*,MQ_LTR> MqContextC::StorageResolve () {
2569 MK_UNUSED auto ctx = getCTX();
2570 MkRtSetup_X(ctx);
2571 MQ_CTX otherCtxP_out;
2572 MQ_LTR otherLIdP_out;
2573 enum MkErrorE errVal = MqStorageResolve(ctx, &otherCtxP_out, &otherLIdP_out);
2574 MkErrorC_Check(ctx, errVal);
2575 std::tuple<MqContextC*,MQ_LTR> __retVal__L = {MqContextC::MqContextC_ObjNew(MK_RT_CALL otherCtxP_out),otherLIdP_out};
2576 return __retVal__L;
2577 }
2578
2580 // MqContextC_StorageApi_Storage_CC_API
2581
2585
2586 // doc-key: MqContextC,MqContextC-TOR,sCc
2587
2591 MQ_CTX tmpl_hdl = MqContextC::getCTX__null_allow(tmpl);
2592 MQ_CTX __retVal__L = MqContextCreate(NULL, tmpl_hdl);
2593 if (__retVal__L == NULL) {
2594 throw MkInitError("MqContextC::CTOR");
2595 }
2596 return (MK_OBJ)__retVal__L;
2597 }
2598
2602 MQ_CTX tmpl_hdl = MqContextC::getCTX__null_allow(tmpl);
2603 MQ_CTX __retVal__L = MqContextCreate(NULL, tmpl_hdl);
2604 if (__retVal__L == NULL) {
2605 throw MkInitError("MqContextC::Create");
2606 }
2607 return MqContextC::MqContextC_ObjCreate(MK_RT_CALL __retVal__L);
2608 }
2609
2611 // MqContextC_TOR_CC_API
2612
2613 // END-MqContextC - created by 'cc_MqC.tcl -i NHI1_HOME/theLink/c/gen/c_mqmsgque.meta' - DO NOT change
2614
2619 MQ_CTX tmpl_hdl = MqContextC::getCTX__null_allow(tmpl);
2620 MQ_CTX __retVal__L = MqContextCreate(typ, tmpl_hdl);
2621 if (__retVal__L == NULL) {
2622 throw MkInitError("MqContextC::CTOR");
2623 }
2624 return (MK_OBJ)__retVal__L;
2625 }
2626
2627} // END - namespace "ccmqmsgque"
MqCall_cc.hh - 17 Nov 2024 - aotto1968.
implements the ccmqmsgque API object: ConfigSetBgError
PUBLIC data structure for the ccmqmsgque-specific-data → C-API: libmqmsgque::MqContextS
MqDumpC - the class known as dmp or dump is used to export a ccmqmsgque data package as binary … ...
Definition MqDumpC_cc.hh:27
implements the ccmqmsgque API object: ConfigSetEvent
data used to define a factory → C-API: libmqmsgque::MqFactoryS
implements the ccmqmsgque API object: ConfigSetServerCleanup
implements the ccmqmsgque API object: ConfigSetServerSetup
Callback for a Service.
static MkBufferC * MkBufferC_ObjNew(MK_RT_ARGS MK_BUF hdl)
MK_BUF getBUF() const
MK_BUFN getBUFN() const
MK_BUF getBUF__null_allow() const
MK_BFLN getBFLN() const
static MkBufferListC * MkBufferListC_ObjNew(MK_RT_ARGS MK_BFL hdl)
MK_BFL getBFL__null_allow() const
static MkErrorC * MkErrorC_ObjNew(MK_RT_ARGS MK_ERR hdl)
#define MK_ERROR_PANIC
static MkBinaryR MkBinaryCreate(MK_SIZE size, MK_BINN data)
#define MK_DECL
#define MK_UNUSED
static MkStringR MkStringCreate(MK_NUM len, MK_STRN str)
double MK_DBL
unsigned char MK_BOL
signed char MK_I8
signed long long MK_I64
MK_STRB const * MK_FST
int32_t MK_HDL
time_t MK_TIME_T
int32_t MK_NUM
signed short int MK_I16
signed int MK_I32
MK_PTRB * MK_PTR
const MK_STRB * MK_STRN
void ErrorCheck(enum MkErrorE err, MK_STRN const caller=__builtin_FUNCTION(), MK_I32 const line=__builtin_LINE()) const
MK_OBJN getOBJN__null_allow() const
MK_OBJN getOBJN() const
MK_PTR MkSysRealloc(MK_OBJN fmtobj, MK_PTR const buf, size_t const size)
static MK_I32 MkRuntimeGetDebug(void)
#define MkRtSetup_XN(x)
#define MK_RT_CALL
#define MkRtSetup_X(x)
#define MK_RT_ARGS
#define MkRtSetup_NULL
MQ_CTX getCTX() const
return the LibMsgqueObject from current MqContextC instance
MQ_CTXN getCTXN__null_allow() const
(const) return the LibMsgqueObject from current MqContextC instance
MQ_CTX getCTX__null_allow() const
return the LibMsgqueObject from current MqContextC instance
MQ_CTXN getCTXN() const
(const) return the LibMsgqueObject from current MqContextC instance
static MqContextC * MqContextC_ObjNew(MK_RT_ARGS MQ_CTX hdl)
return MqContextC from LibMsgqueObject
static MK_PTR MqContextC_selfCreate(MK_RT_ARGS MK_OBJ obj, MK_PTR const env)
static MqContextC * MqContextC_ObjCreate(MK_RT_ARGS MQ_CTX hdl)
static MK_ERR MqContextErrorFORMAT(MQ_CTXN const fmtobj)
helper used to access MkErrorDEFAULT from MqContextC
void ClassIdentSet(MK_STRN ident)
C++: ctx.ClassIdentSet(MK_STRN ident) → C-API link the MqContextC to a new MqFactoryC identifie...
void ClassFactorySet(MqFactoryC *item)
C++: ctx.ClassFactorySet(MqFactoryC* item) → C-API link the MqContextC to a new MqFactoryC
MK_STRN ClassOriginalIdentGet() const
C++: MK_STRN ctx.ClassOriginalIdentGet() → C-API get the libmqmsgque::MqFactoryS::originalIdent...
MK_STRN ClassIdentGet() const
C++: MK_STRN ctx.ClassIdentGet() → C-API get the application-identification …
MqFactoryC * ClassFactoryGet() const
C++: MqFactoryC* ctx.ClassFactoryGet() → C-API get the MqFactoryC used by the MqContextC
#define MqClassFactorySet(...)
MK_STRN MqClassIdentGet(MQ_CTXN const ctx)
get the application-identification …
#define MqClassIdentSet(...)
MQ_FCT const MqClassFactoryGet(MQ_CTXN const ctx)
get the MqFactoryC used by the MqContextC
MK_STRN MqClassOriginalIdentGet(MQ_CTXN const ctx)
get the libmqmsgque::MqFactoryS::originalIdent from the MqContextC
static MqContextC * HandleResolve(MK_HDL netHdl)
C++: [static] MqContextC* MqContextC::HandleResolve(MK_HDL netHdl) → C-API Handle-Resolve-Slot -...
MqContextC * Prev()
C++: MqContextC* ctx.Prev() → C-API get previous instance from linked-list of MqContextS type
static MqContextC * Instances()
C++: [static] MqContextC* MqContextC::Instances() → C-API get head-instance from linked-list of ...
MqContextC * Next()
C++: MqContextC* ctx.Next() → C-API get next instance from linked-list of MqContextS type
static MqContextC * GetNull()
C++: [static] MqContextC* MqContextC::GetNull() → C-API Null-Slot - return a MqContextC typed NU...
#define MqContextHandleResolve(...)
static MQ_CTX MqContextGetNull(void)
Null-Slot - return a MqContextC typed NULL instance …
#define MqContextInstances()
static MQ_CTX MqContextNext(MQ_CTX const ctx)
get next instance from linked-list of MqContextS type
static MQ_CTX MqContextPrev(MQ_CTX const ctx)
get previous instance from linked-list of MqContextS type
MqStatusIsEF ConfigGetStatusIs()
C++: MqStatusIsEF ctx.ConfigGetStatusIs() → C-API return the libmqmsgque::MqContextS::statusIs ...
MqStartE ConfigGetStartAs()
C++: MqStartE ctx.ConfigGetStartAs() → C-API return the libmqmsgque::MqConfigS::startAs value
MK_STRN ConfigGetStorage() const
C++: MK_STRN ctx.ConfigGetStorage() → C-API get the storage of the context object
MK_I32 ConfigGetPkgsize() const
C++: MK_I32 ctx.ConfigGetPkgsize() → C-API get the maximun size of a BDY package
MQ_SOCK_HDL ConfigGetIoPipe()
C++: MQ_SOCK_HDL ctx.ConfigGetIoPipe() → C-API return the libmqmsgque::MqIoPipeConfigS
MK_TIME_T ConfigGetTimeout() const
C++: MK_TIME_T ctx.ConfigGetTimeout() → C-API get the timeout value of the context object
MkBufferListC * ConfigGetIoTcpL()
C++: MkBufferListC* ctx.ConfigGetIoTcpL() → C-API get the configuration-data of the tcp-client-...
void ConfigSetConfigFile(MK_STRN filename)
C++: ctx.ConfigSetConfigFile(MK_STRN filename) → C-API set the config-file and parse for well-k...
MK_I32 ConfigGetBuffersize() const
C++: MK_I32 ctx.ConfigGetBuffersize() → C-API get the minimum of the read/send buffersize of th...
MK_BOOL ConfigGetIsParent()
C++: MK_BOOL ctx.ConfigGetIsParent() → C-API does the context object is a parent ?...
MK_STRN ConfigGetPostfix() const
C++: MK_STRN ctx.ConfigGetPostfix() → C-API get the libmqmsgque::MqConfigS::dispPostfix
MK_BOOL ConfigGetIsString()
C++: MK_BOOL ctx.ConfigGetIsString() → C-API does the context object is using the string-mode ?
MK_STRN ConfigGetName() const
C++: MK_STRN ctx.ConfigGetName() → C-API get the name of the context object
MqIdentE ConfigGetIdentFrom()
C++: MqIdentE ctx.ConfigGetIdentFrom() → C-API get the libmqmsgque::MqConfigS::identFrom
std::tuple< MK_STRN, MK_STRN, MK_STRN, MK_STRN > ConfigGetIoTcp()
C++: {host:MK_STRN port:MK_STRN myhost:MK_STRN myport:MK_STRN} ctx.ConfigGetIoTcp() → C-API get...
MK_BOOL ConfigGetIsServer()
C++: MK_BOOL ctx.ConfigGetIsServer() → C-API does the context object is a server ?
MK_STRN ConfigGetPrefix() const
C++: MK_STRN ctx.ConfigGetPrefix() → C-API get the libmqmsgque::MqConfigS::dispPrefix
MK_STRN ConfigGetIoUds() const
C++: MK_STRN ctx.ConfigGetIoUds() → C-API return the libmqmsgque::MqIoUdsConfigS
static bool MqConfigGetIsString(MQ_CTX const ctx)
does the context object is using the string-mode ?
static bool MqConfigGetIsParent(MQ_CTX const ctx)
does the context object is a parent ? An objext is a parent id the libmqmsgque::MqConfigS::parent att...
static bool MqConfigGetIsServer(MQ_CTX const ctx)
does the context object is a server ?
static MK_STRN MqConfigGetPostfix(MQ_CTXN const ctx)
get the libmqmsgque::MqConfigS::dispPostfix
static MK_STRN MqConfigGetStorage(MQ_CTXN const ctx)
get the storage of the context object
static MK_TIME_T MqConfigGetTimeout(MQ_CTXN const ctx)
get the timeout value of the context object
#define MqConfigSetConfigFile(...)
static MQ_SOCK_HDL MqConfigGetIoPipe(MQ_CTX const ctx)
return the libmqmsgque::MqIoPipeConfigS
enum MkErrorE MqConfigGetIoTcp(MQ_CTX const ctx, MK_STRN *host_out, MK_STRN *port_out, MK_STRN *myhost_out, MK_STRN *myport_out)
get the configuration-data of the tcp-client-server-link …
static enum MqStartE MqConfigGetStartAs(MQ_CTX const ctx)
return the libmqmsgque::MqConfigS::startAs value
static MK_STRN MqConfigGetName(MQ_CTXN const ctx)
get the name of the context object
static enum MqIdentE MqConfigGetIdentFrom(MQ_CTX const ctx)
get the libmqmsgque::MqConfigS::identFrom
static MK_STRN MqConfigGetIoUds(MQ_CTXN const ctx)
return the libmqmsgque::MqIoUdsConfigS
static MK_I32 MqConfigGetPkgsize(MQ_CTXN const ctx)
get the maximun size of a BDY package
static MK_I32 MqConfigGetBuffersize(MQ_CTXN const ctx)
get the minimum of the read/send buffersize of the socket
static enum MqStatusIsEF MqConfigGetStatusIs(MQ_CTX const ctx)
return the libmqmsgque::MqContextS::statusIs value
#define MqConfigGetIoTcpL(...)
static MK_STRN MqConfigGetPrefix(MQ_CTXN const ctx)
get the libmqmsgque::MqConfigS::dispPrefix
void ConfigSetServerCleanup(MqServerCleanupCCB callback=NULL)
C++: ctx.ConfigSetServerCleanup(MqServerCleanupICB MqServerCleanupCCB MqServerCleanupIF* callback = ...
void ConfigSetServerSetup(MqServerSetupCCB callback=NULL)
C++: ctx.ConfigSetServerSetup(MqServerSetupICB MqServerSetupCCB MqServerSetupIF* callback = NULL) →...
void ConfigSetBgError(MqBgErrorCCB callback=NULL)
C++: ctx.ConfigSetBgError(MqBgErrorICB MqBgErrorCCB MqBgErrorIF* callback = NULL) → C-API set t...
void ConfigSetEvent(MqEventCCB callback=NULL)
C++: ctx.ConfigSetEvent(MqEventICB MqEventCCB MqEventIF* callback = NULL) → C-API set the libmq...
#define MqConfigSetBgError(...)
#define MqConfigSetServerSetup(...)
#define MqConfigSetServerCleanup(...)
#define MqConfigSetEvent(...)
void ConfigReset()
C++: ctx.ConfigReset() → C-API clean the libmqmsgque::MqContextS::config data
#define MqConfigReset(...)
void ConfigSetBuffersize(MK_I32 data)
C++: ctx.ConfigSetBuffersize(MK_I32 data) → C-API set the libmqmsgque::MqIoConfigS::buffersize ...
void ConfigSetPrefix(MK_STRN data)
C++: ctx.ConfigSetPrefix(MK_STRN data) → C-API set the server-part (1) of the application-ide...
MK_BOOL ConfigCheckStartAs(MqStartE data)
C++: MK_BOOL ctx.ConfigCheckStartAs(MqStartE data) → C-API check if libmqmsgque::MqConfigS::sta...
void ConfigSetPostfix(MK_STRN data)
C++: ctx.ConfigSetPostfix(MK_STRN data) → C-API set the client-part (2) of the application-id...
void ConfigSetIgnoreExit(MK_BOOL data)
C++: ctx.ConfigSetIgnoreExit(MK_BOOL data) → C-API set the libmqmsgque::MqSetupS::ignoreExit va...
void ConfigSetIdentFrom(MqIdentE data)
C++: ctx.ConfigSetIdentFrom(MqIdentE data) → C-API set the libmqmsgque::MqConfigS::identFrom va...
void ConfigSetStartAsString(MK_STRN data)
C++: ctx.ConfigSetStartAsString(MK_STRN data) → C-API set the libmqmsgque::MqConfigS::startAs v...
void ConfigSetAllDebug(MK_I32 data)
C++: ctx.ConfigSetAllDebug(MK_I32 data) → C-API set the MkRuntimeS::debug value
void ConfigSetStartAs(MqStartE data)
C++: ctx.ConfigSetStartAs(MqStartE data) → C-API set the libmqmsgque::MqConfigS::startAs value
void ConfigSetDaemon(MK_STRN pidfile)
C++: ctx.ConfigSetDaemon(MK_STRN pidfile) → C-API start the server-context as daemon …
void ConfigSetPkgsize(MK_I32 data)
C++: ctx.ConfigSetPkgsize(MK_I32 data) → C-API set the libmqmsgque::MqIoConfigS::pkgsize value
void ConfigSetStorage(MK_STRN data)
C++: ctx.ConfigSetStorage(MK_STRN data) → C-API set the Storage value and cleanup old value
void ConfigSetIsString(MK_BOOL data)
C++: ctx.ConfigSetIsString(MK_BOOL data) → C-API set the libmqmsgque::MqConfigS::native value '...
void ConfigSetName(MK_STRN data)
C++: ctx.ConfigSetName(MK_STRN data) → C-API set the libmqmsgque::MqConfigS::dispName value and...
void ConfigSetIoTcp(MK_STRN host=NULL, MK_STRN port=NULL, MK_STRN myhost=NULL, MK_STRN myport=NULL)
C++: ctx.ConfigSetIoTcp(MK_STRN host = NULL, MK_STRN port = NULL, MK_STRN myhost = NULL,...
void ConfigSetIoUds(MK_STRN file)
C++: ctx.ConfigSetIoUds(MK_STRN file) → C-API configure a context to use a uds-client-server-...
void ConfigSetTimeout(MK_TIME_T data)
C++: ctx.ConfigSetTimeout(MK_TIME_T data) → C-API set the libmqmsgque::MqIoConfigS::timeout val...
void ConfigSetIoPipe(MQ_SOCK_HDL fh)
C++: ctx.ConfigSetIoPipe(MQ_SOCK_HDL fh) → C-API set the pipe configuration data …
void ConfigSetIsServer(MK_BOOL data)
C++: ctx.ConfigSetIsServer(MK_BOOL data) → C-API set the libmqmsgque::MqSetupS::isServer value
#define MqConfigSetDaemon(...)
void MqConfigSetIsServer(MQ_CTX const ctx, bool data)
set the libmqmsgque::MqSetupS::isServer value
enum MkErrorE MqConfigSetStartAsString(MQ_CTX const ctx, MK_STRN data)
set the libmqmsgque::MqConfigS::startAs value using string default, thread, fork or spawn
bool MqConfigCheckStartAs(MQ_CTX const ctx, enum MqStartE data)
check if libmqmsgque::MqConfigS::startAs can be set to data
#define MqConfigSetPrefix(...)
void MqConfigSetBuffersize(MQ_CTX const ctx, MK_I32 data)
set the libmqmsgque::MqIoConfigS::buffersize value
void MqConfigSetIgnoreExit(MQ_CTX const ctx, bool data)
set the libmqmsgque::MqSetupS::ignoreExit value
#define MqConfigSetIoPipe(...)
#define MqConfigSetIoTcp(...)
void MqConfigSetIsString(MQ_CTX const ctx, bool data)
set the libmqmsgque::MqConfigS::native value 'S'string or 'L'owEndian or 'B'igEndian
#define MqConfigSetPostfix(...)
#define MqConfigSetName(...)
void MqConfigSetTimeout(MQ_CTX const ctx, MK_TIME_T data)
set the libmqmsgque::MqIoConfigS::timeout value
void MqConfigSetIdentFrom(MQ_CTX const ctx, enum MqIdentE data)
set the libmqmsgque::MqConfigS::identFrom value
#define MqConfigSetIoUds(...)
enum MkErrorE MqConfigSetStartAs(MQ_CTX const ctx, enum MqStartE data)
set the libmqmsgque::MqConfigS::startAs value
void MqConfigSetPkgsize(MQ_CTX const ctx, MK_I32 data)
set the libmqmsgque::MqIoConfigS::pkgsize value
#define MqConfigSetAllDebug(...)
#define MqConfigSetIoTcpL(...)
#define MqConfigSetStorage(...)
void EnvProtect()
C++: ctx.EnvProtect() → C-API protect the service-environment
void EnvRestore()
C++: ctx.EnvRestore() → C-API restore the service-environment
#define MqEnvProtect(...)
void MqEnvRestore(MQ_CTX ctx)
restore the service-environment
MkErrorC * ErrorFORMAT() const
C++: MkErrorC* fmtobj.ErrorFORMAT() → C-API helper used to access MkErrorDEFAULT from MqContext...
MkErrorE ErrorCopy(const MqContextC *sourceCtx) const
C++: MkErrorE targetCtx.ErrorCopy(const MqContextC* sourceCtx) → C-API copy a MkErrorS from the...
MkErrorE ErrorMove(const MqContextC *sourceCtx) const
C++: MkErrorE targetCtx.ErrorMove(const MqContextC* sourceCtx) → C-API move a MkErrorS from the...
#define MqContextErrorMove(...)
#define MqContextErrorCopy(...)
void SendVL2(MK_STRN cstr, va_list var_list)
C++: ctx.SendVL2(MK_STRN cstr, va_list var_list) → C-API A version of MqSend with va_list suppo...
#define MqSendVL2(...)
MK_STRN LogParentOrChild() const
C++: MK_STRN ctx.LogParentOrChild() → C-API is ctx a PARENT or a CHILD ? …
void LogType(const MkObjectC *fmtobj=NULL, MK_DBG debug=0, MK_STRN callfunc=__builtin_FUNCTION(), MK_I32 lvl=0) const
C++: ctx.LogType(const MkObjectC* fmtobj = NULL, MK_DBG debug = 0, MK_STRN callfunc = __builtin_FUNC...
void LogShort(const MkObjectC *fmtobj=NULL, MK_DBG debug=0, MK_STRN callfunc=__builtin_FUNCTION(), MK_I32 lvl=0, MK_STRN label=NULL) const
C++: ctx.LogShort(const MkObjectC* fmtobj = NULL, MK_DBG debug = 0, MK_STRN callfunc = __builtin_FUN...
void LogLink(const MkObjectC *fmtobj=NULL, MK_DBG debug=0, MK_STRN callfunc=__builtin_FUNCTION(), MK_I32 lvl=0) const
C++: ctx.LogLink(const MkObjectC* fmtobj = NULL, MK_DBG debug = 0, MK_STRN callfunc = __builtin_FUNC...
void LogEnv(const MkObjectC *fmtobj=NULL, MK_DBG debug=0, MK_STRN callfunc=__builtin_FUNCTION(), MK_I32 lvl=0) const
C++: ctx.LogEnv(const MkObjectC* fmtobj = NULL, MK_DBG debug = 0, MK_STRN callfunc = __builtin_FUNCT...
void LogConfig(const MkObjectC *fmtobj=NULL, MK_DBG debug=0, MK_STRN callfunc=__builtin_FUNCTION(), MK_I32 lvl=0) const
C++: ctx.LogConfig(const MkObjectC* fmtobj = NULL, MK_DBG debug = 0, MK_STRN callfunc = __builtin_FU...
void LogSetup(const MkObjectC *fmtobj=NULL, MK_DBG debug=0, MK_STRN callfunc=__builtin_FUNCTION(), MK_I32 lvl=0) const
C++: ctx.LogSetup(const MkObjectC* fmtobj = NULL, MK_DBG debug = 0, MK_STRN callfunc = __builtin_FUN...
MK_STRN LogServerOrClient() const
C++: MK_STRN ctx.LogServerOrClient() → C-API is ctx a SERVER or a CLIENT ? …
#define MqContextLogShort(...)
#define MqContextLogEnv(...)
#define MqContextLogConfig(...)
#define MqContextLogSetup(...)
#define MqContextLogLink(...)
#define MqContextLogType(...)
static MK_STRN MqLogServerOrClient(MQ_CTXN const ctx)
is ctx a SERVER or a CLIENT ? …
static MK_STRN MqLogParentOrChild(MQ_CTXN ctx)
is ctx a PARENT or a CHILD ? …
void ProcessEvent(MqWaitOnEventE wait=MQ_WAIT_NO, MK_TIME_T timeout=MK_TIMEOUT_DEFAULT)
C++: ctx.ProcessEvent(MqWaitOnEventE wait = MQ_WAIT_NO, MK_TIME_T timeout = MK_TIMEOUT_DEFAULT) → C...
MkBufferC * GetBuffer()
C++: MkBufferC* ctx.GetBuffer() → C-API get the libmqmsgque::MqContextS::ctxbuf object
MqContextC * GetRoot()
C++: MqContextC* ctx.GetRoot() → C-API get the Root (toplevel initial context)
void Exit(MK_STRN callfunc=__builtin_FUNCTION(), MK_STRN callfile=__builtin_FILE(), MK_I32 callline=__builtin_LINE())
C++: ctx.Exit(MK_STRN callfunc = __builtin_FUNCTION(), MK_STRN callfile = __builtin_FILE(),...
#define MqProcessEvent(...)
#define MqExit(...)
#define MqContextGetBuffer(...)
static MQ_CTX MqGetRoot(MQ_CTX ctx)
get the Root (toplevel initial context)
void ProxyForward(MqContextC *targetCtx, MqDumpC *dump=NULL, MK_TIME_T timeout=MK_TIMEOUT_DEFAULT)
C++: sourceCtx.ProxyForward(MqContextC* targetCtx, MqDumpC* dump = NULL, MK_TIME_T timeout = MK_TIME...
void ProxyItem(MqContextC *targetCtx)
C++: sourceCtx.ProxyItem(MqContextC* targetCtx) → C-API Copy a single-data-item from the source...
#define MqProxyItem(...)
#define MqProxyForward(...)
MK_BNP ReadBinaryR()
C++: MK_BNP ctx.ReadBinaryR() → C-API read a MkBinaryR from the read-data-package …
std::string ReadStringR()
C++: std::string ctx.ReadStringR() → C-API read a MkStringR from the read-data-package …
MK_HDL ReadHDL()
C++: MK_HDL ctx.ReadHDL() → C-API read the handle from the read-data-package
MK_BNP ReadBIN()
C++: doc_mq_cc_ReadBIN → C-API generic function to read an libmkkernel::MK_BIN object from the r...
MK_BOL ReadBOL()
C++: doc_mq_cc_ReadBOL → C-API read a PRIMITIVE TYPE from the read-data-package …
MkBufferC * ReadBUF()
C++: MkBufferC* ctx.ReadBUF() → C-API get a temporary MkBufferC from the read-data-package …
MkBufferListC * ReadBFL()
C++: MkBufferListC* ctx.ReadBFL() → C-API get a temporary MkBufferListC from next list-item in ...
MkBufferListC * ReadALL(MkBufferListC *val_inout=NULL)
C++: MkBufferListC* ctx.ReadALL(MkBufferListC* val_inout = NULL) → C-API get a temporary MkBuff...
MK_I32 ReadI32()
C++: doc_mq_cc_ReadI32 → C-API read a PRIMITIVE TYPE from the read-data-package …
MK_I64 ReadI64()
C++: doc_mq_cc_ReadI64 → C-API read a PRIMITIVE TYPE from the read-data-package …
MK_LONG ReadLONG()
C++: MK_LONG ctx.ReadLONG() → C-API read the long native object from the read-data-package
MK_I16 ReadI16()
C++: doc_mq_cc_ReadI16 → C-API read a PRIMITIVE TYPE from the read-data-package …
MK_FLT ReadFLT()
C++: doc_mq_cc_ReadFLT → C-API read a PRIMITIVE TYPE from the read-data-package …
MK_DBL ReadDBL()
C++: doc_mq_cc_ReadDBL → C-API read a PRIMITIVE TYPE from the read-data-package …
MK_STRN ReadSTR()
C++: doc_mq_cc_ReadSTR → C-API read a PRIMITIVE TYPE from the read-data-package …
MK_I8 ReadI8()
C++: doc_mq_cc_ReadI8 → C-API read a PRIMITIVE TYPE from the read-data-package …
#define MqReadI64(...)
#define MqReadSTR(...)
#define MqReadI16(...)
#define MqReadDBL(...)
#define MqReadBFL(...)
#define MqReadBUF(...)
#define MqReadHDL(...)
#define MqReadLONG(...)
#define MqReadI8(...)
#define MqReadBIN(...)
#define MqReadFLT(...)
#define MqReadBinaryR(...)
#define MqReadALL(...)
#define MqReadStringR(...)
#define MqReadBOL(...)
#define MqReadI32(...)
void ReadT_END()
C++: ctx.ReadT_END() → C-API finish to extract a longterm-transaction-item from the read-data-p...
void ReadL_END()
C++: ctx.ReadL_END() → C-API finish to extract a list-items from the read-data-package....
void ReadT_START()
C++: ctx.ReadT_START() → C-API start to extract a longterm-transaction-item from the read-data-...
void ReadL_START(MkBufferC *buf=NULL)
C++: ctx.ReadL_START(MkBufferC* buf = NULL) → C-API start to extract a list-items from the read...
#define MqReadT_START(...)
#define MqReadL_START(...)
#define MqReadT_END(...)
#define MqReadL_END(...)
MK_BOOL ReadItemExists()
C++: MK_BOOL ctx.ReadItemExists() → C-API check if an item exists in the read-data-package …
void ReadUndo()
C++: ctx.ReadUndo() → C-API undo the last MqContextC READ API function call …
MkTypeE ReadGetNextType()
C++: MkTypeE ctx.ReadGetNextType() → C-API get the type (MkTypeE) of the next Item in the read-...
MK_NUM ReadGetNumItems()
C++: MK_NUM ctx.ReadGetNumItems() → C-API get the number of items left in the read-data-package...
MK_NUM MqReadGetNumItems(MQ_CTX const ctx)
get the number of items left in the read-data-package …
#define MqReadDbg(...)
bool MqReadItemExists(MQ_CTX const ctx)
check if an item exists in the read-data-package …
#define MqReadUndo(...)
enum MkTypeE MqReadGetNextType(MQ_CTX const ctx)
get the type (MkTypeE) of the next Item in the read-data-buffer or "0" if not available
MK_STRN RouteGetPath()
C++: MK_STRN ctx.RouteGetPath() → C-API return the absolut route-connection-string up to the cu...
MqContextC_A RouteResolve(MK_STRN ident, MK_NUM retnum=-1)
C++: MqContextC_A ctx.RouteResolve(MK_STRN ident, MK_NUM retnum = -1) → C-API return a list of ...
MkBufferListC * RouteGetTree()
C++: MkBufferListC* ctx.RouteGetTree() → C-API create an overview about all available routing-t...
void RouteCreate(MK_STRN route, MK_STRN service, MK_BOOL overwrite=false)
C++: ctx.RouteCreate(MK_STRN route, MK_STRN service, MK_BOOL overwrite = false) → C-API create/...
void RouteDelete(MK_STRN route, MK_STRN service, MK_BOOL overwrite=false)
C++: ctx.RouteDelete(MK_STRN route, MK_STRN service, MK_BOOL overwrite = false) → C-API delete ...
void RouteTraverse(MK_STRN service, MkBufferListC *args=NULL)
C++: ctx.RouteTraverse(MK_STRN service, MkBufferListC* args = NULL) → C-API traverse a tree dow...
#define MqRouteDelete(...)
#define MqRouteTraverse(...)
#define MqRouteGetTree(...)
#define MqRouteCreate(...)
#define MqRouteGetPath(...)
#define MqRouteResolve(...)
void SendBOL(MK_BOL val)
C++: doc_mq_cc_SendBOL → C-API MqContextC - append a native PRIMITIVE TYPE value to the send-d...
void SendVL(MK_FST printfmt, va_list var_list)
C++: ctx.SendVL(MK_FST printfmt, va_list var_list) → C-API append a vararg string as va_list to...
void SendStringR(const std::string &val)
C++: ctx.SendStringR(const std::string& val) → C-API MqContextC - append a native PRIMITIVE T...
void SendBFL(const MkBufferListC *val)
C++: ctx.SendBFL(const MkBufferListC* val) → C-API append a MkBufferListC object to the send-da...
void SendBinaryR(MK_BNP val)
C++: ctx.SendBinaryR(MK_BNP val) → C-API append a MkBinaryR object to the send-data-package....
void SendBUS_FLAT(const MkBufferStreamC *val)
C++: ctx.SendBUS_FLAT(const MkBufferStreamC* val) → C-API append a MkBufferStreamC object to th...
void SendLONG(MK_LONG val)
C++: ctx.SendLONG(MK_LONG val) → C-API send the long native object to the send-data-package
void SendDBL(MK_DBL val)
C++: doc_mq_cc_SendDBL → C-API MqContextC - append a native PRIMITIVE TYPE value to the send-d...
void SendI64(MK_I64 val)
C++: doc_mq_cc_SendI64 → C-API MqContextC - append a native PRIMITIVE TYPE value to the send-d...
void SendBIN(MK_BNP val)
C++: doc_mq_cc_SendBIN → C-API append a libmkkernel::MK_BIN object to the send-data-package....
void SendHDL(MK_HDL val)
C++: ctx.SendHDL(MK_HDL val) → C-API send the handle to the send-data-package
void SendL_FLAT(const MkBufferListC *val)
C++: ctx.SendL_FLAT(const MkBufferListC* val) → C-API append a MkBufferListC object as flat lis...
void SendI16(MK_I16 val)
C++: doc_mq_cc_SendI16 → C-API MqContextC - append a native PRIMITIVE TYPE value to the send-d...
void SendLTR(MQ_LTR transLId)
SendLTR
void SendFLT(MK_FLT val)
C++: doc_mq_cc_SendFLT → C-API MqContextC - append a native PRIMITIVE TYPE value to the send-d...
void SendV(MK_FST printfmt,...)
C++: ctx.SendV(MK_FST printfmt, ... ) → C-API append a vararg string to the send-data-package o...
void SendBUF(const MkBufferC *val)
C++: ctx.SendBUF(const MkBufferC* val) → C-API append a MkBufferC object to the send-data-packa...
void SendI8(MK_I8 val)
C++: doc_mq_cc_SendI8 → C-API MqContextC - append a native PRIMITIVE TYPE value to the send-data...
void SendSTR(MK_STRN val)
C++: doc_mq_cc_SendSTR → C-API MqContextC - append a native PRIMITIVE TYPE value to the send-d...
void SendI32(MK_I32 val)
C++: doc_mq_cc_SendI32 → C-API MqContextC - append a native PRIMITIVE TYPE value to the send-d...
#define MqSendBIN(...)
#define MqSendLONG(...)
#define MqSendI8(...)
#define MqSendBOL(...)
#define MqSendI64(...)
#define MqSendI32(...)
#define MqSendBFL(...)
#define MqSendStringR(...)
#define MqSendI16(...)
#define MqSendL_FLAT(...)
#define MqSendSTR(...)
#define MqSendLTR(...)
#define MqSendHDL(...)
#define MqSendFLT(...)
#define MqSendDBL(...)
#define MqSendBUF(...)
#define MqSendBUS_FLAT(...)
#define MqSendBinaryR(...)
#define MqSendVL(...)
void SendEND_AND_SUB(MQ_TOK token, MqServiceCCB callback, MK_TIME_T timeout=MK_TIMEOUT_DEFAULT)
C++: ctx.SendEND_AND_SUB(MQ_TOK token, MqServiceICB MqServiceCCB MqServiceIF* callback,...
void SendEND_AND_CALLBACK(MQ_TOK token, MqServiceCCB callback, MK_TIME_T timeout=MK_TIMEOUT_DEFAULT)
C++: ctx.SendEND_AND_CALLBACK(MQ_TOK token, MqServiceICB MqServiceCCB MqServiceIF* callback,...
void SendSTART()
C++: ctx.SendSTART() → C-API initialize the send-data-package. …
void SendEND_AND_WAIT(MQ_TOK token, MK_TIME_T timeout=MK_TIMEOUT_DEFAULT)
C++: ctx.SendEND_AND_WAIT(MQ_TOK token, MK_TIME_T timeout = MK_TIMEOUT_DEFAULT) → C-API finish ...
void SendSYNC()
C++: ctx.SendSYNC() → C-API garantee that all pending asynchronous-service-calls are processed....
void SendEND_AND_TRANSACTION(MQ_TOK token, MQ_TOK callback, MK_TIME_T timeout=MK_TIMEOUT_DEFAULT)
C++: ctx.SendEND_AND_TRANSACTION(MQ_TOK token, MQ_TOK callback, MK_TIME_T timeout = MK_TIMEOUT_DEFAU...
void SendEND(MQ_TOK token, MK_TIME_T timeout=MK_TIMEOUT_DEFAULT)
C++: ctx.SendEND(MQ_TOK token, MK_TIME_T timeout = MK_TIMEOUT_DEFAULT) → C-API MqContextC - fin...
#define MqSendSTART(...)
#define MqSendEND_AND_TRANSACTION(...)
#define MqSendEND_AND_CALLBACK(...)
#define MqSendEND_AND_SUB(...)
#define MqSendEND_AND_WAIT(...)
#define MqSendEND(...)
#define MqSendSYNC(...)
void SendL_END()
C++: ctx.SendL_END() → C-API finish to append an embedded body-list-item to the send-data-packa...
void SendT_START()
C++: ctx.SendT_START() → C-API open a longterm-transaction-item …
void SendL_START()
C++: ctx.SendL_START() → C-API start to append an embedded body-list-item to the send-data-pack...
void SendT_END()
C++: ctx.SendT_END() → C-API closed a longterm-transaction-item …
#define MqSendL_START(...)
#define MqSendT_END(...)
#define MqSendL_END(...)
#define MqSendT_START(...)
void SendRETURN_SUB()
C++: ctx.SendRETURN_SUB() → C-API return Sub-Data-Blocks required by MqSendEND_AND_SUB …
void SendERROR()
C++: ctx.SendERROR() → C-API send the data from the MkErrorC to the link target ....
void SendRETURN()
C++: ctx.SendRETURN() → C-API MqContextC - finish the send-data-block on the server and optiona...
#define MqSendRETURN_SUB(...)
#define MqSendERROR(...)
#define MqSendRETURN(...)
MK_BOOL ServiceIsTransaction()
C++: MK_BOOL ctx.ServiceIsTransaction() → C-API check if the ongoing-service-call belongs to a ...
void ServiceProxyCtx(MQ_TOK token, MqContextC *target)
C++: ctx.ServiceProxyCtx(MQ_TOK token, MqContextC* target) → C-API same as MqServiceProxy but u...
MK_BOOL ServiceProxyCtxExists(MQ_TOK token, MqContextC *target)
C++: MK_BOOL ctx.ServiceProxyCtxExists(MQ_TOK token, MqContextC* target) → C-API check if servi...
void ServiceProxyRoundRobin(MQ_TOK token, MK_STRN ident)
C++: ctx.ServiceProxyRoundRobin(MQ_TOK token, MK_STRN ident) → C-API create a proxy-service usi...
void ServiceProxy(MQ_TOK token, MQ_SLAVE_ID id=MQ_SLAVE_OTHER)
C++: ctx.ServiceProxy(MQ_TOK token, MQ_SLAVE_ID id = MQ_SLAVE_OTHER) → C-API create a service t...
void ServiceStorage(MQ_TOK token)
C++: ctx.ServiceStorage(MQ_TOK token) → C-API setup a service listen on a MqContextC_ServiceApi...
MK_BOOL ServiceTokenExists(MQ_TOK token)
C++: MK_BOOL ctx.ServiceTokenExists(MQ_TOK token) → C-API check if the MqContextC_ServiceApi_Id...
void ServiceDelete(MQ_TOK token)
C++: ctx.ServiceDelete(MQ_TOK token) → C-API delete a service. …
MK_BOOL ServiceTokenCheck(MQ_TOK token)
C++: MK_BOOL ctx.ServiceTokenCheck(MQ_TOK token) → C-API in an ongoing-service-call check if th...
MQ_TOK ServiceTokenGet()
C++: MQ_TOK ctx.ServiceTokenGet() → C-API in an ongoing-service-call get the current MqContextC...
void ServiceCreate(MQ_TOK token, MqServiceCCB callback)
C++: ctx.ServiceCreate(MQ_TOK token, MqServiceICB MqServiceCCB MqServiceIF* cal...
#define MqServiceStorage(...)
#define MqServiceProxyCtx(...)
static bool MqServiceIsTransaction(MQ_CTX const ctx)
check if the ongoing-service-call belongs to a transaction …
#define MqServiceCreate(...)
MK_STRN MQ_TOK
MqContextC - a char[4+1] or hex[8+1] string used to unique identify a service …
bool MqServiceProxyCtxExists(MQ_CTX const ctx, MQ_TOK const token, MQ_CTX const target)
check if service who belongs to token is a proxy-service
#define MqServiceProxy(...)
MQ_TOK MqServiceTokenGet(MQ_CTX const ctx)
in an ongoing-service-call get the current MqContextC_ServiceApi_Identifer …
bool MqServiceTokenCheck(MQ_CTX const ctx, MQ_TOK const token)
in an ongoing-service-call check if the current MqContextC_ServiceApi_Identifer is token …
#define MqServiceProxyRoundRobin(...)
bool MqServiceTokenExists(MQ_CTX const ctx, MQ_TOK const token)
check if the MqContextC_ServiceApi_Identifer token is defined as ctx service …
#define MqServiceDelete(...)
MK_BOOL SlaveCheck(MQ_SLAVE_ID id) const
C++: MK_BOOL ctx.SlaveCheck(MQ_SLAVE_ID id) → C-API check if slave-id is valid
MqContextC * SlaveGetProxy(MQ_SLAVE_ID id)
C++: MqContextC* ctx.SlaveGetProxy(MQ_SLAVE_ID id) → C-API on slave return the master and on ma...
void SlaveCreate(MQ_SLAVE_ID id, MqContextC *slave)
C++: ctx.SlaveCreate(MQ_SLAVE_ID id, MqContextC* slave) → C-API create a master/slave link betw...
MqContextC * SlaveGet(MQ_SLAVE_ID id)
C++: MqContextC* ctx.SlaveGet(MQ_SLAVE_ID id) → C-API get the slave-context from a master-conte...
void SlaveDelete(MQ_SLAVE_ID id)
C++: ctx.SlaveDelete(MQ_SLAVE_ID id) → C-API Delete a slave object from a master/slave link ide...
MqContextC * SlaveGetFilter()
C++: MqContextC* ctx.SlaveGetFilter() → C-API get the filter-ctx or the master-ctx …
MK_BOOL SlaveIs() const
C++: MK_BOOL ctx.SlaveIs() → C-API is the context a slave-context ? …
MqContextC * SlaveGetMaster()
C++: MqContextC* ctx.SlaveGetMaster() → C-API opposite function of MqSlaveGetFilter
void SlaveWorker(MQ_SLAVE_ID id, MK_STRN fct="WORKER", MkBufferListC *args=NULL)
C++: ctx.SlaveWorker(MQ_SLAVE_ID id, MK_STRN fct = "WORKER", MkBufferListC* args = NULL) → C-API ...
#define MqSlaveGet(...)
static bool MqSlaveCheck(MQ_CTXN const ctx, MQ_SLAVE_ID const id)
check if slave-id is valid
#define MqSlaveGetProxy(...)
#define MqSlaveCreate(...)
static MQ_CTX MqSlaveGetMaster(MQ_CTX const ctx)
opposite function of MqSlaveGetFilter
static bool MqSlaveIs(MQ_CTXN const ctx)
is the context a slave-context ? …
#define MqSlaveGetFilter(...)
#define MqSlaveDelete(...)
#define MqSlaveWorker(...)
MK_I32 StorageErrCnt(MQ_LTR transLId)
C++: MK_I32 ctx.StorageErrCnt(MQ_LTR transLId) → C-API increment and return the database row-er...
void StorageClose()
C++: ctx.StorageClose() → C-API close the storage. …
void StorageOpen(MK_STRN storageFile)
C++: ctx.StorageOpen(MK_STRN storageFile) → C-API switch to a file-based-transaction-database …
std::tuple< MqContextC *, MQ_LTR > StorageResolve()
C++: {otherCtxP:MqContextC* otherLIdP:MQ_LTR} ctx.StorageResolve() → C-API extract the context-...
MQ_LTR StorageDelete(MQ_LTR *transLIdP_inout=0)
C++: MQ_LTR ctx.StorageDelete(MQ_LTR *transLIdP_inout = 0) → C-API delete the storage-row ident...
MQ_LTR StorageExport()
C++: MQ_LTR ctx.StorageExport() → C-API export the read-data-package into the STORAGE …
void StorageDecrRef(MQ_LTR transLId)
C++: ctx.StorageDecrRef(MQ_LTR transLId) → C-API decrease the internal refCount lock of the dat...
MQ_LTR StorageCount()
C++: MQ_LTR ctx.StorageCount() → C-API count the number of storage-rows …
MQ_LTR StorageImport(MQ_LTR *transLIdP_inout=0)
C++: MQ_LTR ctx.StorageImport(MQ_LTR *transLIdP_inout = 0) → C-API import the storage-package i...
void StorageLog(MK_STRN callfunc=__builtin_FUNCTION())
C++: ctx.StorageLog(MK_STRN callfunc = __builtin_FUNCTION()) → C-API log the storage the status...
void StorageIncrRef(MQ_LTR transLId)
C++: ctx.StorageIncrRef(MQ_LTR transLId) → C-API increase the internal refCount lock of the dat...
#define MqStorageIncrRef(...)
#define MqStorageResolve(...)
#define MqStorageLog(...)
#define MqStorageExport(...)
#define MqStorageDecrRef(...)
#define MqStorageClose(...)
#define MqStorageOpen(...)
#define MqStorageImport(...)
#define MqStorageCount(...)
#define MqStorageDelete(...)
#define MqStorageErrCnt(...)
static MK_OBJ CTOR(MqContextC *tmpl=NULL)
C++: [constructor,static] MqContextC* MqContextC::Create(MqContextC* tmpl = NULL) → C-API create...
static MqContextC * Create(MqContextC *tmpl=NULL)
C++: [constructor,static] MqContextC* MqContextC::Create(MqContextC* tmpl = NULL) → C-API create...
#define MqContextCreate(...)
MQ_DMP getDMP__null_allow() const
return the LibMsgqueObject from current MqDumpC instance
Definition MqDumpC_cc.hh:81
MQ_DMP getDMP() const
return the LibMsgqueObject from current MqDumpC instance
Definition MqDumpC_cc.hh:74
MQ_FCT getFCT() const
return the LibMsgqueObject from current MqFactoryC instance
static MqFactoryC * MqFactoryC_ObjNew(MK_RT_ARGS MQ_FCT hdl)
return MqFactoryC from LibMsgqueObject
MqIdentE
identify the application using prefix (default) or factory …
MqWaitOnEventE
wait for an event? …
MqStatusIsEF
Information about how the context was created.
MqStartE
User preferences on HOWTO start a new entity.
MK_NUM MQ_SLAVE_ID
a slave identiver
int MQ_LTR
32bit longterm transaction token because PHP-32 does NOT support long long
std::pair< MK_SIZE, MK_BINN > MK_BNP
namespace for the CcMqMsgque "C++"-API
PUBLIC data structure for the ccmqmsgque-specific-data → C-API: libmqmsgque::MqContextS
static MK_CBP Create(MK_RT mkrt, MqContextC::MqTokenICB const callback, MqContextC *self=NULL)
Definition MqCall_cc.hh:60
static enum MkErrorE Call(MQ_SERVICE_CALL_ARGS)
Definition MqCall_cc.cc:81
static void Copy(MQ_SERVICE_COPY_ARGS)
Definition MqCall_cc.cc:76
static void Free(MQ_SERVICE_FREE_ARGS)
Definition MqCall_cc.cc:70
array of MqContextC instances
PUBLIC data structure for the ccmqmsgque-specific-data
MqDumpC - the class known as dmp or dump is used to export a ccmqmsgque data package as binary …
data used to define a factory