theLink 10.0
Loading...
Searching...
No Matches
MqContextC_inline_cc.hh
Go to the documentation of this file.
1
9/* LABEL-NO */
10
11#include "MqCall_cc.hh"
12
13namespace ccmqmsgque {
14
15/*
16 inline MK_PTR MqContextC::MqContextC_selfCreate (MK_RT_ARGS MK_OBJ obj, MK_PTR const env) {
17 return new MqContextC(obj);
18 }
19*/
20
21 inline void MqContextC::SlaveWorker (const MQ_SLAVE_ID id, MK_STRN fct, const MkBufferListC& args) {
22 MK_BAC args_hdl = MkBufferListC::getBFL(args);
23 MkRtSetup_XN(args_hdl);
24 enum MkErrorE errVal = MqSlaveWorker (reinterpret_cast<MQ_CTX>(hdl), id, fct, args_hdl);
25 ErrorCheck(errVal);
26 }
27
28 // BEGIN-MqContextC - created by 'cc_MqC.tcl -i NHI1_HOME/theLink/c/gen/c_mqmsgque.meta' - DO NOT change
29
33
34 // doc-key: MqContextC,MqContextC-Class-Export,sc_
35
39 MQ_CTX __retVal__L = MqContextHandleResolve(netHdl);
40 return MqContextC::MqContextC_ObjNew(MK_RT_CALL __retVal__L);
41 }
42
43 // doc-key: MqContextC,MqContextC-Class-Export,om_
44
45 // skip class-overload: HandleGet = MqContextHandleGet → MkObjectHandleGet
46
48 // MqContextC_Class_CC_API
49
53
54 // doc-key: MqContextC,MqContextC-Class-Introspection,oc_
55
58 MK_UNUSED auto ctx = getCTX();
59 MQ_CTX __retVal__L = MqContextNext(ctx);
60 return MqContextC::MqContextC_ObjNew(MK_RT_CALL __retVal__L);
61 }
62
65 MK_UNUSED auto ctx = getCTX();
66 MQ_CTX __retVal__L = MqContextPrev(ctx);
67 return MqContextC::MqContextC_ObjNew(MK_RT_CALL __retVal__L);
68 }
69
70 // doc-key: MqContextC,MqContextC-Class-Introspection,sc_
71
75 MQ_CTX __retVal__L = MqContextInstances();
76 return MqContextC::MqContextC_ObjNew(MK_RT_CALL __retVal__L);
77 }
78
80 // MqContextC_Class_CC_API
81
85
86 // doc-key: MqContextC,MqContextC-Class-Misc,sc_
87
91 MQ_CTX __retVal__L = MqContextGetNull();
92 return MqContextC::MqContextC_ObjNew(MK_RT_CALL __retVal__L);
93 }
94
96 // MqContextC_Class_CC_API
97
101
102 // doc-key: MqContextC,MqContextC-ClassApi-Class,oc_
103
106 MK_UNUSED auto ctx = getCTXN();
107 MQ_FCT __retVal__L = MqClassFactoryGet(ctx);
108 return MqFactoryC::MqFactoryC_ObjNew(MK_RT_CALL __retVal__L);
109 }
110
111 // doc-key: MqContextC,MqContextC-ClassApi-Class,om_
112
115 MK_UNUSED auto ctx = getCTX();
116 MQ_FCT item_hdl = MqFactoryC::getFCT(item);
117 enum MkErrorE errVal = MqClassFactorySet(ctx, item_hdl);
118 MkErrorC_Check(ctx, errVal);
119 }
120
122 inline void MqContextC::ClassFactorySet (const MqFactoryC& item) {
123 MK_UNUSED auto ctx = getCTX();
124 const MQ_FCT item_hdl = MqFactoryC::getFCT(item);
125 enum MkErrorE errVal = MqClassFactorySet(ctx, item_hdl);
126 MkErrorC_Check(ctx, errVal);
127 }
128
131 MK_UNUSED auto ctx = getCTXN();
132 MK_STRN __retVal__L = MqClassIdentGet(ctx);
133 return __retVal__L;
134 }
135
137 inline void MqContextC::ClassIdentSet (MK_STRN ident) {
138 MK_UNUSED auto ctx = getCTX();
139 enum MkErrorE errVal = MqClassIdentSet(ctx, ident);
140 MkErrorC_Check(ctx, errVal);
141 }
142
144 inline void MqContextC::ClassIdentSet (const std::string& ident) {
145 MK_UNUSED auto ctx = getCTX();
146 const MK_STRN ident_hdl = ident.c_str();
147 enum MkErrorE errVal = MqClassIdentSet(ctx, ident_hdl);
148 MkErrorC_Check(ctx, errVal);
149 }
150
153 MK_UNUSED auto ctx = getCTXN();
154 MK_STRN __retVal__L = MqClassOriginalIdentGet(ctx);
155 return __retVal__L;
156 }
157
159 // MqContextC_ClassApi_Class_CC_API
160
164
165 // doc-key: MqContextC,MqContextC-ConfigApi-Get,oco
166
169 MK_UNUSED auto ctx = getCTX();
170 MK_BFL vals_out;
171 enum MkErrorE errVal = MqConfigGetIoTcpL(ctx, &vals_out);
172 MkErrorC_Check(ctx, errVal);
174 }
175
176 // doc-key: MqContextC,MqContextC-ConfigApi-Get,om_
177
180 MK_UNUSED auto ctx = getCTXN();
181 MK_I32 __retVal__L = MqConfigGetBuffersize(ctx);
182 return __retVal__L;
183 }
184
187 MK_UNUSED auto ctx = getCTX();
188 enum MqIdentE __retVal__L = MqConfigGetIdentFrom(ctx);
189 return __retVal__L;
190 }
191
194 MK_UNUSED auto ctx = getCTX();
195 MQ_SOCK_HDL __retVal__L = MqConfigGetIoPipe(ctx);
196 return __retVal__L;
197 }
198
201 MK_UNUSED auto ctx = getCTXN();
202 MK_STRN __retVal__L = MqConfigGetIoUds(ctx);
203 return __retVal__L;
204 }
205
208 MK_UNUSED auto ctx = getCTX();
209 MK_BOOL __retVal__L = MqConfigGetIsParent(ctx);
210 return __retVal__L;
211 }
212
215 MK_UNUSED auto ctx = getCTX();
216 MK_BOOL __retVal__L = MqConfigGetIsServer(ctx);
217 return __retVal__L;
218 }
219
222 MK_UNUSED auto ctx = getCTX();
223 MK_BOOL __retVal__L = MqConfigGetIsString(ctx);
224 return __retVal__L;
225 }
226
229 MK_UNUSED auto ctx = getCTXN();
230 MK_STRN __retVal__L = MqConfigGetName(ctx);
231 return __retVal__L;
232 }
233
236 MK_UNUSED auto ctx = getCTXN();
237 MK_I32 __retVal__L = MqConfigGetPkgsize(ctx);
238 return __retVal__L;
239 }
240
243 MK_UNUSED auto ctx = getCTXN();
244 MK_STRN __retVal__L = MqConfigGetPostfix(ctx);
245 return __retVal__L;
246 }
247
250 MK_UNUSED auto ctx = getCTXN();
251 MK_STRN __retVal__L = MqConfigGetPrefix(ctx);
252 return __retVal__L;
253 }
254
257 MK_UNUSED auto ctx = getCTX();
258 enum MqStartE __retVal__L = MqConfigGetStartAs(ctx);
259 return __retVal__L;
260 }
261
264 MK_UNUSED auto ctx = getCTX();
265 enum MqStatusIsEF __retVal__L = MqConfigGetStatusIs(ctx);
266 return __retVal__L;
267 }
268
271 MK_UNUSED auto ctx = getCTXN();
272 MK_STRN __retVal__L = MqConfigGetStorage(ctx);
273 return __retVal__L;
274 }
275
278 MK_UNUSED auto ctx = getCTXN();
279 MK_TIME_T __retVal__L = MqConfigGetTimeout(ctx);
280 return __retVal__L;
281 }
282
285 MK_UNUSED auto ctx = getCTX();
286 enum MkErrorE errVal = MqConfigSetConfigFile(ctx, filename);
287 MkErrorC_Check(ctx, errVal);
288 }
289
291 inline void MqContextC::ConfigSetConfigFile (const std::string& filename) {
292 MK_UNUSED auto ctx = getCTX();
293 const MK_STRN filename_hdl = filename.c_str();
294 enum MkErrorE errVal = MqConfigSetConfigFile(ctx, filename_hdl);
295 MkErrorC_Check(ctx, errVal);
296 }
297
298 // doc-key: MqContextC,MqContextC-ConfigApi-Get,omo
299
301 inline std::tuple<MK_STRN,MK_STRN,MK_STRN,MK_STRN> MqContextC::ConfigGetIoTcp () {
302 MK_UNUSED auto ctx = getCTX();
303 MK_STRN host_out;
304 MK_STRN port_out;
305 MK_STRN myhost_out;
306 MK_STRN myport_out;
307 enum MkErrorE errVal = MqConfigGetIoTcp(ctx, &host_out, &port_out, &myhost_out, &myport_out);
308 MkErrorC_Check(ctx, errVal);
309 std::tuple<MK_STRN,MK_STRN,MK_STRN,MK_STRN> __retVal__L = {host_out,port_out,myhost_out,myport_out};
310 return __retVal__L;
311 }
312
314 // MqContextC_ConfigApi_Get_CC_API
315
319
320 // doc-key: MqContextC,MqContextC-ConfigApi-Interface,om_
321
324 MK_UNUSED auto ctx = getCTX();
325 auto fCall = MqServiceCallbackC::Call;
326 auto callback_ptr = MqBgErrorCallbackC::Create(MK_RT_CALL callback, this);
327 if (callback_ptr == NULL) fCall = NULL;
329 }
330
333 MK_UNUSED auto ctx = getCTX();
334 auto fCall = MqServiceCallbackC::Call;
335 auto callback_ptr = MqBgErrorCallbackC::Create(MK_RT_CALL callback, this);
336 if (callback_ptr == NULL) fCall = NULL;
338 }
339
342 MK_UNUSED auto ctx = getCTX();
343 auto fCall = MqServiceCallbackC::Call;
344 auto callback_ptr = MqBgErrorCallbackC::Create(MK_RT_CALL callback, this);
345 if (callback_ptr == NULL) fCall = NULL;
347 }
348
350 inline void MqContextC::ConfigSetEvent (MqEventCCB callback) {
351 MK_UNUSED auto ctx = getCTX();
352 auto fCall = MqServiceCallbackC::Call;
353 auto callback_ptr = MqEventCallbackC::Create(MK_RT_CALL callback, this);
354 if (callback_ptr == NULL) fCall = NULL;
356 }
357
359 inline void MqContextC::ConfigSetEvent (MqEventICB callback) {
360 MK_UNUSED auto ctx = getCTX();
361 auto fCall = MqServiceCallbackC::Call;
362 auto callback_ptr = MqEventCallbackC::Create(MK_RT_CALL callback, this);
363 if (callback_ptr == NULL) fCall = NULL;
365 }
366
368 inline void MqContextC::ConfigSetEvent (MqEventIF* callback) {
369 MK_UNUSED auto ctx = getCTX();
370 auto fCall = MqServiceCallbackC::Call;
371 auto callback_ptr = MqEventCallbackC::Create(MK_RT_CALL callback, this);
372 if (callback_ptr == NULL) fCall = NULL;
374 }
375
378 MK_UNUSED auto ctx = getCTX();
379 auto fCall = MqServiceCallbackC::Call;
380 auto callback_ptr = MqServerCleanupCallbackC::Create(MK_RT_CALL callback, this);
381 if (callback_ptr == NULL) fCall = NULL;
383 }
384
387 MK_UNUSED auto ctx = getCTX();
388 auto fCall = MqServiceCallbackC::Call;
389 auto callback_ptr = MqServerCleanupCallbackC::Create(MK_RT_CALL callback, this);
390 if (callback_ptr == NULL) fCall = NULL;
392 }
393
396 MK_UNUSED auto ctx = getCTX();
397 auto fCall = MqServiceCallbackC::Call;
398 auto callback_ptr = MqServerCleanupCallbackC::Create(MK_RT_CALL callback, this);
399 if (callback_ptr == NULL) fCall = NULL;
401 }
402
405 MK_UNUSED auto ctx = getCTX();
406 auto fCall = MqServiceCallbackC::Call;
407 auto callback_ptr = MqServerSetupCallbackC::Create(MK_RT_CALL callback, this);
408 if (callback_ptr == NULL) fCall = NULL;
410 }
411
414 MK_UNUSED auto ctx = getCTX();
415 auto fCall = MqServiceCallbackC::Call;
416 auto callback_ptr = MqServerSetupCallbackC::Create(MK_RT_CALL callback, this);
417 if (callback_ptr == NULL) fCall = NULL;
419 }
420
423 MK_UNUSED auto ctx = getCTX();
424 auto fCall = MqServiceCallbackC::Call;
425 auto callback_ptr = MqServerSetupCallbackC::Create(MK_RT_CALL callback, this);
426 if (callback_ptr == NULL) fCall = NULL;
428 }
429
431 // MqContextC_ConfigApi_Interface_CC_API
432
436
437 // doc-key: MqContextC,MqContextC-ConfigApi-Misc,om_
438
440 inline void MqContextC::ConfigReset () {
441 MK_UNUSED auto ctx = getCTX();
442 MqConfigReset(ctx);
443 }
444
446 // MqContextC_ConfigApi_Misc_CC_API
447
451
452 // doc-key: MqContextC,MqContextC-ConfigApi-Set,om_
453
456 MK_UNUSED auto ctx = getCTX();
457 MK_BOOL __retVal__L = MqConfigCheckStartAs(ctx, data);
458 return __retVal__L;
459 }
460
463 MK_UNUSED auto ctx = getCTX();
464 enum MkErrorE errVal = MqConfigSetAllDebug(ctx, data);
465 MkErrorC_Check(ctx, errVal);
466 }
467
470 MK_UNUSED auto ctx = getCTX();
471 MqConfigSetBuffersize(ctx, data);
472 }
473
475 inline void MqContextC::ConfigSetDaemon (MK_STRN pidfile) {
476 MK_UNUSED auto ctx = getCTX();
477 enum MkErrorE errVal = MqConfigSetDaemon(ctx, pidfile);
478 MkErrorC_Check(ctx, errVal);
479 }
480
482 inline void MqContextC::ConfigSetDaemon (const std::string& pidfile) {
483 MK_UNUSED auto ctx = getCTX();
484 const MK_STRN pidfile_hdl = pidfile.c_str();
485 enum MkErrorE errVal = MqConfigSetDaemon(ctx, pidfile_hdl);
486 MkErrorC_Check(ctx, errVal);
487 }
488
491 MK_UNUSED auto ctx = getCTX();
492 MqConfigSetIdentFrom(ctx, data);
493 }
494
497 MK_UNUSED auto ctx = getCTX();
498 MqConfigSetIgnoreExit(ctx, data);
499 }
500
503 MK_UNUSED auto ctx = getCTX();
504 enum MkErrorE errVal = MqConfigSetIoPipe(ctx, fh);
505 MkErrorC_Check(ctx, errVal);
506 }
507
509 inline void MqContextC::ConfigSetIoTcp (MK_STRN host, MK_STRN port, MK_STRN myhost, MK_STRN myport) {
510 MK_UNUSED auto ctx = getCTX();
511 enum MkErrorE errVal = MqConfigSetIoTcp(ctx, host, port, myhost, myport);
512 MkErrorC_Check(ctx, errVal);
513 }
514
517 MK_UNUSED auto ctx = getCTX();
518 MK_BFL vals_hdl = MkBufferListC::getBFL(vals);
519 enum MkErrorE errVal = MqConfigSetIoTcpL(ctx, vals_hdl);
520 MkErrorC_Check(ctx, errVal);
521 }
522
524 inline void MqContextC::ConfigSetIoTcp (const MkBufferListC& vals) {
525 MK_UNUSED auto ctx = getCTX();
526 const MK_BFL vals_hdl = MkBufferListC::getBFL(vals);
527 enum MkErrorE errVal = MqConfigSetIoTcpL(ctx, vals_hdl);
528 MkErrorC_Check(ctx, errVal);
529 }
530
533 MK_UNUSED auto ctx = getCTX();
534 enum MkErrorE errVal = MqConfigSetIoUds(ctx, file);
535 MkErrorC_Check(ctx, errVal);
536 }
537
539 inline void MqContextC::ConfigSetIoUds (const std::string& file) {
540 MK_UNUSED auto ctx = getCTX();
541 const MK_STRN file_hdl = file.c_str();
542 enum MkErrorE errVal = MqConfigSetIoUds(ctx, file_hdl);
543 MkErrorC_Check(ctx, errVal);
544 }
545
548 MK_UNUSED auto ctx = getCTX();
549 MqConfigSetIsServer(ctx, data);
550 }
551
554 MK_UNUSED auto ctx = getCTX();
555 MqConfigSetIsString(ctx, data);
556 }
557
560 MK_UNUSED auto ctx = getCTX();
561 MqConfigSetName(ctx, data);
562 }
563
565 inline void MqContextC::ConfigSetName (const std::string& data) {
566 MK_UNUSED auto ctx = getCTX();
567 const MK_STRN data_hdl = data.c_str();
568 MqConfigSetName(ctx, data_hdl);
569 }
570
573 MK_UNUSED auto ctx = getCTX();
574 MqConfigSetPkgsize(ctx, data);
575 }
576
579 MK_UNUSED auto ctx = getCTX();
580 MqConfigSetPostfix(ctx, data);
581 }
582
584 inline void MqContextC::ConfigSetPostfix (const std::string& data) {
585 MK_UNUSED auto ctx = getCTX();
586 const MK_STRN data_hdl = data.c_str();
587 MqConfigSetPostfix(ctx, data_hdl);
588 }
589
592 MK_UNUSED auto ctx = getCTX();
593 MqConfigSetPrefix(ctx, data);
594 }
595
597 inline void MqContextC::ConfigSetPrefix (const std::string& data) {
598 MK_UNUSED auto ctx = getCTX();
599 const MK_STRN data_hdl = data.c_str();
600 MqConfigSetPrefix(ctx, data_hdl);
601 }
602
605 MK_UNUSED auto ctx = getCTX();
606 enum MkErrorE errVal = MqConfigSetStartAs(ctx, data);
607 MkErrorC_Check(ctx, errVal);
608 }
609
612 MK_UNUSED auto ctx = getCTX();
613 enum MkErrorE errVal = MqConfigSetStartAsString(ctx, data);
614 MkErrorC_Check(ctx, errVal);
615 }
616
618 inline void MqContextC::ConfigSetStartAsString (const std::string& data) {
619 MK_UNUSED auto ctx = getCTX();
620 const MK_STRN data_hdl = data.c_str();
621 enum MkErrorE errVal = MqConfigSetStartAsString(ctx, data_hdl);
622 MkErrorC_Check(ctx, errVal);
623 }
624
627 MK_UNUSED auto ctx = getCTX();
628 MqConfigSetStorage(ctx, data);
629 }
630
632 inline void MqContextC::ConfigSetStorage (const std::string& data) {
633 MK_UNUSED auto ctx = getCTX();
634 const MK_STRN data_hdl = data.c_str();
635 MqConfigSetStorage(ctx, data_hdl);
636 }
637
640 MK_UNUSED auto ctx = getCTX();
641 MqConfigSetTimeout(ctx, data);
642 }
643
645 // MqContextC_ConfigApi_Set_CC_API
646
650
651 // doc-key: MqContextC,MqContextC-EnvApi-Env,om_
652
654 inline void MqContextC::EnvProtect () {
655 MK_UNUSED auto ctx = getCTX();
656 MqEnvProtect(ctx);
657 }
658
660 inline void MqContextC::EnvRestore () {
661 MK_UNUSED auto ctx = getCTX();
662 MqEnvRestore(ctx);
663 }
664
666 // MqContextC_EnvApi_Env_CC_API
667
671
672 // doc-key: MqContextC,MqContextC-ErrorApi-Error,oc_
673
676 MK_UNUSED auto fmtobj = getCTXN__null_allow();
677 MK_ERR __retVal__L = MqContextErrorFORMAT(fmtobj);
678 return MkErrorC::MkErrorC_ObjNew(MK_RT_CALL __retVal__L);
679 }
680
681 // doc-key: MqContextC,MqContextC-ErrorApi-Error,om_
682
684 inline MkErrorE MqContextC::ErrorCopy (const MqContextC* sourceCtx) const {
685 MK_UNUSED auto targetCtx = getCTXN();
686 MQ_CTXN sourceCtx_hdl = MqContextC::getCTXN(sourceCtx);
687 enum MkErrorE errVal = MqContextErrorCopy(targetCtx, sourceCtx_hdl);
688 return errVal;
689 }
690
692 inline MkErrorE MqContextC::ErrorCopy (const MqContextC& sourceCtx) const {
693 MK_UNUSED auto targetCtx = getCTXN();
694 const MQ_CTXN sourceCtx_hdl = MqContextC::getCTXN(sourceCtx);
695 enum MkErrorE errVal = MqContextErrorCopy(targetCtx, sourceCtx_hdl);
696 return errVal;
697 }
698
700 inline MkErrorE MqContextC::ErrorMove (const MqContextC* sourceCtx) const {
701 MK_UNUSED auto targetCtx = getCTXN();
702 MQ_CTXN sourceCtx_hdl = MqContextC::getCTXN(sourceCtx);
703 enum MkErrorE errVal = MqContextErrorMove(targetCtx, sourceCtx_hdl);
704 return errVal;
705 }
706
708 inline MkErrorE MqContextC::ErrorMove (const MqContextC& sourceCtx) const {
709 MK_UNUSED auto targetCtx = getCTXN();
710 const MQ_CTXN sourceCtx_hdl = MqContextC::getCTXN(sourceCtx);
711 enum MkErrorE errVal = MqContextErrorMove(targetCtx, sourceCtx_hdl);
712 return errVal;
713 }
714
716 // MqContextC_ErrorApi_Error_CC_API
717
721
722 // doc-key: MqContextC,MqContextC-HighApi-High,om_
723
725 inline void MqContextC::SendVL2 (MK_STRN cstr, va_list var_list) {
726 MK_UNUSED auto ctx = getCTX();
727 enum MkErrorE errVal = MqSendVL2(ctx, cstr, var_list);
728 MkErrorC_Check(ctx, errVal);
729 }
730
732 inline void MqContextC::SendVL2 (const std::string& cstr, va_list var_list) {
733 MK_UNUSED auto ctx = getCTX();
734 const MK_STRN cstr_hdl = cstr.c_str();
735 enum MkErrorE errVal = MqSendVL2(ctx, cstr_hdl, var_list);
736 MkErrorC_Check(ctx, errVal);
737 }
738
740 // MqContextC_HighApi_High_CC_API
741
745
746 // doc-key: MqContextC,MqContextC-LinkApi-Link,oc_
747
750 MK_UNUSED auto ctx = getCTX();
751 MQ_CTX __retVal__L = MqLinkGetParent(ctx);
752 return MqContextC::MqContextC_ObjNew(MK_RT_CALL __retVal__L);
753 }
754
755 // doc-key: MqContextC,MqContextC-LinkApi-Link,om_
756
758 inline void MqContextC::LinkConnect () {
759 MK_UNUSED auto ctx = getCTX();
760 enum MkErrorE errVal = MqLinkConnect(ctx);
761 MkErrorC_Check(ctx, errVal);
762 }
763
766 MK_UNUSED auto ctx = getCTX();
768 enum MkErrorE errVal = MqLinkCreate(ctx, args_hdl);
769 MkErrorC_Check(ctx, errVal);
770 }
771
773 inline void MqContextC::LinkCreate (const MkBufferListC& args) {
774 MK_UNUSED auto ctx = getCTX();
775 const MK_BAC args_hdl = MkBufferListC::getBFL(args);
776 enum MkErrorE errVal = MqLinkCreate(ctx, args_hdl);
777 MkErrorC_Check(ctx, errVal);
778 }
779
782 MK_UNUSED auto ctx = getCTX();
783 MQ_CTX parent_hdl = MqContextC::getCTX(parent);
785 enum MkErrorE errVal = MqLinkCreateChild(ctx, parent_hdl, args_hdl);
786 MkErrorC_Check(ctx, errVal);
787 }
788
790 inline void MqContextC::LinkCreateChild (const MqContextC& parent, const MkBufferListC& args) {
791 MK_UNUSED auto ctx = getCTX();
792 const MQ_CTX parent_hdl = MqContextC::getCTX(parent);
793 const MK_BAC args_hdl = MkBufferListC::getBFL(args);
794 enum MkErrorE errVal = MqLinkCreateChild(ctx, parent_hdl, args_hdl);
795 MkErrorC_Check(ctx, errVal);
796 }
797
799 inline void MqContextC::LinkDelete () {
800 MK_UNUSED auto ctx = getCTX();
801 MqLinkDelete(ctx);
802 }
803
806 MK_UNUSED auto ctx = getCTX();
807 MK_NUM __retVal__L = MqLinkGetCtxId(ctx);
808 return __retVal__L;
809 }
810
813 MK_UNUSED auto ctx = getCTX();
814 MK_STRN __retVal__L = MqLinkGetTargetIdent(ctx);
815 return __retVal__L;
816 }
817
820 MK_UNUSED auto ctx = getCTX();
821 MK_BOOL __retVal__L = MqLinkIsConnected(ctx);
822 return __retVal__L;
823 }
824
827 MK_UNUSED auto ctx = getCTX();
828 MK_BOOL __retVal__L = MqLinkIsParent(ctx);
829 return __retVal__L;
830 }
831
834 MK_UNUSED auto ctx = getCTX();
835 enum MkErrorE errVal = MqLinkShutdown(ctx);
836 MkErrorC_Check(ctx, errVal);
837 }
838
840 // MqContextC_LinkApi_Link_CC_API
841
845
846 // doc-key: MqContextC,MqContextC-LogApi-Log,om_
847
848 // skip class-overload: Log = MqContextLog → MkObjectLog
849
850 // skip class-overload: Log = MqContextLog → MkObjectLog
851
853 inline void MqContextC::LogConfig (const MkObjectC* fmtobj, MK_DBG debug, MK_STRN callfunc, MK_I32 lvl) const {
854 MK_UNUSED auto ctx = getCTXN();
855 MK_OBJN fmtobj_hdl = MkObjectC::getOBJN__null_allow(fmtobj);
856 if (callfunc == NULL) {callfunc = __builtin_FUNCTION();}
857 if (debug > (MK_DBG)(MkRuntimeDebugGet())) {return;}
858 MqContextLogConfig(ctx, fmtobj_hdl, debug, callfunc, lvl);
859 }
860
862 inline void MqContextC::LogConfig (const MkObjectC& fmtobj, MK_DBG debug, MK_STRN callfunc, MK_I32 lvl) const {
863 MK_UNUSED auto ctx = getCTXN();
864 const MK_OBJN fmtobj_hdl = MkObjectC::getOBJN(fmtobj);
865 if (callfunc == NULL) {callfunc = __builtin_FUNCTION();}
866 if (debug > (MK_DBG)(MkRuntimeDebugGet())) {return;}
867 MqContextLogConfig(ctx, fmtobj_hdl, debug, callfunc, lvl);
868 }
869
871 inline void MqContextC::LogEnv (const MkObjectC* fmtobj, MK_DBG debug, MK_STRN callfunc, MK_I32 lvl) const {
872 MK_UNUSED auto ctx = getCTX();
873 MK_OBJN fmtobj_hdl = MkObjectC::getOBJN__null_allow(fmtobj);
874 if (callfunc == NULL) {callfunc = __builtin_FUNCTION();}
875 if (debug > (MK_DBG)(MkRuntimeDebugGet())) {return;}
876 MqContextLogEnv(ctx, fmtobj_hdl, debug, callfunc, lvl);
877 }
878
880 inline void MqContextC::LogEnv (const MkObjectC& fmtobj, MK_DBG debug, MK_STRN callfunc, MK_I32 lvl) const {
881 MK_UNUSED auto ctx = getCTX();
882 const MK_OBJN fmtobj_hdl = MkObjectC::getOBJN(fmtobj);
883 if (callfunc == NULL) {callfunc = __builtin_FUNCTION();}
884 if (debug > (MK_DBG)(MkRuntimeDebugGet())) {return;}
885 MqContextLogEnv(ctx, fmtobj_hdl, debug, callfunc, lvl);
886 }
887
889 inline void MqContextC::LogLink (const MkObjectC* fmtobj, MK_DBG debug, MK_STRN callfunc, MK_I32 lvl) const {
890 MK_UNUSED auto ctx = getCTXN();
891 MK_OBJN fmtobj_hdl = MkObjectC::getOBJN__null_allow(fmtobj);
892 if (callfunc == NULL) {callfunc = __builtin_FUNCTION();}
893 if (debug > (MK_DBG)(MkRuntimeDebugGet())) {return;}
894 MqContextLogLink(ctx, fmtobj_hdl, debug, callfunc, lvl);
895 }
896
898 inline void MqContextC::LogLink (const MkObjectC& fmtobj, MK_DBG debug, MK_STRN callfunc, MK_I32 lvl) const {
899 MK_UNUSED auto ctx = getCTXN();
900 const MK_OBJN fmtobj_hdl = MkObjectC::getOBJN(fmtobj);
901 if (callfunc == NULL) {callfunc = __builtin_FUNCTION();}
902 if (debug > (MK_DBG)(MkRuntimeDebugGet())) {return;}
903 MqContextLogLink(ctx, fmtobj_hdl, debug, callfunc, lvl);
904 }
905
907 inline void MqContextC::LogSetup (const MkObjectC* fmtobj, MK_DBG debug, MK_STRN callfunc, MK_I32 lvl) const {
908 MK_UNUSED auto ctx = getCTXN();
909 MK_OBJN fmtobj_hdl = MkObjectC::getOBJN__null_allow(fmtobj);
910 if (callfunc == NULL) {callfunc = __builtin_FUNCTION();}
911 if (debug > (MK_DBG)(MkRuntimeDebugGet())) {return;}
912 MqContextLogSetup(ctx, fmtobj_hdl, debug, callfunc, lvl);
913 }
914
916 inline void MqContextC::LogSetup (const MkObjectC& fmtobj, MK_DBG debug, MK_STRN callfunc, MK_I32 lvl) const {
917 MK_UNUSED auto ctx = getCTXN();
918 const MK_OBJN fmtobj_hdl = MkObjectC::getOBJN(fmtobj);
919 if (callfunc == NULL) {callfunc = __builtin_FUNCTION();}
920 if (debug > (MK_DBG)(MkRuntimeDebugGet())) {return;}
921 MqContextLogSetup(ctx, fmtobj_hdl, debug, callfunc, lvl);
922 }
923
925 inline void MqContextC::LogShort (const MkObjectC* fmtobj, MK_DBG debug, MK_STRN callfunc, MK_I32 lvl, MK_STRN label) const {
926 MK_UNUSED auto ctx = getCTXN();
927 MK_OBJN fmtobj_hdl = MkObjectC::getOBJN__null_allow(fmtobj);
928 if (callfunc == NULL) {callfunc = __builtin_FUNCTION();}
929 if (debug > (MK_DBG)(MkRuntimeDebugGet())) {return;}
930 MqContextLogShort(ctx, fmtobj_hdl, debug, callfunc, lvl, label);
931 }
932
934 inline void MqContextC::LogShort (const MkObjectC& fmtobj, MK_DBG debug, MK_STRN callfunc, MK_I32 lvl, MK_STRN label) const {
935 MK_UNUSED auto ctx = getCTXN();
936 const MK_OBJN fmtobj_hdl = MkObjectC::getOBJN(fmtobj);
937 if (callfunc == NULL) {callfunc = __builtin_FUNCTION();}
938 if (debug > (MK_DBG)(MkRuntimeDebugGet())) {return;}
939 MqContextLogShort(ctx, fmtobj_hdl, debug, callfunc, lvl, label);
940 }
941
943 inline void MqContextC::LogType (const MkObjectC* fmtobj, MK_DBG debug, MK_STRN callfunc, MK_I32 lvl) const {
944 MK_UNUSED auto ctx = getCTX();
945 MK_OBJN fmtobj_hdl = MkObjectC::getOBJN__null_allow(fmtobj);
946 if (callfunc == NULL) {callfunc = __builtin_FUNCTION();}
947 if (debug > (MK_DBG)(MkRuntimeDebugGet())) {return;}
948 MqContextLogType(ctx, fmtobj_hdl, debug, callfunc, lvl);
949 }
950
952 inline void MqContextC::LogType (const MkObjectC& fmtobj, MK_DBG debug, MK_STRN callfunc, MK_I32 lvl) const {
953 MK_UNUSED auto ctx = getCTX();
954 const MK_OBJN fmtobj_hdl = MkObjectC::getOBJN(fmtobj);
955 if (callfunc == NULL) {callfunc = __builtin_FUNCTION();}
956 if (debug > (MK_DBG)(MkRuntimeDebugGet())) {return;}
957 MqContextLogType(ctx, fmtobj_hdl, debug, callfunc, lvl);
958 }
959
962 MK_UNUSED auto ctx = getCTXN();
963 MK_STRN __retVal__L = MqLogParentOrChild(ctx);
964 return __retVal__L;
965 }
966
969 MK_UNUSED auto ctx = getCTXN();
970 MK_STRN __retVal__L = MqLogServerOrClient(ctx);
971 return __retVal__L;
972 }
973
975 // MqContextC_LogApi_Log_CC_API
976
980
981 // doc-key: MqContextC,MqContextC-MiscApi-Misc,oc_
982
985 MK_UNUSED auto ctx = getCTX();
986 MK_BUF __retVal__L = MqContextGetBuffer(ctx);
987 return MkBufferC::MkBufferC_ObjNew(MK_RT_CALL __retVal__L);
988 }
989
992 MK_UNUSED auto ctx = getCTX();
993 MQ_CTX __retVal__L = MqGetRoot(ctx);
994 return MqContextC::MqContextC_ObjNew(MK_RT_CALL __retVal__L);
995 }
996
997 // doc-key: MqContextC,MqContextC-MiscApi-Misc,om_
998
999 // skip class-overload: ToString = MqContextToString → MkObjectToString
1000
1002 inline MK_I32 MqContextC::Exit (MK_STRN callfunc, MK_STRN callfile, MK_I32 callline) {
1003 MK_UNUSED auto ctx = getCTX__null_allow();
1004 if (callline == -1) {callline = __builtin_LINE();}
1005 if (callfile == NULL) {callfile = __builtin_FILE();}
1006 if (callfunc == NULL) {callfunc = __builtin_FUNCTION();}
1007 MK_I32 __retVal__L = MqExit(ctx, callfunc, callfile, callline);
1008 return __retVal__L;
1009 }
1010
1013 MK_UNUSED auto ctx = getCTX();
1014 enum MkErrorE errVal = MqProcessEvent(ctx, wait, timeout);
1015 MkErrorC_Check(ctx, errVal);
1016 }
1017
1019 // MqContextC_MiscApi_Misc_CC_API
1020
1024
1025 // doc-key: MqContextC,MqContextC-ProxyApi-Proxy,om_
1026
1028 inline void MqContextC::ProxyForward (MqContextC* targetCtx, MqDumpC* dump, MK_TIME_T timeout) {
1029 MK_UNUSED auto sourceCtx = getCTX();
1030 MQ_CTX targetCtx_hdl = MqContextC::getCTX(targetCtx);
1031 MQ_DMP dump_hdl = MqDumpC::getDMP__null_allow(dump);
1032 enum MkErrorE errVal = MqProxyForward(sourceCtx, targetCtx_hdl, dump_hdl, timeout);
1033 MkErrorC_Check(sourceCtx, errVal);
1034 }
1035
1037 inline void MqContextC::ProxyForward (const MqContextC& targetCtx, const MqDumpC& dump, MK_TIME_T timeout) {
1038 MK_UNUSED auto sourceCtx = getCTX();
1039 const MQ_CTX targetCtx_hdl = MqContextC::getCTX(targetCtx);
1040 const MQ_DMP dump_hdl = MqDumpC::getDMP(dump);
1041 enum MkErrorE errVal = MqProxyForward(sourceCtx, targetCtx_hdl, dump_hdl, timeout);
1042 MkErrorC_Check(sourceCtx, errVal);
1043 }
1044
1046 inline void MqContextC::ProxyItem (MqContextC* targetCtx) {
1047 MK_UNUSED auto sourceCtx = getCTX();
1048 MQ_CTX targetCtx_hdl = MqContextC::getCTX(targetCtx);
1049 enum MkErrorE errVal = MqProxyItem(sourceCtx, targetCtx_hdl);
1050 MkErrorC_Check(sourceCtx, errVal);
1051 }
1052
1054 inline void MqContextC::ProxyItem (const MqContextC& targetCtx) {
1055 MK_UNUSED auto sourceCtx = getCTX();
1056 const MQ_CTX targetCtx_hdl = MqContextC::getCTX(targetCtx);
1057 enum MkErrorE errVal = MqProxyItem(sourceCtx, targetCtx_hdl);
1058 MkErrorC_Check(sourceCtx, errVal);
1059 }
1060
1062 // MqContextC_ProxyApi_Proxy_CC_API
1063
1067
1068 // doc-key: MqContextC,MqContextC-ReadApi-Atom,oci
1069
1072 MK_UNUSED auto ctx = getCTX();
1073 MK_BFL val_inout_hdl = MkBufferListC::getBFL__null_allow(val_inout);
1074 enum MkErrorE errVal = MqReadALL(ctx, &val_inout_hdl);
1075 MkErrorC_Check(ctx, errVal);
1076 return MkBufferListC::MkBufferListC_ObjNew(MK_RT_CALL val_inout_hdl);
1077 }
1078
1079 // doc-key: MqContextC,MqContextC-ReadApi-Atom,oco
1080
1083 MK_UNUSED auto ctx = getCTX();
1084 MK_BFL val_out;
1085 enum MkErrorE errVal = MqReadBFL(ctx, &val_out);
1086 MkErrorC_Check(ctx, errVal);
1088 }
1089
1092 MK_UNUSED auto ctx = getCTX();
1093 MK_BUF val_out;
1094 enum MkErrorE errVal = MqReadBUF(ctx, &val_out);
1095 MkErrorC_Check(ctx, errVal);
1097 }
1098
1099 // doc-key: MqContextC,MqContextC-ReadApi-Atom,omo
1100
1103 MK_UNUSED auto ctx = getCTX();
1104 MkBinaryR val_out_ref;
1105 enum MkErrorE errVal = MqReadBIN(ctx, &val_out_ref);
1106 ErrorCheck(errVal);
1107 MK_BNP val_out = std::make_pair(val_out_ref.size,val_out_ref.data);
1108 return val_out;
1109 }
1110
1113 MK_UNUSED auto ctx = getCTX();
1114 MK_BOL val_out;
1115 enum MkErrorE errVal = MqReadBOL(ctx, &val_out);
1116 MkErrorC_Check(ctx, errVal);
1117 return val_out != 0;
1118 }
1119
1122 MK_UNUSED auto ctx = getCTX();
1123 MkBinaryR val_out_ref;
1124 enum MkErrorE errVal = MqReadBinaryR(ctx, &val_out_ref);
1125 ErrorCheck(errVal);
1126 MK_BNP val_out = std::make_pair(val_out_ref.size,val_out_ref.data);
1127 return val_out;
1128 }
1129
1132 MK_UNUSED auto ctx = getCTX();
1133 MK_DBL val_out;
1134 enum MkErrorE errVal = MqReadDBL(ctx, &val_out);
1135 MkErrorC_Check(ctx, errVal);
1136 return val_out;
1137 }
1138
1141 MK_UNUSED auto ctx = getCTX();
1142 MK_FLT val_out;
1143 enum MkErrorE errVal = MqReadFLT(ctx, &val_out);
1144 MkErrorC_Check(ctx, errVal);
1145 return val_out;
1146 }
1147
1150 MK_UNUSED auto ctx = getCTX();
1151 MK_HDL val_out;
1152 enum MkErrorE errVal = MqReadHDL(ctx, &val_out);
1153 MkErrorC_Check(ctx, errVal);
1154 return val_out;
1155 }
1156
1159 MK_UNUSED auto ctx = getCTX();
1160 MK_I16 val_out;
1161 enum MkErrorE errVal = MqReadI16(ctx, &val_out);
1162 MkErrorC_Check(ctx, errVal);
1163 return val_out;
1164 }
1165
1168 MK_UNUSED auto ctx = getCTX();
1169 MK_I32 val_out;
1170 enum MkErrorE errVal = MqReadI32(ctx, &val_out);
1171 MkErrorC_Check(ctx, errVal);
1172 return val_out;
1173 }
1174
1177 MK_UNUSED auto ctx = getCTX();
1178 MK_I64 val_out;
1179 enum MkErrorE errVal = MqReadI64(ctx, &val_out);
1180 MkErrorC_Check(ctx, errVal);
1181 return val_out;
1182 }
1183
1186 MK_UNUSED auto ctx = getCTX();
1187 MK_I8 val_out;
1188 enum MkErrorE errVal = MqReadI8(ctx, &val_out);
1189 MkErrorC_Check(ctx, errVal);
1190 return (MK_I8)val_out;
1191 }
1192
1195
1198 MK_UNUSED auto ctx = getCTX();
1199 MK_LONG val_out;
1200 enum MkErrorE errVal = MqReadLONG(ctx, &val_out);
1201 MkErrorC_Check(ctx, errVal);
1202 return val_out;
1203 }
1204
1207
1210 MK_UNUSED auto ctx = getCTX();
1211 MK_STRN val_out;
1212 enum MkErrorE errVal = MqReadSTR(ctx, &val_out);
1213 MkErrorC_Check(ctx, errVal);
1214 return val_out;
1215 }
1216
1218 inline std::string MqContextC::ReadStringR () {
1219 MK_UNUSED auto ctx = getCTX();
1220 MkStringR val_out_ref;
1221 enum MkErrorE errVal = MqReadStringR(ctx, &val_out_ref);
1222 ErrorCheck(errVal);
1223 const std::string& val_out = std::string(val_out_ref.ptr,val_out_ref.len);
1224 return val_out;
1225 }
1226
1228 // MqContextC_ReadApi_Atom_CC_API
1229
1233
1234 // doc-key: MqContextC,MqContextC-ReadApi-Block,om_
1235
1237 inline void MqContextC::ReadL_END () {
1238 MK_UNUSED auto ctx = getCTX();
1239 enum MkErrorE errVal = MqReadL_END(ctx);
1240 MkErrorC_Check(ctx, errVal);
1241 }
1242
1245 MK_UNUSED auto ctx = getCTX();
1247 enum MkErrorE errVal = MqReadL_START(ctx, buf_hdl);
1248 MkErrorC_Check(ctx, errVal);
1249 }
1250
1252 inline void MqContextC::ReadL_START (const MkBufferC& buf) {
1253 MK_UNUSED auto ctx = getCTX();
1254 const MK_BUF buf_hdl = MkBufferC::getBUF(buf);
1255 enum MkErrorE errVal = MqReadL_START(ctx, buf_hdl);
1256 MkErrorC_Check(ctx, errVal);
1257 }
1258
1260 inline void MqContextC::ReadT_END () {
1261 MK_UNUSED auto ctx = getCTX();
1262 enum MkErrorE errVal = MqReadT_END(ctx);
1263 MkErrorC_Check(ctx, errVal);
1264 }
1265
1268 MK_UNUSED auto ctx = getCTX();
1269 enum MkErrorE errVal = MqReadT_START(ctx);
1270 MkErrorC_Check(ctx, errVal);
1271 }
1272
1274 // MqContextC_ReadApi_Block_CC_API
1275
1279
1280 // doc-key: MqContextC,MqContextC-ReadApi-Misc,om_
1281
1283 inline void MqContextC::ReadDbg () {
1284 MK_UNUSED auto ctx = getCTX();
1285 MqReadDbg(ctx);
1286 }
1287
1290 MK_UNUSED auto ctx = getCTX();
1291 enum MkTypeE __retVal__L = MqReadGetNextType(ctx);
1292 return __retVal__L;
1293 }
1294
1297 MK_UNUSED auto ctx = getCTX();
1298 MK_NUM __retVal__L = MqReadGetNumItems(ctx);
1299 return __retVal__L;
1300 }
1301
1304 MK_UNUSED auto ctx = getCTX();
1305 MK_BOOL __retVal__L = MqReadItemExists(ctx);
1306 return __retVal__L;
1307 }
1308
1310 inline void MqContextC::ReadUndo () {
1311 MK_UNUSED auto ctx = getCTX();
1312 enum MkErrorE errVal = MqReadUndo(ctx);
1313 MkErrorC_Check(ctx, errVal);
1314 }
1315
1317 // MqContextC_ReadApi_Misc_CC_API
1318
1322
1323 // doc-key: MqContextC,MqContextC-RouteApi-Route,oco
1324
1327 MK_UNUSED auto ctx = getCTX();
1328 MK_BFL treeP_out;
1329 enum MkErrorE errVal = MqRouteGetTree(ctx, &treeP_out);
1330 MkErrorC_Check(ctx, errVal);
1332 }
1333
1334 // doc-key: MqContextC,MqContextC-RouteApi-Route,om_
1335
1337 inline void MqContextC::RouteCreate (MK_STRN route, MK_STRN service, MK_BOOL overwrite) {
1338 MK_UNUSED auto ctx = getCTX();
1339 enum MkErrorE errVal = MqRouteCreate(ctx, route, service, overwrite);
1340 MkErrorC_Check(ctx, errVal);
1341 }
1342
1344 inline void MqContextC::RouteCreate (const std::string& route, const std::string& service, MK_BOOL overwrite) {
1345 MK_UNUSED auto ctx = getCTX();
1346 const MK_STRN route_hdl = route.c_str();
1347 const MK_STRN service_hdl = service.c_str();
1348 enum MkErrorE errVal = MqRouteCreate(ctx, route_hdl, service_hdl, overwrite);
1349 MkErrorC_Check(ctx, errVal);
1350 }
1351
1353 inline void MqContextC::RouteDelete (MK_STRN route, MK_STRN service, MK_BOOL overwrite) {
1354 MK_UNUSED auto ctx = getCTX();
1355 enum MkErrorE errVal = MqRouteDelete(ctx, route, service, overwrite);
1356 MkErrorC_Check(ctx, errVal);
1357 }
1358
1360 inline void MqContextC::RouteDelete (const std::string& route, const std::string& service, MK_BOOL overwrite) {
1361 MK_UNUSED auto ctx = getCTX();
1362 const MK_STRN route_hdl = route.c_str();
1363 const MK_STRN service_hdl = service.c_str();
1364 enum MkErrorE errVal = MqRouteDelete(ctx, route_hdl, service_hdl, overwrite);
1365 MkErrorC_Check(ctx, errVal);
1366 }
1367
1370 MK_UNUSED auto ctx = getCTX();
1371 MQ_CTX_A __retVal__L = MqRouteResolve(ctx, ident, retnum);
1372 static __thread MK_NUM szret = 0;
1373 static __thread MqContextC* *ret = NULL;
1374 if (__retVal__L.size+1 > szret) {
1375 szret=__retVal__L.size*2+1;
1376 ret=(MqContextC**)MkSysRealloc(MK_ERROR_PANIC,ret,szret*sizeof(MqContextC*));
1377 }
1378 MK_NUM num;
1379 for (num=0; num<__retVal__L.size; num++) {
1380 ret[num] = MqContextC::MqContextC_ObjNew(MK_RT_CALL __retVal__L.data[num]);
1381 }
1382 ret[num] = NULL;
1383 return (MqContextC_A) {__retVal__L.size,ret};
1384 }
1385
1387 inline MqContextC_A MqContextC::RouteResolve (const std::string& ident, MK_NUM retnum) {
1388 MK_UNUSED auto ctx = getCTX();
1389 const MK_STRN ident_hdl = ident.c_str();
1390 MQ_CTX_A __retVal__L = MqRouteResolve(ctx, ident_hdl, retnum);
1391 static __thread MK_NUM szret = 0;
1392 static __thread MqContextC* *ret = NULL;
1393 if (__retVal__L.size+1 > szret) {
1394 szret=__retVal__L.size*2+1;
1395 ret=(MqContextC**)MkSysRealloc(MK_ERROR_PANIC,ret,szret*sizeof(MqContextC*));
1396 }
1397 MK_NUM num;
1398 for (num=0; num<__retVal__L.size; num++) {
1399 ret[num] = MqContextC::MqContextC_ObjNew(MK_RT_CALL __retVal__L.data[num]);
1400 }
1401 ret[num] = NULL;
1402 return (MqContextC_A) {__retVal__L.size,ret};
1403 }
1404
1406 inline void MqContextC::RouteTraverse (MK_STRN service, MkBufferListC* args) {
1407 MK_UNUSED auto ctx = getCTX();
1409 enum MkErrorE errVal = MqRouteTraverse(ctx, service, args_hdl);
1410 MkErrorC_Check(ctx, errVal);
1411 }
1412
1414 inline void MqContextC::RouteTraverse (MK_STRN service, const MkBufferListC& args) {
1415 MK_UNUSED auto ctx = getCTX();
1416 const MK_BAC args_hdl = MkBufferListC::getBFL(args);
1417 enum MkErrorE errVal = MqRouteTraverse(ctx, service, args_hdl);
1418 MkErrorC_Check(ctx, errVal);
1419 }
1420
1422 inline void MqContextC::RouteTraverse (const std::string& service, MkBufferListC* args) {
1423 MK_UNUSED auto ctx = getCTX();
1424 const MK_STRN service_hdl = service.c_str();
1426 enum MkErrorE errVal = MqRouteTraverse(ctx, service_hdl, args_hdl);
1427 MkErrorC_Check(ctx, errVal);
1428 }
1429
1431 inline void MqContextC::RouteTraverse (const std::string& service, const MkBufferListC& args) {
1432 MK_UNUSED auto ctx = getCTX();
1433 const MK_STRN service_hdl = service.c_str();
1434 const MK_BAC args_hdl = MkBufferListC::getBFL(args);
1435 enum MkErrorE errVal = MqRouteTraverse(ctx, service_hdl, args_hdl);
1436 MkErrorC_Check(ctx, errVal);
1437 }
1438
1439 // doc-key: MqContextC,MqContextC-RouteApi-Route,omo
1440
1443 MK_UNUSED auto ctx = getCTX();
1444 MK_STRN path_out;
1445 enum MkErrorE errVal = MqRouteGetPath(ctx, &path_out);
1446 MkErrorC_Check(ctx, errVal);
1447 return path_out;
1448 }
1449
1451 // MqContextC_RouteApi_Route_CC_API
1452
1456
1457 // doc-key: MqContextC,MqContextC-SendApi-Atom,om_
1458
1460 inline void MqContextC::SendBFL (const MkBufferListC* val) {
1461 MK_UNUSED auto ctx = getCTX();
1462 MK_BFLN val_hdl = MkBufferListC::getBFLN(val);
1463 enum MkErrorE errVal = MqSendBFL(ctx, val_hdl);
1464 MkErrorC_Check(ctx, errVal);
1465 }
1466
1468 inline void MqContextC::SendBFL (const MkBufferListC& val) {
1469 MK_UNUSED auto ctx = getCTX();
1470 const MK_BFLN val_hdl = MkBufferListC::getBFLN(val);
1471 enum MkErrorE errVal = MqSendBFL(ctx, val_hdl);
1472 MkErrorC_Check(ctx, errVal);
1473 }
1474
1476 inline void MqContextC::SendBIN (MK_BNP val) {
1477 MK_UNUSED auto ctx = getCTX();
1478 const MkBinaryR val_ref = MkBinaryCreate(val.first,val.second);
1479 enum MkErrorE errVal = MqSendBIN(ctx, val_ref);
1480 MkErrorC_Check(ctx, errVal);
1481 }
1482
1484 inline void MqContextC::SendBOL (MK_BOL val) {
1485 MK_UNUSED auto ctx = getCTX();
1486 enum MkErrorE errVal = MqSendBOL(ctx, (MK_BOL)(val?1:0));
1487 MkErrorC_Check(ctx, errVal);
1488 }
1489
1491 inline void MqContextC::SendBUF (const MkBufferC* val) {
1492 MK_UNUSED auto ctx = getCTX();
1493 MK_BUFN val_hdl = MkBufferC::getBUFN(val);
1494 enum MkErrorE errVal = MqSendBUF(ctx, val_hdl);
1495 MkErrorC_Check(ctx, errVal);
1496 }
1497
1499 inline void MqContextC::SendBUF (const MkBufferC& val) {
1500 MK_UNUSED auto ctx = getCTX();
1501 const MK_BUFN val_hdl = MkBufferC::getBUFN(val);
1502 enum MkErrorE errVal = MqSendBUF(ctx, val_hdl);
1503 MkErrorC_Check(ctx, errVal);
1504 }
1505
1508 MK_UNUSED auto ctx = getCTX();
1509 MK_BUSN val_hdl = MkBufferStreamC::getBUSN(val);
1510 enum MkErrorE errVal = MqSendBUS_FLAT(ctx, val_hdl);
1511 MkErrorC_Check(ctx, errVal);
1512 }
1513
1516 MK_UNUSED auto ctx = getCTX();
1517 const MK_BUSN val_hdl = MkBufferStreamC::getBUSN(val);
1518 enum MkErrorE errVal = MqSendBUS_FLAT(ctx, val_hdl);
1519 MkErrorC_Check(ctx, errVal);
1520 }
1521
1524 MK_UNUSED auto ctx = getCTX();
1525 const MkBinaryR val_ref = MkBinaryCreate(val.first,val.second);
1526 enum MkErrorE errVal = MqSendBinaryR(ctx, val_ref);
1527 MkErrorC_Check(ctx, errVal);
1528 }
1529
1531 inline void MqContextC::SendDBL (MK_DBL val) {
1532 MK_UNUSED auto ctx = getCTX();
1533 enum MkErrorE errVal = MqSendDBL(ctx, val);
1534 MkErrorC_Check(ctx, errVal);
1535 }
1536
1538 inline void MqContextC::SendFLT (MK_FLT val) {
1539 MK_UNUSED auto ctx = getCTX();
1540 enum MkErrorE errVal = MqSendFLT(ctx, val);
1541 MkErrorC_Check(ctx, errVal);
1542 }
1543
1545 inline void MqContextC::SendHDL (MK_HDL val) {
1546 MK_UNUSED auto ctx = getCTX();
1547 enum MkErrorE errVal = MqSendHDL(ctx, val);
1548 MkErrorC_Check(ctx, errVal);
1549 }
1550
1552 inline void MqContextC::SendI16 (MK_I16 val) {
1553 MK_UNUSED auto ctx = getCTX();
1554 enum MkErrorE errVal = MqSendI16(ctx, val);
1555 MkErrorC_Check(ctx, errVal);
1556 }
1557
1559 inline void MqContextC::SendI32 (MK_I32 val) {
1560 MK_UNUSED auto ctx = getCTX();
1561 enum MkErrorE errVal = MqSendI32(ctx, val);
1562 MkErrorC_Check(ctx, errVal);
1563 }
1564
1566 inline void MqContextC::SendI64 (MK_I64 val) {
1567 MK_UNUSED auto ctx = getCTX();
1568 enum MkErrorE errVal = MqSendI64(ctx, val);
1569 MkErrorC_Check(ctx, errVal);
1570 }
1571
1573 inline void MqContextC::SendI8 (MK_I8 val) {
1574 MK_UNUSED auto ctx = getCTX();
1575 enum MkErrorE errVal = MqSendI8(ctx, (MK_I8)(val));
1576 MkErrorC_Check(ctx, errVal);
1577 }
1578
1580 inline void MqContextC::SendLONG (MK_LONG val) {
1581 MK_UNUSED auto ctx = getCTX();
1582 enum MkErrorE errVal = MqSendLONG(ctx, val);
1583 MkErrorC_Check(ctx, errVal);
1584 }
1585
1587 inline void MqContextC::SendLTR (MQ_LTR transLId) {
1588 MK_UNUSED auto ctx = getCTX();
1589 enum MkErrorE errVal = MqSendLTR(ctx, transLId);
1590 MkErrorC_Check(ctx, errVal);
1591 }
1592
1594 inline void MqContextC::SendL_FLAT (const MkBufferListC* val) {
1595 MK_UNUSED auto ctx = getCTX();
1596 MK_BFLN val_hdl = MkBufferListC::getBFLN(val);
1597 enum MkErrorE errVal = MqSendL_FLAT(ctx, val_hdl);
1598 MkErrorC_Check(ctx, errVal);
1599 }
1600
1602 inline void MqContextC::SendL_FLAT (const MkBufferListC& val) {
1603 MK_UNUSED auto ctx = getCTX();
1604 const MK_BFLN val_hdl = MkBufferListC::getBFLN(val);
1605 enum MkErrorE errVal = MqSendL_FLAT(ctx, val_hdl);
1606 MkErrorC_Check(ctx, errVal);
1607 }
1608
1610 inline void MqContextC::SendSTR (MK_STRN val) {
1611 MK_UNUSED auto ctx = getCTX();
1612 enum MkErrorE errVal = MqSendSTR(ctx, val);
1613 MkErrorC_Check(ctx, errVal);
1614 }
1615
1617 inline void MqContextC::SendSTR (const std::string& val) {
1618 MK_UNUSED auto ctx = getCTX();
1619 const MK_STRN val_hdl = val.c_str();
1620 enum MkErrorE errVal = MqSendSTR(ctx, val_hdl);
1621 MkErrorC_Check(ctx, errVal);
1622 }
1623
1625 inline void MqContextC::SendStringR (const std::string& val) {
1626 MK_UNUSED auto ctx = getCTX();
1627 const MkStringR val_ref = MkStringCreate((MK_NUM)val.size(),val.c_str());
1628 enum MkErrorE errVal = MqSendStringR(ctx, val_ref);
1629 MkErrorC_Check(ctx, errVal);
1630 }
1631
1633 inline void MqContextC::SendV (MK_FST printfmt, ... ) {
1634 MK_UNUSED auto ctx = getCTX();
1635 va_list ap;
1636 va_start (ap, printfmt);
1637 enum MkErrorE errVal = MqSendVL(ctx, printfmt, ap);
1638 va_end (ap);
1639 MkErrorC_Check(ctx, errVal);
1640 }
1641
1643 inline void MqContextC::SendVL (MK_FST printfmt, va_list var_list) {
1644 MK_UNUSED auto ctx = getCTX();
1645 enum MkErrorE errVal = MqSendVL(ctx, printfmt, var_list);
1646 MkErrorC_Check(ctx, errVal);
1647 }
1648
1650 // MqContextC_SendApi_Atom_CC_API
1651
1655
1656 // doc-key: MqContextC,MqContextC-SendApi-Basics,om_
1657
1659 inline void MqContextC::SendEND (MQ_TOK token, MK_TIME_T timeout) {
1660 MK_UNUSED auto ctx = getCTX();
1661 enum MkErrorE errVal = MqSendEND(ctx, token, timeout);
1662 MkErrorC_Check(ctx, errVal);
1663 }
1664
1666 inline void MqContextC::SendEND (const std::string& token, MK_TIME_T timeout) {
1667 MK_UNUSED auto ctx = getCTX();
1668 const MK_STRN token_hdl = token.c_str();
1669 enum MkErrorE errVal = MqSendEND(ctx, token_hdl, timeout);
1670 MkErrorC_Check(ctx, errVal);
1671 }
1672
1674 inline void MqContextC::SendEND_AND_CALLBACK (MQ_TOK token, MqServiceCCB callback, MK_TIME_T timeout) {
1675 MK_UNUSED auto ctx = getCTX();
1676 auto callback_ptr = MqServiceCallbackC::Create(MK_RT_CALL callback, this);
1677 enum MkErrorE errVal = MqSendEND_AND_CALLBACK(ctx, token, MqServiceCallbackC::Call, callback_ptr, MqServiceCallbackC::Free, timeout);
1678 MkErrorC_Check(ctx, errVal);
1679 }
1680
1682 inline void MqContextC::SendEND_AND_CALLBACK (const std::string& token, MqServiceCCB callback, MK_TIME_T timeout) {
1683 MK_UNUSED auto ctx = getCTX();
1684 const MK_STRN token_hdl = token.c_str();
1685 auto callback_ptr = MqServiceCallbackC::Create(MK_RT_CALL callback, this);
1686 enum MkErrorE errVal = MqSendEND_AND_CALLBACK(ctx, token_hdl, MqServiceCallbackC::Call, callback_ptr, MqServiceCallbackC::Free, timeout);
1687 MkErrorC_Check(ctx, errVal);
1688 }
1689
1691 inline void MqContextC::SendEND_AND_CALLBACK (MQ_TOK token, MqServiceICB callback, MK_TIME_T timeout) {
1692 MK_UNUSED auto ctx = getCTX();
1693 auto callback_ptr = MqServiceCallbackC::Create(MK_RT_CALL callback, this);
1694 enum MkErrorE errVal = MqSendEND_AND_CALLBACK(ctx, token, MqServiceCallbackC::Call, callback_ptr, MqServiceCallbackC::Free, timeout);
1695 MkErrorC_Check(ctx, errVal);
1696 }
1697
1699 inline void MqContextC::SendEND_AND_CALLBACK (const std::string& token, MqServiceICB callback, MK_TIME_T timeout) {
1700 MK_UNUSED auto ctx = getCTX();
1701 const MK_STRN token_hdl = token.c_str();
1702 auto callback_ptr = MqServiceCallbackC::Create(MK_RT_CALL callback, this);
1703 enum MkErrorE errVal = MqSendEND_AND_CALLBACK(ctx, token_hdl, MqServiceCallbackC::Call, callback_ptr, MqServiceCallbackC::Free, timeout);
1704 MkErrorC_Check(ctx, errVal);
1705 }
1706
1708 inline void MqContextC::SendEND_AND_CALLBACK (MQ_TOK token, MqServiceIF* callback, MK_TIME_T timeout) {
1709 MK_UNUSED auto ctx = getCTX();
1710 auto callback_ptr = MqServiceCallbackC::Create(MK_RT_CALL callback, this);
1711 enum MkErrorE errVal = MqSendEND_AND_CALLBACK(ctx, token, MqServiceCallbackC::Call, callback_ptr, MqServiceCallbackC::Free, timeout);
1712 MkErrorC_Check(ctx, errVal);
1713 }
1714
1716 inline void MqContextC::SendEND_AND_CALLBACK (const std::string& token, MqServiceIF* callback, MK_TIME_T timeout) {
1717 MK_UNUSED auto ctx = getCTX();
1718 const MK_STRN token_hdl = token.c_str();
1719 auto callback_ptr = MqServiceCallbackC::Create(MK_RT_CALL callback, this);
1720 enum MkErrorE errVal = MqSendEND_AND_CALLBACK(ctx, token_hdl, MqServiceCallbackC::Call, callback_ptr, MqServiceCallbackC::Free, timeout);
1721 MkErrorC_Check(ctx, errVal);
1722 }
1723
1725 inline void MqContextC::SendEND_AND_SUB (MQ_TOK token, MqServiceCCB callback, MK_TIME_T timeout) {
1726 MK_UNUSED auto ctx = getCTX();
1727 auto callback_ptr = MqServiceCallbackC::Create(MK_RT_CALL callback, this);
1728 enum MkErrorE errVal = MqSendEND_AND_SUB(ctx, token, MqServiceCallbackC::Call, callback_ptr, MqServiceCallbackC::Free, timeout);
1729 MkErrorC_Check(ctx, errVal);
1730 }
1731
1733 inline void MqContextC::SendEND_AND_SUB (const std::string& token, MqServiceCCB callback, MK_TIME_T timeout) {
1734 MK_UNUSED auto ctx = getCTX();
1735 const MK_STRN token_hdl = token.c_str();
1736 auto callback_ptr = MqServiceCallbackC::Create(MK_RT_CALL callback, this);
1737 enum MkErrorE errVal = MqSendEND_AND_SUB(ctx, token_hdl, MqServiceCallbackC::Call, callback_ptr, MqServiceCallbackC::Free, timeout);
1738 MkErrorC_Check(ctx, errVal);
1739 }
1740
1742 inline void MqContextC::SendEND_AND_SUB (MQ_TOK token, MqServiceICB callback, MK_TIME_T timeout) {
1743 MK_UNUSED auto ctx = getCTX();
1744 auto callback_ptr = MqServiceCallbackC::Create(MK_RT_CALL callback, this);
1745 enum MkErrorE errVal = MqSendEND_AND_SUB(ctx, token, MqServiceCallbackC::Call, callback_ptr, MqServiceCallbackC::Free, timeout);
1746 MkErrorC_Check(ctx, errVal);
1747 }
1748
1750 inline void MqContextC::SendEND_AND_SUB (const std::string& token, MqServiceICB callback, MK_TIME_T timeout) {
1751 MK_UNUSED auto ctx = getCTX();
1752 const MK_STRN token_hdl = token.c_str();
1753 auto callback_ptr = MqServiceCallbackC::Create(MK_RT_CALL callback, this);
1754 enum MkErrorE errVal = MqSendEND_AND_SUB(ctx, token_hdl, MqServiceCallbackC::Call, callback_ptr, MqServiceCallbackC::Free, timeout);
1755 MkErrorC_Check(ctx, errVal);
1756 }
1757
1759 inline void MqContextC::SendEND_AND_SUB (MQ_TOK token, MqServiceIF* callback, MK_TIME_T timeout) {
1760 MK_UNUSED auto ctx = getCTX();
1761 auto callback_ptr = MqServiceCallbackC::Create(MK_RT_CALL callback, this);
1762 enum MkErrorE errVal = MqSendEND_AND_SUB(ctx, token, MqServiceCallbackC::Call, callback_ptr, MqServiceCallbackC::Free, timeout);
1763 MkErrorC_Check(ctx, errVal);
1764 }
1765
1767 inline void MqContextC::SendEND_AND_SUB (const std::string& token, MqServiceIF* callback, MK_TIME_T timeout) {
1768 MK_UNUSED auto ctx = getCTX();
1769 const MK_STRN token_hdl = token.c_str();
1770 auto callback_ptr = MqServiceCallbackC::Create(MK_RT_CALL callback, this);
1771 enum MkErrorE errVal = MqSendEND_AND_SUB(ctx, token_hdl, MqServiceCallbackC::Call, callback_ptr, MqServiceCallbackC::Free, timeout);
1772 MkErrorC_Check(ctx, errVal);
1773 }
1774
1776 inline void MqContextC::SendEND_AND_TRANSACTION (MQ_TOK token, MQ_TOK callback, MK_TIME_T timeout) {
1777 MK_UNUSED auto ctx = getCTX();
1778 enum MkErrorE errVal = MqSendEND_AND_TRANSACTION(ctx, token, callback, timeout);
1779 MkErrorC_Check(ctx, errVal);
1780 }
1781
1783 inline void MqContextC::SendEND_AND_TRANSACTION (const std::string& token, const std::string& callback, MK_TIME_T timeout) {
1784 MK_UNUSED auto ctx = getCTX();
1785 const MK_STRN token_hdl = token.c_str();
1786 const MK_STRN callback_hdl = callback.c_str();
1787 enum MkErrorE errVal = MqSendEND_AND_TRANSACTION(ctx, token_hdl, callback_hdl, timeout);
1788 MkErrorC_Check(ctx, errVal);
1789 }
1790
1792 inline void MqContextC::SendEND_AND_WAIT (MQ_TOK token, MK_TIME_T timeout) {
1793 MK_UNUSED auto ctx = getCTX();
1794 enum MkErrorE errVal = MqSendEND_AND_WAIT(ctx, token, timeout);
1795 MkErrorC_Check(ctx, errVal);
1796 }
1797
1799 inline void MqContextC::SendEND_AND_WAIT (const std::string& token, MK_TIME_T timeout) {
1800 MK_UNUSED auto ctx = getCTX();
1801 const MK_STRN token_hdl = token.c_str();
1802 enum MkErrorE errVal = MqSendEND_AND_WAIT(ctx, token_hdl, timeout);
1803 MkErrorC_Check(ctx, errVal);
1804 }
1805
1807 inline void MqContextC::SendSTART () {
1808 MK_UNUSED auto ctx = getCTX();
1809 enum MkErrorE errVal = MqSendSTART(ctx);
1810 MkErrorC_Check(ctx, errVal);
1811 }
1812
1814 inline void MqContextC::SendSYNC () {
1815 MK_UNUSED auto ctx = getCTX();
1816 enum MkErrorE errVal = MqSendSYNC(ctx);
1817 MkErrorC_Check(ctx, errVal);
1818 }
1819
1821 // MqContextC_SendApi_Basics_CC_API
1822
1826
1827 // doc-key: MqContextC,MqContextC-SendApi-Block,om_
1828
1830 inline void MqContextC::SendL_END () {
1831 MK_UNUSED auto ctx = getCTX();
1832 enum MkErrorE errVal = MqSendL_END(ctx);
1833 MkErrorC_Check(ctx, errVal);
1834 }
1835
1838 MK_UNUSED auto ctx = getCTX();
1839 enum MkErrorE errVal = MqSendL_START(ctx);
1840 MkErrorC_Check(ctx, errVal);
1841 }
1842
1844 inline void MqContextC::SendT_END () {
1845 MK_UNUSED auto ctx = getCTX();
1846 enum MkErrorE errVal = MqSendT_END(ctx);
1847 MkErrorC_Check(ctx, errVal);
1848 }
1849
1852 MK_UNUSED auto ctx = getCTX();
1853 enum MkErrorE errVal = MqSendT_START(ctx);
1854 MkErrorC_Check(ctx, errVal);
1855 }
1856
1858 // MqContextC_SendApi_Block_CC_API
1859
1863
1864 // doc-key: MqContextC,MqContextC-SendApi-Return,om_
1865
1867 inline void MqContextC::SendERROR () {
1868 MK_UNUSED auto ctx = getCTX();
1869 enum MkErrorE errVal = MqSendERROR(ctx);
1870 MkErrorC_Check(ctx, errVal);
1871 }
1872
1874 inline void MqContextC::SendRETURN () {
1875 MK_UNUSED auto ctx = getCTX();
1876 enum MkErrorE errVal = MqSendRETURN(ctx);
1877 MkErrorC_Check(ctx, errVal);
1878 }
1879
1882 MK_UNUSED auto ctx = getCTX();
1883 enum MkErrorE errVal = MqSendRETURN_SUB(ctx);
1884 MkErrorC_Check(ctx, errVal);
1885 }
1886
1888 // MqContextC_SendApi_Return_CC_API
1889
1893
1894 // doc-key: MqContextC,MqContextC-ServiceApi-Service,om_
1895
1897 inline void MqContextC::ServiceCreate (MQ_TOK token, MqServiceCCB callback) {
1898 MK_UNUSED auto ctx = getCTX();
1899 auto callback_ptr = MqServiceCallbackC::Create(MK_RT_CALL callback, this);
1900 enum MkErrorE errVal = MqServiceCreate(ctx, token, MqServiceCallbackC::Call, callback_ptr, MqServiceCallbackC::Free, NULL);
1901 MkErrorC_Check(ctx, errVal);
1902 }
1903
1905 inline void MqContextC::ServiceCreate (const std::string& token, MqServiceCCB callback) {
1906 MK_UNUSED auto ctx = getCTX();
1907 const MK_STRN token_hdl = token.c_str();
1908 auto callback_ptr = MqServiceCallbackC::Create(MK_RT_CALL callback, this);
1909 enum MkErrorE errVal = MqServiceCreate(ctx, token_hdl, MqServiceCallbackC::Call, callback_ptr, MqServiceCallbackC::Free, NULL);
1910 MkErrorC_Check(ctx, errVal);
1911 }
1912
1914 inline void MqContextC::ServiceCreate (MQ_TOK token, MqServiceICB callback) {
1915 MK_UNUSED auto ctx = getCTX();
1916 auto callback_ptr = MqServiceCallbackC::Create(MK_RT_CALL callback, this);
1917 enum MkErrorE errVal = MqServiceCreate(ctx, token, MqServiceCallbackC::Call, callback_ptr, MqServiceCallbackC::Free, NULL);
1918 MkErrorC_Check(ctx, errVal);
1919 }
1920
1922 inline void MqContextC::ServiceCreate (const std::string& token, MqServiceICB callback) {
1923 MK_UNUSED auto ctx = getCTX();
1924 const MK_STRN token_hdl = token.c_str();
1925 auto callback_ptr = MqServiceCallbackC::Create(MK_RT_CALL callback, this);
1926 enum MkErrorE errVal = MqServiceCreate(ctx, token_hdl, MqServiceCallbackC::Call, callback_ptr, MqServiceCallbackC::Free, NULL);
1927 MkErrorC_Check(ctx, errVal);
1928 }
1929
1931 inline void MqContextC::ServiceCreate (MQ_TOK token, MqServiceIF* callback) {
1932 MK_UNUSED auto ctx = getCTX();
1933 auto callback_ptr = MqServiceCallbackC::Create(MK_RT_CALL callback, this);
1934 enum MkErrorE errVal = MqServiceCreate(ctx, token, MqServiceCallbackC::Call, callback_ptr, MqServiceCallbackC::Free, NULL);
1935 MkErrorC_Check(ctx, errVal);
1936 }
1937
1939 inline void MqContextC::ServiceCreate (const std::string& token, MqServiceIF* callback) {
1940 MK_UNUSED auto ctx = getCTX();
1941 const MK_STRN token_hdl = token.c_str();
1942 auto callback_ptr = MqServiceCallbackC::Create(MK_RT_CALL callback, this);
1943 enum MkErrorE errVal = MqServiceCreate(ctx, token_hdl, MqServiceCallbackC::Call, callback_ptr, MqServiceCallbackC::Free, NULL);
1944 MkErrorC_Check(ctx, errVal);
1945 }
1946
1948 inline void MqContextC::ServiceDelete (MQ_TOK token) {
1949 MK_UNUSED auto ctx = getCTX();
1950 enum MkErrorE errVal = MqServiceDelete(ctx, token);
1951 MkErrorC_Check(ctx, errVal);
1952 }
1953
1955 inline void MqContextC::ServiceDelete (const std::string& token) {
1956 MK_UNUSED auto ctx = getCTX();
1957 const MK_STRN token_hdl = token.c_str();
1958 enum MkErrorE errVal = MqServiceDelete(ctx, token_hdl);
1959 MkErrorC_Check(ctx, errVal);
1960 }
1961
1964 MK_UNUSED auto ctx = getCTX();
1965 MK_BOOL __retVal__L = MqServiceIsTransaction(ctx);
1966 return __retVal__L;
1967 }
1968
1971 MK_UNUSED auto ctx = getCTX();
1972 enum MkErrorE errVal = MqServiceProxy(ctx, token, id);
1973 MkErrorC_Check(ctx, errVal);
1974 }
1975
1977 inline void MqContextC::ServiceProxy (const std::string& token, MQ_SLAVE_ID id) {
1978 MK_UNUSED auto ctx = getCTX();
1979 const MK_STRN token_hdl = token.c_str();
1980 enum MkErrorE errVal = MqServiceProxy(ctx, token_hdl, id);
1981 MkErrorC_Check(ctx, errVal);
1982 }
1983
1985 inline void MqContextC::ServiceProxyCtx (MQ_TOK token, MqContextC* target) {
1986 MK_UNUSED auto ctx = getCTX();
1987 MQ_CTX target_hdl = MqContextC::getCTX(target);
1988 enum MkErrorE errVal = MqServiceProxyCtx(ctx, token, target_hdl);
1989 MkErrorC_Check(ctx, errVal);
1990 }
1991
1993 inline void MqContextC::ServiceProxyCtx (MQ_TOK token, const MqContextC& target) {
1994 MK_UNUSED auto ctx = getCTX();
1995 const MQ_CTX target_hdl = MqContextC::getCTX(target);
1996 enum MkErrorE errVal = MqServiceProxyCtx(ctx, token, target_hdl);
1997 MkErrorC_Check(ctx, errVal);
1998 }
1999
2001 inline void MqContextC::ServiceProxyCtx (const std::string& token, MqContextC* target) {
2002 MK_UNUSED auto ctx = getCTX();
2003 const MK_STRN token_hdl = token.c_str();
2004 MQ_CTX target_hdl = MqContextC::getCTX(target);
2005 enum MkErrorE errVal = MqServiceProxyCtx(ctx, token_hdl, target_hdl);
2006 MkErrorC_Check(ctx, errVal);
2007 }
2008
2010 inline void MqContextC::ServiceProxyCtx (const std::string& token, const MqContextC& target) {
2011 MK_UNUSED auto ctx = getCTX();
2012 const MK_STRN token_hdl = token.c_str();
2013 const MQ_CTX target_hdl = MqContextC::getCTX(target);
2014 enum MkErrorE errVal = MqServiceProxyCtx(ctx, token_hdl, target_hdl);
2015 MkErrorC_Check(ctx, errVal);
2016 }
2017
2020 MK_UNUSED auto ctx = getCTX();
2021 MQ_CTX target_hdl = MqContextC::getCTX(target);
2022 MK_BOOL __retVal__L = MqServiceProxyCtxExists(ctx, token, target_hdl);
2023 return __retVal__L;
2024 }
2025
2028 MK_UNUSED auto ctx = getCTX();
2029 const MQ_CTX target_hdl = MqContextC::getCTX(target);
2030 MK_BOOL __retVal__L = MqServiceProxyCtxExists(ctx, token, target_hdl);
2031 return __retVal__L;
2032 }
2033
2035 inline MK_BOOL MqContextC::ServiceProxyCtxExists (const std::string& token, MqContextC* target) {
2036 MK_UNUSED auto ctx = getCTX();
2037 const MK_STRN token_hdl = token.c_str();
2038 MQ_CTX target_hdl = MqContextC::getCTX(target);
2039 MK_BOOL __retVal__L = MqServiceProxyCtxExists(ctx, token_hdl, target_hdl);
2040 return __retVal__L;
2041 }
2042
2044 inline MK_BOOL MqContextC::ServiceProxyCtxExists (const std::string& token, const MqContextC& target) {
2045 MK_UNUSED auto ctx = getCTX();
2046 const MK_STRN token_hdl = token.c_str();
2047 const MQ_CTX target_hdl = MqContextC::getCTX(target);
2048 MK_BOOL __retVal__L = MqServiceProxyCtxExists(ctx, token_hdl, target_hdl);
2049 return __retVal__L;
2050 }
2051
2054 MK_UNUSED auto ctx = getCTX();
2055 enum MkErrorE errVal = MqServiceProxyRoundRobin(ctx, token, ident);
2056 MkErrorC_Check(ctx, errVal);
2057 }
2058
2060 inline void MqContextC::ServiceProxyRoundRobin (const std::string& token, const std::string& ident) {
2061 MK_UNUSED auto ctx = getCTX();
2062 const MK_STRN token_hdl = token.c_str();
2063 const MK_STRN ident_hdl = ident.c_str();
2064 enum MkErrorE errVal = MqServiceProxyRoundRobin(ctx, token_hdl, ident_hdl);
2065 MkErrorC_Check(ctx, errVal);
2066 }
2067
2070 MK_UNUSED auto ctx = getCTX();
2071 enum MkErrorE errVal = MqServiceStorage(ctx, token);
2072 MkErrorC_Check(ctx, errVal);
2073 }
2074
2076 inline void MqContextC::ServiceStorage (const std::string& token) {
2077 MK_UNUSED auto ctx = getCTX();
2078 const MK_STRN token_hdl = token.c_str();
2079 enum MkErrorE errVal = MqServiceStorage(ctx, token_hdl);
2080 MkErrorC_Check(ctx, errVal);
2081 }
2082
2085 MK_UNUSED auto ctx = getCTX();
2086 MK_BOOL __retVal__L = MqServiceTokenCheck(ctx, token);
2087 return __retVal__L;
2088 }
2089
2091 inline MK_BOOL MqContextC::ServiceTokenCheck (const std::string& token) {
2092 MK_UNUSED auto ctx = getCTX();
2093 const MK_STRN token_hdl = token.c_str();
2094 MK_BOOL __retVal__L = MqServiceTokenCheck(ctx, token_hdl);
2095 return __retVal__L;
2096 }
2097
2100 MK_UNUSED auto ctx = getCTX();
2101 MK_BOOL __retVal__L = MqServiceTokenExists(ctx, token);
2102 return __retVal__L;
2103 }
2104
2106 inline MK_BOOL MqContextC::ServiceTokenExists (const std::string& token) {
2107 MK_UNUSED auto ctx = getCTX();
2108 const MK_STRN token_hdl = token.c_str();
2109 MK_BOOL __retVal__L = MqServiceTokenExists(ctx, token_hdl);
2110 return __retVal__L;
2111 }
2112
2115 MK_UNUSED auto ctx = getCTX();
2116 MQ_TOK __retVal__L = MqServiceTokenGet(ctx);
2117 return __retVal__L;
2118 }
2119
2121 // MqContextC_ServiceApi_Service_CC_API
2122
2126
2127 // doc-key: MqContextC,MqContextC-SlaveApi-Slave,oc_
2128
2131 MK_UNUSED auto ctx = getCTX();
2132 MQ_CTX __retVal__L = MqSlaveGetMaster(ctx);
2133 return MqContextC::MqContextC_ObjNew(MK_RT_CALL __retVal__L);
2134 }
2135
2136 // doc-key: MqContextC,MqContextC-SlaveApi-Slave,oco
2137
2140 MK_UNUSED auto ctx = getCTX();
2141 MQ_CTX ctx_out;
2142 enum MkErrorE errVal = MqSlaveGet(ctx, id, &ctx_out);
2143 MkErrorC_Check(ctx, errVal);
2145 }
2146
2149 MK_UNUSED auto ctx = getCTX();
2150 MQ_CTX ctx_out;
2151 enum MkErrorE errVal = MqSlaveGetFilter(ctx, &ctx_out);
2152 MkErrorC_Check(ctx, errVal);
2154 }
2155
2158 MK_UNUSED auto ctx = getCTX();
2159 MQ_CTX ctx_out;
2160 enum MkErrorE errVal = MqSlaveGetProxy(ctx, id, &ctx_out);
2161 MkErrorC_Check(ctx, errVal);
2163 }
2164
2165 // doc-key: MqContextC,MqContextC-SlaveApi-Slave,om_
2166
2169 MK_UNUSED auto ctx = getCTXN();
2170 MK_BOOL __retVal__L = MqSlaveCheck(ctx, id);
2171 return __retVal__L;
2172 }
2173
2176 MK_UNUSED auto ctx = getCTX();
2177 MQ_CTX slave_hdl = MqContextC::getCTX(slave);
2178 enum MkErrorE errVal = MqSlaveCreate(ctx, id, slave_hdl);
2179 MkErrorC_Check(ctx, errVal);
2180 }
2181
2183 inline void MqContextC::SlaveCreate (MQ_SLAVE_ID id, const MqContextC& slave) {
2184 MK_UNUSED auto ctx = getCTX();
2185 const MQ_CTX slave_hdl = MqContextC::getCTX(slave);
2186 enum MkErrorE errVal = MqSlaveCreate(ctx, id, slave_hdl);
2187 MkErrorC_Check(ctx, errVal);
2188 }
2189
2192 MK_UNUSED auto ctx = getCTX();
2193 enum MkErrorE errVal = MqSlaveDelete(ctx, id);
2194 MkErrorC_Check(ctx, errVal);
2195 }
2196
2199 MK_UNUSED auto ctx = getCTXN();
2200 MK_BOOL __retVal__L = MqSlaveIs(ctx);
2201 return __retVal__L;
2202 }
2203
2206 MK_UNUSED auto ctx = getCTX();
2208 enum MkErrorE errVal = MqSlaveWorker(ctx, id, fct, args_hdl);
2209 MkErrorC_Check(ctx, errVal);
2210 }
2211
2213 // MqContextC_SlaveApi_Slave_CC_API
2214
2218
2219 // doc-key: MqContextC,MqContextC-StorageApi-Storage,oci
2220
2222 inline MQ_LTR MqContextC::StorageDelete (MQ_LTR *transLIdP_inout) {
2223 MK_UNUSED auto ctx = getCTX();
2224 MQ_LTR transLIdP_inout_val = transLIdP_inout == NULL ? 0 : (MQ_LTR)(*transLIdP_inout);
2225 enum MkErrorE errVal = MqStorageDelete(ctx, &transLIdP_inout_val);
2226 if (transLIdP_inout != NULL) {*transLIdP_inout = (MQ_LTR)(transLIdP_inout_val);}
2227 MkErrorC_Check(ctx, errVal);
2228 return transLIdP_inout_val;
2229 }
2230
2232 inline MQ_LTR MqContextC::StorageImport (MQ_LTR *transLIdP_inout) {
2233 MK_UNUSED auto ctx = getCTX();
2234 MQ_LTR transLIdP_inout_val = transLIdP_inout == NULL ? 0 : (MQ_LTR)(*transLIdP_inout);
2235 enum MkErrorE errVal = MqStorageImport(ctx, &transLIdP_inout_val);
2236 if (transLIdP_inout != NULL) {*transLIdP_inout = (MQ_LTR)(transLIdP_inout_val);}
2237 MkErrorC_Check(ctx, errVal);
2238 return transLIdP_inout_val;
2239 }
2240
2241 // doc-key: MqContextC,MqContextC-StorageApi-Storage,om_
2242
2245 MK_UNUSED auto ctx = getCTX();
2246 enum MkErrorE errVal = MqStorageClose(ctx);
2247 MkErrorC_Check(ctx, errVal);
2248 }
2249
2251 inline void MqContextC::StorageDecrRef (MQ_LTR transLId) {
2252 MK_UNUSED auto ctx = getCTX();
2253 enum MkErrorE errVal = MqStorageDecrRef(ctx, transLId);
2254 MkErrorC_Check(ctx, errVal);
2255 }
2256
2258 inline void MqContextC::StorageIncrRef (MQ_LTR transLId) {
2259 MK_UNUSED auto ctx = getCTX();
2260 enum MkErrorE errVal = MqStorageIncrRef(ctx, transLId);
2261 MkErrorC_Check(ctx, errVal);
2262 }
2263
2265 inline void MqContextC::StorageLog (MK_STRN callfunc) {
2266 MK_UNUSED auto ctx = getCTX();
2267 if (callfunc == NULL) {callfunc = __builtin_FUNCTION();}
2268 enum MkErrorE errVal = MqStorageLog(ctx, callfunc);
2269 MkErrorC_Check(ctx, errVal);
2270 }
2271
2273 inline void MqContextC::StorageOpen (MK_STRN storageFile) {
2274 MK_UNUSED auto ctx = getCTX();
2275 enum MkErrorE errVal = MqStorageOpen(ctx, storageFile);
2276 MkErrorC_Check(ctx, errVal);
2277 }
2278
2280 inline void MqContextC::StorageOpen (const std::string& storageFile) {
2281 MK_UNUSED auto ctx = getCTX();
2282 const MK_STRN storageFile_hdl = storageFile.c_str();
2283 enum MkErrorE errVal = MqStorageOpen(ctx, storageFile_hdl);
2284 MkErrorC_Check(ctx, errVal);
2285 }
2286
2287 // doc-key: MqContextC,MqContextC-StorageApi-Storage,omo
2288
2291 MK_UNUSED auto ctx = getCTX();
2292 MQ_LTR cnt_out;
2293 enum MkErrorE errVal = MqStorageCount(ctx, &cnt_out);
2294 MkErrorC_Check(ctx, errVal);
2295 return cnt_out;
2296 }
2297
2300 MK_UNUSED auto ctx = getCTX();
2301 MK_I32 cnt_out;
2302 enum MkErrorE errVal = MqStorageErrCnt(ctx, transLId, &cnt_out);
2303 MkErrorC_Check(ctx, errVal);
2304 return cnt_out;
2305 }
2306
2309 MK_UNUSED auto ctx = getCTX();
2310 MQ_LTR ltid_out;
2311 enum MkErrorE errVal = MqStorageExport(ctx, &ltid_out);
2312 MkErrorC_Check(ctx, errVal);
2313 return ltid_out;
2314 }
2315
2317 inline std::tuple<MqContextC*,MQ_LTR> MqContextC::StorageResolve () {
2318 MK_UNUSED auto ctx = getCTX();
2319 MQ_CTX otherCtxP_out;
2320 MQ_LTR otherLIdP_out;
2321 enum MkErrorE errVal = MqStorageResolve(ctx, &otherCtxP_out, &otherLIdP_out);
2322 MkErrorC_Check(ctx, errVal);
2323 std::tuple<MqContextC*,MQ_LTR> __retVal__L = {MqContextC::MqContextC_ObjNew(MK_RT_CALL otherCtxP_out),otherLIdP_out};
2324 return __retVal__L;
2325 }
2326
2328 // MqContextC_StorageApi_Storage_CC_API
2329
2333
2334 // doc-key: MqContextC,MqContextC-TOR,sCc
2335
2339 MQ_CTX tmpl_hdl = MqContextC::getCTX__null_allow(tmpl);
2340 MQ_CTX __retVal__L = MqContextCreate(NULL, tmpl_hdl);
2341 if (__retVal__L == NULL) {
2342 throw MkInitError("MqContextC::CTOR");
2343 }
2344 return (MK_OBJ)__retVal__L;
2345 }
2346
2350 MQ_CTX tmpl_hdl = MqContextC::getCTX__null_allow(tmpl);
2351 MQ_CTX __retVal__L = MqContextCreate(NULL, tmpl_hdl);
2352 if (__retVal__L == NULL) {
2353 throw MkInitError("MqContextC::Create");
2354 }
2355 return MqContextC::MqContextC_ObjCreate(MK_RT_CALL __retVal__L);
2356 }
2357
2359 // MqContextC_TOR_CC_API
2360
2361 // END-MqContextC - created by 'cc_MqC.tcl -i NHI1_HOME/theLink/c/gen/c_mqmsgque.meta' - DO NOT change
2362
2367 MQ_CTX tmpl_hdl = MqContextC::getCTX__null_allow(tmpl);
2368 MQ_CTX __retVal__L = MqContextCreate(typ, tmpl_hdl);
2369 if (__retVal__L == NULL) {
2370 throw MkInitError("MqContextC::CTOR");
2371 }
2372 return (MK_OBJ)__retVal__L;
2373 }
2374
2375} // END - namespace "ccmqmsgque"
tag: nhi1-release-250425
implements the ccmqmsgque API object: ConfigSetBgError
PUBLIC data structure for the ccmqmsgque-specific-data → C-API: libmqmsgque::MqContextS
MqDumpC - the class known as dmp or dump is used to export a ccmqmsgque data package as binary … ...
Definition MqDumpC_cc.hh:24
implements the ccmqmsgque API object: ConfigSetEvent
data used to define a factory → C-API: libmqmsgque::MqFactoryS
implements the ccmqmsgque API object: ConfigSetServerCleanup
implements the ccmqmsgque API object: ConfigSetServerSetup
Callback for a Service.
static MkBufferC * MkBufferC_ObjNew(MK_RT_ARGS MK_BUF hdl)
MK_BUF getBUF() const
MK_BUFN getBUFN() const
MK_BUF getBUF__null_allow() const
MK_BFLN getBFLN() const
static MkBufferListC * MkBufferListC_ObjNew(MK_RT_ARGS MK_BFL hdl)
MK_BFL getBFL__null_allow() const
static MkErrorC * MkErrorC_ObjNew(MK_RT_ARGS MK_ERR hdl)
#define MK_ERROR_PANIC
static MkBinaryR MkBinaryCreate(MK_SIZE size, MK_BINN data)
#define MK_DECL
#define MK_UNUSED
static MkStringR MkStringCreate(MK_NUM len, MK_STRN str)
double MK_DBL
unsigned char MK_BOL
signed char MK_I8
signed long long MK_I64
MK_STRB const * MK_FST
int32_t MK_HDL
time_t MK_TIME_T
int32_t MK_NUM
signed short int MK_I16
signed int MK_I32
const MK_STRB * MK_STRN
void ErrorCheck(enum MkErrorE err, MK_STRN const caller=__builtin_FUNCTION(), MK_I32 const line=__builtin_LINE()) const
MK_OBJN getOBJN__null_allow() const
MK_OBJN getOBJN() const
MK_PTR MkSysRealloc(MK_OBJN fmtobj, MK_PTR const buf, size_t const size)
static MK_I32 MkRuntimeDebugGet(void)
#define MkRtSetup_XN(x)
#define MK_RT_CALL
#define MkRtSetup_NULL
MQ_CTX getCTX() const
return the LibMsgqueObject from current MqContextC instance
MQ_CTXN getCTXN__null_allow() const
(const) return the LibMsgqueObject from current MqContextC instance
MQ_CTX getCTX__null_allow() const
return the LibMsgqueObject from current MqContextC instance
MQ_CTXN getCTXN() const
(const) return the LibMsgqueObject from current MqContextC instance
static MqContextC * MqContextC_ObjNew(MK_RT_ARGS MQ_CTX hdl)
return MqContextC from LibMsgqueObject
static MqContextC * MqContextC_ObjCreate(MK_RT_ARGS MQ_CTX hdl)
static MK_ERR MqContextErrorFORMAT(MQ_CTXN const fmtobj)
helper used to access MkErrorDEFAULT from MqContextC
void ClassIdentSet(MK_STRN ident)
C++: ctx.ClassIdentSet(MK_STRN ident) → C-API link the MqContextC to a new MqFactoryC identifie...
void ClassFactorySet(MqFactoryC *item)
C++: ctx.ClassFactorySet(MqFactoryC* item) → C-API link the MqContextC to a new MqFactoryC
MK_STRN ClassOriginalIdentGet() const
C++: MK_STRN ctx.ClassOriginalIdentGet() → C-API get the libmqmsgque::MqFactoryS::originalIdent...
MK_STRN ClassIdentGet() const
C++: MK_STRN ctx.ClassIdentGet() → C-API get the application-identification …
MqFactoryC * ClassFactoryGet() const
C++: MqFactoryC* ctx.ClassFactoryGet() → C-API get the MqFactoryC used by the MqContextC
#define MqClassFactorySet(...)
MK_STRN MqClassIdentGet(MQ_CTXN const ctx)
get the application-identification …
#define MqClassIdentSet(...)
MQ_FCT const MqClassFactoryGet(MQ_CTXN const ctx)
get the MqFactoryC used by the MqContextC
MK_STRN MqClassOriginalIdentGet(MQ_CTXN const ctx)
get the libmqmsgque::MqFactoryS::originalIdent from the MqContextC
static MqContextC * HandleResolve(MK_HDL netHdl)
C++: [static] MqContextC* MqContextC::HandleResolve(MK_HDL netHdl) → C-API Handle-Resolve-Slot -...
MqContextC * Prev()
C++: MqContextC* ctx.Prev() → C-API get previous instance from linked-list of MqContextS type
static MqContextC * Instances()
C++: [static] MqContextC* MqContextC::Instances() → C-API get head-instance from linked-list of ...
MqContextC * Next()
C++: MqContextC* ctx.Next() → C-API get next instance from linked-list of MqContextS type
static MqContextC * GetNull()
C++: [static] MqContextC* MqContextC::GetNull() → C-API Null-Slot - return a MqContextC typed NU...
#define MqContextHandleResolve(...)
static MQ_CTX MqContextGetNull(void)
Null-Slot - return a MqContextC typed NULL instance …
#define MqContextInstances()
static MQ_CTX MqContextNext(MQ_CTX const ctx)
get next instance from linked-list of MqContextS type
static MQ_CTX MqContextPrev(MQ_CTX const ctx)
get previous instance from linked-list of MqContextS type
MqStatusIsEF ConfigGetStatusIs()
C++: MqStatusIsEF ctx.ConfigGetStatusIs() → C-API return the libmqmsgque::MqContextS::statusIs ...
MqStartE ConfigGetStartAs()
C++: MqStartE ctx.ConfigGetStartAs() → C-API return the libmqmsgque::MqConfigS::startAs value
MK_STRN ConfigGetStorage() const
C++: MK_STRN ctx.ConfigGetStorage() → C-API get the storage of the context object
MK_I32 ConfigGetPkgsize() const
C++: MK_I32 ctx.ConfigGetPkgsize() → C-API get the maximun size of a BDY package
MQ_SOCK_HDL ConfigGetIoPipe()
C++: MQ_SOCK_HDL ctx.ConfigGetIoPipe() → C-API return the libmqmsgque::MqIoPipeConfigS
MK_TIME_T ConfigGetTimeout() const
C++: MK_TIME_T ctx.ConfigGetTimeout() → C-API get the timeout value of the context object
MkBufferListC * ConfigGetIoTcpL()
C++: MkBufferListC* ctx.ConfigGetIoTcpL() → C-API get the configuration-data of the tcp-client-...
void ConfigSetConfigFile(MK_STRN filename)
C++: ctx.ConfigSetConfigFile(MK_STRN filename) → C-API set the config-file and parse for well-k...
MK_I32 ConfigGetBuffersize() const
C++: MK_I32 ctx.ConfigGetBuffersize() → C-API get the minimum of the read/send buffersize of th...
MK_BOOL ConfigGetIsParent()
C++: MK_BOOL ctx.ConfigGetIsParent() → C-API does the context object is a parent ?...
MK_STRN ConfigGetPostfix() const
C++: MK_STRN ctx.ConfigGetPostfix() → C-API get the libmqmsgque::MqConfigS::dispPostfix
MK_BOOL ConfigGetIsString()
C++: MK_BOOL ctx.ConfigGetIsString() → C-API does the context object is using the string-mode ?
MK_STRN ConfigGetName() const
C++: MK_STRN ctx.ConfigGetName() → C-API get the name of the context object
MqIdentE ConfigGetIdentFrom()
C++: MqIdentE ctx.ConfigGetIdentFrom() → C-API get the libmqmsgque::MqConfigS::identFrom
std::tuple< MK_STRN, MK_STRN, MK_STRN, MK_STRN > ConfigGetIoTcp()
C++: {host:MK_STRN port:MK_STRN myhost:MK_STRN myport:MK_STRN} ctx.ConfigGetIoTcp() → C-API get...
MK_BOOL ConfigGetIsServer()
C++: MK_BOOL ctx.ConfigGetIsServer() → C-API does the context object is a server ?
MK_STRN ConfigGetPrefix() const
C++: MK_STRN ctx.ConfigGetPrefix() → C-API get the libmqmsgque::MqConfigS::dispPrefix
MK_STRN ConfigGetIoUds() const
C++: MK_STRN ctx.ConfigGetIoUds() → C-API return the libmqmsgque::MqIoUdsConfigS
static bool MqConfigGetIsString(MQ_CTX const ctx)
does the context object is using the string-mode ?
static bool MqConfigGetIsParent(MQ_CTX const ctx)
does the context object is a parent ? An objext is a parent id the libmqmsgque::MqConfigS::parent att...
static bool MqConfigGetIsServer(MQ_CTX const ctx)
does the context object is a server ?
static MK_STRN MqConfigGetPostfix(MQ_CTXN const ctx)
get the libmqmsgque::MqConfigS::dispPostfix
static MK_STRN MqConfigGetStorage(MQ_CTXN const ctx)
get the storage of the context object
static MK_TIME_T MqConfigGetTimeout(MQ_CTXN const ctx)
get the timeout value of the context object
#define MqConfigSetConfigFile(...)
static MQ_SOCK_HDL MqConfigGetIoPipe(MQ_CTX const ctx)
return the libmqmsgque::MqIoPipeConfigS
enum MkErrorE MqConfigGetIoTcp(MQ_CTX const ctx, MK_STRN *host_out, MK_STRN *port_out, MK_STRN *myhost_out, MK_STRN *myport_out)
get the configuration-data of the tcp-client-server-link …
static enum MqStartE MqConfigGetStartAs(MQ_CTX const ctx)
return the libmqmsgque::MqConfigS::startAs value
static MK_STRN MqConfigGetName(MQ_CTXN const ctx)
get the name of the context object
static enum MqIdentE MqConfigGetIdentFrom(MQ_CTX const ctx)
get the libmqmsgque::MqConfigS::identFrom
static MK_STRN MqConfigGetIoUds(MQ_CTXN const ctx)
return the libmqmsgque::MqIoUdsConfigS
static MK_I32 MqConfigGetPkgsize(MQ_CTXN const ctx)
get the maximun size of a BDY package
static MK_I32 MqConfigGetBuffersize(MQ_CTXN const ctx)
get the minimum of the read/send buffersize of the socket
static enum MqStatusIsEF MqConfigGetStatusIs(MQ_CTX const ctx)
return the libmqmsgque::MqContextS::statusIs value
#define MqConfigGetIoTcpL(...)
static MK_STRN MqConfigGetPrefix(MQ_CTXN const ctx)
get the libmqmsgque::MqConfigS::dispPrefix
void ConfigSetServerCleanup(MqServerCleanupCCB callback=NULL)
C++: ctx.ConfigSetServerCleanup(MqServerCleanupICB MqServerCleanupCCB MqServerCleanupIF* callback = ...
void ConfigSetServerSetup(MqServerSetupCCB callback=NULL)
C++: ctx.ConfigSetServerSetup(MqServerSetupICB MqServerSetupCCB MqServerSetupIF* callback = NULL) →...
void ConfigSetBgError(MqBgErrorCCB callback=NULL)
C++: ctx.ConfigSetBgError(MqBgErrorICB MqBgErrorCCB MqBgErrorIF* callback = NULL) → C-API set t...
void ConfigSetEvent(MqEventCCB callback=NULL)
C++: ctx.ConfigSetEvent(MqEventICB MqEventCCB MqEventIF* callback = NULL) → C-API set the libmq...
#define MqConfigSetBgError(...)
#define MqConfigSetServerSetup(...)
#define MqConfigSetServerCleanup(...)
#define MqConfigSetEvent(...)
void ConfigReset()
C++: ctx.ConfigReset() → C-API clean the libmqmsgque::MqContextS::config data
#define MqConfigReset(...)
void ConfigSetBuffersize(MK_I32 data)
C++: ctx.ConfigSetBuffersize(MK_I32 data) → C-API set the libmqmsgque::MqIoConfigS::buffersize ...
void ConfigSetPrefix(MK_STRN data)
C++: ctx.ConfigSetPrefix(MK_STRN data) → C-API set the server-part (1) of the application-ide...
MK_BOOL ConfigCheckStartAs(MqStartE data)
C++: MK_BOOL ctx.ConfigCheckStartAs(MqStartE data) → C-API check if libmqmsgque::MqConfigS::sta...
void ConfigSetPostfix(MK_STRN data)
C++: ctx.ConfigSetPostfix(MK_STRN data) → C-API set the client-part (2) of the application-id...
void ConfigSetIgnoreExit(MK_BOOL data)
C++: ctx.ConfigSetIgnoreExit(MK_BOOL data) → C-API set the libmqmsgque::MqSetupS::ignoreExit va...
void ConfigSetIdentFrom(MqIdentE data)
C++: ctx.ConfigSetIdentFrom(MqIdentE data) → C-API set the libmqmsgque::MqConfigS::identFrom va...
void ConfigSetStartAsString(MK_STRN data)
C++: ctx.ConfigSetStartAsString(MK_STRN data) → C-API set the libmqmsgque::MqConfigS::startAs v...
void ConfigSetAllDebug(MK_I32 data)
C++: ctx.ConfigSetAllDebug(MK_I32 data) → C-API set the MkRuntimeS::debug value
void ConfigSetStartAs(MqStartE data)
C++: ctx.ConfigSetStartAs(MqStartE data) → C-API set the libmqmsgque::MqConfigS::startAs value
void ConfigSetDaemon(MK_STRN pidfile)
C++: ctx.ConfigSetDaemon(MK_STRN pidfile) → C-API start the server-context as daemon …
void ConfigSetPkgsize(MK_I32 data)
C++: ctx.ConfigSetPkgsize(MK_I32 data) → C-API set the libmqmsgque::MqIoConfigS::pkgsize value
void ConfigSetStorage(MK_STRN data)
C++: ctx.ConfigSetStorage(MK_STRN data) → C-API set the Storage value and cleanup old value
void ConfigSetIsString(MK_BOOL data)
C++: ctx.ConfigSetIsString(MK_BOOL data) → C-API set the libmqmsgque::MqConfigS::native value '...
void ConfigSetName(MK_STRN data)
C++: ctx.ConfigSetName(MK_STRN data) → C-API set the libmqmsgque::MqConfigS::dispName value and...
void ConfigSetIoTcp(MK_STRN host=NULL, MK_STRN port=NULL, MK_STRN myhost=NULL, MK_STRN myport=NULL)
C++: ctx.ConfigSetIoTcp(MK_STRN host = NULL, MK_STRN port = NULL, MK_STRN myhost = NULL,...
void ConfigSetIoUds(MK_STRN file)
C++: ctx.ConfigSetIoUds(MK_STRN file) → C-API configure a context to use a uds-client-server-...
void ConfigSetTimeout(MK_TIME_T data)
C++: ctx.ConfigSetTimeout(MK_TIME_T data) → C-API set the libmqmsgque::MqIoConfigS::timeout val...
void ConfigSetIoPipe(MQ_SOCK_HDL fh)
C++: ctx.ConfigSetIoPipe(MQ_SOCK_HDL fh) → C-API set the pipe configuration data …
void ConfigSetIsServer(MK_BOOL data)
C++: ctx.ConfigSetIsServer(MK_BOOL data) → C-API set the libmqmsgque::MqSetupS::isServer value
#define MqConfigSetDaemon(...)
void MqConfigSetIsServer(MQ_CTX const ctx, bool data)
set the libmqmsgque::MqSetupS::isServer value
enum MkErrorE MqConfigSetStartAsString(MQ_CTX const ctx, MK_STRN data)
set the libmqmsgque::MqConfigS::startAs value using string default, thread, fork or spawn
bool MqConfigCheckStartAs(MQ_CTX const ctx, enum MqStartE data)
check if libmqmsgque::MqConfigS::startAs can be set to data
#define MqConfigSetPrefix(...)
void MqConfigSetBuffersize(MQ_CTX const ctx, MK_I32 data)
set the libmqmsgque::MqIoConfigS::buffersize value
void MqConfigSetIgnoreExit(MQ_CTX const ctx, bool data)
set the libmqmsgque::MqSetupS::ignoreExit value
#define MqConfigSetIoPipe(...)
#define MqConfigSetIoTcp(...)
void MqConfigSetIsString(MQ_CTX const ctx, bool data)
set the libmqmsgque::MqConfigS::native value 'S'string or 'L'owEndian or 'B'igEndian
#define MqConfigSetPostfix(...)
#define MqConfigSetName(...)
void MqConfigSetTimeout(MQ_CTX const ctx, MK_TIME_T data)
set the libmqmsgque::MqIoConfigS::timeout value
void MqConfigSetIdentFrom(MQ_CTX const ctx, enum MqIdentE data)
set the libmqmsgque::MqConfigS::identFrom value
#define MqConfigSetIoUds(...)
enum MkErrorE MqConfigSetStartAs(MQ_CTX const ctx, enum MqStartE data)
set the libmqmsgque::MqConfigS::startAs value
void MqConfigSetPkgsize(MQ_CTX const ctx, MK_I32 data)
set the libmqmsgque::MqIoConfigS::pkgsize value
#define MqConfigSetAllDebug(...)
#define MqConfigSetIoTcpL(...)
#define MqConfigSetStorage(...)
void EnvProtect()
C++: ctx.EnvProtect() → C-API protect the service-environment
void EnvRestore()
C++: ctx.EnvRestore() → C-API restore the service-environment
#define MqEnvProtect(...)
void MqEnvRestore(MQ_CTX ctx)
restore the service-environment
MkErrorC * ErrorFORMAT() const
C++: MkErrorC* fmtobj.ErrorFORMAT() → C-API helper used to access MkErrorDEFAULT from MqContext...
MkErrorE ErrorCopy(const MqContextC *sourceCtx) const
C++: MkErrorE targetCtx.ErrorCopy(const MqContextC* sourceCtx) → C-API copy a MkErrorS from the...
MkErrorE ErrorMove(const MqContextC *sourceCtx) const
C++: MkErrorE targetCtx.ErrorMove(const MqContextC* sourceCtx) → C-API move a MkErrorS from the...
#define MqContextErrorMove(...)
#define MqContextErrorCopy(...)
void SendVL2(MK_STRN cstr, va_list var_list)
C++: ctx.SendVL2(MK_STRN cstr, va_list var_list) → C-API A version of MqSend with va_list suppo...
#define MqSendVL2(...)
MK_STRN LogParentOrChild() const
C++: MK_STRN ctx.LogParentOrChild() → C-API is ctx a PARENT or a CHILD ? …
void LogType(const MkObjectC *fmtobj=NULL, MK_DBG debug=0, MK_STRN callfunc=__builtin_FUNCTION(), MK_I32 lvl=0) const
C++: ctx.LogType(const MkObjectC* fmtobj = NULL, MK_DBG debug = 0, MK_STRN callfunc = __builtin_FUNC...
void LogShort(const MkObjectC *fmtobj=NULL, MK_DBG debug=0, MK_STRN callfunc=__builtin_FUNCTION(), MK_I32 lvl=0, MK_STRN label=NULL) const
C++: ctx.LogShort(const MkObjectC* fmtobj = NULL, MK_DBG debug = 0, MK_STRN callfunc = __builtin_FUN...
void LogLink(const MkObjectC *fmtobj=NULL, MK_DBG debug=0, MK_STRN callfunc=__builtin_FUNCTION(), MK_I32 lvl=0) const
C++: ctx.LogLink(const MkObjectC* fmtobj = NULL, MK_DBG debug = 0, MK_STRN callfunc = __builtin_FUNC...
void LogEnv(const MkObjectC *fmtobj=NULL, MK_DBG debug=0, MK_STRN callfunc=__builtin_FUNCTION(), MK_I32 lvl=0) const
C++: ctx.LogEnv(const MkObjectC* fmtobj = NULL, MK_DBG debug = 0, MK_STRN callfunc = __builtin_FUNCT...
void LogConfig(const MkObjectC *fmtobj=NULL, MK_DBG debug=0, MK_STRN callfunc=__builtin_FUNCTION(), MK_I32 lvl=0) const
C++: ctx.LogConfig(const MkObjectC* fmtobj = NULL, MK_DBG debug = 0, MK_STRN callfunc = __builtin_FU...
void LogSetup(const MkObjectC *fmtobj=NULL, MK_DBG debug=0, MK_STRN callfunc=__builtin_FUNCTION(), MK_I32 lvl=0) const
C++: ctx.LogSetup(const MkObjectC* fmtobj = NULL, MK_DBG debug = 0, MK_STRN callfunc = __builtin_FUN...
MK_STRN LogServerOrClient() const
C++: MK_STRN ctx.LogServerOrClient() → C-API is ctx a SERVER or a CLIENT ? …
#define MqContextLogShort(...)
#define MqContextLogEnv(...)
#define MqContextLogConfig(...)
#define MqContextLogSetup(...)
#define MqContextLogLink(...)
#define MqContextLogType(...)
static MK_STRN MqLogServerOrClient(MQ_CTXN const ctx)
is ctx a SERVER or a CLIENT ? …
static MK_STRN MqLogParentOrChild(MQ_CTXN ctx)
is ctx a PARENT or a CHILD ? …
void ProcessEvent(MqWaitOnEventE wait=MQ_WAIT_NO, MK_TIME_T timeout=MK_TIMEOUT_DEFAULT)
C++: ctx.ProcessEvent(MqWaitOnEventE wait = MQ_WAIT_NO, MK_TIME_T timeout = MK_TIMEOUT_DEFAULT) → C...
MkBufferC * GetBuffer()
C++: MkBufferC* ctx.GetBuffer() → C-API get the libmqmsgque::MqContextS::ctxbuf object
MqContextC * GetRoot()
C++: MqContextC* ctx.GetRoot() → C-API get the Root (toplevel initial context)
MK_I32 Exit(MK_STRN callfunc=__builtin_FUNCTION(), MK_STRN callfile=__builtin_FILE(), MK_I32 callline=__builtin_LINE())
C++: MK_I32 ctx.Exit(MK_STRN callfunc = __builtin_FUNCTION(), MK_STRN callfile = __builtin_FILE(),...
#define MqProcessEvent(...)
#define MqExit(...)
#define MqContextGetBuffer(...)
static MQ_CTX MqGetRoot(MQ_CTX ctx)
get the Root (toplevel initial context)
void ProxyForward(MqContextC *targetCtx, MqDumpC *dump=NULL, MK_TIME_T timeout=MK_TIMEOUT_DEFAULT)
C++: sourceCtx.ProxyForward(MqContextC* targetCtx, MqDumpC* dump = NULL, MK_TIME_T timeout = MK_TIME...
void ProxyItem(MqContextC *targetCtx)
C++: sourceCtx.ProxyItem(MqContextC* targetCtx) → C-API Copy a single-data-item from the source...
#define MqProxyItem(...)
#define MqProxyForward(...)
MK_BNP ReadBinaryR()
C++: MK_BNP ctx.ReadBinaryR() → C-API read a MkBinaryR from the read-data-package …
std::string ReadStringR()
C++: std::string ctx.ReadStringR() → C-API read a MkStringR from the read-data-package …
MK_HDL ReadHDL()
C++: MK_HDL ctx.ReadHDL() → C-API read the handle from the read-data-package
MK_BNP ReadBIN()
C++: doc_mq_cc_ReadBIN → C-API generic function to read an libmkkernel::MK_BIN object from the r...
MK_BOL ReadBOL()
C++: doc_mq_cc_ReadBOL → C-API read a PRIMITIVE TYPE from the read-data-package …
MkBufferC * ReadBUF()
C++: MkBufferC* ctx.ReadBUF() → C-API get a temporary MkBufferC from the read-data-package …
MkBufferListC * ReadBFL()
C++: MkBufferListC* ctx.ReadBFL() → C-API get a temporary MkBufferListC from next list-item in ...
MkBufferListC * ReadALL(MkBufferListC *val_inout=NULL)
C++: MkBufferListC* ctx.ReadALL(MkBufferListC* val_inout = NULL) → C-API get a temporary MkBuff...
MK_I32 ReadI32()
C++: doc_mq_cc_ReadI32 → C-API read a PRIMITIVE TYPE from the read-data-package …
MK_I64 ReadI64()
C++: doc_mq_cc_ReadI64 → C-API read a PRIMITIVE TYPE from the read-data-package …
MK_LONG ReadLONG()
C++: MK_LONG ctx.ReadLONG() → C-API read the long native object from the read-data-package
MK_I16 ReadI16()
C++: doc_mq_cc_ReadI16 → C-API read a PRIMITIVE TYPE from the read-data-package …
MK_FLT ReadFLT()
C++: doc_mq_cc_ReadFLT → C-API read a PRIMITIVE TYPE from the read-data-package …
MK_DBL ReadDBL()
C++: doc_mq_cc_ReadDBL → C-API read a PRIMITIVE TYPE from the read-data-package …
MK_STRN ReadSTR()
C++: doc_mq_cc_ReadSTR → C-API read a PRIMITIVE TYPE from the read-data-package …
MK_I8 ReadI8()
C++: doc_mq_cc_ReadI8 → C-API read a PRIMITIVE TYPE from the read-data-package …
#define MqReadI64(...)
#define MqReadSTR(...)
#define MqReadI16(...)
#define MqReadDBL(...)
#define MqReadBFL(...)
#define MqReadBUF(...)
#define MqReadHDL(...)
#define MqReadLONG(...)
#define MqReadI8(...)
#define MqReadBIN(...)
#define MqReadFLT(...)
#define MqReadBinaryR(...)
#define MqReadALL(...)
#define MqReadStringR(...)
#define MqReadBOL(...)
#define MqReadI32(...)
void ReadT_END()
C++: ctx.ReadT_END() → C-API finish to extract a longterm-transaction-item from the read-data-p...
void ReadL_END()
C++: ctx.ReadL_END() → C-API finish to extract a list-items from the read-data-package....
void ReadT_START()
C++: ctx.ReadT_START() → C-API start to extract a longterm-transaction-item from the read-data-...
void ReadL_START(MkBufferC *buf=NULL)
C++: ctx.ReadL_START(MkBufferC* buf = NULL) → C-API start to extract a list-items from the read...
#define MqReadT_START(...)
#define MqReadL_START(...)
#define MqReadT_END(...)
#define MqReadL_END(...)
MK_BOOL ReadItemExists()
C++: MK_BOOL ctx.ReadItemExists() → C-API check if an item exists in the read-data-package …
void ReadUndo()
C++: ctx.ReadUndo() → C-API undo the last MqContextC READ API function call …
MkTypeE ReadGetNextType()
C++: MkTypeE ctx.ReadGetNextType() → C-API get the type (MkTypeE) of the next Item in the read-...
MK_NUM ReadGetNumItems()
C++: MK_NUM ctx.ReadGetNumItems() → C-API get the number of items left in the read-data-package...
MK_NUM MqReadGetNumItems(MQ_CTX const ctx)
get the number of items left in the read-data-package …
#define MqReadDbg(...)
bool MqReadItemExists(MQ_CTX const ctx)
check if an item exists in the read-data-package …
#define MqReadUndo(...)
enum MkTypeE MqReadGetNextType(MQ_CTX const ctx)
get the type (MkTypeE) of the next Item in the read-data-buffer or "0" if not available
MK_STRN RouteGetPath()
C++: MK_STRN ctx.RouteGetPath() → C-API return the absolut route-connection-string up to the cu...
MqContextC_A RouteResolve(MK_STRN ident, MK_NUM retnum=-1)
C++: MqContextC_A ctx.RouteResolve(MK_STRN ident, MK_NUM retnum = -1) → C-API return a list of ...
MkBufferListC * RouteGetTree()
C++: MkBufferListC* ctx.RouteGetTree() → C-API create an overview about all available routing-t...
void RouteCreate(MK_STRN route, MK_STRN service, MK_BOOL overwrite=false)
C++: ctx.RouteCreate(MK_STRN route, MK_STRN service, MK_BOOL overwrite = false) → C-API create/...
void RouteDelete(MK_STRN route, MK_STRN service, MK_BOOL overwrite=false)
C++: ctx.RouteDelete(MK_STRN route, MK_STRN service, MK_BOOL overwrite = false) → C-API delete ...
void RouteTraverse(MK_STRN service, MkBufferListC *args=NULL)
C++: ctx.RouteTraverse(MK_STRN service, MkBufferListC* args = NULL) → C-API traverse a tree dow...
#define MqRouteDelete(...)
#define MqRouteTraverse(...)
#define MqRouteGetTree(...)
#define MqRouteCreate(...)
#define MqRouteGetPath(...)
#define MqRouteResolve(...)
void SendBOL(MK_BOL val)
C++: doc_mq_cc_SendBOL → C-API MqContextC - append a native PRIMITIVE TYPE value to the send-d...
void SendVL(MK_FST printfmt, va_list var_list)
C++: ctx.SendVL(MK_FST printfmt, va_list var_list) → C-API append a vararg string as va_list to...
void SendStringR(const std::string &val)
C++: ctx.SendStringR(const std::string& val) → C-API MqContextC - append a native PRIMITIVE T...
void SendBFL(const MkBufferListC *val)
C++: ctx.SendBFL(const MkBufferListC* val) → C-API append a MkBufferListC object to the send-da...
void SendBinaryR(MK_BNP val)
C++: ctx.SendBinaryR(MK_BNP val) → C-API append a MkBinaryR object to the send-data-package....
void SendBUS_FLAT(const MkBufferStreamC *val)
C++: ctx.SendBUS_FLAT(const MkBufferStreamC* val) → C-API append a MkBufferStreamC object to th...
void SendLONG(MK_LONG val)
C++: ctx.SendLONG(MK_LONG val) → C-API send the long native object to the send-data-package
void SendDBL(MK_DBL val)
C++: doc_mq_cc_SendDBL → C-API MqContextC - append a native PRIMITIVE TYPE value to the send-d...
void SendI64(MK_I64 val)
C++: doc_mq_cc_SendI64 → C-API MqContextC - append a native PRIMITIVE TYPE value to the send-d...
void SendBIN(MK_BNP val)
C++: doc_mq_cc_SendBIN → C-API append a libmkkernel::MK_BIN object to the send-data-package....
void SendHDL(MK_HDL val)
C++: ctx.SendHDL(MK_HDL val) → C-API send the handle to the send-data-package
void SendL_FLAT(const MkBufferListC *val)
C++: ctx.SendL_FLAT(const MkBufferListC* val) → C-API append a MkBufferListC object as flat lis...
void SendI16(MK_I16 val)
C++: doc_mq_cc_SendI16 → C-API MqContextC - append a native PRIMITIVE TYPE value to the send-d...
void SendLTR(MQ_LTR transLId)
SendLTR
void SendFLT(MK_FLT val)
C++: doc_mq_cc_SendFLT → C-API MqContextC - append a native PRIMITIVE TYPE value to the send-d...
void SendV(MK_FST printfmt,...)
C++: ctx.SendV(MK_FST printfmt, ... ) → C-API append a vararg string to the send-data-package o...
void SendBUF(const MkBufferC *val)
C++: ctx.SendBUF(const MkBufferC* val) → C-API append a MkBufferC object to the send-data-packa...
void SendI8(MK_I8 val)
C++: doc_mq_cc_SendI8 → C-API MqContextC - append a native PRIMITIVE TYPE value to the send-data...
void SendSTR(MK_STRN val)
C++: doc_mq_cc_SendSTR → C-API MqContextC - append a native PRIMITIVE TYPE value to the send-d...
void SendI32(MK_I32 val)
C++: doc_mq_cc_SendI32 → C-API MqContextC - append a native PRIMITIVE TYPE value to the send-d...
#define MqSendBIN(...)
#define MqSendLONG(...)
#define MqSendI8(...)
#define MqSendBOL(...)
#define MqSendI64(...)
#define MqSendI32(...)
#define MqSendBFL(...)
#define MqSendStringR(...)
#define MqSendI16(...)
#define MqSendL_FLAT(...)
#define MqSendSTR(...)
#define MqSendLTR(...)
#define MqSendHDL(...)
#define MqSendFLT(...)
#define MqSendDBL(...)
#define MqSendBUF(...)
#define MqSendBUS_FLAT(...)
#define MqSendBinaryR(...)
#define MqSendVL(...)
void SendEND_AND_SUB(MQ_TOK token, MqServiceCCB callback, MK_TIME_T timeout=MK_TIMEOUT_DEFAULT)
C++: ctx.SendEND_AND_SUB(MQ_TOK token, MqServiceICB MqServiceCCB MqServiceIF* callback,...
void SendEND_AND_CALLBACK(MQ_TOK token, MqServiceCCB callback, MK_TIME_T timeout=MK_TIMEOUT_DEFAULT)
C++: ctx.SendEND_AND_CALLBACK(MQ_TOK token, MqServiceICB MqServiceCCB MqServiceIF* callback,...
void SendSTART()
C++: ctx.SendSTART() → C-API initialize the send-data-package. …
void SendEND_AND_WAIT(MQ_TOK token, MK_TIME_T timeout=MK_TIMEOUT_DEFAULT)
C++: ctx.SendEND_AND_WAIT(MQ_TOK token, MK_TIME_T timeout = MK_TIMEOUT_DEFAULT) → C-API finish ...
void SendSYNC()
C++: ctx.SendSYNC() → C-API garantee that all pending asynchronous-service-calls are processed....
void SendEND_AND_TRANSACTION(MQ_TOK token, MQ_TOK callback, MK_TIME_T timeout=MK_TIMEOUT_DEFAULT)
C++: ctx.SendEND_AND_TRANSACTION(MQ_TOK token, MQ_TOK callback, MK_TIME_T timeout = MK_TIMEOUT_DEFAU...
void SendEND(MQ_TOK token, MK_TIME_T timeout=MK_TIMEOUT_DEFAULT)
C++: ctx.SendEND(MQ_TOK token, MK_TIME_T timeout = MK_TIMEOUT_DEFAULT) → C-API MqContextC - fin...
#define MqSendSTART(...)
#define MqSendEND_AND_TRANSACTION(...)
#define MqSendEND_AND_CALLBACK(...)
#define MqSendEND_AND_SUB(...)
#define MqSendEND_AND_WAIT(...)
#define MqSendEND(...)
#define MqSendSYNC(...)
void SendL_END()
C++: ctx.SendL_END() → C-API finish to append an embedded body-list-item to the send-data-packa...
void SendT_START()
C++: ctx.SendT_START() → C-API open a longterm-transaction-item …
void SendL_START()
C++: ctx.SendL_START() → C-API start to append an embedded body-list-item to the send-data-pack...
void SendT_END()
C++: ctx.SendT_END() → C-API closed a longterm-transaction-item …
#define MqSendL_START(...)
#define MqSendT_END(...)
#define MqSendL_END(...)
#define MqSendT_START(...)
void SendRETURN_SUB()
C++: ctx.SendRETURN_SUB() → C-API return Sub-Data-Blocks required by MqSendEND_AND_SUB …
void SendERROR()
C++: ctx.SendERROR() → C-API send the data from the MkErrorC to the link target ....
void SendRETURN()
C++: ctx.SendRETURN() → C-API MqContextC - finish the send-data-block on the server and optiona...
#define MqSendRETURN_SUB(...)
#define MqSendERROR(...)
#define MqSendRETURN(...)
MK_BOOL ServiceIsTransaction()
C++: MK_BOOL ctx.ServiceIsTransaction() → C-API check if the ongoing-service-call belongs to a ...
void ServiceProxyCtx(MQ_TOK token, MqContextC *target)
C++: ctx.ServiceProxyCtx(MQ_TOK token, MqContextC* target) → C-API same as MqServiceProxy but u...
MK_BOOL ServiceProxyCtxExists(MQ_TOK token, MqContextC *target)
C++: MK_BOOL ctx.ServiceProxyCtxExists(MQ_TOK token, MqContextC* target) → C-API check if servi...
void ServiceProxyRoundRobin(MQ_TOK token, MK_STRN ident)
C++: ctx.ServiceProxyRoundRobin(MQ_TOK token, MK_STRN ident) → C-API create a proxy-service usi...
void ServiceProxy(MQ_TOK token, MQ_SLAVE_ID id=MQ_SLAVE_OTHER)
C++: ctx.ServiceProxy(MQ_TOK token, MQ_SLAVE_ID id = MQ_SLAVE_OTHER) → C-API create a service t...
void ServiceStorage(MQ_TOK token)
C++: ctx.ServiceStorage(MQ_TOK token) → C-API setup a service listen on a MqContextC_ServiceApi...
MK_BOOL ServiceTokenExists(MQ_TOK token)
C++: MK_BOOL ctx.ServiceTokenExists(MQ_TOK token) → C-API check if the MqContextC_ServiceApi_Id...
void ServiceDelete(MQ_TOK token)
C++: ctx.ServiceDelete(MQ_TOK token) → C-API delete a service. …
MK_BOOL ServiceTokenCheck(MQ_TOK token)
C++: MK_BOOL ctx.ServiceTokenCheck(MQ_TOK token) → C-API in an ongoing-service-call check if th...
MQ_TOK ServiceTokenGet()
C++: MQ_TOK ctx.ServiceTokenGet() → C-API in an ongoing-service-call get the current MqContextC...
void ServiceCreate(MQ_TOK token, MqServiceCCB callback)
C++: ctx.ServiceCreate(MQ_TOK token, MqServiceICB MqServiceCCB MqServiceIF* cal...
#define MqServiceStorage(...)
#define MqServiceProxyCtx(...)
static bool MqServiceIsTransaction(MQ_CTX const ctx)
check if the ongoing-service-call belongs to a transaction …
#define MqServiceCreate(...)
MK_STRN MQ_TOK
MqContextC - a char[4+1] or hex[8+1] string used to unique identify a service …
bool MqServiceProxyCtxExists(MQ_CTX const ctx, MQ_TOK const token, MQ_CTX const target)
check if service who belongs to token is a proxy-service
#define MqServiceProxy(...)
MQ_TOK MqServiceTokenGet(MQ_CTX const ctx)
in an ongoing-service-call get the current MqContextC_ServiceApi_Identifer …
bool MqServiceTokenCheck(MQ_CTX const ctx, MQ_TOK const token)
in an ongoing-service-call check if the current MqContextC_ServiceApi_Identifer is token …
#define MqServiceProxyRoundRobin(...)
bool MqServiceTokenExists(MQ_CTX const ctx, MQ_TOK const token)
check if the MqContextC_ServiceApi_Identifer token is defined as ctx service …
#define MqServiceDelete(...)
MK_BOOL SlaveCheck(MQ_SLAVE_ID id) const
C++: MK_BOOL ctx.SlaveCheck(MQ_SLAVE_ID id) → C-API check if slave-id is valid
MqContextC * SlaveGetProxy(MQ_SLAVE_ID id)
C++: MqContextC* ctx.SlaveGetProxy(MQ_SLAVE_ID id) → C-API on slave return the master and on ma...
void SlaveCreate(MQ_SLAVE_ID id, MqContextC *slave)
C++: ctx.SlaveCreate(MQ_SLAVE_ID id, MqContextC* slave) → C-API create a master/slave link betw...
MqContextC * SlaveGet(MQ_SLAVE_ID id)
C++: MqContextC* ctx.SlaveGet(MQ_SLAVE_ID id) → C-API get the slave-context from a master-conte...
void SlaveDelete(MQ_SLAVE_ID id)
C++: ctx.SlaveDelete(MQ_SLAVE_ID id) → C-API Delete a slave object from a master/slave link ide...
MqContextC * SlaveGetFilter()
C++: MqContextC* ctx.SlaveGetFilter() → C-API get the filter-ctx or the master-ctx …
MK_BOOL SlaveIs() const
C++: MK_BOOL ctx.SlaveIs() → C-API is the context a slave-context ? …
MqContextC * SlaveGetMaster()
C++: MqContextC* ctx.SlaveGetMaster() → C-API opposite function of MqSlaveGetFilter
void SlaveWorker(MQ_SLAVE_ID id, MK_STRN fct="WORKER", MkBufferListC *args=NULL)
C++: ctx.SlaveWorker(MQ_SLAVE_ID id, MK_STRN fct = "WORKER", MkBufferListC* args = NULL) → C-API ...
#define MqSlaveGet(...)
static bool MqSlaveCheck(MQ_CTXN const ctx, MQ_SLAVE_ID const id)
check if slave-id is valid
#define MqSlaveGetProxy(...)
#define MqSlaveCreate(...)
static MQ_CTX MqSlaveGetMaster(MQ_CTX const ctx)
opposite function of MqSlaveGetFilter
static bool MqSlaveIs(MQ_CTXN const ctx)
is the context a slave-context ? …
#define MqSlaveGetFilter(...)
#define MqSlaveDelete(...)
#define MqSlaveWorker(...)
MK_I32 StorageErrCnt(MQ_LTR transLId)
C++: MK_I32 ctx.StorageErrCnt(MQ_LTR transLId) → C-API increment and return the database row-er...
void StorageClose()
C++: ctx.StorageClose() → C-API close the storage. …
void StorageOpen(MK_STRN storageFile)
C++: ctx.StorageOpen(MK_STRN storageFile) → C-API switch to a file-based-transaction-database …
std::tuple< MqContextC *, MQ_LTR > StorageResolve()
C++: {otherCtxP:MqContextC* otherLIdP:MQ_LTR} ctx.StorageResolve() → C-API extract the context-...
MQ_LTR StorageDelete(MQ_LTR *transLIdP_inout=0)
C++: MQ_LTR ctx.StorageDelete(MQ_LTR *transLIdP_inout = 0) → C-API delete the storage-row ident...
MQ_LTR StorageExport()
C++: MQ_LTR ctx.StorageExport() → C-API export the read-data-package into the STORAGE …
void StorageDecrRef(MQ_LTR transLId)
C++: ctx.StorageDecrRef(MQ_LTR transLId) → C-API decrease the internal refCount lock of the dat...
MQ_LTR StorageCount()
C++: MQ_LTR ctx.StorageCount() → C-API count the number of storage-rows …
MQ_LTR StorageImport(MQ_LTR *transLIdP_inout=0)
C++: MQ_LTR ctx.StorageImport(MQ_LTR *transLIdP_inout = 0) → C-API import the storage-package i...
void StorageLog(MK_STRN callfunc=__builtin_FUNCTION())
C++: ctx.StorageLog(MK_STRN callfunc = __builtin_FUNCTION()) → C-API log the storage the status...
void StorageIncrRef(MQ_LTR transLId)
C++: ctx.StorageIncrRef(MQ_LTR transLId) → C-API increase the internal refCount lock of the dat...
#define MqStorageIncrRef(...)
#define MqStorageResolve(...)
#define MqStorageLog(...)
#define MqStorageExport(...)
#define MqStorageDecrRef(...)
#define MqStorageClose(...)
#define MqStorageOpen(...)
#define MqStorageImport(...)
#define MqStorageCount(...)
#define MqStorageDelete(...)
#define MqStorageErrCnt(...)
static MK_OBJ CTOR(MqContextC *tmpl=NULL)
C++: [constructor,static] MqContextC* MqContextC::Create(MqContextC* tmpl = NULL) → C-API create...
static MqContextC * Create(MqContextC *tmpl=NULL)
C++: [constructor,static] MqContextC* MqContextC::Create(MqContextC* tmpl = NULL) → C-API create...
#define MqContextCreate(...)
MQ_DMP getDMP__null_allow() const
return the LibMsgqueObject from current MqDumpC instance
Definition MqDumpC_cc.hh:89
MQ_DMP getDMP() const
return the LibMsgqueObject from current MqDumpC instance
Definition MqDumpC_cc.hh:82
MQ_FCT getFCT() const
return the LibMsgqueObject from current MqFactoryC instance
static MqFactoryC * MqFactoryC_ObjNew(MK_RT_ARGS MQ_FCT hdl)
return MqFactoryC from LibMsgqueObject
MqIdentE
identify the application using prefix (default) or factory …
MqWaitOnEventE
wait for an event? …
MqStatusIsEF
Information about how the context was created.
MqStartE
User preferences on HOWTO start a new entity.
MK_NUM MQ_SLAVE_ID
a slave identiver
int MQ_LTR
32bit longterm transaction token because PHP-32 does NOT support long long
std::pair< MK_SIZE, MK_BINN > MK_BNP
namespace for the CcMqMsgque "C++"-API
PUBLIC data structure for the ccmqmsgque-specific-data → C-API: libmqmsgque::MqContextS
static MK_CBP Create(MK_RT mkrt, MqContextC::MqTokenICB const callback, MqContextC *self=NULL)
Definition MqCall_cc.hh:57
static enum MkErrorE Call(MQ_SERVICE_CALL_ARGS)
Definition MqCall_cc.cc:78
static void Copy(MQ_SERVICE_COPY_ARGS)
Definition MqCall_cc.cc:73
static void Free(MQ_SERVICE_FREE_ARGS)
Definition MqCall_cc.cc:67
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