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(MK_NULL_NO);
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(MK_NULL_NO);
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(MK_NULL_NO);
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(MK_NULL_NO);
120 MkRtSetup_X(ctx);
121 MQ_FCT item_hdl = MqFactoryC::getFCT(item,MK_NULL_NO);
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(MK_NULL_NO);
129 MkRtSetup_X(ctx);
130 const MQ_FCT item_hdl = MqFactoryC::getFCT(item,MK_NULL_NO);
131 enum MkErrorE errVal = MqClassFactorySet(ctx, item_hdl);
132 MkErrorC_Check(ctx, errVal);
133 }
134
137 MK_UNUSED auto ctx = getCTXN(MK_NULL_NO);
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(MK_NULL_NO);
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(MK_NULL_NO);
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(MK_NULL_NO);
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(MK_NULL_NO);
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(MK_NULL_NO);
192 MkRtSetup_X(ctx);
193 MK_I32 __retVal__L = MqConfigGetBuffersize(ctx);
194 return __retVal__L;
195 }
196
199 MK_UNUSED auto ctx = getCTX(MK_NULL_NO);
200 MkRtSetup_X(ctx);
201 enum MqIdentE __retVal__L = MqConfigGetIdentFrom(ctx);
202 return __retVal__L;
203 }
204
207 MK_UNUSED auto ctx = getCTX(MK_NULL_NO);
208 MkRtSetup_X(ctx);
209 MQ_SOCK_HDL __retVal__L = MqConfigGetIoPipe(ctx);
210 return __retVal__L;
211 }
212
215 MK_UNUSED auto ctx = getCTXN(MK_NULL_NO);
216 MkRtSetup_X(ctx);
217 MK_STRN __retVal__L = MqConfigGetIoUds(ctx);
218 return __retVal__L;
219 }
220
223 MK_UNUSED auto ctx = getCTX(MK_NULL_NO);
224 MkRtSetup_X(ctx);
225 MK_BOOL __retVal__L = MqConfigGetIsParent(ctx);
226 return __retVal__L;
227 }
228
231 MK_UNUSED auto ctx = getCTX(MK_NULL_NO);
232 MkRtSetup_X(ctx);
233 MK_BOOL __retVal__L = MqConfigGetIsServer(ctx);
234 return __retVal__L;
235 }
236
239 MK_UNUSED auto ctx = getCTX(MK_NULL_NO);
240 MkRtSetup_X(ctx);
241 MK_BOOL __retVal__L = MqConfigGetIsString(ctx);
242 return __retVal__L;
243 }
244
247 MK_UNUSED auto ctx = getCTXN(MK_NULL_NO);
248 MkRtSetup_X(ctx);
249 MK_STRN __retVal__L = MqConfigGetName(ctx);
250 return __retVal__L;
251 }
252
255 MK_UNUSED auto ctx = getCTXN(MK_NULL_NO);
256 MkRtSetup_X(ctx);
257 MK_I32 __retVal__L = MqConfigGetPkgsize(ctx);
258 return __retVal__L;
259 }
260
263 MK_UNUSED auto ctx = getCTXN(MK_NULL_NO);
264 MkRtSetup_X(ctx);
265 MK_STRN __retVal__L = MqConfigGetPostfix(ctx);
266 return __retVal__L;
267 }
268
271 MK_UNUSED auto ctx = getCTXN(MK_NULL_NO);
272 MkRtSetup_X(ctx);
273 MK_STRN __retVal__L = MqConfigGetPrefix(ctx);
274 return __retVal__L;
275 }
276
279 MK_UNUSED auto ctx = getCTX(MK_NULL_NO);
280 MkRtSetup_X(ctx);
281 enum MqStartE __retVal__L = MqConfigGetStartAs(ctx);
282 return __retVal__L;
283 }
284
287 MK_UNUSED auto ctx = getCTX(MK_NULL_NO);
288 MkRtSetup_X(ctx);
289 enum MqStatusIsEF __retVal__L = MqConfigGetStatusIs(ctx);
290 return __retVal__L;
291 }
292
295 MK_UNUSED auto ctx = getCTXN(MK_NULL_NO);
296 MkRtSetup_X(ctx);
297 MK_STRN __retVal__L = MqConfigGetStorage(ctx);
298 return __retVal__L;
299 }
300
303 MK_UNUSED auto ctx = getCTXN(MK_NULL_NO);
304 MkRtSetup_X(ctx);
305 MK_TIME_T __retVal__L = MqConfigGetTimeout(ctx);
306 return __retVal__L;
307 }
308
311 MK_UNUSED auto ctx = getCTX(MK_NULL_NO);
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(MK_NULL_NO);
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(MK_NULL_NO);
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(MK_NULL_NO);
354 MkRtSetup_X(ctx);
355 auto fCall = MqBgErrorCallbackC::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(MK_NULL_NO);
364 MkRtSetup_X(ctx);
365 auto fCall = MqBgErrorCallbackC::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(MK_NULL_NO);
374 MkRtSetup_X(ctx);
375 auto fCall = MqBgErrorCallbackC::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 (MqEventICB callback) {
383 MK_UNUSED auto ctx = getCTX(MK_NULL_NO);
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 (MqEventCCB callback) {
393 MK_UNUSED auto ctx = getCTX(MK_NULL_NO);
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(MK_NULL_NO);
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(MK_NULL_NO);
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(MK_NULL_NO);
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(MK_NULL_NO);
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(MK_NULL_NO);
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(MK_NULL_NO);
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(MK_NULL_NO);
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(MK_NULL_NO);
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(MK_NULL_NO);
499 MkRtSetup_X(ctx);
500 MK_BOOL __retVal__L = MqConfigCheckStartAs(ctx, data);
501 return __retVal__L;
502 }
503
506 MK_UNUSED auto ctx = getCTX(MK_NULL_NO);
507 MkRtSetup_X(ctx);
508 enum MkErrorE errVal = MqConfigSetAllDebug(ctx, data);
509 MkErrorC_Check(ctx, errVal);
510 }
511
514 MK_UNUSED auto ctx = getCTX(MK_NULL_NO);
515 MkRtSetup_X(ctx);
516 MqConfigSetBuffersize(ctx, data);
517 }
518
520 inline void MqContextC::ConfigSetDaemon (MK_STRN pidfile) {
521 MK_UNUSED auto ctx = getCTX(MK_NULL_NO);
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(MK_NULL_NO);
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(MK_NULL_NO);
539 MkRtSetup_X(ctx);
540 MqConfigSetIdentFrom(ctx, data);
541 }
542
545 MK_UNUSED auto ctx = getCTX(MK_NULL_NO);
546 MkRtSetup_X(ctx);
547 MqConfigSetIgnoreExit(ctx, data);
548 }
549
552 MK_UNUSED auto ctx = getCTX(MK_NULL_NO);
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(MK_NULL_NO);
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(MK_NULL_NO);
569 MkRtSetup_X(ctx);
570 MK_BFL vals_hdl = MkBufferListC::getBFL(vals,MK_NULL_NO);
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(MK_NULL_NO);
578 MkRtSetup_X(ctx);
579 const MK_BFL vals_hdl = MkBufferListC::getBFL(vals,MK_NULL_NO);
580 enum MkErrorE errVal = MqConfigSetIoTcpL(ctx, vals_hdl);
581 MkErrorC_Check(ctx, errVal);
582 }
583
586 MK_UNUSED auto ctx = getCTX(MK_NULL_NO);
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(MK_NULL_NO);
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(MK_NULL_NO);
604 MkRtSetup_X(ctx);
605 MqConfigSetIsServer(ctx, data);
606 }
607
610 MK_UNUSED auto ctx = getCTX(MK_NULL_NO);
611 MkRtSetup_X(ctx);
612 MqConfigSetIsString(ctx, data);
613 }
614
617 MK_UNUSED auto ctx = getCTX(MK_NULL_NO);
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(MK_NULL_NO);
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(MK_NULL_NO);
633 MkRtSetup_X(ctx);
634 MqConfigSetPkgsize(ctx, data);
635 }
636
639 MK_UNUSED auto ctx = getCTX(MK_NULL_NO);
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(MK_NULL_NO);
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(MK_NULL_NO);
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(MK_NULL_NO);
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(MK_NULL_NO);
670 MkRtSetup_X(ctx);
671 enum MkErrorE errVal = MqConfigSetStartAs(ctx, data);
672 MkErrorC_Check(ctx, errVal);
673 }
674
677 MK_UNUSED auto ctx = getCTX(MK_NULL_NO);
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(MK_NULL_NO);
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(MK_NULL_NO);
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(MK_NULL_NO);
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(MK_NULL_NO);
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(MK_NULL_NO);
726 MkRtSetup_X(ctx);
727 MqEnvProtect(ctx);
728 }
729
731 inline void MqContextC::EnvRestore () {
732 MK_UNUSED auto ctx = getCTX(MK_NULL_NO);
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(MK_NULL_YES);
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(MK_NULL_NO);
759 MkRtSetup_X(targetCtx);
760 MQ_CTXN sourceCtx_hdl = MqContextC::getCTXN(sourceCtx,MK_NULL_NO);
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(MK_NULL_NO);
768 MkRtSetup_X(targetCtx);
769 const MQ_CTXN sourceCtx_hdl = MqContextC::getCTXN(sourceCtx,MK_NULL_NO);
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(MK_NULL_NO);
777 MkRtSetup_X(targetCtx);
778 MQ_CTXN sourceCtx_hdl = MqContextC::getCTXN(sourceCtx,MK_NULL_NO);
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(MK_NULL_NO);
786 MkRtSetup_X(targetCtx);
787 const MQ_CTXN sourceCtx_hdl = MqContextC::getCTXN(sourceCtx,MK_NULL_NO);
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(MK_NULL_NO);
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(MK_NULL_NO);
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(MK_NULL_NO);
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(MK_NULL_NO);
840 MkRtSetup_X(ctx);
841 enum MkErrorE errVal = MqLinkConnect(ctx);
842 MkErrorC_Check(ctx, errVal);
843 }
844
847 MK_UNUSED auto ctx = getCTX(MK_NULL_NO);
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(MK_NULL_NO);
857 MkRtSetup_X(ctx);
858 const MK_BAC args_hdl = MkBufferListC::getBFL(args,MK_NULL_NO);
859 enum MkErrorE errVal = MqLinkCreate(ctx, args_hdl);
860 MkErrorC_Check(ctx, errVal);
861 }
862
865 MK_UNUSED auto ctx = getCTX(MK_NULL_NO);
866 MkRtSetup_X(ctx);
867 MQ_CTX parent_hdl = MqContextC::getCTX(parent,MK_NULL_NO);
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(MK_NULL_NO);
876 MkRtSetup_X(ctx);
877 const MQ_CTX parent_hdl = MqContextC::getCTX(parent,MK_NULL_NO);
878 const MK_BAC args_hdl = MkBufferListC::getBFL(args,MK_NULL_NO);
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(MK_NULL_NO);
886 MkRtSetup_X(ctx);
887 MqLinkDelete(ctx);
888 }
889
892 MK_UNUSED auto ctx = getCTX(MK_NULL_NO);
893 MkRtSetup_X(ctx);
894 MK_NUM __retVal__L = MqLinkGetCtxId(ctx);
895 return __retVal__L;
896 }
897
900 MK_UNUSED auto ctx = getCTX(MK_NULL_NO);
901 MkRtSetup_X(ctx);
902 MK_STRN __retVal__L = MqLinkGetTargetIdent(ctx);
903 return __retVal__L;
904 }
905
908 MK_UNUSED auto ctx = getCTX(MK_NULL_NO);
909 MkRtSetup_X(ctx);
910 MK_BOOL __retVal__L = MqLinkIsConnected(ctx);
911 return __retVal__L;
912 }
913
916 MK_UNUSED auto ctx = getCTX(MK_NULL_NO);
917 MkRtSetup_X(ctx);
918 MK_BOOL __retVal__L = MqLinkIsParent(ctx);
919 return __retVal__L;
920 }
921
924 MK_UNUSED auto ctx = getCTX(MK_NULL_NO);
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
940 inline void MqContextC::Log (const MkObjectC* fmtobj, MK_DBG debug, MK_STRN callfunc, MK_I32 lvl) const {
941 MK_UNUSED auto ctx = getCTXN(MK_NULL_NO);
942 MkRtSetup_X(ctx);
943 MK_OBJN fmtobj_hdl = MkObjectC::getOBJN(fmtobj,MK_NULL_YES);
944 if (callfunc == NULL) {callfunc = __builtin_FUNCTION();}
945 if (debug > (MK_DBG)(MkRuntimeGetDebug())) {return;}
946 MqContextLog(ctx, fmtobj_hdl, debug, callfunc, lvl);
947 }
948
950 inline void MqContextC::Log (const MkObjectC& fmtobj, MK_DBG debug, MK_STRN callfunc, MK_I32 lvl) const {
951 MK_UNUSED auto ctx = getCTXN(MK_NULL_NO);
952 MkRtSetup_X(ctx);
953 const MK_OBJN fmtobj_hdl = MkObjectC::getOBJN(fmtobj,MK_NULL_NO);
954 if (callfunc == NULL) {callfunc = __builtin_FUNCTION();}
955 if (debug > (MK_DBG)(MkRuntimeGetDebug())) {return;}
956 MqContextLog(ctx, fmtobj_hdl, debug, callfunc, lvl);
957 }
958
960 inline void MqContextC::LogConfig (const MkObjectC* fmtobj, MK_DBG debug, MK_STRN callfunc, MK_I32 lvl) const {
961 MK_UNUSED auto ctx = getCTXN(MK_NULL_NO);
962 MkRtSetup_X(ctx);
963 MK_OBJN fmtobj_hdl = MkObjectC::getOBJN(fmtobj,MK_NULL_YES);
964 if (callfunc == NULL) {callfunc = __builtin_FUNCTION();}
965 if (debug > (MK_DBG)(MkRuntimeGetDebug())) {return;}
966 MqContextLogConfig(ctx, fmtobj_hdl, debug, callfunc, lvl);
967 }
968
970 inline void MqContextC::LogConfig (const MkObjectC& fmtobj, MK_DBG debug, MK_STRN callfunc, MK_I32 lvl) const {
971 MK_UNUSED auto ctx = getCTXN(MK_NULL_NO);
972 MkRtSetup_X(ctx);
973 const MK_OBJN fmtobj_hdl = MkObjectC::getOBJN(fmtobj,MK_NULL_NO);
974 if (callfunc == NULL) {callfunc = __builtin_FUNCTION();}
975 if (debug > (MK_DBG)(MkRuntimeGetDebug())) {return;}
976 MqContextLogConfig(ctx, fmtobj_hdl, debug, callfunc, lvl);
977 }
978
980 inline void MqContextC::LogEnv (MkObjectC* fmtobj, MK_DBG debug, MK_STRN callfunc, MK_I32 lvl) const {
981 MK_UNUSED auto ctx = getCTX(MK_NULL_NO);
982 MkRtSetup_X(ctx);
983 MK_OBJ fmtobj_hdl = MkObjectC::getOBJ(fmtobj,MK_NULL_YES);
984 if (callfunc == NULL) {callfunc = __builtin_FUNCTION();}
985 if (debug > (MK_DBG)(MkRuntimeGetDebug())) {return;}
986 MqContextLogEnv(ctx, fmtobj_hdl, debug, callfunc, lvl);
987 }
988
990 inline void MqContextC::LogEnv (const MkObjectC& fmtobj, MK_DBG debug, MK_STRN callfunc, MK_I32 lvl) const {
991 MK_UNUSED auto ctx = getCTX(MK_NULL_NO);
992 MkRtSetup_X(ctx);
993 const MK_OBJ fmtobj_hdl = MkObjectC::getOBJ(fmtobj,MK_NULL_NO);
994 if (callfunc == NULL) {callfunc = __builtin_FUNCTION();}
995 if (debug > (MK_DBG)(MkRuntimeGetDebug())) {return;}
996 MqContextLogEnv(ctx, fmtobj_hdl, debug, callfunc, lvl);
997 }
998
1000 inline void MqContextC::LogLink (const MkObjectC* fmtobj, MK_DBG debug, MK_STRN callfunc, MK_I32 lvl) const {
1001 MK_UNUSED auto ctx = getCTXN(MK_NULL_NO);
1002 MkRtSetup_X(ctx);
1003 MK_OBJN fmtobj_hdl = MkObjectC::getOBJN(fmtobj,MK_NULL_YES);
1004 if (callfunc == NULL) {callfunc = __builtin_FUNCTION();}
1005 if (debug > (MK_DBG)(MkRuntimeGetDebug())) {return;}
1006 MqContextLogLink(ctx, fmtobj_hdl, debug, callfunc, lvl);
1007 }
1008
1010 inline void MqContextC::LogLink (const MkObjectC& fmtobj, MK_DBG debug, MK_STRN callfunc, MK_I32 lvl) const {
1011 MK_UNUSED auto ctx = getCTXN(MK_NULL_NO);
1012 MkRtSetup_X(ctx);
1013 const MK_OBJN fmtobj_hdl = MkObjectC::getOBJN(fmtobj,MK_NULL_NO);
1014 if (callfunc == NULL) {callfunc = __builtin_FUNCTION();}
1015 if (debug > (MK_DBG)(MkRuntimeGetDebug())) {return;}
1016 MqContextLogLink(ctx, fmtobj_hdl, debug, callfunc, lvl);
1017 }
1018
1020 inline void MqContextC::LogSetup (const MkObjectC* fmtobj, MK_DBG debug, MK_STRN callfunc, MK_I32 lvl) const {
1021 MK_UNUSED auto ctx = getCTXN(MK_NULL_NO);
1022 MkRtSetup_X(ctx);
1023 MK_OBJN fmtobj_hdl = MkObjectC::getOBJN(fmtobj,MK_NULL_YES);
1024 if (callfunc == NULL) {callfunc = __builtin_FUNCTION();}
1025 if (debug > (MK_DBG)(MkRuntimeGetDebug())) {return;}
1026 MqContextLogSetup(ctx, fmtobj_hdl, debug, callfunc, lvl);
1027 }
1028
1030 inline void MqContextC::LogSetup (const MkObjectC& fmtobj, MK_DBG debug, MK_STRN callfunc, MK_I32 lvl) const {
1031 MK_UNUSED auto ctx = getCTXN(MK_NULL_NO);
1032 MkRtSetup_X(ctx);
1033 const MK_OBJN fmtobj_hdl = MkObjectC::getOBJN(fmtobj,MK_NULL_NO);
1034 if (callfunc == NULL) {callfunc = __builtin_FUNCTION();}
1035 if (debug > (MK_DBG)(MkRuntimeGetDebug())) {return;}
1036 MqContextLogSetup(ctx, fmtobj_hdl, debug, callfunc, lvl);
1037 }
1038
1040 inline void MqContextC::LogShort (const MkObjectC* fmtobj, MK_DBG debug, MK_STRN callfunc, MK_I32 lvl, MK_STRN label) const {
1041 MK_UNUSED auto ctx = getCTXN(MK_NULL_NO);
1042 MkRtSetup_X(ctx);
1043 MK_OBJN fmtobj_hdl = MkObjectC::getOBJN(fmtobj,MK_NULL_YES);
1044 if (callfunc == NULL) {callfunc = __builtin_FUNCTION();}
1045 if (debug > (MK_DBG)(MkRuntimeGetDebug())) {return;}
1046 MqContextLogShort(ctx, fmtobj_hdl, debug, callfunc, lvl, label);
1047 }
1048
1050 inline void MqContextC::LogShort (const MkObjectC& fmtobj, MK_DBG debug, MK_STRN callfunc, MK_I32 lvl, MK_STRN label) const {
1051 MK_UNUSED auto ctx = getCTXN(MK_NULL_NO);
1052 MkRtSetup_X(ctx);
1053 const MK_OBJN fmtobj_hdl = MkObjectC::getOBJN(fmtobj,MK_NULL_NO);
1054 if (callfunc == NULL) {callfunc = __builtin_FUNCTION();}
1055 if (debug > (MK_DBG)(MkRuntimeGetDebug())) {return;}
1056 MqContextLogShort(ctx, fmtobj_hdl, debug, callfunc, lvl, label);
1057 }
1058
1060 inline void MqContextC::LogType (MkObjectC* fmtobj, MK_DBG debug, MK_STRN callfunc, MK_I32 lvl) const {
1061 MK_UNUSED auto ctx = getCTX(MK_NULL_NO);
1062 MkRtSetup_X(ctx);
1063 MK_OBJ fmtobj_hdl = MkObjectC::getOBJ(fmtobj,MK_NULL_YES);
1064 if (callfunc == NULL) {callfunc = __builtin_FUNCTION();}
1065 if (debug > (MK_DBG)(MkRuntimeGetDebug())) {return;}
1066 MqContextLogType(ctx, fmtobj_hdl, debug, callfunc, lvl);
1067 }
1068
1070 inline void MqContextC::LogType (const MkObjectC& fmtobj, MK_DBG debug, MK_STRN callfunc, MK_I32 lvl) const {
1071 MK_UNUSED auto ctx = getCTX(MK_NULL_NO);
1072 MkRtSetup_X(ctx);
1073 const MK_OBJ fmtobj_hdl = MkObjectC::getOBJ(fmtobj,MK_NULL_NO);
1074 if (callfunc == NULL) {callfunc = __builtin_FUNCTION();}
1075 if (debug > (MK_DBG)(MkRuntimeGetDebug())) {return;}
1076 MqContextLogType(ctx, fmtobj_hdl, debug, callfunc, lvl);
1077 }
1078
1081 MK_UNUSED auto ctx = getCTXN(MK_NULL_NO);
1082 MkRtSetup_X(ctx);
1083 MK_STRN __retVal__L = MqLogParentOrChild(ctx);
1084 return __retVal__L;
1085 }
1086
1089 MK_UNUSED auto ctx = getCTXN(MK_NULL_NO);
1090 MkRtSetup_X(ctx);
1091 MK_STRN __retVal__L = MqLogServerOrClient(ctx);
1092 return __retVal__L;
1093 }
1094
1096 // MqContextC_LogApi_Log_CC_API
1097
1101
1102 // doc-key: MqContextC,MqContextC-MiscApi-Misc,oc_
1103
1106 MK_UNUSED auto ctx = getCTX(MK_NULL_NO);
1107 MkRtSetup_X(ctx);
1108 MK_BUF __retVal__L = MqContextGetBuffer(ctx);
1109 return MkBufferC::MkBufferC_ObjNew(MK_RT_CALL __retVal__L);
1110 }
1111
1114 MK_UNUSED auto ctx = getCTX(MK_NULL_NO);
1115 MkRtSetup_X(ctx);
1116 MQ_CTX __retVal__L = MqGetRoot(ctx);
1117 return MqContextC::MqContextC_ObjNew(MK_RT_CALL __retVal__L);
1118 }
1119
1120 // doc-key: MqContextC,MqContextC-MiscApi-Misc,om_
1121
1124 MK_UNUSED auto ctx = getCTXN(MK_NULL_NO);
1125 MkRtSetup_X(ctx);
1126 MK_STRN __retVal__L = MqContextToString(ctx);
1127 return __retVal__L;
1128 }
1129
1131 inline void MqContextC::Exit (MK_STRN callfunc, MK_STRN callfile, MK_I32 callline) {
1132 MK_UNUSED auto ctx = getCTX(MK_NULL_NO);
1133 MkRtSetup_X(ctx);
1134 if (callline == -1) {callline = __builtin_LINE();}
1135 if (callfile == NULL) {callfile = __builtin_FILE();}
1136 if (callfunc == NULL) {callfunc = __builtin_FUNCTION();}
1137 MqExit(ctx, callfunc, callfile, callline);
1138 }
1139
1142 MK_UNUSED auto ctx = getCTX(MK_NULL_NO);
1143 MkRtSetup_X(ctx);
1144 enum MkErrorE errVal = MqProcessEvent(ctx, wait, timeout);
1145 MkErrorC_Check(ctx, errVal);
1146 }
1147
1149 // MqContextC_MiscApi_Misc_CC_API
1150
1154
1155 // doc-key: MqContextC,MqContextC-ProxyApi-Proxy,om_
1156
1158 inline void MqContextC::ProxyForward (MqContextC* targetCtx, MqDumpC* dump, MK_TIME_T timeout) {
1159 MK_UNUSED auto sourceCtx = getCTX(MK_NULL_NO);
1160 MkRtSetup_X(sourceCtx);
1161 MQ_CTX targetCtx_hdl = MqContextC::getCTX(targetCtx,MK_NULL_NO);
1162 MQ_DMP dump_hdl = MqDumpC::getDMP(dump,MK_NULL_YES);
1163 enum MkErrorE errVal = MqProxyForward(sourceCtx, targetCtx_hdl, dump_hdl, timeout);
1164 MkErrorC_Check(sourceCtx, errVal);
1165 }
1166
1168 inline void MqContextC::ProxyForward (const MqContextC& targetCtx, const MqDumpC& dump, MK_TIME_T timeout) {
1169 MK_UNUSED auto sourceCtx = getCTX(MK_NULL_NO);
1170 MkRtSetup_X(sourceCtx);
1171 const MQ_CTX targetCtx_hdl = MqContextC::getCTX(targetCtx,MK_NULL_NO);
1172 const MQ_DMP dump_hdl = MqDumpC::getDMP(dump,MK_NULL_NO);
1173 enum MkErrorE errVal = MqProxyForward(sourceCtx, targetCtx_hdl, dump_hdl, timeout);
1174 MkErrorC_Check(sourceCtx, errVal);
1175 }
1176
1178 inline void MqContextC::ProxyItem (MqContextC* targetCtx) {
1179 MK_UNUSED auto sourceCtx = getCTX(MK_NULL_NO);
1180 MkRtSetup_X(sourceCtx);
1181 MQ_CTX targetCtx_hdl = MqContextC::getCTX(targetCtx,MK_NULL_NO);
1182 enum MkErrorE errVal = MqProxyItem(sourceCtx, targetCtx_hdl);
1183 MkErrorC_Check(sourceCtx, errVal);
1184 }
1185
1187 inline void MqContextC::ProxyItem (const MqContextC& targetCtx) {
1188 MK_UNUSED auto sourceCtx = getCTX(MK_NULL_NO);
1189 MkRtSetup_X(sourceCtx);
1190 const MQ_CTX targetCtx_hdl = MqContextC::getCTX(targetCtx,MK_NULL_NO);
1191 enum MkErrorE errVal = MqProxyItem(sourceCtx, targetCtx_hdl);
1192 MkErrorC_Check(sourceCtx, errVal);
1193 }
1194
1196 // MqContextC_ProxyApi_Proxy_CC_API
1197
1201
1202 // doc-key: MqContextC,MqContextC-ReadApi-Atom,oci
1203
1206 MK_UNUSED auto ctx = getCTX(MK_NULL_NO);
1207 MkRtSetup_X(ctx);
1208 MK_BFL val_inout_hdl = MkBufferListC::getBFL(val_inout,MK_NULL_YES);
1209 enum MkErrorE errVal = MqReadALL(ctx, &val_inout_hdl);
1210 MkErrorC_Check(ctx, errVal);
1211 return MkBufferListC::MkBufferListC_ObjNew(MK_RT_CALL val_inout_hdl);
1212 }
1213
1214 // doc-key: MqContextC,MqContextC-ReadApi-Atom,oco
1215
1218 MK_UNUSED auto ctx = getCTX(MK_NULL_NO);
1219 MkRtSetup_X(ctx);
1220 MK_BFL val_out;
1221 enum MkErrorE errVal = MqReadBFL(ctx, &val_out);
1222 MkErrorC_Check(ctx, errVal);
1224 }
1225
1228 MK_UNUSED auto ctx = getCTX(MK_NULL_NO);
1229 MkRtSetup_X(ctx);
1230 MK_BUF val_out;
1231 enum MkErrorE errVal = MqReadBUF(ctx, &val_out);
1232 MkErrorC_Check(ctx, errVal);
1234 }
1235
1236 // doc-key: MqContextC,MqContextC-ReadApi-Atom,omo
1237
1240 MK_UNUSED auto ctx = getCTX(MK_NULL_NO);
1241 MkRtSetup_X(ctx);
1242 MkBinaryR val_out_ref;
1243 enum MkErrorE errVal = MqReadBIN(ctx, &val_out_ref);
1244 ErrorCheck(errVal);
1245 MK_BNP val_out = std::make_pair(val_out_ref.size,val_out_ref.data);
1246 return val_out;
1247 }
1248
1251 MK_UNUSED auto ctx = getCTX(MK_NULL_NO);
1252 MkRtSetup_X(ctx);
1253 MK_BOL val_out;
1254 enum MkErrorE errVal = MqReadBOL(ctx, &val_out);
1255 MkErrorC_Check(ctx, errVal);
1256 return val_out != 0;
1257 }
1258
1261 MK_UNUSED auto ctx = getCTX(MK_NULL_NO);
1262 MkRtSetup_X(ctx);
1263 MkBinaryR val_out_ref;
1264 enum MkErrorE errVal = MqReadBinaryR(ctx, &val_out_ref);
1265 ErrorCheck(errVal);
1266 MK_BNP val_out = std::make_pair(val_out_ref.size,val_out_ref.data);
1267 return val_out;
1268 }
1269
1272 MK_UNUSED auto ctx = getCTX(MK_NULL_NO);
1273 MkRtSetup_X(ctx);
1274 MK_DBL val_out;
1275 enum MkErrorE errVal = MqReadDBL(ctx, &val_out);
1276 MkErrorC_Check(ctx, errVal);
1277 return val_out;
1278 }
1279
1282 MK_UNUSED auto ctx = getCTX(MK_NULL_NO);
1283 MkRtSetup_X(ctx);
1284 MK_FLT val_out;
1285 enum MkErrorE errVal = MqReadFLT(ctx, &val_out);
1286 MkErrorC_Check(ctx, errVal);
1287 return val_out;
1288 }
1289
1292 MK_UNUSED auto ctx = getCTX(MK_NULL_NO);
1293 MkRtSetup_X(ctx);
1294 MK_HDL val_out;
1295 enum MkErrorE errVal = MqReadHDL(ctx, &val_out);
1296 MkErrorC_Check(ctx, errVal);
1297 return val_out;
1298 }
1299
1302 MK_UNUSED auto ctx = getCTX(MK_NULL_NO);
1303 MkRtSetup_X(ctx);
1304 MK_I16 val_out;
1305 enum MkErrorE errVal = MqReadI16(ctx, &val_out);
1306 MkErrorC_Check(ctx, errVal);
1307 return val_out;
1308 }
1309
1312 MK_UNUSED auto ctx = getCTX(MK_NULL_NO);
1313 MkRtSetup_X(ctx);
1314 MK_I32 val_out;
1315 enum MkErrorE errVal = MqReadI32(ctx, &val_out);
1316 MkErrorC_Check(ctx, errVal);
1317 return val_out;
1318 }
1319
1322 MK_UNUSED auto ctx = getCTX(MK_NULL_NO);
1323 MkRtSetup_X(ctx);
1324 MK_I64 val_out;
1325 enum MkErrorE errVal = MqReadI64(ctx, &val_out);
1326 MkErrorC_Check(ctx, errVal);
1327 return val_out;
1328 }
1329
1332 MK_UNUSED auto ctx = getCTX(MK_NULL_NO);
1333 MkRtSetup_X(ctx);
1334 MK_I8 val_out;
1335 enum MkErrorE errVal = MqReadI8(ctx, &val_out);
1336 MkErrorC_Check(ctx, errVal);
1337 return (MK_I8)val_out;
1338 }
1339
1342
1345 MK_UNUSED auto ctx = getCTX(MK_NULL_NO);
1346 MkRtSetup_X(ctx);
1347 MK_LONG val_out;
1348 enum MkErrorE errVal = MqReadLONG(ctx, &val_out);
1349 MkErrorC_Check(ctx, errVal);
1350 return val_out;
1351 }
1352
1355
1358 MK_UNUSED auto ctx = getCTX(MK_NULL_NO);
1359 MkRtSetup_X(ctx);
1360 MK_STRN val_out;
1361 enum MkErrorE errVal = MqReadSTR(ctx, &val_out);
1362 MkErrorC_Check(ctx, errVal);
1363 return val_out;
1364 }
1365
1367 inline std::string MqContextC::ReadStringR () {
1368 MK_UNUSED auto ctx = getCTX(MK_NULL_NO);
1369 MkRtSetup_X(ctx);
1370 MkStringR val_out_ref;
1371 enum MkErrorE errVal = MqReadStringR(ctx, &val_out_ref);
1372 ErrorCheck(errVal);
1373 const std::string& val_out = std::string(val_out_ref.ptr,val_out_ref.len);
1374 return val_out;
1375 }
1376
1378 // MqContextC_ReadApi_Atom_CC_API
1379
1383
1384 // doc-key: MqContextC,MqContextC-ReadApi-Block,om_
1385
1387 inline void MqContextC::ReadL_END () {
1388 MK_UNUSED auto ctx = getCTX(MK_NULL_NO);
1389 MkRtSetup_X(ctx);
1390 enum MkErrorE errVal = MqReadL_END(ctx);
1391 MkErrorC_Check(ctx, errVal);
1392 }
1393
1396 MK_UNUSED auto ctx = getCTX(MK_NULL_NO);
1397 MkRtSetup_X(ctx);
1398 MK_BUF buf_hdl = MkBufferC::getBUF(buf,MK_NULL_YES);
1399 enum MkErrorE errVal = MqReadL_START(ctx, buf_hdl);
1400 MkErrorC_Check(ctx, errVal);
1401 }
1402
1404 inline void MqContextC::ReadL_START (const MkBufferC& buf) {
1405 MK_UNUSED auto ctx = getCTX(MK_NULL_NO);
1406 MkRtSetup_X(ctx);
1407 const MK_BUF buf_hdl = MkBufferC::getBUF(buf,MK_NULL_NO);
1408 enum MkErrorE errVal = MqReadL_START(ctx, buf_hdl);
1409 MkErrorC_Check(ctx, errVal);
1410 }
1411
1413 inline void MqContextC::ReadT_END () {
1414 MK_UNUSED auto ctx = getCTX(MK_NULL_NO);
1415 MkRtSetup_X(ctx);
1416 enum MkErrorE errVal = MqReadT_END(ctx);
1417 MkErrorC_Check(ctx, errVal);
1418 }
1419
1422 MK_UNUSED auto ctx = getCTX(MK_NULL_NO);
1423 MkRtSetup_X(ctx);
1424 enum MkErrorE errVal = MqReadT_START(ctx);
1425 MkErrorC_Check(ctx, errVal);
1426 }
1427
1429 // MqContextC_ReadApi_Block_CC_API
1430
1434
1435 // doc-key: MqContextC,MqContextC-ReadApi-Misc,om_
1436
1438 inline void MqContextC::ReadDbg () {
1439 MK_UNUSED auto ctx = getCTX(MK_NULL_NO);
1440 MkRtSetup_X(ctx);
1441 MqReadDbg(ctx);
1442 }
1443
1446 MK_UNUSED auto ctx = getCTX(MK_NULL_NO);
1447 MkRtSetup_X(ctx);
1448 enum MkTypeE __retVal__L = MqReadGetNextType(ctx);
1449 return __retVal__L;
1450 }
1451
1454 MK_UNUSED auto ctx = getCTX(MK_NULL_NO);
1455 MkRtSetup_X(ctx);
1456 MK_NUM __retVal__L = MqReadGetNumItems(ctx);
1457 return __retVal__L;
1458 }
1459
1462 MK_UNUSED auto ctx = getCTX(MK_NULL_NO);
1463 MkRtSetup_X(ctx);
1464 MK_BOOL __retVal__L = MqReadItemExists(ctx);
1465 return __retVal__L;
1466 }
1467
1469 inline void MqContextC::ReadUndo () {
1470 MK_UNUSED auto ctx = getCTX(MK_NULL_NO);
1471 MkRtSetup_X(ctx);
1472 enum MkErrorE errVal = MqReadUndo(ctx);
1473 MkErrorC_Check(ctx, errVal);
1474 }
1475
1477 // MqContextC_ReadApi_Misc_CC_API
1478
1482
1483 // doc-key: MqContextC,MqContextC-RouteApi-Route,oco
1484
1487 MK_UNUSED auto ctx = getCTX(MK_NULL_NO);
1488 MkRtSetup_X(ctx);
1489 MK_BFL treeP_out;
1490 enum MkErrorE errVal = MqRouteGetTree(ctx, &treeP_out);
1491 MkErrorC_Check(ctx, errVal);
1493 }
1494
1495 // doc-key: MqContextC,MqContextC-RouteApi-Route,om_
1496
1498 inline void MqContextC::RouteCreate (MK_STRN route, MK_STRN service, MK_BOOL overwrite) {
1499 MK_UNUSED auto ctx = getCTX(MK_NULL_NO);
1500 MkRtSetup_X(ctx);
1501 enum MkErrorE errVal = MqRouteCreate(ctx, route, service, overwrite);
1502 MkErrorC_Check(ctx, errVal);
1503 }
1504
1506 inline void MqContextC::RouteCreate (const std::string& route, const std::string& service, MK_BOOL overwrite) {
1507 MK_UNUSED auto ctx = getCTX(MK_NULL_NO);
1508 MkRtSetup_X(ctx);
1509 const MK_STRN route_hdl = route.c_str();
1510 const MK_STRN service_hdl = service.c_str();
1511 enum MkErrorE errVal = MqRouteCreate(ctx, route_hdl, service_hdl, overwrite);
1512 MkErrorC_Check(ctx, errVal);
1513 }
1514
1516 inline void MqContextC::RouteDelete (MK_STRN route, MK_STRN service, MK_BOOL overwrite) {
1517 MK_UNUSED auto ctx = getCTX(MK_NULL_NO);
1518 MkRtSetup_X(ctx);
1519 enum MkErrorE errVal = MqRouteDelete(ctx, route, service, overwrite);
1520 MkErrorC_Check(ctx, errVal);
1521 }
1522
1524 inline void MqContextC::RouteDelete (const std::string& route, const std::string& service, MK_BOOL overwrite) {
1525 MK_UNUSED auto ctx = getCTX(MK_NULL_NO);
1526 MkRtSetup_X(ctx);
1527 const MK_STRN route_hdl = route.c_str();
1528 const MK_STRN service_hdl = service.c_str();
1529 enum MkErrorE errVal = MqRouteDelete(ctx, route_hdl, service_hdl, overwrite);
1530 MkErrorC_Check(ctx, errVal);
1531 }
1532
1535 MK_UNUSED auto ctx = getCTX(MK_NULL_NO);
1536 MkRtSetup_X(ctx);
1537 MQ_CTX_A __retVal__L = MqRouteResolve(ctx, ident, retnum);
1538 static __thread MK_NUM szret = 0;
1539 static __thread MqContextC* *ret = NULL;
1540 if (__retVal__L.size+1 > szret) {
1541 szret=__retVal__L.size*2+1;
1542 ret=(MqContextC**)MkSysRealloc(MK_ERROR_PANIC,ret,szret*sizeof(MqContextC*));
1543 }
1544 MK_NUM num;
1545 for (num=0; num<__retVal__L.size; num++) {
1546 ret[num] = MqContextC::MqContextC_ObjNew(MK_RT_CALL __retVal__L.data[num]);
1547 }
1548 ret[num] = NULL;
1549 return (MqContextC_A) {__retVal__L.size,ret};
1550 }
1551
1553 inline MqContextC_A MqContextC::RouteResolve (const std::string& ident, MK_NUM retnum) {
1554 MK_UNUSED auto ctx = getCTX(MK_NULL_NO);
1555 MkRtSetup_X(ctx);
1556 const MK_STRN ident_hdl = ident.c_str();
1557 MQ_CTX_A __retVal__L = MqRouteResolve(ctx, ident_hdl, retnum);
1558 static __thread MK_NUM szret = 0;
1559 static __thread MqContextC* *ret = NULL;
1560 if (__retVal__L.size+1 > szret) {
1561 szret=__retVal__L.size*2+1;
1562 ret=(MqContextC**)MkSysRealloc(MK_ERROR_PANIC,ret,szret*sizeof(MqContextC*));
1563 }
1564 MK_NUM num;
1565 for (num=0; num<__retVal__L.size; num++) {
1566 ret[num] = MqContextC::MqContextC_ObjNew(MK_RT_CALL __retVal__L.data[num]);
1567 }
1568 ret[num] = NULL;
1569 return (MqContextC_A) {__retVal__L.size,ret};
1570 }
1571
1573 inline void MqContextC::RouteTraverse (MK_STRN service, MkBufferListC* args) {
1574 MK_UNUSED auto ctx = getCTX(MK_NULL_NO);
1575 MkRtSetup_X(ctx);
1576 MK_BAC args_hdl = MkBufferListC::getBFL(args,MK_NULL_YES);
1577 enum MkErrorE errVal = MqRouteTraverse(ctx, service, args_hdl);
1578 MkErrorC_Check(ctx, errVal);
1579 }
1580
1582 inline void MqContextC::RouteTraverse (MK_STRN service, const MkBufferListC& args) {
1583 MK_UNUSED auto ctx = getCTX(MK_NULL_NO);
1584 MkRtSetup_X(ctx);
1585 const MK_BAC args_hdl = MkBufferListC::getBFL(args,MK_NULL_NO);
1586 enum MkErrorE errVal = MqRouteTraverse(ctx, service, args_hdl);
1587 MkErrorC_Check(ctx, errVal);
1588 }
1589
1591 inline void MqContextC::RouteTraverse (const std::string& service, MkBufferListC* args) {
1592 MK_UNUSED auto ctx = getCTX(MK_NULL_NO);
1593 MkRtSetup_X(ctx);
1594 const MK_STRN service_hdl = service.c_str();
1595 MK_BAC args_hdl = MkBufferListC::getBFL(args,MK_NULL_YES);
1596 enum MkErrorE errVal = MqRouteTraverse(ctx, service_hdl, args_hdl);
1597 MkErrorC_Check(ctx, errVal);
1598 }
1599
1601 inline void MqContextC::RouteTraverse (const std::string& service, const MkBufferListC& args) {
1602 MK_UNUSED auto ctx = getCTX(MK_NULL_NO);
1603 MkRtSetup_X(ctx);
1604 const MK_STRN service_hdl = service.c_str();
1605 const MK_BAC args_hdl = MkBufferListC::getBFL(args,MK_NULL_NO);
1606 enum MkErrorE errVal = MqRouteTraverse(ctx, service_hdl, args_hdl);
1607 MkErrorC_Check(ctx, errVal);
1608 }
1609
1610 // doc-key: MqContextC,MqContextC-RouteApi-Route,omo
1611
1614 MK_UNUSED auto ctx = getCTX(MK_NULL_NO);
1615 MkRtSetup_X(ctx);
1616 MK_STRN path_out;
1617 enum MkErrorE errVal = MqRouteGetPath(ctx, &path_out);
1618 MkErrorC_Check(ctx, errVal);
1619 return path_out;
1620 }
1621
1623 // MqContextC_RouteApi_Route_CC_API
1624
1628
1629 // doc-key: MqContextC,MqContextC-SendApi-Atom,om_
1630
1632 inline void MqContextC::SendBFL (const MkBufferListC* val) {
1633 MK_UNUSED auto ctx = getCTX(MK_NULL_NO);
1634 MkRtSetup_X(ctx);
1636 enum MkErrorE errVal = MqSendBFL(ctx, val_hdl);
1637 MkErrorC_Check(ctx, errVal);
1638 }
1639
1641 inline void MqContextC::SendBFL (const MkBufferListC& val) {
1642 MK_UNUSED auto ctx = getCTX(MK_NULL_NO);
1643 MkRtSetup_X(ctx);
1644 const MK_BFLN val_hdl = MkBufferListC::getBFLN(val,MK_NULL_NO);
1645 enum MkErrorE errVal = MqSendBFL(ctx, val_hdl);
1646 MkErrorC_Check(ctx, errVal);
1647 }
1648
1650 inline void MqContextC::SendBIN (MK_BNP val) {
1651 MK_UNUSED auto ctx = getCTX(MK_NULL_NO);
1652 MkRtSetup_X(ctx);
1653 const MkBinaryR val_ref = MkBinaryCreate(val.first,val.second);
1654 enum MkErrorE errVal = MqSendBIN(ctx, val_ref);
1655 MkErrorC_Check(ctx, errVal);
1656 }
1657
1659 inline void MqContextC::SendBOL (MK_BOL val) {
1660 MK_UNUSED auto ctx = getCTX(MK_NULL_NO);
1661 MkRtSetup_X(ctx);
1662 enum MkErrorE errVal = MqSendBOL(ctx, (MK_BOL)(val?1:0));
1663 MkErrorC_Check(ctx, errVal);
1664 }
1665
1667 inline void MqContextC::SendBUF (const MkBufferC* val) {
1668 MK_UNUSED auto ctx = getCTX(MK_NULL_NO);
1669 MkRtSetup_X(ctx);
1670 MK_BUFN val_hdl = MkBufferC::getBUFN(val,MK_NULL_NO);
1671 enum MkErrorE errVal = MqSendBUF(ctx, val_hdl);
1672 MkErrorC_Check(ctx, errVal);
1673 }
1674
1676 inline void MqContextC::SendBUF (const MkBufferC& val) {
1677 MK_UNUSED auto ctx = getCTX(MK_NULL_NO);
1678 MkRtSetup_X(ctx);
1679 const MK_BUFN val_hdl = MkBufferC::getBUFN(val,MK_NULL_NO);
1680 enum MkErrorE errVal = MqSendBUF(ctx, val_hdl);
1681 MkErrorC_Check(ctx, errVal);
1682 }
1683
1686 MK_UNUSED auto ctx = getCTX(MK_NULL_NO);
1687 MkRtSetup_X(ctx);
1689 enum MkErrorE errVal = MqSendBUS_FLAT(ctx, val_hdl);
1690 MkErrorC_Check(ctx, errVal);
1691 }
1692
1695 MK_UNUSED auto ctx = getCTX(MK_NULL_NO);
1696 MkRtSetup_X(ctx);
1697 const MK_BUSN val_hdl = MkBufferStreamC::getBUSN(val,MK_NULL_NO);
1698 enum MkErrorE errVal = MqSendBUS_FLAT(ctx, val_hdl);
1699 MkErrorC_Check(ctx, errVal);
1700 }
1701
1704 MK_UNUSED auto ctx = getCTX(MK_NULL_NO);
1705 MkRtSetup_X(ctx);
1706 const MkBinaryR val_ref = MkBinaryCreate(val.first,val.second);
1707 enum MkErrorE errVal = MqSendBinaryR(ctx, val_ref);
1708 MkErrorC_Check(ctx, errVal);
1709 }
1710
1712 inline void MqContextC::SendDBL (MK_DBL val) {
1713 MK_UNUSED auto ctx = getCTX(MK_NULL_NO);
1714 MkRtSetup_X(ctx);
1715 enum MkErrorE errVal = MqSendDBL(ctx, val);
1716 MkErrorC_Check(ctx, errVal);
1717 }
1718
1720 inline void MqContextC::SendFLT (MK_FLT val) {
1721 MK_UNUSED auto ctx = getCTX(MK_NULL_NO);
1722 MkRtSetup_X(ctx);
1723 enum MkErrorE errVal = MqSendFLT(ctx, val);
1724 MkErrorC_Check(ctx, errVal);
1725 }
1726
1728 inline void MqContextC::SendHDL (MK_HDL val) {
1729 MK_UNUSED auto ctx = getCTX(MK_NULL_NO);
1730 MkRtSetup_X(ctx);
1731 enum MkErrorE errVal = MqSendHDL(ctx, val);
1732 MkErrorC_Check(ctx, errVal);
1733 }
1734
1736 inline void MqContextC::SendI16 (MK_I16 val) {
1737 MK_UNUSED auto ctx = getCTX(MK_NULL_NO);
1738 MkRtSetup_X(ctx);
1739 enum MkErrorE errVal = MqSendI16(ctx, val);
1740 MkErrorC_Check(ctx, errVal);
1741 }
1742
1744 inline void MqContextC::SendI32 (MK_I32 val) {
1745 MK_UNUSED auto ctx = getCTX(MK_NULL_NO);
1746 MkRtSetup_X(ctx);
1747 enum MkErrorE errVal = MqSendI32(ctx, val);
1748 MkErrorC_Check(ctx, errVal);
1749 }
1750
1752 inline void MqContextC::SendI64 (MK_I64 val) {
1753 MK_UNUSED auto ctx = getCTX(MK_NULL_NO);
1754 MkRtSetup_X(ctx);
1755 enum MkErrorE errVal = MqSendI64(ctx, val);
1756 MkErrorC_Check(ctx, errVal);
1757 }
1758
1760 inline void MqContextC::SendI8 (MK_I8 val) {
1761 MK_UNUSED auto ctx = getCTX(MK_NULL_NO);
1762 MkRtSetup_X(ctx);
1763 enum MkErrorE errVal = MqSendI8(ctx, (MK_I8)(val));
1764 MkErrorC_Check(ctx, errVal);
1765 }
1766
1768 inline void MqContextC::SendLONG (MK_LONG val) {
1769 MK_UNUSED auto ctx = getCTX(MK_NULL_NO);
1770 MkRtSetup_X(ctx);
1771 enum MkErrorE errVal = MqSendLONG(ctx, val);
1772 MkErrorC_Check(ctx, errVal);
1773 }
1774
1776 inline void MqContextC::SendLTR (MQ_LTR transLId) {
1777 MK_UNUSED auto ctx = getCTX(MK_NULL_NO);
1778 MkRtSetup_X(ctx);
1779 enum MkErrorE errVal = MqSendLTR(ctx, transLId);
1780 MkErrorC_Check(ctx, errVal);
1781 }
1782
1784 inline void MqContextC::SendL_FLAT (const MkBufferListC* val) {
1785 MK_UNUSED auto ctx = getCTX(MK_NULL_NO);
1786 MkRtSetup_X(ctx);
1788 enum MkErrorE errVal = MqSendL_FLAT(ctx, val_hdl);
1789 MkErrorC_Check(ctx, errVal);
1790 }
1791
1793 inline void MqContextC::SendL_FLAT (const MkBufferListC& val) {
1794 MK_UNUSED auto ctx = getCTX(MK_NULL_NO);
1795 MkRtSetup_X(ctx);
1796 const MK_BFLN val_hdl = MkBufferListC::getBFLN(val,MK_NULL_NO);
1797 enum MkErrorE errVal = MqSendL_FLAT(ctx, val_hdl);
1798 MkErrorC_Check(ctx, errVal);
1799 }
1800
1802 inline void MqContextC::SendSTR (MK_STRN val) {
1803 MK_UNUSED auto ctx = getCTX(MK_NULL_NO);
1804 MkRtSetup_X(ctx);
1805 enum MkErrorE errVal = MqSendSTR(ctx, val);
1806 MkErrorC_Check(ctx, errVal);
1807 }
1808
1810 inline void MqContextC::SendSTR (const std::string& val) {
1811 MK_UNUSED auto ctx = getCTX(MK_NULL_NO);
1812 MkRtSetup_X(ctx);
1813 const MK_STRN val_hdl = val.c_str();
1814 enum MkErrorE errVal = MqSendSTR(ctx, val_hdl);
1815 MkErrorC_Check(ctx, errVal);
1816 }
1817
1819 inline void MqContextC::SendStringR (const std::string& val) {
1820 MK_UNUSED auto ctx = getCTX(MK_NULL_NO);
1821 MkRtSetup_X(ctx);
1822 const MkStringR val_ref = MkStringCreate((MK_NUM)val.size(),val.c_str());
1823 enum MkErrorE errVal = MqSendStringR(ctx, val_ref);
1824 MkErrorC_Check(ctx, errVal);
1825 }
1826
1828 inline void MqContextC::SendV (MK_FST printfmt, ... ) {
1829 MK_UNUSED auto ctx = getCTX(MK_NULL_NO);
1830 MkRtSetup_X(ctx);
1831 va_list ap;
1832 va_start (ap, printfmt);
1833 enum MkErrorE errVal = MqSendVL(ctx, printfmt, ap);
1834 va_end (ap);
1835 MkErrorC_Check(ctx, errVal);
1836 }
1837
1839 inline void MqContextC::SendVL (MK_FST printfmt, va_list var_list) {
1840 MK_UNUSED auto ctx = getCTX(MK_NULL_NO);
1841 MkRtSetup_X(ctx);
1842 enum MkErrorE errVal = MqSendVL(ctx, printfmt, var_list);
1843 MkErrorC_Check(ctx, errVal);
1844 }
1845
1847 // MqContextC_SendApi_Atom_CC_API
1848
1852
1853 // doc-key: MqContextC,MqContextC-SendApi-Basics,om_
1854
1856 inline void MqContextC::SendEND (MQ_TOK token, MK_TIME_T timeout) {
1857 MK_UNUSED auto ctx = getCTX(MK_NULL_NO);
1858 MkRtSetup_X(ctx);
1859 enum MkErrorE errVal = MqSendEND(ctx, token, timeout);
1860 MkErrorC_Check(ctx, errVal);
1861 }
1862
1864 inline void MqContextC::SendEND (const std::string& token, MK_TIME_T timeout) {
1865 MK_UNUSED auto ctx = getCTX(MK_NULL_NO);
1866 MkRtSetup_X(ctx);
1867 const MK_STRN token_hdl = token.c_str();
1868 enum MkErrorE errVal = MqSendEND(ctx, token_hdl, timeout);
1869 MkErrorC_Check(ctx, errVal);
1870 }
1871
1873 inline void MqContextC::SendEND_AND_CALLBACK (MQ_TOK token, MqServiceICB callback, MK_TIME_T timeout) {
1874 MK_UNUSED auto ctx = getCTX(MK_NULL_NO);
1875 MkRtSetup_X(ctx);
1876 auto callback_ptr = MqServiceCallbackC::Create(MK_RT_CALL callback, this);
1877 enum MkErrorE errVal = MqSendEND_AND_CALLBACK(ctx, token, MqServiceCallbackC::Call, callback_ptr, MqServiceCallbackC::Free, timeout);
1878 MkErrorC_Check(ctx, errVal);
1879 }
1880
1882 inline void MqContextC::SendEND_AND_CALLBACK (const std::string& token, MqServiceICB callback, MK_TIME_T timeout) {
1883 MK_UNUSED auto ctx = getCTX(MK_NULL_NO);
1884 MkRtSetup_X(ctx);
1885 const MK_STRN token_hdl = token.c_str();
1886 auto callback_ptr = MqServiceCallbackC::Create(MK_RT_CALL callback, this);
1887 enum MkErrorE errVal = MqSendEND_AND_CALLBACK(ctx, token_hdl, MqServiceCallbackC::Call, callback_ptr, MqServiceCallbackC::Free, timeout);
1888 MkErrorC_Check(ctx, errVal);
1889 }
1890
1892 inline void MqContextC::SendEND_AND_CALLBACK (MQ_TOK token, MqServiceCCB callback, MK_TIME_T timeout) {
1893 MK_UNUSED auto ctx = getCTX(MK_NULL_NO);
1894 MkRtSetup_X(ctx);
1895 auto callback_ptr = MqServiceCallbackC::Create(MK_RT_CALL callback, this);
1896 enum MkErrorE errVal = MqSendEND_AND_CALLBACK(ctx, token, MqServiceCallbackC::Call, callback_ptr, MqServiceCallbackC::Free, timeout);
1897 MkErrorC_Check(ctx, errVal);
1898 }
1899
1901 inline void MqContextC::SendEND_AND_CALLBACK (const std::string& token, MqServiceCCB callback, MK_TIME_T timeout) {
1902 MK_UNUSED auto ctx = getCTX(MK_NULL_NO);
1903 MkRtSetup_X(ctx);
1904 const MK_STRN token_hdl = token.c_str();
1905 auto callback_ptr = MqServiceCallbackC::Create(MK_RT_CALL callback, this);
1906 enum MkErrorE errVal = MqSendEND_AND_CALLBACK(ctx, token_hdl, MqServiceCallbackC::Call, callback_ptr, MqServiceCallbackC::Free, timeout);
1907 MkErrorC_Check(ctx, errVal);
1908 }
1909
1911 inline void MqContextC::SendEND_AND_CALLBACK (MQ_TOK token, MqServiceIF* callback, MK_TIME_T timeout) {
1912 MK_UNUSED auto ctx = getCTX(MK_NULL_NO);
1913 MkRtSetup_X(ctx);
1914 auto callback_ptr = MqServiceCallbackC::Create(MK_RT_CALL callback, this);
1915 enum MkErrorE errVal = MqSendEND_AND_CALLBACK(ctx, token, MqServiceCallbackC::Call, callback_ptr, MqServiceCallbackC::Free, timeout);
1916 MkErrorC_Check(ctx, errVal);
1917 }
1918
1920 inline void MqContextC::SendEND_AND_CALLBACK (const std::string& token, MqServiceIF* callback, MK_TIME_T timeout) {
1921 MK_UNUSED auto ctx = getCTX(MK_NULL_NO);
1922 MkRtSetup_X(ctx);
1923 const MK_STRN token_hdl = token.c_str();
1924 auto callback_ptr = MqServiceCallbackC::Create(MK_RT_CALL callback, this);
1925 enum MkErrorE errVal = MqSendEND_AND_CALLBACK(ctx, token_hdl, MqServiceCallbackC::Call, callback_ptr, MqServiceCallbackC::Free, timeout);
1926 MkErrorC_Check(ctx, errVal);
1927 }
1928
1930 inline void MqContextC::SendEND_AND_SUB (MQ_TOK token, MqServiceICB callback, MK_TIME_T timeout) {
1931 MK_UNUSED auto ctx = getCTX(MK_NULL_NO);
1932 MkRtSetup_X(ctx);
1933 auto callback_ptr = MqServiceCallbackC::Create(MK_RT_CALL callback, this);
1934 enum MkErrorE errVal = MqSendEND_AND_SUB(ctx, token, MqServiceCallbackC::Call, callback_ptr, MqServiceCallbackC::Free, timeout);
1935 MkErrorC_Check(ctx, errVal);
1936 }
1937
1939 inline void MqContextC::SendEND_AND_SUB (const std::string& token, MqServiceICB callback, MK_TIME_T timeout) {
1940 MK_UNUSED auto ctx = getCTX(MK_NULL_NO);
1941 MkRtSetup_X(ctx);
1942 const MK_STRN token_hdl = token.c_str();
1943 auto callback_ptr = MqServiceCallbackC::Create(MK_RT_CALL callback, this);
1944 enum MkErrorE errVal = MqSendEND_AND_SUB(ctx, token_hdl, MqServiceCallbackC::Call, callback_ptr, MqServiceCallbackC::Free, timeout);
1945 MkErrorC_Check(ctx, errVal);
1946 }
1947
1949 inline void MqContextC::SendEND_AND_SUB (MQ_TOK token, MqServiceCCB callback, MK_TIME_T timeout) {
1950 MK_UNUSED auto ctx = getCTX(MK_NULL_NO);
1951 MkRtSetup_X(ctx);
1952 auto callback_ptr = MqServiceCallbackC::Create(MK_RT_CALL callback, this);
1953 enum MkErrorE errVal = MqSendEND_AND_SUB(ctx, token, MqServiceCallbackC::Call, callback_ptr, MqServiceCallbackC::Free, timeout);
1954 MkErrorC_Check(ctx, errVal);
1955 }
1956
1958 inline void MqContextC::SendEND_AND_SUB (const std::string& token, MqServiceCCB callback, MK_TIME_T timeout) {
1959 MK_UNUSED auto ctx = getCTX(MK_NULL_NO);
1960 MkRtSetup_X(ctx);
1961 const MK_STRN token_hdl = token.c_str();
1962 auto callback_ptr = MqServiceCallbackC::Create(MK_RT_CALL callback, this);
1963 enum MkErrorE errVal = MqSendEND_AND_SUB(ctx, token_hdl, MqServiceCallbackC::Call, callback_ptr, MqServiceCallbackC::Free, timeout);
1964 MkErrorC_Check(ctx, errVal);
1965 }
1966
1968 inline void MqContextC::SendEND_AND_SUB (MQ_TOK token, MqServiceIF* callback, MK_TIME_T timeout) {
1969 MK_UNUSED auto ctx = getCTX(MK_NULL_NO);
1970 MkRtSetup_X(ctx);
1971 auto callback_ptr = MqServiceCallbackC::Create(MK_RT_CALL callback, this);
1972 enum MkErrorE errVal = MqSendEND_AND_SUB(ctx, token, MqServiceCallbackC::Call, callback_ptr, MqServiceCallbackC::Free, timeout);
1973 MkErrorC_Check(ctx, errVal);
1974 }
1975
1977 inline void MqContextC::SendEND_AND_SUB (const std::string& token, MqServiceIF* callback, MK_TIME_T timeout) {
1978 MK_UNUSED auto ctx = getCTX(MK_NULL_NO);
1979 MkRtSetup_X(ctx);
1980 const MK_STRN token_hdl = token.c_str();
1981 auto callback_ptr = MqServiceCallbackC::Create(MK_RT_CALL callback, this);
1982 enum MkErrorE errVal = MqSendEND_AND_SUB(ctx, token_hdl, MqServiceCallbackC::Call, callback_ptr, MqServiceCallbackC::Free, timeout);
1983 MkErrorC_Check(ctx, errVal);
1984 }
1985
1987 inline void MqContextC::SendEND_AND_TRANSACTION (MQ_TOK token, MQ_TOK callback, MK_TIME_T timeout) {
1988 MK_UNUSED auto ctx = getCTX(MK_NULL_NO);
1989 MkRtSetup_X(ctx);
1990 enum MkErrorE errVal = MqSendEND_AND_TRANSACTION(ctx, token, callback, timeout);
1991 MkErrorC_Check(ctx, errVal);
1992 }
1993
1995 inline void MqContextC::SendEND_AND_TRANSACTION (const std::string& token, const std::string& callback, MK_TIME_T timeout) {
1996 MK_UNUSED auto ctx = getCTX(MK_NULL_NO);
1997 MkRtSetup_X(ctx);
1998 const MK_STRN token_hdl = token.c_str();
1999 const MK_STRN callback_hdl = callback.c_str();
2000 enum MkErrorE errVal = MqSendEND_AND_TRANSACTION(ctx, token_hdl, callback_hdl, timeout);
2001 MkErrorC_Check(ctx, errVal);
2002 }
2003
2005 inline void MqContextC::SendEND_AND_WAIT (MQ_TOK token, MK_TIME_T timeout) {
2006 MK_UNUSED auto ctx = getCTX(MK_NULL_NO);
2007 MkRtSetup_X(ctx);
2008 enum MkErrorE errVal = MqSendEND_AND_WAIT(ctx, token, timeout);
2009 MkErrorC_Check(ctx, errVal);
2010 }
2011
2013 inline void MqContextC::SendEND_AND_WAIT (const std::string& token, MK_TIME_T timeout) {
2014 MK_UNUSED auto ctx = getCTX(MK_NULL_NO);
2015 MkRtSetup_X(ctx);
2016 const MK_STRN token_hdl = token.c_str();
2017 enum MkErrorE errVal = MqSendEND_AND_WAIT(ctx, token_hdl, timeout);
2018 MkErrorC_Check(ctx, errVal);
2019 }
2020
2022 inline void MqContextC::SendSTART () {
2023 MK_UNUSED auto ctx = getCTX(MK_NULL_NO);
2024 MkRtSetup_X(ctx);
2025 enum MkErrorE errVal = MqSendSTART(ctx);
2026 MkErrorC_Check(ctx, errVal);
2027 }
2028
2030 inline void MqContextC::SendSYNC () {
2031 MK_UNUSED auto ctx = getCTX(MK_NULL_NO);
2032 MkRtSetup_X(ctx);
2033 enum MkErrorE errVal = MqSendSYNC(ctx);
2034 MkErrorC_Check(ctx, errVal);
2035 }
2036
2038 // MqContextC_SendApi_Basics_CC_API
2039
2043
2044 // doc-key: MqContextC,MqContextC-SendApi-Block,om_
2045
2047 inline void MqContextC::SendL_END () {
2048 MK_UNUSED auto ctx = getCTX(MK_NULL_NO);
2049 MkRtSetup_X(ctx);
2050 enum MkErrorE errVal = MqSendL_END(ctx);
2051 MkErrorC_Check(ctx, errVal);
2052 }
2053
2056 MK_UNUSED auto ctx = getCTX(MK_NULL_NO);
2057 MkRtSetup_X(ctx);
2058 enum MkErrorE errVal = MqSendL_START(ctx);
2059 MkErrorC_Check(ctx, errVal);
2060 }
2061
2063 inline void MqContextC::SendT_END () {
2064 MK_UNUSED auto ctx = getCTX(MK_NULL_NO);
2065 MkRtSetup_X(ctx);
2066 enum MkErrorE errVal = MqSendT_END(ctx);
2067 MkErrorC_Check(ctx, errVal);
2068 }
2069
2072 MK_UNUSED auto ctx = getCTX(MK_NULL_NO);
2073 MkRtSetup_X(ctx);
2074 enum MkErrorE errVal = MqSendT_START(ctx);
2075 MkErrorC_Check(ctx, errVal);
2076 }
2077
2079 // MqContextC_SendApi_Block_CC_API
2080
2084
2085 // doc-key: MqContextC,MqContextC-SendApi-Return,om_
2086
2088 inline void MqContextC::SendERROR () {
2089 MK_UNUSED auto ctx = getCTX(MK_NULL_NO);
2090 MkRtSetup_X(ctx);
2091 enum MkErrorE errVal = MqSendERROR(ctx);
2092 MkErrorC_Check(ctx, errVal);
2093 }
2094
2096 inline void MqContextC::SendRETURN () {
2097 MK_UNUSED auto ctx = getCTX(MK_NULL_NO);
2098 MkRtSetup_X(ctx);
2099 enum MkErrorE errVal = MqSendRETURN(ctx);
2100 MkErrorC_Check(ctx, errVal);
2101 }
2102
2105 MK_UNUSED auto ctx = getCTX(MK_NULL_NO);
2106 MkRtSetup_X(ctx);
2107 enum MkErrorE errVal = MqSendRETURN_SUB(ctx);
2108 MkErrorC_Check(ctx, errVal);
2109 }
2110
2112 // MqContextC_SendApi_Return_CC_API
2113
2117
2118 // doc-key: MqContextC,MqContextC-ServiceApi-Service,om_
2119
2121 inline void MqContextC::ServiceCreate (MQ_TOK token, MqServiceICB callback) {
2122 MK_UNUSED auto ctx = getCTX(MK_NULL_NO);
2123 MkRtSetup_X(ctx);
2124 auto callback_ptr = MqServiceCallbackC::Create(MK_RT_CALL callback, this);
2125 enum MkErrorE errVal = MqServiceCreate(ctx, token, MqServiceCallbackC::Call, callback_ptr, MqServiceCallbackC::Free, NULL);
2126 MkErrorC_Check(ctx, errVal);
2127 }
2128
2130 inline void MqContextC::ServiceCreate (const std::string& token, MqServiceICB callback) {
2131 MK_UNUSED auto ctx = getCTX(MK_NULL_NO);
2132 MkRtSetup_X(ctx);
2133 const MK_STRN token_hdl = token.c_str();
2134 auto callback_ptr = MqServiceCallbackC::Create(MK_RT_CALL callback, this);
2135 enum MkErrorE errVal = MqServiceCreate(ctx, token_hdl, MqServiceCallbackC::Call, callback_ptr, MqServiceCallbackC::Free, NULL);
2136 MkErrorC_Check(ctx, errVal);
2137 }
2138
2140 inline void MqContextC::ServiceCreate (MQ_TOK token, MqServiceCCB callback) {
2141 MK_UNUSED auto ctx = getCTX(MK_NULL_NO);
2142 MkRtSetup_X(ctx);
2143 auto callback_ptr = MqServiceCallbackC::Create(MK_RT_CALL callback, this);
2144 enum MkErrorE errVal = MqServiceCreate(ctx, token, MqServiceCallbackC::Call, callback_ptr, MqServiceCallbackC::Free, NULL);
2145 MkErrorC_Check(ctx, errVal);
2146 }
2147
2149 inline void MqContextC::ServiceCreate (const std::string& token, MqServiceCCB callback) {
2150 MK_UNUSED auto ctx = getCTX(MK_NULL_NO);
2151 MkRtSetup_X(ctx);
2152 const MK_STRN token_hdl = token.c_str();
2153 auto callback_ptr = MqServiceCallbackC::Create(MK_RT_CALL callback, this);
2154 enum MkErrorE errVal = MqServiceCreate(ctx, token_hdl, MqServiceCallbackC::Call, callback_ptr, MqServiceCallbackC::Free, NULL);
2155 MkErrorC_Check(ctx, errVal);
2156 }
2157
2159 inline void MqContextC::ServiceCreate (MQ_TOK token, MqServiceIF* callback) {
2160 MK_UNUSED auto ctx = getCTX(MK_NULL_NO);
2161 MkRtSetup_X(ctx);
2162 auto callback_ptr = MqServiceCallbackC::Create(MK_RT_CALL callback, this);
2163 enum MkErrorE errVal = MqServiceCreate(ctx, token, MqServiceCallbackC::Call, callback_ptr, MqServiceCallbackC::Free, NULL);
2164 MkErrorC_Check(ctx, errVal);
2165 }
2166
2168 inline void MqContextC::ServiceCreate (const std::string& token, MqServiceIF* callback) {
2169 MK_UNUSED auto ctx = getCTX(MK_NULL_NO);
2170 MkRtSetup_X(ctx);
2171 const MK_STRN token_hdl = token.c_str();
2172 auto callback_ptr = MqServiceCallbackC::Create(MK_RT_CALL callback, this);
2173 enum MkErrorE errVal = MqServiceCreate(ctx, token_hdl, MqServiceCallbackC::Call, callback_ptr, MqServiceCallbackC::Free, NULL);
2174 MkErrorC_Check(ctx, errVal);
2175 }
2176
2178 inline void MqContextC::ServiceDelete (MQ_TOK token) {
2179 MK_UNUSED auto ctx = getCTX(MK_NULL_NO);
2180 MkRtSetup_X(ctx);
2181 enum MkErrorE errVal = MqServiceDelete(ctx, token);
2182 MkErrorC_Check(ctx, errVal);
2183 }
2184
2186 inline void MqContextC::ServiceDelete (const std::string& token) {
2187 MK_UNUSED auto ctx = getCTX(MK_NULL_NO);
2188 MkRtSetup_X(ctx);
2189 const MK_STRN token_hdl = token.c_str();
2190 enum MkErrorE errVal = MqServiceDelete(ctx, token_hdl);
2191 MkErrorC_Check(ctx, errVal);
2192 }
2193
2196 MK_UNUSED auto ctx = getCTX(MK_NULL_NO);
2197 MkRtSetup_X(ctx);
2198 MK_BOOL __retVal__L = MqServiceIsTransaction(ctx);
2199 return __retVal__L;
2200 }
2201
2204 MK_UNUSED auto ctx = getCTX(MK_NULL_NO);
2205 MkRtSetup_X(ctx);
2206 enum MkErrorE errVal = MqServiceProxy(ctx, token, id);
2207 MkErrorC_Check(ctx, errVal);
2208 }
2209
2211 inline void MqContextC::ServiceProxy (const std::string& token, MQ_SLAVE_ID id) {
2212 MK_UNUSED auto ctx = getCTX(MK_NULL_NO);
2213 MkRtSetup_X(ctx);
2214 const MK_STRN token_hdl = token.c_str();
2215 enum MkErrorE errVal = MqServiceProxy(ctx, token_hdl, id);
2216 MkErrorC_Check(ctx, errVal);
2217 }
2218
2220 inline void MqContextC::ServiceProxyCtx (MQ_TOK token, MqContextC* target) {
2221 MK_UNUSED auto ctx = getCTX(MK_NULL_NO);
2222 MkRtSetup_X(ctx);
2223 MQ_CTX target_hdl = MqContextC::getCTX(target,MK_NULL_NO);
2224 enum MkErrorE errVal = MqServiceProxyCtx(ctx, token, target_hdl);
2225 MkErrorC_Check(ctx, errVal);
2226 }
2227
2229 inline void MqContextC::ServiceProxyCtx (MQ_TOK token, const MqContextC& target) {
2230 MK_UNUSED auto ctx = getCTX(MK_NULL_NO);
2231 MkRtSetup_X(ctx);
2232 const MQ_CTX target_hdl = MqContextC::getCTX(target,MK_NULL_NO);
2233 enum MkErrorE errVal = MqServiceProxyCtx(ctx, token, target_hdl);
2234 MkErrorC_Check(ctx, errVal);
2235 }
2236
2238 inline void MqContextC::ServiceProxyCtx (const std::string& token, MqContextC* target) {
2239 MK_UNUSED auto ctx = getCTX(MK_NULL_NO);
2240 MkRtSetup_X(ctx);
2241 const MK_STRN token_hdl = token.c_str();
2242 MQ_CTX target_hdl = MqContextC::getCTX(target,MK_NULL_NO);
2243 enum MkErrorE errVal = MqServiceProxyCtx(ctx, token_hdl, target_hdl);
2244 MkErrorC_Check(ctx, errVal);
2245 }
2246
2248 inline void MqContextC::ServiceProxyCtx (const std::string& token, const MqContextC& target) {
2249 MK_UNUSED auto ctx = getCTX(MK_NULL_NO);
2250 MkRtSetup_X(ctx);
2251 const MK_STRN token_hdl = token.c_str();
2252 const MQ_CTX target_hdl = MqContextC::getCTX(target,MK_NULL_NO);
2253 enum MkErrorE errVal = MqServiceProxyCtx(ctx, token_hdl, target_hdl);
2254 MkErrorC_Check(ctx, errVal);
2255 }
2256
2259 MK_UNUSED auto ctx = getCTX(MK_NULL_NO);
2260 MkRtSetup_X(ctx);
2261 MQ_CTX target_hdl = MqContextC::getCTX(target,MK_NULL_NO);
2262 MK_BOOL __retVal__L = MqServiceProxyCtxExists(ctx, token, target_hdl);
2263 return __retVal__L;
2264 }
2265
2268 MK_UNUSED auto ctx = getCTX(MK_NULL_NO);
2269 MkRtSetup_X(ctx);
2270 const MQ_CTX target_hdl = MqContextC::getCTX(target,MK_NULL_NO);
2271 MK_BOOL __retVal__L = MqServiceProxyCtxExists(ctx, token, target_hdl);
2272 return __retVal__L;
2273 }
2274
2276 inline MK_BOOL MqContextC::ServiceProxyCtxExists (const std::string& token, MqContextC* target) {
2277 MK_UNUSED auto ctx = getCTX(MK_NULL_NO);
2278 MkRtSetup_X(ctx);
2279 const MK_STRN token_hdl = token.c_str();
2280 MQ_CTX target_hdl = MqContextC::getCTX(target,MK_NULL_NO);
2281 MK_BOOL __retVal__L = MqServiceProxyCtxExists(ctx, token_hdl, target_hdl);
2282 return __retVal__L;
2283 }
2284
2286 inline MK_BOOL MqContextC::ServiceProxyCtxExists (const std::string& token, const MqContextC& target) {
2287 MK_UNUSED auto ctx = getCTX(MK_NULL_NO);
2288 MkRtSetup_X(ctx);
2289 const MK_STRN token_hdl = token.c_str();
2290 const MQ_CTX target_hdl = MqContextC::getCTX(target,MK_NULL_NO);
2291 MK_BOOL __retVal__L = MqServiceProxyCtxExists(ctx, token_hdl, target_hdl);
2292 return __retVal__L;
2293 }
2294
2297 MK_UNUSED auto ctx = getCTX(MK_NULL_NO);
2298 MkRtSetup_X(ctx);
2299 enum MkErrorE errVal = MqServiceProxyRoundRobin(ctx, token, ident);
2300 MkErrorC_Check(ctx, errVal);
2301 }
2302
2304 inline void MqContextC::ServiceProxyRoundRobin (const std::string& token, const std::string& ident) {
2305 MK_UNUSED auto ctx = getCTX(MK_NULL_NO);
2306 MkRtSetup_X(ctx);
2307 const MK_STRN token_hdl = token.c_str();
2308 const MK_STRN ident_hdl = ident.c_str();
2309 enum MkErrorE errVal = MqServiceProxyRoundRobin(ctx, token_hdl, ident_hdl);
2310 MkErrorC_Check(ctx, errVal);
2311 }
2312
2315 MK_UNUSED auto ctx = getCTX(MK_NULL_NO);
2316 MkRtSetup_X(ctx);
2317 enum MkErrorE errVal = MqServiceStorage(ctx, token);
2318 MkErrorC_Check(ctx, errVal);
2319 }
2320
2322 inline void MqContextC::ServiceStorage (const std::string& token) {
2323 MK_UNUSED auto ctx = getCTX(MK_NULL_NO);
2324 MkRtSetup_X(ctx);
2325 const MK_STRN token_hdl = token.c_str();
2326 enum MkErrorE errVal = MqServiceStorage(ctx, token_hdl);
2327 MkErrorC_Check(ctx, errVal);
2328 }
2329
2332 MK_UNUSED auto ctx = getCTX(MK_NULL_NO);
2333 MkRtSetup_X(ctx);
2334 MK_BOOL __retVal__L = MqServiceTokenCheck(ctx, token);
2335 return __retVal__L;
2336 }
2337
2339 inline MK_BOOL MqContextC::ServiceTokenCheck (const std::string& token) {
2340 MK_UNUSED auto ctx = getCTX(MK_NULL_NO);
2341 MkRtSetup_X(ctx);
2342 const MK_STRN token_hdl = token.c_str();
2343 MK_BOOL __retVal__L = MqServiceTokenCheck(ctx, token_hdl);
2344 return __retVal__L;
2345 }
2346
2349 MK_UNUSED auto ctx = getCTX(MK_NULL_NO);
2350 MkRtSetup_X(ctx);
2351 MK_BOOL __retVal__L = MqServiceTokenExists(ctx, token);
2352 return __retVal__L;
2353 }
2354
2356 inline MK_BOOL MqContextC::ServiceTokenExists (const std::string& token) {
2357 MK_UNUSED auto ctx = getCTX(MK_NULL_NO);
2358 MkRtSetup_X(ctx);
2359 const MK_STRN token_hdl = token.c_str();
2360 MK_BOOL __retVal__L = MqServiceTokenExists(ctx, token_hdl);
2361 return __retVal__L;
2362 }
2363
2366 MK_UNUSED auto ctx = getCTX(MK_NULL_NO);
2367 MkRtSetup_X(ctx);
2368 MQ_TOK __retVal__L = MqServiceTokenGet(ctx);
2369 return __retVal__L;
2370 }
2371
2373 // MqContextC_ServiceApi_Service_CC_API
2374
2378
2379 // doc-key: MqContextC,MqContextC-SlaveApi-Slave,oc_
2380
2383 MK_UNUSED auto ctx = getCTX(MK_NULL_NO);
2384 MkRtSetup_X(ctx);
2385 MQ_CTX __retVal__L = MqSlaveGetMaster(ctx);
2386 return MqContextC::MqContextC_ObjNew(MK_RT_CALL __retVal__L);
2387 }
2388
2389 // doc-key: MqContextC,MqContextC-SlaveApi-Slave,oco
2390
2393 MK_UNUSED auto ctx = getCTX(MK_NULL_NO);
2394 MkRtSetup_X(ctx);
2395 MQ_CTX ctx_out;
2396 enum MkErrorE errVal = MqSlaveGet(ctx, id, &ctx_out);
2397 MkErrorC_Check(ctx, errVal);
2399 }
2400
2403 MK_UNUSED auto ctx = getCTX(MK_NULL_NO);
2404 MkRtSetup_X(ctx);
2405 MQ_CTX ctx_out;
2406 enum MkErrorE errVal = MqSlaveGetFilter(ctx, &ctx_out);
2407 MkErrorC_Check(ctx, errVal);
2409 }
2410
2413 MK_UNUSED auto ctx = getCTX(MK_NULL_NO);
2414 MkRtSetup_X(ctx);
2415 MQ_CTX ctx_out;
2416 enum MkErrorE errVal = MqSlaveGetProxy(ctx, id, &ctx_out);
2417 MkErrorC_Check(ctx, errVal);
2419 }
2420
2421 // doc-key: MqContextC,MqContextC-SlaveApi-Slave,om_
2422
2425 MK_UNUSED auto ctx = getCTXN(MK_NULL_NO);
2426 MkRtSetup_X(ctx);
2427 MK_BOOL __retVal__L = MqSlaveCheck(ctx, id);
2428 return __retVal__L;
2429 }
2430
2433 MK_UNUSED auto ctx = getCTX(MK_NULL_NO);
2434 MkRtSetup_X(ctx);
2435 MQ_CTX slave_hdl = MqContextC::getCTX(slave,MK_NULL_NO);
2436 enum MkErrorE errVal = MqSlaveCreate(ctx, id, slave_hdl);
2437 MkErrorC_Check(ctx, errVal);
2438 }
2439
2441 inline void MqContextC::SlaveCreate (MQ_SLAVE_ID id, const MqContextC& slave) {
2442 MK_UNUSED auto ctx = getCTX(MK_NULL_NO);
2443 MkRtSetup_X(ctx);
2444 const MQ_CTX slave_hdl = MqContextC::getCTX(slave,MK_NULL_NO);
2445 enum MkErrorE errVal = MqSlaveCreate(ctx, id, slave_hdl);
2446 MkErrorC_Check(ctx, errVal);
2447 }
2448
2451 MK_UNUSED auto ctx = getCTX(MK_NULL_NO);
2452 MkRtSetup_X(ctx);
2453 enum MkErrorE errVal = MqSlaveDelete(ctx, id);
2454 MkErrorC_Check(ctx, errVal);
2455 }
2456
2459 MK_UNUSED auto ctx = getCTXN(MK_NULL_NO);
2460 MkRtSetup_X(ctx);
2461 MK_BOOL __retVal__L = MqSlaveIs(ctx);
2462 return __retVal__L;
2463 }
2464
2467 MK_UNUSED auto ctx = getCTX(MK_NULL_NO);
2468 MkRtSetup_X(ctx);
2469 MK_BAC args_hdl = MkBufferListC::getBFL(args,MK_NULL_YES);
2470 enum MkErrorE errVal = MqSlaveWorker(ctx, id, fct, args_hdl);
2471 MkErrorC_Check(ctx, errVal);
2472 }
2473
2475 // MqContextC_SlaveApi_Slave_CC_API
2476
2480
2481 // doc-key: MqContextC,MqContextC-StorageApi-Storage,oci
2482
2484 inline MQ_LTR MqContextC::StorageDelete (MQ_LTR *transLIdP_inout) {
2485 MK_UNUSED auto ctx = getCTX(MK_NULL_NO);
2486 MkRtSetup_X(ctx);
2487 MQ_LTR transLIdP_inout_val = transLIdP_inout == NULL ? 0 : (MQ_LTR)(*transLIdP_inout);
2488 enum MkErrorE errVal = MqStorageDelete(ctx, &transLIdP_inout_val);
2489 if (transLIdP_inout != NULL) {*transLIdP_inout = (MQ_LTR)(transLIdP_inout_val);}
2490 MkErrorC_Check(ctx, errVal);
2491 return transLIdP_inout_val;
2492 }
2493
2495 inline MQ_LTR MqContextC::StorageImport (MQ_LTR *transLIdP_inout) {
2496 MK_UNUSED auto ctx = getCTX(MK_NULL_NO);
2497 MkRtSetup_X(ctx);
2498 MQ_LTR transLIdP_inout_val = transLIdP_inout == NULL ? 0 : (MQ_LTR)(*transLIdP_inout);
2499 enum MkErrorE errVal = MqStorageImport(ctx, &transLIdP_inout_val);
2500 if (transLIdP_inout != NULL) {*transLIdP_inout = (MQ_LTR)(transLIdP_inout_val);}
2501 MkErrorC_Check(ctx, errVal);
2502 return transLIdP_inout_val;
2503 }
2504
2505 // doc-key: MqContextC,MqContextC-StorageApi-Storage,om_
2506
2509 MK_UNUSED auto ctx = getCTX(MK_NULL_NO);
2510 MkRtSetup_X(ctx);
2511 enum MkErrorE errVal = MqStorageClose(ctx);
2512 MkErrorC_Check(ctx, errVal);
2513 }
2514
2516 inline void MqContextC::StorageDecrRef (MQ_LTR transLId) {
2517 MK_UNUSED auto ctx = getCTX(MK_NULL_NO);
2518 MkRtSetup_X(ctx);
2519 enum MkErrorE errVal = MqStorageDecrRef(ctx, transLId);
2520 MkErrorC_Check(ctx, errVal);
2521 }
2522
2524 inline void MqContextC::StorageIncrRef (MQ_LTR transLId) {
2525 MK_UNUSED auto ctx = getCTX(MK_NULL_NO);
2526 MkRtSetup_X(ctx);
2527 enum MkErrorE errVal = MqStorageIncrRef(ctx, transLId);
2528 MkErrorC_Check(ctx, errVal);
2529 }
2530
2532 inline void MqContextC::StorageLog (MK_STRN callfunc) {
2533 MK_UNUSED auto ctx = getCTX(MK_NULL_NO);
2534 MkRtSetup_X(ctx);
2535 if (callfunc == NULL) {callfunc = __builtin_FUNCTION();}
2536 enum MkErrorE errVal = MqStorageLog(ctx, callfunc);
2537 MkErrorC_Check(ctx, errVal);
2538 }
2539
2541 inline void MqContextC::StorageOpen (MK_STRN storageFile) {
2542 MK_UNUSED auto ctx = getCTX(MK_NULL_NO);
2543 MkRtSetup_X(ctx);
2544 enum MkErrorE errVal = MqStorageOpen(ctx, storageFile);
2545 MkErrorC_Check(ctx, errVal);
2546 }
2547
2549 inline void MqContextC::StorageOpen (const std::string& storageFile) {
2550 MK_UNUSED auto ctx = getCTX(MK_NULL_NO);
2551 MkRtSetup_X(ctx);
2552 const MK_STRN storageFile_hdl = storageFile.c_str();
2553 enum MkErrorE errVal = MqStorageOpen(ctx, storageFile_hdl);
2554 MkErrorC_Check(ctx, errVal);
2555 }
2556
2557 // doc-key: MqContextC,MqContextC-StorageApi-Storage,omo
2558
2561 MK_UNUSED auto ctx = getCTX(MK_NULL_NO);
2562 MkRtSetup_X(ctx);
2563 MQ_LTR cnt_out;
2564 enum MkErrorE errVal = MqStorageCount(ctx, &cnt_out);
2565 MkErrorC_Check(ctx, errVal);
2566 return cnt_out;
2567 }
2568
2571 MK_UNUSED auto ctx = getCTX(MK_NULL_NO);
2572 MkRtSetup_X(ctx);
2573 MK_I32 cnt_out;
2574 enum MkErrorE errVal = MqStorageErrCnt(ctx, transLId, &cnt_out);
2575 MkErrorC_Check(ctx, errVal);
2576 return cnt_out;
2577 }
2578
2581 MK_UNUSED auto ctx = getCTX(MK_NULL_NO);
2582 MkRtSetup_X(ctx);
2583 MQ_LTR ltid_out;
2584 enum MkErrorE errVal = MqStorageExport(ctx, &ltid_out);
2585 MkErrorC_Check(ctx, errVal);
2586 return ltid_out;
2587 }
2588
2590 inline std::tuple<MqContextC*,MQ_LTR> MqContextC::StorageResolve () {
2591 MK_UNUSED auto ctx = getCTX(MK_NULL_NO);
2592 MkRtSetup_X(ctx);
2593 MQ_CTX otherCtxP_out;
2594 MQ_LTR otherLIdP_out;
2595 enum MkErrorE errVal = MqStorageResolve(ctx, &otherCtxP_out, &otherLIdP_out);
2596 MkErrorC_Check(ctx, errVal);
2597 std::tuple<MqContextC*,MQ_LTR> __retVal__L = {MqContextC::MqContextC_ObjNew(MK_RT_CALL otherCtxP_out),otherLIdP_out};
2598 return __retVal__L;
2599 }
2600
2602 // MqContextC_StorageApi_Storage_CC_API
2603
2607
2608 // doc-key: MqContextC,MqContextC-TOR,sCc
2609
2613 MQ_CTX tmpl_hdl = MqContextC::getCTX(tmpl,MK_NULL_YES);
2614 MQ_CTX __retVal__L = MqContextCreate(NULL, tmpl_hdl);
2615 if (__retVal__L == NULL) {
2616 throw MkInitError("MqContextC::CTOR");
2617 }
2618 return (MK_OBJ)__retVal__L;
2619 }
2620
2624 MQ_CTX tmpl_hdl = MqContextC::getCTX(tmpl,MK_NULL_YES);
2625 MQ_CTX __retVal__L = MqContextCreate(NULL, tmpl_hdl);
2626 if (__retVal__L == NULL) {
2627 throw MkInitError("MqContextC::Create");
2628 }
2629 return MqContextC::MqContextC_ObjCreate(MK_RT_CALL __retVal__L);
2630 }
2631
2633 // MqContextC_TOR_CC_API
2634
2635 // END-MqContextC - created by 'cc_MqC.tcl -i NHI1_HOME/theLink/c/gen/c_mqmsgque.meta' - DO NOT change
2636
2641 MQ_CTX tmpl_hdl = MqContextC::getCTX(tmpl, MK_NULL_YES);
2642 MQ_CTX __retVal__L = MqContextCreate(typ, tmpl_hdl);
2643 if (__retVal__L == NULL) {
2644 throw MkInitError("MqContextC::CTOR");
2645 }
2646 return (MK_OBJ)__retVal__L;
2647 }
2648
2649} // END - namespace "ccmqmsgque"
MqCall_cc.hh - 25 Aug 2024 - aotto1968.
implements the ccmqmsgque API object: ConfigSetBgError
implements the ccmqmsgque API object: ConfigSetEvent
implements the ccmqmsgque API object: ConfigSetServerCleanup
implements the ccmqmsgque API object: ConfigSetServerSetup
Callback for a Service.
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
data used to define a factory → C-API: libmqmsgque::MqFactoryS
MK_BUFN getBUFN(bool nullB=MK_NULL_NO) const
static MkBufferC * MkBufferC_ObjNew(MK_RT const mkrt, MK_BUF hdl)
MK_BUF getBUF(bool nullB=MK_NULL_NO) const
MK_BFLN getBFLN(bool nullB=MK_NULL_NO) const
MK_BFL getBFL(bool nullB=MK_NULL_NO) const
static MkBufferListC * MkBufferListC_ObjNew(MK_RT const mkrt, MK_BFL hdl)
MK_BUSN getBUSN(bool nullB=MK_NULL_NO) const
static MkErrorC * MkErrorC_ObjNew(MK_RT const mkrt, MK_ERR hdl)
#define MK_ERROR_PANIC
MkBinaryR MkBinaryCreate(MK_SIZE size, MK_BINN data)
#define MK_DECL
#define MK_NULL_NO
#define MK_NULL_YES
#define MK_UNUSED
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
MK_OBJ getOBJ(bool nullB=MK_NULL_NO) const
void ErrorCheck(enum MkErrorE err, MK_STRN const caller=__builtin_FUNCTION(), MK_I32 const line=__builtin_LINE()) const
MK_OBJN getOBJN(bool nullB=MK_NULL_NO) const
MK_EXTERN MK_PTR MkSysRealloc(MK_OBJ const fmtobj, MK_PTR const buf, size_t const size)
MK_I32 MkRuntimeGetDebug(void)
#define MkRtSetup_XN(x)
#define MK_RT_CALL
#define MkRtSetup_X(x)
#define MK_RT_ARGS
#define MkRtSetup_NULL
static MqContextC * MqContextC_ObjNew(MK_RT const mkrt, MQ_CTX hdl)
return MqContextC from LibMsgqueObject
static MK_PTR MqContextC_selfCreate(MK_RT const mkrt, MK_OBJ obj, MK_PTR const env)
MQ_CTX getCTX(bool nullB=MK_NULL_NO) const
return the LibMsgqueObject from current MqContextC instance
static MqContextC * MqContextC_ObjCreate(MK_RT const mkrt, MQ_CTX hdl)
MQ_CTXN getCTXN(bool nullB=MK_NULL_NO) const
(const) return the LibMsgqueObject from current MqContextC instance
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(...)
MQ_EXTERN MK_STRN MqClassOriginalIdentGet(MQ_CTXN const ctx) MK_ATTR_HDL
get the libmqmsgque::MqFactoryS::originalIdent from the MqContextC
MQ_EXTERN MQ_FCT const MqClassFactoryGet(MQ_CTXN const ctx) MK_ATTR_HDL
get the MqFactoryC used by the MqContextC
#define MqClassIdentSet(...)
MQ_EXTERN MK_STRN MqClassIdentGet(MQ_CTXN const ctx) MK_ATTR_HDL
get the application-identification …
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(...)
MK_ATTR_HDL MQ_CTX MqContextPrev(MQ_CTX const ctx)
get previous instance from linked-list of MqContextS type
#define MqContextInstances()
MQ_CTX MqContextGetNull(void)
Null-Slot - return a MqContextC typed NULL instance …
MK_ATTR_HDL MQ_CTX MqContextNext(MQ_CTX const ctx)
get next 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::postfix
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::prefix
MK_STRN ConfigGetIoUds() const
C++: MK_STRN ctx.ConfigGetIoUds() → C-API return the libmqmsgque::MqIoUdsConfigS
MK_ATTR_HDL bool MqConfigGetIsServer(MQ_CTX const ctx)
does the context object is a server ?
MK_ATTR_HDL MK_STRN MqConfigGetName(MQ_CTXN const ctx)
get the name of the context object
MK_ATTR_HDL enum MqIdentE MqConfigGetIdentFrom(MQ_CTX const ctx)
get the libmqmsgque::MqConfigS::identFrom
#define MqConfigSetConfigFile(...)
MQ_EXTERN enum MkErrorE MqConfigGetIoTcp(MQ_CTX const ctx, MK_STRN *host_out, MK_STRN *port_out, MK_STRN *myhost_out, MK_STRN *myport_out) MK_ATTR_HDL
get the configuration-data of the tcp-client-server-link …
MK_ATTR_HDL MK_STRN MqConfigGetPostfix(MQ_CTXN const ctx)
get the libmqmsgque::MqConfigS::postfix
MK_ATTR_HDL bool MqConfigGetIsString(MQ_CTX const ctx)
does the context object is using the string-mode ?
MQ_EXTERN enum MkErrorE MqConfigGetIoTcpL(MQ_CTX const ctx, MK_BFL *vals_out) MK_ATTR_HDL
get the configuration-data of the tcp-client-server-link as MkBufferListC …
MK_ATTR_HDL MK_TIME_T MqConfigGetTimeout(MQ_CTXN const ctx)
get the timeout value of the context object
MK_ATTR_HDL MK_STRN MqConfigGetIoUds(MQ_CTXN const ctx)
return the libmqmsgque::MqIoUdsConfigS
MK_ATTR_HDL MQ_SOCK_HDL MqConfigGetIoPipe(MQ_CTX const ctx)
return the libmqmsgque::MqIoPipeConfigS
MK_ATTR_HDL enum MqStartE MqConfigGetStartAs(MQ_CTX const ctx)
return the libmqmsgque::MqConfigS::startAs value
MK_ATTR_HDL MK_I32 MqConfigGetPkgsize(MQ_CTXN const ctx)
get the maximun size of a BDY package
MK_ATTR_HDL MK_STRN MqConfigGetPrefix(MQ_CTXN const ctx)
get the libmqmsgque::MqConfigS::prefix
MK_ATTR_HDL MK_I32 MqConfigGetBuffersize(MQ_CTXN const ctx)
get the minimum of the read/send buffersize of the socket
MK_ATTR_HDL MK_STRN MqConfigGetStorage(MQ_CTXN const ctx)
get the storage of the context object
MK_ATTR_HDL bool MqConfigGetIsParent(MQ_CTX const ctx)
does the context object is a parent ? An objext is a parent id the libmqmsgque::MqConfigS::parent att...
MK_ATTR_HDL enum MqStatusIsEF MqConfigGetStatusIs(MQ_CTX const ctx)
return the libmqmsgque::MqContextS::statusIs value
void ConfigSetServerCleanup(MqServerCleanupICB callback=NULL)
C++: ctx.ConfigSetServerCleanup(MqServerCleanupICB MqServerCleanupCCB MqServerCleanupIF* callback = ...
void ConfigSetEvent(MqEventICB callback=NULL)
C++: ctx.ConfigSetEvent(MqEventICB MqEventCCB MqEventIF* callback = NULL) → C-API set the libmq...
void ConfigSetServerSetup(MqServerSetupICB callback=NULL)
C++: ctx.ConfigSetServerSetup(MqServerSetupICB MqServerSetupCCB MqServerSetupIF* callback = NULL) →...
void ConfigSetBgError(MqBgErrorICB callback=NULL)
C++: ctx.ConfigSetBgError(MqBgErrorICB MqBgErrorCCB MqBgErrorIF* callback = NULL) → C-API set t...
#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(...)
#define MqConfigSetPrefix(...)
MQ_EXTERN enum MkErrorE MqConfigSetStartAsString(MQ_CTX const ctx, MK_STRN data) MK_ATTR_HDL
set the libmqmsgque::MqConfigS::startAs value using string default, thread, fork or spawn
#define MqConfigSetIoPipe(...)
MQ_EXTERN void MqConfigSetIdentFrom(MQ_CTX const ctx, enum MqIdentE data) MK_ATTR_HDL
set the libmqmsgque::MqConfigS::identFrom value
#define MqConfigSetIoTcp(...)
#define MqConfigSetPostfix(...)
#define MqConfigSetName(...)
MQ_EXTERN void MqConfigSetIsServer(MQ_CTX const ctx, bool data) MK_ATTR_HDL
set the libmqmsgque::MqSetupS::isServer value
MQ_EXTERN void MqConfigSetBuffersize(MQ_CTX const ctx, MK_I32 data) MK_ATTR_HDL
set the libmqmsgque::MqIoConfigS::buffersize value
MQ_EXTERN void MqConfigSetPkgsize(MQ_CTX const ctx, MK_I32 data) MK_ATTR_HDL
set the libmqmsgque::MqIoConfigS::pkgsize value
MQ_EXTERN void MqConfigSetTimeout(MQ_CTX const ctx, MK_TIME_T data) MK_ATTR_HDL
set the libmqmsgque::MqIoConfigS::timeout value
#define MqConfigSetIoUds(...)
MQ_EXTERN enum MkErrorE MqConfigSetStartAs(MQ_CTX const ctx, enum MqStartE data) MK_ATTR_HDL
set the libmqmsgque::MqConfigS::startAs value
#define MqConfigSetAllDebug(...)
#define MqConfigSetIoTcpL(...)
MQ_EXTERN void MqConfigSetIsString(MQ_CTX const ctx, bool data) MK_ATTR_HDL
set the libmqmsgque::MqConfigS::native value 'S'string or 'L'owEndian or 'B'igEndian
#define MqConfigSetStorage(...)
MQ_EXTERN bool MqConfigCheckStartAs(MQ_CTX const ctx, enum MqStartE data) MK_ATTR_HDL
check if libmqmsgque::MqConfigS::startAs can be set to data
MQ_EXTERN void MqConfigSetIgnoreExit(MQ_CTX const ctx, bool data) MK_ATTR_HDL
set the libmqmsgque::MqSetupS::ignoreExit value
void EnvProtect()
C++: ctx.EnvProtect() → C-API protect the service-environment
void EnvRestore()
C++: ctx.EnvRestore() → C-API restore the service-environment
#define MqEnvProtect(...)
MQ_EXTERN void MqEnvRestore(MQ_CTX ctx) MK_ATTR_HDL
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 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 LogType(MkObjectC *fmtobj=NULL, MK_DBG debug=0, MK_STRN callfunc=__builtin_FUNCTION(), MK_I32 lvl=0) const
C++: ctx.LogType(MkObjectC* fmtobj = NULL, MK_DBG debug = 0, MK_STRN callfunc = __builtin_FUNCTION()...
void LogEnv(MkObjectC *fmtobj=NULL, MK_DBG debug=0, MK_STRN callfunc=__builtin_FUNCTION(), MK_I32 lvl=0) const
C++: ctx.LogEnv(MkObjectC* fmtobj = NULL, MK_DBG debug = 0, MK_STRN callfunc = __builtin_FUNCTION(),...
void Log(const MkObjectC *fmtobj=NULL, MK_DBG debug=0, MK_STRN callfunc=__builtin_FUNCTION(), MK_I32 lvl=0) const
C++: ctx.Log(const MkObjectC* fmtobj = NULL, MK_DBG debug = 0, MK_STRN callfunc = __builtin_FUNCTION...
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(...)
MK_ATTR_HDL MK_STRN MqLogServerOrClient(MQ_CTXN const ctx)
is ctx a SERVER or a CLIENT ? …
#define MqContextLog(...)
#define MqContextLogLink(...)
#define MqContextLogType(...)
MK_ATTR_HDL 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)
MK_STRN ToString() const
C++: MK_STRN ctx.ToString() → C-API String-Slot - returns the string representation of the inst...
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(...)
#define MqContextToString(...)
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...
#define MqReadDbg(...)
MQ_EXTERN bool MqReadItemExists(MQ_CTX const ctx) MK_ATTR_HDL
check if an item exists in the read-data-package …
MQ_EXTERN MK_NUM MqReadGetNumItems(MQ_CTX const ctx) MK_ATTR_HDL
get the number of items left in the read-data-package …
#define MqReadUndo(...)
MQ_EXTERN enum MkTypeE MqReadGetNextType(MQ_CTX const ctx) MK_ATTR_HDL
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 SendSTART()
C++: ctx.SendSTART() → C-API initialize the send-data-package. …
void SendEND_AND_CALLBACK(MQ_TOK token, MqServiceICB callback, MK_TIME_T timeout=MK_TIMEOUT_DEFAULT)
C++: ctx.SendEND_AND_CALLBACK(MQ_TOK token, MqServiceICB MqServiceCCB MqServiceIF* callback,...
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...
void SendEND_AND_SUB(MQ_TOK token, MqServiceICB callback, MK_TIME_T timeout=MK_TIMEOUT_DEFAULT)
C++: ctx.SendEND_AND_SUB(MQ_TOK token, MqServiceICB MqServiceCCB MqServiceIF* callback,...
#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 ServiceCreate(MQ_TOK token, MqServiceICB callback)
C++: ctx.ServiceCreate(MQ_TOK token, MqServiceICB MqServiceCCB MqServiceIF* callback) ...
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...
#define MqServiceStorage(...)
#define MqServiceProxyCtx(...)
MQ_EXTERN 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 MqServiceCreate(...)
MK_STRN MQ_TOK
MqContextC - a char[4+1] or hex[8+1] string used to unique identify a service …
MK_ATTR_HDL bool MqServiceIsTransaction(MQ_CTX const ctx)
check if the ongoing-service-call belongs to a transaction …
#define MqServiceProxy(...)
MQ_EXTERN bool MqServiceTokenExists(MQ_CTX const ctx, MQ_TOK const token) MK_ATTR_HDL
check if the MqContextC_ServiceApi_Identifer token is defined as ctx service …
MQ_EXTERN bool MqServiceTokenCheck(MQ_CTX const ctx, MQ_TOK const token) MK_ATTR_HDL
in an ongoing-service-call check if the current MqContextC_ServiceApi_Identifer is token …
#define MqServiceProxyRoundRobin(...)
MQ_EXTERN MQ_TOK MqServiceTokenGet(MQ_CTX const ctx) MK_ATTR_HDL
in an ongoing-service-call get the current MqContextC_ServiceApi_Identifer …
#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(...)
#define MqSlaveGetProxy(...)
#define MqSlaveCreate(...)
bool MqSlaveCheck(MQ_CTXN const ctx, MQ_SLAVE_ID const id)
check if slave-id is valid
MQ_CTX MqSlaveGetMaster(MQ_CTX const ctx)
opposite function of MqSlaveGetFilter
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 …
MQ_LTR StorageDelete(MQ_LTR *transLIdP_inout=NULL)
C++: MQ_LTR ctx.StorageDelete(MQ_LTR *transLIdP_inout = NULL) → C-API delete the storage-row id...
std::tuple< MqContextC *, MQ_LTR > StorageResolve()
C++: {otherCtxP:MqContextC* otherLIdP:MQ_LTR} ctx.StorageResolve() → C-API extract the context-...
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=NULL)
C++: MQ_LTR ctx.StorageImport(MQ_LTR *transLIdP_inout = NULL) → C-API import the storage-packag...
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(bool nullB=MK_NULL_NO) const
return the LibMsgqueObject from current MqDumpC instance
Definition MqDumpC_cc.hh:76
static MqFactoryC * MqFactoryC_ObjNew(MK_RT const mkrt, MQ_FCT hdl)
return MqFactoryC from LibMsgqueObject
MQ_FCT getFCT(bool nullB=MK_NULL_NO) const
return the LibMsgqueObject from current MqFactoryC instance
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 enum MkErrorE Call(MQ_SERVICE_CALL_ARGS)
Definition MqCall_cc.cc:81
static MK_CBP Create(MK_RT const mkrt, MqContextC::MqTokenICB const callback, MqContextC *self=NULL)
Definition MqCall_cc.hh:58
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