theLink 10.0
Loading...
Searching...
No Matches
MqContextC_tcl.c
Go to the documentation of this file.
1
9/* LABEL-START */
10
11#define META_FILE_NAME "MqContextC_tcl.c"
12
14
15#define OT_CLASS NS(MqContextC)
16#define OT_CLASS_NAME "MqContextC"
17
18#define OBJECT2CTX(O) MkAssertCastM(MqContextC,(Tcl_ObjectGetMetadata(O, &MK(AtomMeta))))
19
20// TCL class
22
23// META class
25MkThreadLocal OT_OBJ_T MQ(MqContextC_MK_NULL) = NULL;
26
27// META: ObjNew feature: selfCreate will be called from "ObjNew->MkSelfNew" if MkObj need a SELF pointer
28static MK_PTR NS(MqContextC_selfCreate) (MK_RT_ARGS MK_OBJ const obj, MK_PTR const env) {
29 OT_ENV_T interp = env;
30 return MK(AtomCreate) (MK_RT_CALL interp,obj,OT_CLASS,NULL,NULL);
31}
32// META: is called when the META object is destroyed and SELF does NOT belongs to the META.
33static void NS(MqContextC_selfDelete) (MK_RT_ARGS MK_PTR selfP, MK_PTR const env) {
34 OT_SELF_T selfO = selfP;
35 OT_ENV_T interp = env;
36 MK(AtomDeleteHard) (MK_RT_CALL interp, selfO);
37}
38// META: is called when the META object is destroyed and SELF does NOT belong to the META.
39static void NS(MqContextC_selfUnlink) (MK_RT_ARGS MK_PTR selfP, MK_PTR const env) {
40 OT_SELF_T selfO = selfP;
41 OT_ENV_T interp = env;
42 MK(AtomUnlink) (MK_RT_CALL interp, selfO);
43}
44
45// ATTENTION: TCL has no "Unlink" because the "Tcl_ObjectSetMetadata(selfO,&MK(AtomMeta),NULL);" call
46// also the destructor
47
48#define OT_SETUP_hdl_static_constr_pre
49#define OT_SETUP_hdl_static_constr \
50 OT_SETUP_hdl_static_constr_pre; \
51 OT_SETUP_hdl_static
52
53#define OT_SETUP_hdl_static \
54 int __skip=Tcl_ObjectContextSkippedArgs(objCtx); \
55 AllRtSetup_NULL; \
56 __attribute__((unused)) OT_SELF_T selfO = Tcl_ObjectContextObject(objCtx); \
57 __attribute__((unused)) MK_TYP hdl = MqContextC##_TT;
58
59#define OT_SETUP_hdl SetupHdlFromMetaData_2(CTX,MQ_CTX);
60#define OT_SETUP_hdl__null_allow SetupHdlFromMetaData__null_allow_2(CTX,MQ_CTX);
61#define OT_SETUP_hdl_destr SetupHdlFromMetaData__null_allow_2(CTX,MQ_CTX);
62
63#define OT_SETUP_hdl_constr_pre
64#define OT_SETUP_hdl_constr \
65 OT_SETUP_hdl_constr_pre; \
66 int __skip=Tcl_ObjectContextSkippedArgs(objCtx); \
67 AllRtSetup_NULL; \
68 MK_RT_UNUSED OT_SELF_T selfO = Tcl_ObjectContextObject(objCtx); \
69 MQ_CTX hdl = (MQ_CTX) &MkERROR;
70
71#if !defined(SetupRtFromHdl_XN)
72 #define SetupRtFromHdl_XN(hdl) AllRtSetup_XN(hdl)
73 #define SetupRtFromHdl_X(hdl) AllRtSetup_X(hdl)
74#endif
75
76// initialize the TCL and MO class specific object
77#define ClassInit \
78 /* if not already done, initialize NEW MQ type */ \
79 if (MqContextCTT == NULL) MqContextCTT = MqContextSTT; \
80 \
81 /* protect against double call */ \
82 if (MqContextCTT->selfCreate == NS(MqContextC_selfCreate)) return MK_OK; \
83 \
84 /* add "selfCreate" and "selfDelete" feature to the MQ-Class */ \
85 MqContextCTT->selfCreate = NS(MqContextC_selfCreate); \
86 MqContextCTT->selfDelete = NS(MqContextC_selfDelete); \
87 MqContextCTT->selfUnlink = NS(MqContextC_selfUnlink); \
88 \
89 /* create the TCL-class */ \
90 OT_SELF_T classO = MK(ClassDef)(interp,ns,MqContextCTT); \
91 check_NULL(classO) goto error; \
92 OT_CLASS = Tcl_GetObjectAsClass(classO); \
93 \
94 /* create the TCL static Methods */ \
95 static MkThreadLocal OtUnknownS NS(sClassUnknown) = {OT_UNKNOWN_CLASS}; \
96 check_LNG(MK(UnknownSetup) (interp,classO,NS(sOtClassDef),&NS(sClassUnknown))) goto error; \
97 \
98 /* create the TCL instance Methods */ \
99 static MkThreadLocal OtUnknownS NS(sInstanceUnknown) = {OT_UNKNOWN_INSTANCE}; \
100 check_LNG(MK(UnknownSetup) (interp,classO,NS(sInstanceDef),&NS(sInstanceUnknown))) goto error; \
101 \
102 /* define the "NULL" object */ \
103 MQ(MqContextC_MK_NULL) = Tcl_GetObjectName(interp, \
104 MK(AtomCreate) (MK_RT_CALL interp, NULL /*obj*/, OT_CLASS, "MK_NULL" /*name*/, "::tclmqmsgque::MqContextC" /*ns*/) \
105 ); \
106 Tcl_IncrRefCount(MQ(MqContextC_MK_NULL));
107
108#define VER TCL_OO_METHOD_VERSION_CURRENT
109
110/* LABEL-END */
111
112#include "mk_check_tcl.h"
113
114#if 1
115#undef OT_CONSTRUCTOR_POST
116// don't modify 'prefix' if initial object is a class
117#define OT_CONSTRUCTOR_POST(x) if (Tcl_GetObjectAsClass(selfO) == NULL) \
118 MqConfigSetPrefixWithNoLock(x,MK(GetClassNameFromObject)(OT_Prefix_CALL selfO));
119#endif
120
121// BEGIN-DOC - created by 'tcl_MqS.tcl -i NHI1_HOME/theLink/c/gen/c_mqmsgque.meta' - DO NOT change
122
123// doc-key: MqContextC,MqClass,oc_,func
124#define ClassFactoryGet_doc "MqFactoryC [$ctx ClassFactoryGet] (const)"
125
126// doc-key: MqContextC,MqClass,om_,func
127#define ClassFactorySet_doc "$ctx ClassFactorySet item:MqFactoryC"
128#define ClassIdentGet_doc "string [$ctx ClassIdentGet] (const)"
129#define ClassIdentSet_doc "$ctx ClassIdentSet ident:string"
130#define ClassOriginalIdentGet_doc "string [$ctx ClassOriginalIdentGet] (const)"
131
132// doc-key: MqContextC,MqConfig,oco,func
133#define ConfigGetIoTcpL_doc "MkBufferListC [$ctx ConfigGetIoTcpL]"
134
135// doc-key: MqContextC,MqConfig,om_,func
136#define ConfigCheckStartAs_doc "bool [$ctx ConfigCheckStartAs data:MqStartE]"
137#define ConfigGetBuffersize_doc "int32 [$ctx ConfigGetBuffersize] (const)"
138#define ConfigGetIdentFrom_doc "MqIdentE [$ctx ConfigGetIdentFrom]"
139#define ConfigGetIoPipe_doc "int32 [$ctx ConfigGetIoPipe]"
140#define ConfigGetIoUds_doc "string [$ctx ConfigGetIoUds] (const)"
141#define ConfigGetIsParent_doc "bool [$ctx ConfigGetIsParent]"
142#define ConfigGetIsServer_doc "bool [$ctx ConfigGetIsServer]"
143#define ConfigGetIsString_doc "bool [$ctx ConfigGetIsString]"
144#define ConfigGetName_doc "string [$ctx ConfigGetName] (const)"
145#define ConfigGetPkgsize_doc "int32 [$ctx ConfigGetPkgsize] (const)"
146#define ConfigGetPostfix_doc "string [$ctx ConfigGetPostfix] (const)"
147#define ConfigGetPrefix_doc "string [$ctx ConfigGetPrefix] (const)"
148#define ConfigGetStartAs_doc "MqStartE [$ctx ConfigGetStartAs]"
149#define ConfigGetStatusIs_doc "MqStatusIsEF [$ctx ConfigGetStatusIs]"
150#define ConfigGetStorage_doc "string [$ctx ConfigGetStorage] (const)"
151#define ConfigGetTimeout_doc "MkTimeoutE|int32 [$ctx ConfigGetTimeout] (const)"
152#define ConfigReset_doc "$ctx ConfigReset"
153#define ConfigSetAllDebug_doc "$ctx ConfigSetAllDebug data:int32"
154#define ConfigSetAllTimeout_doc "$ctx ConfigSetAllTimeout data:MkTimeoutE|int32"
155#define ConfigSetBgError_doc "$ctx ConfigSetBgError ?callback:callable=\"MK_NULL\"?"
156#define ConfigSetBuffersize_doc "$ctx ConfigSetBuffersize data:int32"
157#define ConfigSetConfigFile_doc "$ctx ConfigSetConfigFile filename:string"
158#define ConfigSetDaemon_doc "$ctx ConfigSetDaemon pidfile:string"
159#define ConfigSetEvent_doc "$ctx ConfigSetEvent ?callback:callable=\"MK_NULL\"?"
160#define ConfigSetIdentFrom_doc "$ctx ConfigSetIdentFrom data:MqIdentE"
161#define ConfigSetIgnoreExit_doc "$ctx ConfigSetIgnoreExit data:bool"
162#define ConfigSetIoPipe_doc "$ctx ConfigSetIoPipe fh:int32"
163#define ConfigSetIoTcp_doc "$ctx ConfigSetIoTcp ?host:string=\"NULL\"? ?port:string=\"NULL\"? ?myhost:string=\"NULL\"? ?myport:string=\"NULL\"?"
164#define ConfigSetIoTcpL_doc "$ctx ConfigSetIoTcpL vals:MkBufferListC"
165#define ConfigSetIoUds_doc "$ctx ConfigSetIoUds file:string"
166#define ConfigSetIsServer_doc "$ctx ConfigSetIsServer data:bool"
167#define ConfigSetIsString_doc "$ctx ConfigSetIsString data:bool"
168#define ConfigSetName_doc "$ctx ConfigSetName data:string"
169#define ConfigSetPkgsize_doc "$ctx ConfigSetPkgsize data:int32"
170#define ConfigSetPostfix_doc "$ctx ConfigSetPostfix data:string"
171#define ConfigSetPrefix_doc "$ctx ConfigSetPrefix data:string"
172#define ConfigSetServerCleanup_doc "$ctx ConfigSetServerCleanup ?callback:callable=\"MK_NULL\"?"
173#define ConfigSetServerSetup_doc "$ctx ConfigSetServerSetup ?callback:callable=\"MK_NULL\"?"
174#define ConfigSetStartAs_doc "$ctx ConfigSetStartAs data:MqStartE"
175#define ConfigSetStartAsString_doc "$ctx ConfigSetStartAsString data:string"
176#define ConfigSetStorage_doc "$ctx ConfigSetStorage data:string"
177#define ConfigSetTimeout_doc "$ctx ConfigSetTimeout data:MkTimeoutE|int32"
178
179// doc-key: MqContextC,MqConfig,omo,func
180#define ConfigGetIoTcp_doc "{host:string port:string myhost:string myport:string} [$ctx ConfigGetIoTcp]"
181
182// doc-key: MqContextC,MqContext,sCc,func
183#define CTOR_doc "MqContextC [MqContextC CTOR ?tmpl:MqContextC=\"MK_NULL\"?]"
184#define Create_doc "MqContextC [MqContextC Create ?tmpl:MqContextC=\"MK_NULL\"?]"
185
186// doc-key: MqContextC,MqContext,sc_,func
187#define GetNull_doc "MqContextC [MqContextC GetNull]"
188#define HandleResolve_doc "MqContextC [MqContextC HandleResolve netHdl:MK_HDL]"
189#define Instances_doc "MqContextC [MqContextC Instances]"
190
191// doc-key: MqContextC,MqContext,oc_,func
192#define ErrorFORMAT_doc "MkErrorC [$fmtobj ErrorFORMAT] (const)"
193#define GetBuffer_doc "MkBufferC [$ctx GetBuffer]"
194#define Next_doc "MqContextC [$ctx Next]"
195#define Prev_doc "MqContextC [$ctx Prev]"
196
197// doc-key: MqContextC,MqContext,om_,func
198#define ErrorCopy_doc "MkErrorE [$targetCtx ErrorCopy sourceCtx:MqContextC] (const)"
199#define ErrorMove_doc "MkErrorE [$targetCtx ErrorMove sourceCtx:MqContextC] (const)"
200// skip class-overload: HandleGet → MkObjectHandleGet
201// skip class-overload: Log → MkObjectLog
202#define LogConfig_doc "$ctx LogConfig ?fmtobj:MkObjectC=\"MK_NULL\"? ?debug:int32=0? ?callfunc:string=\"MK_NULL\"? ?lvl:int32=0? (const)"
203#define LogEnv_doc "$ctx LogEnv ?fmtobj:MkObjectC=\"MK_NULL\"? ?debug:int32=0? ?callfunc:string=\"MK_NULL\"? ?lvl:int32=0? (const)"
204#define LogLink_doc "$ctx LogLink ?fmtobj:MkObjectC=\"MK_NULL\"? ?debug:int32=0? ?callfunc:string=\"MK_NULL\"? ?lvl:int32=0? (const)"
205#define LogSetup_doc "$ctx LogSetup ?fmtobj:MkObjectC=\"MK_NULL\"? ?debug:int32=0? ?callfunc:string=\"MK_NULL\"? ?lvl:int32=0? (const)"
206#define LogShort_doc "$ctx LogShort ?fmtobj:MkObjectC=\"MK_NULL\"? ?debug:int32=0? ?callfunc:string=\"MK_NULL\"? ?lvl:int32=0? ?label:string=\"NULL\"? (const)"
207#define LogType_doc "$ctx LogType ?fmtobj:MkObjectC=\"MK_NULL\"? ?debug:int32=0? ?callfunc:string=\"MK_NULL\"? ?lvl:int32=0? (const)"
208// skip class-overload: ToString → MkObjectToString
209
210// doc-key: MqContextC,MqEnv,om_,func
211#define EnvProtect_doc "$ctx EnvProtect"
212#define EnvRestore_doc "$ctx EnvRestore"
213
214// doc-key: MqContextC,MqExit,om_,func
215#define Exit_doc "int32 [$ctx Exit ?callfunc:string=\"MK_NULL\"? ?callfile:string=\"MK_NULL\"? ?callline:int32=-1?]"
216
217// doc-key: MqContextC,MqGet,oc_,func
218#define GetRoot_doc "MqContextC [$ctx GetRoot]"
219
220// doc-key: MqContextC,MqLink,oc_,func
221#define LinkGetParent_doc "MqContextC [$ctx LinkGetParent]"
222
223// doc-key: MqContextC,MqLink,om_,func
224#define LinkConnect_doc "$ctx LinkConnect"
225#define LinkCreate_doc "$ctx LinkCreate ?args:MkBufferListC...=\"MK_NULL\"?"
226#define LinkCreateChild_doc "$ctx LinkCreateChild parent:MqContextC ?args:MkBufferListC...=\"MK_NULL\"?"
227#define LinkDelete_doc "$ctx LinkDelete"
228#define LinkGetCtxId_doc "int32 [$ctx LinkGetCtxId]"
229#define LinkGetTargetIdent_doc "string [$ctx LinkGetTargetIdent]"
230#define LinkIsConnected_doc "bool [$ctx LinkIsConnected]"
231#define LinkIsParent_doc "bool [$ctx LinkIsParent]"
232#define LinkShutdown_doc "$ctx LinkShutdown"
233
234// doc-key: MqContextC,MqLog,om_,func
235#define LogParentOrChild_doc "string [$ctx LogParentOrChild] (const)"
236#define LogServerOrClient_doc "string [$ctx LogServerOrClient] (const)"
237
238// doc-key: MqContextC,MqProcess,om_,func
239#define ProcessEvent_doc "$ctx ProcessEvent ?wait:MqWaitOnEventE=NO? ?timeout:MkTimeoutE|int32=DEFAULT?"
240
241// doc-key: MqContextC,MqProxy,om_,func
242#define ProxyForward_doc "$sourceCtx ProxyForward targetCtx:MqContextC ?dump:MqDumpC=\"MK_NULL\"? ?timeout:MkTimeoutE|int32=DEFAULT?"
243#define ProxyItem_doc "$sourceCtx ProxyItem targetCtx:MqContextC"
244
245// doc-key: MqContextC,MqRead,oci,func
246#define ReadALL_doc "MkBufferListC [$ctx ReadALL ?val_inout:MkBufferListC=\"MK_NULL\"?]"
247
248// doc-key: MqContextC,MqRead,oco,func
249#define ReadBFL_doc "MkBufferListC [$ctx ReadBFL]"
250#define ReadBUF_doc "MkBufferC [$ctx ReadBUF]"
251
252// doc-key: MqContextC,MqRead,om_,func
253#define ReadDbg_doc "$ctx ReadDbg"
254#define ReadGetNextType_doc "MkTypeE [$ctx ReadGetNextType]"
255#define ReadGetNumItems_doc "int32 [$ctx ReadGetNumItems]"
256#define ReadItemExists_doc "bool [$ctx ReadItemExists]"
257#define ReadL_END_doc "$ctx ReadL_END"
258#define ReadL_START_doc "$ctx ReadL_START ?buf:MkBufferC=\"MK_NULL\"?"
259#define ReadT_END_doc "$ctx ReadT_END"
260#define ReadT_START_doc "$ctx ReadT_START"
261#define ReadUndo_doc "$ctx ReadUndo"
262
263// doc-key: MqContextC,MqRead,omo,func
264#define ReadBIN_doc "binary [$ctx ReadBIN]"
265#define ReadBOL_doc "bool [$ctx ReadBOL]"
266#define ReadBinaryR_doc "binary [$ctx ReadBinaryR]"
267#define ReadDBL_doc "double [$ctx ReadDBL]"
268#define ReadFLT_doc "float [$ctx ReadFLT]"
269#define ReadHDL_doc "MK_HDL [$ctx ReadHDL]"
270#define ReadI16_doc "int16 [$ctx ReadI16]"
271#define ReadI32_doc "int32 [$ctx ReadI32]"
272#define ReadI64_doc "int64 [$ctx ReadI64]"
273#define ReadI8_doc "int8 [$ctx ReadI8]"
274#define ReadLIST_doc "[list...] [$ctx ReadLIST]"
275#define ReadLONG_doc "long [$ctx ReadLONG]"
276#define ReadNEXT_doc "obj [$ctx ReadNEXT]"
277#define ReadSTR_doc "string [$ctx ReadSTR]"
278#define ReadStringR_doc "string [$ctx ReadStringR]"
279
280// doc-key: MqContextC,MqRoute,oco,func
281#define RouteGetTree_doc "MkBufferListC [$ctx RouteGetTree]"
282
283// doc-key: MqContextC,MqRoute,om_,func
284#define RouteCreate_doc "$ctx RouteCreate route:string service:string ?overwrite:bool=false?"
285#define RouteDelete_doc "$ctx RouteDelete route:string service:string ?overwrite:bool=false?"
286#define RouteResolve_doc "[MqContextC...] [$ctx RouteResolve ident:string ?retnum:int32=-1?]"
287#define RouteTraverse_doc "$ctx RouteTraverse service:string ?args:MkBufferListC...=\"MK_NULL\"?"
288
289// doc-key: MqContextC,MqRoute,omo,func
290#define RouteGetPath_doc "string [$ctx RouteGetPath]"
291
292// doc-key: MqContextC,MqSend,om_,func
293#define Send_doc "$ctx Send cstr:string args:args..."
294#define SendBFL_doc "$ctx SendBFL val:MkBufferListC"
295#define SendBIN_doc "$ctx SendBIN val:binary"
296#define SendBOL_doc "$ctx SendBOL val:bool"
297#define SendBUF_doc "$ctx SendBUF val:MkBufferC"
298#define SendBUS_FLAT_doc "$ctx SendBUS_FLAT val:MkBufferStreamC"
299#define SendBinaryR_doc "$ctx SendBinaryR val:binary"
300#define SendDBL_doc "$ctx SendDBL val:double"
301#define SendEND_doc "$ctx SendEND token:string[4] ?timeout:MkTimeoutE|int32=DEFAULT?"
302#define SendEND_AND_CALLBACK_doc "$ctx SendEND_AND_CALLBACK token:string[4] callback:callable ?timeout:MkTimeoutE|int32=DEFAULT?"
303#define SendEND_AND_SUB_doc "$ctx SendEND_AND_SUB token:string[4] callback:callable ?timeout:MkTimeoutE|int32=DEFAULT?"
304#define SendEND_AND_TRANSACTION_doc "$ctx SendEND_AND_TRANSACTION token:string[4] callback:string[4] ?timeout:MkTimeoutE|int32=DEFAULT?"
305#define SendEND_AND_WAIT_doc "$ctx SendEND_AND_WAIT token:string[4] ?timeout:MkTimeoutE|int32=DEFAULT?"
306#define SendERROR_doc "$ctx SendERROR"
307#define SendFLT_doc "$ctx SendFLT val:float"
308#define SendHDL_doc "$ctx SendHDL val:MK_HDL"
309#define SendI16_doc "$ctx SendI16 val:int16"
310#define SendI32_doc "$ctx SendI32 val:int32"
311#define SendI64_doc "$ctx SendI64 val:int64"
312#define SendI8_doc "$ctx SendI8 val:int8"
313#define SendLONG_doc "$ctx SendLONG val:long"
314#define SendLTR_doc "$ctx SendLTR transLId:int32"
315#define SendL_END_doc "$ctx SendL_END"
316#define SendL_FLAT_doc "$ctx SendL_FLAT val:MkBufferListC"
317#define SendL_START_doc "$ctx SendL_START"
318#define SendRETURN_doc "$ctx SendRETURN"
319#define SendRETURN_SUB_doc "$ctx SendRETURN_SUB"
320#define SendSTART_doc "$ctx SendSTART"
321#define SendSTR_doc "$ctx SendSTR val:string"
322#define SendSYNC_doc "$ctx SendSYNC"
323#define SendStringR_doc "$ctx SendStringR val:string"
324#define SendT_END_doc "$ctx SendT_END"
325#define SendT_START_doc "$ctx SendT_START"
326
327// doc-key: MqContextC,MqService,om_,func
328#define ServiceCreate_doc "$ctx ServiceCreate token:string[4] callback:callable"
329#define ServiceDelete_doc "$ctx ServiceDelete token:string[4]"
330#define ServiceIsTransaction_doc "bool [$ctx ServiceIsTransaction]"
331#define ServiceProxy_doc "$ctx ServiceProxy token:string[4] ?id:MqSlaveE|int32=MQ_SLAVE_OTHER?"
332#define ServiceProxyCtx_doc "$ctx ServiceProxyCtx token:string[4] target:MqContextC"
333#define ServiceProxyCtxExists_doc "bool [$ctx ServiceProxyCtxExists token:string[4] target:MqContextC]"
334#define ServiceProxyRoundRobin_doc "$ctx ServiceProxyRoundRobin token:string[4] ident:string"
335#define ServiceStorage_doc "$ctx ServiceStorage token:string[4]"
336#define ServiceTokenCheck_doc "bool [$ctx ServiceTokenCheck token:string[4]]"
337#define ServiceTokenExists_doc "bool [$ctx ServiceTokenExists token:string[4]]"
338#define ServiceTokenGet_doc "string[4] [$ctx ServiceTokenGet]"
339
340// doc-key: MqContextC,MqSlave,oc_,func
341#define SlaveGetMaster_doc "MqContextC [$ctx SlaveGetMaster]"
342
343// doc-key: MqContextC,MqSlave,oco,func
344#define SlaveGet_doc "MqContextC [$ctx SlaveGet id:MqSlaveE|int32]"
345#define SlaveGetFilter_doc "MqContextC [$ctx SlaveGetFilter]"
346#define SlaveGetProxy_doc "MqContextC [$ctx SlaveGetProxy id:MqSlaveE|int32]"
347
348// doc-key: MqContextC,MqSlave,om_,func
349#define SlaveCheck_doc "bool [$ctx SlaveCheck id:MqSlaveE|int32] (const)"
350#define SlaveCreate_doc "$ctx SlaveCreate id:MqSlaveE|int32 slave:MqContextC"
351#define SlaveDelete_doc "$ctx SlaveDelete id:MqSlaveE|int32"
352#define SlaveIs_doc "bool [$ctx SlaveIs] (const)"
353#define SlaveWorker_doc "$ctx SlaveWorker id:MqSlaveE|int32 ?fct:string=\"WORKER\"? ?args:MkBufferListC...=\"MK_NULL\"?"
354
355// doc-key: MqContextC,MqStorage,oci,func
356#define StorageDelete_doc "int32 [$ctx StorageDelete ?*transLIdP_inout:int32=0?]"
357#define StorageImport_doc "int32 [$ctx StorageImport ?*transLIdP_inout:int32=0?]"
358
359// doc-key: MqContextC,MqStorage,om_,func
360#define StorageClose_doc "$ctx StorageClose"
361#define StorageDecrRef_doc "$ctx StorageDecrRef transLId:int32"
362#define StorageIncrRef_doc "$ctx StorageIncrRef transLId:int32"
363#define StorageLog_doc "$ctx StorageLog ?callfunc:string=\"MK_NULL\"?"
364#define StorageOpen_doc "$ctx StorageOpen storageFile:string"
365
366// doc-key: MqContextC,MqStorage,omo,func
367#define StorageCount_doc "int32 [$ctx StorageCount]"
368#define StorageErrCnt_doc "int32 [$ctx StorageErrCnt transLId:int32]"
369#define StorageExport_doc "int32 [$ctx StorageExport]"
370#define StorageResolve_doc "{otherCtxP:MqContextC otherLIdP:int32} [$ctx StorageResolve]"
371
372// END-DOC - created by 'tcl_MqS.tcl -i NHI1_HOME/theLink/c/gen/c_mqmsgque.meta' - DO NOT change
373
374/*****************************************************************************/
375/* */
376/* S T A R T */
377/* */
378/*****************************************************************************/
379
380/*****************************************************************************/
381/* */
382/* O B J E C T - hand */
383/* */
384/*****************************************************************************/
385
388static OT_ProcRet NS(MqContextC_Debug) (MqContextC_ARGS)
389{
391 OT_SETUP_VARARGS(1,1,"$ctx Debug prefix:str")
392 MK_STRN prefix;
393 OT_CHECK_STR(prefix)
395 MkLogC_4X(hdl,"…\n",0,prefix),
397 goto end;
398 error:
400 end:
402}
403
406static OT_ProcRet NS(MqContextC_printObj) (MqContextC_ARGS)
407{
409 OT_SETUP_VARARGS(1,2,"$ctx printObj obj:Tcl_Obj ?prefix:string=\"\"?")
410 OT_OBJ_T tclO = 0;
412 MK_STRN prefix="print";
415 MK_OBJ obj;
416 MkTestClassE flag;
417 int mqR;
418 if(OT_LNG_OBJECT_IS_3(tclO, &obj, &flag)) {
419 mqR=-2;
420 switch (flag) {
421 case MkTestClassE_OK: mqR=obj->refCount; break;
422 case MkTestClassE_NULL: mqR=0; break;
423 case MkTestClassE_INVALID_SIGNATURE: mqR=-1; break;
426 case MkTestClassE_INTERNAL: mqR=-2; break;
427 }
428 } else {
429 mqR=-2;
430 }
431 printXV(hdl,"%-10s: string<%s>, type<%s>, refCount[mq=%i,tcl=%i], ptr<%p>\n",
432 prefix, Tcl_GetString(tclO), MK(GetTypeFromObj) (OT_Prefix_CALL tclO, NULL), mqR, tclO->refCount, tclO
433 );
435 goto end;
436 error:
438 end:
440}
441
444static OT_ProcRet NS(MqContextC_ConfigGetStartAsNum) (MqContextC_ARGS) {
446 OT_SETUP_NOARG("int [$ctx ConfigGetStartAsNum]");
448 OT_retObj_SET(Tcl_NewIntObj(MqConfigGetStartAs (hdl)));
449 goto end;
450 error:
452 end:
454}
455
458static OT_ProcRet NS(MqContextC_ConfigGetStatusIsNum) (MqContextC_ARGS) {
460 OT_SETUP_NOARG("int [$ctx ConfigGetStatusIsNum]");
462 OT_retObj_SET(Tcl_NewIntObj(MqConfigGetStatusIs (hdl)));
463 goto end;
464 error:
466 end:
468}
469
472
473// MARK_O
474/*****************************************************************************/
475/* */
476/* O B J E C T */
477/* */
478/*****************************************************************************/
479
480// BEGIN-MqContextC - created by 'tcl_MqC.tcl -i NHI1_HOME/theLink/c/gen/c_mqmsgque.meta' - DO NOT change
481
485
486// doc-key: MqContextC,MqContextC-Class-Export,sc_
487
489static OT_ProcRet NS(MqContextC_HandleResolve) (OtClass_ARGS) {
492 MK_HDL netHdl = 0;
495 MQ_CTX retVal = MqContextHandleResolve (netHdl);
496 OT_retObj_SET_CTX(retVal);
497 goto end;
498 error:
500 end:
502}
503
504// doc-key: MqContextC,MqContextC-Class-Export,om_
505
506// skip on class-overload: MqContextHandleGet → MkObjectHandleGet
508static OT_ProcRet NS(MqContextC_HandleGet) (MqContextC_ARGS) {OT_ERROR_LNG_RETURN;}
509
511// MqContextC_Class_TCL_API
512
516
517// doc-key: MqContextC,MqContextC-Class-Introspection,oc_
518
520static OT_ProcRet NS(MqContextC_Next) (MqContextC_ARGS) {
524 MQ_CTX retVal = MqContextNext (hdl);
525 OT_retObj_SET_CTX(retVal);
526 goto end;
527 error:
529 end:
531}
532
534static OT_ProcRet NS(MqContextC_Prev) (MqContextC_ARGS) {
538 MQ_CTX retVal = MqContextPrev (hdl);
539 OT_retObj_SET_CTX(retVal);
540 goto end;
541 error:
543 end:
545}
546
547// doc-key: MqContextC,MqContextC-Class-Introspection,sc_
548
550static OT_ProcRet NS(MqContextC_Instances) (OtClass_ARGS) {
554 MQ_CTX retVal = MqContextInstances ();
555 OT_retObj_SET_CTX(retVal);
556 goto end;
557 error:
559 end:
561}
562
564// MqContextC_Class_TCL_API
565
569
570// doc-key: MqContextC,MqContextC-Class-Misc,sc_
571
573static OT_ProcRet NS(MqContextC_GetNull) (OtClass_ARGS) {
577 MQ_CTX retVal = MqContextGetNull ();
578 OT_retObj_SET_CTX(retVal);
579 goto end;
580 error:
582 end:
584}
585
587// MqContextC_Class_TCL_API
588
592
593// doc-key: MqContextC,MqContextC-ClassApi-Class,oc_
594
596static OT_ProcRet NS(MqContextC_ClassFactoryGet) (MqContextC_ARGS) {
600 MQ_FCT retVal = MqClassFactoryGet (hdl);
601 OT_retObj_SET_FCT(retVal);
602 goto end;
603 error:
605 end:
607}
608
609// doc-key: MqContextC,MqContextC-ClassApi-Class,om_
610
612static OT_ProcRet NS(MqContextC_ClassFactorySet) (MqContextC_ARGS) {
615 MQ_FCT item = 0;
618 MkErrorC_Check(hdl,MqClassFactorySet (hdl, item));
620 goto end;
621 error:
623 end:
625}
626
628static OT_ProcRet NS(MqContextC_ClassIdentGet) (MqContextC_ARGS) {
633 goto end;
634 error:
636 end:
638}
639
641static OT_ProcRet NS(MqContextC_ClassIdentSet) (MqContextC_ARGS) {
644 MK_STRN ident = 0;
647 MkErrorC_Check(hdl,MqClassIdentSet (hdl, ident));
649 goto end;
650 error:
652 end:
654}
655
657static OT_ProcRet NS(MqContextC_ClassOriginalIdentGet) (MqContextC_ARGS) {
662 goto end;
663 error:
665 end:
667}
668
670// MqContextC_ClassApi_Class_TCL_API
671
675
676// doc-key: MqContextC,MqContextC-ConfigApi-Get,oco
677
679static OT_ProcRet NS(MqContextC_ConfigGetIoTcpL) (MqContextC_ARGS) {
683 MK_BFL vals_out;
684 MkErrorC_Check(hdl,MqConfigGetIoTcpL (hdl, &vals_out));
685 OT_retObj_SET_BFL(vals_out);
686 goto end;
687 error:
689 end:
691}
692
693// doc-key: MqContextC,MqContextC-ConfigApi-Get,om_
694
696static OT_ProcRet NS(MqContextC_ConfigGetBuffersize) (MqContextC_ARGS) {
701 goto end;
702 error:
704 end:
706}
707
709static OT_ProcRet NS(MqContextC_ConfigGetIdentFrom) (MqContextC_ARGS) {
714 goto end;
715 error:
717 end:
719}
720
722static OT_ProcRet NS(MqContextC_ConfigGetIoPipe) (MqContextC_ARGS) {
727 goto end;
728 error:
730 end:
732}
733
735static OT_ProcRet NS(MqContextC_ConfigGetIoUds) (MqContextC_ARGS) {
740 goto end;
741 error:
743 end:
745}
746
748static OT_ProcRet NS(MqContextC_ConfigGetIsParent) (MqContextC_ARGS) {
753 goto end;
754 error:
756 end:
758}
759
761static OT_ProcRet NS(MqContextC_ConfigGetIsServer) (MqContextC_ARGS) {
766 goto end;
767 error:
769 end:
771}
772
774static OT_ProcRet NS(MqContextC_ConfigGetIsString) (MqContextC_ARGS) {
779 goto end;
780 error:
782 end:
784}
785
787static OT_ProcRet NS(MqContextC_ConfigGetName) (MqContextC_ARGS) {
792 goto end;
793 error:
795 end:
797}
798
800static OT_ProcRet NS(MqContextC_ConfigGetPkgsize) (MqContextC_ARGS) {
805 goto end;
806 error:
808 end:
810}
811
813static OT_ProcRet NS(MqContextC_ConfigGetPostfix) (MqContextC_ARGS) {
818 goto end;
819 error:
821 end:
823}
824
826static OT_ProcRet NS(MqContextC_ConfigGetPrefix) (MqContextC_ARGS) {
831 goto end;
832 error:
834 end:
836}
837
839static OT_ProcRet NS(MqContextC_ConfigGetStartAs) (MqContextC_ARGS) {
844 goto end;
845 error:
847 end:
849}
850
852static OT_ProcRet NS(MqContextC_ConfigGetStatusIs) (MqContextC_ARGS) {
857 goto end;
858 error:
860 end:
862}
863
865static OT_ProcRet NS(MqContextC_ConfigGetStorage) (MqContextC_ARGS) {
870 goto end;
871 error:
873 end:
875}
876
878static OT_ProcRet NS(MqContextC_ConfigGetTimeout) (MqContextC_ARGS) {
883 goto end;
884 error:
886 end:
888}
889
891static OT_ProcRet NS(MqContextC_ConfigSetConfigFile) (MqContextC_ARGS) {
894 MK_STRN filename = 0;
897 MkErrorC_Check(hdl,MqConfigSetConfigFile (hdl, filename));
899 goto end;
900 error:
902 end:
904}
905
906// doc-key: MqContextC,MqContextC-ConfigApi-Get,omo
907
909static OT_ProcRet NS(MqContextC_ConfigGetIoTcp) (MqContextC_ARGS) {
913 MK_STRN host_out;
914 MK_STRN port_out;
915 MK_STRN myhost_out;
916 MK_STRN myport_out;
917 MkErrorC_Check(hdl,MqConfigGetIoTcp (hdl, &host_out, &port_out, &myhost_out, &myport_out));
921 OT_retObj_APPEND(OT_TMP_STR_OBJ(myhost_out));
922 OT_retObj_APPEND(OT_TMP_STR_OBJ(myport_out));
923 goto end;
924 error:
926 end:
928}
929
931// MqContextC_ConfigApi_Get_TCL_API
932
936
937// doc-key: MqContextC,MqContextC-ConfigApi-Interface,om_
938
940static OT_ProcRet NS(MqContextC_ConfigSetBgError) (MqContextC_ARGS) {
943 OT_SETUP_CALLABLE(callback)
946 MqServiceCallbackF fCall = (callback == NULL ? NULL : NS(ServiceCall));
947 MqConfigSetBgError (hdl, fCall, callback, NS(ServiceFree), NS(ServiceCopy));
949 goto end;
950 error:
952 end:
953 OT_CLEANUP_CALLABLE(callback)
955}
956
958static OT_ProcRet NS(MqContextC_ConfigSetEvent) (MqContextC_ARGS) {
961 OT_SETUP_CALLABLE(callback)
964 MqServiceCallbackF fCall = (callback == NULL ? NULL : NS(ServiceCall));
965 MqConfigSetEvent (hdl, fCall, callback, NS(ServiceFree), NS(ServiceCopy));
967 goto end;
968 error:
970 end:
971 OT_CLEANUP_CALLABLE(callback)
973}
974
976static OT_ProcRet NS(MqContextC_ConfigSetServerCleanup) (MqContextC_ARGS) {
979 OT_SETUP_CALLABLE(callback)
982 MqServiceCallbackF fCall = (callback == NULL ? NULL : NS(ServiceCall));
983 MqConfigSetServerCleanup (hdl, fCall, callback, NS(ServiceFree), NS(ServiceCopy));
985 goto end;
986 error:
988 end:
989 OT_CLEANUP_CALLABLE(callback)
991}
992
994static OT_ProcRet NS(MqContextC_ConfigSetServerSetup) (MqContextC_ARGS) {
997 OT_SETUP_CALLABLE(callback)
1000 MqServiceCallbackF fCall = (callback == NULL ? NULL : NS(ServiceCall));
1001 MqConfigSetServerSetup (hdl, fCall, callback, NS(ServiceFree), NS(ServiceCopy));
1003 goto end;
1004 error:
1006 end:
1007 OT_CLEANUP_CALLABLE(callback)
1009}
1010
1012// MqContextC_ConfigApi_Interface_TCL_API
1013
1017
1018// doc-key: MqContextC,MqContextC-ConfigApi-Misc,om_
1019
1021static OT_ProcRet NS(MqContextC_ConfigReset) (MqContextC_ARGS) {
1025 MqConfigReset (hdl);
1027 goto end;
1028 error:
1030 end:
1032}
1033
1035// MqContextC_ConfigApi_Misc_TCL_API
1036
1040
1041// doc-key: MqContextC,MqContextC-ConfigApi-Set,om_
1042
1044static OT_ProcRet NS(MqContextC_ConfigCheckStartAs) (MqContextC_ARGS) {
1047 enum MqStartE data = 0;
1051 goto end;
1052 error:
1054 end:
1056}
1057
1059static OT_ProcRet NS(MqContextC_ConfigSetAllDebug) (MqContextC_ARGS) {
1062 MK_I32 data = 0;
1065 MkErrorC_Check(hdl,MqConfigSetAllDebug (hdl, data));
1067 goto end;
1068 error:
1070 end:
1072}
1073
1075static OT_ProcRet NS(MqContextC_ConfigSetAllTimeout) (MqContextC_ARGS) {
1078 MK_TIME_T data = 0;
1081 MqConfigSetAllTimeout (hdl, data);
1083 goto end;
1084 error:
1086 end:
1088}
1089
1091static OT_ProcRet NS(MqContextC_ConfigSetBuffersize) (MqContextC_ARGS) {
1094 MK_I32 data = 0;
1097 MqConfigSetBuffersize (hdl, data);
1099 goto end;
1100 error:
1102 end:
1104}
1105
1107static OT_ProcRet NS(MqContextC_ConfigSetDaemon) (MqContextC_ARGS) {
1110 MK_STRN pidfile = 0;
1113 MkErrorC_Check(hdl,MqConfigSetDaemon (hdl, pidfile));
1115 goto end;
1116 error:
1118 end:
1120}
1121
1123static OT_ProcRet NS(MqContextC_ConfigSetIdentFrom) (MqContextC_ARGS) {
1126 enum MqIdentE data = 0;
1129 MqConfigSetIdentFrom (hdl, data);
1131 goto end;
1132 error:
1134 end:
1136}
1137
1139static OT_ProcRet NS(MqContextC_ConfigSetIgnoreExit) (MqContextC_ARGS) {
1142 MK_BOOL data = 0;
1145 MqConfigSetIgnoreExit (hdl, data);
1147 goto end;
1148 error:
1150 end:
1152}
1153
1155static OT_ProcRet NS(MqContextC_ConfigSetIoPipe) (MqContextC_ARGS) {
1158 MQ_SOCK_HDL fh = 0;
1161 MkErrorC_Check(hdl,MqConfigSetIoPipe (hdl, fh));
1163 goto end;
1164 error:
1166 end:
1168}
1169
1171static OT_ProcRet NS(MqContextC_ConfigSetIoTcp) (MqContextC_ARGS) {
1174 MK_STRN host = NULL;
1176 MK_STRN port = NULL;
1178 MK_STRN myhost = NULL;
1180 MK_STRN myport = NULL;
1183 MkErrorC_Check(hdl,MqConfigSetIoTcp (hdl, host, port, myhost, myport));
1185 goto end;
1186 error:
1188 end:
1190}
1191
1193static OT_ProcRet NS(MqContextC_ConfigSetIoTcpL) (MqContextC_ARGS) {
1196 MkBufferListCreateTLS_T(vals,10);
1199 MkErrorC_Check(hdl,MqConfigSetIoTcpL (hdl, vals));
1201 goto end;
1202 error:
1204 end:
1206}
1207
1209static OT_ProcRet NS(MqContextC_ConfigSetIoUds) (MqContextC_ARGS) {
1212 MK_STRN file = 0;
1215 MkErrorC_Check(hdl,MqConfigSetIoUds (hdl, file));
1217 goto end;
1218 error:
1220 end:
1222}
1223
1225static OT_ProcRet NS(MqContextC_ConfigSetIsServer) (MqContextC_ARGS) {
1228 MK_BOOL data = 0;
1231 MqConfigSetIsServer (hdl, data);
1233 goto end;
1234 error:
1236 end:
1238}
1239
1241static OT_ProcRet NS(MqContextC_ConfigSetIsString) (MqContextC_ARGS) {
1244 MK_BOOL data = 0;
1247 MqConfigSetIsString (hdl, data);
1249 goto end;
1250 error:
1252 end:
1254}
1255
1257static OT_ProcRet NS(MqContextC_ConfigSetName) (MqContextC_ARGS) {
1260 MK_STRN data = 0;
1263 MqConfigSetName (hdl, data);
1265 goto end;
1266 error:
1268 end:
1270}
1271
1273static OT_ProcRet NS(MqContextC_ConfigSetPkgsize) (MqContextC_ARGS) {
1276 MK_I32 data = 0;
1279 MqConfigSetPkgsize (hdl, data);
1281 goto end;
1282 error:
1284 end:
1286}
1287
1289static OT_ProcRet NS(MqContextC_ConfigSetPostfix) (MqContextC_ARGS) {
1292 MK_STRN data = 0;
1295 MqConfigSetPostfix (hdl, data);
1297 goto end;
1298 error:
1300 end:
1302}
1303
1305static OT_ProcRet NS(MqContextC_ConfigSetPrefix) (MqContextC_ARGS) {
1308 MK_STRN data = 0;
1311 MqConfigSetPrefix (hdl, data);
1313 goto end;
1314 error:
1316 end:
1318}
1319
1321static OT_ProcRet NS(MqContextC_ConfigSetStartAs) (MqContextC_ARGS) {
1324 enum MqStartE data = 0;
1327 MkErrorC_Check(hdl,MqConfigSetStartAs (hdl, data));
1329 goto end;
1330 error:
1332 end:
1334}
1335
1337static OT_ProcRet NS(MqContextC_ConfigSetStartAsString) (MqContextC_ARGS) {
1340 MK_STRN data = 0;
1345 goto end;
1346 error:
1348 end:
1350}
1351
1353static OT_ProcRet NS(MqContextC_ConfigSetStorage) (MqContextC_ARGS) {
1356 MK_STRN data = 0;
1359 MqConfigSetStorage (hdl, data);
1361 goto end;
1362 error:
1364 end:
1366}
1367
1369static OT_ProcRet NS(MqContextC_ConfigSetTimeout) (MqContextC_ARGS) {
1372 MK_TIME_T data = 0;
1375 MqConfigSetTimeout (hdl, data);
1377 goto end;
1378 error:
1380 end:
1382}
1383
1385// MqContextC_ConfigApi_Set_TCL_API
1386
1390
1391// doc-key: MqContextC,MqContextC-EnvApi-Env,om_
1392
1394static OT_ProcRet NS(MqContextC_EnvProtect) (MqContextC_ARGS) {
1398 MqEnvProtect (hdl);
1400 goto end;
1401 error:
1403 end:
1405}
1406
1408static OT_ProcRet NS(MqContextC_EnvRestore) (MqContextC_ARGS) {
1412 MqEnvRestore (hdl);
1414 goto end;
1415 error:
1417 end:
1419}
1420
1422// MqContextC_EnvApi_Env_TCL_API
1423
1427
1428// doc-key: MqContextC,MqContextC-ErrorApi-Error,oc_
1429
1431static OT_ProcRet NS(MqContextC_ErrorFORMAT) (MqContextC_ARGS) {
1435 MK_ERR retVal = MqContextErrorFORMAT (hdl);
1436 OT_retObj_SET_ERR(retVal);
1437 goto end;
1438 error:
1440 end:
1442}
1443
1444// doc-key: MqContextC,MqContextC-ErrorApi-Error,om_
1445
1447OT_ProcRet NS(MqContextC_ErrorCopy) (MqContextC_ARGS) {
1450 MQ_CTXN sourceCtx = 0;
1453 OT_retObj_SET(OT_NEW_Mk_enum_OBJ(ErrorE,MqContextErrorCopy (hdl, sourceCtx)));
1454 goto end;
1455 error:
1457 end:
1459}
1460
1462OT_ProcRet NS(MqContextC_ErrorMove) (MqContextC_ARGS) {
1465 MQ_CTXN sourceCtx = 0;
1468 OT_retObj_SET(OT_NEW_Mk_enum_OBJ(ErrorE,MqContextErrorMove (hdl, sourceCtx)));
1469 goto end;
1470 error:
1472 end:
1474}
1475
1477// MqContextC_ErrorApi_Error_TCL_API
1478
1482
1483// doc-key: MqContextC,MqContextC-HighApi-High,om_
1484
1486OT_ProcRet NS(MqContextC_Send) (MqContextC_ARGS) ; // skip template-required
1487
1489// MqContextC_HighApi_High_TCL_API
1490
1494
1495// doc-key: MqContextC,MqContextC-LinkApi-Link,oc_
1496
1498static OT_ProcRet NS(MqContextC_LinkGetParent) (MqContextC_ARGS) {
1502 MQ_CTX retVal = MqLinkGetParent (hdl);
1503 OT_retObj_SET_CTX(retVal);
1504 goto end;
1505 error:
1507 end:
1509}
1510
1511// doc-key: MqContextC,MqContextC-LinkApi-Link,om_
1512
1514static OT_ProcRet NS(MqContextC_LinkConnect) (MqContextC_ARGS) {
1518 MkErrorC_Check(hdl,MqLinkConnect (hdl));
1520 goto end;
1521 error:
1523 end:
1525}
1526
1528static OT_ProcRet NS(MqContextC_LinkCreate) (MqContextC_ARGS) {
1531 MkBufferListCreateTLS_T(args,10);
1534 MkErrorC_Check(hdl,MqLinkCreate (hdl, args));
1536 goto end;
1537 error:
1539 end:
1541}
1542
1544static OT_ProcRet NS(MqContextC_LinkCreateChild) (MqContextC_ARGS) {
1547 MQ_CTX parent = 0;
1549 MkBufferListCreateTLS_T(args,10);
1552 MkErrorC_Check(hdl,MqLinkCreateChild (hdl, parent, args));
1554 goto end;
1555 error:
1557 end:
1559}
1560
1562static OT_ProcRet NS(MqContextC_LinkDelete) (MqContextC_ARGS) {
1566 MqLinkDelete (hdl);
1568 goto end;
1569 error:
1571 end:
1573}
1574
1576static OT_ProcRet NS(MqContextC_LinkGetCtxId) (MqContextC_ARGS) {
1581 goto end;
1582 error:
1584 end:
1586}
1587
1589static OT_ProcRet NS(MqContextC_LinkGetTargetIdent) (MqContextC_ARGS) {
1594 goto end;
1595 error:
1597 end:
1599}
1600
1602static OT_ProcRet NS(MqContextC_LinkIsConnected) (MqContextC_ARGS) {
1607 goto end;
1608 error:
1610 end:
1612}
1613
1615static OT_ProcRet NS(MqContextC_LinkIsParent) (MqContextC_ARGS) {
1620 goto end;
1621 error:
1623 end:
1625}
1626
1628static OT_ProcRet NS(MqContextC_LinkShutdown) (MqContextC_ARGS) {
1632 MkErrorC_Check(hdl,MqLinkShutdown (hdl));
1634 goto end;
1635 error:
1637 end:
1639}
1640
1642// MqContextC_LinkApi_Link_TCL_API
1643
1647
1648// doc-key: MqContextC,MqContextC-LogApi-Log,om_
1649
1650// skip on class-overload: MqContextLog → MkObjectLog
1653
1655static OT_ProcRet NS(MqContextC_LogConfig) (MqContextC_ARGS) {
1658 MK_OBJN fmtobj = NULL;
1660 MK_DBG debug = 0;
1662 MK_STRN callfunc = NULL;
1664 MK_I32 lvl = 0;
1667 if (debug > MkRuntimeDebugGet()) {
1669 goto end;
1670 }
1671 if (MkSysStringIsNULL(callfunc)) {callfunc = OT_GET_CALL_PROC;}
1672 MqContextLogConfig (hdl, fmtobj, debug, callfunc, lvl);
1674 goto end;
1675 error:
1677 end:
1680}
1681
1683static OT_ProcRet NS(MqContextC_LogEnv) (MqContextC_ARGS) {
1686 MK_OBJN fmtobj = NULL;
1688 MK_DBG debug = 0;
1690 MK_STRN callfunc = NULL;
1692 MK_I32 lvl = 0;
1695 if (debug > MkRuntimeDebugGet()) {
1697 goto end;
1698 }
1699 if (MkSysStringIsNULL(callfunc)) {callfunc = OT_GET_CALL_PROC;}
1700 MqContextLogEnv (hdl, fmtobj, debug, callfunc, lvl);
1702 goto end;
1703 error:
1705 end:
1708}
1709
1711static OT_ProcRet NS(MqContextC_LogLink) (MqContextC_ARGS) {
1714 MK_OBJN fmtobj = NULL;
1716 MK_DBG debug = 0;
1718 MK_STRN callfunc = NULL;
1720 MK_I32 lvl = 0;
1723 if (debug > MkRuntimeDebugGet()) {
1725 goto end;
1726 }
1727 if (MkSysStringIsNULL(callfunc)) {callfunc = OT_GET_CALL_PROC;}
1728 MqContextLogLink (hdl, fmtobj, debug, callfunc, lvl);
1730 goto end;
1731 error:
1733 end:
1736}
1737
1739static OT_ProcRet NS(MqContextC_LogSetup) (MqContextC_ARGS) {
1742 MK_OBJN fmtobj = NULL;
1744 MK_DBG debug = 0;
1746 MK_STRN callfunc = NULL;
1748 MK_I32 lvl = 0;
1751 if (debug > MkRuntimeDebugGet()) {
1753 goto end;
1754 }
1755 if (MkSysStringIsNULL(callfunc)) {callfunc = OT_GET_CALL_PROC;}
1756 MqContextLogSetup (hdl, fmtobj, debug, callfunc, lvl);
1758 goto end;
1759 error:
1761 end:
1764}
1765
1767static OT_ProcRet NS(MqContextC_LogShort) (MqContextC_ARGS) {
1770 MK_OBJN fmtobj = NULL;
1772 MK_DBG debug = 0;
1774 MK_STRN callfunc = NULL;
1776 MK_I32 lvl = 0;
1778 MK_STRN label = NULL;
1781 if (debug > MkRuntimeDebugGet()) {
1783 goto end;
1784 }
1785 if (MkSysStringIsNULL(callfunc)) {callfunc = OT_GET_CALL_PROC;}
1786 MqContextLogShort (hdl, fmtobj, debug, callfunc, lvl, label);
1788 goto end;
1789 error:
1791 end:
1794}
1795
1797static OT_ProcRet NS(MqContextC_LogType) (MqContextC_ARGS) {
1800 MK_OBJN fmtobj = NULL;
1802 MK_DBG debug = 0;
1804 MK_STRN callfunc = NULL;
1806 MK_I32 lvl = 0;
1809 if (debug > MkRuntimeDebugGet()) {
1811 goto end;
1812 }
1813 if (MkSysStringIsNULL(callfunc)) {callfunc = OT_GET_CALL_PROC;}
1814 MqContextLogType (hdl, fmtobj, debug, callfunc, lvl);
1816 goto end;
1817 error:
1819 end:
1822}
1823
1825static OT_ProcRet NS(MqContextC_LogParentOrChild) (MqContextC_ARGS) {
1830 goto end;
1831 error:
1833 end:
1835}
1836
1838static OT_ProcRet NS(MqContextC_LogServerOrClient) (MqContextC_ARGS) {
1843 goto end;
1844 error:
1846 end:
1848}
1849
1851// MqContextC_LogApi_Log_TCL_API
1852
1856
1857// doc-key: MqContextC,MqContextC-MiscApi-Misc,oc_
1858
1860static OT_ProcRet NS(MqContextC_GetBuffer) (MqContextC_ARGS) {
1864 MK_BUF retVal = MqContextGetBuffer (hdl);
1865 OT_retObj_SET_BUF(retVal);
1866 goto end;
1867 error:
1869 end:
1871}
1872
1874static OT_ProcRet NS(MqContextC_GetRoot) (MqContextC_ARGS) {
1878 MQ_CTX retVal = MqGetRoot (hdl);
1879 OT_retObj_SET_CTX(retVal);
1880 goto end;
1881 error:
1883 end:
1885}
1886
1887// doc-key: MqContextC,MqContextC-MiscApi-Misc,om_
1888
1889// skip on class-overload: MqContextToString → MkObjectToString
1891static OT_ProcRet NS(MqContextC_ToString) (MqContextC_ARGS) {OT_ERROR_LNG_RETURN;}
1892
1894static OT_ProcRet NS(MqContextC_Exit) (MqContextC_ARGS) {
1897 MK_STRN callfunc = NULL;
1899 MK_STRN callfile = NULL;
1901 MK_I32 callline = -1;
1904 if (callline == -1 ) {callline = OT_GET_CALL_LINE;}
1905 if (MkSysStringIsNULL(callfile)) {callfile = OT_GET_CALL_FILE;}
1906 if (MkSysStringIsNULL(callfunc)) {callfunc = OT_GET_CALL_PROC;}
1907 OT_retObj_SET_I32(MqExit (hdl, callfunc, callfile, callline));
1908 goto end;
1909 error:
1911 end:
1914}
1915
1933
1935// MqContextC_MiscApi_Misc_TCL_API
1936
1940
1941// doc-key: MqContextC,MqContextC-ProxyApi-Proxy,om_
1942
1944static OT_ProcRet NS(MqContextC_ProxyForward) (MqContextC_ARGS) {
1947 MQ_CTX targetCtx = 0;
1949 MQ_DMP dump = NULL;
1954 MkErrorC_Check(hdl,MqProxyForward (hdl, targetCtx, dump, timeout));
1956 goto end;
1957 error:
1959 end:
1961}
1962
1964static OT_ProcRet NS(MqContextC_ProxyItem) (MqContextC_ARGS) {
1967 MQ_CTX targetCtx = 0;
1970 MkErrorC_Check(hdl,MqProxyItem (hdl, targetCtx));
1972 goto end;
1973 error:
1975 end:
1977}
1978
1980// MqContextC_ProxyApi_Proxy_TCL_API
1981
1985
1986// doc-key: MqContextC,MqContextC-ReadApi-Atom,oci
1987
1989static OT_ProcRet NS(MqContextC_ReadALL) (MqContextC_ARGS) {
1992 MkBufferListCreateTLS_T(val_inout,10);
1995 MkErrorC_Check(hdl,MqReadALL (hdl, &val_inout));
1996 OT_retObj_SET_BFL(val_inout);
1997 goto end;
1998 error:
2000 end:
2002}
2003
2004// doc-key: MqContextC,MqContextC-ReadApi-Atom,oco
2005
2007static OT_ProcRet NS(MqContextC_ReadBFL) (MqContextC_ARGS) {
2011 MK_BFL val_out;
2012 MkErrorC_Check(hdl,MqReadBFL (hdl, &val_out));
2013 OT_retObj_SET_BFL(val_out);
2014 goto end;
2015 error:
2017 end:
2019}
2020
2022static OT_ProcRet NS(MqContextC_ReadBUF) (MqContextC_ARGS) {
2026 MK_BUF val_out;
2027 MkErrorC_Check(hdl,MqReadBUF (hdl, &val_out));
2028 OT_retObj_SET_BUF(val_out);
2029 goto end;
2030 error:
2032 end:
2034}
2035
2036// doc-key: MqContextC,MqContextC-ReadApi-Atom,omo
2037
2039static OT_ProcRet NS(MqContextC_ReadBIN) (MqContextC_ARGS) {
2043 MkBinaryR val_out;
2044 MkErrorC_Check(hdl,MqReadBIN (hdl, &val_out));
2045 MkBinaryR retVal = val_out;
2047 goto end;
2048 error:
2050 end:
2052}
2053
2055static OT_ProcRet NS(MqContextC_ReadBOL) (MqContextC_ARGS) {
2059 MK_BOL val_out;
2060 MkErrorC_Check(hdl,MqReadBOL (hdl, &val_out));
2061 OT_retObj_SET_BOL(val_out == 1);
2062 goto end;
2063 error:
2065 end:
2067}
2068
2070static OT_ProcRet NS(MqContextC_ReadBinaryR) (MqContextC_ARGS) {
2074 MkBinaryR val_out;
2075 MkErrorC_Check(hdl,MqReadBinaryR (hdl, &val_out));
2076 MkBinaryR retVal = val_out;
2078 goto end;
2079 error:
2081 end:
2083}
2084
2086static OT_ProcRet NS(MqContextC_ReadDBL) (MqContextC_ARGS) {
2090 MK_DBL val_out;
2091 MkErrorC_Check(hdl,MqReadDBL (hdl, &val_out));
2092 OT_retObj_SET_DBL(val_out);
2093 goto end;
2094 error:
2096 end:
2098}
2099
2101static OT_ProcRet NS(MqContextC_ReadFLT) (MqContextC_ARGS) {
2105 MK_FLT val_out;
2106 MkErrorC_Check(hdl,MqReadFLT (hdl, &val_out));
2107 OT_retObj_SET_FLT(val_out);
2108 goto end;
2109 error:
2111 end:
2113}
2114
2116static OT_ProcRet NS(MqContextC_ReadHDL) (MqContextC_ARGS) {
2120 MK_HDL val_out;
2121 MkErrorC_Check(hdl,MqReadHDL (hdl, &val_out));
2122 OT_retObj_SET_HDL(val_out);
2123 goto end;
2124 error:
2126 end:
2128}
2129
2131static OT_ProcRet NS(MqContextC_ReadI16) (MqContextC_ARGS) {
2135 MK_I16 val_out;
2136 MkErrorC_Check(hdl,MqReadI16 (hdl, &val_out));
2137 OT_retObj_SET_I16(val_out);
2138 goto end;
2139 error:
2141 end:
2143}
2144
2146static OT_ProcRet NS(MqContextC_ReadI32) (MqContextC_ARGS) {
2150 MK_I32 val_out;
2151 MkErrorC_Check(hdl,MqReadI32 (hdl, &val_out));
2152 OT_retObj_SET_I32(val_out);
2153 goto end;
2154 error:
2156 end:
2158}
2159
2161static OT_ProcRet NS(MqContextC_ReadI64) (MqContextC_ARGS) {
2165 MK_I64 val_out;
2166 MkErrorC_Check(hdl,MqReadI64 (hdl, &val_out));
2167 OT_retObj_SET_I64(val_out);
2168 goto end;
2169 error:
2171 end:
2173}
2174
2176static OT_ProcRet NS(MqContextC_ReadI8) (MqContextC_ARGS) {
2180 MK_I8 val_out;
2181 MkErrorC_Check(hdl,MqReadI8 (hdl, &val_out));
2182 OT_retObj_SET_I8(val_out);
2183 goto end;
2184 error:
2186 end:
2188}
2189
2191OT_ProcRet NS(MqContextC_ReadLIST) (MqContextC_ARGS) ; // skip template-required
2192
2194static OT_ProcRet NS(MqContextC_ReadLONG) (MqContextC_ARGS) {
2198 MK_LONG val_out;
2199 MkErrorC_Check(hdl,MqReadLONG (hdl, &val_out));
2200 OT_retObj_SET_LONG(val_out);
2201 goto end;
2202 error:
2204 end:
2206}
2207
2209OT_ProcRet NS(MqContextC_ReadNEXT) (MqContextC_ARGS) ; // skip template-required
2210
2212static OT_ProcRet NS(MqContextC_ReadSTR) (MqContextC_ARGS) {
2216 MK_STRN val_out;
2217 MkErrorC_Check(hdl,MqReadSTR (hdl, &val_out));
2218 OT_retObj_SET_STR(val_out);
2219 goto end;
2220 error:
2222 end:
2224}
2225
2227static OT_ProcRet NS(MqContextC_ReadStringR) (MqContextC_ARGS) {
2231 MkStringR val_out;
2232 MkErrorC_Check(hdl,MqReadStringR (hdl, &val_out));
2233 MkStringR retVal = val_out;
2235 goto end;
2236 error:
2238 end:
2240}
2241
2243// MqContextC_ReadApi_Atom_TCL_API
2244
2248
2249// doc-key: MqContextC,MqContextC-ReadApi-Block,om_
2250
2252static OT_ProcRet NS(MqContextC_ReadL_END) (MqContextC_ARGS) {
2256 MkErrorC_Check(hdl,MqReadL_END (hdl));
2258 goto end;
2259 error:
2261 end:
2263}
2264
2266static OT_ProcRet NS(MqContextC_ReadL_START) (MqContextC_ARGS) {
2269 MK_BUF buf = NULL;
2272 MkErrorC_Check(hdl,MqReadL_START (hdl, buf));
2274 goto end;
2275 error:
2277 end:
2279}
2280
2282static OT_ProcRet NS(MqContextC_ReadT_END) (MqContextC_ARGS) {
2286 MkErrorC_Check(hdl,MqReadT_END (hdl));
2288 goto end;
2289 error:
2291 end:
2293}
2294
2296static OT_ProcRet NS(MqContextC_ReadT_START) (MqContextC_ARGS) {
2300 MkErrorC_Check(hdl,MqReadT_START (hdl));
2302 goto end;
2303 error:
2305 end:
2307}
2308
2310// MqContextC_ReadApi_Block_TCL_API
2311
2315
2316// doc-key: MqContextC,MqContextC-ReadApi-Misc,om_
2317
2319static OT_ProcRet NS(MqContextC_ReadDbg) (MqContextC_ARGS) {
2323 MqReadDbg (hdl);
2325 goto end;
2326 error:
2328 end:
2330}
2331
2333static OT_ProcRet NS(MqContextC_ReadGetNextType) (MqContextC_ARGS) {
2338 goto end;
2339 error:
2341 end:
2343}
2344
2346static OT_ProcRet NS(MqContextC_ReadGetNumItems) (MqContextC_ARGS) {
2351 goto end;
2352 error:
2354 end:
2356}
2357
2359static OT_ProcRet NS(MqContextC_ReadItemExists) (MqContextC_ARGS) {
2364 goto end;
2365 error:
2367 end:
2369}
2370
2372static OT_ProcRet NS(MqContextC_ReadUndo) (MqContextC_ARGS) {
2376 MkErrorC_Check(hdl,MqReadUndo (hdl));
2378 goto end;
2379 error:
2381 end:
2383}
2384
2386// MqContextC_ReadApi_Misc_TCL_API
2387
2391
2392// doc-key: MqContextC,MqContextC-RouteApi-Route,oco
2393
2395static OT_ProcRet NS(MqContextC_RouteGetTree) (MqContextC_ARGS) {
2399 MK_BFL treeP_out;
2400 MkErrorC_Check(hdl,MqRouteGetTree (hdl, &treeP_out));
2401 OT_retObj_SET_BFL(treeP_out);
2402 goto end;
2403 error:
2405 end:
2407}
2408
2409// doc-key: MqContextC,MqContextC-RouteApi-Route,om_
2410
2412static OT_ProcRet NS(MqContextC_RouteCreate) (MqContextC_ARGS) {
2415 MK_STRN route = 0;
2417 MK_STRN service = 0;
2419 MK_BOOL overwrite = false;
2420 OT_CHECK_OPTIONAL(OT_CHECK_bool (overwrite))
2422 MkErrorC_Check(hdl,MqRouteCreate (hdl, route, service, overwrite));
2424 goto end;
2425 error:
2427 end:
2429}
2430
2432static OT_ProcRet NS(MqContextC_RouteDelete) (MqContextC_ARGS) {
2435 MK_STRN route = 0;
2437 MK_STRN service = 0;
2439 MK_BOOL overwrite = false;
2440 OT_CHECK_OPTIONAL(OT_CHECK_bool (overwrite))
2442 MkErrorC_Check(hdl,MqRouteDelete (hdl, route, service, overwrite));
2444 goto end;
2445 error:
2447 end:
2449}
2450
2452static OT_ProcRet NS(MqContextC_RouteResolve) (MqContextC_ARGS) {
2455 MK_STRN ident = 0;
2457 MK_NUM retnum = -1;
2460 MQ_CTX_A retVal = MqRouteResolve (hdl, ident, retnum);
2462 for (int i=0; i<retVal.size; i++) {
2464 }
2465 goto end;
2466 error:
2468 end:
2470}
2471
2473static OT_ProcRet NS(MqContextC_RouteTraverse) (MqContextC_ARGS) {
2476 MK_STRN service = 0;
2478 MkBufferListCreateTLS_T(args,10);
2481 MkErrorC_Check(hdl,MqRouteTraverse (hdl, service, args));
2483 goto end;
2484 error:
2486 end:
2488}
2489
2490// doc-key: MqContextC,MqContextC-RouteApi-Route,omo
2491
2493static OT_ProcRet NS(MqContextC_RouteGetPath) (MqContextC_ARGS) {
2497 MK_STRN path_out;
2498 MkErrorC_Check(hdl,MqRouteGetPath (hdl, &path_out));
2499 OT_retObj_SET_STR(path_out);
2500 goto end;
2501 error:
2503 end:
2505}
2506
2508// MqContextC_RouteApi_Route_TCL_API
2509
2513
2514// doc-key: MqContextC,MqContextC-SendApi-Atom,om_
2515
2517static OT_ProcRet NS(MqContextC_SendBFL) (MqContextC_ARGS) {
2523 MkErrorC_Check(hdl,MqSendBFL (hdl, val));
2525 goto end;
2526 error:
2528 end:
2530}
2531
2533static OT_ProcRet NS(MqContextC_SendBIN) (MqContextC_ARGS) {
2536 MkBinaryR val = {0};
2539 MkErrorC_Check(hdl,MqSendBIN (hdl, val));
2541 goto end;
2542 error:
2544 end:
2546}
2547
2549static OT_ProcRet NS(MqContextC_SendBOL) (MqContextC_ARGS) {
2552 MK_BOL val = 0;
2555 MkErrorC_Check(hdl,MqSendBOL (hdl, (MK_BOL)(val?1:0)));
2557 goto end;
2558 error:
2560 end:
2562}
2563
2565static OT_ProcRet NS(MqContextC_SendBUF) (MqContextC_ARGS) {
2568 MK_BUFN val = 0;
2571 MkErrorC_Check(hdl,MqSendBUF (hdl, val));
2573 goto end;
2574 error:
2576 end:
2578}
2579
2581static OT_ProcRet NS(MqContextC_SendBUS_FLAT) (MqContextC_ARGS) {
2584 MK_BUSN val = 0;
2587 MkErrorC_Check(hdl,MqSendBUS_FLAT (hdl, val));
2589 goto end;
2590 error:
2592 end:
2594}
2595
2597static OT_ProcRet NS(MqContextC_SendBinaryR) (MqContextC_ARGS) {
2600 MkBinaryR val = {0};
2603 MkErrorC_Check(hdl,MqSendBinaryR (hdl, val));
2605 goto end;
2606 error:
2608 end:
2610}
2611
2613static OT_ProcRet NS(MqContextC_SendDBL) (MqContextC_ARGS) {
2616 MK_DBL val = 0;
2619 MkErrorC_Check(hdl,MqSendDBL (hdl, val));
2621 goto end;
2622 error:
2624 end:
2626}
2627
2629static OT_ProcRet NS(MqContextC_SendFLT) (MqContextC_ARGS) {
2632 MK_FLT val = 0;
2635 MkErrorC_Check(hdl,MqSendFLT (hdl, val));
2637 goto end;
2638 error:
2640 end:
2642}
2643
2645static OT_ProcRet NS(MqContextC_SendHDL) (MqContextC_ARGS) {
2648 MK_HDL val = 0;
2651 MkErrorC_Check(hdl,MqSendHDL (hdl, val));
2653 goto end;
2654 error:
2656 end:
2658}
2659
2661static OT_ProcRet NS(MqContextC_SendI16) (MqContextC_ARGS) {
2664 MK_I16 val = 0;
2667 MkErrorC_Check(hdl,MqSendI16 (hdl, val));
2669 goto end;
2670 error:
2672 end:
2674}
2675
2677static OT_ProcRet NS(MqContextC_SendI32) (MqContextC_ARGS) {
2680 MK_I32 val = 0;
2683 MkErrorC_Check(hdl,MqSendI32 (hdl, val));
2685 goto end;
2686 error:
2688 end:
2690}
2691
2693static OT_ProcRet NS(MqContextC_SendI64) (MqContextC_ARGS) {
2696 MK_I64 val = 0;
2699 MkErrorC_Check(hdl,MqSendI64 (hdl, val));
2701 goto end;
2702 error:
2704 end:
2706}
2707
2709static OT_ProcRet NS(MqContextC_SendI8) (MqContextC_ARGS) {
2712 MK_I8 val = 0;
2715 MkErrorC_Check(hdl,MqSendI8 (hdl, (MK_I8)(val)));
2717 goto end;
2718 error:
2720 end:
2722}
2723
2725static OT_ProcRet NS(MqContextC_SendLONG) (MqContextC_ARGS) {
2728 MK_LONG val = 0;
2731 MkErrorC_Check(hdl,MqSendLONG (hdl, val));
2733 goto end;
2734 error:
2736 end:
2738}
2739
2741static OT_ProcRet NS(MqContextC_SendLTR) (MqContextC_ARGS) {
2744 MQ_LTR transLId = 0;
2747 MkErrorC_Check(hdl,MqSendLTR (hdl, transLId));
2749 goto end;
2750 error:
2752 end:
2754}
2755
2757static OT_ProcRet NS(MqContextC_SendL_FLAT) (MqContextC_ARGS) {
2763 MkErrorC_Check(hdl,MqSendL_FLAT (hdl, val));
2765 goto end;
2766 error:
2768 end:
2770}
2771
2773static OT_ProcRet NS(MqContextC_SendSTR) (MqContextC_ARGS) {
2776 MK_STRN val = 0;
2779 MkErrorC_Check(hdl,MqSendSTR (hdl, val));
2781 goto end;
2782 error:
2784 end:
2786}
2787
2789static OT_ProcRet NS(MqContextC_SendStringR) (MqContextC_ARGS) {
2792 MkStringR val = {0};
2795 MkErrorC_Check(hdl,MqSendStringR (hdl, val));
2797 goto end;
2798 error:
2800 end:
2802}
2803
2805// MqContextC_SendApi_Atom_TCL_API
2806
2810
2811// doc-key: MqContextC,MqContextC-SendApi-Basics,om_
2812
2830
2832static OT_ProcRet NS(MqContextC_SendEND_AND_CALLBACK) (MqContextC_ARGS) {
2835 MQ_TOK token = 0;
2837 OT_SETUP_CALLABLE(callback)
2842 MkErrorC_Check(hdl,MqSendEND_AND_CALLBACK (hdl, token, NS(ServiceCall), callback, NS(ServiceFree), timeout));
2844 goto end;
2845 error:
2847 end:
2848 OT_CLEANUP_CALLABLE(callback)
2850}
2851
2853static OT_ProcRet NS(MqContextC_SendEND_AND_SUB) (MqContextC_ARGS) {
2856 MQ_TOK token = 0;
2858 OT_SETUP_CALLABLE(callback)
2863 MkErrorC_Check(hdl,MqSendEND_AND_SUB (hdl, token, NS(ServiceCall), callback, NS(ServiceFree), timeout));
2865 goto end;
2866 error:
2868 end:
2869 OT_CLEANUP_CALLABLE(callback)
2871}
2872
2874static OT_ProcRet NS(MqContextC_SendEND_AND_TRANSACTION) (MqContextC_ARGS) {
2877 MQ_TOK token = 0;
2879 MQ_TOK callback = 0;
2886 goto end;
2887 error:
2889 end:
2891}
2892
2910
2912static OT_ProcRet NS(MqContextC_SendSTART) (MqContextC_ARGS) {
2916 MkErrorC_Check(hdl,MqSendSTART (hdl));
2918 goto end;
2919 error:
2921 end:
2923}
2924
2926static OT_ProcRet NS(MqContextC_SendSYNC) (MqContextC_ARGS) {
2930 MkErrorC_Check(hdl,MqSendSYNC (hdl));
2932 goto end;
2933 error:
2935 end:
2937}
2938
2940// MqContextC_SendApi_Basics_TCL_API
2941
2945
2946// doc-key: MqContextC,MqContextC-SendApi-Block,om_
2947
2949static OT_ProcRet NS(MqContextC_SendL_END) (MqContextC_ARGS) {
2953 MkErrorC_Check(hdl,MqSendL_END (hdl));
2955 goto end;
2956 error:
2958 end:
2960}
2961
2963static OT_ProcRet NS(MqContextC_SendL_START) (MqContextC_ARGS) {
2967 MkErrorC_Check(hdl,MqSendL_START (hdl));
2969 goto end;
2970 error:
2972 end:
2974}
2975
2977static OT_ProcRet NS(MqContextC_SendT_END) (MqContextC_ARGS) {
2981 MkErrorC_Check(hdl,MqSendT_END (hdl));
2983 goto end;
2984 error:
2986 end:
2988}
2989
2991static OT_ProcRet NS(MqContextC_SendT_START) (MqContextC_ARGS) {
2995 MkErrorC_Check(hdl,MqSendT_START (hdl));
2997 goto end;
2998 error:
3000 end:
3002}
3003
3005// MqContextC_SendApi_Block_TCL_API
3006
3010
3011// doc-key: MqContextC,MqContextC-SendApi-Return,om_
3012
3014static OT_ProcRet NS(MqContextC_SendERROR) (MqContextC_ARGS) {
3018 MkErrorC_Check(hdl,MqSendERROR (hdl));
3020 goto end;
3021 error:
3023 end:
3025}
3026
3028static OT_ProcRet NS(MqContextC_SendRETURN) (MqContextC_ARGS) {
3032 MkErrorC_Check(hdl,MqSendRETURN (hdl));
3034 goto end;
3035 error:
3037 end:
3039}
3040
3042static OT_ProcRet NS(MqContextC_SendRETURN_SUB) (MqContextC_ARGS) {
3048 goto end;
3049 error:
3051 end:
3053}
3054
3056// MqContextC_SendApi_Return_TCL_API
3057
3061
3062// doc-key: MqContextC,MqContextC-ServiceApi-Service,om_
3063
3065static OT_ProcRet NS(MqContextC_ServiceCreate) (MqContextC_ARGS) {
3068 MQ_TOK token = 0;
3070 OT_SETUP_CALLABLE(callback)
3073 MkErrorC_Check(hdl,MqServiceCreate (hdl, token, NS(ServiceCall), callback, NS(ServiceFree), NULL));
3075 goto end;
3076 error:
3078 end:
3079 OT_CLEANUP_CALLABLE(callback)
3081}
3082
3084static OT_ProcRet NS(MqContextC_ServiceDelete) (MqContextC_ARGS) {
3087 MQ_TOK token = 0;
3092 goto end;
3093 error:
3095 end:
3097}
3098
3100static OT_ProcRet NS(MqContextC_ServiceIsTransaction) (MqContextC_ARGS) {
3105 goto end;
3106 error:
3108 end:
3110}
3111
3113static OT_ProcRet NS(MqContextC_ServiceProxy) (MqContextC_ARGS) {
3116 MQ_TOK token = 0;
3121 MkErrorC_Check(hdl,MqServiceProxy (hdl, token, id));
3123 goto end;
3124 error:
3126 end:
3128}
3129
3131static OT_ProcRet NS(MqContextC_ServiceProxyCtx) (MqContextC_ARGS) {
3134 MQ_TOK token = 0;
3136 MQ_CTX target = 0;
3139 MkErrorC_Check(hdl,MqServiceProxyCtx (hdl, token, target));
3141 goto end;
3142 error:
3144 end:
3146}
3147
3149static OT_ProcRet NS(MqContextC_ServiceProxyCtxExists) (MqContextC_ARGS) {
3152 MQ_TOK token = 0;
3154 MQ_CTX target = 0;
3158 goto end;
3159 error:
3161 end:
3163}
3164
3166static OT_ProcRet NS(MqContextC_ServiceProxyRoundRobin) (MqContextC_ARGS) {
3169 MQ_TOK token = 0;
3171 MK_STRN ident = 0;
3176 goto end;
3177 error:
3179 end:
3181}
3182
3184static OT_ProcRet NS(MqContextC_ServiceStorage) (MqContextC_ARGS) {
3187 MQ_TOK token = 0;
3192 goto end;
3193 error:
3195 end:
3197}
3198
3200static OT_ProcRet NS(MqContextC_ServiceTokenCheck) (MqContextC_ARGS) {
3203 MQ_TOK token = 0;
3207 goto end;
3208 error:
3210 end:
3212}
3213
3215static OT_ProcRet NS(MqContextC_ServiceTokenExists) (MqContextC_ARGS) {
3218 MQ_TOK token = 0;
3222 goto end;
3223 error:
3225 end:
3227}
3228
3230static OT_ProcRet NS(MqContextC_ServiceTokenGet) (MqContextC_ARGS) {
3235 goto end;
3236 error:
3238 end:
3240}
3241
3243// MqContextC_ServiceApi_Service_TCL_API
3244
3248
3249// doc-key: MqContextC,MqContextC-SlaveApi-Slave,oc_
3250
3252static OT_ProcRet NS(MqContextC_SlaveGetMaster) (MqContextC_ARGS) {
3256 MQ_CTX retVal = MqSlaveGetMaster (hdl);
3257 OT_retObj_SET_CTX(retVal);
3258 goto end;
3259 error:
3261 end:
3263}
3264
3265// doc-key: MqContextC,MqContextC-SlaveApi-Slave,oco
3266
3268static OT_ProcRet NS(MqContextC_SlaveGet) (MqContextC_ARGS) {
3271 MQ_SLAVE_ID id = 0;
3274 MQ_CTX ctx_out;
3275 MkErrorC_Check(hdl,MqSlaveGet (hdl, id, &ctx_out));
3276 OT_retObj_SET_CTX(ctx_out);
3277 goto end;
3278 error:
3280 end:
3282}
3283
3285static OT_ProcRet NS(MqContextC_SlaveGetFilter) (MqContextC_ARGS) {
3289 MQ_CTX ctx_out;
3290 MkErrorC_Check(hdl,MqSlaveGetFilter (hdl, &ctx_out));
3291 OT_retObj_SET_CTX(ctx_out);
3292 goto end;
3293 error:
3295 end:
3297}
3298
3300static OT_ProcRet NS(MqContextC_SlaveGetProxy) (MqContextC_ARGS) {
3303 MQ_SLAVE_ID id = 0;
3306 MQ_CTX ctx_out;
3307 MkErrorC_Check(hdl,MqSlaveGetProxy (hdl, id, &ctx_out));
3308 OT_retObj_SET_CTX(ctx_out);
3309 goto end;
3310 error:
3312 end:
3314}
3315
3316// doc-key: MqContextC,MqContextC-SlaveApi-Slave,om_
3317
3319static OT_ProcRet NS(MqContextC_SlaveCheck) (MqContextC_ARGS) {
3322 MQ_SLAVE_ID id = 0;
3326 goto end;
3327 error:
3329 end:
3331}
3332
3334static OT_ProcRet NS(MqContextC_SlaveCreate) (MqContextC_ARGS) {
3337 MQ_SLAVE_ID id = 0;
3339 MQ_CTX slave = 0;
3342 MkErrorC_Check(hdl,MqSlaveCreate (hdl, id, slave));
3344 goto end;
3345 error:
3347 end:
3349}
3350
3352static OT_ProcRet NS(MqContextC_SlaveDelete) (MqContextC_ARGS) {
3355 MQ_SLAVE_ID id = 0;
3358 MkErrorC_Check(hdl,MqSlaveDelete (hdl, id));
3360 goto end;
3361 error:
3363 end:
3365}
3366
3368static OT_ProcRet NS(MqContextC_SlaveIs) (MqContextC_ARGS) {
3373 goto end;
3374 error:
3376 end:
3378}
3379
3381static OT_ProcRet NS(MqContextC_SlaveWorker) (MqContextC_ARGS) {
3384 MQ_SLAVE_ID id = 0;
3386 MK_STRN fct = "WORKER";
3388 MkBufferListCreateTLS_T(args,10);
3391 MkErrorC_Check(hdl,MqSlaveWorker (hdl, id, fct, args));
3393 goto end;
3394 error:
3396 end:
3398}
3399
3401// MqContextC_SlaveApi_Slave_TCL_API
3402
3406
3407// doc-key: MqContextC,MqContextC-StorageApi-Storage,oci
3408
3410static OT_ProcRet NS(MqContextC_StorageDelete) (MqContextC_ARGS) {
3413 MQ_LTR transLIdP_inout = 0;
3414 OT_CHECK_OPTIONAL(OT_CHECK_NI4 (transLIdP_inout))
3416 MkErrorC_Check(hdl,MqStorageDelete (hdl, &transLIdP_inout));
3417 OT_retObj_SET_I32(transLIdP_inout);
3418 goto end;
3419 error:
3421 end:
3423}
3424
3426static OT_ProcRet NS(MqContextC_StorageImport) (MqContextC_ARGS) {
3429 MQ_LTR transLIdP_inout = 0;
3430 OT_CHECK_OPTIONAL(OT_CHECK_NI4 (transLIdP_inout))
3432 MkErrorC_Check(hdl,MqStorageImport (hdl, &transLIdP_inout));
3433 OT_retObj_SET_I32(transLIdP_inout);
3434 goto end;
3435 error:
3437 end:
3439}
3440
3441// doc-key: MqContextC,MqContextC-StorageApi-Storage,om_
3442
3444static OT_ProcRet NS(MqContextC_StorageClose) (MqContextC_ARGS) {
3448 MkErrorC_Check(hdl,MqStorageClose (hdl));
3450 goto end;
3451 error:
3453 end:
3455}
3456
3458static OT_ProcRet NS(MqContextC_StorageDecrRef) (MqContextC_ARGS) {
3461 MQ_LTR transLId = 0;
3464 MkErrorC_Check(hdl,MqStorageDecrRef (hdl, transLId));
3466 goto end;
3467 error:
3469 end:
3471}
3472
3474static OT_ProcRet NS(MqContextC_StorageIncrRef) (MqContextC_ARGS) {
3477 MQ_LTR transLId = 0;
3480 MkErrorC_Check(hdl,MqStorageIncrRef (hdl, transLId));
3482 goto end;
3483 error:
3485 end:
3487}
3488
3490static OT_ProcRet NS(MqContextC_StorageLog) (MqContextC_ARGS) {
3493 MK_STRN callfunc = NULL;
3496 if (MkSysStringIsNULL(callfunc)) {callfunc = OT_GET_CALL_PROC;}
3497 MkErrorC_Check(hdl,MqStorageLog (hdl, callfunc));
3499 goto end;
3500 error:
3502 end:
3505}
3506
3508static OT_ProcRet NS(MqContextC_StorageOpen) (MqContextC_ARGS) {
3511 MK_STRN storageFile = 0;
3512 OT_CHECK_REQUIRED(OT_CHECK_STRN (storageFile))
3514 MkErrorC_Check(hdl,MqStorageOpen (hdl, storageFile));
3516 goto end;
3517 error:
3519 end:
3521}
3522
3523// doc-key: MqContextC,MqContextC-StorageApi-Storage,omo
3524
3526static OT_ProcRet NS(MqContextC_StorageCount) (MqContextC_ARGS) {
3530 MQ_LTR cnt_out;
3531 MkErrorC_Check(hdl,MqStorageCount (hdl, &cnt_out));
3532 OT_retObj_SET_I32(cnt_out);
3533 goto end;
3534 error:
3536 end:
3538}
3539
3541static OT_ProcRet NS(MqContextC_StorageErrCnt) (MqContextC_ARGS) {
3544 MQ_LTR transLId = 0;
3547 MK_I32 cnt_out;
3548 MkErrorC_Check(hdl,MqStorageErrCnt (hdl, transLId, &cnt_out));
3549 OT_retObj_SET_I32(cnt_out);
3550 goto end;
3551 error:
3553 end:
3555}
3556
3558static OT_ProcRet NS(MqContextC_StorageExport) (MqContextC_ARGS) {
3562 MQ_LTR ltid_out;
3563 MkErrorC_Check(hdl,MqStorageExport (hdl, &ltid_out));
3564 OT_retObj_SET_I32(ltid_out);
3565 goto end;
3566 error:
3568 end:
3570}
3571
3573static OT_ProcRet NS(MqContextC_StorageResolve) (MqContextC_ARGS) {
3577 MQ_CTX otherCtxP_out;
3578 MQ_LTR otherLIdP_out;
3579 MkErrorC_Check(hdl,MqStorageResolve (hdl, &otherCtxP_out, &otherLIdP_out));
3581 OT_retObj_APPEND(OT_TMP_CTX_OBJ(otherCtxP_out));
3582 OT_retObj_APPEND(OT_TMP_I32_OBJ(otherLIdP_out));
3583 goto end;
3584 error:
3586 end:
3588}
3589
3591// MqContextC_StorageApi_Storage_TCL_API
3592
3596
3597// doc-key: MqContextC,MqContextC-TOR,sCc
3598
3600static OT_ProcRet NS(MqContextC_CTOR) (CONSTR_ARGS) {
3603 MQ_CTX tmpl = NULL;
3605 MQ_CTX retVal = MqContextCreate (MqContextCTT, tmpl);
3606 if (retVal == NULL) {
3607 OT_ERROR_CONSTRUCTOR(MqContextC);
3608 goto error;
3609 }
3610 OT_CONSTRUCTOR_POST(retVal)
3611 OT_retObj_CONSTR(retVal);
3612 goto end;
3613 error:
3615 end:
3617}
3618
3620static OT_ProcRet NS(MqContextC_Create) (OtClass_ARGS) {
3623 MQ_CTX tmpl = NULL;
3626 MQ_CTX retVal = MqContextCreate (MqContextCTT, tmpl);
3627 if (retVal == NULL) {
3628 OT_ERROR_CONSTRUCTOR(MqContextC);
3629 goto error;
3630 }
3631 OT_CONSTRUCTOR_POST(retVal)
3632 OT_retObj_SET_CTX(retVal);
3633 goto end;
3634 error:
3636 end:
3638}
3639
3641// MqContextC_TOR_TCL_API
3642
3643// END-MqContextC - created by 'tcl_MqC.tcl -i NHI1_HOME/theLink/c/gen/c_mqmsgque.meta' - DO NOT change
3644
3645// ---------------------------------------------------------------------------------------
3646
3647static Tcl_MethodType NS(sOtClassDef)[] = {
3648// BEGIN-CLASS - created by 'tcl_MqS.tcl -i NHI1_HOME/theLink/c/gen/c_mqmsgque.meta' - DO NOT change
3649
3650// doc-key: MqContextC,MqContext,sCc
3651 {VER, "Create" , NS(MqContextC_Create) , NULL, NULL},
3652
3653// doc-key: MqContextC,MqContext,sc_
3654 {VER, "GetNull" , NS(MqContextC_GetNull) , NULL, NULL},
3655 {VER, "HandleResolve" , NS(MqContextC_HandleResolve) , NULL, NULL},
3656 {VER, "Instances" , NS(MqContextC_Instances) , NULL, NULL},
3657
3658// END-CLASS - created by 'tcl_MqS.tcl -i NHI1_HOME/theLink/c/gen/c_mqmsgque.meta' - DO NOT change
3659 {0, NULL, NULL, NULL}
3660};
3661
3662// ---------------------------------------------------------------------------------------
3663
3664static Tcl_MethodType NS(sInstanceDef)[] = {
3665
3666 {VER, "Debug", NS(MqContextC_Debug) , NULL, NULL},
3667 {VER, "printObj", NS(MqContextC_printObj) , NULL, NULL},
3668 {VER, "ConfigGetStartAsNum", NS(MqContextC_ConfigGetStartAsNum) , NULL, NULL},
3669 {VER, "ConfigGetStatusIsNum", NS(MqContextC_ConfigGetStatusIsNum) , NULL, NULL},
3670
3671// BEGIN-OBJ - created by 'tcl_MqS.tcl -i NHI1_HOME/theLink/c/gen/c_mqmsgque.meta' - DO NOT change
3672
3673// doc-key: MqContextC,MqClass,oc_
3674 {VER, "ClassFactoryGet" , NS(MqContextC_ClassFactoryGet) , NULL, NULL},
3675
3676// doc-key: MqContextC,MqClass,om_
3677 {VER, "ClassFactorySet" , NS(MqContextC_ClassFactorySet) , NULL, NULL},
3678 {VER, "ClassIdentGet" , NS(MqContextC_ClassIdentGet) , NULL, NULL},
3679 {VER, "ClassIdentSet" , NS(MqContextC_ClassIdentSet) , NULL, NULL},
3680 {VER, "ClassOriginalIdentGet", NS(MqContextC_ClassOriginalIdentGet) , NULL, NULL},
3681
3682// doc-key: MqContextC,MqConfig,oco
3683 {VER, "ConfigGetIoTcpL" , NS(MqContextC_ConfigGetIoTcpL) , NULL, NULL},
3684
3685// doc-key: MqContextC,MqConfig,om_
3686 {VER, "ConfigCheckStartAs" , NS(MqContextC_ConfigCheckStartAs) , NULL, NULL},
3687 {VER, "ConfigGetBuffersize" , NS(MqContextC_ConfigGetBuffersize) , NULL, NULL},
3688 {VER, "ConfigGetIdentFrom" , NS(MqContextC_ConfigGetIdentFrom) , NULL, NULL},
3689 {VER, "ConfigGetIoPipe" , NS(MqContextC_ConfigGetIoPipe) , NULL, NULL},
3690 {VER, "ConfigGetIoUds" , NS(MqContextC_ConfigGetIoUds) , NULL, NULL},
3691 {VER, "ConfigGetIsParent" , NS(MqContextC_ConfigGetIsParent) , NULL, NULL},
3692 {VER, "ConfigGetIsServer" , NS(MqContextC_ConfigGetIsServer) , NULL, NULL},
3693 {VER, "ConfigGetIsString" , NS(MqContextC_ConfigGetIsString) , NULL, NULL},
3694 {VER, "ConfigGetName" , NS(MqContextC_ConfigGetName) , NULL, NULL},
3695 {VER, "ConfigGetPkgsize" , NS(MqContextC_ConfigGetPkgsize) , NULL, NULL},
3696 {VER, "ConfigGetPostfix" , NS(MqContextC_ConfigGetPostfix) , NULL, NULL},
3697 {VER, "ConfigGetPrefix" , NS(MqContextC_ConfigGetPrefix) , NULL, NULL},
3698 {VER, "ConfigGetStartAs" , NS(MqContextC_ConfigGetStartAs) , NULL, NULL},
3699 {VER, "ConfigGetStatusIs" , NS(MqContextC_ConfigGetStatusIs) , NULL, NULL},
3700 {VER, "ConfigGetStorage" , NS(MqContextC_ConfigGetStorage) , NULL, NULL},
3701 {VER, "ConfigGetTimeout" , NS(MqContextC_ConfigGetTimeout) , NULL, NULL},
3702 {VER, "ConfigReset" , NS(MqContextC_ConfigReset) , NULL, NULL},
3703 {VER, "ConfigSetAllDebug" , NS(MqContextC_ConfigSetAllDebug) , NULL, NULL},
3704 {VER, "ConfigSetAllTimeout" , NS(MqContextC_ConfigSetAllTimeout) , NULL, NULL},
3705 {VER, "ConfigSetBgError" , NS(MqContextC_ConfigSetBgError) , NULL, NULL},
3706 {VER, "ConfigSetBuffersize" , NS(MqContextC_ConfigSetBuffersize) , NULL, NULL},
3707 {VER, "ConfigSetConfigFile" , NS(MqContextC_ConfigSetConfigFile) , NULL, NULL},
3708 {VER, "ConfigSetDaemon" , NS(MqContextC_ConfigSetDaemon) , NULL, NULL},
3709 {VER, "ConfigSetEvent" , NS(MqContextC_ConfigSetEvent) , NULL, NULL},
3710 {VER, "ConfigSetIdentFrom" , NS(MqContextC_ConfigSetIdentFrom) , NULL, NULL},
3711 {VER, "ConfigSetIgnoreExit" , NS(MqContextC_ConfigSetIgnoreExit) , NULL, NULL},
3712 {VER, "ConfigSetIoPipe" , NS(MqContextC_ConfigSetIoPipe) , NULL, NULL},
3713 {VER, "ConfigSetIoTcp" , NS(MqContextC_ConfigSetIoTcp) , NULL, NULL},
3714 {VER, "ConfigSetIoTcpL" , NS(MqContextC_ConfigSetIoTcpL) , NULL, NULL},
3715 {VER, "ConfigSetIoUds" , NS(MqContextC_ConfigSetIoUds) , NULL, NULL},
3716 {VER, "ConfigSetIsServer" , NS(MqContextC_ConfigSetIsServer) , NULL, NULL},
3717 {VER, "ConfigSetIsString" , NS(MqContextC_ConfigSetIsString) , NULL, NULL},
3718 {VER, "ConfigSetName" , NS(MqContextC_ConfigSetName) , NULL, NULL},
3719 {VER, "ConfigSetPkgsize" , NS(MqContextC_ConfigSetPkgsize) , NULL, NULL},
3720 {VER, "ConfigSetPostfix" , NS(MqContextC_ConfigSetPostfix) , NULL, NULL},
3721 {VER, "ConfigSetPrefix" , NS(MqContextC_ConfigSetPrefix) , NULL, NULL},
3722 {VER, "ConfigSetServerCleanup", NS(MqContextC_ConfigSetServerCleanup) , NULL, NULL},
3723 {VER, "ConfigSetServerSetup", NS(MqContextC_ConfigSetServerSetup) , NULL, NULL},
3724 {VER, "ConfigSetStartAs" , NS(MqContextC_ConfigSetStartAs) , NULL, NULL},
3725 {VER, "ConfigSetStartAsString", NS(MqContextC_ConfigSetStartAsString) , NULL, NULL},
3726 {VER, "ConfigSetStorage" , NS(MqContextC_ConfigSetStorage) , NULL, NULL},
3727 {VER, "ConfigSetTimeout" , NS(MqContextC_ConfigSetTimeout) , NULL, NULL},
3728
3729// doc-key: MqContextC,MqConfig,omo
3730 {VER, "ConfigGetIoTcp" , NS(MqContextC_ConfigGetIoTcp) , NULL, NULL},
3731
3732// doc-key: MqContextC,MqContext,oC_
3733 {VER, "<constructor>" , NS(MqContextC_CTOR) , NULL, NULL},
3734
3735// doc-key: MqContextC,MqContext,oc_
3736 {VER, "ErrorFORMAT" , NS(MqContextC_ErrorFORMAT) , NULL, NULL},
3737 {VER, "GetBuffer" , NS(MqContextC_GetBuffer) , NULL, NULL},
3738 {VER, "Next" , NS(MqContextC_Next) , NULL, NULL},
3739 {VER, "Prev" , NS(MqContextC_Prev) , NULL, NULL},
3740
3741// doc-key: MqContextC,MqContext,om_
3742 {VER, "ErrorCopy" , NS(MqContextC_ErrorCopy) , NULL, NULL},
3743 {VER, "ErrorMove" , NS(MqContextC_ErrorMove) , NULL, NULL},
3744 // skip class-overload: MqContextHandleGet → HandleGet, NS(MqContextC_HandleGet)
3745 // skip class-overload: MqContextLog → Log, NS(MqContextC_Log)
3746 {VER, "LogConfig" , NS(MqContextC_LogConfig) , NULL, NULL},
3747 {VER, "LogEnv" , NS(MqContextC_LogEnv) , NULL, NULL},
3748 {VER, "LogLink" , NS(MqContextC_LogLink) , NULL, NULL},
3749 {VER, "LogSetup" , NS(MqContextC_LogSetup) , NULL, NULL},
3750 {VER, "LogShort" , NS(MqContextC_LogShort) , NULL, NULL},
3751 {VER, "LogType" , NS(MqContextC_LogType) , NULL, NULL},
3752 // skip class-overload: MqContextToString → ToString, NS(MqContextC_ToString)
3753
3754// doc-key: MqContextC,MqEnv,om_
3755 {VER, "EnvProtect" , NS(MqContextC_EnvProtect) , NULL, NULL},
3756 {VER, "EnvRestore" , NS(MqContextC_EnvRestore) , NULL, NULL},
3757
3758// doc-key: MqContextC,MqExit,om_
3759 {VER, "Exit" , NS(MqContextC_Exit) , NULL, NULL},
3760
3761// doc-key: MqContextC,MqGet,oc_
3762 {VER, "GetRoot" , NS(MqContextC_GetRoot) , NULL, NULL},
3763
3764// doc-key: MqContextC,MqLink,oc_
3765 {VER, "LinkGetParent" , NS(MqContextC_LinkGetParent) , NULL, NULL},
3766
3767// doc-key: MqContextC,MqLink,om_
3768 {VER, "LinkConnect" , NS(MqContextC_LinkConnect) , NULL, NULL},
3769 {VER, "LinkCreate" , NS(MqContextC_LinkCreate) , NULL, NULL},
3770 {VER, "LinkCreateChild" , NS(MqContextC_LinkCreateChild) , NULL, NULL},
3771 {VER, "LinkDelete" , NS(MqContextC_LinkDelete) , NULL, NULL},
3772 {VER, "LinkGetCtxId" , NS(MqContextC_LinkGetCtxId) , NULL, NULL},
3773 {VER, "LinkGetTargetIdent" , NS(MqContextC_LinkGetTargetIdent) , NULL, NULL},
3774 {VER, "LinkIsConnected" , NS(MqContextC_LinkIsConnected) , NULL, NULL},
3775 {VER, "LinkIsParent" , NS(MqContextC_LinkIsParent) , NULL, NULL},
3776 {VER, "LinkShutdown" , NS(MqContextC_LinkShutdown) , NULL, NULL},
3777
3778// doc-key: MqContextC,MqLog,om_
3779 {VER, "LogParentOrChild" , NS(MqContextC_LogParentOrChild) , NULL, NULL},
3780 {VER, "LogServerOrClient" , NS(MqContextC_LogServerOrClient) , NULL, NULL},
3781
3782// doc-key: MqContextC,MqProcess,om_
3783 {VER, "ProcessEvent" , NS(MqContextC_ProcessEvent) , NULL, NULL},
3784
3785// doc-key: MqContextC,MqProxy,om_
3786 {VER, "ProxyForward" , NS(MqContextC_ProxyForward) , NULL, NULL},
3787 {VER, "ProxyItem" , NS(MqContextC_ProxyItem) , NULL, NULL},
3788
3789// doc-key: MqContextC,MqRead,oci
3790 {VER, "ReadALL" , NS(MqContextC_ReadALL) , NULL, NULL},
3791
3792// doc-key: MqContextC,MqRead,oco
3793 {VER, "ReadBFL" , NS(MqContextC_ReadBFL) , NULL, NULL},
3794 {VER, "ReadBUF" , NS(MqContextC_ReadBUF) , NULL, NULL},
3795
3796// doc-key: MqContextC,MqRead,om_
3797 {VER, "ReadDbg" , NS(MqContextC_ReadDbg) , NULL, NULL},
3798 {VER, "ReadGetNextType" , NS(MqContextC_ReadGetNextType) , NULL, NULL},
3799 {VER, "ReadGetNumItems" , NS(MqContextC_ReadGetNumItems) , NULL, NULL},
3800 {VER, "ReadItemExists" , NS(MqContextC_ReadItemExists) , NULL, NULL},
3801 {VER, "ReadL_END" , NS(MqContextC_ReadL_END) , NULL, NULL},
3802 {VER, "ReadL_START" , NS(MqContextC_ReadL_START) , NULL, NULL},
3803 {VER, "ReadT_END" , NS(MqContextC_ReadT_END) , NULL, NULL},
3804 {VER, "ReadT_START" , NS(MqContextC_ReadT_START) , NULL, NULL},
3805 {VER, "ReadUndo" , NS(MqContextC_ReadUndo) , NULL, NULL},
3806
3807// doc-key: MqContextC,MqRead,omo
3808 {VER, "ReadBIN" , NS(MqContextC_ReadBIN) , NULL, NULL},
3809 {VER, "ReadBOL" , NS(MqContextC_ReadBOL) , NULL, NULL},
3810 {VER, "ReadBinaryR" , NS(MqContextC_ReadBinaryR) , NULL, NULL},
3811 {VER, "ReadDBL" , NS(MqContextC_ReadDBL) , NULL, NULL},
3812 {VER, "ReadFLT" , NS(MqContextC_ReadFLT) , NULL, NULL},
3813 {VER, "ReadHDL" , NS(MqContextC_ReadHDL) , NULL, NULL},
3814 {VER, "ReadI16" , NS(MqContextC_ReadI16) , NULL, NULL},
3815 {VER, "ReadI32" , NS(MqContextC_ReadI32) , NULL, NULL},
3816 {VER, "ReadI64" , NS(MqContextC_ReadI64) , NULL, NULL},
3817 {VER, "ReadI8" , NS(MqContextC_ReadI8) , NULL, NULL},
3818 {VER, "ReadLIST" , NS(MqContextC_ReadLIST) , NULL, NULL},
3819 {VER, "ReadLONG" , NS(MqContextC_ReadLONG) , NULL, NULL},
3820 {VER, "ReadNEXT" , NS(MqContextC_ReadNEXT) , NULL, NULL},
3821 {VER, "ReadSTR" , NS(MqContextC_ReadSTR) , NULL, NULL},
3822 {VER, "ReadStringR" , NS(MqContextC_ReadStringR) , NULL, NULL},
3823
3824// doc-key: MqContextC,MqRoute,oco
3825 {VER, "RouteGetTree" , NS(MqContextC_RouteGetTree) , NULL, NULL},
3826
3827// doc-key: MqContextC,MqRoute,om_
3828 {VER, "RouteCreate" , NS(MqContextC_RouteCreate) , NULL, NULL},
3829 {VER, "RouteDelete" , NS(MqContextC_RouteDelete) , NULL, NULL},
3830 {VER, "RouteResolve" , NS(MqContextC_RouteResolve) , NULL, NULL},
3831 {VER, "RouteTraverse" , NS(MqContextC_RouteTraverse) , NULL, NULL},
3832
3833// doc-key: MqContextC,MqRoute,omo
3834 {VER, "RouteGetPath" , NS(MqContextC_RouteGetPath) , NULL, NULL},
3835
3836// doc-key: MqContextC,MqSend,om_
3837 {VER, "Send" , NS(MqContextC_Send) , NULL, NULL},
3838 {VER, "SendBFL" , NS(MqContextC_SendBFL) , NULL, NULL},
3839 {VER, "SendBIN" , NS(MqContextC_SendBIN) , NULL, NULL},
3840 {VER, "SendBOL" , NS(MqContextC_SendBOL) , NULL, NULL},
3841 {VER, "SendBUF" , NS(MqContextC_SendBUF) , NULL, NULL},
3842 {VER, "SendBUS_FLAT" , NS(MqContextC_SendBUS_FLAT) , NULL, NULL},
3843 {VER, "SendBinaryR" , NS(MqContextC_SendBinaryR) , NULL, NULL},
3844 {VER, "SendDBL" , NS(MqContextC_SendDBL) , NULL, NULL},
3845 {VER, "SendEND" , NS(MqContextC_SendEND) , NULL, NULL},
3846 {VER, "SendEND_AND_CALLBACK", NS(MqContextC_SendEND_AND_CALLBACK) , NULL, NULL},
3847 {VER, "SendEND_AND_SUB" , NS(MqContextC_SendEND_AND_SUB) , NULL, NULL},
3848 {VER, "SendEND_AND_TRANSACTION", NS(MqContextC_SendEND_AND_TRANSACTION) , NULL, NULL},
3849 {VER, "SendEND_AND_WAIT" , NS(MqContextC_SendEND_AND_WAIT) , NULL, NULL},
3850 {VER, "SendERROR" , NS(MqContextC_SendERROR) , NULL, NULL},
3851 {VER, "SendFLT" , NS(MqContextC_SendFLT) , NULL, NULL},
3852 {VER, "SendHDL" , NS(MqContextC_SendHDL) , NULL, NULL},
3853 {VER, "SendI16" , NS(MqContextC_SendI16) , NULL, NULL},
3854 {VER, "SendI32" , NS(MqContextC_SendI32) , NULL, NULL},
3855 {VER, "SendI64" , NS(MqContextC_SendI64) , NULL, NULL},
3856 {VER, "SendI8" , NS(MqContextC_SendI8) , NULL, NULL},
3857 {VER, "SendLONG" , NS(MqContextC_SendLONG) , NULL, NULL},
3858 {VER, "SendLTR" , NS(MqContextC_SendLTR) , NULL, NULL},
3859 {VER, "SendL_END" , NS(MqContextC_SendL_END) , NULL, NULL},
3860 {VER, "SendL_FLAT" , NS(MqContextC_SendL_FLAT) , NULL, NULL},
3861 {VER, "SendL_START" , NS(MqContextC_SendL_START) , NULL, NULL},
3862 {VER, "SendRETURN" , NS(MqContextC_SendRETURN) , NULL, NULL},
3863 {VER, "SendRETURN_SUB" , NS(MqContextC_SendRETURN_SUB) , NULL, NULL},
3864 {VER, "SendSTART" , NS(MqContextC_SendSTART) , NULL, NULL},
3865 {VER, "SendSTR" , NS(MqContextC_SendSTR) , NULL, NULL},
3866 {VER, "SendSYNC" , NS(MqContextC_SendSYNC) , NULL, NULL},
3867 {VER, "SendStringR" , NS(MqContextC_SendStringR) , NULL, NULL},
3868 {VER, "SendT_END" , NS(MqContextC_SendT_END) , NULL, NULL},
3869 {VER, "SendT_START" , NS(MqContextC_SendT_START) , NULL, NULL},
3870
3871// doc-key: MqContextC,MqService,om_
3872 {VER, "ServiceCreate" , NS(MqContextC_ServiceCreate) , NULL, NULL},
3873 {VER, "ServiceDelete" , NS(MqContextC_ServiceDelete) , NULL, NULL},
3874 {VER, "ServiceIsTransaction", NS(MqContextC_ServiceIsTransaction) , NULL, NULL},
3875 {VER, "ServiceProxy" , NS(MqContextC_ServiceProxy) , NULL, NULL},
3876 {VER, "ServiceProxyCtx" , NS(MqContextC_ServiceProxyCtx) , NULL, NULL},
3877 {VER, "ServiceProxyCtxExists", NS(MqContextC_ServiceProxyCtxExists) , NULL, NULL},
3878 {VER, "ServiceProxyRoundRobin", NS(MqContextC_ServiceProxyRoundRobin) , NULL, NULL},
3879 {VER, "ServiceStorage" , NS(MqContextC_ServiceStorage) , NULL, NULL},
3880 {VER, "ServiceTokenCheck" , NS(MqContextC_ServiceTokenCheck) , NULL, NULL},
3881 {VER, "ServiceTokenExists" , NS(MqContextC_ServiceTokenExists) , NULL, NULL},
3882 {VER, "ServiceTokenGet" , NS(MqContextC_ServiceTokenGet) , NULL, NULL},
3883
3884// doc-key: MqContextC,MqSlave,oc_
3885 {VER, "SlaveGetMaster" , NS(MqContextC_SlaveGetMaster) , NULL, NULL},
3886
3887// doc-key: MqContextC,MqSlave,oco
3888 {VER, "SlaveGet" , NS(MqContextC_SlaveGet) , NULL, NULL},
3889 {VER, "SlaveGetFilter" , NS(MqContextC_SlaveGetFilter) , NULL, NULL},
3890 {VER, "SlaveGetProxy" , NS(MqContextC_SlaveGetProxy) , NULL, NULL},
3891
3892// doc-key: MqContextC,MqSlave,om_
3893 {VER, "SlaveCheck" , NS(MqContextC_SlaveCheck) , NULL, NULL},
3894 {VER, "SlaveCreate" , NS(MqContextC_SlaveCreate) , NULL, NULL},
3895 {VER, "SlaveDelete" , NS(MqContextC_SlaveDelete) , NULL, NULL},
3896 {VER, "SlaveIs" , NS(MqContextC_SlaveIs) , NULL, NULL},
3897 {VER, "SlaveWorker" , NS(MqContextC_SlaveWorker) , NULL, NULL},
3898
3899// doc-key: MqContextC,MqStorage,oci
3900 {VER, "StorageDelete" , NS(MqContextC_StorageDelete) , NULL, NULL},
3901 {VER, "StorageImport" , NS(MqContextC_StorageImport) , NULL, NULL},
3902
3903// doc-key: MqContextC,MqStorage,om_
3904 {VER, "StorageClose" , NS(MqContextC_StorageClose) , NULL, NULL},
3905 {VER, "StorageDecrRef" , NS(MqContextC_StorageDecrRef) , NULL, NULL},
3906 {VER, "StorageIncrRef" , NS(MqContextC_StorageIncrRef) , NULL, NULL},
3907 {VER, "StorageLog" , NS(MqContextC_StorageLog) , NULL, NULL},
3908 {VER, "StorageOpen" , NS(MqContextC_StorageOpen) , NULL, NULL},
3909
3910// doc-key: MqContextC,MqStorage,omo
3911 {VER, "StorageCount" , NS(MqContextC_StorageCount) , NULL, NULL},
3912 {VER, "StorageErrCnt" , NS(MqContextC_StorageErrCnt) , NULL, NULL},
3913 {VER, "StorageExport" , NS(MqContextC_StorageExport) , NULL, NULL},
3914 {VER, "StorageResolve" , NS(MqContextC_StorageResolve) , NULL, NULL},
3915
3916// END-OBJ - created by 'tcl_MqS.tcl -i NHI1_HOME/theLink/c/gen/c_mqmsgque.meta' - DO NOT change
3917 {0, NULL, NULL, NULL, NULL}
3918};
3919
3925
3926// vim: Marker(c)
3927MK_UNUSED static int NS(ProcessExit) ( MK_RT_ARGS MK_I32 num) {
3928 Tcl_Exit(num);
3929 return num;
3930}
3931
3932static int NS(ThreadExit) ( MK_RT_ARGS MK_I32 num) {
3933 return num;
3934}
3935
3936static enum MkErrorE NS(Idle) ( MQ_SERVICE_CALL_ARGS ) {
3937 Tcl_DoOneEvent(TCL_ALL_EVENTS|TCL_DONT_WAIT);
3938 return MK_OK;
3939}
3940
3946
3948
3949static void NS(sMqContextC_Type) ( MK_RT_ARGS_ONLY )
3950{
3952 assert(MqContextCTT == NULL);
3953
3954 // define type
3955
3956 MqContextCTT = MkTypeDup2(MqContextC_TT,"TclMqContextC");
3957 MqContextCTT->objsize = sizeof(struct TclContextS) ;
3958 MqContextCT->argvFix = true ;
3959 MqContextCT->MqProcessExitCB = NS(ProcessExit) ;
3960 MqContextCT->MqThreadExitCB = NS(ThreadExit) ;
3961 MqContextCT->Child.fCreate = MqLinkDefault_RT ;
3962 MqContextCT->Parent.fCreate = MqLinkDefault_RT ;
3963 MqContextCT->Idle.fCall = NS(Idle) ;
3964}
3965
3966int NS(pMqContextC_Init) ( MK_RT_ARGS OT_ENV_T interp, OT_NS_T ns )
3967{
3969
3970 if (MqContextCTT == NULL) {
3971
3972 // register a new type
3973 MkRuntimeCallbackAdd( MK_RT_CALL &sTclMqRuntimeCallback, NS(sMqContextC_Type) , "TclMqContextC" );
3974
3975 // tcl does !not! support fork for a threaded interpreter
3976 if (Tcl_GetVar2Ex(interp,"tcl_platform","threaded",TCL_GLOBAL_ONLY) != NULL) {
3977 MqContextCT->ignoreFork = true;
3978 }
3979 }
3980
3981 ClassInit
3982
3983 return TCL_OK;
3984error:
3985 return TCL_ERROR;
3986}
#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_CHECK_NIH(val)
#define OT_retObj_SET_BOL(nat)
#define OT_SETUP_NOARG(d)
#define OT_SETUP_ONEARG(d)
Tcl_Class OT_CLS_T
#define OT_ERROR_LNG_RETURN
Tcl_Namespace * OT_NS_T
#define OT_CHECK_NI4(val)
#define OT_CHECK_NI8(val)
#define OT_retObj_SET_I16(nat)
#define OT_retObj_SET_Error
#define OT_CHECK_NF8(val)
#define OT_GET_CALL_LINE
#define OT_CHECK_NIL(val)
#define OT_FRAME_CLEANUP
#define OT_retObj_SET_BUF(nat)
#define OT_ERROR_CONSTRUCTOR(class)
#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_SET_HDL(nat)
#define OT_CHECK_REQUIRED(val)
#define OT_retObj_SET_None
#define OT_retObj_SET_I32(nat)
#define OT_Prefix_CALL
#define OT_GET_CALL_FILE
#define OT_CHECK_NF4(val)
#define OT_retObj_SET_BFL(nat)
#define OT_GET__ME_REF_MkStringR(s)
#define OT_TMP_I32_OBJ(val)
#define OT_GET__ME_REF_MkBinaryR(b)
#define OT_SETUP_CONSTRUCTOR_ARGS(...)
#define OT_CHECK_ENUM(ename, val)
#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_retObj_SET_STR(nat)
#define OT_CHECK_NB1(val)
#define OT_NEW_Mk_enum_OBJ(typ, val)
Tcl_Object OT_SELF_T
#define OT_CHECK_OPTIONAL(val)
#define OT_TMP_STR_OBJ(val)
#define OT_retObj_SET_ERR(nat)
#define OT_retObj_SET(val)
#define OT_retObj_CONSTR(x)
#define OT_CHECK_NOARGS
#define MkErrorC_Check(mng, PROC)
#define OT_ProcRet
Tcl_Interp * OT_ENV_T
#define CONSTR_ARGS
Tcl_Obj * OT_OBJ_T
#define OT_CHECK_STRN(val)
tag: nhi1-release-250425
#define OtClass_ARGS
#define OT_NEW_Mq_enum_OBJ(typ, val)
#define OT_retObj_SET_CTX(nat)
#define MQ(n)
#define NS(n)
#define OT_retObj_SET_FCT(nat)
#define MqContextC_ARGS
#define OT_TMP_CTX_OBJ(val)
tag: nhi1-release-250425
OT_ProcRet NS MqContextC_ReadLIST(MqContextC_ARGS)
tag: nhi1-release-250425
OT_ProcRet NS MqContextC_ReadNEXT(MqContextC_ARGS)
#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
static struct MkRuntimeCallbackS sTclMqRuntimeCallback
#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 OT_CONSTRUCTOR_POST(x)
#define ReadBFL_doc
#define ConfigSetAllTimeout_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
static __thread MK_TYP MqContextCTT
#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
#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 VER
#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 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 ConfigSetEvent_doc
#define ConfigGetPostfix_doc
#define LinkGetCtxId_doc
#define ConfigGetIoTcpL_doc
#define SendEND_AND_SUB_doc
#define LinkIsParent_doc
#define CTOR_doc
#define SendBUF_doc
#define ErrorMove_doc
#define ReadSTR_doc
#define SendSYNC_doc
#define ClassInit
#define SendBOL_doc
#define ConfigSetStartAs_doc
#define SendFLT_doc
#define ReadBOL_doc
#define error
Definition high_lng.h:339
#define MkBufferListCreateTLS_T(name, num)
#define MK_NULL_NO
#define MK_NULL_YES
#define MK_UNUSED
#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
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
#define MkLogC_4X(x, message, debug, callfunc)
static bool MkSysStringIsNULL(MK_STRN str)
static MK_I32 MkRuntimeDebugGet(void)
size_t MkRuntimeCallbackAdd(MK_RT mkrt, MkRuntimeCallbackS *cbdata, MkRuntimeInitF rt_callback, MK_STRN ident)
#define MkThreadLocal
#define MK_RT_CALL
#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 …
#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 …
#define MQ_SERVICE_CALL_ARGS
the MqTokenF arguments with default names
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 "MK...
#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
void MqConfigSetAllTimeout(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 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_STATIC_RT
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
#define OT_CHECK_STR(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_LNG_OBJECT_IS_3(objV, obj, flag)
#define OT_SETUP_CALLABLE(val)
#define OT_CHECK_TIME_T(val)
#define OT_CHECK_BUSN(val, nullB)
#define OT_CHECK_LNG_T(val)
#define OT_CHECK_BAC(val)
#define OT_CHECK_OBJN(val, nullB)
@ MkTestClassE_NONE_OBJECT
@ MkTestClassE_INTERNAL
@ MkTestClassE_OK
@ MkTestClassE_INVALID_SIGNATURE
@ MkTestClassE_NULL
@ MkTestClassE_WRONG_CLASS
#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
MK_I32 refCount
size_t objsize
PUBLIC data structure for the tclmqmsgque-specific-data
MqDumpC - the class known as dmp or dump is used to export a tclmqmsgque data package as binary …
data used to define a factory