theLink 10.0
Loading...
Searching...
No Matches
MqContextC_rb.c
Go to the documentation of this file.
1
9/* LABEL-START */
10#define META_FILE_NAME "MqContextC_rb.c"
11
13
14#define OT_CLASS NS(MqContextC)
15#define OT_CLASS_NAME "MqContextC"
16
17#define OT_LNG2META(O) MqCtx(VAL2MNG(O))
18
20
21// new Class type object
22static MK_TYP MqContextCTT = NULL;
24
25// GS marker in "Data_Wrap_Struct"
26static void NS(sMark) (MK_PTR);
27
28// ruby datatype of the wrapped struct
29static rb_data_type_t NS(MqContextC_T) = {
30 "MqContextC",
31 {
32 NS(sMark),
33 MK(AtomDeleteSoft),
34 0, /* dsize */
35 0, /* reserved[1] */
36 },
37 NULL, /* parent */
38 NULL, /* data */
39 RUBY_TYPED_FREE_IMMEDIATELY
40};
41
42// >>THIS<< is a Phase-1-CONSTRUCTOR: a constructor which create the SELF object
43// A Phase-2-CONSTRUCTOR is a constructor which configure an already existing object
44// DO: create a new SELF and link this SELF with the MQ-Object "mng"
45// clazz is the toplevel "subclass" or "MqContextC"
46mk_inline OT_OBJ_T NS(LNG_CONSTR) (OT_CLS_T clazz, MK_MNG mng, int objc, VALUE* objv) {
47 return MK(AtomObjCrt)(clazz,&NS(MqContextC_T),mng,objc,objv);
48}
49// MQ: ObjNew feature: called to return a new or an already existing RUBY-SELF-Object
50// -> moved to: msgque_rb.h
51// OT_OBJ_T NS(MqContextC_ObjNew) (MK_CTX hdl) {
52// return MK(AtomObjNew) (MqContextC_X2obj(hdl));
53// }
54// MQ: ObjNew feature: selfCreate will be called from "ObjNew->MkSelfNew" if MkObj need a SELF pointer
55static MK_PTR NS(MqContextC_selfCreate) (MK_RT_ARGS MK_OBJ obj, MK_PTR envP) {
56 OT_OBJ_T self = NS(LNG_CONSTR) (OT_CLASS, obj, 0, NULL);
57 return VAL2PTR(self);
58}
59// MQ: called on instance-destruction for a "selfCreate" instance → goal: destroy the SELF
60static void NS(MqContextC_selfDelete) (MK_RT_ARGS MK_PTR ptr, MK_PTR envP) {
62}
63// MQ: called to destroy link from SELF to META
64static void NS(MqContextC_selfUnlink) (MK_RT_ARGS MK_PTR ptr, MK_PTR envP) {
65 OT_OBJ_T self = PTR2VAL(ptr);
66 RDATA(self)->data = NULL;
67}
68// initialize the RUBY and MO class specific object
69#define S_INIT NS(sInit)(MK_RT_CALL_ONLY)
70static void NS(sInit)(MK_RT_ARGS_ONLY) {
71
72 // add "selfCreate" and "selfDelete" feature to the MQ-MqContextC-Type
73 MqContextCTT->selfCreate = NS(MqContextC_selfCreate);
74 MqContextCTT->selfDelete = NS(MqContextC_selfDelete);
75 MqContextCTT->selfUnlink = NS(MqContextC_selfUnlink);
76
77 // create the RUBY class
78 OT_CLASS = rb_define_class_under(OT_PKG, "MqContextC", MK_BASE_CLASS);
79 rb_undef_alloc_func(OT_CLASS);
80
81 /* define the "NULL" object */
82 VALUE nullO = TypedData_Wrap_Struct (OT_CLASS, &NS(MqContextC_T), MK_NULL);
83 NS(MqContextC_MK_NULL) = nullO;
85}
86
87#define OT_SETUP_hdl OT_SETUP_hdl_tmpl(MqContextC);
88#define OT_SETUP_hdl__null_allow OT_SETUP_hdl_tmpl__null_allow(MqContextC);
89#define OT_SETUP_hdl_constr AllRtSetup_NULL; \
90 OT_OBJ_T clazz = self; \
91 MqContextC_type hdl = (MqContextC_type) &MkERROR;
92#define OT_SETUP_hdl_destr OT_SETUP_hdl_tmpl__null_allow(MqContextC);
93#define OT_SETUP_hdl_static AllRtSetup_NULL; \
94 __attribute__((unused)) MK_TYP hdl = MqContextC##_TT;
95#define OT_SETUP_hdl_static_constr OT_SETUP_hdl_static
96
97#if !defined(SetupRtFromObj_X)
98 #define SetupRtFromObj_X(hdl) AllRtSetup_X(hdl)
99 #define SetupRtFromObj_XN(hdl) AllRtSetup_XN(hdl)
100#endif
101
102/* LABEL-END */
103
109
110// BEGIN-DOC - created by 'rb_MqS.tcl -i NHI1_HOME/theLink/c/gen/c_mqmsgque.meta' - DO NOT change
111
112// doc-key: MqContextC,MqClass,oc_,func
113#define ClassFactoryGet_doc "MqFactoryC ctx.ClassFactoryGet() (const)"
114
115// doc-key: MqContextC,MqClass,om_,func
116#define ClassFactorySet_doc "ctx.ClassFactorySet(item:MqFactoryC)"
117#define ClassIdentGet_doc "string ctx.ClassIdentGet() (const)"
118#define ClassIdentSet_doc "ctx.ClassIdentSet(ident:string)"
119#define ClassOriginalIdentGet_doc "string ctx.ClassOriginalIdentGet() (const)"
120
121// doc-key: MqContextC,MqConfig,oco,func
122#define ConfigGetIoTcpL_doc "MkBufferListC ctx.ConfigGetIoTcpL()"
123
124// doc-key: MqContextC,MqConfig,om_,func
125#define ConfigCheckStartAs_doc "bool ctx.ConfigCheckStartAs(data:MqStartE)"
126#define ConfigGetBuffersize_doc "int32 ctx.ConfigGetBuffersize() (const)"
127#define ConfigGetIdentFrom_doc "MqIdentE ctx.ConfigGetIdentFrom()"
128#define ConfigGetIoPipe_doc "int32 ctx.ConfigGetIoPipe()"
129#define ConfigGetIoUds_doc "string ctx.ConfigGetIoUds() (const)"
130#define ConfigGetIsParent_doc "bool ctx.ConfigGetIsParent()"
131#define ConfigGetIsServer_doc "bool ctx.ConfigGetIsServer()"
132#define ConfigGetIsString_doc "bool ctx.ConfigGetIsString()"
133#define ConfigGetName_doc "string ctx.ConfigGetName() (const)"
134#define ConfigGetPkgsize_doc "int32 ctx.ConfigGetPkgsize() (const)"
135#define ConfigGetPostfix_doc "string ctx.ConfigGetPostfix() (const)"
136#define ConfigGetPrefix_doc "string ctx.ConfigGetPrefix() (const)"
137#define ConfigGetStartAs_doc "MqStartE ctx.ConfigGetStartAs()"
138#define ConfigGetStatusIs_doc "MqStatusIsEF ctx.ConfigGetStatusIs()"
139#define ConfigGetStorage_doc "string ctx.ConfigGetStorage() (const)"
140#define ConfigGetTimeout_doc "MkTimeoutE|int32 ctx.ConfigGetTimeout() (const)"
141#define ConfigReset_doc "ctx.ConfigReset()"
142#define ConfigSetAllDebug_doc "ctx.ConfigSetAllDebug(data:int32)"
143#define ConfigSetBgError_doc "ctx.ConfigSetBgError(?callback:callable=nil?)"
144#define ConfigSetBuffersize_doc "ctx.ConfigSetBuffersize(data:int32)"
145#define ConfigSetConfigFile_doc "ctx.ConfigSetConfigFile(filename:string)"
146#define ConfigSetDaemon_doc "ctx.ConfigSetDaemon(pidfile:string)"
147#define ConfigSetEvent_doc "ctx.ConfigSetEvent(?callback:callable=nil?)"
148#define ConfigSetIdentFrom_doc "ctx.ConfigSetIdentFrom(data:MqIdentE)"
149#define ConfigSetIgnoreExit_doc "ctx.ConfigSetIgnoreExit(data:bool)"
150#define ConfigSetIoPipe_doc "ctx.ConfigSetIoPipe(fh:int32)"
151#define ConfigSetIoTcp_doc "ctx.ConfigSetIoTcp(?host:string=\"nil\"?, ?port:string=\"nil\"?, ?myhost:string=\"nil\"?, ?myport:string=\"nil\"?)"
152#define ConfigSetIoTcpL_doc "ctx.ConfigSetIoTcpL(vals:MkBufferListC)"
153#define ConfigSetIoUds_doc "ctx.ConfigSetIoUds(file:string)"
154#define ConfigSetIsServer_doc "ctx.ConfigSetIsServer(data:bool)"
155#define ConfigSetIsString_doc "ctx.ConfigSetIsString(data:bool)"
156#define ConfigSetName_doc "ctx.ConfigSetName(data:string)"
157#define ConfigSetPkgsize_doc "ctx.ConfigSetPkgsize(data:int32)"
158#define ConfigSetPostfix_doc "ctx.ConfigSetPostfix(data:string)"
159#define ConfigSetPrefix_doc "ctx.ConfigSetPrefix(data:string)"
160#define ConfigSetServerCleanup_doc "ctx.ConfigSetServerCleanup(?callback:callable=nil?)"
161#define ConfigSetServerSetup_doc "ctx.ConfigSetServerSetup(?callback:callable=nil?)"
162#define ConfigSetStartAs_doc "ctx.ConfigSetStartAs(data:MqStartE)"
163#define ConfigSetStartAsString_doc "ctx.ConfigSetStartAsString(data:string)"
164#define ConfigSetStorage_doc "ctx.ConfigSetStorage(data:string)"
165#define ConfigSetTimeout_doc "ctx.ConfigSetTimeout(data:MkTimeoutE|int32)"
166
167// doc-key: MqContextC,MqConfig,omo,func
168#define ConfigGetIoTcp_doc "{host:string port:string myhost:string myport:string} ctx.ConfigGetIoTcp()"
169
170// doc-key: MqContextC,MqContext,sCc,func
171#define Create_doc "MqContextC MqContextC.Create(?tmpl:MqContextC=nil?)"
172#define new_doc "MqContextC MqContextC.new(?tmpl:MqContextC=nil?)"
173
174// doc-key: MqContextC,MqContext,sc_,func
175#define GetNull_doc "MqContextC MqContextC.GetNull()"
176#define HandleResolve_doc "MqContextC MqContextC.HandleResolve(netHdl:MK_HDL)"
177#define Instances_doc "MqContextC MqContextC.Instances()"
178
179// doc-key: MqContextC,MqContext,oc_,func
180#define ErrorFORMAT_doc "MkErrorC fmtobj.ErrorFORMAT() (const)"
181#define GetBuffer_doc "MkBufferC ctx.GetBuffer()"
182#define Next_doc "MqContextC ctx.Next()"
183#define Prev_doc "MqContextC ctx.Prev()"
184
185// doc-key: MqContextC,MqContext,om_,func
186#define ErrorCopy_doc "MkErrorE targetCtx.ErrorCopy(sourceCtx:MqContextC) (const)"
187#define ErrorMove_doc "MkErrorE targetCtx.ErrorMove(sourceCtx:MqContextC) (const)"
188// skip class-overload: HandleGet → MkObjectHandleGet
189// skip class-overload: Log → MkObjectLog
190#define LogConfig_doc "ctx.LogConfig(?fmtobj:MkObjectC=nil?, ?debug:int32=0?, ?callfunc:string=\"MK_NULL\"?, ?lvl:int32=0?) (const)"
191#define LogEnv_doc "ctx.LogEnv(?fmtobj:MkObjectC=nil?, ?debug:int32=0?, ?callfunc:string=\"MK_NULL\"?, ?lvl:int32=0?) (const)"
192#define LogLink_doc "ctx.LogLink(?fmtobj:MkObjectC=nil?, ?debug:int32=0?, ?callfunc:string=\"MK_NULL\"?, ?lvl:int32=0?) (const)"
193#define LogSetup_doc "ctx.LogSetup(?fmtobj:MkObjectC=nil?, ?debug:int32=0?, ?callfunc:string=\"MK_NULL\"?, ?lvl:int32=0?) (const)"
194#define LogShort_doc "ctx.LogShort(?fmtobj:MkObjectC=nil?, ?debug:int32=0?, ?callfunc:string=\"MK_NULL\"?, ?lvl:int32=0?, ?label:string=\"nil\"?) (const)"
195#define LogType_doc "ctx.LogType(?fmtobj:MkObjectC=nil?, ?debug:int32=0?, ?callfunc:string=\"MK_NULL\"?, ?lvl:int32=0?) (const)"
196// skip class-overload: ToString → MkObjectToString
197
198// doc-key: MqContextC,MqEnv,om_,func
199#define EnvProtect_doc "ctx.EnvProtect()"
200#define EnvRestore_doc "ctx.EnvRestore()"
201
202// doc-key: MqContextC,MqExit,om_,func
203#define Exit_doc "int32 ctx.Exit(?callfunc:string=\"MK_NULL\"?, ?callfile:string=\"MK_NULL\"?, ?callline:int32=-1?)"
204
205// doc-key: MqContextC,MqGet,oc_,func
206#define GetRoot_doc "MqContextC ctx.GetRoot()"
207
208// doc-key: MqContextC,MqLink,oc_,func
209#define LinkGetParent_doc "MqContextC ctx.LinkGetParent()"
210
211// doc-key: MqContextC,MqLink,om_,func
212#define LinkConnect_doc "ctx.LinkConnect()"
213#define LinkCreate_doc "ctx.LinkCreate(?args:MkBufferListC...=nil?)"
214#define LinkCreateChild_doc "ctx.LinkCreateChild(parent:MqContextC, ?args:MkBufferListC...=nil?)"
215#define LinkDelete_doc "ctx.LinkDelete()"
216#define LinkGetCtxId_doc "int32 ctx.LinkGetCtxId()"
217#define LinkGetTargetIdent_doc "string ctx.LinkGetTargetIdent()"
218#define LinkIsConnected_doc "bool ctx.LinkIsConnected()"
219#define LinkIsParent_doc "bool ctx.LinkIsParent()"
220#define LinkShutdown_doc "ctx.LinkShutdown()"
221
222// doc-key: MqContextC,MqLog,om_,func
223#define LogParentOrChild_doc "string ctx.LogParentOrChild() (const)"
224#define LogServerOrClient_doc "string ctx.LogServerOrClient() (const)"
225
226// doc-key: MqContextC,MqProcess,om_,func
227#define ProcessEvent_doc "ctx.ProcessEvent(?wait:MqWaitOnEventE=NO?, ?timeout:MkTimeoutE|int32=DEFAULT?)"
228
229// doc-key: MqContextC,MqProxy,om_,func
230#define ProxyForward_doc "sourceCtx.ProxyForward(targetCtx:MqContextC, ?dump:MqDumpC=nil?, ?timeout:MkTimeoutE|int32=DEFAULT?)"
231#define ProxyItem_doc "sourceCtx.ProxyItem(targetCtx:MqContextC)"
232
233// doc-key: MqContextC,MqRead,oci,func
234#define ReadALL_doc "MkBufferListC ctx.ReadALL(?val_inout:MkBufferListC=nil?)"
235
236// doc-key: MqContextC,MqRead,oco,func
237#define ReadBFL_doc "MkBufferListC ctx.ReadBFL()"
238#define ReadBUF_doc "MkBufferC ctx.ReadBUF()"
239
240// doc-key: MqContextC,MqRead,om_,func
241#define ReadDbg_doc "ctx.ReadDbg()"
242#define ReadGetNextType_doc "MkTypeE ctx.ReadGetNextType()"
243#define ReadGetNumItems_doc "int32 ctx.ReadGetNumItems()"
244#define ReadItemExists_doc "bool ctx.ReadItemExists()"
245#define ReadL_END_doc "ctx.ReadL_END()"
246#define ReadL_START_doc "ctx.ReadL_START(?buf:MkBufferC=nil?)"
247#define ReadT_END_doc "ctx.ReadT_END()"
248#define ReadT_START_doc "ctx.ReadT_START()"
249#define ReadUndo_doc "ctx.ReadUndo()"
250
251// doc-key: MqContextC,MqRead,omo,func
252#define ReadBIN_doc "binary ctx.ReadBIN()"
253#define ReadBOL_doc "bool ctx.ReadBOL()"
254#define ReadBinaryR_doc "binary ctx.ReadBinaryR()"
255#define ReadDBL_doc "double ctx.ReadDBL()"
256#define ReadFLT_doc "float ctx.ReadFLT()"
257#define ReadHDL_doc "MK_HDL ctx.ReadHDL()"
258#define ReadI16_doc "int16 ctx.ReadI16()"
259#define ReadI32_doc "int32 ctx.ReadI32()"
260#define ReadI64_doc "int64 ctx.ReadI64()"
261#define ReadI8_doc "int8 ctx.ReadI8()"
262#define ReadLIST_doc "[list...] ctx.ReadLIST()"
263#define ReadLONG_doc "long ctx.ReadLONG()"
264#define ReadNEXT_doc "obj ctx.ReadNEXT()"
265#define ReadSTR_doc "string ctx.ReadSTR()"
266#define ReadStringR_doc "string ctx.ReadStringR()"
267
268// doc-key: MqContextC,MqRoute,oco,func
269#define RouteGetTree_doc "MkBufferListC ctx.RouteGetTree()"
270
271// doc-key: MqContextC,MqRoute,om_,func
272#define RouteCreate_doc "ctx.RouteCreate(route:string, service:string, ?overwrite:bool=false?)"
273#define RouteDelete_doc "ctx.RouteDelete(route:string, service:string, ?overwrite:bool=false?)"
274#define RouteResolve_doc "[MqContextC...] ctx.RouteResolve(ident:string, ?retnum:int32=-1?)"
275#define RouteTraverse_doc "ctx.RouteTraverse(service:string, ?args:MkBufferListC...=nil?)"
276
277// doc-key: MqContextC,MqRoute,omo,func
278#define RouteGetPath_doc "string ctx.RouteGetPath()"
279
280// doc-key: MqContextC,MqSend,om_,func
281#define Send_doc "ctx.Send(cstr:string, args:args...)"
282#define SendBFL_doc "ctx.SendBFL(val:MkBufferListC)"
283#define SendBIN_doc "ctx.SendBIN(val:binary)"
284#define SendBOL_doc "ctx.SendBOL(val:bool)"
285#define SendBUF_doc "ctx.SendBUF(val:MkBufferC)"
286#define SendBUS_FLAT_doc "ctx.SendBUS_FLAT(val:MkBufferStreamC)"
287#define SendBinaryR_doc "ctx.SendBinaryR(val:binary)"
288#define SendDBL_doc "ctx.SendDBL(val:double)"
289#define SendEND_doc "ctx.SendEND(token:string[4], ?timeout:MkTimeoutE|int32=DEFAULT?)"
290#define SendEND_AND_CALLBACK_doc "ctx.SendEND_AND_CALLBACK(token:string[4], callback:callable, ?timeout:MkTimeoutE|int32=DEFAULT?)"
291#define SendEND_AND_SUB_doc "ctx.SendEND_AND_SUB(token:string[4], callback:callable, ?timeout:MkTimeoutE|int32=DEFAULT?)"
292#define SendEND_AND_TRANSACTION_doc "ctx.SendEND_AND_TRANSACTION(token:string[4], callback:string[4], ?timeout:MkTimeoutE|int32=DEFAULT?)"
293#define SendEND_AND_WAIT_doc "ctx.SendEND_AND_WAIT(token:string[4], ?timeout:MkTimeoutE|int32=DEFAULT?)"
294#define SendERROR_doc "ctx.SendERROR()"
295#define SendFLT_doc "ctx.SendFLT(val:float)"
296#define SendHDL_doc "ctx.SendHDL(val:MK_HDL)"
297#define SendI16_doc "ctx.SendI16(val:int16)"
298#define SendI32_doc "ctx.SendI32(val:int32)"
299#define SendI64_doc "ctx.SendI64(val:int64)"
300#define SendI8_doc "ctx.SendI8(val:int8)"
301#define SendLONG_doc "ctx.SendLONG(val:long)"
302#define SendLTR_doc "ctx.SendLTR(transLId:int32)"
303#define SendL_END_doc "ctx.SendL_END()"
304#define SendL_FLAT_doc "ctx.SendL_FLAT(val:MkBufferListC)"
305#define SendL_START_doc "ctx.SendL_START()"
306#define SendRETURN_doc "ctx.SendRETURN()"
307#define SendRETURN_SUB_doc "ctx.SendRETURN_SUB()"
308#define SendSTART_doc "ctx.SendSTART()"
309#define SendSTR_doc "ctx.SendSTR(val:string)"
310#define SendSYNC_doc "ctx.SendSYNC()"
311#define SendStringR_doc "ctx.SendStringR(val:string)"
312#define SendT_END_doc "ctx.SendT_END()"
313#define SendT_START_doc "ctx.SendT_START()"
314
315// doc-key: MqContextC,MqService,om_,func
316#define ServiceCreate_doc "ctx.ServiceCreate(token:string[4], callback:callable)"
317#define ServiceDelete_doc "ctx.ServiceDelete(token:string[4])"
318#define ServiceIsTransaction_doc "bool ctx.ServiceIsTransaction()"
319#define ServiceProxy_doc "ctx.ServiceProxy(token:string[4], ?id:MqSlaveE|int32=MQ_SLAVE_OTHER?)"
320#define ServiceProxyCtx_doc "ctx.ServiceProxyCtx(token:string[4], target:MqContextC)"
321#define ServiceProxyCtxExists_doc "bool ctx.ServiceProxyCtxExists(token:string[4], target:MqContextC)"
322#define ServiceProxyRoundRobin_doc "ctx.ServiceProxyRoundRobin(token:string[4], ident:string)"
323#define ServiceStorage_doc "ctx.ServiceStorage(token:string[4])"
324#define ServiceTokenCheck_doc "bool ctx.ServiceTokenCheck(token:string[4])"
325#define ServiceTokenExists_doc "bool ctx.ServiceTokenExists(token:string[4])"
326#define ServiceTokenGet_doc "string[4] ctx.ServiceTokenGet()"
327
328// doc-key: MqContextC,MqSlave,oc_,func
329#define SlaveGetMaster_doc "MqContextC ctx.SlaveGetMaster()"
330
331// doc-key: MqContextC,MqSlave,oco,func
332#define SlaveGet_doc "MqContextC ctx.SlaveGet(id:MqSlaveE|int32)"
333#define SlaveGetFilter_doc "MqContextC ctx.SlaveGetFilter()"
334#define SlaveGetProxy_doc "MqContextC ctx.SlaveGetProxy(id:MqSlaveE|int32)"
335
336// doc-key: MqContextC,MqSlave,om_,func
337#define SlaveCheck_doc "bool ctx.SlaveCheck(id:MqSlaveE|int32) (const)"
338#define SlaveCreate_doc "ctx.SlaveCreate(id:MqSlaveE|int32, slave:MqContextC)"
339#define SlaveDelete_doc "ctx.SlaveDelete(id:MqSlaveE|int32)"
340#define SlaveIs_doc "bool ctx.SlaveIs() (const)"
341#define SlaveWorker_doc "ctx.SlaveWorker(id:MqSlaveE|int32, ?fct:string=\"WORKER\"?, ?args:MkBufferListC...=nil?)"
342
343// doc-key: MqContextC,MqStorage,oci,func
344#define StorageDelete_doc "int32 ctx.StorageDelete(?*transLIdP_inout:int32=0?)"
345#define StorageImport_doc "int32 ctx.StorageImport(?*transLIdP_inout:int32=0?)"
346
347// doc-key: MqContextC,MqStorage,om_,func
348#define StorageClose_doc "ctx.StorageClose()"
349#define StorageDecrRef_doc "ctx.StorageDecrRef(transLId:int32)"
350#define StorageIncrRef_doc "ctx.StorageIncrRef(transLId:int32)"
351#define StorageLog_doc "ctx.StorageLog(?callfunc:string=\"MK_NULL\"?)"
352#define StorageOpen_doc "ctx.StorageOpen(storageFile:string)"
353
354// doc-key: MqContextC,MqStorage,omo,func
355#define StorageCount_doc "int32 ctx.StorageCount()"
356#define StorageErrCnt_doc "int32 ctx.StorageErrCnt(transLId:int32)"
357#define StorageExport_doc "int32 ctx.StorageExport()"
358#define StorageResolve_doc "{otherCtxP:MqContextC otherLIdP:int32} ctx.StorageResolve()"
359
360// END-DOC - created by 'rb_MqS.tcl -i NHI1_HOME/theLink/c/gen/c_mqmsgque.meta' - DO NOT change
361
367
370OT_ProcRet NS(MqContextC_ReadNEXT) (MqContextC_ARGS);
372
375OT_ProcRet NS(MqContextC_ReadLIST) (MqContextC_ARGS);
377
378// BEGIN-MqContextC - created by 'rb_MqC.tcl -i NHI1_HOME/theLink/c/gen/c_mqmsgque.meta' - DO NOT change
379
383
384// doc-key: MqContextC,MqContextC-Class-Export,sc_
385
387static OT_ProcRet NS(MqContextC_HandleResolve) (OtClass_ARGS) {
390 MK_HDL netHdl = 0;
393 MQ_CTX retVal = MqContextHandleResolve (netHdl);
394 OT_retObj_SET_CTX(retVal);
395 end: MK_UNUSED /* LONG JUMP on error */
397}
398
399// doc-key: MqContextC,MqContextC-Class-Export,om_
400
401// skip on class-overload: MqContextHandleGet → MkObjectHandleGet
403static OT_ProcRet NS(MqContextC_HandleGet) (MqContextC_ARGS) {OT_ERROR_LNG_RETURN;}
404
406// MqContextC_Class_RB_API
407
411
412// doc-key: MqContextC,MqContextC-Class-Introspection,oc_
413
415static OT_ProcRet NS(MqContextC_Next) (MqContextC_ARGS) {
419 MQ_CTX retVal = MqContextNext (hdl);
420 OT_retObj_SET_CTX(retVal);
421 end: MK_UNUSED /* LONG JUMP on error */
423}
424
426static OT_ProcRet NS(MqContextC_Prev) (MqContextC_ARGS) {
430 MQ_CTX retVal = MqContextPrev (hdl);
431 OT_retObj_SET_CTX(retVal);
432 end: MK_UNUSED /* LONG JUMP on error */
434}
435
436// doc-key: MqContextC,MqContextC-Class-Introspection,sc_
437
439static OT_ProcRet NS(MqContextC_Instances) (OtClass_ARGS) {
443 MQ_CTX retVal = MqContextInstances ();
444 OT_retObj_SET_CTX(retVal);
445 end: MK_UNUSED /* LONG JUMP on error */
447}
448
450// MqContextC_Class_RB_API
451
455
456// doc-key: MqContextC,MqContextC-Class-Misc,sc_
457
459static OT_ProcRet NS(MqContextC_GetNull) (OtClass_ARGS) {
463 MQ_CTX retVal = MqContextGetNull ();
464 OT_retObj_SET_CTX(retVal);
465 end: MK_UNUSED /* LONG JUMP on error */
467}
468
470// MqContextC_Class_RB_API
471
475
476// doc-key: MqContextC,MqContextC-ClassApi-Class,oc_
477
479static OT_ProcRet NS(MqContextC_ClassFactoryGet) (MqContextC_ARGS) {
483 MQ_FCT retVal = MqClassFactoryGet (hdl);
484 OT_retObj_SET_FCT(retVal);
485 end: MK_UNUSED /* LONG JUMP on error */
487}
488
489// doc-key: MqContextC,MqContextC-ClassApi-Class,om_
490
492static OT_ProcRet NS(MqContextC_ClassFactorySet) (MqContextC_ARGS) {
495 MQ_FCT item = 0;
498 MkErrorC_Check(hdl,MqClassFactorySet (hdl, item));
500 end: MK_UNUSED /* LONG JUMP on error */
502}
503
505static OT_ProcRet NS(MqContextC_ClassIdentGet) (MqContextC_ARGS) {
510 end: MK_UNUSED /* LONG JUMP on error */
512}
513
515static OT_ProcRet NS(MqContextC_ClassIdentSet) (MqContextC_ARGS) {
518 MK_STRN ident = 0;
521 MkErrorC_Check(hdl,MqClassIdentSet (hdl, ident));
523 end: MK_UNUSED /* LONG JUMP on error */
525}
526
528static OT_ProcRet NS(MqContextC_ClassOriginalIdentGet) (MqContextC_ARGS) {
533 end: MK_UNUSED /* LONG JUMP on error */
535}
536
538// MqContextC_ClassApi_Class_RB_API
539
543
544// doc-key: MqContextC,MqContextC-ConfigApi-Get,oco
545
547static OT_ProcRet NS(MqContextC_ConfigGetIoTcpL) (MqContextC_ARGS) {
551 MK_BFL vals_out;
552 MkErrorC_Check(hdl,MqConfigGetIoTcpL (hdl, &vals_out));
553 OT_retObj_SET_BFL(vals_out);
554 end: MK_UNUSED /* LONG JUMP on error */
556}
557
558// doc-key: MqContextC,MqContextC-ConfigApi-Get,om_
559
561static OT_ProcRet NS(MqContextC_ConfigGetBuffersize) (MqContextC_ARGS) {
566 end: MK_UNUSED /* LONG JUMP on error */
568}
569
571static OT_ProcRet NS(MqContextC_ConfigGetIdentFrom) (MqContextC_ARGS) {
576 end: MK_UNUSED /* LONG JUMP on error */
578}
579
581static OT_ProcRet NS(MqContextC_ConfigGetIoPipe) (MqContextC_ARGS) {
586 end: MK_UNUSED /* LONG JUMP on error */
588}
589
591static OT_ProcRet NS(MqContextC_ConfigGetIoUds) (MqContextC_ARGS) {
596 end: MK_UNUSED /* LONG JUMP on error */
598}
599
601static OT_ProcRet NS(MqContextC_ConfigGetIsParent) (MqContextC_ARGS) {
606 end: MK_UNUSED /* LONG JUMP on error */
608}
609
611static OT_ProcRet NS(MqContextC_ConfigGetIsServer) (MqContextC_ARGS) {
616 end: MK_UNUSED /* LONG JUMP on error */
618}
619
621static OT_ProcRet NS(MqContextC_ConfigGetIsString) (MqContextC_ARGS) {
626 end: MK_UNUSED /* LONG JUMP on error */
628}
629
631static OT_ProcRet NS(MqContextC_ConfigGetName) (MqContextC_ARGS) {
636 end: MK_UNUSED /* LONG JUMP on error */
638}
639
641static OT_ProcRet NS(MqContextC_ConfigGetPkgsize) (MqContextC_ARGS) {
646 end: MK_UNUSED /* LONG JUMP on error */
648}
649
651static OT_ProcRet NS(MqContextC_ConfigGetPostfix) (MqContextC_ARGS) {
656 end: MK_UNUSED /* LONG JUMP on error */
658}
659
661static OT_ProcRet NS(MqContextC_ConfigGetPrefix) (MqContextC_ARGS) {
666 end: MK_UNUSED /* LONG JUMP on error */
668}
669
671static OT_ProcRet NS(MqContextC_ConfigGetStartAs) (MqContextC_ARGS) {
676 end: MK_UNUSED /* LONG JUMP on error */
678}
679
681static OT_ProcRet NS(MqContextC_ConfigGetStatusIs) (MqContextC_ARGS) {
686 end: MK_UNUSED /* LONG JUMP on error */
688}
689
691static OT_ProcRet NS(MqContextC_ConfigGetStorage) (MqContextC_ARGS) {
696 end: MK_UNUSED /* LONG JUMP on error */
698}
699
701static OT_ProcRet NS(MqContextC_ConfigGetTimeout) (MqContextC_ARGS) {
706 end: MK_UNUSED /* LONG JUMP on error */
708}
709
711static OT_ProcRet NS(MqContextC_ConfigSetConfigFile) (MqContextC_ARGS) {
714 MK_STRN filename = 0;
717 MkErrorC_Check(hdl,MqConfigSetConfigFile (hdl, filename));
719 end: MK_UNUSED /* LONG JUMP on error */
721}
722
723// doc-key: MqContextC,MqContextC-ConfigApi-Get,omo
724
726static OT_ProcRet NS(MqContextC_ConfigGetIoTcp) (MqContextC_ARGS) {
730 MK_STRN host_out;
731 MK_STRN port_out;
732 MK_STRN myhost_out;
733 MK_STRN myport_out;
734 MkErrorC_Check(hdl,MqConfigGetIoTcp (hdl, &host_out, &port_out, &myhost_out, &myport_out));
738 OT_retObj_APPEND(OT_TMP_STR_OBJ(myhost_out));
739 OT_retObj_APPEND(OT_TMP_STR_OBJ(myport_out));
740 end: MK_UNUSED /* LONG JUMP on error */
742}
743
745// MqContextC_ConfigApi_Get_RB_API
746
750
751// doc-key: MqContextC,MqContextC-ConfigApi-Interface,om_
752
754static OT_ProcRet NS(MqContextC_ConfigSetBgError) (MqContextC_ARGS) {
757 OT_SETUP_CALLABLE(callback)
760 MqServiceCallbackF fCall = (callback == NULL ? NULL : NS(ServiceCall));
761 MqConfigSetBgError (hdl, fCall, callback, NS(ServiceFree), NS(ServiceCopy));
763 end: MK_UNUSED /* LONG JUMP on error */
764 OT_CLEANUP_CALLABLE(callback)
766}
767
769static OT_ProcRet NS(MqContextC_ConfigSetEvent) (MqContextC_ARGS) {
772 OT_SETUP_CALLABLE(callback)
775 MqServiceCallbackF fCall = (callback == NULL ? NULL : NS(ServiceCall));
776 MqConfigSetEvent (hdl, fCall, callback, NS(ServiceFree), NS(ServiceCopy));
778 end: MK_UNUSED /* LONG JUMP on error */
779 OT_CLEANUP_CALLABLE(callback)
781}
782
784static OT_ProcRet NS(MqContextC_ConfigSetServerCleanup) (MqContextC_ARGS) {
787 OT_SETUP_CALLABLE(callback)
790 MqServiceCallbackF fCall = (callback == NULL ? NULL : NS(ServiceCall));
791 MqConfigSetServerCleanup (hdl, fCall, callback, NS(ServiceFree), NS(ServiceCopy));
793 end: MK_UNUSED /* LONG JUMP on error */
794 OT_CLEANUP_CALLABLE(callback)
796}
797
799static OT_ProcRet NS(MqContextC_ConfigSetServerSetup) (MqContextC_ARGS) {
802 OT_SETUP_CALLABLE(callback)
805 MqServiceCallbackF fCall = (callback == NULL ? NULL : NS(ServiceCall));
806 MqConfigSetServerSetup (hdl, fCall, callback, NS(ServiceFree), NS(ServiceCopy));
808 end: MK_UNUSED /* LONG JUMP on error */
809 OT_CLEANUP_CALLABLE(callback)
811}
812
814// MqContextC_ConfigApi_Interface_RB_API
815
819
820// doc-key: MqContextC,MqContextC-ConfigApi-Misc,om_
821
823static OT_ProcRet NS(MqContextC_ConfigReset) (MqContextC_ARGS) {
827 MqConfigReset (hdl);
829 end: MK_UNUSED /* LONG JUMP on error */
831}
832
834// MqContextC_ConfigApi_Misc_RB_API
835
839
840// doc-key: MqContextC,MqContextC-ConfigApi-Set,om_
841
843static OT_ProcRet NS(MqContextC_ConfigCheckStartAs) (MqContextC_ARGS) {
846 enum MqStartE data = 0;
850 end: MK_UNUSED /* LONG JUMP on error */
852}
853
855static OT_ProcRet NS(MqContextC_ConfigSetAllDebug) (MqContextC_ARGS) {
858 MK_I32 data = 0;
861 MkErrorC_Check(hdl,MqConfigSetAllDebug (hdl, data));
863 end: MK_UNUSED /* LONG JUMP on error */
865}
866
868static OT_ProcRet NS(MqContextC_ConfigSetBuffersize) (MqContextC_ARGS) {
871 MK_I32 data = 0;
874 MqConfigSetBuffersize (hdl, data);
876 end: MK_UNUSED /* LONG JUMP on error */
878}
879
881static OT_ProcRet NS(MqContextC_ConfigSetDaemon) (MqContextC_ARGS) {
884 MK_STRN pidfile = 0;
887 MkErrorC_Check(hdl,MqConfigSetDaemon (hdl, pidfile));
889 end: MK_UNUSED /* LONG JUMP on error */
891}
892
894static OT_ProcRet NS(MqContextC_ConfigSetIdentFrom) (MqContextC_ARGS) {
897 enum MqIdentE data = 0;
900 MqConfigSetIdentFrom (hdl, data);
902 end: MK_UNUSED /* LONG JUMP on error */
904}
905
907static OT_ProcRet NS(MqContextC_ConfigSetIgnoreExit) (MqContextC_ARGS) {
910 MK_BOOL data = 0;
913 MqConfigSetIgnoreExit (hdl, data);
915 end: MK_UNUSED /* LONG JUMP on error */
917}
918
920static OT_ProcRet NS(MqContextC_ConfigSetIoPipe) (MqContextC_ARGS) {
923 MQ_SOCK_HDL fh = 0;
926 MkErrorC_Check(hdl,MqConfigSetIoPipe (hdl, fh));
928 end: MK_UNUSED /* LONG JUMP on error */
930}
931
933static OT_ProcRet NS(MqContextC_ConfigSetIoTcp) (MqContextC_ARGS) {
936 MK_STRN host = NULL;
938 MK_STRN port = NULL;
940 MK_STRN myhost = NULL;
942 MK_STRN myport = NULL;
945 MkErrorC_Check(hdl,MqConfigSetIoTcp (hdl, host, port, myhost, myport));
947 end: MK_UNUSED /* LONG JUMP on error */
949}
950
952static OT_ProcRet NS(MqContextC_ConfigSetIoTcpL) (MqContextC_ARGS) {
958 MkErrorC_Check(hdl,MqConfigSetIoTcpL (hdl, vals));
960 end: MK_UNUSED /* LONG JUMP on error */
962}
963
965static OT_ProcRet NS(MqContextC_ConfigSetIoUds) (MqContextC_ARGS) {
968 MK_STRN file = 0;
971 MkErrorC_Check(hdl,MqConfigSetIoUds (hdl, file));
973 end: MK_UNUSED /* LONG JUMP on error */
975}
976
978static OT_ProcRet NS(MqContextC_ConfigSetIsServer) (MqContextC_ARGS) {
981 MK_BOOL data = 0;
984 MqConfigSetIsServer (hdl, data);
986 end: MK_UNUSED /* LONG JUMP on error */
988}
989
991static OT_ProcRet NS(MqContextC_ConfigSetIsString) (MqContextC_ARGS) {
994 MK_BOOL data = 0;
997 MqConfigSetIsString (hdl, data);
999 end: MK_UNUSED /* LONG JUMP on error */
1001}
1002
1004static OT_ProcRet NS(MqContextC_ConfigSetName) (MqContextC_ARGS) {
1007 MK_STRN data = 0;
1010 MqConfigSetName (hdl, data);
1012 end: MK_UNUSED /* LONG JUMP on error */
1014}
1015
1017static OT_ProcRet NS(MqContextC_ConfigSetPkgsize) (MqContextC_ARGS) {
1020 MK_I32 data = 0;
1023 MqConfigSetPkgsize (hdl, data);
1025 end: MK_UNUSED /* LONG JUMP on error */
1027}
1028
1030static OT_ProcRet NS(MqContextC_ConfigSetPostfix) (MqContextC_ARGS) {
1033 MK_STRN data = 0;
1036 MqConfigSetPostfix (hdl, data);
1038 end: MK_UNUSED /* LONG JUMP on error */
1040}
1041
1043static OT_ProcRet NS(MqContextC_ConfigSetPrefix) (MqContextC_ARGS) {
1046 MK_STRN data = 0;
1049 MqConfigSetPrefix (hdl, data);
1051 end: MK_UNUSED /* LONG JUMP on error */
1053}
1054
1056static OT_ProcRet NS(MqContextC_ConfigSetStartAs) (MqContextC_ARGS) {
1059 enum MqStartE data = 0;
1062 MkErrorC_Check(hdl,MqConfigSetStartAs (hdl, data));
1064 end: MK_UNUSED /* LONG JUMP on error */
1066}
1067
1069static OT_ProcRet NS(MqContextC_ConfigSetStartAsString) (MqContextC_ARGS) {
1072 MK_STRN data = 0;
1077 end: MK_UNUSED /* LONG JUMP on error */
1079}
1080
1082static OT_ProcRet NS(MqContextC_ConfigSetStorage) (MqContextC_ARGS) {
1085 MK_STRN data = 0;
1088 MqConfigSetStorage (hdl, data);
1090 end: MK_UNUSED /* LONG JUMP on error */
1092}
1093
1095static OT_ProcRet NS(MqContextC_ConfigSetTimeout) (MqContextC_ARGS) {
1098 MK_TIME_T data = 0;
1101 MqConfigSetTimeout (hdl, data);
1103 end: MK_UNUSED /* LONG JUMP on error */
1105}
1106
1108// MqContextC_ConfigApi_Set_RB_API
1109
1113
1114// doc-key: MqContextC,MqContextC-EnvApi-Env,om_
1115
1117static OT_ProcRet NS(MqContextC_EnvProtect) (MqContextC_ARGS) {
1121 MqEnvProtect (hdl);
1123 end: MK_UNUSED /* LONG JUMP on error */
1125}
1126
1128static OT_ProcRet NS(MqContextC_EnvRestore) (MqContextC_ARGS) {
1132 MqEnvRestore (hdl);
1134 end: MK_UNUSED /* LONG JUMP on error */
1136}
1137
1139// MqContextC_EnvApi_Env_RB_API
1140
1144
1145// doc-key: MqContextC,MqContextC-ErrorApi-Error,oc_
1146
1148static OT_ProcRet NS(MqContextC_ErrorFORMAT) (MqContextC_ARGS) {
1152 MK_ERR retVal = MqContextErrorFORMAT (hdl);
1153 OT_retObj_SET_ERR(retVal);
1154 end: MK_UNUSED /* LONG JUMP on error */
1156}
1157
1158// doc-key: MqContextC,MqContextC-ErrorApi-Error,om_
1159
1161OT_ProcRet NS(MqContextC_ErrorCopy) (MqContextC_ARGS) {
1164 MQ_CTXN sourceCtx = 0;
1167 OT_retObj_SET(OT_NEW_Mk_enum_OBJ(ErrorE,MqContextErrorCopy (hdl, sourceCtx)));
1168 end: MK_UNUSED /* LONG JUMP on error */
1170}
1171
1173OT_ProcRet NS(MqContextC_ErrorMove) (MqContextC_ARGS) {
1176 MQ_CTXN sourceCtx = 0;
1179 OT_retObj_SET(OT_NEW_Mk_enum_OBJ(ErrorE,MqContextErrorMove (hdl, sourceCtx)));
1180 end: MK_UNUSED /* LONG JUMP on error */
1182}
1183
1185// MqContextC_ErrorApi_Error_RB_API
1186
1190
1191// doc-key: MqContextC,MqContextC-HighApi-High,om_
1192
1194OT_ProcRet NS(MqContextC_Send) (MqContextC_ARGS) ; // skip template-required
1195
1197// MqContextC_HighApi_High_RB_API
1198
1202
1203// doc-key: MqContextC,MqContextC-LinkApi-Link,oc_
1204
1206static OT_ProcRet NS(MqContextC_LinkGetParent) (MqContextC_ARGS) {
1210 MQ_CTX retVal = MqLinkGetParent (hdl);
1211 OT_retObj_SET_CTX(retVal);
1212 end: MK_UNUSED /* LONG JUMP on error */
1214}
1215
1216// doc-key: MqContextC,MqContextC-LinkApi-Link,om_
1217
1219static OT_ProcRet NS(MqContextC_LinkConnect) (MqContextC_ARGS) {
1223 MkErrorC_Check(hdl,MqLinkConnect (hdl));
1225 end: MK_UNUSED /* LONG JUMP on error */
1227}
1228
1230static OT_ProcRet NS(MqContextC_LinkCreate) (MqContextC_ARGS) {
1233 MkBufferListCreateTLS_T(args,10);
1236 MkErrorC_Check(hdl,MqLinkCreate (hdl, args));
1238 end: MK_UNUSED /* LONG JUMP on error */
1240}
1241
1243static OT_ProcRet NS(MqContextC_LinkCreateChild) (MqContextC_ARGS) {
1246 MQ_CTX parent = 0;
1248 MkBufferListCreateTLS_T(args,10);
1251 MkErrorC_Check(hdl,MqLinkCreateChild (hdl, parent, args));
1253 end: MK_UNUSED /* LONG JUMP on error */
1255}
1256
1258static OT_ProcRet NS(MqContextC_LinkDelete) (MqContextC_ARGS) {
1262 MqLinkDelete (hdl);
1264 end: MK_UNUSED /* LONG JUMP on error */
1266}
1267
1269static OT_ProcRet NS(MqContextC_LinkGetCtxId) (MqContextC_ARGS) {
1274 end: MK_UNUSED /* LONG JUMP on error */
1276}
1277
1279static OT_ProcRet NS(MqContextC_LinkGetTargetIdent) (MqContextC_ARGS) {
1284 end: MK_UNUSED /* LONG JUMP on error */
1286}
1287
1289static OT_ProcRet NS(MqContextC_LinkIsConnected) (MqContextC_ARGS) {
1294 end: MK_UNUSED /* LONG JUMP on error */
1296}
1297
1299static OT_ProcRet NS(MqContextC_LinkIsParent) (MqContextC_ARGS) {
1304 end: MK_UNUSED /* LONG JUMP on error */
1306}
1307
1309static OT_ProcRet NS(MqContextC_LinkShutdown) (MqContextC_ARGS) {
1313 MkErrorC_Check(hdl,MqLinkShutdown (hdl));
1315 end: MK_UNUSED /* LONG JUMP on error */
1317}
1318
1320// MqContextC_LinkApi_Link_RB_API
1321
1325
1326// doc-key: MqContextC,MqContextC-LogApi-Log,om_
1327
1328// skip on class-overload: MqContextLog → MkObjectLog
1331
1333static OT_ProcRet NS(MqContextC_LogConfig) (MqContextC_ARGS) {
1336 MK_OBJN fmtobj = NULL;
1338 MK_DBG debug = 0;
1340 MK_STRN callfunc = NULL;
1342 MK_I32 lvl = 0;
1345 if (debug > MkRuntimeDebugGet()) {
1347 goto end;
1348 }
1349 if (MkSysStringIsNULL(callfunc)) {callfunc = OT_GET_CALL_PROC;}
1350 MqContextLogConfig (hdl, fmtobj, debug, callfunc, lvl);
1352 end: MK_UNUSED /* LONG JUMP on error */
1355}
1356
1358static OT_ProcRet NS(MqContextC_LogEnv) (MqContextC_ARGS) {
1361 MK_OBJN fmtobj = NULL;
1363 MK_DBG debug = 0;
1365 MK_STRN callfunc = NULL;
1367 MK_I32 lvl = 0;
1370 if (debug > MkRuntimeDebugGet()) {
1372 goto end;
1373 }
1374 if (MkSysStringIsNULL(callfunc)) {callfunc = OT_GET_CALL_PROC;}
1375 MqContextLogEnv (hdl, fmtobj, debug, callfunc, lvl);
1377 end: MK_UNUSED /* LONG JUMP on error */
1380}
1381
1383static OT_ProcRet NS(MqContextC_LogLink) (MqContextC_ARGS) {
1386 MK_OBJN fmtobj = NULL;
1388 MK_DBG debug = 0;
1390 MK_STRN callfunc = NULL;
1392 MK_I32 lvl = 0;
1395 if (debug > MkRuntimeDebugGet()) {
1397 goto end;
1398 }
1399 if (MkSysStringIsNULL(callfunc)) {callfunc = OT_GET_CALL_PROC;}
1400 MqContextLogLink (hdl, fmtobj, debug, callfunc, lvl);
1402 end: MK_UNUSED /* LONG JUMP on error */
1405}
1406
1408static OT_ProcRet NS(MqContextC_LogSetup) (MqContextC_ARGS) {
1411 MK_OBJN fmtobj = NULL;
1413 MK_DBG debug = 0;
1415 MK_STRN callfunc = NULL;
1417 MK_I32 lvl = 0;
1420 if (debug > MkRuntimeDebugGet()) {
1422 goto end;
1423 }
1424 if (MkSysStringIsNULL(callfunc)) {callfunc = OT_GET_CALL_PROC;}
1425 MqContextLogSetup (hdl, fmtobj, debug, callfunc, lvl);
1427 end: MK_UNUSED /* LONG JUMP on error */
1430}
1431
1433static OT_ProcRet NS(MqContextC_LogShort) (MqContextC_ARGS) {
1436 MK_OBJN fmtobj = NULL;
1438 MK_DBG debug = 0;
1440 MK_STRN callfunc = NULL;
1442 MK_I32 lvl = 0;
1444 MK_STRN label = NULL;
1447 if (debug > MkRuntimeDebugGet()) {
1449 goto end;
1450 }
1451 if (MkSysStringIsNULL(callfunc)) {callfunc = OT_GET_CALL_PROC;}
1452 MqContextLogShort (hdl, fmtobj, debug, callfunc, lvl, label);
1454 end: MK_UNUSED /* LONG JUMP on error */
1457}
1458
1460static OT_ProcRet NS(MqContextC_LogType) (MqContextC_ARGS) {
1463 MK_OBJN fmtobj = NULL;
1465 MK_DBG debug = 0;
1467 MK_STRN callfunc = NULL;
1469 MK_I32 lvl = 0;
1472 if (debug > MkRuntimeDebugGet()) {
1474 goto end;
1475 }
1476 if (MkSysStringIsNULL(callfunc)) {callfunc = OT_GET_CALL_PROC;}
1477 MqContextLogType (hdl, fmtobj, debug, callfunc, lvl);
1479 end: MK_UNUSED /* LONG JUMP on error */
1482}
1483
1485static OT_ProcRet NS(MqContextC_LogParentOrChild) (MqContextC_ARGS) {
1490 end: MK_UNUSED /* LONG JUMP on error */
1492}
1493
1495static OT_ProcRet NS(MqContextC_LogServerOrClient) (MqContextC_ARGS) {
1500 end: MK_UNUSED /* LONG JUMP on error */
1502}
1503
1505// MqContextC_LogApi_Log_RB_API
1506
1510
1511// doc-key: MqContextC,MqContextC-MiscApi-Misc,oc_
1512
1514static OT_ProcRet NS(MqContextC_GetBuffer) (MqContextC_ARGS) {
1518 MK_BUF retVal = MqContextGetBuffer (hdl);
1519 OT_retObj_SET_BUF(retVal);
1520 end: MK_UNUSED /* LONG JUMP on error */
1522}
1523
1525static OT_ProcRet NS(MqContextC_GetRoot) (MqContextC_ARGS) {
1529 MQ_CTX retVal = MqGetRoot (hdl);
1530 OT_retObj_SET_CTX(retVal);
1531 end: MK_UNUSED /* LONG JUMP on error */
1533}
1534
1535// doc-key: MqContextC,MqContextC-MiscApi-Misc,om_
1536
1537// skip on class-overload: MqContextToString → MkObjectToString
1539static OT_ProcRet NS(MqContextC_ToString) (MqContextC_ARGS) {OT_ERROR_LNG_RETURN;}
1540
1542static OT_ProcRet NS(MqContextC_Exit) (MqContextC_ARGS) {
1545 MK_STRN callfunc = NULL;
1547 MK_STRN callfile = NULL;
1549 MK_I32 callline = -1;
1552 if (callline == -1 ) {callline = OT_GET_CALL_LINE;}
1553 if (MkSysStringIsNULL(callfile)) {callfile = OT_GET_CALL_FILE;}
1554 if (MkSysStringIsNULL(callfunc)) {callfunc = OT_GET_CALL_PROC;}
1555 OT_retObj_SET_I32(MqExit (hdl, callfunc, callfile, callline));
1556 end: MK_UNUSED /* LONG JUMP on error */
1559}
1560
1562static OT_ProcRet NS(MqContextC_ProcessEvent) (MqContextC_ARGS) {
1565 enum MqWaitOnEventE wait = MQ_WAIT_NO;
1570 MkErrorC_Check(hdl,MqProcessEvent (hdl, wait, timeout));
1572 end: MK_UNUSED /* LONG JUMP on error */
1574}
1575
1577// MqContextC_MiscApi_Misc_RB_API
1578
1582
1583// doc-key: MqContextC,MqContextC-ProxyApi-Proxy,om_
1584
1586static OT_ProcRet NS(MqContextC_ProxyForward) (MqContextC_ARGS) {
1589 MQ_CTX targetCtx = 0;
1591 MQ_DMP dump = NULL;
1596 MkErrorC_Check(hdl,MqProxyForward (hdl, targetCtx, dump, timeout));
1598 end: MK_UNUSED /* LONG JUMP on error */
1600}
1601
1603static OT_ProcRet NS(MqContextC_ProxyItem) (MqContextC_ARGS) {
1606 MQ_CTX targetCtx = 0;
1609 MkErrorC_Check(hdl,MqProxyItem (hdl, targetCtx));
1611 end: MK_UNUSED /* LONG JUMP on error */
1613}
1614
1616// MqContextC_ProxyApi_Proxy_RB_API
1617
1621
1622// doc-key: MqContextC,MqContextC-ReadApi-Atom,oci
1623
1625static OT_ProcRet NS(MqContextC_ReadALL) (MqContextC_ARGS) {
1628 MkBufferListCreateTLS_T(val_inout,10);
1631 MkErrorC_Check(hdl,MqReadALL (hdl, &val_inout));
1632 OT_retObj_SET_BFL(val_inout);
1633 end: MK_UNUSED /* LONG JUMP on error */
1635}
1636
1637// doc-key: MqContextC,MqContextC-ReadApi-Atom,oco
1638
1640static OT_ProcRet NS(MqContextC_ReadBFL) (MqContextC_ARGS) {
1644 MK_BFL val_out;
1645 MkErrorC_Check(hdl,MqReadBFL (hdl, &val_out));
1646 OT_retObj_SET_BFL(val_out);
1647 end: MK_UNUSED /* LONG JUMP on error */
1649}
1650
1652static OT_ProcRet NS(MqContextC_ReadBUF) (MqContextC_ARGS) {
1656 MK_BUF val_out;
1657 MkErrorC_Check(hdl,MqReadBUF (hdl, &val_out));
1658 OT_retObj_SET_BUF(val_out);
1659 end: MK_UNUSED /* LONG JUMP on error */
1661}
1662
1663// doc-key: MqContextC,MqContextC-ReadApi-Atom,omo
1664
1666static OT_ProcRet NS(MqContextC_ReadBIN) (MqContextC_ARGS) {
1670 MkBinaryR val_out;
1671 MkErrorC_Check(hdl,MqReadBIN (hdl, &val_out));
1672 MkBinaryR retVal = val_out;
1674 end: MK_UNUSED /* LONG JUMP on error */
1676}
1677
1679static OT_ProcRet NS(MqContextC_ReadBOL) (MqContextC_ARGS) {
1683 MK_BOL val_out;
1684 MkErrorC_Check(hdl,MqReadBOL (hdl, &val_out));
1685 OT_retObj_SET_BOL(val_out == 1);
1686 end: MK_UNUSED /* LONG JUMP on error */
1688}
1689
1691static OT_ProcRet NS(MqContextC_ReadBinaryR) (MqContextC_ARGS) {
1695 MkBinaryR val_out;
1696 MkErrorC_Check(hdl,MqReadBinaryR (hdl, &val_out));
1697 MkBinaryR retVal = val_out;
1699 end: MK_UNUSED /* LONG JUMP on error */
1701}
1702
1704static OT_ProcRet NS(MqContextC_ReadDBL) (MqContextC_ARGS) {
1708 MK_DBL val_out;
1709 MkErrorC_Check(hdl,MqReadDBL (hdl, &val_out));
1710 OT_retObj_SET_DBL(val_out);
1711 end: MK_UNUSED /* LONG JUMP on error */
1713}
1714
1716static OT_ProcRet NS(MqContextC_ReadFLT) (MqContextC_ARGS) {
1720 MK_FLT val_out;
1721 MkErrorC_Check(hdl,MqReadFLT (hdl, &val_out));
1722 OT_retObj_SET_FLT(val_out);
1723 end: MK_UNUSED /* LONG JUMP on error */
1725}
1726
1728static OT_ProcRet NS(MqContextC_ReadHDL) (MqContextC_ARGS) {
1732 MK_HDL val_out;
1733 MkErrorC_Check(hdl,MqReadHDL (hdl, &val_out));
1734 OT_retObj_SET_HDL(val_out);
1735 end: MK_UNUSED /* LONG JUMP on error */
1737}
1738
1740static OT_ProcRet NS(MqContextC_ReadI16) (MqContextC_ARGS) {
1744 MK_I16 val_out;
1745 MkErrorC_Check(hdl,MqReadI16 (hdl, &val_out));
1746 OT_retObj_SET_I16(val_out);
1747 end: MK_UNUSED /* LONG JUMP on error */
1749}
1750
1752static OT_ProcRet NS(MqContextC_ReadI32) (MqContextC_ARGS) {
1756 MK_I32 val_out;
1757 MkErrorC_Check(hdl,MqReadI32 (hdl, &val_out));
1758 OT_retObj_SET_I32(val_out);
1759 end: MK_UNUSED /* LONG JUMP on error */
1761}
1762
1764static OT_ProcRet NS(MqContextC_ReadI64) (MqContextC_ARGS) {
1768 MK_I64 val_out;
1769 MkErrorC_Check(hdl,MqReadI64 (hdl, &val_out));
1770 OT_retObj_SET_I64(val_out);
1771 end: MK_UNUSED /* LONG JUMP on error */
1773}
1774
1776static OT_ProcRet NS(MqContextC_ReadI8) (MqContextC_ARGS) {
1780 MK_I8 val_out;
1781 MkErrorC_Check(hdl,MqReadI8 (hdl, &val_out));
1782 OT_retObj_SET_I8(val_out);
1783 end: MK_UNUSED /* LONG JUMP on error */
1785}
1786
1788OT_ProcRet NS(MqContextC_ReadLIST) (MqContextC_ARGS) ; // skip template-required
1789
1791static OT_ProcRet NS(MqContextC_ReadLONG) (MqContextC_ARGS) {
1795 MK_LONG val_out;
1796 MkErrorC_Check(hdl,MqReadLONG (hdl, &val_out));
1797 OT_retObj_SET_LONG(val_out);
1798 end: MK_UNUSED /* LONG JUMP on error */
1800}
1801
1803OT_ProcRet NS(MqContextC_ReadNEXT) (MqContextC_ARGS) ; // skip template-required
1804
1806static OT_ProcRet NS(MqContextC_ReadSTR) (MqContextC_ARGS) {
1810 MK_STRN val_out;
1811 MkErrorC_Check(hdl,MqReadSTR (hdl, &val_out));
1812 OT_retObj_SET_STR(val_out);
1813 end: MK_UNUSED /* LONG JUMP on error */
1815}
1816
1818static OT_ProcRet NS(MqContextC_ReadStringR) (MqContextC_ARGS) {
1822 MkStringR val_out;
1823 MkErrorC_Check(hdl,MqReadStringR (hdl, &val_out));
1824 MkStringR retVal = val_out;
1826 end: MK_UNUSED /* LONG JUMP on error */
1828}
1829
1831// MqContextC_ReadApi_Atom_RB_API
1832
1836
1837// doc-key: MqContextC,MqContextC-ReadApi-Block,om_
1838
1840static OT_ProcRet NS(MqContextC_ReadL_END) (MqContextC_ARGS) {
1844 MkErrorC_Check(hdl,MqReadL_END (hdl));
1846 end: MK_UNUSED /* LONG JUMP on error */
1848}
1849
1851static OT_ProcRet NS(MqContextC_ReadL_START) (MqContextC_ARGS) {
1854 MK_BUF buf = NULL;
1857 MkErrorC_Check(hdl,MqReadL_START (hdl, buf));
1859 end: MK_UNUSED /* LONG JUMP on error */
1861}
1862
1864static OT_ProcRet NS(MqContextC_ReadT_END) (MqContextC_ARGS) {
1868 MkErrorC_Check(hdl,MqReadT_END (hdl));
1870 end: MK_UNUSED /* LONG JUMP on error */
1872}
1873
1875static OT_ProcRet NS(MqContextC_ReadT_START) (MqContextC_ARGS) {
1879 MkErrorC_Check(hdl,MqReadT_START (hdl));
1881 end: MK_UNUSED /* LONG JUMP on error */
1883}
1884
1886// MqContextC_ReadApi_Block_RB_API
1887
1891
1892// doc-key: MqContextC,MqContextC-ReadApi-Misc,om_
1893
1895static OT_ProcRet NS(MqContextC_ReadDbg) (MqContextC_ARGS) {
1899 MqReadDbg (hdl);
1901 end: MK_UNUSED /* LONG JUMP on error */
1903}
1904
1906static OT_ProcRet NS(MqContextC_ReadGetNextType) (MqContextC_ARGS) {
1911 end: MK_UNUSED /* LONG JUMP on error */
1913}
1914
1916static OT_ProcRet NS(MqContextC_ReadGetNumItems) (MqContextC_ARGS) {
1921 end: MK_UNUSED /* LONG JUMP on error */
1923}
1924
1926static OT_ProcRet NS(MqContextC_ReadItemExists) (MqContextC_ARGS) {
1931 end: MK_UNUSED /* LONG JUMP on error */
1933}
1934
1936static OT_ProcRet NS(MqContextC_ReadUndo) (MqContextC_ARGS) {
1940 MkErrorC_Check(hdl,MqReadUndo (hdl));
1942 end: MK_UNUSED /* LONG JUMP on error */
1944}
1945
1947// MqContextC_ReadApi_Misc_RB_API
1948
1952
1953// doc-key: MqContextC,MqContextC-RouteApi-Route,oco
1954
1956static OT_ProcRet NS(MqContextC_RouteGetTree) (MqContextC_ARGS) {
1960 MK_BFL treeP_out;
1961 MkErrorC_Check(hdl,MqRouteGetTree (hdl, &treeP_out));
1962 OT_retObj_SET_BFL(treeP_out);
1963 end: MK_UNUSED /* LONG JUMP on error */
1965}
1966
1967// doc-key: MqContextC,MqContextC-RouteApi-Route,om_
1968
1970static OT_ProcRet NS(MqContextC_RouteCreate) (MqContextC_ARGS) {
1973 MK_STRN route = 0;
1975 MK_STRN service = 0;
1977 MK_BOOL overwrite = false;
1978 OT_CHECK_OPTIONAL(OT_CHECK_bool (overwrite))
1980 MkErrorC_Check(hdl,MqRouteCreate (hdl, route, service, overwrite));
1982 end: MK_UNUSED /* LONG JUMP on error */
1984}
1985
1987static OT_ProcRet NS(MqContextC_RouteDelete) (MqContextC_ARGS) {
1990 MK_STRN route = 0;
1992 MK_STRN service = 0;
1994 MK_BOOL overwrite = false;
1995 OT_CHECK_OPTIONAL(OT_CHECK_bool (overwrite))
1997 MkErrorC_Check(hdl,MqRouteDelete (hdl, route, service, overwrite));
1999 end: MK_UNUSED /* LONG JUMP on error */
2001}
2002
2004static OT_ProcRet NS(MqContextC_RouteResolve) (MqContextC_ARGS) {
2007 MK_STRN ident = 0;
2009 MK_NUM retnum = -1;
2012 MQ_CTX_A retVal = MqRouteResolve (hdl, ident, retnum);
2014 for (int i=0; i<retVal.size; i++) {
2016 }
2017 end: MK_UNUSED /* LONG JUMP on error */
2019}
2020
2022static OT_ProcRet NS(MqContextC_RouteTraverse) (MqContextC_ARGS) {
2025 MK_STRN service = 0;
2027 MkBufferListCreateTLS_T(args,10);
2030 MkErrorC_Check(hdl,MqRouteTraverse (hdl, service, args));
2032 end: MK_UNUSED /* LONG JUMP on error */
2034}
2035
2036// doc-key: MqContextC,MqContextC-RouteApi-Route,omo
2037
2039static OT_ProcRet NS(MqContextC_RouteGetPath) (MqContextC_ARGS) {
2043 MK_STRN path_out;
2044 MkErrorC_Check(hdl,MqRouteGetPath (hdl, &path_out));
2045 OT_retObj_SET_STR(path_out);
2046 end: MK_UNUSED /* LONG JUMP on error */
2048}
2049
2051// MqContextC_RouteApi_Route_RB_API
2052
2056
2057// doc-key: MqContextC,MqContextC-SendApi-Atom,om_
2058
2060static OT_ProcRet NS(MqContextC_SendBFL) (MqContextC_ARGS) {
2066 MkErrorC_Check(hdl,MqSendBFL (hdl, val));
2068 end: MK_UNUSED /* LONG JUMP on error */
2070}
2071
2073static OT_ProcRet NS(MqContextC_SendBIN) (MqContextC_ARGS) {
2076 MkBinaryR val = {0};
2079 MkErrorC_Check(hdl,MqSendBIN (hdl, val));
2081 end: MK_UNUSED /* LONG JUMP on error */
2083}
2084
2086static OT_ProcRet NS(MqContextC_SendBOL) (MqContextC_ARGS) {
2089 MK_BOL val = 0;
2092 MkErrorC_Check(hdl,MqSendBOL (hdl, (MK_BOL)(val?1:0)));
2094 end: MK_UNUSED /* LONG JUMP on error */
2096}
2097
2099static OT_ProcRet NS(MqContextC_SendBUF) (MqContextC_ARGS) {
2102 MK_BUFN val = 0;
2105 MkErrorC_Check(hdl,MqSendBUF (hdl, val));
2107 end: MK_UNUSED /* LONG JUMP on error */
2109}
2110
2112static OT_ProcRet NS(MqContextC_SendBUS_FLAT) (MqContextC_ARGS) {
2115 MK_BUSN val = 0;
2118 MkErrorC_Check(hdl,MqSendBUS_FLAT (hdl, val));
2120 end: MK_UNUSED /* LONG JUMP on error */
2122}
2123
2125static OT_ProcRet NS(MqContextC_SendBinaryR) (MqContextC_ARGS) {
2128 MkBinaryR val = {0};
2131 MkErrorC_Check(hdl,MqSendBinaryR (hdl, val));
2133 end: MK_UNUSED /* LONG JUMP on error */
2135}
2136
2138static OT_ProcRet NS(MqContextC_SendDBL) (MqContextC_ARGS) {
2141 MK_DBL val = 0;
2144 MkErrorC_Check(hdl,MqSendDBL (hdl, val));
2146 end: MK_UNUSED /* LONG JUMP on error */
2148}
2149
2151static OT_ProcRet NS(MqContextC_SendFLT) (MqContextC_ARGS) {
2154 MK_FLT val = 0;
2157 MkErrorC_Check(hdl,MqSendFLT (hdl, val));
2159 end: MK_UNUSED /* LONG JUMP on error */
2161}
2162
2164static OT_ProcRet NS(MqContextC_SendHDL) (MqContextC_ARGS) {
2167 MK_HDL val = 0;
2170 MkErrorC_Check(hdl,MqSendHDL (hdl, val));
2172 end: MK_UNUSED /* LONG JUMP on error */
2174}
2175
2177static OT_ProcRet NS(MqContextC_SendI16) (MqContextC_ARGS) {
2180 MK_I16 val = 0;
2183 MkErrorC_Check(hdl,MqSendI16 (hdl, val));
2185 end: MK_UNUSED /* LONG JUMP on error */
2187}
2188
2190static OT_ProcRet NS(MqContextC_SendI32) (MqContextC_ARGS) {
2193 MK_I32 val = 0;
2196 MkErrorC_Check(hdl,MqSendI32 (hdl, val));
2198 end: MK_UNUSED /* LONG JUMP on error */
2200}
2201
2203static OT_ProcRet NS(MqContextC_SendI64) (MqContextC_ARGS) {
2206 MK_I64 val = 0;
2209 MkErrorC_Check(hdl,MqSendI64 (hdl, val));
2211 end: MK_UNUSED /* LONG JUMP on error */
2213}
2214
2216static OT_ProcRet NS(MqContextC_SendI8) (MqContextC_ARGS) {
2219 MK_I8 val = 0;
2222 MkErrorC_Check(hdl,MqSendI8 (hdl, (MK_I8)(val)));
2224 end: MK_UNUSED /* LONG JUMP on error */
2226}
2227
2229static OT_ProcRet NS(MqContextC_SendLONG) (MqContextC_ARGS) {
2232 MK_LONG val = 0;
2235 MkErrorC_Check(hdl,MqSendLONG (hdl, val));
2237 end: MK_UNUSED /* LONG JUMP on error */
2239}
2240
2242static OT_ProcRet NS(MqContextC_SendLTR) (MqContextC_ARGS) {
2245 MQ_LTR transLId = 0;
2248 MkErrorC_Check(hdl,MqSendLTR (hdl, transLId));
2250 end: MK_UNUSED /* LONG JUMP on error */
2252}
2253
2255static OT_ProcRet NS(MqContextC_SendL_FLAT) (MqContextC_ARGS) {
2261 MkErrorC_Check(hdl,MqSendL_FLAT (hdl, val));
2263 end: MK_UNUSED /* LONG JUMP on error */
2265}
2266
2268static OT_ProcRet NS(MqContextC_SendSTR) (MqContextC_ARGS) {
2271 MK_STRN val = 0;
2274 MkErrorC_Check(hdl,MqSendSTR (hdl, val));
2276 end: MK_UNUSED /* LONG JUMP on error */
2278}
2279
2281static OT_ProcRet NS(MqContextC_SendStringR) (MqContextC_ARGS) {
2284 MkStringR val = {0};
2287 MkErrorC_Check(hdl,MqSendStringR (hdl, val));
2289 end: MK_UNUSED /* LONG JUMP on error */
2291}
2292
2294// MqContextC_SendApi_Atom_RB_API
2295
2299
2300// doc-key: MqContextC,MqContextC-SendApi-Basics,om_
2301
2316
2318static OT_ProcRet NS(MqContextC_SendEND_AND_CALLBACK) (MqContextC_ARGS) {
2321 MQ_TOK token = 0;
2323 OT_SETUP_CALLABLE(callback)
2328 MkErrorC_Check(hdl,MqSendEND_AND_CALLBACK (hdl, token, NS(ServiceCall), callback, NS(ServiceFree), timeout));
2330 end: MK_UNUSED /* LONG JUMP on error */
2331 OT_CLEANUP_CALLABLE(callback)
2333}
2334
2336static OT_ProcRet NS(MqContextC_SendEND_AND_SUB) (MqContextC_ARGS) {
2339 MQ_TOK token = 0;
2341 OT_SETUP_CALLABLE(callback)
2346 MkErrorC_Check(hdl,MqSendEND_AND_SUB (hdl, token, NS(ServiceCall), callback, NS(ServiceFree), timeout));
2348 end: MK_UNUSED /* LONG JUMP on error */
2349 OT_CLEANUP_CALLABLE(callback)
2351}
2352
2354static OT_ProcRet NS(MqContextC_SendEND_AND_TRANSACTION) (MqContextC_ARGS) {
2357 MQ_TOK token = 0;
2359 MQ_TOK callback = 0;
2366 end: MK_UNUSED /* LONG JUMP on error */
2368}
2369
2384
2386static OT_ProcRet NS(MqContextC_SendSTART) (MqContextC_ARGS) {
2390 MkErrorC_Check(hdl,MqSendSTART (hdl));
2392 end: MK_UNUSED /* LONG JUMP on error */
2394}
2395
2397static OT_ProcRet NS(MqContextC_SendSYNC) (MqContextC_ARGS) {
2401 MkErrorC_Check(hdl,MqSendSYNC (hdl));
2403 end: MK_UNUSED /* LONG JUMP on error */
2405}
2406
2408// MqContextC_SendApi_Basics_RB_API
2409
2413
2414// doc-key: MqContextC,MqContextC-SendApi-Block,om_
2415
2417static OT_ProcRet NS(MqContextC_SendL_END) (MqContextC_ARGS) {
2421 MkErrorC_Check(hdl,MqSendL_END (hdl));
2423 end: MK_UNUSED /* LONG JUMP on error */
2425}
2426
2428static OT_ProcRet NS(MqContextC_SendL_START) (MqContextC_ARGS) {
2432 MkErrorC_Check(hdl,MqSendL_START (hdl));
2434 end: MK_UNUSED /* LONG JUMP on error */
2436}
2437
2439static OT_ProcRet NS(MqContextC_SendT_END) (MqContextC_ARGS) {
2443 MkErrorC_Check(hdl,MqSendT_END (hdl));
2445 end: MK_UNUSED /* LONG JUMP on error */
2447}
2448
2450static OT_ProcRet NS(MqContextC_SendT_START) (MqContextC_ARGS) {
2454 MkErrorC_Check(hdl,MqSendT_START (hdl));
2456 end: MK_UNUSED /* LONG JUMP on error */
2458}
2459
2461// MqContextC_SendApi_Block_RB_API
2462
2466
2467// doc-key: MqContextC,MqContextC-SendApi-Return,om_
2468
2470static OT_ProcRet NS(MqContextC_SendERROR) (MqContextC_ARGS) {
2474 MkErrorC_Check(hdl,MqSendERROR (hdl));
2476 end: MK_UNUSED /* LONG JUMP on error */
2478}
2479
2481static OT_ProcRet NS(MqContextC_SendRETURN) (MqContextC_ARGS) {
2485 MkErrorC_Check(hdl,MqSendRETURN (hdl));
2487 end: MK_UNUSED /* LONG JUMP on error */
2489}
2490
2492static OT_ProcRet NS(MqContextC_SendRETURN_SUB) (MqContextC_ARGS) {
2498 end: MK_UNUSED /* LONG JUMP on error */
2500}
2501
2503// MqContextC_SendApi_Return_RB_API
2504
2508
2509// doc-key: MqContextC,MqContextC-ServiceApi-Service,om_
2510
2512static OT_ProcRet NS(MqContextC_ServiceCreate) (MqContextC_ARGS) {
2515 MQ_TOK token = 0;
2517 OT_SETUP_CALLABLE(callback)
2520 MkErrorC_Check(hdl,MqServiceCreate (hdl, token, NS(ServiceCall), callback, NS(ServiceFree), NS(ProcMark)));
2522 end: MK_UNUSED /* LONG JUMP on error */
2523 OT_CLEANUP_CALLABLE(callback)
2525}
2526
2528static OT_ProcRet NS(MqContextC_ServiceDelete) (MqContextC_ARGS) {
2531 MQ_TOK token = 0;
2536 end: MK_UNUSED /* LONG JUMP on error */
2538}
2539
2541static OT_ProcRet NS(MqContextC_ServiceIsTransaction) (MqContextC_ARGS) {
2546 end: MK_UNUSED /* LONG JUMP on error */
2548}
2549
2551static OT_ProcRet NS(MqContextC_ServiceProxy) (MqContextC_ARGS) {
2554 MQ_TOK token = 0;
2559 MkErrorC_Check(hdl,MqServiceProxy (hdl, token, id));
2561 end: MK_UNUSED /* LONG JUMP on error */
2563}
2564
2566static OT_ProcRet NS(MqContextC_ServiceProxyCtx) (MqContextC_ARGS) {
2569 MQ_TOK token = 0;
2571 MQ_CTX target = 0;
2574 MkErrorC_Check(hdl,MqServiceProxyCtx (hdl, token, target));
2576 end: MK_UNUSED /* LONG JUMP on error */
2578}
2579
2581static OT_ProcRet NS(MqContextC_ServiceProxyCtxExists) (MqContextC_ARGS) {
2584 MQ_TOK token = 0;
2586 MQ_CTX target = 0;
2590 end: MK_UNUSED /* LONG JUMP on error */
2592}
2593
2595static OT_ProcRet NS(MqContextC_ServiceProxyRoundRobin) (MqContextC_ARGS) {
2598 MQ_TOK token = 0;
2600 MK_STRN ident = 0;
2605 end: MK_UNUSED /* LONG JUMP on error */
2607}
2608
2610static OT_ProcRet NS(MqContextC_ServiceStorage) (MqContextC_ARGS) {
2613 MQ_TOK token = 0;
2618 end: MK_UNUSED /* LONG JUMP on error */
2620}
2621
2623static OT_ProcRet NS(MqContextC_ServiceTokenCheck) (MqContextC_ARGS) {
2626 MQ_TOK token = 0;
2630 end: MK_UNUSED /* LONG JUMP on error */
2632}
2633
2635static OT_ProcRet NS(MqContextC_ServiceTokenExists) (MqContextC_ARGS) {
2638 MQ_TOK token = 0;
2642 end: MK_UNUSED /* LONG JUMP on error */
2644}
2645
2647static OT_ProcRet NS(MqContextC_ServiceTokenGet) (MqContextC_ARGS) {
2652 end: MK_UNUSED /* LONG JUMP on error */
2654}
2655
2657// MqContextC_ServiceApi_Service_RB_API
2658
2662
2663// doc-key: MqContextC,MqContextC-SlaveApi-Slave,oc_
2664
2666static OT_ProcRet NS(MqContextC_SlaveGetMaster) (MqContextC_ARGS) {
2670 MQ_CTX retVal = MqSlaveGetMaster (hdl);
2671 OT_retObj_SET_CTX(retVal);
2672 end: MK_UNUSED /* LONG JUMP on error */
2674}
2675
2676// doc-key: MqContextC,MqContextC-SlaveApi-Slave,oco
2677
2679static OT_ProcRet NS(MqContextC_SlaveGet) (MqContextC_ARGS) {
2682 MQ_SLAVE_ID id = 0;
2685 MQ_CTX ctx_out;
2686 MkErrorC_Check(hdl,MqSlaveGet (hdl, id, &ctx_out));
2687 OT_retObj_SET_CTX(ctx_out);
2688 end: MK_UNUSED /* LONG JUMP on error */
2690}
2691
2693static OT_ProcRet NS(MqContextC_SlaveGetFilter) (MqContextC_ARGS) {
2697 MQ_CTX ctx_out;
2698 MkErrorC_Check(hdl,MqSlaveGetFilter (hdl, &ctx_out));
2699 OT_retObj_SET_CTX(ctx_out);
2700 end: MK_UNUSED /* LONG JUMP on error */
2702}
2703
2705static OT_ProcRet NS(MqContextC_SlaveGetProxy) (MqContextC_ARGS) {
2708 MQ_SLAVE_ID id = 0;
2711 MQ_CTX ctx_out;
2712 MkErrorC_Check(hdl,MqSlaveGetProxy (hdl, id, &ctx_out));
2713 OT_retObj_SET_CTX(ctx_out);
2714 end: MK_UNUSED /* LONG JUMP on error */
2716}
2717
2718// doc-key: MqContextC,MqContextC-SlaveApi-Slave,om_
2719
2721static OT_ProcRet NS(MqContextC_SlaveCheck) (MqContextC_ARGS) {
2724 MQ_SLAVE_ID id = 0;
2728 end: MK_UNUSED /* LONG JUMP on error */
2730}
2731
2733static OT_ProcRet NS(MqContextC_SlaveCreate) (MqContextC_ARGS) {
2736 MQ_SLAVE_ID id = 0;
2738 MQ_CTX slave = 0;
2741 MkErrorC_Check(hdl,MqSlaveCreate (hdl, id, slave));
2743 end: MK_UNUSED /* LONG JUMP on error */
2745}
2746
2748static OT_ProcRet NS(MqContextC_SlaveDelete) (MqContextC_ARGS) {
2751 MQ_SLAVE_ID id = 0;
2754 MkErrorC_Check(hdl,MqSlaveDelete (hdl, id));
2756 end: MK_UNUSED /* LONG JUMP on error */
2758}
2759
2761static OT_ProcRet NS(MqContextC_SlaveIs) (MqContextC_ARGS) {
2766 end: MK_UNUSED /* LONG JUMP on error */
2768}
2769
2771static OT_ProcRet NS(MqContextC_SlaveWorker) (MqContextC_ARGS) {
2774 MQ_SLAVE_ID id = 0;
2776 MK_STRN fct = "WORKER";
2778 MkBufferListCreateTLS_T(args,10);
2781 MkErrorC_Check(hdl,MqSlaveWorker (hdl, id, fct, args));
2783 end: MK_UNUSED /* LONG JUMP on error */
2785}
2786
2788// MqContextC_SlaveApi_Slave_RB_API
2789
2793
2794// doc-key: MqContextC,MqContextC-StorageApi-Storage,oci
2795
2797static OT_ProcRet NS(MqContextC_StorageDelete) (MqContextC_ARGS) {
2800 MQ_LTR transLIdP_inout = 0;
2801 OT_CHECK_OPTIONAL(OT_CHECK_NI4 (transLIdP_inout))
2803 MkErrorC_Check(hdl,MqStorageDelete (hdl, &transLIdP_inout));
2804 OT_retObj_SET_I32(transLIdP_inout);
2805 end: MK_UNUSED /* LONG JUMP on error */
2807}
2808
2810static OT_ProcRet NS(MqContextC_StorageImport) (MqContextC_ARGS) {
2813 MQ_LTR transLIdP_inout = 0;
2814 OT_CHECK_OPTIONAL(OT_CHECK_NI4 (transLIdP_inout))
2816 MkErrorC_Check(hdl,MqStorageImport (hdl, &transLIdP_inout));
2817 OT_retObj_SET_I32(transLIdP_inout);
2818 end: MK_UNUSED /* LONG JUMP on error */
2820}
2821
2822// doc-key: MqContextC,MqContextC-StorageApi-Storage,om_
2823
2825static OT_ProcRet NS(MqContextC_StorageClose) (MqContextC_ARGS) {
2829 MkErrorC_Check(hdl,MqStorageClose (hdl));
2831 end: MK_UNUSED /* LONG JUMP on error */
2833}
2834
2836static OT_ProcRet NS(MqContextC_StorageDecrRef) (MqContextC_ARGS) {
2839 MQ_LTR transLId = 0;
2842 MkErrorC_Check(hdl,MqStorageDecrRef (hdl, transLId));
2844 end: MK_UNUSED /* LONG JUMP on error */
2846}
2847
2849static OT_ProcRet NS(MqContextC_StorageIncrRef) (MqContextC_ARGS) {
2852 MQ_LTR transLId = 0;
2855 MkErrorC_Check(hdl,MqStorageIncrRef (hdl, transLId));
2857 end: MK_UNUSED /* LONG JUMP on error */
2859}
2860
2862static OT_ProcRet NS(MqContextC_StorageLog) (MqContextC_ARGS) {
2865 MK_STRN callfunc = NULL;
2868 if (MkSysStringIsNULL(callfunc)) {callfunc = OT_GET_CALL_PROC;}
2869 MkErrorC_Check(hdl,MqStorageLog (hdl, callfunc));
2871 end: MK_UNUSED /* LONG JUMP on error */
2874}
2875
2877static OT_ProcRet NS(MqContextC_StorageOpen) (MqContextC_ARGS) {
2880 MK_STRN storageFile = 0;
2881 OT_CHECK_REQUIRED(OT_CHECK_STRN (storageFile))
2883 MkErrorC_Check(hdl,MqStorageOpen (hdl, storageFile));
2885 end: MK_UNUSED /* LONG JUMP on error */
2887}
2888
2889// doc-key: MqContextC,MqContextC-StorageApi-Storage,omo
2890
2892static OT_ProcRet NS(MqContextC_StorageCount) (MqContextC_ARGS) {
2896 MQ_LTR cnt_out;
2897 MkErrorC_Check(hdl,MqStorageCount (hdl, &cnt_out));
2898 OT_retObj_SET_I32(cnt_out);
2899 end: MK_UNUSED /* LONG JUMP on error */
2901}
2902
2904static OT_ProcRet NS(MqContextC_StorageErrCnt) (MqContextC_ARGS) {
2907 MQ_LTR transLId = 0;
2910 MK_I32 cnt_out;
2911 MkErrorC_Check(hdl,MqStorageErrCnt (hdl, transLId, &cnt_out));
2912 OT_retObj_SET_I32(cnt_out);
2913 end: MK_UNUSED /* LONG JUMP on error */
2915}
2916
2918static OT_ProcRet NS(MqContextC_StorageExport) (MqContextC_ARGS) {
2922 MQ_LTR ltid_out;
2923 MkErrorC_Check(hdl,MqStorageExport (hdl, &ltid_out));
2924 OT_retObj_SET_I32(ltid_out);
2925 end: MK_UNUSED /* LONG JUMP on error */
2927}
2928
2930static OT_ProcRet NS(MqContextC_StorageResolve) (MqContextC_ARGS) {
2934 MQ_CTX otherCtxP_out;
2935 MQ_LTR otherLIdP_out;
2936 MkErrorC_Check(hdl,MqStorageResolve (hdl, &otherCtxP_out, &otherLIdP_out));
2938 OT_retObj_APPEND(OT_TMP_CTX_OBJ(otherCtxP_out));
2939 OT_retObj_APPEND(OT_TMP_I32_OBJ(otherLIdP_out));
2940 end: MK_UNUSED /* LONG JUMP on error */
2942}
2943
2945// MqContextC_StorageApi_Storage_RB_API
2946
2950
2951// doc-key: MqContextC,MqContextC-TOR,sCc
2952
2954static OT_ProcRet NS(MqContextC_Create) (OtClass_ARGS) {
2957 MQ_CTX tmpl = NULL;
2960 MQ_CTX retVal = MqContextCreate (MqContextCTT, tmpl);
2961 if (retVal == NULL) {
2962 OT_ERROR_CONSTRUCTOR(MqContextC);
2963 }
2964 OT_CONSTRUCTOR_POST(retVal)
2965 OT_retObj_SET_CTX(retVal);
2966 end: MK_UNUSED /* LONG JUMP on error */
2968}
2969
2971static OT_ProcRet NS(MqContextC_new) (CONSTR_ARGS) {
2974 MQ_CTX tmpl = NULL;
2976 MQ_CTX retVal = MqContextCreate (MqContextCTT, tmpl);
2977 if (retVal == NULL) {
2978 OT_ERROR_CONSTRUCTOR(MqContextC);
2979 }
2980 OT_CONSTRUCTOR_POST(retVal)
2981 OT_retObj_CONSTR(retVal);
2982 end: MK_UNUSED /* LONG JUMP on error */
2984}
2985
2987// MqContextC_TOR_RB_API
2988
2989// END-MqContextC - created by 'rb_MqC.tcl -i NHI1_HOME/theLink/c/gen/c_mqmsgque.meta' - DO NOT change
2990
2991/*****************************************************************************/
2992/* */
2993/* public */
2994/* */
2995/*****************************************************************************/
2996
2997static enum MkErrorE NS(Idle) (
2999 MQ_CTX const ctx,
3000 MK_PTR const data
3001) {
3002 rb_thread_schedule();
3003 return MK_OK;
3004}
3005
3006static void NS(sMark) (MK_MNG mng)
3007{
3008 MQ_CTX mqctx = MqCtx(mng);
3011}
3012
3013static void NS(MarkData) (MK_RT_ARGS MK_PTR data) {
3014 rb_gc_mark((VALUE)data);
3015}
3016
3017void NS(MqContextC_Init) (MQ_RT_ARGS_ONLY) {
3018
3019 // init type
3020 MqContextCTT = MkTypeDup2(MqContextC_TT, "RbMqContextC");
3021 MqContextCT->argvFix = true;
3022 // https://stackoverflow.com/questions/26488029/embeded-ruby-in-a-cpp-thread-crashes
3023 // It fails because the Ruby VM is not thread safe
3024 MqContextCT->ignoreThread = true;
3025 MqContextCT->Idle.fCall = NS(Idle);
3026 MqContextCT->dataMF = NS(MarkData);
3027 MqContextCT->callbackMF = NS(ProcMark);
3028
3029 S_INIT;
3030
3031 // init class
3032
3033// BEGIN-CLASS - created by 'rb_MqS.tcl -i NHI1_HOME/theLink/c/gen/c_mqmsgque.meta' - DO NOT change
3034
3035// doc-key: MqContextC,MqContext,sCc
3036OT_METH_S ( MqContextC, Create, MqContextC_Create )
3037OT_METH_C ( MqContextC, new, MqContextC_new )
3038
3039// doc-key: MqContextC,MqContext,sc_
3040OT_METH_O ( MqContextC, GetNull, MqContextC_GetNull )
3041OT_METH_S ( MqContextC, GetNull, MqContextC_GetNull )
3042OT_METH_O ( MqContextC, HandleResolve, MqContextC_HandleResolve )
3043OT_METH_S ( MqContextC, HandleResolve, MqContextC_HandleResolve )
3044OT_METH_O ( MqContextC, Instances, MqContextC_Instances )
3045OT_METH_S ( MqContextC, Instances, MqContextC_Instances )
3046
3047// END-CLASS - created by 'rb_MqS.tcl -i NHI1_HOME/theLink/c/gen/c_mqmsgque.meta' - DO NOT change
3048
3049// BEGIN-OBJ - created by 'rb_MqS.tcl -i NHI1_HOME/theLink/c/gen/c_mqmsgque.meta' - DO NOT change
3050
3051// doc-key: MqContextC,MqClass,oc_
3052OT_METH_O ( MqContextC, ClassFactoryGet, MqContextC_ClassFactoryGet )
3053
3054// doc-key: MqContextC,MqClass,om_
3055OT_METH_O ( MqContextC, ClassFactorySet, MqContextC_ClassFactorySet )
3056OT_METH_O ( MqContextC, ClassIdentGet, MqContextC_ClassIdentGet )
3057OT_METH_O ( MqContextC, ClassIdentSet, MqContextC_ClassIdentSet )
3058OT_METH_O ( MqContextC, ClassOriginalIdentGet, MqContextC_ClassOriginalIdentGet )
3059
3060// doc-key: MqContextC,MqConfig,oco
3061OT_METH_O ( MqContextC, ConfigGetIoTcpL, MqContextC_ConfigGetIoTcpL )
3062
3063// doc-key: MqContextC,MqConfig,om_
3064OT_METH_O ( MqContextC, ConfigCheckStartAs, MqContextC_ConfigCheckStartAs )
3065OT_METH_O ( MqContextC, ConfigGetBuffersize, MqContextC_ConfigGetBuffersize )
3066OT_METH_O ( MqContextC, ConfigGetIdentFrom, MqContextC_ConfigGetIdentFrom )
3067OT_METH_O ( MqContextC, ConfigGetIoPipe, MqContextC_ConfigGetIoPipe )
3068OT_METH_O ( MqContextC, ConfigGetIoUds, MqContextC_ConfigGetIoUds )
3069OT_METH_O ( MqContextC, ConfigGetIsParent, MqContextC_ConfigGetIsParent )
3070OT_METH_O ( MqContextC, ConfigGetIsServer, MqContextC_ConfigGetIsServer )
3071OT_METH_O ( MqContextC, ConfigGetIsString, MqContextC_ConfigGetIsString )
3072OT_METH_O ( MqContextC, ConfigGetName, MqContextC_ConfigGetName )
3073OT_METH_O ( MqContextC, ConfigGetPkgsize, MqContextC_ConfigGetPkgsize )
3074OT_METH_O ( MqContextC, ConfigGetPostfix, MqContextC_ConfigGetPostfix )
3075OT_METH_O ( MqContextC, ConfigGetPrefix, MqContextC_ConfigGetPrefix )
3076OT_METH_O ( MqContextC, ConfigGetStartAs, MqContextC_ConfigGetStartAs )
3077OT_METH_O ( MqContextC, ConfigGetStatusIs, MqContextC_ConfigGetStatusIs )
3078OT_METH_O ( MqContextC, ConfigGetStorage, MqContextC_ConfigGetStorage )
3079OT_METH_O ( MqContextC, ConfigGetTimeout, MqContextC_ConfigGetTimeout )
3080OT_METH_O ( MqContextC, ConfigReset, MqContextC_ConfigReset )
3081OT_METH_O ( MqContextC, ConfigSetAllDebug, MqContextC_ConfigSetAllDebug )
3082OT_METH_O ( MqContextC, ConfigSetBgError, MqContextC_ConfigSetBgError )
3083OT_METH_O ( MqContextC, ConfigSetBuffersize, MqContextC_ConfigSetBuffersize )
3084OT_METH_O ( MqContextC, ConfigSetConfigFile, MqContextC_ConfigSetConfigFile )
3085OT_METH_O ( MqContextC, ConfigSetDaemon, MqContextC_ConfigSetDaemon )
3086OT_METH_O ( MqContextC, ConfigSetEvent, MqContextC_ConfigSetEvent )
3087OT_METH_O ( MqContextC, ConfigSetIdentFrom, MqContextC_ConfigSetIdentFrom )
3088OT_METH_O ( MqContextC, ConfigSetIgnoreExit, MqContextC_ConfigSetIgnoreExit )
3089OT_METH_O ( MqContextC, ConfigSetIoPipe, MqContextC_ConfigSetIoPipe )
3090OT_METH_O ( MqContextC, ConfigSetIoTcp, MqContextC_ConfigSetIoTcp )
3091OT_METH_O ( MqContextC, ConfigSetIoTcpL, MqContextC_ConfigSetIoTcpL )
3092OT_METH_O ( MqContextC, ConfigSetIoUds, MqContextC_ConfigSetIoUds )
3093OT_METH_O ( MqContextC, ConfigSetIsServer, MqContextC_ConfigSetIsServer )
3094OT_METH_O ( MqContextC, ConfigSetIsString, MqContextC_ConfigSetIsString )
3095OT_METH_O ( MqContextC, ConfigSetName, MqContextC_ConfigSetName )
3096OT_METH_O ( MqContextC, ConfigSetPkgsize, MqContextC_ConfigSetPkgsize )
3097OT_METH_O ( MqContextC, ConfigSetPostfix, MqContextC_ConfigSetPostfix )
3098OT_METH_O ( MqContextC, ConfigSetPrefix, MqContextC_ConfigSetPrefix )
3099OT_METH_O ( MqContextC, ConfigSetServerCleanup, MqContextC_ConfigSetServerCleanup )
3100OT_METH_O ( MqContextC, ConfigSetServerSetup, MqContextC_ConfigSetServerSetup )
3101OT_METH_O ( MqContextC, ConfigSetStartAs, MqContextC_ConfigSetStartAs )
3102OT_METH_O ( MqContextC, ConfigSetStartAsString, MqContextC_ConfigSetStartAsString )
3103OT_METH_O ( MqContextC, ConfigSetStorage, MqContextC_ConfigSetStorage )
3104OT_METH_O ( MqContextC, ConfigSetTimeout, MqContextC_ConfigSetTimeout )
3105
3106// doc-key: MqContextC,MqConfig,omo
3107OT_METH_O ( MqContextC, ConfigGetIoTcp, MqContextC_ConfigGetIoTcp )
3108
3109// doc-key: MqContextC,MqContext,oc_
3110OT_METH_O ( MqContextC, ErrorFORMAT, MqContextC_ErrorFORMAT )
3111OT_METH_O ( MqContextC, GetBuffer, MqContextC_GetBuffer )
3112OT_METH_O ( MqContextC, Next, MqContextC_Next )
3113OT_METH_O ( MqContextC, Prev, MqContextC_Prev )
3114
3115// doc-key: MqContextC,MqContext,om_
3116OT_METH_O ( MqContextC, ErrorCopy, MqContextC_ErrorCopy )
3117OT_METH_O ( MqContextC, ErrorMove, MqContextC_ErrorMove )
3118// skip class-overload: MqContextHandleGet → HandleGet, MqContextC_HandleGet
3119// skip class-overload: MqContextLog → Log, MqContextC_Log
3120OT_METH_O ( MqContextC, LogConfig, MqContextC_LogConfig )
3121OT_METH_O ( MqContextC, LogEnv, MqContextC_LogEnv )
3122OT_METH_O ( MqContextC, LogLink, MqContextC_LogLink )
3123OT_METH_O ( MqContextC, LogSetup, MqContextC_LogSetup )
3124OT_METH_O ( MqContextC, LogShort, MqContextC_LogShort )
3125OT_METH_O ( MqContextC, LogType, MqContextC_LogType )
3126// skip class-overload: MqContextToString → ToString, MqContextC_ToString
3127
3128// doc-key: MqContextC,MqEnv,om_
3129OT_METH_O ( MqContextC, EnvProtect, MqContextC_EnvProtect )
3130OT_METH_O ( MqContextC, EnvRestore, MqContextC_EnvRestore )
3131
3132// doc-key: MqContextC,MqExit,om_
3133OT_METH_O ( MqContextC, Exit, MqContextC_Exit )
3134
3135// doc-key: MqContextC,MqGet,oc_
3136OT_METH_O ( MqContextC, GetRoot, MqContextC_GetRoot )
3137
3138// doc-key: MqContextC,MqLink,oc_
3139OT_METH_O ( MqContextC, LinkGetParent, MqContextC_LinkGetParent )
3140
3141// doc-key: MqContextC,MqLink,om_
3142OT_METH_O ( MqContextC, LinkConnect, MqContextC_LinkConnect )
3143OT_METH_O ( MqContextC, LinkCreate, MqContextC_LinkCreate )
3144OT_METH_O ( MqContextC, LinkCreateChild, MqContextC_LinkCreateChild )
3145OT_METH_O ( MqContextC, LinkDelete, MqContextC_LinkDelete )
3146OT_METH_O ( MqContextC, LinkGetCtxId, MqContextC_LinkGetCtxId )
3147OT_METH_O ( MqContextC, LinkGetTargetIdent, MqContextC_LinkGetTargetIdent )
3148OT_METH_O ( MqContextC, LinkIsConnected, MqContextC_LinkIsConnected )
3149OT_METH_O ( MqContextC, LinkIsParent, MqContextC_LinkIsParent )
3150OT_METH_O ( MqContextC, LinkShutdown, MqContextC_LinkShutdown )
3151
3152// doc-key: MqContextC,MqLog,om_
3153OT_METH_O ( MqContextC, LogParentOrChild, MqContextC_LogParentOrChild )
3154OT_METH_O ( MqContextC, LogServerOrClient, MqContextC_LogServerOrClient )
3155
3156// doc-key: MqContextC,MqProcess,om_
3157OT_METH_O ( MqContextC, ProcessEvent, MqContextC_ProcessEvent )
3158
3159// doc-key: MqContextC,MqProxy,om_
3160OT_METH_O ( MqContextC, ProxyForward, MqContextC_ProxyForward )
3161OT_METH_O ( MqContextC, ProxyItem, MqContextC_ProxyItem )
3162
3163// doc-key: MqContextC,MqRead,oci
3164OT_METH_O ( MqContextC, ReadALL, MqContextC_ReadALL )
3165
3166// doc-key: MqContextC,MqRead,oco
3167OT_METH_O ( MqContextC, ReadBFL, MqContextC_ReadBFL )
3168OT_METH_O ( MqContextC, ReadBUF, MqContextC_ReadBUF )
3169
3170// doc-key: MqContextC,MqRead,om_
3171OT_METH_O ( MqContextC, ReadDbg, MqContextC_ReadDbg )
3172OT_METH_O ( MqContextC, ReadGetNextType, MqContextC_ReadGetNextType )
3173OT_METH_O ( MqContextC, ReadGetNumItems, MqContextC_ReadGetNumItems )
3174OT_METH_O ( MqContextC, ReadItemExists, MqContextC_ReadItemExists )
3175OT_METH_O ( MqContextC, ReadL_END, MqContextC_ReadL_END )
3176OT_METH_O ( MqContextC, ReadL_START, MqContextC_ReadL_START )
3177OT_METH_O ( MqContextC, ReadT_END, MqContextC_ReadT_END )
3178OT_METH_O ( MqContextC, ReadT_START, MqContextC_ReadT_START )
3179OT_METH_O ( MqContextC, ReadUndo, MqContextC_ReadUndo )
3180
3181// doc-key: MqContextC,MqRead,omo
3182OT_METH_O ( MqContextC, ReadBIN, MqContextC_ReadBIN )
3183OT_METH_O ( MqContextC, ReadBOL, MqContextC_ReadBOL )
3184OT_METH_O ( MqContextC, ReadBinaryR, MqContextC_ReadBinaryR )
3185OT_METH_O ( MqContextC, ReadDBL, MqContextC_ReadDBL )
3186OT_METH_O ( MqContextC, ReadFLT, MqContextC_ReadFLT )
3187OT_METH_O ( MqContextC, ReadHDL, MqContextC_ReadHDL )
3188OT_METH_O ( MqContextC, ReadI16, MqContextC_ReadI16 )
3189OT_METH_O ( MqContextC, ReadI32, MqContextC_ReadI32 )
3190OT_METH_O ( MqContextC, ReadI64, MqContextC_ReadI64 )
3191OT_METH_O ( MqContextC, ReadI8, MqContextC_ReadI8 )
3192OT_METH_O ( MqContextC, ReadLIST, MqContextC_ReadLIST )
3193OT_METH_O ( MqContextC, ReadLONG, MqContextC_ReadLONG )
3194OT_METH_O ( MqContextC, ReadNEXT, MqContextC_ReadNEXT )
3195OT_METH_O ( MqContextC, ReadSTR, MqContextC_ReadSTR )
3196OT_METH_O ( MqContextC, ReadStringR, MqContextC_ReadStringR )
3197
3198// doc-key: MqContextC,MqRoute,oco
3199OT_METH_O ( MqContextC, RouteGetTree, MqContextC_RouteGetTree )
3200
3201// doc-key: MqContextC,MqRoute,om_
3202OT_METH_O ( MqContextC, RouteCreate, MqContextC_RouteCreate )
3203OT_METH_O ( MqContextC, RouteDelete, MqContextC_RouteDelete )
3204OT_METH_O ( MqContextC, RouteResolve, MqContextC_RouteResolve )
3205OT_METH_O ( MqContextC, RouteTraverse, MqContextC_RouteTraverse )
3206
3207// doc-key: MqContextC,MqRoute,omo
3208OT_METH_O ( MqContextC, RouteGetPath, MqContextC_RouteGetPath )
3209
3210// doc-key: MqContextC,MqSend,om_
3211OT_METH_O ( MqContextC, Send, MqContextC_Send )
3212OT_METH_O ( MqContextC, SendBFL, MqContextC_SendBFL )
3213OT_METH_O ( MqContextC, SendBIN, MqContextC_SendBIN )
3214OT_METH_O ( MqContextC, SendBOL, MqContextC_SendBOL )
3215OT_METH_O ( MqContextC, SendBUF, MqContextC_SendBUF )
3216OT_METH_O ( MqContextC, SendBUS_FLAT, MqContextC_SendBUS_FLAT )
3217OT_METH_O ( MqContextC, SendBinaryR, MqContextC_SendBinaryR )
3218OT_METH_O ( MqContextC, SendDBL, MqContextC_SendDBL )
3219OT_METH_O ( MqContextC, SendEND, MqContextC_SendEND )
3220OT_METH_O ( MqContextC, SendEND_AND_CALLBACK, MqContextC_SendEND_AND_CALLBACK )
3221OT_METH_O ( MqContextC, SendEND_AND_SUB, MqContextC_SendEND_AND_SUB )
3222OT_METH_O ( MqContextC, SendEND_AND_TRANSACTION, MqContextC_SendEND_AND_TRANSACTION )
3223OT_METH_O ( MqContextC, SendEND_AND_WAIT, MqContextC_SendEND_AND_WAIT )
3224OT_METH_O ( MqContextC, SendERROR, MqContextC_SendERROR )
3225OT_METH_O ( MqContextC, SendFLT, MqContextC_SendFLT )
3226OT_METH_O ( MqContextC, SendHDL, MqContextC_SendHDL )
3227OT_METH_O ( MqContextC, SendI16, MqContextC_SendI16 )
3228OT_METH_O ( MqContextC, SendI32, MqContextC_SendI32 )
3229OT_METH_O ( MqContextC, SendI64, MqContextC_SendI64 )
3230OT_METH_O ( MqContextC, SendI8, MqContextC_SendI8 )
3231OT_METH_O ( MqContextC, SendLONG, MqContextC_SendLONG )
3232OT_METH_O ( MqContextC, SendLTR, MqContextC_SendLTR )
3233OT_METH_O ( MqContextC, SendL_END, MqContextC_SendL_END )
3234OT_METH_O ( MqContextC, SendL_FLAT, MqContextC_SendL_FLAT )
3235OT_METH_O ( MqContextC, SendL_START, MqContextC_SendL_START )
3236OT_METH_O ( MqContextC, SendRETURN, MqContextC_SendRETURN )
3237OT_METH_O ( MqContextC, SendRETURN_SUB, MqContextC_SendRETURN_SUB )
3238OT_METH_O ( MqContextC, SendSTART, MqContextC_SendSTART )
3239OT_METH_O ( MqContextC, SendSTR, MqContextC_SendSTR )
3240OT_METH_O ( MqContextC, SendSYNC, MqContextC_SendSYNC )
3241OT_METH_O ( MqContextC, SendStringR, MqContextC_SendStringR )
3242OT_METH_O ( MqContextC, SendT_END, MqContextC_SendT_END )
3243OT_METH_O ( MqContextC, SendT_START, MqContextC_SendT_START )
3244
3245// doc-key: MqContextC,MqService,om_
3246OT_METH_O ( MqContextC, ServiceCreate, MqContextC_ServiceCreate )
3247OT_METH_O ( MqContextC, ServiceDelete, MqContextC_ServiceDelete )
3248OT_METH_O ( MqContextC, ServiceIsTransaction, MqContextC_ServiceIsTransaction )
3249OT_METH_O ( MqContextC, ServiceProxy, MqContextC_ServiceProxy )
3250OT_METH_O ( MqContextC, ServiceProxyCtx, MqContextC_ServiceProxyCtx )
3251OT_METH_O ( MqContextC, ServiceProxyCtxExists, MqContextC_ServiceProxyCtxExists )
3252OT_METH_O ( MqContextC, ServiceProxyRoundRobin, MqContextC_ServiceProxyRoundRobin )
3253OT_METH_O ( MqContextC, ServiceStorage, MqContextC_ServiceStorage )
3254OT_METH_O ( MqContextC, ServiceTokenCheck, MqContextC_ServiceTokenCheck )
3255OT_METH_O ( MqContextC, ServiceTokenExists, MqContextC_ServiceTokenExists )
3256OT_METH_O ( MqContextC, ServiceTokenGet, MqContextC_ServiceTokenGet )
3257
3258// doc-key: MqContextC,MqSlave,oc_
3259OT_METH_O ( MqContextC, SlaveGetMaster, MqContextC_SlaveGetMaster )
3260
3261// doc-key: MqContextC,MqSlave,oco
3262OT_METH_O ( MqContextC, SlaveGet, MqContextC_SlaveGet )
3263OT_METH_O ( MqContextC, SlaveGetFilter, MqContextC_SlaveGetFilter )
3264OT_METH_O ( MqContextC, SlaveGetProxy, MqContextC_SlaveGetProxy )
3265
3266// doc-key: MqContextC,MqSlave,om_
3267OT_METH_O ( MqContextC, SlaveCheck, MqContextC_SlaveCheck )
3268OT_METH_O ( MqContextC, SlaveCreate, MqContextC_SlaveCreate )
3269OT_METH_O ( MqContextC, SlaveDelete, MqContextC_SlaveDelete )
3270OT_METH_O ( MqContextC, SlaveIs, MqContextC_SlaveIs )
3271OT_METH_O ( MqContextC, SlaveWorker, MqContextC_SlaveWorker )
3272
3273// doc-key: MqContextC,MqStorage,oci
3274OT_METH_O ( MqContextC, StorageDelete, MqContextC_StorageDelete )
3275OT_METH_O ( MqContextC, StorageImport, MqContextC_StorageImport )
3276
3277// doc-key: MqContextC,MqStorage,om_
3278OT_METH_O ( MqContextC, StorageClose, MqContextC_StorageClose )
3279OT_METH_O ( MqContextC, StorageDecrRef, MqContextC_StorageDecrRef )
3280OT_METH_O ( MqContextC, StorageIncrRef, MqContextC_StorageIncrRef )
3281OT_METH_O ( MqContextC, StorageLog, MqContextC_StorageLog )
3282OT_METH_O ( MqContextC, StorageOpen, MqContextC_StorageOpen )
3283
3284// doc-key: MqContextC,MqStorage,omo
3285OT_METH_O ( MqContextC, StorageCount, MqContextC_StorageCount )
3286OT_METH_O ( MqContextC, StorageErrCnt, MqContextC_StorageErrCnt )
3287OT_METH_O ( MqContextC, StorageExport, MqContextC_StorageExport )
3288OT_METH_O ( MqContextC, StorageResolve, MqContextC_StorageResolve )
3289
3290// END-OBJ - created by 'rb_MqS.tcl -i NHI1_HOME/theLink/c/gen/c_mqmsgque.meta' - DO NOT change
3291}
#define OT_CHECK_NI1(val)
#define OT_CHECK_bool(val)
#define OT_retObj_SET_I8(nat)
#define MK(n)
#define OT_retObj_SET_FLT(nat)
#define OT_SETUP_VARARGS(min, max, d)
#define OT_retObj_SET_BOL(nat)
#define OT_SETUP_NOARG(d)
#define OT_SETUP_ONEARG(d)
#define OT_NEW_Mk_enum_OBJ(typ, i)
#define OT_ERROR_LNG_RETURN
#define PTR2VAL(nat)
#define OT_CHECK_NI4(val)
#define OT_CHECK_NI8(val)
#define OT_retObj_SET_I16(nat)
#define OT_CHECK_NF8(val)
#define OT_CONSTRUCTOR_POST(x)
#define OT_GET_CALL_LINE
#define OT_METH_S(c, s, f)
#define OT_CHECK_NIL(val)
#define MK_BASE_CLASS
#define OT_CLS_T
#define OT_FRAME_CLEANUP
#define OT_retObj_SET_BUF(nat)
#define OT_retObj_SET_DBL(nat)
#define OT_retObj_SET_I64(nat)
#define OT_retObj_SET_LONG(nat)
#define OT_retObj_SET_List
#define OT_retObj_CONSTR(mng)
#define OT_retObj_SET_HDL(nat)
#define OT_CHECK_REQUIRED(val)
#define OT_retObj_SET_None
#define OT_retObj_SET_I32(nat)
#define OT_METH_O(c, s, f)
#define OT_GET_CALL_FILE
#define OT_SETUP_CONSTRUCTOR_ARGS(min, max, d)
#define INCR_REF(valP)
#define OT_CHECK_NF4(val)
#define OT_OBJ_T
#define OT_retObj_SET_BFL(nat)
#define OT_TMP_I32_OBJ(val)
#define OT_GET__ME_REF_MkBinaryR(b)
#define OT_retObj_RETURN
#define OT_GET_CALL_PROC
#define OT_retObj_APPEND(var)
#define OT_CHECK__ME_REF_MkStringR(val)
#define OT_CHECK__ME_REF_MkBinaryR(val)
#define OT_CHECK_NI2(val)
#define OT_OBJECT_DELETE_HARD(obj)
#define OT_retObj_SET_STR(nat)
#define OT_ERROR_CONSTRUCTOR(clazz)
#define OT_CHECK_NB1(val)
#define OT_CHECK_OPTIONAL(val)
#define OT_TMP_STR_OBJ(val)
#define OT_retObj_SET_ERR(nat)
#define OT_retObj_SET(val)
#define VAL2PTR(val)
#define OT_CHECK_NOARGS
#define MkErrorC_Check(mng, PROC)
#define OT_ProcRet
#define OT_GET__ME_REF_MkStringR(b)
#define OT_METH_C(c, s, f)
#define CONSTR_ARGS
#define OtClass_ARGS
#define OT_CHECK_STRN(val)
tag: nhi1-release-250425
#define MqContextC_MK_NULL
#define OT_PKG
#define OT_retObj_SET_CTX(nat)
#define MQ(n)
#define NS(n)
#define OT_NEW_Mq_enum_OBJ(typ, i)
#define OT_retObj_SET_FCT(nat)
#define MqContextC_ARGS
#define OT_TMP_CTX_OBJ(val)
tag: nhi1-release-250425
tag: nhi1-release-250425
#define ConfigGetStartAs_doc
#define ServiceTokenGet_doc
#define Instances_doc
#define ConfigGetIoTcp_doc
#define ProxyItem_doc
#define ConfigGetName_doc
#define SlaveCreate_doc
#define LogShort_doc
#define RouteCreate_doc
#define ConfigSetIoPipe_doc
#define ReadBIN_doc
#define ReadBUF_doc
#define ConfigGetIsString_doc
#define SendT_START_doc
#define LogType_doc
#define SendLONG_doc
#define StorageDelete_doc
#define SendBinaryR_doc
#define ServiceProxy_doc
#define OT_SETUP_hdl_static_constr
#define ConfigSetIgnoreExit_doc
#define ConfigSetBgError_doc
#define SendEND_AND_WAIT_doc
#define ClassOriginalIdentGet_doc
#define StorageClose_doc
#define ServiceProxyRoundRobin_doc
#define ConfigCheckStartAs_doc
#define RouteDelete_doc
#define ConfigSetName_doc
#define StorageIncrRef_doc
#define ConfigSetIdentFrom_doc
#define ClassFactoryGet_doc
#define SlaveWorker_doc
#define SendSTART_doc
#define ReadUndo_doc
#define ProxyForward_doc
#define ReadBFL_doc
#define LinkDelete_doc
#define ConfigGetStatusIs_doc
#define SendL_END_doc
#define ConfigSetDaemon_doc
#define StorageDecrRef_doc
#define ConfigGetPrefix_doc
#define SlaveGetProxy_doc
#define ConfigSetAllDebug_doc
#define OT_SETUP_hdl
#define ReadI64_doc
#define LinkCreateChild_doc
#define ConfigSetBuffersize_doc
#define ServiceStorage_doc
#define GetBuffer_doc
#define GetRoot_doc
#define ConfigGetIdentFrom_doc
#define SendERROR_doc
#define ServiceTokenCheck_doc
#define ReadI32_doc
#define SlaveGetFilter_doc
#define ReadGetNextType_doc
#define ErrorFORMAT_doc
#define ServiceDelete_doc
#define EnvProtect_doc
#define LogConfig_doc
#define ProcessEvent_doc
#define SendI32_doc
#define LinkConnect_doc
#define ConfigSetIsString_doc
#define StorageCount_doc
#define ConfigSetTimeout_doc
#define LogParentOrChild_doc
#define RouteResolve_doc
#define ConfigSetPrefix_doc
#define LogServerOrClient_doc
#define ConfigSetIoTcp_doc
#define ConfigGetStorage_doc
#define SendStringR_doc
#define StorageOpen_doc
#define LogSetup_doc
#define SendBFL_doc
#define ConfigSetServerCleanup_doc
#define ErrorCopy_doc
#define ConfigGetTimeout_doc
#define GetNull_doc
#define ReadT_END_doc
#define ConfigGetPkgsize_doc
static MK_TYP MqContextCTT
#define SendI16_doc
#define ConfigSetIoUds_doc
#define ConfigSetIsServer_doc
#define LinkIsConnected_doc
#define Next_doc
#define RouteGetPath_doc
#define SlaveGet_doc
#define ConfigSetConfigFile_doc
#define SendL_FLAT_doc
#define ConfigSetServerSetup_doc
#define RouteTraverse_doc
#define ConfigSetStorage_doc
#define SendSTR_doc
#define SendEND_AND_TRANSACTION_doc
#define ConfigGetBuffersize_doc
#define ConfigGetIoUds_doc
#define ReadDbg_doc
#define SendBUS_FLAT_doc
#define Create_doc
#define ReadGetNumItems_doc
#define ServiceTokenExists_doc
#define ServiceCreate_doc
#define HandleResolve_doc
#define SendI64_doc
#define StorageResolve_doc
#define ReadL_END_doc
#define StorageLog_doc
#define ServiceProxyCtx_doc
#define LogLink_doc
#define SendEND_doc
#define Prev_doc
#define ClassIdentSet_doc
#define ReadHDL_doc
#define SendHDL_doc
#define SendDBL_doc
#define ConfigSetStartAsString_doc
#define ConfigGetIsServer_doc
#define ReadFLT_doc
#define StorageImport_doc
#define SendRETURN_SUB_doc
#define OT_CLASS
#define OT_SETUP_hdl_static
#define SendRETURN_doc
#define OT_SETUP_hdl_constr
#define Exit_doc
#define SendLTR_doc
#define ReadALL_doc
#define ReadI8_doc
#define ReadBinaryR_doc
#define SendBIN_doc
#define EnvRestore_doc
#define ConfigGetIoPipe_doc
#define StorageErrCnt_doc
#define ClassIdentGet_doc
#define SendEND_AND_CALLBACK_doc
#define ConfigSetIoTcpL_doc
#define ReadDBL_doc
#define SendL_START_doc
#define RouteGetTree_doc
#define ConfigSetPkgsize_doc
#define ServiceProxyCtxExists_doc
#define LinkShutdown_doc
#define LinkCreate_doc
#define LogEnv_doc
#define ClassFactorySet_doc
#define OT_SETUP_hdl__null_allow
#define SlaveGetMaster_doc
#define SlaveCheck_doc
#define ConfigSetPostfix_doc
#define SlaveIs_doc
#define new_doc
#define ReadL_START_doc
#define ServiceIsTransaction_doc
#define ConfigGetIsParent_doc
#define LinkGetParent_doc
#define ReadI16_doc
#define StorageExport_doc
#define LinkGetTargetIdent_doc
#define SendI8_doc
#define ReadT_START_doc
#define ReadStringR_doc
#define SlaveDelete_doc
#define SendT_END_doc
#define ConfigReset_doc
#define ReadItemExists_doc
#define ReadLONG_doc
#define S_INIT
#define ConfigSetEvent_doc
#define ConfigGetPostfix_doc
#define LinkGetCtxId_doc
#define ConfigGetIoTcpL_doc
#define SendEND_AND_SUB_doc
#define LinkIsParent_doc
#define SendBUF_doc
#define ErrorMove_doc
#define ReadSTR_doc
#define SendSYNC_doc
#define SendBOL_doc
#define ConfigSetStartAs_doc
#define SendFLT_doc
#define ReadBOL_doc
#define mqctx
#define MkBufferListCreateTLS_T(name, num)
#define mk_inline
#define MK_NULL_NO
#define MK_NULL_YES
#define MK_UNUSED
#define MK_NULL
#define MK_DEPRECATED
MkErrorE
MK_TIMEOUT_DEFAULT
MK_OK
int32_t MK_NUM
float MK_FLT
MK_PTRB * MK_PTR
const MK_STRB * MK_STRN
MK_PTRB * MK_MNG
signed char MK_I8
signed long long MK_I64
bool MK_BOOL
unsigned char MK_BOL
long MK_LONG
signed short int MK_I16
double MK_DBL
time_t MK_TIME_T
int32_t MK_HDL
signed int MK_I32
int MK_DBG
static bool MkSysStringIsNULL(MK_STRN str)
static MK_I32 MkRuntimeDebugGet(void)
#define MkRtSetup_X(x)
#define MK_RT_ARGS
#define MK_RT_ARGS_ONLY
#define MkTypeDup2(...)
static MK_ERR MqContextErrorFORMAT(MQ_CTXN const fmtobj)
helper used to access MkErrorDEFAULT from MqContextC
#define MqClassFactorySet(...)
MK_STRN MqClassIdentGet(MQ_CTXN const ctx)
get the application-identification …
#define MqClassIdentSet(...)
MK_STRN MqClassOriginalIdentGet(MQ_CTXN const ctx)
get the MqFactoryS::originalIdent from the MqContextC
MQ_FCT const MqClassFactoryGet(MQ_CTXN const ctx)
get the MqFactoryC used by the MqContextC
#define MqContextHandleResolve(...)
#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
static MQ_CTX MqContextGetNull(void)
Null-Slot - return a MqContextC typed NULL instance …
static MQ_CTX MqCtx(MK_MNG mng)
cast a unknown-object into an MqContextS pointer or NULL if not possible
#define MqContextC_T
class as MqTypeCtxS-class-type, useable in a class-macro as: class##_T …
#define MqContextCT
class as MqTypeCtxS-class-type for MqContextC in the Target-Programming-Language (TPL) …
#define MqContextC_TT
class as MkTypeS-class-type, useable in a class-macro as: class##_TT …
static enum MqStartE MqConfigGetStartAs(MQ_CTX const ctx)
return the MqConfigS::startAs value
static MK_I32 MqConfigGetPkgsize(MQ_CTXN const ctx)
get the maximun size of a BDY package
static MK_STRN MqConfigGetName(MQ_CTXN const ctx)
get the name of the context object
static MK_TIME_T MqConfigGetTimeout(MQ_CTXN const ctx)
get the timeout value of the context object
static bool MqConfigGetIsParent(MQ_CTX const ctx)
does the context object is a parent ? An objext is a parent id the MqConfigS::parent attribute is nil
#define MqConfigSetConfigFile(...)
static MK_I32 MqConfigGetBuffersize(MQ_CTXN const ctx)
get the minimum of the read/send buffersize of the socket
static MK_STRN MqConfigGetPostfix(MQ_CTXN const ctx)
get the MqConfigS::dispPostfix
static bool MqConfigGetIsServer(MQ_CTX const ctx)
does the context object is a server ?
static MQ_SOCK_HDL MqConfigGetIoPipe(MQ_CTX const ctx)
return the MqIoPipeConfigS
static MK_STRN MqConfigGetPrefix(MQ_CTXN const ctx)
get the MqConfigS::dispPrefix
static MK_STRN MqConfigGetStorage(MQ_CTXN const ctx)
get the storage of the context object
static MK_STRN MqConfigGetIoUds(MQ_CTXN const ctx)
return the MqIoUdsConfigS
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 …
#define MqConfigGetIoTcpL(...)
static enum MqIdentE MqConfigGetIdentFrom(MQ_CTX const ctx)
get the MqConfigS::identFrom
static enum MqStatusIsEF MqConfigGetStatusIs(MQ_CTX const ctx)
return the MqContextS::statusIs value
static bool MqConfigGetIsString(MQ_CTX const ctx)
does the context object is using the string-mode ?
#define MqConfigSetBgError(...)
#define MqConfigSetServerSetup(...)
#define MqConfigSetServerCleanup(...)
#define MqConfigSetEvent(...)
#define MqConfigReset(...)
#define MqConfigSetDaemon(...)
#define MqConfigSetPrefix(...)
void MqConfigSetPkgsize(MQ_CTX const ctx, MK_I32 data)
set the MqIoConfigS::pkgsize value
bool MqConfigCheckStartAs(MQ_CTX const ctx, enum MqStartE data)
check if MqConfigS::startAs can be set to data
#define MqConfigSetIoPipe(...)
void MqConfigSetIgnoreExit(MQ_CTX const ctx, bool data)
set the MqSetupS::ignoreExit value
#define MqConfigSetIoTcp(...)
#define MqConfigSetPostfix(...)
#define MqConfigSetName(...)
void MqConfigSetTimeout(MQ_CTX const ctx, MK_TIME_T data)
set the MqIoConfigS::timeout value
enum MkErrorE MqConfigSetStartAsString(MQ_CTX const ctx, MK_STRN data)
set the MqConfigS::startAs value using string default, thread, fork or spawn
void MqConfigSetIsString(MQ_CTX const ctx, bool data)
set the MqConfigS::native value 'S'string or 'L'owEndian or 'B'igEndian
#define MqConfigSetIoUds(...)
void MqConfigSetIdentFrom(MQ_CTX const ctx, enum MqIdentE data)
set the MqConfigS::identFrom value
enum MkErrorE MqConfigSetStartAs(MQ_CTX const ctx, enum MqStartE data)
set the MqConfigS::startAs value
void MqConfigSetBuffersize(MQ_CTX const ctx, MK_I32 data)
set the MqIoConfigS::buffersize value
#define MqConfigSetAllDebug(...)
#define MqConfigSetIoTcpL(...)
#define MqConfigSetStorage(...)
void MqConfigSetIsServer(MQ_CTX const ctx, bool data)
set the MqSetupS::isServer value
void MqEnvRestore(MQ_CTX ctx)
restore the service-environment
#define MqEnvProtect(...)
#define MqContextErrorMove(...)
#define MqContextErrorCopy(...)
#define MqContextLogShort(...)
#define MqContextLogEnv(...)
static MK_STRN MqLogParentOrChild(MQ_CTXN ctx)
is ctx a PARENT or a CHILD ? …
#define MqContextLogConfig(...)
#define MqContextLogSetup(...)
#define MqContextLogLink(...)
#define MqContextLogType(...)
static MK_STRN MqLogServerOrClient(MQ_CTXN const ctx)
is ctx a SERVER or a CLIENT ? …
#define MqProcessEvent(...)
#define MqExit(...)
#define MqContextGetBuffer(...)
static MQ_CTX MqGetRoot(MQ_CTX ctx)
get the Root (toplevel initial context)
#define MqContextMark(...)
#define MqProxyItem(...)
#define MqProxyForward(...)
#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(...)
#define MqReadT_START(...)
#define MqReadL_START(...)
#define MqReadT_END(...)
#define MqReadL_END(...)
#define MqReadDbg(...)
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_NUM MqReadGetNumItems(MQ_CTX const ctx)
get the number of items left in the read-data-package …
bool MqReadItemExists(MQ_CTX const ctx)
check if an item exists in the read-data-package …
#define MqReadUndo(...)
#define MqRouteDelete(...)
#define MqRouteTraverse(...)
#define MqRouteGetTree(...)
#define MqRouteCreate(...)
#define MqRouteGetPath(...)
#define MqRouteResolve(...)
#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 MqSendSTART(...)
#define MqSendEND_AND_TRANSACTION(...)
#define MqSendEND_AND_CALLBACK(...)
#define MqSendEND_AND_SUB(...)
#define MqSendEND_AND_WAIT(...)
#define MqSendEND(...)
#define MqSendSYNC(...)
#define MqSendL_START(...)
#define MqSendT_END(...)
#define MqSendL_END(...)
#define MqSendT_START(...)
#define MqSendRETURN_SUB(...)
#define MqSendERROR(...)
#define MqSendRETURN(...)
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 MqServiceStorage(...)
#define MqServiceProxyCtx(...)
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
MQ_TOK MqServiceTokenGet(MQ_CTX const ctx)
in an ongoing-service-call get the current MqContextC_ServiceApi_Identifer …
static bool MqServiceIsTransaction(MQ_CTX const ctx)
check if the ongoing-service-call belongs to a transaction …
#define MqServiceCreate(...)
#define MqServiceProxy(...)
MK_STRN MQ_TOK
MqContextC - a char[4+1] or hex[8+1] string used to unique identify a service …
MqTokenF MqServiceCallbackF
MqContextC - the callback-function is used as a service-handle or as a event-handle …
#define MqServiceProxyRoundRobin(...)
#define MqServiceDelete(...)
bool MqServiceTokenExists(MQ_CTX const ctx, MQ_TOK const token)
check if the MqContextC_ServiceApi_Identifer token is defined as ctx service …
#define MqSlaveGet(...)
static bool MqSlaveIs(MQ_CTXN const ctx)
is the context a slave-context ? …
#define MqSlaveGetProxy(...)
#define MqSlaveCreate(...)
static bool MqSlaveCheck(MQ_CTXN const ctx, MQ_SLAVE_ID const id)
check if slave-id is valid
#define MqSlaveGetFilter(...)
static MQ_CTX MqSlaveGetMaster(MQ_CTX const ctx)
opposite function of MqSlaveGetFilter
#define MqSlaveDelete(...)
#define MqSlaveWorker(...)
#define MqStorageIncrRef(...)
#define MqStorageResolve(...)
#define MqStorageLog(...)
#define MqStorageExport(...)
#define MqStorageDecrRef(...)
#define MqStorageClose(...)
#define MqStorageOpen(...)
#define MqStorageImport(...)
#define MqStorageCount(...)
#define MqStorageDelete(...)
#define MqStorageErrCnt(...)
#define MqContextCreate(...)
MqWaitOnEventE
wait for an event? …
MqIdentE
identify the application using prefix (default) or factory …
MqStartE
User preferences on HOWTO start a new entity.
@ MQ_WAIT_NO
Check for one event but do not wait …
@ MQ_SLAVE_OTHER
internal: on the master-ctx get the slave-ctx and on the slave-ctx get the master-ctx
MK_NUM MQ_SLAVE_ID
a slave identiver
int MQ_LTR
32bit longterm transaction token because PHP-32 does NOT support long long
int MQ_SOCK_HDL
#define MQ_RT_ARGS_ONLY
MK_OBJ const obj
Definition high_lng.h:136
MK_STRB token[9]
Definition high_lng.h:229
MK_TIME_T timeout
Definition high_lng.h:133
MK_STRN ptr
Definition high_lng.h:130
#define OT_CHECK_NIH(val)
#define OT_CHECK_CALLABLE(val)
#define OT_CHECK_BUFN(val, nullB)
#define OT_CHECK_BUF(val, nullB)
#define OT_CLEANUP_CALLABLE(val)
#define OT_CHECK_BFLN(val, nullB)
#define OT_CHECK_ENUM(ename, val)
#define OT_SETUP_CALLABLE(val)
#define OT_CHECK_TIME_T(val)
#define OT_CHECK_BUSN(val, nullB)
#define OT_CHECK_BAC(val)
#define OT_CHECK_OBJN(val, nullB)
#define OT_CHECK_BFL(val, nullB)
#define OT_CHECK_CTXN(val, nullB)
#define OT_CHECK_FCT(val, nullB)
#define OT_CHECK_SLAVE_ID(val)
#define OT_CHECK_CTX(val, nullB)
#define OT_CHECK_DMP(val, nullB)
array of MqContextC instances
MQ_CTX * data
MkSelfUnlinkF selfUnlink
MkSelfDeleteF selfDelete
MkSelfCreateF selfCreate
PUBLIC data structure for the rbmqmsgque-specific-data
MqDumpC - the class known as dmp or dump is used to export a rbmqmsgque data package as binary …
data used to define a factory