theLink 10.0
Loading...
Searching...
No Matches
MqContextC_atl.c
Go to the documentation of this file.
1
9/* LABEL-START */
10
11#define META_FILE_NAME "MqContextC_atl.c"
12
14
15#define OT_CLASS amqrt->AtlMqContextC
16#define OT_NULL amqrt->AtlMqContextC_MK_NULL
17#define OT_CLASS_NAME "MqContextC"
18
19#define SELF2HDL(O) MqCtx(VAL2MNG(O))
20
21// LNG: class
22// -> moved to LibMqMsgque_atl.h → OT_MQ_RT_S → AtlMqMsgqueCTT;
23
24// META: ObjNew feature: called to return a new or an already existing ATL-SELF-Object
25// -> moved to LibMqMsgque_atl.h → MqMsgqueC_ObjNew
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 SETUP_amqrt(env);
30 return AtomMake(obj,OT_CLASS,NULL,NULL,env);
31}
32
33// META: called if MkObj must be destroyed and if the SELF is still alive → goal: destroy the SELF
34static void NS(MqContextC_selfDelete) (MK_RT_ARGS MK_PTR selfP, MK_PTR const env) {
35 OT_SELF_T selfO = selfP;
36 SETUP_amqrt(env);
37 MK(AtomDeleteHard) (OT_MK_CALL selfO);
38}
39
40// META: called to destroy link from SELF to META
41static void NS(MqContextC_selfUnlink) (MK_RT_ARGS MK_PTR selfP, MK_PTR const env) {
42 OT_SELF_T selfO = selfP;
43 SETUP_amqrt(env);
44 return MK(AtomUnlink) (OT_MK_CALL selfO);
45}
46
47#define OT_SETUP_hdl SetupHdlFromMetaData_2(MQ_CTX)
48#define OT_SETUP_hdl__null_allow SetupHdlFromMetaData__null_allow_2(MQ_CTX)
49#define OT_SETUP_hdl_destr SetupHdlFromMetaData__null_allow_2(MQ_CTX)
50#define OT_SETUP_hdl_constr SetupHdlConstr(MqContextC)
51#define OT_SETUP_hdl_static_constr OT_SETUP_hdl_static
52#define OT_SETUP_hdl_static SetupHdlStatic(MqContextC)
53
54#define OT_retObj_CONSTR(x) OT_retObj_SET(AtomInit(OT_SELF,MqContextC_X2obj(x),amqrt))
55
56// initialize the ATL and META class specific object
57#define ClassInit \
58 /* if not already done, initialize NEW META type */ \
59 if (MqContextCTT == NULL) MqContextCTT = MqContextSTT; \
60 \
61 /* protect against double call */ \
62 if (MqContextCTT->selfCreate == NS(MqContextC_selfCreate)) return MK_OK; \
63 \
64 /* add "selfCreate" and "selfDelete" feature to the META-Class */ \
65 MqContextCTT->selfCreate = NS(MqContextC_selfCreate); \
66 MqContextCTT->selfDelete = NS(MqContextC_selfDelete); \
67 MqContextCTT->selfUnlink = NS(MqContextC_selfUnlink); \
68 \
69 /* create the ATL-class */ \
70 OT_CLASS = AltClassDef(MqContextCTT,&amqrt->AtlMqContextC_NS); \
71 if (OT_CLASS == NULL) goto error; \
72 OT_REF_INCR(OT_CLASS); \
73 \
74 /* create the ATL static Methods */ \
75 check_LNG(AtlUnknownSetup (NS(sOtClassDef),amqrt)) goto error; \
76 \
77 /* create the ATL instance Methods */ \
78 check_LNG(AtlUnknownSetup (NS(sInstanceDef),amqrt)) goto error; \
79 \
80 /* after class was modified, recompile the class */ \
81 RL_init(2, recompile, RL_T(0,RecompileN)); RL_O(1,OT_CLASS) ; \
82 int retI = RL_EvalEx(0); \
83 if (retI != TCL_OK) return retI; \
84 \
85 /* define the "NULL" object */ \
86 OT_NULL = AtomCreateNULL(OT_CLASS, "::MqContextC::MK_NULL", (MK_PTR)amqrt); \
87 if (OT_NULL == NULL) goto error; \
88 OT_REF_INCR(OT_NULL);
89/* LABEL-END */
90
91#include "mk_check_atl.h"
92
93#if 1
94#undef OT_CONSTRUCTOR_POST
95// don't modify 'prefix' if initial object is a class
96#define OT_CONSTRUCTOR_POST(x) if (MoxMyIsN(selfO)) MqConfigSetPrefixWithNoLock(x,VAL2STR(MoxCls__NAME__N(MoxMy__CLASS__N(selfO))));
97#endif
98
99// BEGIN-DOC - created by 'atl_MqS.tcl -i NHI1_HOME/theLink/c/gen/c_mqmsgque.meta' - DO NOT change
100
101// doc-key: MqContextC,MqClass,oc_,func
102#define ClassFactoryGet_doc "MqFactoryC [MqContextC::ClassFactoryGet $ctx] (const)"
103
104// doc-key: MqContextC,MqClass,om_,func
105#define ClassFactorySet_doc "MqContextC::ClassFactorySet $ctx item:MqFactoryC"
106#define ClassIdentGet_doc "string [MqContextC::ClassIdentGet $ctx] (const)"
107#define ClassIdentSet_doc "MqContextC::ClassIdentSet $ctx ident:string"
108#define ClassOriginalIdentGet_doc "string [MqContextC::ClassOriginalIdentGet $ctx] (const)"
109
110// doc-key: MqContextC,MqConfig,oco,func
111#define ConfigGetIoTcpL_doc "MkBufferListC [MqContextC::ConfigGetIoTcpL $ctx]"
112
113// doc-key: MqContextC,MqConfig,om_,func
114#define ConfigCheckStartAs_doc "bool [MqContextC::ConfigCheckStartAs $ctx data:MqStartE]"
115#define ConfigGetBuffersize_doc "int32 [MqContextC::ConfigGetBuffersize $ctx] (const)"
116#define ConfigGetIdentFrom_doc "MqIdentE [MqContextC::ConfigGetIdentFrom $ctx]"
117#define ConfigGetIoPipe_doc "int32 [MqContextC::ConfigGetIoPipe $ctx]"
118#define ConfigGetIoUds_doc "string [MqContextC::ConfigGetIoUds $ctx] (const)"
119#define ConfigGetIsParent_doc "bool [MqContextC::ConfigGetIsParent $ctx]"
120#define ConfigGetIsServer_doc "bool [MqContextC::ConfigGetIsServer $ctx]"
121#define ConfigGetIsString_doc "bool [MqContextC::ConfigGetIsString $ctx]"
122#define ConfigGetName_doc "string [MqContextC::ConfigGetName $ctx] (const)"
123#define ConfigGetPkgsize_doc "int32 [MqContextC::ConfigGetPkgsize $ctx] (const)"
124#define ConfigGetPostfix_doc "string [MqContextC::ConfigGetPostfix $ctx] (const)"
125#define ConfigGetPrefix_doc "string [MqContextC::ConfigGetPrefix $ctx] (const)"
126#define ConfigGetStartAs_doc "MqStartE [MqContextC::ConfigGetStartAs $ctx]"
127#define ConfigGetStatusIs_doc "MqStatusIsEF [MqContextC::ConfigGetStatusIs $ctx]"
128#define ConfigGetStorage_doc "string [MqContextC::ConfigGetStorage $ctx] (const)"
129#define ConfigGetTimeout_doc "MkTimeoutE|int32 [MqContextC::ConfigGetTimeout $ctx] (const)"
130#define ConfigReset_doc "MqContextC::ConfigReset $ctx"
131#define ConfigSetAllDebug_doc "MqContextC::ConfigSetAllDebug $ctx data:int32"
132#define ConfigSetAllTimeout_doc "MqContextC::ConfigSetAllTimeout $ctx data:MkTimeoutE|int32"
133#define ConfigSetBgError_doc "MqContextC::ConfigSetBgError $ctx ?callback:callable=NULL?"
134#define ConfigSetBuffersize_doc "MqContextC::ConfigSetBuffersize $ctx data:int32"
135#define ConfigSetConfigFile_doc "MqContextC::ConfigSetConfigFile $ctx filename:string"
136#define ConfigSetDaemon_doc "MqContextC::ConfigSetDaemon $ctx pidfile:string"
137#define ConfigSetEvent_doc "MqContextC::ConfigSetEvent $ctx ?callback:callable=NULL?"
138#define ConfigSetIdentFrom_doc "MqContextC::ConfigSetIdentFrom $ctx data:MqIdentE"
139#define ConfigSetIgnoreExit_doc "MqContextC::ConfigSetIgnoreExit $ctx data:bool"
140#define ConfigSetIoPipe_doc "MqContextC::ConfigSetIoPipe $ctx fh:int32"
141#define ConfigSetIoTcp_doc "MqContextC::ConfigSetIoTcp $ctx ?host:string=\"NULL\"? ?port:string=\"NULL\"? ?myhost:string=\"NULL\"? ?myport:string=\"NULL\"?"
142#define ConfigSetIoTcpL_doc "MqContextC::ConfigSetIoTcpL $ctx vals:MkBufferListC"
143#define ConfigSetIoUds_doc "MqContextC::ConfigSetIoUds $ctx file:string"
144#define ConfigSetIsServer_doc "MqContextC::ConfigSetIsServer $ctx data:bool"
145#define ConfigSetIsString_doc "MqContextC::ConfigSetIsString $ctx data:bool"
146#define ConfigSetName_doc "MqContextC::ConfigSetName $ctx data:string"
147#define ConfigSetPkgsize_doc "MqContextC::ConfigSetPkgsize $ctx data:int32"
148#define ConfigSetPostfix_doc "MqContextC::ConfigSetPostfix $ctx data:string"
149#define ConfigSetPrefix_doc "MqContextC::ConfigSetPrefix $ctx data:string"
150#define ConfigSetServerCleanup_doc "MqContextC::ConfigSetServerCleanup $ctx ?callback:callable=NULL?"
151#define ConfigSetServerSetup_doc "MqContextC::ConfigSetServerSetup $ctx ?callback:callable=NULL?"
152#define ConfigSetStartAs_doc "MqContextC::ConfigSetStartAs $ctx data:MqStartE"
153#define ConfigSetStartAsString_doc "MqContextC::ConfigSetStartAsString $ctx data:string"
154#define ConfigSetStorage_doc "MqContextC::ConfigSetStorage $ctx data:string"
155#define ConfigSetTimeout_doc "MqContextC::ConfigSetTimeout $ctx data:MkTimeoutE|int32"
156
157// doc-key: MqContextC,MqConfig,omo,func
158#define ConfigGetIoTcp_doc "{host:string port:string myhost:string myport:string} [MqContextC::ConfigGetIoTcp $ctx]"
159
160// doc-key: MqContextC,MqContext,sCc,func
161#define CTOR_doc "MqContextC [MqContextC::CTOR ?tmpl:MqContextC=NULL?]"
162#define Create_doc "MqContextC [MqContextC::Create ?tmpl:MqContextC=NULL?]"
163
164// doc-key: MqContextC,MqContext,sc_,func
165#define GetNull_doc "MqContextC [MqContextC::GetNull]"
166#define HandleResolve_doc "MqContextC [MqContextC::HandleResolve netHdl:MK_HDL]"
167#define Instances_doc "MqContextC [MqContextC::Instances]"
168
169// doc-key: MqContextC,MqContext,oc_,func
170#define ErrorFORMAT_doc "MkErrorC [MqContextC::ErrorFORMAT $fmtobj] (const)"
171#define GetBuffer_doc "MkBufferC [MqContextC::GetBuffer $ctx]"
172#define Next_doc "MqContextC [MqContextC::Next $ctx]"
173#define Prev_doc "MqContextC [MqContextC::Prev $ctx]"
174
175// doc-key: MqContextC,MqContext,om_,func
176#define ErrorCopy_doc "MkErrorE [MqContextC::ErrorCopy $targetCtx sourceCtx:MqContextC] (const)"
177#define ErrorMove_doc "MkErrorE [MqContextC::ErrorMove $targetCtx sourceCtx:MqContextC] (const)"
178// skip class-overload: HandleGet → MkObjectHandleGet
179// skip class-overload: Log → MkObjectLog
180#define LogConfig_doc "MqContextC::LogConfig $ctx ?fmtobj:MkObjectC=NULL? ?debug:int32=0? ?callfunc:string=\"MK_NULL\"? ?lvl:int32=0? (const)"
181#define LogEnv_doc "MqContextC::LogEnv $ctx ?fmtobj:MkObjectC=NULL? ?debug:int32=0? ?callfunc:string=\"MK_NULL\"? ?lvl:int32=0? (const)"
182#define LogLink_doc "MqContextC::LogLink $ctx ?fmtobj:MkObjectC=NULL? ?debug:int32=0? ?callfunc:string=\"MK_NULL\"? ?lvl:int32=0? (const)"
183#define LogSetup_doc "MqContextC::LogSetup $ctx ?fmtobj:MkObjectC=NULL? ?debug:int32=0? ?callfunc:string=\"MK_NULL\"? ?lvl:int32=0? (const)"
184#define LogShort_doc "MqContextC::LogShort $ctx ?fmtobj:MkObjectC=NULL? ?debug:int32=0? ?callfunc:string=\"MK_NULL\"? ?lvl:int32=0? ?label:string=\"NULL\"? (const)"
185#define LogType_doc "MqContextC::LogType $ctx ?fmtobj:MkObjectC=NULL? ?debug:int32=0? ?callfunc:string=\"MK_NULL\"? ?lvl:int32=0? (const)"
186// skip class-overload: ToString → MkObjectToString
187
188// doc-key: MqContextC,MqEnv,om_,func
189#define EnvProtect_doc "MqContextC::EnvProtect $ctx"
190#define EnvRestore_doc "MqContextC::EnvRestore $ctx"
191
192// doc-key: MqContextC,MqExit,om_,func
193#define Exit_doc "int32 [MqContextC::Exit $ctx ?callfunc:string=\"MK_NULL\"? ?callfile:string=\"MK_NULL\"? ?callline:int32=-1?]"
194
195// doc-key: MqContextC,MqGet,oc_,func
196#define GetRoot_doc "MqContextC [MqContextC::GetRoot $ctx]"
197
198// doc-key: MqContextC,MqLink,oc_,func
199#define LinkGetParent_doc "MqContextC [MqContextC::LinkGetParent $ctx]"
200
201// doc-key: MqContextC,MqLink,om_,func
202#define LinkConnect_doc "MqContextC::LinkConnect $ctx"
203#define LinkCreate_doc "MqContextC::LinkCreate $ctx ?args:MkBufferListC...=NULL?"
204#define LinkCreateChild_doc "MqContextC::LinkCreateChild $ctx parent:MqContextC ?args:MkBufferListC...=NULL?"
205#define LinkDelete_doc "MqContextC::LinkDelete $ctx"
206#define LinkGetCtxId_doc "int32 [MqContextC::LinkGetCtxId $ctx]"
207#define LinkGetTargetIdent_doc "string [MqContextC::LinkGetTargetIdent $ctx]"
208#define LinkIsConnected_doc "bool [MqContextC::LinkIsConnected $ctx]"
209#define LinkIsParent_doc "bool [MqContextC::LinkIsParent $ctx]"
210#define LinkShutdown_doc "MqContextC::LinkShutdown $ctx"
211
212// doc-key: MqContextC,MqLog,om_,func
213#define LogParentOrChild_doc "string [MqContextC::LogParentOrChild $ctx] (const)"
214#define LogServerOrClient_doc "string [MqContextC::LogServerOrClient $ctx] (const)"
215
216// doc-key: MqContextC,MqProcess,om_,func
217#define ProcessEvent_doc "MqContextC::ProcessEvent $ctx ?wait:MqWaitOnEventE=NO? ?timeout:MkTimeoutE|int32=DEFAULT?"
218
219// doc-key: MqContextC,MqProxy,om_,func
220#define ProxyForward_doc "MqContextC::ProxyForward $sourceCtx targetCtx:MqContextC ?dump:MqDumpC=NULL? ?timeout:MkTimeoutE|int32=DEFAULT?"
221#define ProxyItem_doc "MqContextC::ProxyItem $sourceCtx targetCtx:MqContextC"
222
223// doc-key: MqContextC,MqRead,oci,func
224#define ReadALL_doc "MkBufferListC [MqContextC::ReadALL $ctx ?val_inout:MkBufferListC=NULL?]"
225
226// doc-key: MqContextC,MqRead,oco,func
227#define ReadBFL_doc "MkBufferListC [MqContextC::ReadBFL $ctx]"
228#define ReadBUF_doc "MkBufferC [MqContextC::ReadBUF $ctx]"
229
230// doc-key: MqContextC,MqRead,om_,func
231#define ReadDbg_doc "MqContextC::ReadDbg $ctx"
232#define ReadGetNextType_doc "MkTypeE [MqContextC::ReadGetNextType $ctx]"
233#define ReadGetNumItems_doc "int32 [MqContextC::ReadGetNumItems $ctx]"
234#define ReadItemExists_doc "bool [MqContextC::ReadItemExists $ctx]"
235#define ReadL_END_doc "MqContextC::ReadL_END $ctx"
236#define ReadL_START_doc "MqContextC::ReadL_START $ctx ?buf:MkBufferC=NULL?"
237#define ReadT_END_doc "MqContextC::ReadT_END $ctx"
238#define ReadT_START_doc "MqContextC::ReadT_START $ctx"
239#define ReadUndo_doc "MqContextC::ReadUndo $ctx"
240
241// doc-key: MqContextC,MqRead,omo,func
242#define ReadBIN_doc "binary [MqContextC::ReadBIN $ctx]"
243#define ReadBOL_doc "bool [MqContextC::ReadBOL $ctx]"
244#define ReadBinaryR_doc "binary [MqContextC::ReadBinaryR $ctx]"
245#define ReadDBL_doc "double [MqContextC::ReadDBL $ctx]"
246#define ReadFLT_doc "float [MqContextC::ReadFLT $ctx]"
247#define ReadHDL_doc "MK_HDL [MqContextC::ReadHDL $ctx]"
248#define ReadI16_doc "int16 [MqContextC::ReadI16 $ctx]"
249#define ReadI32_doc "int32 [MqContextC::ReadI32 $ctx]"
250#define ReadI64_doc "int64 [MqContextC::ReadI64 $ctx]"
251#define ReadI8_doc "int8 [MqContextC::ReadI8 $ctx]"
252#define ReadLIST_doc "[list...] [MqContextC::ReadLIST $ctx]"
253#define ReadLONG_doc "long [MqContextC::ReadLONG $ctx]"
254#define ReadNEXT_doc "obj [MqContextC::ReadNEXT $ctx]"
255#define ReadSTR_doc "string [MqContextC::ReadSTR $ctx]"
256#define ReadStringR_doc "string [MqContextC::ReadStringR $ctx]"
257
258// doc-key: MqContextC,MqRoute,oco,func
259#define RouteGetTree_doc "MkBufferListC [MqContextC::RouteGetTree $ctx]"
260
261// doc-key: MqContextC,MqRoute,om_,func
262#define RouteCreate_doc "MqContextC::RouteCreate $ctx route:string service:string ?overwrite:bool=false?"
263#define RouteDelete_doc "MqContextC::RouteDelete $ctx route:string service:string ?overwrite:bool=false?"
264#define RouteResolve_doc "[MqContextC...] [MqContextC::RouteResolve $ctx ident:string ?retnum:int32=-1?]"
265#define RouteTraverse_doc "MqContextC::RouteTraverse $ctx service:string ?args:MkBufferListC...=NULL?"
266
267// doc-key: MqContextC,MqRoute,omo,func
268#define RouteGetPath_doc "string [MqContextC::RouteGetPath $ctx]"
269
270// doc-key: MqContextC,MqSend,om_,func
271#define Send_doc "MqContextC::Send $ctx cstr:string args:args..."
272#define SendBFL_doc "MqContextC::SendBFL $ctx val:MkBufferListC"
273#define SendBIN_doc "MqContextC::SendBIN $ctx val:binary"
274#define SendBOL_doc "MqContextC::SendBOL $ctx val:bool"
275#define SendBUF_doc "MqContextC::SendBUF $ctx val:MkBufferC"
276#define SendBUS_FLAT_doc "MqContextC::SendBUS_FLAT $ctx val:MkBufferStreamC"
277#define SendBinaryR_doc "MqContextC::SendBinaryR $ctx val:binary"
278#define SendDBL_doc "MqContextC::SendDBL $ctx val:double"
279#define SendEND_doc "MqContextC::SendEND $ctx token:string[4] ?timeout:MkTimeoutE|int32=DEFAULT?"
280#define SendEND_AND_CALLBACK_doc "MqContextC::SendEND_AND_CALLBACK $ctx token:string[4] callback:callable ?timeout:MkTimeoutE|int32=DEFAULT?"
281#define SendEND_AND_SUB_doc "MqContextC::SendEND_AND_SUB $ctx token:string[4] callback:callable ?timeout:MkTimeoutE|int32=DEFAULT?"
282#define SendEND_AND_TRANSACTION_doc "MqContextC::SendEND_AND_TRANSACTION $ctx token:string[4] callback:string[4] ?timeout:MkTimeoutE|int32=DEFAULT?"
283#define SendEND_AND_WAIT_doc "MqContextC::SendEND_AND_WAIT $ctx token:string[4] ?timeout:MkTimeoutE|int32=DEFAULT?"
284#define SendERROR_doc "MqContextC::SendERROR $ctx"
285#define SendFLT_doc "MqContextC::SendFLT $ctx val:float"
286#define SendHDL_doc "MqContextC::SendHDL $ctx val:MK_HDL"
287#define SendI16_doc "MqContextC::SendI16 $ctx val:int16"
288#define SendI32_doc "MqContextC::SendI32 $ctx val:int32"
289#define SendI64_doc "MqContextC::SendI64 $ctx val:int64"
290#define SendI8_doc "MqContextC::SendI8 $ctx val:int8"
291#define SendLONG_doc "MqContextC::SendLONG $ctx val:long"
292#define SendLTR_doc "MqContextC::SendLTR $ctx transLId:int32"
293#define SendL_END_doc "MqContextC::SendL_END $ctx"
294#define SendL_FLAT_doc "MqContextC::SendL_FLAT $ctx val:MkBufferListC"
295#define SendL_START_doc "MqContextC::SendL_START $ctx"
296#define SendRETURN_doc "MqContextC::SendRETURN $ctx"
297#define SendRETURN_SUB_doc "MqContextC::SendRETURN_SUB $ctx"
298#define SendSTART_doc "MqContextC::SendSTART $ctx"
299#define SendSTR_doc "MqContextC::SendSTR $ctx val:string"
300#define SendSYNC_doc "MqContextC::SendSYNC $ctx"
301#define SendStringR_doc "MqContextC::SendStringR $ctx val:string"
302#define SendT_END_doc "MqContextC::SendT_END $ctx"
303#define SendT_START_doc "MqContextC::SendT_START $ctx"
304
305// doc-key: MqContextC,MqService,om_,func
306#define ServiceCreate_doc "MqContextC::ServiceCreate $ctx token:string[4] callback:callable"
307#define ServiceDelete_doc "MqContextC::ServiceDelete $ctx token:string[4]"
308#define ServiceIsTransaction_doc "bool [MqContextC::ServiceIsTransaction $ctx]"
309#define ServiceProxy_doc "MqContextC::ServiceProxy $ctx token:string[4] ?id:MqSlaveE|int32=MQ_SLAVE_OTHER?"
310#define ServiceProxyCtx_doc "MqContextC::ServiceProxyCtx $ctx token:string[4] target:MqContextC"
311#define ServiceProxyCtxExists_doc "bool [MqContextC::ServiceProxyCtxExists $ctx token:string[4] target:MqContextC]"
312#define ServiceProxyRoundRobin_doc "MqContextC::ServiceProxyRoundRobin $ctx token:string[4] ident:string"
313#define ServiceStorage_doc "MqContextC::ServiceStorage $ctx token:string[4]"
314#define ServiceTokenCheck_doc "bool [MqContextC::ServiceTokenCheck $ctx token:string[4]]"
315#define ServiceTokenExists_doc "bool [MqContextC::ServiceTokenExists $ctx token:string[4]]"
316#define ServiceTokenGet_doc "string[4] [MqContextC::ServiceTokenGet $ctx]"
317
318// doc-key: MqContextC,MqSlave,oc_,func
319#define SlaveGetMaster_doc "MqContextC [MqContextC::SlaveGetMaster $ctx]"
320
321// doc-key: MqContextC,MqSlave,oco,func
322#define SlaveGet_doc "MqContextC [MqContextC::SlaveGet $ctx id:MqSlaveE|int32]"
323#define SlaveGetFilter_doc "MqContextC [MqContextC::SlaveGetFilter $ctx]"
324#define SlaveGetProxy_doc "MqContextC [MqContextC::SlaveGetProxy $ctx id:MqSlaveE|int32]"
325
326// doc-key: MqContextC,MqSlave,om_,func
327#define SlaveCheck_doc "bool [MqContextC::SlaveCheck $ctx id:MqSlaveE|int32] (const)"
328#define SlaveCreate_doc "MqContextC::SlaveCreate $ctx id:MqSlaveE|int32 slave:MqContextC"
329#define SlaveDelete_doc "MqContextC::SlaveDelete $ctx id:MqSlaveE|int32"
330#define SlaveIs_doc "bool [MqContextC::SlaveIs $ctx] (const)"
331#define SlaveWorker_doc "MqContextC::SlaveWorker $ctx id:MqSlaveE|int32 ?fct:string=\"WORKER\"? ?args:MkBufferListC...=NULL?"
332
333// doc-key: MqContextC,MqStorage,oci,func
334#define StorageDelete_doc "int32 [MqContextC::StorageDelete $ctx ?*transLIdP_inout:int32=0?]"
335#define StorageImport_doc "int32 [MqContextC::StorageImport $ctx ?*transLIdP_inout:int32=0?]"
336
337// doc-key: MqContextC,MqStorage,om_,func
338#define StorageClose_doc "MqContextC::StorageClose $ctx"
339#define StorageDecrRef_doc "MqContextC::StorageDecrRef $ctx transLId:int32"
340#define StorageIncrRef_doc "MqContextC::StorageIncrRef $ctx transLId:int32"
341#define StorageLog_doc "MqContextC::StorageLog $ctx ?callfunc:string=\"MK_NULL\"?"
342#define StorageOpen_doc "MqContextC::StorageOpen $ctx storageFile:string"
343
344// doc-key: MqContextC,MqStorage,omo,func
345#define StorageCount_doc "int32 [MqContextC::StorageCount $ctx]"
346#define StorageErrCnt_doc "int32 [MqContextC::StorageErrCnt $ctx transLId:int32]"
347#define StorageExport_doc "int32 [MqContextC::StorageExport $ctx]"
348#define StorageResolve_doc "{otherCtxP:MqContextC otherLIdP:int32} [MqContextC::StorageResolve $ctx]"
349
350// END-DOC - created by 'atl_MqS.tcl -i NHI1_HOME/theLink/c/gen/c_mqmsgque.meta' - DO NOT change
351
352/*****************************************************************************/
353/* */
354/* S T A R T */
355/* */
356/*****************************************************************************/
357
358/*****************************************************************************/
359/* */
360/* O B J E C T - hand */
361/* */
362/*****************************************************************************/
363
366static OT_ProcRet NS(MqContextC_Debug) (MqContextC_ARGS)
367{
369 OT_SETUP_VARARGS(1,1,"$ctx Debug prefix:str");
370 MK_STRN prefix;
371 OT_CHECK_STR(prefix)
373 MkLogC_4X(hdl,"…\n",0,prefix),
375 goto end;
376 error:
378 end:
380}
381
384static OT_ProcRet NS(MqContextC_printObj) (MqContextC_ARGS)
385{
387 OT_SETUP_VARARGS(1,2,"$ctx printObj obj:Tcl_Obj ?prefix:string=\"\"?");
388 OT_OBJ_T tclO = 0;;
390 MK_STRN prefix="print";
393 MK_OBJ obj;
394 MkTestClassE flag;
395 int mqR;
396 if(OT_LNG_OBJECT_IS_3(tclO, &obj, &flag)) {
397 mqR=-2;
398 switch (flag) {
399 case MkTestClassE_OK: mqR=obj->refCount; break;
400 case MkTestClassE_NULL: mqR=0; break;
401 case MkTestClassE_INVALID_SIGNATURE: mqR=-1; break;
404 case MkTestClassE_INTERNAL: mqR=-2; break;
405 }
406 } else {
407 mqR=-2;
408 }
409 printXV(hdl,"%-10s: string<%s>, type<%s>, refCount[mq=%i,tcl=%i], ptr<%p>\n",
410 prefix, Tcl_GetString(tclO), MK(GetTypeFromObj) (OT_Prefix_CALL tclO, NULL), mqR, tclO->refCount, tclO
411 );
413 goto end;
414 error:
416 end:
418}
419
422static OT_ProcRet NS(MqContextC_ConfigGetStartAsNum) (MqContextC_ARGS) {
424 OT_SETUP_NOARG("int [$ctx ConfigGetStartAsNum]");
426 OT_retObj_SET(Tcl_NewIntObj(MqConfigGetStartAs (hdl)));
427 goto end;
428 error:
430 end:
432}
433
436static OT_ProcRet NS(MqContextC_ConfigGetStatusIsNum) (MqContextC_ARGS) {
438 OT_SETUP_NOARG("int [$ctx ConfigGetStatusIsNum]");
440 OT_retObj_SET(Tcl_NewIntObj(MqConfigGetStatusIs (hdl)));
441 goto end;
442 error:
444 end:
446}
447
450
451// MARK_O
452/*****************************************************************************/
453/* */
454/* O B J E C T */
455/* */
456/*****************************************************************************/
457
458// BEGIN-MqContextC - created by 'atl_MqC.tcl -i NHI1_HOME/theLink/c/gen/c_mqmsgque.meta' - DO NOT change
459
463
464// doc-key: MqContextC,MqContextC-Class-Export,sc_
465
467static OT_ProcRet NS(MqContextC_HandleResolve) (OtClass_ARGS) {
470 MK_HDL netHdl = 0;
473 MQ_CTX retVal = MqContextHandleResolve (netHdl);
474 OT_retObj_SET_CTX(retVal);
475 goto end;
476 error:
478 end:
480}
481
482// doc-key: MqContextC,MqContextC-Class-Export,om_
483
484// skip on class-overload: MqContextHandleGet → MkObjectHandleGet
486static OT_ProcRet NS(MqContextC_HandleGet) (MqContextC_ARGS) {OT_ERROR_LNG_RETURN;}
487
489// MqContextC_Class_ATL_API
490
494
495// doc-key: MqContextC,MqContextC-Class-Introspection,oc_
496
498static OT_ProcRet NS(MqContextC_Next) (MqContextC_ARGS) {
502 MQ_CTX retVal = MqContextNext (hdl);
503 OT_retObj_SET_CTX(retVal);
504 goto end;
505 error:
507 end:
509}
510
512static OT_ProcRet NS(MqContextC_Prev) (MqContextC_ARGS) {
516 MQ_CTX retVal = MqContextPrev (hdl);
517 OT_retObj_SET_CTX(retVal);
518 goto end;
519 error:
521 end:
523}
524
525// doc-key: MqContextC,MqContextC-Class-Introspection,sc_
526
528static OT_ProcRet NS(MqContextC_Instances) (OtClass_ARGS) {
532 MQ_CTX retVal = MqContextInstances ();
533 OT_retObj_SET_CTX(retVal);
534 goto end;
535 error:
537 end:
539}
540
542// MqContextC_Class_ATL_API
543
547
548// doc-key: MqContextC,MqContextC-Class-Misc,sc_
549
551static OT_ProcRet NS(MqContextC_GetNull) (OtClass_ARGS) {
555 MQ_CTX retVal = MqContextGetNull ();
556 OT_retObj_SET_CTX(retVal);
557 goto end;
558 error:
560 end:
562}
563
565// MqContextC_Class_ATL_API
566
570
571// doc-key: MqContextC,MqContextC-ClassApi-Class,oc_
572
574static OT_ProcRet NS(MqContextC_ClassFactoryGet) (MqContextC_ARGS) {
578 MQ_FCT retVal = MqClassFactoryGet (hdl);
579 OT_retObj_SET_FCT(retVal);
580 goto end;
581 error:
583 end:
585}
586
587// doc-key: MqContextC,MqContextC-ClassApi-Class,om_
588
590static OT_ProcRet NS(MqContextC_ClassFactorySet) (MqContextC_ARGS) {
593 MQ_FCT item = 0;
596 MkErrorC_Check(hdl,MqClassFactorySet (hdl, item));
598 goto end;
599 error:
601 end:
603}
604
606static OT_ProcRet NS(MqContextC_ClassIdentGet) (MqContextC_ARGS) {
611 goto end;
612 error:
614 end:
616}
617
619static OT_ProcRet NS(MqContextC_ClassIdentSet) (MqContextC_ARGS) {
622 MK_STRN ident = 0;
625 MkErrorC_Check(hdl,MqClassIdentSet (hdl, ident));
627 goto end;
628 error:
630 end:
632}
633
635static OT_ProcRet NS(MqContextC_ClassOriginalIdentGet) (MqContextC_ARGS) {
640 goto end;
641 error:
643 end:
645}
646
648// MqContextC_ClassApi_Class_ATL_API
649
653
654// doc-key: MqContextC,MqContextC-ConfigApi-Get,oco
655
657static OT_ProcRet NS(MqContextC_ConfigGetIoTcpL) (MqContextC_ARGS) {
661 MK_BFL vals_out;
662 MkErrorC_Check(hdl,MqConfigGetIoTcpL (hdl, &vals_out));
663 OT_retObj_SET_BFL(vals_out);
664 goto end;
665 error:
667 end:
669}
670
671// doc-key: MqContextC,MqContextC-ConfigApi-Get,om_
672
674static OT_ProcRet NS(MqContextC_ConfigGetBuffersize) (MqContextC_ARGS) {
679 goto end;
680 error:
682 end:
684}
685
687static OT_ProcRet NS(MqContextC_ConfigGetIdentFrom) (MqContextC_ARGS) {
692 goto end;
693 error:
695 end:
697}
698
700static OT_ProcRet NS(MqContextC_ConfigGetIoPipe) (MqContextC_ARGS) {
705 goto end;
706 error:
708 end:
710}
711
713static OT_ProcRet NS(MqContextC_ConfigGetIoUds) (MqContextC_ARGS) {
718 goto end;
719 error:
721 end:
723}
724
726static OT_ProcRet NS(MqContextC_ConfigGetIsParent) (MqContextC_ARGS) {
731 goto end;
732 error:
734 end:
736}
737
739static OT_ProcRet NS(MqContextC_ConfigGetIsServer) (MqContextC_ARGS) {
744 goto end;
745 error:
747 end:
749}
750
752static OT_ProcRet NS(MqContextC_ConfigGetIsString) (MqContextC_ARGS) {
757 goto end;
758 error:
760 end:
762}
763
765static OT_ProcRet NS(MqContextC_ConfigGetName) (MqContextC_ARGS) {
770 goto end;
771 error:
773 end:
775}
776
778static OT_ProcRet NS(MqContextC_ConfigGetPkgsize) (MqContextC_ARGS) {
783 goto end;
784 error:
786 end:
788}
789
791static OT_ProcRet NS(MqContextC_ConfigGetPostfix) (MqContextC_ARGS) {
796 goto end;
797 error:
799 end:
801}
802
804static OT_ProcRet NS(MqContextC_ConfigGetPrefix) (MqContextC_ARGS) {
809 goto end;
810 error:
812 end:
814}
815
817static OT_ProcRet NS(MqContextC_ConfigGetStartAs) (MqContextC_ARGS) {
822 goto end;
823 error:
825 end:
827}
828
830static OT_ProcRet NS(MqContextC_ConfigGetStatusIs) (MqContextC_ARGS) {
835 goto end;
836 error:
838 end:
840}
841
843static OT_ProcRet NS(MqContextC_ConfigGetStorage) (MqContextC_ARGS) {
848 goto end;
849 error:
851 end:
853}
854
856static OT_ProcRet NS(MqContextC_ConfigGetTimeout) (MqContextC_ARGS) {
861 goto end;
862 error:
864 end:
866}
867
869static OT_ProcRet NS(MqContextC_ConfigSetConfigFile) (MqContextC_ARGS) {
872 MK_STRN filename = 0;
875 MkErrorC_Check(hdl,MqConfigSetConfigFile (hdl, filename));
877 goto end;
878 error:
880 end:
882}
883
884// doc-key: MqContextC,MqContextC-ConfigApi-Get,omo
885
887static OT_ProcRet NS(MqContextC_ConfigGetIoTcp) (MqContextC_ARGS) {
891 MK_STRN host_out;
892 MK_STRN port_out;
893 MK_STRN myhost_out;
894 MK_STRN myport_out;
895 MkErrorC_Check(hdl,MqConfigGetIoTcp (hdl, &host_out, &port_out, &myhost_out, &myport_out));
899 OT_retObj_APPEND(OT_TMP_STR_OBJ(myhost_out));
900 OT_retObj_APPEND(OT_TMP_STR_OBJ(myport_out));
901 goto end;
902 error:
904 end:
906}
907
909// MqContextC_ConfigApi_Get_ATL_API
910
914
915// doc-key: MqContextC,MqContextC-ConfigApi-Interface,om_
916
918static OT_ProcRet NS(MqContextC_ConfigSetBgError) (MqContextC_ARGS) {
921 OT_SETUP_CALLABLE(callback)
924 MqServiceCallbackF fCall = (callback == NULL ? NULL : NS(ServiceCall));
925 MqConfigSetBgError (hdl, fCall, callback, NS(ServiceFree), NS(ServiceCopy));
927 goto end;
928 error:
930 end:
931 OT_CLEANUP_CALLABLE(callback)
933}
934
936static OT_ProcRet NS(MqContextC_ConfigSetEvent) (MqContextC_ARGS) {
939 OT_SETUP_CALLABLE(callback)
942 MqServiceCallbackF fCall = (callback == NULL ? NULL : NS(ServiceCall));
943 MqConfigSetEvent (hdl, fCall, callback, NS(ServiceFree), NS(ServiceCopy));
945 goto end;
946 error:
948 end:
949 OT_CLEANUP_CALLABLE(callback)
951}
952
954static OT_ProcRet NS(MqContextC_ConfigSetServerCleanup) (MqContextC_ARGS) {
957 OT_SETUP_CALLABLE(callback)
960 MqServiceCallbackF fCall = (callback == NULL ? NULL : NS(ServiceCall));
961 MqConfigSetServerCleanup (hdl, fCall, callback, NS(ServiceFree), NS(ServiceCopy));
963 goto end;
964 error:
966 end:
967 OT_CLEANUP_CALLABLE(callback)
969}
970
972static OT_ProcRet NS(MqContextC_ConfigSetServerSetup) (MqContextC_ARGS) {
975 OT_SETUP_CALLABLE(callback)
978 MqServiceCallbackF fCall = (callback == NULL ? NULL : NS(ServiceCall));
979 MqConfigSetServerSetup (hdl, fCall, callback, NS(ServiceFree), NS(ServiceCopy));
981 goto end;
982 error:
984 end:
985 OT_CLEANUP_CALLABLE(callback)
987}
988
990// MqContextC_ConfigApi_Interface_ATL_API
991
995
996// doc-key: MqContextC,MqContextC-ConfigApi-Misc,om_
997
999static OT_ProcRet NS(MqContextC_ConfigReset) (MqContextC_ARGS) {
1003 MqConfigReset (hdl);
1005 goto end;
1006 error:
1008 end:
1010}
1011
1013// MqContextC_ConfigApi_Misc_ATL_API
1014
1018
1019// doc-key: MqContextC,MqContextC-ConfigApi-Set,om_
1020
1022static OT_ProcRet NS(MqContextC_ConfigCheckStartAs) (MqContextC_ARGS) {
1025 enum MqStartE data = 0;
1029 goto end;
1030 error:
1032 end:
1034}
1035
1037static OT_ProcRet NS(MqContextC_ConfigSetAllDebug) (MqContextC_ARGS) {
1040 MK_I32 data = 0;
1043 MkErrorC_Check(hdl,MqConfigSetAllDebug (hdl, data));
1045 goto end;
1046 error:
1048 end:
1050}
1051
1053static OT_ProcRet NS(MqContextC_ConfigSetAllTimeout) (MqContextC_ARGS) {
1056 MK_TIME_T data = 0;
1059 MqConfigSetAllTimeout (hdl, data);
1061 goto end;
1062 error:
1064 end:
1066}
1067
1069static OT_ProcRet NS(MqContextC_ConfigSetBuffersize) (MqContextC_ARGS) {
1072 MK_I32 data = 0;
1075 MqConfigSetBuffersize (hdl, data);
1077 goto end;
1078 error:
1080 end:
1082}
1083
1085static OT_ProcRet NS(MqContextC_ConfigSetDaemon) (MqContextC_ARGS) {
1088 MK_STRN pidfile = 0;
1091 MkErrorC_Check(hdl,MqConfigSetDaemon (hdl, pidfile));
1093 goto end;
1094 error:
1096 end:
1098}
1099
1101static OT_ProcRet NS(MqContextC_ConfigSetIdentFrom) (MqContextC_ARGS) {
1104 enum MqIdentE data = 0;
1107 MqConfigSetIdentFrom (hdl, data);
1109 goto end;
1110 error:
1112 end:
1114}
1115
1117static OT_ProcRet NS(MqContextC_ConfigSetIgnoreExit) (MqContextC_ARGS) {
1120 MK_BOOL data = 0;
1123 MqConfigSetIgnoreExit (hdl, data);
1125 goto end;
1126 error:
1128 end:
1130}
1131
1133static OT_ProcRet NS(MqContextC_ConfigSetIoPipe) (MqContextC_ARGS) {
1136 MQ_SOCK_HDL fh = 0;
1139 MkErrorC_Check(hdl,MqConfigSetIoPipe (hdl, fh));
1141 goto end;
1142 error:
1144 end:
1146}
1147
1149static OT_ProcRet NS(MqContextC_ConfigSetIoTcp) (MqContextC_ARGS) {
1152 MK_STRN host = NULL;
1154 MK_STRN port = NULL;
1156 MK_STRN myhost = NULL;
1158 MK_STRN myport = NULL;
1161 MkErrorC_Check(hdl,MqConfigSetIoTcp (hdl, host, port, myhost, myport));
1163 goto end;
1164 error:
1166 end:
1168}
1169
1171static OT_ProcRet NS(MqContextC_ConfigSetIoTcpL) (MqContextC_ARGS) {
1174 MkBufferListCreateTLS_T(vals,10);
1177 MkErrorC_Check(hdl,MqConfigSetIoTcpL (hdl, vals));
1179 goto end;
1180 error:
1182 end:
1184}
1185
1187static OT_ProcRet NS(MqContextC_ConfigSetIoUds) (MqContextC_ARGS) {
1190 MK_STRN file = 0;
1193 MkErrorC_Check(hdl,MqConfigSetIoUds (hdl, file));
1195 goto end;
1196 error:
1198 end:
1200}
1201
1203static OT_ProcRet NS(MqContextC_ConfigSetIsServer) (MqContextC_ARGS) {
1206 MK_BOOL data = 0;
1209 MqConfigSetIsServer (hdl, data);
1211 goto end;
1212 error:
1214 end:
1216}
1217
1219static OT_ProcRet NS(MqContextC_ConfigSetIsString) (MqContextC_ARGS) {
1222 MK_BOOL data = 0;
1225 MqConfigSetIsString (hdl, data);
1227 goto end;
1228 error:
1230 end:
1232}
1233
1235static OT_ProcRet NS(MqContextC_ConfigSetName) (MqContextC_ARGS) {
1238 MK_STRN data = 0;
1241 MqConfigSetName (hdl, data);
1243 goto end;
1244 error:
1246 end:
1248}
1249
1251static OT_ProcRet NS(MqContextC_ConfigSetPkgsize) (MqContextC_ARGS) {
1254 MK_I32 data = 0;
1257 MqConfigSetPkgsize (hdl, data);
1259 goto end;
1260 error:
1262 end:
1264}
1265
1267static OT_ProcRet NS(MqContextC_ConfigSetPostfix) (MqContextC_ARGS) {
1270 MK_STRN data = 0;
1273 MqConfigSetPostfix (hdl, data);
1275 goto end;
1276 error:
1278 end:
1280}
1281
1283static OT_ProcRet NS(MqContextC_ConfigSetPrefix) (MqContextC_ARGS) {
1286 MK_STRN data = 0;
1289 MqConfigSetPrefix (hdl, data);
1291 goto end;
1292 error:
1294 end:
1296}
1297
1299static OT_ProcRet NS(MqContextC_ConfigSetStartAs) (MqContextC_ARGS) {
1302 enum MqStartE data = 0;
1305 MkErrorC_Check(hdl,MqConfigSetStartAs (hdl, data));
1307 goto end;
1308 error:
1310 end:
1312}
1313
1315static OT_ProcRet NS(MqContextC_ConfigSetStartAsString) (MqContextC_ARGS) {
1318 MK_STRN data = 0;
1323 goto end;
1324 error:
1326 end:
1328}
1329
1331static OT_ProcRet NS(MqContextC_ConfigSetStorage) (MqContextC_ARGS) {
1334 MK_STRN data = 0;
1337 MqConfigSetStorage (hdl, data);
1339 goto end;
1340 error:
1342 end:
1344}
1345
1347static OT_ProcRet NS(MqContextC_ConfigSetTimeout) (MqContextC_ARGS) {
1350 MK_TIME_T data = 0;
1353 MqConfigSetTimeout (hdl, data);
1355 goto end;
1356 error:
1358 end:
1360}
1361
1363// MqContextC_ConfigApi_Set_ATL_API
1364
1368
1369// doc-key: MqContextC,MqContextC-EnvApi-Env,om_
1370
1372static OT_ProcRet NS(MqContextC_EnvProtect) (MqContextC_ARGS) {
1376 MqEnvProtect (hdl);
1378 goto end;
1379 error:
1381 end:
1383}
1384
1386static OT_ProcRet NS(MqContextC_EnvRestore) (MqContextC_ARGS) {
1390 MqEnvRestore (hdl);
1392 goto end;
1393 error:
1395 end:
1397}
1398
1400// MqContextC_EnvApi_Env_ATL_API
1401
1405
1406// doc-key: MqContextC,MqContextC-ErrorApi-Error,oc_
1407
1409static OT_ProcRet NS(MqContextC_ErrorFORMAT) (MqContextC_ARGS) {
1413 MK_ERR retVal = MqContextErrorFORMAT (hdl);
1414 OT_retObj_SET_ERR(retVal);
1415 goto end;
1416 error:
1418 end:
1420}
1421
1422// doc-key: MqContextC,MqContextC-ErrorApi-Error,om_
1423
1425OT_ProcRet NS(MqContextC_ErrorCopy) (MqContextC_ARGS) {
1428 MQ_CTXN sourceCtx = 0;
1431 OT_retObj_SET(OT_NEW_Mk_enum_OBJ(ErrorE,MqContextErrorCopy (hdl, sourceCtx)));
1432 goto end;
1433 error:
1435 end:
1437}
1438
1440OT_ProcRet NS(MqContextC_ErrorMove) (MqContextC_ARGS) {
1443 MQ_CTXN sourceCtx = 0;
1446 OT_retObj_SET(OT_NEW_Mk_enum_OBJ(ErrorE,MqContextErrorMove (hdl, sourceCtx)));
1447 goto end;
1448 error:
1450 end:
1452}
1453
1455// MqContextC_ErrorApi_Error_ATL_API
1456
1460
1461// doc-key: MqContextC,MqContextC-HighApi-High,om_
1462
1464OT_ProcRet NS(MqContextC_Send) (MqContextC_ARGS) ; // skip template-required
1465
1467// MqContextC_HighApi_High_ATL_API
1468
1472
1473// doc-key: MqContextC,MqContextC-LinkApi-Link,oc_
1474
1476static OT_ProcRet NS(MqContextC_LinkGetParent) (MqContextC_ARGS) {
1480 MQ_CTX retVal = MqLinkGetParent (hdl);
1481 OT_retObj_SET_CTX(retVal);
1482 goto end;
1483 error:
1485 end:
1487}
1488
1489// doc-key: MqContextC,MqContextC-LinkApi-Link,om_
1490
1492static OT_ProcRet NS(MqContextC_LinkConnect) (MqContextC_ARGS) {
1496 MkErrorC_Check(hdl,MqLinkConnect (hdl));
1498 goto end;
1499 error:
1501 end:
1503}
1504
1506static OT_ProcRet NS(MqContextC_LinkCreate) (MqContextC_ARGS) {
1509 MkBufferListCreateTLS_T(args,10);
1512 MkErrorC_Check(hdl,MqLinkCreate (hdl, args));
1514 goto end;
1515 error:
1517 end:
1519}
1520
1522static OT_ProcRet NS(MqContextC_LinkCreateChild) (MqContextC_ARGS) {
1525 MQ_CTX parent = 0;
1527 MkBufferListCreateTLS_T(args,10);
1530 MkErrorC_Check(hdl,MqLinkCreateChild (hdl, parent, args));
1532 goto end;
1533 error:
1535 end:
1537}
1538
1540static OT_ProcRet NS(MqContextC_LinkDelete) (MqContextC_ARGS) {
1544 MqLinkDelete (hdl);
1546 goto end;
1547 error:
1549 end:
1551}
1552
1554static OT_ProcRet NS(MqContextC_LinkGetCtxId) (MqContextC_ARGS) {
1559 goto end;
1560 error:
1562 end:
1564}
1565
1567static OT_ProcRet NS(MqContextC_LinkGetTargetIdent) (MqContextC_ARGS) {
1572 goto end;
1573 error:
1575 end:
1577}
1578
1580static OT_ProcRet NS(MqContextC_LinkIsConnected) (MqContextC_ARGS) {
1585 goto end;
1586 error:
1588 end:
1590}
1591
1593static OT_ProcRet NS(MqContextC_LinkIsParent) (MqContextC_ARGS) {
1598 goto end;
1599 error:
1601 end:
1603}
1604
1606static OT_ProcRet NS(MqContextC_LinkShutdown) (MqContextC_ARGS) {
1610 MkErrorC_Check(hdl,MqLinkShutdown (hdl));
1612 goto end;
1613 error:
1615 end:
1617}
1618
1620// MqContextC_LinkApi_Link_ATL_API
1621
1625
1626// doc-key: MqContextC,MqContextC-LogApi-Log,om_
1627
1628// skip on class-overload: MqContextLog → MkObjectLog
1631
1633static OT_ProcRet NS(MqContextC_LogConfig) (MqContextC_ARGS) {
1636 MK_OBJN fmtobj = NULL;
1638 MK_DBG debug = 0;
1640 MK_STRN callfunc = NULL;
1642 MK_I32 lvl = 0;
1645 if (debug > MkRuntimeDebugGet()) {
1647 goto end;
1648 }
1649 if (MkSysStringIsNULL(callfunc)) {callfunc = OT_GET_CALL_PROC;}
1650 MqContextLogConfig (hdl, fmtobj, debug, callfunc, lvl);
1652 goto end;
1653 error:
1655 end:
1658}
1659
1661static OT_ProcRet NS(MqContextC_LogEnv) (MqContextC_ARGS) {
1664 MK_OBJN fmtobj = NULL;
1666 MK_DBG debug = 0;
1668 MK_STRN callfunc = NULL;
1670 MK_I32 lvl = 0;
1673 if (debug > MkRuntimeDebugGet()) {
1675 goto end;
1676 }
1677 if (MkSysStringIsNULL(callfunc)) {callfunc = OT_GET_CALL_PROC;}
1678 MqContextLogEnv (hdl, fmtobj, debug, callfunc, lvl);
1680 goto end;
1681 error:
1683 end:
1686}
1687
1689static OT_ProcRet NS(MqContextC_LogLink) (MqContextC_ARGS) {
1692 MK_OBJN fmtobj = NULL;
1694 MK_DBG debug = 0;
1696 MK_STRN callfunc = NULL;
1698 MK_I32 lvl = 0;
1701 if (debug > MkRuntimeDebugGet()) {
1703 goto end;
1704 }
1705 if (MkSysStringIsNULL(callfunc)) {callfunc = OT_GET_CALL_PROC;}
1706 MqContextLogLink (hdl, fmtobj, debug, callfunc, lvl);
1708 goto end;
1709 error:
1711 end:
1714}
1715
1717static OT_ProcRet NS(MqContextC_LogSetup) (MqContextC_ARGS) {
1720 MK_OBJN fmtobj = NULL;
1722 MK_DBG debug = 0;
1724 MK_STRN callfunc = NULL;
1726 MK_I32 lvl = 0;
1729 if (debug > MkRuntimeDebugGet()) {
1731 goto end;
1732 }
1733 if (MkSysStringIsNULL(callfunc)) {callfunc = OT_GET_CALL_PROC;}
1734 MqContextLogSetup (hdl, fmtobj, debug, callfunc, lvl);
1736 goto end;
1737 error:
1739 end:
1742}
1743
1745static OT_ProcRet NS(MqContextC_LogShort) (MqContextC_ARGS) {
1748 MK_OBJN fmtobj = NULL;
1750 MK_DBG debug = 0;
1752 MK_STRN callfunc = NULL;
1754 MK_I32 lvl = 0;
1756 MK_STRN label = NULL;
1759 if (debug > MkRuntimeDebugGet()) {
1761 goto end;
1762 }
1763 if (MkSysStringIsNULL(callfunc)) {callfunc = OT_GET_CALL_PROC;}
1764 MqContextLogShort (hdl, fmtobj, debug, callfunc, lvl, label);
1766 goto end;
1767 error:
1769 end:
1772}
1773
1775static OT_ProcRet NS(MqContextC_LogType) (MqContextC_ARGS) {
1778 MK_OBJN fmtobj = NULL;
1780 MK_DBG debug = 0;
1782 MK_STRN callfunc = NULL;
1784 MK_I32 lvl = 0;
1787 if (debug > MkRuntimeDebugGet()) {
1789 goto end;
1790 }
1791 if (MkSysStringIsNULL(callfunc)) {callfunc = OT_GET_CALL_PROC;}
1792 MqContextLogType (hdl, fmtobj, debug, callfunc, lvl);
1794 goto end;
1795 error:
1797 end:
1800}
1801
1803static OT_ProcRet NS(MqContextC_LogParentOrChild) (MqContextC_ARGS) {
1808 goto end;
1809 error:
1811 end:
1813}
1814
1816static OT_ProcRet NS(MqContextC_LogServerOrClient) (MqContextC_ARGS) {
1821 goto end;
1822 error:
1824 end:
1826}
1827
1829// MqContextC_LogApi_Log_ATL_API
1830
1834
1835// doc-key: MqContextC,MqContextC-MiscApi-Misc,oc_
1836
1838static OT_ProcRet NS(MqContextC_GetBuffer) (MqContextC_ARGS) {
1842 MK_BUF retVal = MqContextGetBuffer (hdl);
1843 OT_retObj_SET_BUF(retVal);
1844 goto end;
1845 error:
1847 end:
1849}
1850
1852static OT_ProcRet NS(MqContextC_GetRoot) (MqContextC_ARGS) {
1856 MQ_CTX retVal = MqGetRoot (hdl);
1857 OT_retObj_SET_CTX(retVal);
1858 goto end;
1859 error:
1861 end:
1863}
1864
1865// doc-key: MqContextC,MqContextC-MiscApi-Misc,om_
1866
1867// skip on class-overload: MqContextToString → MkObjectToString
1869static OT_ProcRet NS(MqContextC_ToString) (MqContextC_ARGS) {OT_ERROR_LNG_RETURN;}
1870
1872static OT_ProcRet NS(MqContextC_Exit) (MqContextC_ARGS) {
1875 MK_STRN callfunc = NULL;
1877 MK_STRN callfile = NULL;
1879 MK_I32 callline = -1;
1882 if (callline == -1 ) {callline = OT_GET_CALL_LINE;}
1883 if (MkSysStringIsNULL(callfile)) {callfile = OT_GET_CALL_FILE;}
1884 if (MkSysStringIsNULL(callfunc)) {callfunc = OT_GET_CALL_PROC;}
1885 OT_retObj_SET_I32(MqExit (hdl, callfunc, callfile, callline));
1886 goto end;
1887 error:
1889 end:
1892}
1893
1911
1913// MqContextC_MiscApi_Misc_ATL_API
1914
1918
1919// doc-key: MqContextC,MqContextC-ProxyApi-Proxy,om_
1920
1922static OT_ProcRet NS(MqContextC_ProxyForward) (MqContextC_ARGS) {
1925 MQ_CTX targetCtx = 0;
1927 MQ_DMP dump = NULL;
1932 MkErrorC_Check(hdl,MqProxyForward (hdl, targetCtx, dump, timeout));
1934 goto end;
1935 error:
1937 end:
1939}
1940
1942static OT_ProcRet NS(MqContextC_ProxyItem) (MqContextC_ARGS) {
1945 MQ_CTX targetCtx = 0;
1948 MkErrorC_Check(hdl,MqProxyItem (hdl, targetCtx));
1950 goto end;
1951 error:
1953 end:
1955}
1956
1958// MqContextC_ProxyApi_Proxy_ATL_API
1959
1963
1964// doc-key: MqContextC,MqContextC-ReadApi-Atom,oci
1965
1967static OT_ProcRet NS(MqContextC_ReadALL) (MqContextC_ARGS) {
1970 MkBufferListCreateTLS_T(val_inout,10);
1973 MkErrorC_Check(hdl,MqReadALL (hdl, &val_inout));
1974 OT_retObj_SET_BFL(val_inout);
1975 goto end;
1976 error:
1978 end:
1980}
1981
1982// doc-key: MqContextC,MqContextC-ReadApi-Atom,oco
1983
1985static OT_ProcRet NS(MqContextC_ReadBFL) (MqContextC_ARGS) {
1989 MK_BFL val_out;
1990 MkErrorC_Check(hdl,MqReadBFL (hdl, &val_out));
1991 OT_retObj_SET_BFL(val_out);
1992 goto end;
1993 error:
1995 end:
1997}
1998
2000static OT_ProcRet NS(MqContextC_ReadBUF) (MqContextC_ARGS) {
2004 MK_BUF val_out;
2005 MkErrorC_Check(hdl,MqReadBUF (hdl, &val_out));
2006 OT_retObj_SET_BUF(val_out);
2007 goto end;
2008 error:
2010 end:
2012}
2013
2014// doc-key: MqContextC,MqContextC-ReadApi-Atom,omo
2015
2017static OT_ProcRet NS(MqContextC_ReadBIN) (MqContextC_ARGS) {
2021 MkBinaryR val_out;
2022 MkErrorC_Check(hdl,MqReadBIN (hdl, &val_out));
2023 MkBinaryR retVal = val_out;
2025 goto end;
2026 error:
2028 end:
2030}
2031
2033static OT_ProcRet NS(MqContextC_ReadBOL) (MqContextC_ARGS) {
2037 MK_BOL val_out;
2038 MkErrorC_Check(hdl,MqReadBOL (hdl, &val_out));
2039 OT_retObj_SET_BOL(val_out == 1);
2040 goto end;
2041 error:
2043 end:
2045}
2046
2048static OT_ProcRet NS(MqContextC_ReadBinaryR) (MqContextC_ARGS) {
2052 MkBinaryR val_out;
2053 MkErrorC_Check(hdl,MqReadBinaryR (hdl, &val_out));
2054 MkBinaryR retVal = val_out;
2056 goto end;
2057 error:
2059 end:
2061}
2062
2064static OT_ProcRet NS(MqContextC_ReadDBL) (MqContextC_ARGS) {
2068 MK_DBL val_out;
2069 MkErrorC_Check(hdl,MqReadDBL (hdl, &val_out));
2070 OT_retObj_SET_DBL(val_out);
2071 goto end;
2072 error:
2074 end:
2076}
2077
2079static OT_ProcRet NS(MqContextC_ReadFLT) (MqContextC_ARGS) {
2083 MK_FLT val_out;
2084 MkErrorC_Check(hdl,MqReadFLT (hdl, &val_out));
2085 OT_retObj_SET_FLT(val_out);
2086 goto end;
2087 error:
2089 end:
2091}
2092
2094static OT_ProcRet NS(MqContextC_ReadHDL) (MqContextC_ARGS) {
2098 MK_HDL val_out;
2099 MkErrorC_Check(hdl,MqReadHDL (hdl, &val_out));
2100 OT_retObj_SET_HDL(val_out);
2101 goto end;
2102 error:
2104 end:
2106}
2107
2109static OT_ProcRet NS(MqContextC_ReadI16) (MqContextC_ARGS) {
2113 MK_I16 val_out;
2114 MkErrorC_Check(hdl,MqReadI16 (hdl, &val_out));
2115 OT_retObj_SET_I16(val_out);
2116 goto end;
2117 error:
2119 end:
2121}
2122
2124static OT_ProcRet NS(MqContextC_ReadI32) (MqContextC_ARGS) {
2128 MK_I32 val_out;
2129 MkErrorC_Check(hdl,MqReadI32 (hdl, &val_out));
2130 OT_retObj_SET_I32(val_out);
2131 goto end;
2132 error:
2134 end:
2136}
2137
2139static OT_ProcRet NS(MqContextC_ReadI64) (MqContextC_ARGS) {
2143 MK_I64 val_out;
2144 MkErrorC_Check(hdl,MqReadI64 (hdl, &val_out));
2145 OT_retObj_SET_I64(val_out);
2146 goto end;
2147 error:
2149 end:
2151}
2152
2154static OT_ProcRet NS(MqContextC_ReadI8) (MqContextC_ARGS) {
2158 MK_I8 val_out;
2159 MkErrorC_Check(hdl,MqReadI8 (hdl, &val_out));
2160 OT_retObj_SET_I8(val_out);
2161 goto end;
2162 error:
2164 end:
2166}
2167
2169OT_ProcRet NS(MqContextC_ReadLIST) (MqContextC_ARGS) ; // skip template-required
2170
2172static OT_ProcRet NS(MqContextC_ReadLONG) (MqContextC_ARGS) {
2176 MK_LONG val_out;
2177 MkErrorC_Check(hdl,MqReadLONG (hdl, &val_out));
2178 OT_retObj_SET_LONG(val_out);
2179 goto end;
2180 error:
2182 end:
2184}
2185
2187OT_ProcRet NS(MqContextC_ReadNEXT) (MqContextC_ARGS) ; // skip template-required
2188
2190static OT_ProcRet NS(MqContextC_ReadSTR) (MqContextC_ARGS) {
2194 MK_STRN val_out;
2195 MkErrorC_Check(hdl,MqReadSTR (hdl, &val_out));
2196 OT_retObj_SET_STR(val_out);
2197 goto end;
2198 error:
2200 end:
2202}
2203
2205static OT_ProcRet NS(MqContextC_ReadStringR) (MqContextC_ARGS) {
2209 MkStringR val_out;
2210 MkErrorC_Check(hdl,MqReadStringR (hdl, &val_out));
2211 MkStringR retVal = val_out;
2213 goto end;
2214 error:
2216 end:
2218}
2219
2221// MqContextC_ReadApi_Atom_ATL_API
2222
2226
2227// doc-key: MqContextC,MqContextC-ReadApi-Block,om_
2228
2230static OT_ProcRet NS(MqContextC_ReadL_END) (MqContextC_ARGS) {
2234 MkErrorC_Check(hdl,MqReadL_END (hdl));
2236 goto end;
2237 error:
2239 end:
2241}
2242
2244static OT_ProcRet NS(MqContextC_ReadL_START) (MqContextC_ARGS) {
2247 MK_BUF buf = NULL;
2250 MkErrorC_Check(hdl,MqReadL_START (hdl, buf));
2252 goto end;
2253 error:
2255 end:
2257}
2258
2260static OT_ProcRet NS(MqContextC_ReadT_END) (MqContextC_ARGS) {
2264 MkErrorC_Check(hdl,MqReadT_END (hdl));
2266 goto end;
2267 error:
2269 end:
2271}
2272
2274static OT_ProcRet NS(MqContextC_ReadT_START) (MqContextC_ARGS) {
2278 MkErrorC_Check(hdl,MqReadT_START (hdl));
2280 goto end;
2281 error:
2283 end:
2285}
2286
2288// MqContextC_ReadApi_Block_ATL_API
2289
2293
2294// doc-key: MqContextC,MqContextC-ReadApi-Misc,om_
2295
2297static OT_ProcRet NS(MqContextC_ReadDbg) (MqContextC_ARGS) {
2301 MqReadDbg (hdl);
2303 goto end;
2304 error:
2306 end:
2308}
2309
2311static OT_ProcRet NS(MqContextC_ReadGetNextType) (MqContextC_ARGS) {
2316 goto end;
2317 error:
2319 end:
2321}
2322
2324static OT_ProcRet NS(MqContextC_ReadGetNumItems) (MqContextC_ARGS) {
2329 goto end;
2330 error:
2332 end:
2334}
2335
2337static OT_ProcRet NS(MqContextC_ReadItemExists) (MqContextC_ARGS) {
2342 goto end;
2343 error:
2345 end:
2347}
2348
2350static OT_ProcRet NS(MqContextC_ReadUndo) (MqContextC_ARGS) {
2354 MkErrorC_Check(hdl,MqReadUndo (hdl));
2356 goto end;
2357 error:
2359 end:
2361}
2362
2364// MqContextC_ReadApi_Misc_ATL_API
2365
2369
2370// doc-key: MqContextC,MqContextC-RouteApi-Route,oco
2371
2373static OT_ProcRet NS(MqContextC_RouteGetTree) (MqContextC_ARGS) {
2377 MK_BFL treeP_out;
2378 MkErrorC_Check(hdl,MqRouteGetTree (hdl, &treeP_out));
2379 OT_retObj_SET_BFL(treeP_out);
2380 goto end;
2381 error:
2383 end:
2385}
2386
2387// doc-key: MqContextC,MqContextC-RouteApi-Route,om_
2388
2390static OT_ProcRet NS(MqContextC_RouteCreate) (MqContextC_ARGS) {
2393 MK_STRN route = 0;
2395 MK_STRN service = 0;
2397 MK_BOOL overwrite = false;
2398 OT_CHECK_OPTIONAL(OT_CHECK_bool (overwrite))
2400 MkErrorC_Check(hdl,MqRouteCreate (hdl, route, service, overwrite));
2402 goto end;
2403 error:
2405 end:
2407}
2408
2410static OT_ProcRet NS(MqContextC_RouteDelete) (MqContextC_ARGS) {
2413 MK_STRN route = 0;
2415 MK_STRN service = 0;
2417 MK_BOOL overwrite = false;
2418 OT_CHECK_OPTIONAL(OT_CHECK_bool (overwrite))
2420 MkErrorC_Check(hdl,MqRouteDelete (hdl, route, service, overwrite));
2422 goto end;
2423 error:
2425 end:
2427}
2428
2430static OT_ProcRet NS(MqContextC_RouteResolve) (MqContextC_ARGS) {
2433 MK_STRN ident = 0;
2435 MK_NUM retnum = -1;
2438 MQ_CTX_A retVal = MqRouteResolve (hdl, ident, retnum);
2440 for (int i=0; i<retVal.size; i++) {
2442 }
2443 goto end;
2444 error:
2446 end:
2448}
2449
2451static OT_ProcRet NS(MqContextC_RouteTraverse) (MqContextC_ARGS) {
2454 MK_STRN service = 0;
2456 MkBufferListCreateTLS_T(args,10);
2459 MkErrorC_Check(hdl,MqRouteTraverse (hdl, service, args));
2461 goto end;
2462 error:
2464 end:
2466}
2467
2468// doc-key: MqContextC,MqContextC-RouteApi-Route,omo
2469
2471static OT_ProcRet NS(MqContextC_RouteGetPath) (MqContextC_ARGS) {
2475 MK_STRN path_out;
2476 MkErrorC_Check(hdl,MqRouteGetPath (hdl, &path_out));
2477 OT_retObj_SET_STR(path_out);
2478 goto end;
2479 error:
2481 end:
2483}
2484
2486// MqContextC_RouteApi_Route_ATL_API
2487
2491
2492// doc-key: MqContextC,MqContextC-SendApi-Atom,om_
2493
2495static OT_ProcRet NS(MqContextC_SendBFL) (MqContextC_ARGS) {
2501 MkErrorC_Check(hdl,MqSendBFL (hdl, val));
2503 goto end;
2504 error:
2506 end:
2508}
2509
2511static OT_ProcRet NS(MqContextC_SendBIN) (MqContextC_ARGS) {
2514 MkBinaryR val = {0};
2517 MkErrorC_Check(hdl,MqSendBIN (hdl, val));
2519 goto end;
2520 error:
2522 end:
2524}
2525
2527static OT_ProcRet NS(MqContextC_SendBOL) (MqContextC_ARGS) {
2530 MK_BOL val = 0;
2533 MkErrorC_Check(hdl,MqSendBOL (hdl, (MK_BOL)(val?1:0)));
2535 goto end;
2536 error:
2538 end:
2540}
2541
2543static OT_ProcRet NS(MqContextC_SendBUF) (MqContextC_ARGS) {
2546 MK_BUFN val = 0;
2549 MkErrorC_Check(hdl,MqSendBUF (hdl, val));
2551 goto end;
2552 error:
2554 end:
2556}
2557
2559static OT_ProcRet NS(MqContextC_SendBUS_FLAT) (MqContextC_ARGS) {
2562 MK_BUSN val = 0;
2565 MkErrorC_Check(hdl,MqSendBUS_FLAT (hdl, val));
2567 goto end;
2568 error:
2570 end:
2572}
2573
2575static OT_ProcRet NS(MqContextC_SendBinaryR) (MqContextC_ARGS) {
2578 MkBinaryR val = {0};
2581 MkErrorC_Check(hdl,MqSendBinaryR (hdl, val));
2583 goto end;
2584 error:
2586 end:
2588}
2589
2591static OT_ProcRet NS(MqContextC_SendDBL) (MqContextC_ARGS) {
2594 MK_DBL val = 0;
2597 MkErrorC_Check(hdl,MqSendDBL (hdl, val));
2599 goto end;
2600 error:
2602 end:
2604}
2605
2607static OT_ProcRet NS(MqContextC_SendFLT) (MqContextC_ARGS) {
2610 MK_FLT val = 0;
2613 MkErrorC_Check(hdl,MqSendFLT (hdl, val));
2615 goto end;
2616 error:
2618 end:
2620}
2621
2623static OT_ProcRet NS(MqContextC_SendHDL) (MqContextC_ARGS) {
2626 MK_HDL val = 0;
2629 MkErrorC_Check(hdl,MqSendHDL (hdl, val));
2631 goto end;
2632 error:
2634 end:
2636}
2637
2639static OT_ProcRet NS(MqContextC_SendI16) (MqContextC_ARGS) {
2642 MK_I16 val = 0;
2645 MkErrorC_Check(hdl,MqSendI16 (hdl, val));
2647 goto end;
2648 error:
2650 end:
2652}
2653
2655static OT_ProcRet NS(MqContextC_SendI32) (MqContextC_ARGS) {
2658 MK_I32 val = 0;
2661 MkErrorC_Check(hdl,MqSendI32 (hdl, val));
2663 goto end;
2664 error:
2666 end:
2668}
2669
2671static OT_ProcRet NS(MqContextC_SendI64) (MqContextC_ARGS) {
2674 MK_I64 val = 0;
2677 MkErrorC_Check(hdl,MqSendI64 (hdl, val));
2679 goto end;
2680 error:
2682 end:
2684}
2685
2687static OT_ProcRet NS(MqContextC_SendI8) (MqContextC_ARGS) {
2690 MK_I8 val = 0;
2693 MkErrorC_Check(hdl,MqSendI8 (hdl, (MK_I8)(val)));
2695 goto end;
2696 error:
2698 end:
2700}
2701
2703static OT_ProcRet NS(MqContextC_SendLONG) (MqContextC_ARGS) {
2706 MK_LONG val = 0;
2709 MkErrorC_Check(hdl,MqSendLONG (hdl, val));
2711 goto end;
2712 error:
2714 end:
2716}
2717
2719static OT_ProcRet NS(MqContextC_SendLTR) (MqContextC_ARGS) {
2722 MQ_LTR transLId = 0;
2725 MkErrorC_Check(hdl,MqSendLTR (hdl, transLId));
2727 goto end;
2728 error:
2730 end:
2732}
2733
2735static OT_ProcRet NS(MqContextC_SendL_FLAT) (MqContextC_ARGS) {
2741 MkErrorC_Check(hdl,MqSendL_FLAT (hdl, val));
2743 goto end;
2744 error:
2746 end:
2748}
2749
2751static OT_ProcRet NS(MqContextC_SendSTR) (MqContextC_ARGS) {
2754 MK_STRN val = 0;
2757 MkErrorC_Check(hdl,MqSendSTR (hdl, val));
2759 goto end;
2760 error:
2762 end:
2764}
2765
2767static OT_ProcRet NS(MqContextC_SendStringR) (MqContextC_ARGS) {
2770 MkStringR val = {0};
2773 MkErrorC_Check(hdl,MqSendStringR (hdl, val));
2775 goto end;
2776 error:
2778 end:
2780}
2781
2783// MqContextC_SendApi_Atom_ATL_API
2784
2788
2789// doc-key: MqContextC,MqContextC-SendApi-Basics,om_
2790
2808
2810static OT_ProcRet NS(MqContextC_SendEND_AND_CALLBACK) (MqContextC_ARGS) {
2813 MQ_TOK token = 0;
2815 OT_SETUP_CALLABLE(callback)
2820 MkErrorC_Check(hdl,MqSendEND_AND_CALLBACK (hdl, token, NS(ServiceCall), callback, NS(ServiceFree), timeout));
2822 goto end;
2823 error:
2825 end:
2826 OT_CLEANUP_CALLABLE(callback)
2828}
2829
2831static OT_ProcRet NS(MqContextC_SendEND_AND_SUB) (MqContextC_ARGS) {
2834 MQ_TOK token = 0;
2836 OT_SETUP_CALLABLE(callback)
2841 MkErrorC_Check(hdl,MqSendEND_AND_SUB (hdl, token, NS(ServiceCall), callback, NS(ServiceFree), timeout));
2843 goto end;
2844 error:
2846 end:
2847 OT_CLEANUP_CALLABLE(callback)
2849}
2850
2852static OT_ProcRet NS(MqContextC_SendEND_AND_TRANSACTION) (MqContextC_ARGS) {
2855 MQ_TOK token = 0;
2857 MQ_TOK callback = 0;
2864 goto end;
2865 error:
2867 end:
2869}
2870
2888
2890static OT_ProcRet NS(MqContextC_SendSTART) (MqContextC_ARGS) {
2894 MkErrorC_Check(hdl,MqSendSTART (hdl));
2896 goto end;
2897 error:
2899 end:
2901}
2902
2904static OT_ProcRet NS(MqContextC_SendSYNC) (MqContextC_ARGS) {
2908 MkErrorC_Check(hdl,MqSendSYNC (hdl));
2910 goto end;
2911 error:
2913 end:
2915}
2916
2918// MqContextC_SendApi_Basics_ATL_API
2919
2923
2924// doc-key: MqContextC,MqContextC-SendApi-Block,om_
2925
2927static OT_ProcRet NS(MqContextC_SendL_END) (MqContextC_ARGS) {
2931 MkErrorC_Check(hdl,MqSendL_END (hdl));
2933 goto end;
2934 error:
2936 end:
2938}
2939
2941static OT_ProcRet NS(MqContextC_SendL_START) (MqContextC_ARGS) {
2945 MkErrorC_Check(hdl,MqSendL_START (hdl));
2947 goto end;
2948 error:
2950 end:
2952}
2953
2955static OT_ProcRet NS(MqContextC_SendT_END) (MqContextC_ARGS) {
2959 MkErrorC_Check(hdl,MqSendT_END (hdl));
2961 goto end;
2962 error:
2964 end:
2966}
2967
2969static OT_ProcRet NS(MqContextC_SendT_START) (MqContextC_ARGS) {
2973 MkErrorC_Check(hdl,MqSendT_START (hdl));
2975 goto end;
2976 error:
2978 end:
2980}
2981
2983// MqContextC_SendApi_Block_ATL_API
2984
2988
2989// doc-key: MqContextC,MqContextC-SendApi-Return,om_
2990
2992static OT_ProcRet NS(MqContextC_SendERROR) (MqContextC_ARGS) {
2996 MkErrorC_Check(hdl,MqSendERROR (hdl));
2998 goto end;
2999 error:
3001 end:
3003}
3004
3006static OT_ProcRet NS(MqContextC_SendRETURN) (MqContextC_ARGS) {
3010 MkErrorC_Check(hdl,MqSendRETURN (hdl));
3012 goto end;
3013 error:
3015 end:
3017}
3018
3020static OT_ProcRet NS(MqContextC_SendRETURN_SUB) (MqContextC_ARGS) {
3026 goto end;
3027 error:
3029 end:
3031}
3032
3034// MqContextC_SendApi_Return_ATL_API
3035
3039
3040// doc-key: MqContextC,MqContextC-ServiceApi-Service,om_
3041
3043static OT_ProcRet NS(MqContextC_ServiceCreate) (MqContextC_ARGS) {
3046 MQ_TOK token = 0;
3048 OT_SETUP_CALLABLE(callback)
3051 MkErrorC_Check(hdl,MqServiceCreate (hdl, token, NS(ServiceCall), callback, NS(ServiceFree), NULL));
3053 goto end;
3054 error:
3056 end:
3057 OT_CLEANUP_CALLABLE(callback)
3059}
3060
3062static OT_ProcRet NS(MqContextC_ServiceDelete) (MqContextC_ARGS) {
3065 MQ_TOK token = 0;
3070 goto end;
3071 error:
3073 end:
3075}
3076
3078static OT_ProcRet NS(MqContextC_ServiceIsTransaction) (MqContextC_ARGS) {
3083 goto end;
3084 error:
3086 end:
3088}
3089
3091static OT_ProcRet NS(MqContextC_ServiceProxy) (MqContextC_ARGS) {
3094 MQ_TOK token = 0;
3099 MkErrorC_Check(hdl,MqServiceProxy (hdl, token, id));
3101 goto end;
3102 error:
3104 end:
3106}
3107
3109static OT_ProcRet NS(MqContextC_ServiceProxyCtx) (MqContextC_ARGS) {
3112 MQ_TOK token = 0;
3114 MQ_CTX target = 0;
3117 MkErrorC_Check(hdl,MqServiceProxyCtx (hdl, token, target));
3119 goto end;
3120 error:
3122 end:
3124}
3125
3127static OT_ProcRet NS(MqContextC_ServiceProxyCtxExists) (MqContextC_ARGS) {
3130 MQ_TOK token = 0;
3132 MQ_CTX target = 0;
3136 goto end;
3137 error:
3139 end:
3141}
3142
3144static OT_ProcRet NS(MqContextC_ServiceProxyRoundRobin) (MqContextC_ARGS) {
3147 MQ_TOK token = 0;
3149 MK_STRN ident = 0;
3154 goto end;
3155 error:
3157 end:
3159}
3160
3162static OT_ProcRet NS(MqContextC_ServiceStorage) (MqContextC_ARGS) {
3165 MQ_TOK token = 0;
3170 goto end;
3171 error:
3173 end:
3175}
3176
3178static OT_ProcRet NS(MqContextC_ServiceTokenCheck) (MqContextC_ARGS) {
3181 MQ_TOK token = 0;
3185 goto end;
3186 error:
3188 end:
3190}
3191
3193static OT_ProcRet NS(MqContextC_ServiceTokenExists) (MqContextC_ARGS) {
3196 MQ_TOK token = 0;
3200 goto end;
3201 error:
3203 end:
3205}
3206
3208static OT_ProcRet NS(MqContextC_ServiceTokenGet) (MqContextC_ARGS) {
3213 goto end;
3214 error:
3216 end:
3218}
3219
3221// MqContextC_ServiceApi_Service_ATL_API
3222
3226
3227// doc-key: MqContextC,MqContextC-SlaveApi-Slave,oc_
3228
3230static OT_ProcRet NS(MqContextC_SlaveGetMaster) (MqContextC_ARGS) {
3234 MQ_CTX retVal = MqSlaveGetMaster (hdl);
3235 OT_retObj_SET_CTX(retVal);
3236 goto end;
3237 error:
3239 end:
3241}
3242
3243// doc-key: MqContextC,MqContextC-SlaveApi-Slave,oco
3244
3246static OT_ProcRet NS(MqContextC_SlaveGet) (MqContextC_ARGS) {
3249 MQ_SLAVE_ID id = 0;
3252 MQ_CTX ctx_out;
3253 MkErrorC_Check(hdl,MqSlaveGet (hdl, id, &ctx_out));
3254 OT_retObj_SET_CTX(ctx_out);
3255 goto end;
3256 error:
3258 end:
3260}
3261
3263static OT_ProcRet NS(MqContextC_SlaveGetFilter) (MqContextC_ARGS) {
3267 MQ_CTX ctx_out;
3268 MkErrorC_Check(hdl,MqSlaveGetFilter (hdl, &ctx_out));
3269 OT_retObj_SET_CTX(ctx_out);
3270 goto end;
3271 error:
3273 end:
3275}
3276
3278static OT_ProcRet NS(MqContextC_SlaveGetProxy) (MqContextC_ARGS) {
3281 MQ_SLAVE_ID id = 0;
3284 MQ_CTX ctx_out;
3285 MkErrorC_Check(hdl,MqSlaveGetProxy (hdl, id, &ctx_out));
3286 OT_retObj_SET_CTX(ctx_out);
3287 goto end;
3288 error:
3290 end:
3292}
3293
3294// doc-key: MqContextC,MqContextC-SlaveApi-Slave,om_
3295
3297static OT_ProcRet NS(MqContextC_SlaveCheck) (MqContextC_ARGS) {
3300 MQ_SLAVE_ID id = 0;
3304 goto end;
3305 error:
3307 end:
3309}
3310
3312static OT_ProcRet NS(MqContextC_SlaveCreate) (MqContextC_ARGS) {
3315 MQ_SLAVE_ID id = 0;
3317 MQ_CTX slave = 0;
3320 MkErrorC_Check(hdl,MqSlaveCreate (hdl, id, slave));
3322 goto end;
3323 error:
3325 end:
3327}
3328
3330static OT_ProcRet NS(MqContextC_SlaveDelete) (MqContextC_ARGS) {
3333 MQ_SLAVE_ID id = 0;
3336 MkErrorC_Check(hdl,MqSlaveDelete (hdl, id));
3338 goto end;
3339 error:
3341 end:
3343}
3344
3346static OT_ProcRet NS(MqContextC_SlaveIs) (MqContextC_ARGS) {
3351 goto end;
3352 error:
3354 end:
3356}
3357
3359static OT_ProcRet NS(MqContextC_SlaveWorker) (MqContextC_ARGS) {
3362 MQ_SLAVE_ID id = 0;
3364 MK_STRN fct = "WORKER";
3366 MkBufferListCreateTLS_T(args,10);
3369 MkErrorC_Check(hdl,MqSlaveWorker (hdl, id, fct, args));
3371 goto end;
3372 error:
3374 end:
3376}
3377
3379// MqContextC_SlaveApi_Slave_ATL_API
3380
3384
3385// doc-key: MqContextC,MqContextC-StorageApi-Storage,oci
3386
3388static OT_ProcRet NS(MqContextC_StorageDelete) (MqContextC_ARGS) {
3391 MQ_LTR transLIdP_inout = 0;
3392 OT_CHECK_OPTIONAL(OT_CHECK_NI4 (transLIdP_inout))
3394 MkErrorC_Check(hdl,MqStorageDelete (hdl, &transLIdP_inout));
3395 OT_retObj_SET_I32(transLIdP_inout);
3396 goto end;
3397 error:
3399 end:
3401}
3402
3404static OT_ProcRet NS(MqContextC_StorageImport) (MqContextC_ARGS) {
3407 MQ_LTR transLIdP_inout = 0;
3408 OT_CHECK_OPTIONAL(OT_CHECK_NI4 (transLIdP_inout))
3410 MkErrorC_Check(hdl,MqStorageImport (hdl, &transLIdP_inout));
3411 OT_retObj_SET_I32(transLIdP_inout);
3412 goto end;
3413 error:
3415 end:
3417}
3418
3419// doc-key: MqContextC,MqContextC-StorageApi-Storage,om_
3420
3422static OT_ProcRet NS(MqContextC_StorageClose) (MqContextC_ARGS) {
3426 MkErrorC_Check(hdl,MqStorageClose (hdl));
3428 goto end;
3429 error:
3431 end:
3433}
3434
3436static OT_ProcRet NS(MqContextC_StorageDecrRef) (MqContextC_ARGS) {
3439 MQ_LTR transLId = 0;
3442 MkErrorC_Check(hdl,MqStorageDecrRef (hdl, transLId));
3444 goto end;
3445 error:
3447 end:
3449}
3450
3452static OT_ProcRet NS(MqContextC_StorageIncrRef) (MqContextC_ARGS) {
3455 MQ_LTR transLId = 0;
3458 MkErrorC_Check(hdl,MqStorageIncrRef (hdl, transLId));
3460 goto end;
3461 error:
3463 end:
3465}
3466
3468static OT_ProcRet NS(MqContextC_StorageLog) (MqContextC_ARGS) {
3471 MK_STRN callfunc = NULL;
3474 if (MkSysStringIsNULL(callfunc)) {callfunc = OT_GET_CALL_PROC;}
3475 MkErrorC_Check(hdl,MqStorageLog (hdl, callfunc));
3477 goto end;
3478 error:
3480 end:
3483}
3484
3486static OT_ProcRet NS(MqContextC_StorageOpen) (MqContextC_ARGS) {
3489 MK_STRN storageFile = 0;
3490 OT_CHECK_REQUIRED(OT_CHECK_STRN (storageFile))
3492 MkErrorC_Check(hdl,MqStorageOpen (hdl, storageFile));
3494 goto end;
3495 error:
3497 end:
3499}
3500
3501// doc-key: MqContextC,MqContextC-StorageApi-Storage,omo
3502
3504static OT_ProcRet NS(MqContextC_StorageCount) (MqContextC_ARGS) {
3508 MQ_LTR cnt_out;
3509 MkErrorC_Check(hdl,MqStorageCount (hdl, &cnt_out));
3510 OT_retObj_SET_I32(cnt_out);
3511 goto end;
3512 error:
3514 end:
3516}
3517
3519static OT_ProcRet NS(MqContextC_StorageErrCnt) (MqContextC_ARGS) {
3522 MQ_LTR transLId = 0;
3525 MK_I32 cnt_out;
3526 MkErrorC_Check(hdl,MqStorageErrCnt (hdl, transLId, &cnt_out));
3527 OT_retObj_SET_I32(cnt_out);
3528 goto end;
3529 error:
3531 end:
3533}
3534
3536static OT_ProcRet NS(MqContextC_StorageExport) (MqContextC_ARGS) {
3540 MQ_LTR ltid_out;
3541 MkErrorC_Check(hdl,MqStorageExport (hdl, &ltid_out));
3542 OT_retObj_SET_I32(ltid_out);
3543 goto end;
3544 error:
3546 end:
3548}
3549
3551static OT_ProcRet NS(MqContextC_StorageResolve) (MqContextC_ARGS) {
3555 MQ_CTX otherCtxP_out;
3556 MQ_LTR otherLIdP_out;
3557 MkErrorC_Check(hdl,MqStorageResolve (hdl, &otherCtxP_out, &otherLIdP_out));
3559 OT_retObj_APPEND(OT_TMP_CTX_OBJ(otherCtxP_out));
3560 OT_retObj_APPEND(OT_TMP_I32_OBJ(otherLIdP_out));
3561 goto end;
3562 error:
3564 end:
3566}
3567
3569// MqContextC_StorageApi_Storage_ATL_API
3570
3574
3575// doc-key: MqContextC,MqContextC-TOR,sCc
3576
3578static OT_ProcRet NS(MqContextC_CTOR) (CONSTR_ARGS) {
3581 MQ_CTX tmpl = NULL;
3583 MQ_CTX retVal = MqContextCreate (MqContextCTT, tmpl);
3584 if (retVal == NULL) {
3585 OT_ERROR_CONSTRUCTOR(MqContextC);
3586 goto error;
3587 }
3588 OT_CONSTRUCTOR_POST(retVal)
3589 OT_retObj_CONSTR(retVal);
3590 goto end;
3591 error:
3593 end:
3595}
3596
3598static OT_ProcRet NS(MqContextC_Create) (OtClass_ARGS) {
3601 MQ_CTX tmpl = NULL;
3604 MQ_CTX retVal = MqContextCreate (MqContextCTT, tmpl);
3605 if (retVal == NULL) {
3606 OT_ERROR_CONSTRUCTOR(MqContextC);
3607 goto error;
3608 }
3609 OT_CONSTRUCTOR_POST(retVal)
3610 OT_retObj_SET_CTX(retVal);
3611 goto end;
3612 error:
3614 end:
3616}
3617
3619// MqContextC_TOR_ATL_API
3620
3621// END-MqContextC - created by 'atl_MqC.tcl -i NHI1_HOME/theLink/c/gen/c_mqmsgque.meta' - DO NOT change
3622
3623// ---------------------------------------------------------------------------------------
3624
3625static const OtObjProcDefS NS(sOtClassDef)[] = {
3626 // BEGIN-CLASS - created by 'atl_MqS.tcl -i NHI1_HOME/theLink/c/gen/c_mqmsgque.meta' - DO NOT change
3627
3628 // doc-key: MqContextC,MqContext,sCc
3629 { "::MqContextC::Create" , NS(MqContextC_Create) },
3630
3631 // doc-key: MqContextC,MqContext,sc_
3632 { "::MqContextC::GetNull" , NS(MqContextC_GetNull) },
3633 { "::MqContextC::HandleResolve" , NS(MqContextC_HandleResolve) },
3634 { "::MqContextC::Instances" , NS(MqContextC_Instances) },
3635
3636 // END-CLASS - created by 'atl_MqS.tcl -i NHI1_HOME/theLink/c/gen/c_mqmsgque.meta' - DO NOT change
3637 { NULL }
3638};
3639
3640// ---------------------------------------------------------------------------------------
3641
3642static const OtObjProcDefS NS(sInstanceDef)[] = {
3643
3644 { "::MqContextC::Debug" , NS(MqContextC_Debug) },
3645 { "::MqContextC::printObj" , NS(MqContextC_printObj) },
3646 { "::MqContextC::ConfigGetStartAsNum" , NS(MqContextC_ConfigGetStartAsNum) },
3647 { "::MqContextC::ConfigGetStatusIsNum" , NS(MqContextC_ConfigGetStatusIsNum) },
3648
3649 // BEGIN-OBJ - created by 'atl_MqS.tcl -i NHI1_HOME/theLink/c/gen/c_mqmsgque.meta' - DO NOT change
3650
3651 // doc-key: MqContextC,MqClass,oc_
3652 { "::MqContextC::ClassFactoryGet" , NS(MqContextC_ClassFactoryGet) },
3653
3654 // doc-key: MqContextC,MqClass,om_
3655 { "::MqContextC::ClassFactorySet" , NS(MqContextC_ClassFactorySet) },
3656 { "::MqContextC::ClassIdentGet" , NS(MqContextC_ClassIdentGet) },
3657 { "::MqContextC::ClassIdentSet" , NS(MqContextC_ClassIdentSet) },
3658 { "::MqContextC::ClassOriginalIdentGet" , NS(MqContextC_ClassOriginalIdentGet) },
3659
3660 // doc-key: MqContextC,MqConfig,oco
3661 { "::MqContextC::ConfigGetIoTcpL" , NS(MqContextC_ConfigGetIoTcpL) },
3662
3663 // doc-key: MqContextC,MqConfig,om_
3664 { "::MqContextC::ConfigCheckStartAs" , NS(MqContextC_ConfigCheckStartAs) },
3665 { "::MqContextC::ConfigGetBuffersize" , NS(MqContextC_ConfigGetBuffersize) },
3666 { "::MqContextC::ConfigGetIdentFrom" , NS(MqContextC_ConfigGetIdentFrom) },
3667 { "::MqContextC::ConfigGetIoPipe" , NS(MqContextC_ConfigGetIoPipe) },
3668 { "::MqContextC::ConfigGetIoUds" , NS(MqContextC_ConfigGetIoUds) },
3669 { "::MqContextC::ConfigGetIsParent" , NS(MqContextC_ConfigGetIsParent) },
3670 { "::MqContextC::ConfigGetIsServer" , NS(MqContextC_ConfigGetIsServer) },
3671 { "::MqContextC::ConfigGetIsString" , NS(MqContextC_ConfigGetIsString) },
3672 { "::MqContextC::ConfigGetName" , NS(MqContextC_ConfigGetName) },
3673 { "::MqContextC::ConfigGetPkgsize" , NS(MqContextC_ConfigGetPkgsize) },
3674 { "::MqContextC::ConfigGetPostfix" , NS(MqContextC_ConfigGetPostfix) },
3675 { "::MqContextC::ConfigGetPrefix" , NS(MqContextC_ConfigGetPrefix) },
3676 { "::MqContextC::ConfigGetStartAs" , NS(MqContextC_ConfigGetStartAs) },
3677 { "::MqContextC::ConfigGetStatusIs" , NS(MqContextC_ConfigGetStatusIs) },
3678 { "::MqContextC::ConfigGetStorage" , NS(MqContextC_ConfigGetStorage) },
3679 { "::MqContextC::ConfigGetTimeout" , NS(MqContextC_ConfigGetTimeout) },
3680 { "::MqContextC::ConfigReset" , NS(MqContextC_ConfigReset) },
3681 { "::MqContextC::ConfigSetAllDebug" , NS(MqContextC_ConfigSetAllDebug) },
3682 { "::MqContextC::ConfigSetAllTimeout" , NS(MqContextC_ConfigSetAllTimeout) },
3683 { "::MqContextC::ConfigSetBgError" , NS(MqContextC_ConfigSetBgError) },
3684 { "::MqContextC::ConfigSetBuffersize" , NS(MqContextC_ConfigSetBuffersize) },
3685 { "::MqContextC::ConfigSetConfigFile" , NS(MqContextC_ConfigSetConfigFile) },
3686 { "::MqContextC::ConfigSetDaemon" , NS(MqContextC_ConfigSetDaemon) },
3687 { "::MqContextC::ConfigSetEvent" , NS(MqContextC_ConfigSetEvent) },
3688 { "::MqContextC::ConfigSetIdentFrom" , NS(MqContextC_ConfigSetIdentFrom) },
3689 { "::MqContextC::ConfigSetIgnoreExit" , NS(MqContextC_ConfigSetIgnoreExit) },
3690 { "::MqContextC::ConfigSetIoPipe" , NS(MqContextC_ConfigSetIoPipe) },
3691 { "::MqContextC::ConfigSetIoTcp" , NS(MqContextC_ConfigSetIoTcp) },
3692 { "::MqContextC::ConfigSetIoTcpL" , NS(MqContextC_ConfigSetIoTcpL) },
3693 { "::MqContextC::ConfigSetIoUds" , NS(MqContextC_ConfigSetIoUds) },
3694 { "::MqContextC::ConfigSetIsServer" , NS(MqContextC_ConfigSetIsServer) },
3695 { "::MqContextC::ConfigSetIsString" , NS(MqContextC_ConfigSetIsString) },
3696 { "::MqContextC::ConfigSetName" , NS(MqContextC_ConfigSetName) },
3697 { "::MqContextC::ConfigSetPkgsize" , NS(MqContextC_ConfigSetPkgsize) },
3698 { "::MqContextC::ConfigSetPostfix" , NS(MqContextC_ConfigSetPostfix) },
3699 { "::MqContextC::ConfigSetPrefix" , NS(MqContextC_ConfigSetPrefix) },
3700 { "::MqContextC::ConfigSetServerCleanup" , NS(MqContextC_ConfigSetServerCleanup) },
3701 { "::MqContextC::ConfigSetServerSetup" , NS(MqContextC_ConfigSetServerSetup) },
3702 { "::MqContextC::ConfigSetStartAs" , NS(MqContextC_ConfigSetStartAs) },
3703 { "::MqContextC::ConfigSetStartAsString" , NS(MqContextC_ConfigSetStartAsString) },
3704 { "::MqContextC::ConfigSetStorage" , NS(MqContextC_ConfigSetStorage) },
3705 { "::MqContextC::ConfigSetTimeout" , NS(MqContextC_ConfigSetTimeout) },
3706
3707 // doc-key: MqContextC,MqConfig,omo
3708 { "::MqContextC::ConfigGetIoTcp" , NS(MqContextC_ConfigGetIoTcp) },
3709
3710 // doc-key: MqContextC,MqContext,oC_
3711 { "::MqContextC::MqContextC" , NS(MqContextC_CTOR) },
3712
3713 // doc-key: MqContextC,MqContext,oc_
3714 { "::MqContextC::ErrorFORMAT" , NS(MqContextC_ErrorFORMAT) },
3715 { "::MqContextC::GetBuffer" , NS(MqContextC_GetBuffer) },
3716 { "::MqContextC::Next" , NS(MqContextC_Next) },
3717 { "::MqContextC::Prev" , NS(MqContextC_Prev) },
3718
3719 // doc-key: MqContextC,MqContext,om_
3720 { "::MqContextC::ErrorCopy" , NS(MqContextC_ErrorCopy) },
3721 { "::MqContextC::ErrorMove" , NS(MqContextC_ErrorMove) },
3722 // skip class-overload: HandleGet → MkObjectHandleGet
3723 // skip class-overload: Log → MkObjectLog
3724 { "::MqContextC::LogConfig" , NS(MqContextC_LogConfig) },
3725 { "::MqContextC::LogEnv" , NS(MqContextC_LogEnv) },
3726 { "::MqContextC::LogLink" , NS(MqContextC_LogLink) },
3727 { "::MqContextC::LogSetup" , NS(MqContextC_LogSetup) },
3728 { "::MqContextC::LogShort" , NS(MqContextC_LogShort) },
3729 { "::MqContextC::LogType" , NS(MqContextC_LogType) },
3730 // skip class-overload: ToString → MkObjectToString
3731
3732 // doc-key: MqContextC,MqEnv,om_
3733 { "::MqContextC::EnvProtect" , NS(MqContextC_EnvProtect) },
3734 { "::MqContextC::EnvRestore" , NS(MqContextC_EnvRestore) },
3735
3736 // doc-key: MqContextC,MqExit,om_
3737 { "::MqContextC::Exit" , NS(MqContextC_Exit) },
3738
3739 // doc-key: MqContextC,MqGet,oc_
3740 { "::MqContextC::GetRoot" , NS(MqContextC_GetRoot) },
3741
3742 // doc-key: MqContextC,MqLink,oc_
3743 { "::MqContextC::LinkGetParent" , NS(MqContextC_LinkGetParent) },
3744
3745 // doc-key: MqContextC,MqLink,om_
3746 { "::MqContextC::LinkConnect" , NS(MqContextC_LinkConnect) },
3747 { "::MqContextC::LinkCreate" , NS(MqContextC_LinkCreate) },
3748 { "::MqContextC::LinkCreateChild" , NS(MqContextC_LinkCreateChild) },
3749 { "::MqContextC::LinkDelete" , NS(MqContextC_LinkDelete) },
3750 { "::MqContextC::LinkGetCtxId" , NS(MqContextC_LinkGetCtxId) },
3751 { "::MqContextC::LinkGetTargetIdent" , NS(MqContextC_LinkGetTargetIdent) },
3752 { "::MqContextC::LinkIsConnected" , NS(MqContextC_LinkIsConnected) },
3753 { "::MqContextC::LinkIsParent" , NS(MqContextC_LinkIsParent) },
3754 { "::MqContextC::LinkShutdown" , NS(MqContextC_LinkShutdown) },
3755
3756 // doc-key: MqContextC,MqLog,om_
3757 { "::MqContextC::LogParentOrChild" , NS(MqContextC_LogParentOrChild) },
3758 { "::MqContextC::LogServerOrClient" , NS(MqContextC_LogServerOrClient) },
3759
3760 // doc-key: MqContextC,MqProcess,om_
3761 { "::MqContextC::ProcessEvent" , NS(MqContextC_ProcessEvent) },
3762
3763 // doc-key: MqContextC,MqProxy,om_
3764 { "::MqContextC::ProxyForward" , NS(MqContextC_ProxyForward) },
3765 { "::MqContextC::ProxyItem" , NS(MqContextC_ProxyItem) },
3766
3767 // doc-key: MqContextC,MqRead,oci
3768 { "::MqContextC::ReadALL" , NS(MqContextC_ReadALL) },
3769
3770 // doc-key: MqContextC,MqRead,oco
3771 { "::MqContextC::ReadBFL" , NS(MqContextC_ReadBFL) },
3772 { "::MqContextC::ReadBUF" , NS(MqContextC_ReadBUF) },
3773
3774 // doc-key: MqContextC,MqRead,om_
3775 { "::MqContextC::ReadDbg" , NS(MqContextC_ReadDbg) },
3776 { "::MqContextC::ReadGetNextType" , NS(MqContextC_ReadGetNextType) },
3777 { "::MqContextC::ReadGetNumItems" , NS(MqContextC_ReadGetNumItems) },
3778 { "::MqContextC::ReadItemExists" , NS(MqContextC_ReadItemExists) },
3779 { "::MqContextC::ReadL_END" , NS(MqContextC_ReadL_END) },
3780 { "::MqContextC::ReadL_START" , NS(MqContextC_ReadL_START) },
3781 { "::MqContextC::ReadT_END" , NS(MqContextC_ReadT_END) },
3782 { "::MqContextC::ReadT_START" , NS(MqContextC_ReadT_START) },
3783 { "::MqContextC::ReadUndo" , NS(MqContextC_ReadUndo) },
3784
3785 // doc-key: MqContextC,MqRead,omo
3786 { "::MqContextC::ReadBIN" , NS(MqContextC_ReadBIN) },
3787 { "::MqContextC::ReadBOL" , NS(MqContextC_ReadBOL) },
3788 { "::MqContextC::ReadBinaryR" , NS(MqContextC_ReadBinaryR) },
3789 { "::MqContextC::ReadDBL" , NS(MqContextC_ReadDBL) },
3790 { "::MqContextC::ReadFLT" , NS(MqContextC_ReadFLT) },
3791 { "::MqContextC::ReadHDL" , NS(MqContextC_ReadHDL) },
3792 { "::MqContextC::ReadI16" , NS(MqContextC_ReadI16) },
3793 { "::MqContextC::ReadI32" , NS(MqContextC_ReadI32) },
3794 { "::MqContextC::ReadI64" , NS(MqContextC_ReadI64) },
3795 { "::MqContextC::ReadI8" , NS(MqContextC_ReadI8) },
3796 { "::MqContextC::ReadLIST" , NS(MqContextC_ReadLIST) },
3797 { "::MqContextC::ReadLONG" , NS(MqContextC_ReadLONG) },
3798 { "::MqContextC::ReadNEXT" , NS(MqContextC_ReadNEXT) },
3799 { "::MqContextC::ReadSTR" , NS(MqContextC_ReadSTR) },
3800 { "::MqContextC::ReadStringR" , NS(MqContextC_ReadStringR) },
3801
3802 // doc-key: MqContextC,MqRoute,oco
3803 { "::MqContextC::RouteGetTree" , NS(MqContextC_RouteGetTree) },
3804
3805 // doc-key: MqContextC,MqRoute,om_
3806 { "::MqContextC::RouteCreate" , NS(MqContextC_RouteCreate) },
3807 { "::MqContextC::RouteDelete" , NS(MqContextC_RouteDelete) },
3808 { "::MqContextC::RouteResolve" , NS(MqContextC_RouteResolve) },
3809 { "::MqContextC::RouteTraverse" , NS(MqContextC_RouteTraverse) },
3810
3811 // doc-key: MqContextC,MqRoute,omo
3812 { "::MqContextC::RouteGetPath" , NS(MqContextC_RouteGetPath) },
3813
3814 // doc-key: MqContextC,MqSend,om_
3815 { "::MqContextC::Send" , NS(MqContextC_Send) },
3816 { "::MqContextC::SendBFL" , NS(MqContextC_SendBFL) },
3817 { "::MqContextC::SendBIN" , NS(MqContextC_SendBIN) },
3818 { "::MqContextC::SendBOL" , NS(MqContextC_SendBOL) },
3819 { "::MqContextC::SendBUF" , NS(MqContextC_SendBUF) },
3820 { "::MqContextC::SendBUS_FLAT" , NS(MqContextC_SendBUS_FLAT) },
3821 { "::MqContextC::SendBinaryR" , NS(MqContextC_SendBinaryR) },
3822 { "::MqContextC::SendDBL" , NS(MqContextC_SendDBL) },
3823 { "::MqContextC::SendEND" , NS(MqContextC_SendEND) },
3824 { "::MqContextC::SendEND_AND_CALLBACK" , NS(MqContextC_SendEND_AND_CALLBACK) },
3825 { "::MqContextC::SendEND_AND_SUB" , NS(MqContextC_SendEND_AND_SUB) },
3826 { "::MqContextC::SendEND_AND_TRANSACTION" , NS(MqContextC_SendEND_AND_TRANSACTION) },
3827 { "::MqContextC::SendEND_AND_WAIT" , NS(MqContextC_SendEND_AND_WAIT) },
3828 { "::MqContextC::SendERROR" , NS(MqContextC_SendERROR) },
3829 { "::MqContextC::SendFLT" , NS(MqContextC_SendFLT) },
3830 { "::MqContextC::SendHDL" , NS(MqContextC_SendHDL) },
3831 { "::MqContextC::SendI16" , NS(MqContextC_SendI16) },
3832 { "::MqContextC::SendI32" , NS(MqContextC_SendI32) },
3833 { "::MqContextC::SendI64" , NS(MqContextC_SendI64) },
3834 { "::MqContextC::SendI8" , NS(MqContextC_SendI8) },
3835 { "::MqContextC::SendLONG" , NS(MqContextC_SendLONG) },
3836 { "::MqContextC::SendLTR" , NS(MqContextC_SendLTR) },
3837 { "::MqContextC::SendL_END" , NS(MqContextC_SendL_END) },
3838 { "::MqContextC::SendL_FLAT" , NS(MqContextC_SendL_FLAT) },
3839 { "::MqContextC::SendL_START" , NS(MqContextC_SendL_START) },
3840 { "::MqContextC::SendRETURN" , NS(MqContextC_SendRETURN) },
3841 { "::MqContextC::SendRETURN_SUB" , NS(MqContextC_SendRETURN_SUB) },
3842 { "::MqContextC::SendSTART" , NS(MqContextC_SendSTART) },
3843 { "::MqContextC::SendSTR" , NS(MqContextC_SendSTR) },
3844 { "::MqContextC::SendSYNC" , NS(MqContextC_SendSYNC) },
3845 { "::MqContextC::SendStringR" , NS(MqContextC_SendStringR) },
3846 { "::MqContextC::SendT_END" , NS(MqContextC_SendT_END) },
3847 { "::MqContextC::SendT_START" , NS(MqContextC_SendT_START) },
3848
3849 // doc-key: MqContextC,MqService,om_
3850 { "::MqContextC::ServiceCreate" , NS(MqContextC_ServiceCreate) },
3851 { "::MqContextC::ServiceDelete" , NS(MqContextC_ServiceDelete) },
3852 { "::MqContextC::ServiceIsTransaction" , NS(MqContextC_ServiceIsTransaction) },
3853 { "::MqContextC::ServiceProxy" , NS(MqContextC_ServiceProxy) },
3854 { "::MqContextC::ServiceProxyCtx" , NS(MqContextC_ServiceProxyCtx) },
3855 { "::MqContextC::ServiceProxyCtxExists" , NS(MqContextC_ServiceProxyCtxExists) },
3856 { "::MqContextC::ServiceProxyRoundRobin" , NS(MqContextC_ServiceProxyRoundRobin) },
3857 { "::MqContextC::ServiceStorage" , NS(MqContextC_ServiceStorage) },
3858 { "::MqContextC::ServiceTokenCheck" , NS(MqContextC_ServiceTokenCheck) },
3859 { "::MqContextC::ServiceTokenExists" , NS(MqContextC_ServiceTokenExists) },
3860 { "::MqContextC::ServiceTokenGet" , NS(MqContextC_ServiceTokenGet) },
3861
3862 // doc-key: MqContextC,MqSlave,oc_
3863 { "::MqContextC::SlaveGetMaster" , NS(MqContextC_SlaveGetMaster) },
3864
3865 // doc-key: MqContextC,MqSlave,oco
3866 { "::MqContextC::SlaveGet" , NS(MqContextC_SlaveGet) },
3867 { "::MqContextC::SlaveGetFilter" , NS(MqContextC_SlaveGetFilter) },
3868 { "::MqContextC::SlaveGetProxy" , NS(MqContextC_SlaveGetProxy) },
3869
3870 // doc-key: MqContextC,MqSlave,om_
3871 { "::MqContextC::SlaveCheck" , NS(MqContextC_SlaveCheck) },
3872 { "::MqContextC::SlaveCreate" , NS(MqContextC_SlaveCreate) },
3873 { "::MqContextC::SlaveDelete" , NS(MqContextC_SlaveDelete) },
3874 { "::MqContextC::SlaveIs" , NS(MqContextC_SlaveIs) },
3875 { "::MqContextC::SlaveWorker" , NS(MqContextC_SlaveWorker) },
3876
3877 // doc-key: MqContextC,MqStorage,oci
3878 { "::MqContextC::StorageDelete" , NS(MqContextC_StorageDelete) },
3879 { "::MqContextC::StorageImport" , NS(MqContextC_StorageImport) },
3880
3881 // doc-key: MqContextC,MqStorage,om_
3882 { "::MqContextC::StorageClose" , NS(MqContextC_StorageClose) },
3883 { "::MqContextC::StorageDecrRef" , NS(MqContextC_StorageDecrRef) },
3884 { "::MqContextC::StorageIncrRef" , NS(MqContextC_StorageIncrRef) },
3885 { "::MqContextC::StorageLog" , NS(MqContextC_StorageLog) },
3886 { "::MqContextC::StorageOpen" , NS(MqContextC_StorageOpen) },
3887
3888 // doc-key: MqContextC,MqStorage,omo
3889 { "::MqContextC::StorageCount" , NS(MqContextC_StorageCount) },
3890 { "::MqContextC::StorageErrCnt" , NS(MqContextC_StorageErrCnt) },
3891 { "::MqContextC::StorageExport" , NS(MqContextC_StorageExport) },
3892 { "::MqContextC::StorageResolve" , NS(MqContextC_StorageResolve) },
3893
3894 // END-OBJ - created by 'atl_MqS.tcl -i NHI1_HOME/theLink/c/gen/c_mqmsgque.meta' - DO NOT change
3895 { NULL }
3896};
3897
3903
3904// vim: Marker(c)
3905MK_UNUSED static int NS(ProcessExit) ( MK_RT_ARGS MK_I32 num) {
3906 Tcl_Exit(num);
3907 return num;
3908}
3909
3910static int NS(ThreadExit) ( MK_RT_ARGS MK_I32 num) {
3911 return num;
3912}
3913
3914static enum MkErrorE NS(Idle) ( MQ_SERVICE_CALL_ARGS ) {
3915 Tcl_DoOneEvent(TCL_ALL_EVENTS|TCL_DONT_WAIT);
3916 return MK_OK;
3917}
3918
3919// MqWaitForPipeF
3920static bool NS(WaitForPipe) (MK_RT_ARGS MQ_CTX const ctx, const struct MkIdS *idP )
3921{
3922 bool retB = false;
3923 switch ((*idP).type) {
3924 case MK_ID_THREAD: {
3925 if ((*idP).setByExtern) {
3926 Tcl_ThreadId id = (Tcl_ThreadId) idP->val;
3927 int result;
3928 if (Tcl_JoinThread(id, &result) != TCL_OK) {
3929 MkErrorSetC_2M(ctx,"[ThreadError] join failed");
3930 }
3931 retB = true;
3932 }
3933 break;
3934 }
3935 case MK_ID_PROCESS:
3936 case MK_ID_UNUSED: break;
3937 }
3938 return retB;
3939}
3940
3941
3947
3949
3950static void NS(sMqContextC_Type) ( MK_RT_ARGS_ONLY )
3951{
3953 OT_MQ_RT_T amqrt = &amqrtR;
3954 assert(MqContextCTT == NULL);
3955
3956 // define type
3957
3958 MqContextCTT = MkTypeDup2(MqContextC_TT,"AtlMqContextC");
3959 MqContextCT->argvFix = true ;
3960 MqContextCT->MqProcessExitCB = NS(ProcessExit) ;
3961 MqContextCT->MqThreadExitCB = NS(ThreadExit) ;
3962 MqContextCT->MqWaitForPipeCB = NS(WaitForPipe) ;
3963 MqContextCT->Child.fCreate = MqLinkDefault_RT ;
3964 MqContextCT->Parent.fCreate = MqLinkDefault_RT ;
3965 MqContextCT->Idle.fCall = NS(Idle) ;
3966}
3967
3968int NS(pMqContextC_Init) ( OT_MQ_ARGS OT_NS_T ns )
3969{
3971
3972 // define type
3973 if (MqContextCTT == NULL) {
3974
3975 // register a new type
3976 MkRuntimeCallbackAdd( MK_RT_CALL &sAtlMqRuntimeCallback, NS(sMqContextC_Type) , "AtlMqContextC" );
3977
3978 // tcl does !not! support fork for a threaded interpreter
3979 if (Tcl_GetVar2Ex(interp,"tcl_platform","threaded",TCL_GLOBAL_ONLY) != NULL) {
3980 MqContextCT->ignoreFork = true;
3981 }
3982 }
3983
3984 ClassInit
3985
3986 return TCL_OK;
3987error:
3988 return TCL_ERROR;
3989}
#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 AtomMake(...)
#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)
#define OT_ERROR_LNG_RETURN
#define OT_CHECK_NI4(val)
#define OT_CHECK_NI8(val)
MOX_NS_T OT_NS_T
#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
MOX_OBJ_T OT_SELF_T
#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_MK_CALL
#define OT_CHECK_NI2(val)
#define OT_retObj_SET_STR(nat)
#define OT_CHECK_NB1(val)
#define OT_NEW_Mk_enum_OBJ(typ, val)
#define OT_CHECK_OPTIONAL(val)
#define OT_TMP_STR_OBJ(val)
#define OT_retObj_SET_ERR(nat)
#define OT_retObj_SET(val)
#define OT_CHECK_NOARGS
#define MkErrorC_Check(mng, PROC)
#define OT_ProcRet
#define CONSTR_ARGS
#define OT_CHECK_STRN(val)
MOX_OBJ_T OT_OBJ_T
__thread OT_MQ_RT_S amqrtR
#define OtClass_ARGS
#define MqContextCTT
#define SETUP_amqrt(r)
#define OT_TMP_CTX_OBJ(nat)
#define OT_NEW_Mq_enum_OBJ(typ, val)
#define OT_retObj_SET_CTX(nat)
#define NS(n)
#define OT_retObj_SET_FCT(nat)
#define MqContextC_ARGS
#define OT_MQ_ARGS
tag: nhi1-release-250425
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
static MK_UNUSED struct MkRuntimeCallbackS sAtlMqRuntimeCallback
#define ConfigGetIsString_doc
#define SendT_START_doc
#define LogType_doc
#define SendLONG_doc
#define StorageDelete_doc
#define SendBinaryR_doc
#define ServiceProxy_doc
#define OT_SETUP_hdl_static_constr
#define ConfigSetIgnoreExit_doc
#define ConfigSetBgError_doc
#define SendEND_AND_WAIT_doc
#define ClassOriginalIdentGet_doc
#define StorageClose_doc
#define ServiceProxyRoundRobin_doc
#define ConfigCheckStartAs_doc
#define RouteDelete_doc
#define ConfigSetName_doc
#define StorageIncrRef_doc
#define ConfigSetIdentFrom_doc
#define ClassFactoryGet_doc
#define SlaveWorker_doc
#define SendSTART_doc
#define ReadUndo_doc
#define ProxyForward_doc
#define 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
#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 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 OT_retObj_CONSTR(x)
#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 MkErrorSetC_2M(err, message)
#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)
MK_ID_THREAD
MK_ID_PROCESS
MK_ID_UNUSED
static MK_I32 MkRuntimeDebugGet(void)
size_t MkRuntimeCallbackAdd(MK_RT mkrt, MkRuntimeCallbackS *cbdata, MkRuntimeInitF rt_callback, MK_STRN ident)
#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
PUBLIC data structure for the atlmqmsgque-specific-data
MqDumpC - the class known as dmp or dump is used to export a atlmqmsgque data package as binary …
data used to define a factory