11#define META_FILE_NAME "MqContextC_atl.c"
15#define OT_CLASS amqrt->AtlMqContextC
16#define OT_NULL amqrt->AtlMqContextC_MK_NULL
17#define OT_CLASS_NAME "MqContextC"
19#define SELF2HDL(O) MqCtx(VAL2MNG(O))
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)
54#define OT_retObj_CONSTR(x) OT_retObj_SET(AtomInit(OT_SELF,MqContextC_X2obj(x),amqrt))
59 if (MqContextCTT == NULL) MqContextCTT = MqContextSTT; \
62 if (MqContextCTT->selfCreate == NS(MqContextC_selfCreate)) return MK_OK; \
65 MqContextCTT->selfCreate = NS(MqContextC_selfCreate); \
66 MqContextCTT->selfDelete = NS(MqContextC_selfDelete); \
67 MqContextCTT->selfUnlink = NS(MqContextC_selfUnlink); \
70 OT_CLASS = AltClassDef(MqContextCTT,&amqrt->AtlMqContextC_NS); \
71 if (OT_CLASS == NULL) goto error; \
72 OT_REF_INCR(OT_CLASS); \
75 check_LNG(AtlUnknownSetup (NS(sOtClassDef),amqrt)) goto error; \
78 check_LNG(AtlUnknownSetup (NS(sInstanceDef),amqrt)) goto error; \
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; \
86 OT_NULL = AtomCreateNULL(OT_CLASS, "::MqContextC::MK_NULL", (MK_PTR)amqrt); \
87 if (OT_NULL == NULL) goto error; \
91#include "mk_check_atl.h"
94#undef OT_CONSTRUCTOR_POST
96#define OT_CONSTRUCTOR_POST(x) if (MoxMyIsN(selfO)) MqConfigSetPrefixWithNoLock(x,VAL2STR(MoxCls__NAME__N(MoxMy__CLASS__N(selfO))));
102#define ClassFactoryGet_doc "MqFactoryC [MqContextC::ClassFactoryGet $ctx] (const)"
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)"
111#define ConfigGetIoTcpL_doc "MkBufferListC [MqContextC::ConfigGetIoTcpL $ctx]"
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"
158#define ConfigGetIoTcp_doc "{host:string port:string myhost:string myport:string} [MqContextC::ConfigGetIoTcp $ctx]"
161#define CTOR_doc "MqContextC [MqContextC::CTOR ?tmpl:MqContextC=NULL?]"
162#define Create_doc "MqContextC [MqContextC::Create ?tmpl:MqContextC=NULL?]"
165#define GetNull_doc "MqContextC [MqContextC::GetNull]"
166#define HandleResolve_doc "MqContextC [MqContextC::HandleResolve netHdl:MK_HDL]"
167#define Instances_doc "MqContextC [MqContextC::Instances]"
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]"
176#define ErrorCopy_doc "MkErrorE [MqContextC::ErrorCopy $targetCtx sourceCtx:MqContextC] (const)"
177#define ErrorMove_doc "MkErrorE [MqContextC::ErrorMove $targetCtx sourceCtx:MqContextC] (const)"
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)"
189#define EnvProtect_doc "MqContextC::EnvProtect $ctx"
190#define EnvRestore_doc "MqContextC::EnvRestore $ctx"
193#define Exit_doc "int32 [MqContextC::Exit $ctx ?callfunc:string=\"MK_NULL\"? ?callfile:string=\"MK_NULL\"? ?callline:int32=-1?]"
196#define GetRoot_doc "MqContextC [MqContextC::GetRoot $ctx]"
199#define LinkGetParent_doc "MqContextC [MqContextC::LinkGetParent $ctx]"
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"
213#define LogParentOrChild_doc "string [MqContextC::LogParentOrChild $ctx] (const)"
214#define LogServerOrClient_doc "string [MqContextC::LogServerOrClient $ctx] (const)"
217#define ProcessEvent_doc "MqContextC::ProcessEvent $ctx ?wait:MqWaitOnEventE=NO? ?timeout:MkTimeoutE|int32=DEFAULT?"
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"
224#define ReadALL_doc "MkBufferListC [MqContextC::ReadALL $ctx ?val_inout:MkBufferListC=NULL?]"
227#define ReadBFL_doc "MkBufferListC [MqContextC::ReadBFL $ctx]"
228#define ReadBUF_doc "MkBufferC [MqContextC::ReadBUF $ctx]"
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"
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]"
259#define RouteGetTree_doc "MkBufferListC [MqContextC::RouteGetTree $ctx]"
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?"
268#define RouteGetPath_doc "string [MqContextC::RouteGetPath $ctx]"
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"
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]"
319#define SlaveGetMaster_doc "MqContextC [MqContextC::SlaveGetMaster $ctx]"
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]"
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?"
334#define StorageDelete_doc "int32 [MqContextC::StorageDelete $ctx ?*transLIdP_inout:int32=0?]"
335#define StorageImport_doc "int32 [MqContextC::StorageImport $ctx ?*transLIdP_inout:int32=0?]"
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"
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]"
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
2440 for (
int i=0; i<retVal.
size; i++) {
3391 MQ_LTR transLIdP_inout = 0;
3407 MQ_LTR transLIdP_inout = 0;
3584 if (retVal == NULL) {
3605 if (retVal == NULL) {
3629 {
"::MqContextC::Create" ,
NS(MqContextC_Create) },
3632 {
"::MqContextC::GetNull" ,
NS(MqContextC_GetNull) },
3633 {
"::MqContextC::HandleResolve" ,
NS(MqContextC_HandleResolve) },
3634 {
"::MqContextC::Instances" ,
NS(MqContextC_Instances) },
3644 {
"::MqContextC::Debug" ,
NS(MqContextC_Debug) },
3645 {
"::MqContextC::printObj" ,
NS(MqContextC_printObj) },
3646 {
"::MqContextC::ConfigGetStartAsNum" ,
NS(MqContextC_ConfigGetStartAsNum) },
3647 {
"::MqContextC::ConfigGetStatusIsNum" ,
NS(MqContextC_ConfigGetStatusIsNum) },
3652 {
"::MqContextC::ClassFactoryGet" ,
NS(MqContextC_ClassFactoryGet) },
3655 {
"::MqContextC::ClassFactorySet" ,
NS(MqContextC_ClassFactorySet) },
3656 {
"::MqContextC::ClassIdentGet" ,
NS(MqContextC_ClassIdentGet) },
3657 {
"::MqContextC::ClassIdentSet" ,
NS(MqContextC_ClassIdentSet) },
3658 {
"::MqContextC::ClassOriginalIdentGet" ,
NS(MqContextC_ClassOriginalIdentGet) },
3661 {
"::MqContextC::ConfigGetIoTcpL" ,
NS(MqContextC_ConfigGetIoTcpL) },
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) },
3708 {
"::MqContextC::ConfigGetIoTcp" ,
NS(MqContextC_ConfigGetIoTcp) },
3711 {
"::MqContextC::MqContextC" ,
NS(MqContextC_CTOR) },
3714 {
"::MqContextC::ErrorFORMAT" ,
NS(MqContextC_ErrorFORMAT) },
3715 {
"::MqContextC::GetBuffer" ,
NS(MqContextC_GetBuffer) },
3716 {
"::MqContextC::Next" ,
NS(MqContextC_Next) },
3717 {
"::MqContextC::Prev" ,
NS(MqContextC_Prev) },
3720 {
"::MqContextC::ErrorCopy" ,
NS(MqContextC_ErrorCopy) },
3721 {
"::MqContextC::ErrorMove" ,
NS(MqContextC_ErrorMove) },
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) },
3733 {
"::MqContextC::EnvProtect" ,
NS(MqContextC_EnvProtect) },
3734 {
"::MqContextC::EnvRestore" ,
NS(MqContextC_EnvRestore) },
3737 {
"::MqContextC::Exit" ,
NS(MqContextC_Exit) },
3740 {
"::MqContextC::GetRoot" ,
NS(MqContextC_GetRoot) },
3743 {
"::MqContextC::LinkGetParent" ,
NS(MqContextC_LinkGetParent) },
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) },
3757 {
"::MqContextC::LogParentOrChild" ,
NS(MqContextC_LogParentOrChild) },
3758 {
"::MqContextC::LogServerOrClient" ,
NS(MqContextC_LogServerOrClient) },
3761 {
"::MqContextC::ProcessEvent" ,
NS(MqContextC_ProcessEvent) },
3764 {
"::MqContextC::ProxyForward" ,
NS(MqContextC_ProxyForward) },
3765 {
"::MqContextC::ProxyItem" ,
NS(MqContextC_ProxyItem) },
3768 {
"::MqContextC::ReadALL" ,
NS(MqContextC_ReadALL) },
3771 {
"::MqContextC::ReadBFL" ,
NS(MqContextC_ReadBFL) },
3772 {
"::MqContextC::ReadBUF" ,
NS(MqContextC_ReadBUF) },
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) },
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) },
3797 {
"::MqContextC::ReadLONG" ,
NS(MqContextC_ReadLONG) },
3799 {
"::MqContextC::ReadSTR" ,
NS(MqContextC_ReadSTR) },
3800 {
"::MqContextC::ReadStringR" ,
NS(MqContextC_ReadStringR) },
3803 {
"::MqContextC::RouteGetTree" ,
NS(MqContextC_RouteGetTree) },
3806 {
"::MqContextC::RouteCreate" ,
NS(MqContextC_RouteCreate) },
3807 {
"::MqContextC::RouteDelete" ,
NS(MqContextC_RouteDelete) },
3808 {
"::MqContextC::RouteResolve" ,
NS(MqContextC_RouteResolve) },
3809 {
"::MqContextC::RouteTraverse" ,
NS(MqContextC_RouteTraverse) },
3812 {
"::MqContextC::RouteGetPath" ,
NS(MqContextC_RouteGetPath) },
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) },
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) },
3863 {
"::MqContextC::SlaveGetMaster" ,
NS(MqContextC_SlaveGetMaster) },
3866 {
"::MqContextC::SlaveGet" ,
NS(MqContextC_SlaveGet) },
3867 {
"::MqContextC::SlaveGetFilter" ,
NS(MqContextC_SlaveGetFilter) },
3868 {
"::MqContextC::SlaveGetProxy" ,
NS(MqContextC_SlaveGetProxy) },
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) },
3878 {
"::MqContextC::StorageDelete" ,
NS(MqContextC_StorageDelete) },
3879 {
"::MqContextC::StorageImport" ,
NS(MqContextC_StorageImport) },
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) },
3889 {
"::MqContextC::StorageCount" ,
NS(MqContextC_StorageCount) },
3890 {
"::MqContextC::StorageErrCnt" ,
NS(MqContextC_StorageErrCnt) },
3891 {
"::MqContextC::StorageExport" ,
NS(MqContextC_StorageExport) },
3892 {
"::MqContextC::StorageResolve" ,
NS(MqContextC_StorageResolve) },
3915 Tcl_DoOneEvent(TCL_ALL_EVENTS|TCL_DONT_WAIT);
3923 switch ((*idP).type) {
3925 if ((*idP).setByExtern) {
3926 Tcl_ThreadId
id = (Tcl_ThreadId) idP->val;
3928 if (Tcl_JoinThread(
id, &result) != TCL_OK) {
3979 if (Tcl_GetVar2Ex(interp,
"tcl_platform",
"threaded",TCL_GLOBAL_ONLY) != NULL) {
#define OT_CHECK_NI1(val)
#define OT_CHECK_bool(val)
#define OT_retObj_SET_I8(nat)
#define OT_retObj_SET_FLT(nat)
#define OT_SETUP_VARARGS(min, max, d)
#define OT_CHECK_NIH(val)
#define OT_retObj_SET_BOL(nat)
#define OT_SETUP_NOARG(d)
#define OT_SETUP_ONEARG(d)
#define OT_ERROR_LNG_RETURN
#define OT_CHECK_NI4(val)
#define OT_CHECK_NI8(val)
#define OT_retObj_SET_I16(nat)
#define OT_retObj_SET_Error
#define OT_CHECK_NF8(val)
#define OT_CHECK_NIL(val)
#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_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_APPEND(var)
#define OT_CHECK__ME_REF_MkStringR(val)
#define OT_CHECK__ME_REF_MkBinaryR(val)
#define OT_CHECK_NI2(val)
#define OT_retObj_SET_STR(nat)
#define OT_CHECK_NB1(val)
#define OT_NEW_Mk_enum_OBJ(typ, val)
#define OT_CHECK_OPTIONAL(val)
#define OT_TMP_STR_OBJ(val)
#define OT_retObj_SET_ERR(nat)
#define OT_retObj_SET(val)
#define MkErrorC_Check(mng, PROC)
#define OT_CHECK_STRN(val)
__thread OT_MQ_RT_S amqrtR
#define OT_TMP_CTX_OBJ(nat)
#define OT_NEW_Mq_enum_OBJ(typ, val)
#define OT_retObj_SET_CTX(nat)
#define OT_retObj_SET_FCT(nat)
OT_ProcRet NS MqContextC_ReadLIST(MqContextC_ARGS)
OT_ProcRet NS MqContextC_ReadNEXT(MqContextC_ARGS)
#define ConfigGetStartAs_doc
#define ServiceTokenGet_doc
#define ConfigGetIoTcp_doc
#define ConfigGetName_doc
#define ConfigSetIoPipe_doc
static MK_UNUSED struct MkRuntimeCallbackS sAtlMqRuntimeCallback
#define ConfigGetIsString_doc
#define StorageDelete_doc
#define OT_SETUP_hdl_static_constr
#define ConfigSetIgnoreExit_doc
#define ConfigSetBgError_doc
#define SendEND_AND_WAIT_doc
#define ClassOriginalIdentGet_doc
#define ServiceProxyRoundRobin_doc
#define ConfigCheckStartAs_doc
#define ConfigSetName_doc
#define StorageIncrRef_doc
#define ConfigSetIdentFrom_doc
#define ClassFactoryGet_doc
#define OT_CONSTRUCTOR_POST(x)
#define ConfigSetAllTimeout_doc
#define ConfigGetStatusIs_doc
#define ConfigSetDaemon_doc
#define StorageDecrRef_doc
#define ConfigGetPrefix_doc
#define SlaveGetProxy_doc
#define ConfigSetAllDebug_doc
#define LinkCreateChild_doc
#define ConfigSetBuffersize_doc
#define ServiceStorage_doc
#define ConfigGetIdentFrom_doc
#define ServiceTokenCheck_doc
#define SlaveGetFilter_doc
#define ReadGetNextType_doc
#define ServiceDelete_doc
#define ConfigSetIsString_doc
#define ConfigSetTimeout_doc
#define LogParentOrChild_doc
#define ConfigSetPrefix_doc
#define LogServerOrClient_doc
#define ConfigSetIoTcp_doc
#define ConfigGetStorage_doc
#define ConfigSetServerCleanup_doc
#define ConfigGetTimeout_doc
#define ConfigGetPkgsize_doc
#define ConfigSetIoUds_doc
#define ConfigSetIsServer_doc
#define LinkIsConnected_doc
#define ConfigSetConfigFile_doc
#define ConfigSetServerSetup_doc
#define RouteTraverse_doc
#define ConfigSetStorage_doc
#define SendEND_AND_TRANSACTION_doc
#define ConfigGetBuffersize_doc
#define ConfigGetIoUds_doc
#define ReadGetNumItems_doc
#define ServiceTokenExists_doc
#define ServiceCreate_doc
#define HandleResolve_doc
#define StorageResolve_doc
#define ServiceProxyCtx_doc
#define ClassIdentSet_doc
#define ConfigSetStartAsString_doc
#define ConfigGetIsServer_doc
#define StorageImport_doc
#define SendRETURN_SUB_doc
#define OT_SETUP_hdl_static
#define OT_SETUP_hdl_constr
#define ConfigGetIoPipe_doc
#define StorageErrCnt_doc
#define ClassIdentGet_doc
#define SendEND_AND_CALLBACK_doc
#define ConfigSetIoTcpL_doc
#define ConfigSetPkgsize_doc
#define ServiceProxyCtxExists_doc
#define ClassFactorySet_doc
#define OT_SETUP_hdl__null_allow
#define SlaveGetMaster_doc
#define ConfigSetPostfix_doc
#define ServiceIsTransaction_doc
#define ConfigGetIsParent_doc
#define LinkGetParent_doc
#define StorageExport_doc
#define LinkGetTargetIdent_doc
#define ReadItemExists_doc
#define OT_retObj_CONSTR(x)
#define ConfigSetEvent_doc
#define ConfigGetPostfix_doc
#define ConfigGetIoTcpL_doc
#define SendEND_AND_SUB_doc
#define ConfigSetStartAs_doc
#define MkBufferListCreateTLS_T(name, num)
#define MkErrorSetC_2M(err, message)
#define MkLogC_4X(x, message, debug, callfunc)
static bool MkSysStringIsNULL(MK_STRN str)
static MK_I32 MkRuntimeDebugGet(void)
size_t MkRuntimeCallbackAdd(MK_RT mkrt, MkRuntimeCallbackS *cbdata, MkRuntimeInitF rt_callback, MK_STRN ident)
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(...)
enum MkErrorE MqLinkDefault_RT(MK_RT mkrt, MQ_CTX const ctx, MK_BAC const args)
callback as wrapper for MqLinkCreate or MqLinkCreateChild with additional error-check code …
#define MqLinkShutdown(...)
#define MqLinkCreateChild(...)
bool MqLinkIsConnected(MQ_CTX const ctx)
is the context connected? …
static MK_NUM MqLinkGetCtxId(MQ_CTX const ctx)
get an identifier which is unique per parent-or-child-context …
#define MqLinkDelete(...)
#define MqLinkCreate(...)
static bool MqLinkIsParent(MQ_CTX const ctx)
is the context a parent-context? …
#define MqLinkConnect(...)
static MK_STRN MqLinkGetTargetIdent(MQ_CTX const ctx)
get the ident of the link-target …
static MQ_CTX MqLinkGetParent(MQ_CTX const ctx)
get the initial parent-context from a client/server link …
#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 MqContextGetBuffer(...)
static MQ_CTX MqGetRoot(MQ_CTX ctx)
get the Root (toplevel initial context)
#define MqProxyForward(...)
#define MqReadBinaryR(...)
#define MqReadStringR(...)
#define MqReadT_START(...)
#define MqReadL_START(...)
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 MqRouteDelete(...)
#define MqRouteTraverse(...)
#define MqRouteGetTree(...)
#define MqRouteCreate(...)
#define MqRouteGetPath(...)
#define MqRouteResolve(...)
#define MqSendStringR(...)
#define MqSendL_FLAT(...)
#define MqSendBUS_FLAT(...)
#define MqSendBinaryR(...)
#define MqSendEND_AND_TRANSACTION(...)
#define MqSendEND_AND_CALLBACK(...)
#define MqSendEND_AND_SUB(...)
#define MqSendEND_AND_WAIT(...)
#define MqSendL_START(...)
#define MqSendT_START(...)
#define MqSendRETURN_SUB(...)
#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 …
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
#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_INVALID_SIGNATURE
@ 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
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