MqContextC_py.c - 29 Oct 2024 - aotto1968. More...
#include "LibMqMsgque_private_py.h"
#include "tmpl/MqContextC_ReadNEXT_lng.h"
#include "tmpl/MqContextC_ReadLIST_lng.h"
Go to the source code of this file.
Macros | |
#define | META_FILE_NAME "MqContextC_py.c" |
#define | OT_CLASS (&NS(MqContextCR)) |
#define | OT_CLASS_NAME "MqContextC" |
#define | OT_LNG2META(O) |
#define | OT_retObj_CONSTR(mng) |
#define | OT_SETUP_hdl OT_SETUP_hdl_tmpl(MqContextC) |
#define | OT_SETUP_hdl__null_allow OT_SETUP_hdl_tmpl__null_allow(MqContextC) |
#define | OT_SETUP_hdl_constr |
#define | OT_SETUP_hdl_destr OT_SETUP_hdl_tmpl__null_allow(MqContextC) |
#define | OT_SETUP_hdl_static |
#define | OT_SETUP_hdl_static_constr OT_SETUP_hdl_static |
#define | SetupRtFromObj_X(hdl) |
#define | SetupRtFromObj_XN(hdl) |
#define | MqContextCTT MQ(MqMsgqueThreadState).MqContextCTT |
#define | ClassInit |
#define | META_CONTEXT_S hdl |
#define | ClassFactoryGet_doc "MqFactoryC ctx.ClassFactoryGet() (const)" |
#define | ClassFactorySet_doc "ctx.ClassFactorySet(item:MqFactoryC)" |
#define | ClassIdentGet_doc "string ctx.ClassIdentGet() (const)" |
#define | ClassIdentSet_doc "ctx.ClassIdentSet(ident:string)" |
#define | ClassOriginalIdentGet_doc "string ctx.ClassOriginalIdentGet() (const)" |
#define | ConfigGetIoTcpL_doc "MkBufferListC ctx.ConfigGetIoTcpL()" |
#define | ConfigCheckStartAs_doc "bool ctx.ConfigCheckStartAs(data:MqStartE)" |
#define | ConfigGetBuffersize_doc "int32 ctx.ConfigGetBuffersize() (const)" |
#define | ConfigGetIdentFrom_doc "MqIdentE ctx.ConfigGetIdentFrom()" |
#define | ConfigGetIoPipe_doc "int32 ctx.ConfigGetIoPipe()" |
#define | ConfigGetIoUds_doc "string ctx.ConfigGetIoUds() (const)" |
#define | ConfigGetIsParent_doc "bool ctx.ConfigGetIsParent()" |
#define | ConfigGetIsServer_doc "bool ctx.ConfigGetIsServer()" |
#define | ConfigGetIsString_doc "bool ctx.ConfigGetIsString()" |
#define | ConfigGetName_doc "string ctx.ConfigGetName() (const)" |
#define | ConfigGetPkgsize_doc "int32 ctx.ConfigGetPkgsize() (const)" |
#define | ConfigGetPostfix_doc "string ctx.ConfigGetPostfix() (const)" |
#define | ConfigGetPrefix_doc "string ctx.ConfigGetPrefix() (const)" |
#define | ConfigGetStartAs_doc "MqStartE ctx.ConfigGetStartAs()" |
#define | ConfigGetStatusIs_doc "MqStatusIsEF ctx.ConfigGetStatusIs()" |
#define | ConfigGetStorage_doc "string ctx.ConfigGetStorage() (const)" |
#define | ConfigGetTimeout_doc "MkTimeoutE|int32 ctx.ConfigGetTimeout() (const)" |
#define | ConfigReset_doc "ctx.ConfigReset()" |
#define | ConfigSetAllDebug_doc "ctx.ConfigSetAllDebug(data:int32)" |
#define | ConfigSetBgError_doc "ctx.ConfigSetBgError(?callback:callable=None?)" |
#define | ConfigSetBuffersize_doc "ctx.ConfigSetBuffersize(data:int32)" |
#define | ConfigSetConfigFile_doc "ctx.ConfigSetConfigFile(filename:string)" |
#define | ConfigSetDaemon_doc "ctx.ConfigSetDaemon(pidfile:string)" |
#define | ConfigSetEvent_doc "ctx.ConfigSetEvent(?callback:callable=None?)" |
#define | ConfigSetIdentFrom_doc "ctx.ConfigSetIdentFrom(data:MqIdentE)" |
#define | ConfigSetIgnoreExit_doc "ctx.ConfigSetIgnoreExit(data:bool)" |
#define | ConfigSetIoPipe_doc "ctx.ConfigSetIoPipe(fh:int32)" |
#define | ConfigSetIoTcp_doc "ctx.ConfigSetIoTcp(?host:string=\"None\"?, ?port:string=\"None\"?, ?myhost:string=\"None\"?, ?myport:string=\"None\"?)" |
#define | ConfigSetIoTcpL_doc "ctx.ConfigSetIoTcpL(vals:MkBufferListC)" |
#define | ConfigSetIoUds_doc "ctx.ConfigSetIoUds(file:string)" |
#define | ConfigSetIsServer_doc "ctx.ConfigSetIsServer(data:bool)" |
#define | ConfigSetIsString_doc "ctx.ConfigSetIsString(data:bool)" |
#define | ConfigSetName_doc "ctx.ConfigSetName(data:string)" |
#define | ConfigSetPkgsize_doc "ctx.ConfigSetPkgsize(data:int32)" |
#define | ConfigSetPostfix_doc "ctx.ConfigSetPostfix(data:string)" |
#define | ConfigSetPrefix_doc "ctx.ConfigSetPrefix(data:string)" |
#define | ConfigSetServerCleanup_doc "ctx.ConfigSetServerCleanup(?callback:callable=None?)" |
#define | ConfigSetServerSetup_doc "ctx.ConfigSetServerSetup(?callback:callable=None?)" |
#define | ConfigSetStartAs_doc "ctx.ConfigSetStartAs(data:MqStartE)" |
#define | ConfigSetStartAsString_doc "ctx.ConfigSetStartAsString(data:string)" |
#define | ConfigSetStorage_doc "ctx.ConfigSetStorage(data:string)" |
#define | ConfigSetTimeout_doc "ctx.ConfigSetTimeout(data:MkTimeoutE|int32)" |
#define | ConfigGetIoTcp_doc "{host:string port:string myhost:string myport:string} ctx.ConfigGetIoTcp()" |
#define | Create_doc "MqContextC MqContextC.Create(?tmpl:MqContextC=None?)" |
#define | new_doc "MqContextC MqContextC.new(?tmpl:MqContextC=None?)" |
#define | GetNull_doc "MqContextC MqContextC.GetNull()" |
#define | HandleResolve_doc "MqContextC MqContextC.HandleResolve(netHdl:MK_HDL)" |
#define | Instances_doc "MqContextC MqContextC.Instances()" |
#define | ErrorFORMAT_doc "MkErrorC fmtobj.ErrorFORMAT() (const)" |
#define | GetBuffer_doc "MkBufferC ctx.GetBuffer()" |
#define | Next_doc "MqContextC ctx.Next()" |
#define | Prev_doc "MqContextC ctx.Prev()" |
#define | ErrorCopy_doc "MkErrorE targetCtx.ErrorCopy(sourceCtx:MqContextC) (const)" |
#define | ErrorMove_doc "MkErrorE targetCtx.ErrorMove(sourceCtx:MqContextC) (const)" |
#define | HandleGet_doc "MK_HDL ctx.HandleGet()" |
#define | Log_doc "ctx.Log(?fmtobj:MkObjectC=None?, ?debug:int32=0?, ?callfunc:string=\"MK_NULL\"?, ?lvl:int32=0?) (const)" |
#define | LogConfig_doc "ctx.LogConfig(?fmtobj:MkObjectC=None?, ?debug:int32=0?, ?callfunc:string=\"MK_NULL\"?, ?lvl:int32=0?) (const)" |
#define | LogEnv_doc "ctx.LogEnv(?fmtobj:MkObjectC=None?, ?debug:int32=0?, ?callfunc:string=\"MK_NULL\"?, ?lvl:int32=0?) (const)" |
#define | LogLink_doc "ctx.LogLink(?fmtobj:MkObjectC=None?, ?debug:int32=0?, ?callfunc:string=\"MK_NULL\"?, ?lvl:int32=0?) (const)" |
#define | LogSetup_doc "ctx.LogSetup(?fmtobj:MkObjectC=None?, ?debug:int32=0?, ?callfunc:string=\"MK_NULL\"?, ?lvl:int32=0?) (const)" |
#define | LogShort_doc "ctx.LogShort(?fmtobj:MkObjectC=None?, ?debug:int32=0?, ?callfunc:string=\"MK_NULL\"?, ?lvl:int32=0?, ?label:string=\"None\"?) (const)" |
#define | LogType_doc "ctx.LogType(?fmtobj:MkObjectC=None?, ?debug:int32=0?, ?callfunc:string=\"MK_NULL\"?, ?lvl:int32=0?) (const)" |
#define | ToString_doc "string ctx.ToString() (const)" |
#define | EnvProtect_doc "ctx.EnvProtect()" |
#define | EnvRestore_doc "ctx.EnvRestore()" |
#define | Exit_doc "ctx.Exit(?callfunc:string=\"MK_NULL\"?, ?callfile:string=\"MK_NULL\"?, ?callline:int32=-1?)" |
#define | GetRoot_doc "MqContextC ctx.GetRoot()" |
#define | LinkGetParent_doc "MqContextC ctx.LinkGetParent()" |
#define | LinkConnect_doc "ctx.LinkConnect()" |
#define | LinkCreate_doc "ctx.LinkCreate(?args:MkBufferListC...=None?)" |
#define | LinkCreateChild_doc "ctx.LinkCreateChild(parent:MqContextC, ?args:MkBufferListC...=None?)" |
#define | LinkDelete_doc "ctx.LinkDelete()" |
#define | LinkGetCtxId_doc "int32 ctx.LinkGetCtxId()" |
#define | LinkGetTargetIdent_doc "string ctx.LinkGetTargetIdent()" |
#define | LinkIsConnected_doc "bool ctx.LinkIsConnected()" |
#define | LinkIsParent_doc "bool ctx.LinkIsParent()" |
#define | LinkShutdown_doc "ctx.LinkShutdown()" |
#define | LogParentOrChild_doc "string ctx.LogParentOrChild() (const)" |
#define | LogServerOrClient_doc "string ctx.LogServerOrClient() (const)" |
#define | ProcessEvent_doc "ctx.ProcessEvent(?wait:MqWaitOnEventE=NO?, ?timeout:MkTimeoutE|int32=DEFAULT?)" |
#define | ProxyForward_doc "sourceCtx.ProxyForward(targetCtx:MqContextC, ?dump:MqDumpC=None?, ?timeout:MkTimeoutE|int32=DEFAULT?)" |
#define | ProxyItem_doc "sourceCtx.ProxyItem(targetCtx:MqContextC)" |
#define | ReadALL_doc "MkBufferListC ctx.ReadALL(?val_inout:MkBufferListC=None?)" |
#define | ReadBFL_doc "MkBufferListC ctx.ReadBFL()" |
#define | ReadBUF_doc "MkBufferC ctx.ReadBUF()" |
#define | ReadDbg_doc "ctx.ReadDbg()" |
#define | ReadGetNextType_doc "MkTypeE ctx.ReadGetNextType()" |
#define | ReadGetNumItems_doc "int32 ctx.ReadGetNumItems()" |
#define | ReadItemExists_doc "bool ctx.ReadItemExists()" |
#define | ReadL_END_doc "ctx.ReadL_END()" |
#define | ReadL_START_doc "ctx.ReadL_START(?buf:MkBufferC=None?)" |
#define | ReadT_END_doc "ctx.ReadT_END()" |
#define | ReadT_START_doc "ctx.ReadT_START()" |
#define | ReadUndo_doc "ctx.ReadUndo()" |
#define | ReadBIN_doc "binary ctx.ReadBIN()" |
#define | ReadBOL_doc "bool ctx.ReadBOL()" |
#define | ReadBinaryR_doc "binary ctx.ReadBinaryR()" |
#define | ReadDBL_doc "double ctx.ReadDBL()" |
#define | ReadFLT_doc "float ctx.ReadFLT()" |
#define | ReadHDL_doc "MK_HDL ctx.ReadHDL()" |
#define | ReadI16_doc "int16 ctx.ReadI16()" |
#define | ReadI32_doc "int32 ctx.ReadI32()" |
#define | ReadI64_doc "int64 ctx.ReadI64()" |
#define | ReadI8_doc "int8 ctx.ReadI8()" |
#define | ReadLIST_doc "[list...] ctx.ReadLIST()" |
#define | ReadLONG_doc "long ctx.ReadLONG()" |
#define | ReadNEXT_doc "obj ctx.ReadNEXT()" |
#define | ReadSTR_doc "string ctx.ReadSTR()" |
#define | ReadStringR_doc "string ctx.ReadStringR()" |
#define | RouteGetTree_doc "MkBufferListC ctx.RouteGetTree()" |
#define | RouteCreate_doc "ctx.RouteCreate(route:string, service:string, ?overwrite:bool=false?)" |
#define | RouteDelete_doc "ctx.RouteDelete(route:string, service:string, ?overwrite:bool=false?)" |
#define | RouteResolve_doc "[MqContextC...] ctx.RouteResolve(ident:string, ?retnum:int32=-1?)" |
#define | RouteTraverse_doc "ctx.RouteTraverse(service:string, ?args:MkBufferListC...=None?)" |
#define | RouteGetPath_doc "string ctx.RouteGetPath()" |
#define | Send_doc "ctx.Send(cstr:string, args:args...)" |
#define | SendBFL_doc "ctx.SendBFL(val:MkBufferListC)" |
#define | SendBIN_doc "ctx.SendBIN(val:binary)" |
#define | SendBOL_doc "ctx.SendBOL(val:bool)" |
#define | SendBUF_doc "ctx.SendBUF(val:MkBufferC)" |
#define | SendBUS_FLAT_doc "ctx.SendBUS_FLAT(val:MkBufferStreamC)" |
#define | SendBinaryR_doc "ctx.SendBinaryR(val:binary)" |
#define | SendDBL_doc "ctx.SendDBL(val:double)" |
#define | SendEND_doc "ctx.SendEND(token:string[4], ?timeout:MkTimeoutE|int32=DEFAULT?)" |
#define | SendEND_AND_CALLBACK_doc "ctx.SendEND_AND_CALLBACK(token:string[4], callback:callable, ?timeout:MkTimeoutE|int32=DEFAULT?)" |
#define | SendEND_AND_SUB_doc "ctx.SendEND_AND_SUB(token:string[4], callback:callable, ?timeout:MkTimeoutE|int32=DEFAULT?)" |
#define | SendEND_AND_TRANSACTION_doc "ctx.SendEND_AND_TRANSACTION(token:string[4], callback:string[4], ?timeout:MkTimeoutE|int32=DEFAULT?)" |
#define | SendEND_AND_WAIT_doc "ctx.SendEND_AND_WAIT(token:string[4], ?timeout:MkTimeoutE|int32=DEFAULT?)" |
#define | SendERROR_doc "ctx.SendERROR()" |
#define | SendFLT_doc "ctx.SendFLT(val:float)" |
#define | SendHDL_doc "ctx.SendHDL(val:MK_HDL)" |
#define | SendI16_doc "ctx.SendI16(val:int16)" |
#define | SendI32_doc "ctx.SendI32(val:int32)" |
#define | SendI64_doc "ctx.SendI64(val:int64)" |
#define | SendI8_doc "ctx.SendI8(val:int8)" |
#define | SendLONG_doc "ctx.SendLONG(val:long)" |
#define | SendLTR_doc "ctx.SendLTR(transLId:int32)" |
#define | SendL_END_doc "ctx.SendL_END()" |
#define | SendL_FLAT_doc "ctx.SendL_FLAT(val:MkBufferListC)" |
#define | SendL_START_doc "ctx.SendL_START()" |
#define | SendRETURN_doc "ctx.SendRETURN()" |
#define | SendRETURN_SUB_doc "ctx.SendRETURN_SUB()" |
#define | SendSTART_doc "ctx.SendSTART()" |
#define | SendSTR_doc "ctx.SendSTR(val:string)" |
#define | SendSYNC_doc "ctx.SendSYNC()" |
#define | SendStringR_doc "ctx.SendStringR(val:string)" |
#define | SendT_END_doc "ctx.SendT_END()" |
#define | SendT_START_doc "ctx.SendT_START()" |
#define | ServiceCreate_doc "ctx.ServiceCreate(token:string[4], callback:callable)" |
#define | ServiceDelete_doc "ctx.ServiceDelete(token:string[4])" |
#define | ServiceIsTransaction_doc "bool ctx.ServiceIsTransaction()" |
#define | ServiceProxy_doc "ctx.ServiceProxy(token:string[4], ?id:MqSlaveE|int32=MQ_SLAVE_OTHER?)" |
#define | ServiceProxyCtx_doc "ctx.ServiceProxyCtx(token:string[4], target:MqContextC)" |
#define | ServiceProxyCtxExists_doc "bool ctx.ServiceProxyCtxExists(token:string[4], target:MqContextC)" |
#define | ServiceProxyRoundRobin_doc "ctx.ServiceProxyRoundRobin(token:string[4], ident:string)" |
#define | ServiceStorage_doc "ctx.ServiceStorage(token:string[4])" |
#define | ServiceTokenCheck_doc "bool ctx.ServiceTokenCheck(token:string[4])" |
#define | ServiceTokenExists_doc "bool ctx.ServiceTokenExists(token:string[4])" |
#define | ServiceTokenGet_doc "string[4] ctx.ServiceTokenGet()" |
#define | SlaveGetMaster_doc "MqContextC ctx.SlaveGetMaster()" |
#define | SlaveGet_doc "MqContextC ctx.SlaveGet(id:MqSlaveE|int32)" |
#define | SlaveGetFilter_doc "MqContextC ctx.SlaveGetFilter()" |
#define | SlaveGetProxy_doc "MqContextC ctx.SlaveGetProxy(id:MqSlaveE|int32)" |
#define | SlaveCheck_doc "bool ctx.SlaveCheck(id:MqSlaveE|int32) (const)" |
#define | SlaveCreate_doc "ctx.SlaveCreate(id:MqSlaveE|int32, slave:MqContextC)" |
#define | SlaveDelete_doc "ctx.SlaveDelete(id:MqSlaveE|int32)" |
#define | SlaveIs_doc "bool ctx.SlaveIs() (const)" |
#define | SlaveWorker_doc "ctx.SlaveWorker(id:MqSlaveE|int32, ?fct:string=\"WORKER\"?, ?args:MkBufferListC...=None?)" |
#define | StorageDelete_doc "int32 ctx.StorageDelete(?*transLIdP_inout:int32=0?)" |
#define | StorageImport_doc "int32 ctx.StorageImport(?*transLIdP_inout:int32=0?)" |
#define | StorageClose_doc "ctx.StorageClose()" |
#define | StorageDecrRef_doc "ctx.StorageDecrRef(transLId:int32)" |
#define | StorageIncrRef_doc "ctx.StorageIncrRef(transLId:int32)" |
#define | StorageLog_doc "ctx.StorageLog(?callfunc:string=\"MK_NULL\"?)" |
#define | StorageOpen_doc "ctx.StorageOpen(storageFile:string)" |
#define | StorageCount_doc "int32 ctx.StorageCount()" |
#define | StorageErrCnt_doc "int32 ctx.StorageErrCnt(transLId:int32)" |
#define | StorageExport_doc "int32 ctx.StorageExport()" |
#define | StorageResolve_doc "{otherCtxP:MqContextC otherLIdP:int32} ctx.StorageResolve()" |
#define | Send_doc Send_doc_extra |
#define | Debug_doc "None ctx.Debug(prefix:str, obj=self:object)" |
#define | MqContextC_Doc "The msgque project is an infrastructure to link software together to\n\act like a single software. To link mean distributing work from one\n\software to an other software an wait or not wait for an answer. The\n\linking is done using unix or inet domain sockets and is based on\n\packages send from one software to an other software and back. The\n\tclmsgque project is used to handle all the different aspects for setup\n\and maintain the link and is responsible for:\n\\n\o starting and stopping the server application\n\o starting and stopping the communication interface\n\o sending and receiving package data\n\o reading and writing data from or into a package\n\o setup and maintain the event-handling for an asynchronous transfer\n\o propagate the error messages from the server to the client" |
Functions | |
OT_LNG_T | py_mqmsgque_MqContextC_CTOR (MK_RT mkrt, OT_LNG_CLASS_T type, MQ_CTX hdl) |
static MK_PTR | py_mqmsgque_MqContextC_selfCreate (MK_RT mkrt, MK_OBJ const obj, MK_PTR const env) |
static void | py_mqmsgque_MqContextC_selfDelete (MK_RT mkrt, MK_PTR self, MK_PTR const env) |
static void | py_mqmsgque_MqContextC_selfUnlink (MK_RT mkrt, MK_PTR self, MK_PTR const env) |
PyObject * | py_mqmsgque_MqContextC_ReadNEXT (MqContextC_ARGS) |
Python: → C-API get the next argument as native object … | |
PyObject * | py_mqmsgque_MqContextC_ReadLIST (MqContextC_ARGS) |
Python: → C-API get all arguments as native list … | |
static PyObject * | py_mqmsgque_MqContextC_Debug (MqContextC_ARGS) |
static PyObject * | py_mqmsgque_MqContextC_Debug2 (MqContextC_ARGS) |
static OT_ProcRet | py_mqmsgque_MqContextC_HandleResolve (OtClass_ARGS) |
Python: → C-API Handle-Resolve-Slot - return a MqContextC from netHdl or None if invalid… | |
static OT_ProcRet | py_mqmsgque_MqContextC_Next (MqContextC_ARGS) |
Python: → C-API get next instance from linked-list of MqContextS type | |
static OT_ProcRet | py_mqmsgque_MqContextC_Prev (MqContextC_ARGS) |
Python: → C-API get previous instance from linked-list of MqContextS type | |
static OT_ProcRet | py_mqmsgque_MqContextC_Instances (OtClass_ARGS) |
Python: → C-API get head-instance from linked-list of MqContextS type … | |
static OT_ProcRet | py_mqmsgque_MqContextC_GetNull (OtClass_ARGS) |
Python: → C-API Null-Slot - return a MqContextC typed NULL instance … | |
static OT_ProcRet | py_mqmsgque_MqContextC_ClassFactoryGet (MqContextC_ARGS) |
Python: → C-API get the MqFactoryC used by the MqContextC | |
static OT_ProcRet | py_mqmsgque_MqContextC_ClassFactorySet (MqContextC_ARGS) |
Python: → C-API link the MqContextC to a new MqFactoryC | |
static OT_ProcRet | py_mqmsgque_MqContextC_ClassIdentGet (MqContextC_ARGS) |
Python: → C-API get the application-identification … | |
static OT_ProcRet | py_mqmsgque_MqContextC_ClassIdentSet (MqContextC_ARGS) |
Python: → C-API link the MqContextC to a new MqFactoryC identified by ident | |
static OT_ProcRet | py_mqmsgque_MqContextC_ClassOriginalIdentGet (MqContextC_ARGS) |
Python: → C-API get the MqFactoryS::originalIdent from the MqContextC | |
static OT_ProcRet | py_mqmsgque_MqContextC_ConfigGetIoTcpL (MqContextC_ARGS) |
Python: → C-API get the configuration-data of the tcp-client-server-link as MkBufferListC … | |
static OT_ProcRet | py_mqmsgque_MqContextC_ConfigGetBuffersize (MqContextC_ARGS) |
Python: → C-API get the minimum of the read/send buffersize of the socket | |
static OT_ProcRet | py_mqmsgque_MqContextC_ConfigGetIdentFrom (MqContextC_ARGS) |
Python: → C-API get the MqConfigS::identFrom | |
static OT_ProcRet | py_mqmsgque_MqContextC_ConfigGetIoPipe (MqContextC_ARGS) |
Python: → C-API return the MqIoPipeConfigS | |
static OT_ProcRet | py_mqmsgque_MqContextC_ConfigGetIoUds (MqContextC_ARGS) |
Python: → C-API return the MqIoUdsConfigS | |
static OT_ProcRet | py_mqmsgque_MqContextC_ConfigGetIsParent (MqContextC_ARGS) |
Python: → C-API does the context object is a parent ? An objext is a parent id the MqConfigS::parent attribute is None | |
static OT_ProcRet | py_mqmsgque_MqContextC_ConfigGetIsServer (MqContextC_ARGS) |
Python: → C-API does the context object is a server ? | |
static OT_ProcRet | py_mqmsgque_MqContextC_ConfigGetIsString (MqContextC_ARGS) |
Python: → C-API does the context object is using the string-mode ? | |
static OT_ProcRet | py_mqmsgque_MqContextC_ConfigGetName (MqContextC_ARGS) |
Python: → C-API get the name of the context object | |
static OT_ProcRet | py_mqmsgque_MqContextC_ConfigGetPkgsize (MqContextC_ARGS) |
Python: → C-API get the maximun size of a BDY package | |
static OT_ProcRet | py_mqmsgque_MqContextC_ConfigGetPostfix (MqContextC_ARGS) |
Python: → C-API get the MqConfigS::postfix | |
static OT_ProcRet | py_mqmsgque_MqContextC_ConfigGetPrefix (MqContextC_ARGS) |
Python: → C-API get the MqConfigS::prefix | |
static OT_ProcRet | py_mqmsgque_MqContextC_ConfigGetStartAs (MqContextC_ARGS) |
Python: → C-API return the MqConfigS::startAs value | |
static OT_ProcRet | py_mqmsgque_MqContextC_ConfigGetStatusIs (MqContextC_ARGS) |
Python: → C-API return the MqContextS::statusIs value | |
static OT_ProcRet | py_mqmsgque_MqContextC_ConfigGetStorage (MqContextC_ARGS) |
Python: → C-API get the storage of the context object | |
static OT_ProcRet | py_mqmsgque_MqContextC_ConfigGetTimeout (MqContextC_ARGS) |
Python: → C-API get the timeout value of the context object | |
static OT_ProcRet | py_mqmsgque_MqContextC_ConfigSetConfigFile (MqContextC_ARGS) |
Python: → C-API set the config-file and parse for well-known config-items | |
static OT_ProcRet | py_mqmsgque_MqContextC_ConfigGetIoTcp (MqContextC_ARGS) |
Python: → C-API get the configuration-data of the tcp-client-server-link … | |
static OT_ProcRet | py_mqmsgque_MqContextC_ConfigSetBgError (MqContextC_ARGS) |
Python: → C-API set the MqSetupS::BgError | |
static OT_ProcRet | py_mqmsgque_MqContextC_ConfigSetEvent (MqContextC_ARGS) |
Python: → C-API set the MqSetupS::Event | |
static OT_ProcRet | py_mqmsgque_MqContextC_ConfigSetServerCleanup (MqContextC_ARGS) |
Python: → C-API set the MqSetupS::ServerCleanup | |
static OT_ProcRet | py_mqmsgque_MqContextC_ConfigSetServerSetup (MqContextC_ARGS) |
Python: → C-API set the MqSetupS::ServerSetup | |
static OT_ProcRet | py_mqmsgque_MqContextC_ConfigReset (MqContextC_ARGS) |
Python: → C-API clean the MqContextS::config data | |
static OT_ProcRet | py_mqmsgque_MqContextC_ConfigCheckStartAs (MqContextC_ARGS) |
Python: → C-API check if MqConfigS::startAs can be set to data | |
static OT_ProcRet | py_mqmsgque_MqContextC_ConfigSetAllDebug (MqContextC_ARGS) |
Python: → C-API set the MkRuntimeS::debug value | |
static OT_ProcRet | py_mqmsgque_MqContextC_ConfigSetBuffersize (MqContextC_ARGS) |
Python: → C-API set the MqIoConfigS::buffersize value | |
static OT_ProcRet | py_mqmsgque_MqContextC_ConfigSetDaemon (MqContextC_ARGS) |
Python: → C-API start the server-context as daemon … | |
static OT_ProcRet | py_mqmsgque_MqContextC_ConfigSetIdentFrom (MqContextC_ARGS) |
Python: → C-API set the MqConfigS::identFrom value | |
static OT_ProcRet | py_mqmsgque_MqContextC_ConfigSetIgnoreExit (MqContextC_ARGS) |
Python: → C-API set the MqSetupS::ignoreExit value | |
static OT_ProcRet | py_mqmsgque_MqContextC_ConfigSetIoPipe (MqContextC_ARGS) |
Python: → C-API set the pipe configuration data … | |
static OT_ProcRet | py_mqmsgque_MqContextC_ConfigSetIoTcp (MqContextC_ARGS) |
Python: → C-API configure a context to use a tcp-client-server-link … | |
static OT_ProcRet | py_mqmsgque_MqContextC_ConfigSetIoTcpL (MqContextC_ARGS) |
Python: → C-API configure a context to use a tcp-client-server-link … | |
static OT_ProcRet | py_mqmsgque_MqContextC_ConfigSetIoUds (MqContextC_ARGS) |
Python: → C-API configure a context to use a uds-client-server-link … | |
static OT_ProcRet | py_mqmsgque_MqContextC_ConfigSetIsServer (MqContextC_ARGS) |
Python: → C-API set the MqSetupS::isServer value | |
static OT_ProcRet | py_mqmsgque_MqContextC_ConfigSetIsString (MqContextC_ARGS) |
Python: → C-API set the MqConfigS::native value 'S'string or 'L'owEndian or 'B'igEndian | |
static OT_ProcRet | py_mqmsgque_MqContextC_ConfigSetName (MqContextC_ARGS) |
Python: → C-API set the MqConfigS::dispname value and cleanup old value | |
static OT_ProcRet | py_mqmsgque_MqContextC_ConfigSetPkgsize (MqContextC_ARGS) |
Python: → C-API set the MqIoConfigS::pkgsize value | |
static OT_ProcRet | py_mqmsgque_MqContextC_ConfigSetPostfix (MqContextC_ARGS) |
Python: → C-API set the client-part (2) of the application-identifer MqConfigS::dispname … | |
static OT_ProcRet | py_mqmsgque_MqContextC_ConfigSetPrefix (MqContextC_ARGS) |
Python: → C-API set the server-part (1) of the application-identifer MqConfigS::dispname … | |
static OT_ProcRet | py_mqmsgque_MqContextC_ConfigSetStartAs (MqContextC_ARGS) |
Python: → C-API set the MqConfigS::startAs value | |
static OT_ProcRet | py_mqmsgque_MqContextC_ConfigSetStartAsString (MqContextC_ARGS) |
Python: → C-API set the MqConfigS::startAs value using string default , thread , fork or spawn | |
static OT_ProcRet | py_mqmsgque_MqContextC_ConfigSetStorage (MqContextC_ARGS) |
Python: → C-API set the Storage value and cleanup old value | |
static OT_ProcRet | py_mqmsgque_MqContextC_ConfigSetTimeout (MqContextC_ARGS) |
Python: → C-API set the MqIoConfigS::timeout value | |
static OT_ProcRet | py_mqmsgque_MqContextC_EnvProtect (MqContextC_ARGS) |
Python: → C-API protect the service-environment | |
static OT_ProcRet | py_mqmsgque_MqContextC_EnvRestore (MqContextC_ARGS) |
Python: → C-API restore the service-environment | |
static OT_ProcRet | py_mqmsgque_MqContextC_ErrorFORMAT (MqContextC_ARGS) |
Python: → C-API helper used to access MkErrorDEFAULT from MqContextC | |
OT_ProcRet | py_mqmsgque_MqContextC_ErrorCopy (MqContextC_ARGS) |
Python: → C-API copy a MkErrorS from the sourceCtx to the targetCtx … | |
OT_ProcRet | py_mqmsgque_MqContextC_ErrorMove (MqContextC_ARGS) |
Python: → C-API move a MkErrorS from the sourceCtx to the targetCtx … | |
OT_ProcRet | py_mqmsgque_MqContextC_Send (MqContextC_ARGS) |
Python: → C-API user friendly replacement for the MqContextC_SendApi_C_API … | |
static OT_ProcRet | py_mqmsgque_MqContextC_LinkGetParent (MqContextC_ARGS) |
Python: → C-API get the initial parent-context from a client/server link … | |
static OT_ProcRet | py_mqmsgque_MqContextC_LinkConnect (MqContextC_ARGS) |
Python: → C-API re-connect a client-server-link after a server crash or a network downtime … | |
static OT_ProcRet | py_mqmsgque_MqContextC_LinkCreate (MqContextC_ARGS) |
Python: → C-API make ctx to a parent-context and setup a new client-server-link … | |
static OT_ProcRet | py_mqmsgque_MqContextC_LinkCreateChild (MqContextC_ARGS) |
Python: → C-API make a context to a child-context on-top of an existing parent-client-server-link … | |
static OT_ProcRet | py_mqmsgque_MqContextC_LinkDelete (MqContextC_ARGS) |
Python: → C-API close the client-server-link … | |
static OT_ProcRet | py_mqmsgque_MqContextC_LinkGetCtxId (MqContextC_ARGS) |
Python: → C-API get an identifier which is unique per parent-or-child-context … | |
static OT_ProcRet | py_mqmsgque_MqContextC_LinkGetTargetIdent (MqContextC_ARGS) |
Python: → C-API get the ident of the link-target … | |
static OT_ProcRet | py_mqmsgque_MqContextC_LinkIsConnected (MqContextC_ARGS) |
Python: → C-API is the context connected? … | |
static OT_ProcRet | py_mqmsgque_MqContextC_LinkIsParent (MqContextC_ARGS) |
Python: → C-API is the context a parent-context? … | |
static OT_ProcRet | py_mqmsgque_MqContextC_LinkShutdown (MqContextC_ARGS) |
Python: → C-API shutdown the communication with a server | |
static OT_ProcRet | py_mqmsgque_MqContextC_LogConfig (MqContextC_ARGS) |
Python: → C-API log the MqContextC part MqConfigS … | |
static OT_ProcRet | py_mqmsgque_MqContextC_LogEnv (MqContextC_ARGS) |
Python: → C-API log the MqContextC part MqEnvS … | |
static OT_ProcRet | py_mqmsgque_MqContextC_LogLink (MqContextC_ARGS) |
Python: → C-API log the MqContextC part MqLinkS … | |
static OT_ProcRet | py_mqmsgque_MqContextC_LogSetup (MqContextC_ARGS) |
Python: → C-API log the MqContextC part MqSetupS … | |
static OT_ProcRet | py_mqmsgque_MqContextC_LogShort (MqContextC_ARGS) |
Python: → C-API log the MqContextC with less info then MqContextLog … | |
static OT_ProcRet | py_mqmsgque_MqContextC_LogType (MqContextC_ARGS) |
Python: → C-API log the MqContextC part MkTypeS … | |
static OT_ProcRet | py_mqmsgque_MqContextC_LogParentOrChild (MqContextC_ARGS) |
Python: → C-API is ctx a PARENT or a CHILD ? … | |
static OT_ProcRet | py_mqmsgque_MqContextC_LogServerOrClient (MqContextC_ARGS) |
Python: → C-API is ctx a SERVER or a CLIENT ? … | |
static OT_ProcRet | py_mqmsgque_MqContextC_GetBuffer (MqContextC_ARGS) |
Python: → C-API get the MqContextS::ctxbuf object | |
static OT_ProcRet | py_mqmsgque_MqContextC_GetRoot (MqContextC_ARGS) |
Python: → C-API get the Root (toplevel initial context) | |
static OT_ProcRet | py_mqmsgque_MqContextC_Exit (MqContextC_ARGS) |
Python: → C-API delete the context and exit the current process or thread … | |
static OT_ProcRet | py_mqmsgque_MqContextC_ProcessEvent (MqContextC_ARGS) |
Python: → C-API enter the event-loop and wait for an incoming service-request. … | |
static OT_ProcRet | py_mqmsgque_MqContextC_ProxyForward (MqContextC_ARGS) |
Python: → C-API send the entire read-data-package-data to the link-target … | |
static OT_ProcRet | py_mqmsgque_MqContextC_ProxyItem (MqContextC_ARGS) |
Python: → C-API Copy a single-data-item from the sourceCtx to the targetCtx. | |
static OT_ProcRet | py_mqmsgque_MqContextC_ReadALL (MqContextC_ARGS) |
Python: → C-API get a temporary MkBufferListC from all data in the read-data-package … | |
static OT_ProcRet | py_mqmsgque_MqContextC_ReadBFL (MqContextC_ARGS) |
Python: → C-API get a temporary MkBufferListC from next list-item in the read-data-package … | |
static OT_ProcRet | py_mqmsgque_MqContextC_ReadBUF (MqContextC_ARGS) |
Python: → C-API get a temporary MkBufferC from the read-data-package … | |
static OT_ProcRet | py_mqmsgque_MqContextC_ReadBIN (MqContextC_ARGS) |
Python: doc_mq_py_ReadBIN → C-API generic function to read an MK_BIN object from the read-data-package object … | |
static OT_ProcRet | py_mqmsgque_MqContextC_ReadBOL (MqContextC_ARGS) |
Python: doc_mq_py_ReadBOL → C-API read a PRIMITIVE TYPE from the read-data-package … | |
static OT_ProcRet | py_mqmsgque_MqContextC_ReadBinaryR (MqContextC_ARGS) |
Python: → C-API read a MkBinaryR from the read-data-package … | |
static OT_ProcRet | py_mqmsgque_MqContextC_ReadDBL (MqContextC_ARGS) |
Python: doc_mq_py_ReadDBL → C-API read a PRIMITIVE TYPE from the read-data-package … | |
static OT_ProcRet | py_mqmsgque_MqContextC_ReadFLT (MqContextC_ARGS) |
Python: doc_mq_py_ReadFLT → C-API read a PRIMITIVE TYPE from the read-data-package … | |
static OT_ProcRet | py_mqmsgque_MqContextC_ReadHDL (MqContextC_ARGS) |
Python: → C-API read the handle from the read-data-package | |
static OT_ProcRet | py_mqmsgque_MqContextC_ReadI16 (MqContextC_ARGS) |
Python: doc_mq_py_ReadI16 → C-API read a PRIMITIVE TYPE from the read-data-package … | |
static OT_ProcRet | py_mqmsgque_MqContextC_ReadI32 (MqContextC_ARGS) |
Python: doc_mq_py_ReadI32 → C-API read a PRIMITIVE TYPE from the read-data-package … | |
static OT_ProcRet | py_mqmsgque_MqContextC_ReadI64 (MqContextC_ARGS) |
Python: doc_mq_py_ReadI64 → C-API read a PRIMITIVE TYPE from the read-data-package … | |
static OT_ProcRet | py_mqmsgque_MqContextC_ReadI8 (MqContextC_ARGS) |
Python: doc_mq_py_ReadI8 → C-API read a PRIMITIVE TYPE from the read-data-package … | |
static OT_ProcRet | py_mqmsgque_MqContextC_ReadLONG (MqContextC_ARGS) |
Python: → C-API read the long native object from the read-data-package | |
static OT_ProcRet | py_mqmsgque_MqContextC_ReadSTR (MqContextC_ARGS) |
Python: doc_mq_py_ReadSTR → C-API read a PRIMITIVE TYPE from the read-data-package … | |
static OT_ProcRet | py_mqmsgque_MqContextC_ReadStringR (MqContextC_ARGS) |
Python: → C-API read a MkStringR from the read-data-package … | |
static OT_ProcRet | py_mqmsgque_MqContextC_ReadL_END (MqContextC_ARGS) |
Python: → C-API finish to extract a list-items from the read-data-package. … | |
static OT_ProcRet | py_mqmsgque_MqContextC_ReadL_START (MqContextC_ARGS) |
Python: → C-API start to extract a list-items from the read-data-package. … | |
static OT_ProcRet | py_mqmsgque_MqContextC_ReadT_END (MqContextC_ARGS) |
Python: → C-API finish to extract a longterm-transaction-item from the read-data-package. … | |
static OT_ProcRet | py_mqmsgque_MqContextC_ReadT_START (MqContextC_ARGS) |
Python: → C-API start to extract a longterm-transaction-item from the read-data-package. … | |
static OT_ProcRet | py_mqmsgque_MqContextC_ReadDbg (MqContextC_ARGS) |
internal function: MqReadDbg | |
static OT_ProcRet | py_mqmsgque_MqContextC_ReadGetNextType (MqContextC_ARGS) |
Python: → C-API get the type (MkTypeE) of the next Item in the read-data-buffer or "0" if not available | |
static OT_ProcRet | py_mqmsgque_MqContextC_ReadGetNumItems (MqContextC_ARGS) |
Python: → C-API get the number of items left in the read-data-package … | |
static OT_ProcRet | py_mqmsgque_MqContextC_ReadItemExists (MqContextC_ARGS) |
Python: → C-API check if an item exists in the read-data-package … | |
static OT_ProcRet | py_mqmsgque_MqContextC_ReadUndo (MqContextC_ARGS) |
Python: → C-API undo the last MqContextC READ API function call … | |
static OT_ProcRet | py_mqmsgque_MqContextC_RouteGetTree (MqContextC_ARGS) |
Python: → C-API create an overview about all available routing-target and services … | |
static OT_ProcRet | py_mqmsgque_MqContextC_RouteCreate (MqContextC_ARGS) |
Python: → C-API create/delete a routing-link between context an a service using route | |
static OT_ProcRet | py_mqmsgque_MqContextC_RouteDelete (MqContextC_ARGS) |
Python: → C-API delete a routing-link created with MqRouteCreate | |
static OT_ProcRet | py_mqmsgque_MqContextC_RouteResolve (MqContextC_ARGS) |
Python: → C-API return a list of all context belonging to ident … | |
static OT_ProcRet | py_mqmsgque_MqContextC_RouteTraverse (MqContextC_ARGS) |
Python: → C-API traverse a tree down and call service if available. | |
static OT_ProcRet | py_mqmsgque_MqContextC_RouteGetPath (MqContextC_ARGS) |
Python: → C-API return the absolut route-connection-string up to the current ctx … | |
static OT_ProcRet | py_mqmsgque_MqContextC_SendBFL (MqContextC_ARGS) |
Python: → C-API append a MkBufferListC object to the send-data-package object … | |
static OT_ProcRet | py_mqmsgque_MqContextC_SendBIN (MqContextC_ARGS) |
Python: doc_mq_py_SendBIN → C-API append a MK_BIN object to the send-data-package. … | |
static OT_ProcRet | py_mqmsgque_MqContextC_SendBOL (MqContextC_ARGS) |
Python: doc_mq_py_SendBOL → C-API MqContextC - append a native PRIMITIVE TYPE value to the send-data-package … | |
static OT_ProcRet | py_mqmsgque_MqContextC_SendBUF (MqContextC_ARGS) |
Python: → C-API append a MkBufferC object to the send-data-package object … | |
static OT_ProcRet | py_mqmsgque_MqContextC_SendBUS_FLAT (MqContextC_ARGS) |
Python: → C-API append a MkBufferStreamC object to the send-data-package object … | |
static OT_ProcRet | py_mqmsgque_MqContextC_SendBinaryR (MqContextC_ARGS) |
Python: → C-API append a MkBinaryR object to the send-data-package. … | |
static OT_ProcRet | py_mqmsgque_MqContextC_SendDBL (MqContextC_ARGS) |
Python: doc_mq_py_SendDBL → C-API MqContextC - append a native PRIMITIVE TYPE value to the send-data-package … | |
static OT_ProcRet | py_mqmsgque_MqContextC_SendFLT (MqContextC_ARGS) |
Python: doc_mq_py_SendFLT → C-API MqContextC - append a native PRIMITIVE TYPE value to the send-data-package … | |
static OT_ProcRet | py_mqmsgque_MqContextC_SendHDL (MqContextC_ARGS) |
Python: → C-API send the handle to the send-data-package | |
static OT_ProcRet | py_mqmsgque_MqContextC_SendI16 (MqContextC_ARGS) |
Python: doc_mq_py_SendI16 → C-API MqContextC - append a native PRIMITIVE TYPE value to the send-data-package … | |
static OT_ProcRet | py_mqmsgque_MqContextC_SendI32 (MqContextC_ARGS) |
Python: doc_mq_py_SendI32 → C-API MqContextC - append a native PRIMITIVE TYPE value to the send-data-package … | |
static OT_ProcRet | py_mqmsgque_MqContextC_SendI64 (MqContextC_ARGS) |
Python: doc_mq_py_SendI64 → C-API MqContextC - append a native PRIMITIVE TYPE value to the send-data-package … | |
static OT_ProcRet | py_mqmsgque_MqContextC_SendI8 (MqContextC_ARGS) |
Python: doc_mq_py_SendI8 → C-API MqContextC - append a native PRIMITIVE TYPE value to the send-data-package … | |
static OT_ProcRet | py_mqmsgque_MqContextC_SendLONG (MqContextC_ARGS) |
Python: → C-API send the long native object to the send-data-package | |
static OT_ProcRet | py_mqmsgque_MqContextC_SendLTR (MqContextC_ARGS) |
internal function: MqSendLTR | |
static OT_ProcRet | py_mqmsgque_MqContextC_SendL_FLAT (MqContextC_ARGS) |
Python: → C-API append a MkBufferListC object as flat list of items to the send-data-package object … | |
static OT_ProcRet | py_mqmsgque_MqContextC_SendSTR (MqContextC_ARGS) |
Python: doc_mq_py_SendSTR → C-API MqContextC - append a native PRIMITIVE TYPE value to the send-data-package … | |
static OT_ProcRet | py_mqmsgque_MqContextC_SendStringR (MqContextC_ARGS) |
Python: → C-API MqContextC - append a native PRIMITIVE TYPE value to the send-data-package … | |
static OT_ProcRet | py_mqmsgque_MqContextC_SendEND (MqContextC_ARGS) |
Python: → C-API MqContextC - finish the send-data-block and call synchronous/asynchronous a remote-service … | |
static OT_ProcRet | py_mqmsgque_MqContextC_SendEND_AND_CALLBACK (MqContextC_ARGS) |
Python: → C-API finish the send-data-block, call the remote service, do not-wait for the result but expect the result on a callback … | |
static OT_ProcRet | py_mqmsgque_MqContextC_SendEND_AND_SUB (MqContextC_ARGS) |
Python: → C-API finish the send-data-block, call the remote service, do wait for the result and expect multiple sub-results on a callback … | |
static OT_ProcRet | py_mqmsgque_MqContextC_SendEND_AND_TRANSACTION (MqContextC_ARGS) |
Python: → C-API finish the send-data-block, call the remote service to do a longterm-transaction-call … | |
static OT_ProcRet | py_mqmsgque_MqContextC_SendEND_AND_WAIT (MqContextC_ARGS) |
Python: → C-API finish the send-data-block, call the remote service and wait for result… | |
static OT_ProcRet | py_mqmsgque_MqContextC_SendSTART (MqContextC_ARGS) |
Python: → C-API initialize the send-data-package. … | |
static OT_ProcRet | py_mqmsgque_MqContextC_SendSYNC (MqContextC_ARGS) |
Python: → C-API garantee that all pending asynchronous-service-calls are processed. … | |
static OT_ProcRet | py_mqmsgque_MqContextC_SendL_END (MqContextC_ARGS) |
Python: → C-API finish to append an embedded body-list-item to the send-data-package. … | |
static OT_ProcRet | py_mqmsgque_MqContextC_SendL_START (MqContextC_ARGS) |
Python: → C-API start to append an embedded body-list-item to the send-data-package. … | |
static OT_ProcRet | py_mqmsgque_MqContextC_SendT_END (MqContextC_ARGS) |
Python: → C-API closed a longterm-transaction-item … | |
static OT_ProcRet | py_mqmsgque_MqContextC_SendT_START (MqContextC_ARGS) |
Python: → C-API open a longterm-transaction-item … | |
static OT_ProcRet | py_mqmsgque_MqContextC_SendERROR (MqContextC_ARGS) |
Python: → C-API send the data from the MkErrorC to the link target . … | |
static OT_ProcRet | py_mqmsgque_MqContextC_SendRETURN (MqContextC_ARGS) |
Python: → C-API MqContextC - finish the send-data-block on the server and optional return the results. … | |
static OT_ProcRet | py_mqmsgque_MqContextC_SendRETURN_SUB (MqContextC_ARGS) |
Python: → C-API return Sub-Data-Blocks required by MqSendEND_AND_SUB … | |
static OT_ProcRet | py_mqmsgque_MqContextC_ServiceCreate (MqContextC_ARGS) |
Python: → C-API create a link between a service-token and a service-callback … | |
static OT_ProcRet | py_mqmsgque_MqContextC_ServiceDelete (MqContextC_ARGS) |
Python: → C-API delete a service. … | |
static OT_ProcRet | py_mqmsgque_MqContextC_ServiceIsTransaction (MqContextC_ARGS) |
Python: → C-API check if the ongoing-service-call belongs to a transaction … | |
static OT_ProcRet | py_mqmsgque_MqContextC_ServiceProxy (MqContextC_ARGS) |
Python: → C-API create a service to link a master-context with a slave-context. … | |
static OT_ProcRet | py_mqmsgque_MqContextC_ServiceProxyCtx (MqContextC_ARGS) |
Python: → C-API same as MqServiceProxy but use an MqContextC as input. | |
static OT_ProcRet | py_mqmsgque_MqContextC_ServiceProxyCtxExists (MqContextC_ARGS) |
Python: → C-API check if service who belongs to token is a proxy-service | |
static OT_ProcRet | py_mqmsgque_MqContextC_ServiceProxyRoundRobin (MqContextC_ARGS) |
Python: → C-API create a proxy-service using Round-Robin as load-balancer … | |
static OT_ProcRet | py_mqmsgque_MqContextC_ServiceStorage (MqContextC_ARGS) |
Python: → C-API setup a service listen on a MqContextC_ServiceApi_Identifer and save all read-data-package into the STORAGE … | |
static OT_ProcRet | py_mqmsgque_MqContextC_ServiceTokenCheck (MqContextC_ARGS) |
Python: → C-API in an ongoing-service-call check if the current MqContextC_ServiceApi_Identifer is token … | |
static OT_ProcRet | py_mqmsgque_MqContextC_ServiceTokenExists (MqContextC_ARGS) |
Python: → C-API check if the MqContextC_ServiceApi_Identifer token is defined as ctx service … | |
static OT_ProcRet | py_mqmsgque_MqContextC_ServiceTokenGet (MqContextC_ARGS) |
Python: → C-API in an ongoing-service-call get the current MqContextC_ServiceApi_Identifer … | |
static OT_ProcRet | py_mqmsgque_MqContextC_SlaveGetMaster (MqContextC_ARGS) |
Python: → C-API opposite function of MqSlaveGetFilter | |
static OT_ProcRet | py_mqmsgque_MqContextC_SlaveGet (MqContextC_ARGS) |
Python: → C-API get the slave-context from a master-context … | |
static OT_ProcRet | py_mqmsgque_MqContextC_SlaveGetFilter (MqContextC_ARGS) |
Python: → C-API get the filter-ctx or the master-ctx … | |
static OT_ProcRet | py_mqmsgque_MqContextC_SlaveGetProxy (MqContextC_ARGS) |
Python: → C-API on slave return the master and on master return the slave identified by id. | |
static OT_ProcRet | py_mqmsgque_MqContextC_SlaveCheck (MqContextC_ARGS) |
Python: → C-API check if slave-id is valid | |
static OT_ProcRet | py_mqmsgque_MqContextC_SlaveCreate (MqContextC_ARGS) |
Python: → C-API create a master/slave link between the master-parent-context and the slave-parent-context … | |
static OT_ProcRet | py_mqmsgque_MqContextC_SlaveDelete (MqContextC_ARGS) |
Python: → C-API Delete a slave object from a master/slave link identified by id. … | |
static OT_ProcRet | py_mqmsgque_MqContextC_SlaveIs (MqContextC_ARGS) |
Python: → C-API is the context a slave-context ? … | |
static OT_ProcRet | py_mqmsgque_MqContextC_SlaveWorker (MqContextC_ARGS) |
Python: → C-API create a master/slave link using the image of the ctx object self. … | |
static OT_ProcRet | py_mqmsgque_MqContextC_StorageDelete (MqContextC_ARGS) |
Python: → C-API delete the storage-row identified by the transLIdP_inout … | |
static OT_ProcRet | py_mqmsgque_MqContextC_StorageImport (MqContextC_ARGS) |
Python: → C-API import the storage-package into the read-data-package … | |
static OT_ProcRet | py_mqmsgque_MqContextC_StorageClose (MqContextC_ARGS) |
Python: → C-API close the storage. … | |
static OT_ProcRet | py_mqmsgque_MqContextC_StorageDecrRef (MqContextC_ARGS) |
Python: → C-API decrease the internal refCount lock of the database-entry | |
static OT_ProcRet | py_mqmsgque_MqContextC_StorageIncrRef (MqContextC_ARGS) |
Python: → C-API increase the internal refCount lock of the database-entry | |
static OT_ProcRet | py_mqmsgque_MqContextC_StorageLog (MqContextC_ARGS) |
Python: → C-API log the storage the status of the open transactions | |
static OT_ProcRet | py_mqmsgque_MqContextC_StorageOpen (MqContextC_ARGS) |
Python: → C-API switch to a file-based-transaction-database … | |
static OT_ProcRet | py_mqmsgque_MqContextC_StorageCount (MqContextC_ARGS) |
Python: → C-API count the number of storage-rows … | |
static OT_ProcRet | py_mqmsgque_MqContextC_StorageErrCnt (MqContextC_ARGS) |
Python: → C-API increment and return the database row-error-count for the row defined with transLId | |
static OT_ProcRet | py_mqmsgque_MqContextC_StorageExport (MqContextC_ARGS) |
Python: → C-API export the read-data-package into the STORAGE … | |
static OT_ProcRet | py_mqmsgque_MqContextC_StorageResolve (MqContextC_ARGS) |
Python: → C-API extract the context->link.protect.rmtTransLId entry from the database | |
static OT_ProcRet | py_mqmsgque_MqContextC_Create (OtClass_ARGS) |
Python: → C-API create and initialize the MqContextC ... | |
static OT_ProcRet | py_mqmsgque_MqContextC_new (CONSTR_ARGS) |
Python: → C-API create and initialize the MqContextC ... | |
static MK_UNUSED void | py_mqmsgque_sParentBeforeFork (MQ_CTX mqctx) |
static MK_UNUSED void | py_mqmsgque_sParentAfterFork (MQ_CTX mqctx) |
static MK_UNUSED void | py_mqmsgque_sChildAfterFork (MQ_CTX mqctx) |
static void | py_mqmsgque_sIncrSelf (MK_RT mkrt, MQ_CTX hdl, MK_PTR const env) |
static void | py_mqmsgque_sDecrSelf (MK_RT mkrt, MQ_CTX hdl, MK_PTR const env) |
static void | py_mqmsgque_sProcessExit (MK_RT mkrt, int num) |
static MK_UNUSED void | py_mqmsgque_sThreadExit (MK_RT mkrt, int num) |
static PyObject * | py_mqmsgque_sMqContextC_Str (MqContextC_Obj *self) |
static PyObject * | py_mqmsgque_sMqContextC_Repr (MqContextC_Obj *self) |
int | py_mqmsgque_pMqContextC_Init (MQ_RT_ARGS OT_LNG_T m) |
Variables | |
static PyMethodDef | py_mqmsgque_MqContextC_Methods [] |
OT_CLASS_TYPE_REF | py_mqmsgque_MqContextCR |
MqContextC_py.c - 29 Oct 2024 - aotto1968.
Definition in file MqContextC_py.c.
#define ClassFactoryGet_doc "MqFactoryC ctx.ClassFactoryGet() (const)" |
doc definition
Definition at line 130 of file MqContextC_py.c.
#define ClassFactorySet_doc "ctx.ClassFactorySet(item:MqFactoryC)" |
Definition at line 133 of file MqContextC_py.c.
#define ClassIdentGet_doc "string ctx.ClassIdentGet() (const)" |
Definition at line 134 of file MqContextC_py.c.
#define ClassIdentSet_doc "ctx.ClassIdentSet(ident:string)" |
Definition at line 135 of file MqContextC_py.c.
#define ClassInit |
Definition at line 68 of file MqContextC_py.c.
#define ClassOriginalIdentGet_doc "string ctx.ClassOriginalIdentGet() (const)" |
Definition at line 136 of file MqContextC_py.c.
#define ConfigCheckStartAs_doc "bool ctx.ConfigCheckStartAs(data:MqStartE)" |
Definition at line 142 of file MqContextC_py.c.
#define ConfigGetBuffersize_doc "int32 ctx.ConfigGetBuffersize() (const)" |
Definition at line 143 of file MqContextC_py.c.
#define ConfigGetIdentFrom_doc "MqIdentE ctx.ConfigGetIdentFrom()" |
Definition at line 144 of file MqContextC_py.c.
#define ConfigGetIoPipe_doc "int32 ctx.ConfigGetIoPipe()" |
Definition at line 145 of file MqContextC_py.c.
#define ConfigGetIoTcp_doc "{host:string port:string myhost:string myport:string} ctx.ConfigGetIoTcp()" |
Definition at line 185 of file MqContextC_py.c.
#define ConfigGetIoTcpL_doc "MkBufferListC ctx.ConfigGetIoTcpL()" |
Definition at line 139 of file MqContextC_py.c.
#define ConfigGetIoUds_doc "string ctx.ConfigGetIoUds() (const)" |
Definition at line 146 of file MqContextC_py.c.
#define ConfigGetIsParent_doc "bool ctx.ConfigGetIsParent()" |
Definition at line 147 of file MqContextC_py.c.
#define ConfigGetIsServer_doc "bool ctx.ConfigGetIsServer()" |
Definition at line 148 of file MqContextC_py.c.
#define ConfigGetIsString_doc "bool ctx.ConfigGetIsString()" |
Definition at line 149 of file MqContextC_py.c.
#define ConfigGetName_doc "string ctx.ConfigGetName() (const)" |
Definition at line 150 of file MqContextC_py.c.
#define ConfigGetPkgsize_doc "int32 ctx.ConfigGetPkgsize() (const)" |
Definition at line 151 of file MqContextC_py.c.
#define ConfigGetPostfix_doc "string ctx.ConfigGetPostfix() (const)" |
Definition at line 152 of file MqContextC_py.c.
#define ConfigGetPrefix_doc "string ctx.ConfigGetPrefix() (const)" |
Definition at line 153 of file MqContextC_py.c.
#define ConfigGetStartAs_doc "MqStartE ctx.ConfigGetStartAs()" |
Definition at line 154 of file MqContextC_py.c.
#define ConfigGetStatusIs_doc "MqStatusIsEF ctx.ConfigGetStatusIs()" |
Definition at line 155 of file MqContextC_py.c.
#define ConfigGetStorage_doc "string ctx.ConfigGetStorage() (const)" |
Definition at line 156 of file MqContextC_py.c.
#define ConfigGetTimeout_doc "MkTimeoutE|int32 ctx.ConfigGetTimeout() (const)" |
Definition at line 157 of file MqContextC_py.c.
#define ConfigReset_doc "ctx.ConfigReset()" |
Definition at line 158 of file MqContextC_py.c.
#define ConfigSetAllDebug_doc "ctx.ConfigSetAllDebug(data:int32)" |
Definition at line 159 of file MqContextC_py.c.
#define ConfigSetBgError_doc "ctx.ConfigSetBgError(?callback:callable=None?)" |
Definition at line 160 of file MqContextC_py.c.
#define ConfigSetBuffersize_doc "ctx.ConfigSetBuffersize(data:int32)" |
Definition at line 161 of file MqContextC_py.c.
#define ConfigSetConfigFile_doc "ctx.ConfigSetConfigFile(filename:string)" |
Definition at line 162 of file MqContextC_py.c.
#define ConfigSetDaemon_doc "ctx.ConfigSetDaemon(pidfile:string)" |
Definition at line 163 of file MqContextC_py.c.
#define ConfigSetEvent_doc "ctx.ConfigSetEvent(?callback:callable=None?)" |
Definition at line 164 of file MqContextC_py.c.
#define ConfigSetIdentFrom_doc "ctx.ConfigSetIdentFrom(data:MqIdentE)" |
Definition at line 165 of file MqContextC_py.c.
#define ConfigSetIgnoreExit_doc "ctx.ConfigSetIgnoreExit(data:bool)" |
Definition at line 166 of file MqContextC_py.c.
#define ConfigSetIoPipe_doc "ctx.ConfigSetIoPipe(fh:int32)" |
Definition at line 167 of file MqContextC_py.c.
#define ConfigSetIoTcp_doc "ctx.ConfigSetIoTcp(?host:string=\"None\"?, ?port:string=\"None\"?, ?myhost:string=\"None\"?, ?myport:string=\"None\"?)" |
Definition at line 168 of file MqContextC_py.c.
#define ConfigSetIoTcpL_doc "ctx.ConfigSetIoTcpL(vals:MkBufferListC)" |
Definition at line 169 of file MqContextC_py.c.
#define ConfigSetIoUds_doc "ctx.ConfigSetIoUds(file:string)" |
Definition at line 170 of file MqContextC_py.c.
#define ConfigSetIsServer_doc "ctx.ConfigSetIsServer(data:bool)" |
Definition at line 171 of file MqContextC_py.c.
#define ConfigSetIsString_doc "ctx.ConfigSetIsString(data:bool)" |
Definition at line 172 of file MqContextC_py.c.
#define ConfigSetName_doc "ctx.ConfigSetName(data:string)" |
Definition at line 173 of file MqContextC_py.c.
#define ConfigSetPkgsize_doc "ctx.ConfigSetPkgsize(data:int32)" |
Definition at line 174 of file MqContextC_py.c.
#define ConfigSetPostfix_doc "ctx.ConfigSetPostfix(data:string)" |
Definition at line 175 of file MqContextC_py.c.
#define ConfigSetPrefix_doc "ctx.ConfigSetPrefix(data:string)" |
Definition at line 176 of file MqContextC_py.c.
#define ConfigSetServerCleanup_doc "ctx.ConfigSetServerCleanup(?callback:callable=None?)" |
Definition at line 177 of file MqContextC_py.c.
#define ConfigSetServerSetup_doc "ctx.ConfigSetServerSetup(?callback:callable=None?)" |
Definition at line 178 of file MqContextC_py.c.
#define ConfigSetStartAs_doc "ctx.ConfigSetStartAs(data:MqStartE)" |
Definition at line 179 of file MqContextC_py.c.
#define ConfigSetStartAsString_doc "ctx.ConfigSetStartAsString(data:string)" |
Definition at line 180 of file MqContextC_py.c.
#define ConfigSetStorage_doc "ctx.ConfigSetStorage(data:string)" |
Definition at line 181 of file MqContextC_py.c.
#define ConfigSetTimeout_doc "ctx.ConfigSetTimeout(data:MkTimeoutE|int32)" |
Definition at line 182 of file MqContextC_py.c.
#define Create_doc "MqContextC MqContextC.Create(?tmpl:MqContextC=None?)" |
Definition at line 188 of file MqContextC_py.c.
#define Debug_doc "None ctx.Debug(prefix:str, obj=self:object)" |
Definition at line 382 of file MqContextC_py.c.
#define EnvProtect_doc "ctx.EnvProtect()" |
Definition at line 216 of file MqContextC_py.c.
#define EnvRestore_doc "ctx.EnvRestore()" |
Definition at line 217 of file MqContextC_py.c.
#define ErrorCopy_doc "MkErrorE targetCtx.ErrorCopy(sourceCtx:MqContextC) (const)" |
Definition at line 203 of file MqContextC_py.c.
#define ErrorFORMAT_doc "MkErrorC fmtobj.ErrorFORMAT() (const)" |
Definition at line 197 of file MqContextC_py.c.
#define ErrorMove_doc "MkErrorE targetCtx.ErrorMove(sourceCtx:MqContextC) (const)" |
Definition at line 204 of file MqContextC_py.c.
#define Exit_doc "ctx.Exit(?callfunc:string=\"MK_NULL\"?, ?callfile:string=\"MK_NULL\"?, ?callline:int32=-1?)" |
Definition at line 220 of file MqContextC_py.c.
#define GetBuffer_doc "MkBufferC ctx.GetBuffer()" |
Definition at line 198 of file MqContextC_py.c.
#define GetNull_doc "MqContextC MqContextC.GetNull()" |
Definition at line 192 of file MqContextC_py.c.
#define GetRoot_doc "MqContextC ctx.GetRoot()" |
Definition at line 223 of file MqContextC_py.c.
#define HandleGet_doc "MK_HDL ctx.HandleGet()" |
Definition at line 205 of file MqContextC_py.c.
#define HandleResolve_doc "MqContextC MqContextC.HandleResolve(netHdl:MK_HDL)" |
Definition at line 193 of file MqContextC_py.c.
#define Instances_doc "MqContextC MqContextC.Instances()" |
Definition at line 194 of file MqContextC_py.c.
#define LinkConnect_doc "ctx.LinkConnect()" |
Definition at line 229 of file MqContextC_py.c.
#define LinkCreate_doc "ctx.LinkCreate(?args:MkBufferListC...=None?)" |
Definition at line 230 of file MqContextC_py.c.
#define LinkCreateChild_doc "ctx.LinkCreateChild(parent:MqContextC, ?args:MkBufferListC...=None?)" |
Definition at line 231 of file MqContextC_py.c.
#define LinkDelete_doc "ctx.LinkDelete()" |
Definition at line 232 of file MqContextC_py.c.
#define LinkGetCtxId_doc "int32 ctx.LinkGetCtxId()" |
Definition at line 233 of file MqContextC_py.c.
#define LinkGetParent_doc "MqContextC ctx.LinkGetParent()" |
Definition at line 226 of file MqContextC_py.c.
#define LinkGetTargetIdent_doc "string ctx.LinkGetTargetIdent()" |
Definition at line 234 of file MqContextC_py.c.
#define LinkIsConnected_doc "bool ctx.LinkIsConnected()" |
Definition at line 235 of file MqContextC_py.c.
#define LinkIsParent_doc "bool ctx.LinkIsParent()" |
Definition at line 236 of file MqContextC_py.c.
#define LinkShutdown_doc "ctx.LinkShutdown()" |
Definition at line 237 of file MqContextC_py.c.
#define Log_doc "ctx.Log(?fmtobj:MkObjectC=None?, ?debug:int32=0?, ?callfunc:string=\"MK_NULL\"?, ?lvl:int32=0?) (const)" |
Definition at line 206 of file MqContextC_py.c.
#define LogConfig_doc "ctx.LogConfig(?fmtobj:MkObjectC=None?, ?debug:int32=0?, ?callfunc:string=\"MK_NULL\"?, ?lvl:int32=0?) (const)" |
Definition at line 207 of file MqContextC_py.c.
#define LogEnv_doc "ctx.LogEnv(?fmtobj:MkObjectC=None?, ?debug:int32=0?, ?callfunc:string=\"MK_NULL\"?, ?lvl:int32=0?) (const)" |
Definition at line 208 of file MqContextC_py.c.
#define LogLink_doc "ctx.LogLink(?fmtobj:MkObjectC=None?, ?debug:int32=0?, ?callfunc:string=\"MK_NULL\"?, ?lvl:int32=0?) (const)" |
Definition at line 209 of file MqContextC_py.c.
#define LogParentOrChild_doc "string ctx.LogParentOrChild() (const)" |
Definition at line 240 of file MqContextC_py.c.
#define LogServerOrClient_doc "string ctx.LogServerOrClient() (const)" |
Definition at line 241 of file MqContextC_py.c.
#define LogSetup_doc "ctx.LogSetup(?fmtobj:MkObjectC=None?, ?debug:int32=0?, ?callfunc:string=\"MK_NULL\"?, ?lvl:int32=0?) (const)" |
Definition at line 210 of file MqContextC_py.c.
#define LogShort_doc "ctx.LogShort(?fmtobj:MkObjectC=None?, ?debug:int32=0?, ?callfunc:string=\"MK_NULL\"?, ?lvl:int32=0?, ?label:string=\"None\"?) (const)" |
Definition at line 211 of file MqContextC_py.c.
#define LogType_doc "ctx.LogType(?fmtobj:MkObjectC=None?, ?debug:int32=0?, ?callfunc:string=\"MK_NULL\"?, ?lvl:int32=0?) (const)" |
Definition at line 212 of file MqContextC_py.c.
#define META_CONTEXT_S hdl |
Definition at line 119 of file MqContextC_py.c.
#define META_FILE_NAME "MqContextC_py.c" |
Definition at line 14 of file MqContextC_py.c.
#define MqContextC_Doc "The msgque project is an infrastructure to link software together to\n\act like a single software. To link mean distributing work from one\n\software to an other software an wait or not wait for an answer. The\n\linking is done using unix or inet domain sockets and is based on\n\packages send from one software to an other software and back. The\n\tclmsgque project is used to handle all the different aspects for setup\n\and maintain the link and is responsible for:\n\\n\o starting and stopping the server application\n\o starting and stopping the communication interface\n\o sending and receiving package data\n\o reading and writing data from or into a package\n\o setup and maintain the event-handling for an asynchronous transfer\n\o propagate the error messages from the server to the client" |
Definition at line 3913 of file MqContextC_py.c.
#define MqContextCTT MQ(MqMsgqueThreadState).MqContextCTT |
Definition at line 43 of file MqContextC_py.c.
#define new_doc "MqContextC MqContextC.new(?tmpl:MqContextC=None?)" |
Definition at line 189 of file MqContextC_py.c.
#define Next_doc "MqContextC ctx.Next()" |
Definition at line 199 of file MqContextC_py.c.
#define OT_CLASS (&NS(MqContextCR)) |
Definition at line 19 of file MqContextC_py.c.
#define OT_CLASS_NAME "MqContextC" |
Definition at line 20 of file MqContextC_py.c.
#define OT_LNG2META | ( | O | ) |
Definition at line 22 of file MqContextC_py.c.
#define OT_retObj_CONSTR | ( | mng | ) |
Definition at line 24 of file MqContextC_py.c.
#define OT_SETUP_hdl OT_SETUP_hdl_tmpl(MqContextC) |
Definition at line 26 of file MqContextC_py.c.
#define OT_SETUP_hdl__null_allow OT_SETUP_hdl_tmpl__null_allow(MqContextC) |
Definition at line 27 of file MqContextC_py.c.
#define OT_SETUP_hdl_constr |
Definition at line 28 of file MqContextC_py.c.
#define OT_SETUP_hdl_destr OT_SETUP_hdl_tmpl__null_allow(MqContextC) |
Definition at line 30 of file MqContextC_py.c.
#define OT_SETUP_hdl_static |
Definition at line 31 of file MqContextC_py.c.
#define OT_SETUP_hdl_static_constr OT_SETUP_hdl_static |
Definition at line 34 of file MqContextC_py.c.
#define Prev_doc "MqContextC ctx.Prev()" |
Definition at line 200 of file MqContextC_py.c.
#define ProcessEvent_doc "ctx.ProcessEvent(?wait:MqWaitOnEventE=NO?, ?timeout:MkTimeoutE|int32=DEFAULT?)" |
Definition at line 244 of file MqContextC_py.c.
#define ProxyForward_doc "sourceCtx.ProxyForward(targetCtx:MqContextC, ?dump:MqDumpC=None?, ?timeout:MkTimeoutE|int32=DEFAULT?)" |
Definition at line 247 of file MqContextC_py.c.
#define ProxyItem_doc "sourceCtx.ProxyItem(targetCtx:MqContextC)" |
Definition at line 248 of file MqContextC_py.c.
#define ReadALL_doc "MkBufferListC ctx.ReadALL(?val_inout:MkBufferListC=None?)" |
Definition at line 251 of file MqContextC_py.c.
#define ReadBFL_doc "MkBufferListC ctx.ReadBFL()" |
Definition at line 254 of file MqContextC_py.c.
#define ReadBIN_doc "binary ctx.ReadBIN()" |
Definition at line 269 of file MqContextC_py.c.
#define ReadBinaryR_doc "binary ctx.ReadBinaryR()" |
Definition at line 271 of file MqContextC_py.c.
#define ReadBOL_doc "bool ctx.ReadBOL()" |
Definition at line 270 of file MqContextC_py.c.
#define ReadBUF_doc "MkBufferC ctx.ReadBUF()" |
Definition at line 255 of file MqContextC_py.c.
#define ReadDbg_doc "ctx.ReadDbg()" |
Definition at line 258 of file MqContextC_py.c.
#define ReadDBL_doc "double ctx.ReadDBL()" |
Definition at line 272 of file MqContextC_py.c.
#define ReadFLT_doc "float ctx.ReadFLT()" |
Definition at line 273 of file MqContextC_py.c.
#define ReadGetNextType_doc "MkTypeE ctx.ReadGetNextType()" |
Definition at line 259 of file MqContextC_py.c.
#define ReadGetNumItems_doc "int32 ctx.ReadGetNumItems()" |
Definition at line 260 of file MqContextC_py.c.
#define ReadHDL_doc "MK_HDL ctx.ReadHDL()" |
Definition at line 274 of file MqContextC_py.c.
#define ReadI16_doc "int16 ctx.ReadI16()" |
Definition at line 275 of file MqContextC_py.c.
#define ReadI32_doc "int32 ctx.ReadI32()" |
Definition at line 276 of file MqContextC_py.c.
#define ReadI64_doc "int64 ctx.ReadI64()" |
Definition at line 277 of file MqContextC_py.c.
#define ReadI8_doc "int8 ctx.ReadI8()" |
Definition at line 278 of file MqContextC_py.c.
#define ReadItemExists_doc "bool ctx.ReadItemExists()" |
Definition at line 261 of file MqContextC_py.c.
#define ReadL_END_doc "ctx.ReadL_END()" |
Definition at line 262 of file MqContextC_py.c.
#define ReadL_START_doc "ctx.ReadL_START(?buf:MkBufferC=None?)" |
Definition at line 263 of file MqContextC_py.c.
#define ReadLIST_doc "[list...] ctx.ReadLIST()" |
Definition at line 279 of file MqContextC_py.c.
#define ReadLONG_doc "long ctx.ReadLONG()" |
Definition at line 280 of file MqContextC_py.c.
#define ReadNEXT_doc "obj ctx.ReadNEXT()" |
Definition at line 281 of file MqContextC_py.c.
#define ReadSTR_doc "string ctx.ReadSTR()" |
Definition at line 282 of file MqContextC_py.c.
#define ReadStringR_doc "string ctx.ReadStringR()" |
Definition at line 283 of file MqContextC_py.c.
#define ReadT_END_doc "ctx.ReadT_END()" |
Definition at line 264 of file MqContextC_py.c.
#define ReadT_START_doc "ctx.ReadT_START()" |
Definition at line 265 of file MqContextC_py.c.
#define ReadUndo_doc "ctx.ReadUndo()" |
Definition at line 266 of file MqContextC_py.c.
#define RouteCreate_doc "ctx.RouteCreate(route:string, service:string, ?overwrite:bool=false?)" |
Definition at line 289 of file MqContextC_py.c.
#define RouteDelete_doc "ctx.RouteDelete(route:string, service:string, ?overwrite:bool=false?)" |
Definition at line 290 of file MqContextC_py.c.
#define RouteGetPath_doc "string ctx.RouteGetPath()" |
Definition at line 295 of file MqContextC_py.c.
#define RouteGetTree_doc "MkBufferListC ctx.RouteGetTree()" |
Definition at line 286 of file MqContextC_py.c.
#define RouteResolve_doc "[MqContextC...] ctx.RouteResolve(ident:string, ?retnum:int32=-1?)" |
Definition at line 291 of file MqContextC_py.c.
#define RouteTraverse_doc "ctx.RouteTraverse(service:string, ?args:MkBufferListC...=None?)" |
Definition at line 292 of file MqContextC_py.c.
#define Send_doc "ctx.Send(cstr:string, args:args...)" |
Definition at line 298 of file MqContextC_py.c.
#define Send_doc Send_doc_extra |
Definition at line 298 of file MqContextC_py.c.
#define SendBFL_doc "ctx.SendBFL(val:MkBufferListC)" |
Definition at line 299 of file MqContextC_py.c.
#define SendBIN_doc "ctx.SendBIN(val:binary)" |
Definition at line 300 of file MqContextC_py.c.
#define SendBinaryR_doc "ctx.SendBinaryR(val:binary)" |
Definition at line 304 of file MqContextC_py.c.
#define SendBOL_doc "ctx.SendBOL(val:bool)" |
Definition at line 301 of file MqContextC_py.c.
#define SendBUF_doc "ctx.SendBUF(val:MkBufferC)" |
Definition at line 302 of file MqContextC_py.c.
#define SendBUS_FLAT_doc "ctx.SendBUS_FLAT(val:MkBufferStreamC)" |
Definition at line 303 of file MqContextC_py.c.
#define SendDBL_doc "ctx.SendDBL(val:double)" |
Definition at line 305 of file MqContextC_py.c.
#define SendEND_AND_CALLBACK_doc "ctx.SendEND_AND_CALLBACK(token:string[4], callback:callable, ?timeout:MkTimeoutE|int32=DEFAULT?)" |
Definition at line 307 of file MqContextC_py.c.
#define SendEND_AND_SUB_doc "ctx.SendEND_AND_SUB(token:string[4], callback:callable, ?timeout:MkTimeoutE|int32=DEFAULT?)" |
Definition at line 308 of file MqContextC_py.c.
#define SendEND_AND_TRANSACTION_doc "ctx.SendEND_AND_TRANSACTION(token:string[4], callback:string[4], ?timeout:MkTimeoutE|int32=DEFAULT?)" |
Definition at line 309 of file MqContextC_py.c.
#define SendEND_AND_WAIT_doc "ctx.SendEND_AND_WAIT(token:string[4], ?timeout:MkTimeoutE|int32=DEFAULT?)" |
Definition at line 310 of file MqContextC_py.c.
#define SendEND_doc "ctx.SendEND(token:string[4], ?timeout:MkTimeoutE|int32=DEFAULT?)" |
Definition at line 306 of file MqContextC_py.c.
#define SendERROR_doc "ctx.SendERROR()" |
Definition at line 311 of file MqContextC_py.c.
#define SendFLT_doc "ctx.SendFLT(val:float)" |
Definition at line 312 of file MqContextC_py.c.
#define SendHDL_doc "ctx.SendHDL(val:MK_HDL)" |
Definition at line 313 of file MqContextC_py.c.
#define SendI16_doc "ctx.SendI16(val:int16)" |
Definition at line 314 of file MqContextC_py.c.
#define SendI32_doc "ctx.SendI32(val:int32)" |
Definition at line 315 of file MqContextC_py.c.
#define SendI64_doc "ctx.SendI64(val:int64)" |
Definition at line 316 of file MqContextC_py.c.
#define SendI8_doc "ctx.SendI8(val:int8)" |
Definition at line 317 of file MqContextC_py.c.
#define SendL_END_doc "ctx.SendL_END()" |
Definition at line 320 of file MqContextC_py.c.
#define SendL_FLAT_doc "ctx.SendL_FLAT(val:MkBufferListC)" |
Definition at line 321 of file MqContextC_py.c.
#define SendL_START_doc "ctx.SendL_START()" |
Definition at line 322 of file MqContextC_py.c.
#define SendLONG_doc "ctx.SendLONG(val:long)" |
Definition at line 318 of file MqContextC_py.c.
#define SendLTR_doc "ctx.SendLTR(transLId:int32)" |
Definition at line 319 of file MqContextC_py.c.
#define SendRETURN_doc "ctx.SendRETURN()" |
Definition at line 323 of file MqContextC_py.c.
#define SendRETURN_SUB_doc "ctx.SendRETURN_SUB()" |
Definition at line 324 of file MqContextC_py.c.
#define SendSTART_doc "ctx.SendSTART()" |
Definition at line 325 of file MqContextC_py.c.
#define SendSTR_doc "ctx.SendSTR(val:string)" |
Definition at line 326 of file MqContextC_py.c.
#define SendStringR_doc "ctx.SendStringR(val:string)" |
Definition at line 328 of file MqContextC_py.c.
#define SendSYNC_doc "ctx.SendSYNC()" |
Definition at line 327 of file MqContextC_py.c.
#define SendT_END_doc "ctx.SendT_END()" |
Definition at line 329 of file MqContextC_py.c.
#define SendT_START_doc "ctx.SendT_START()" |
Definition at line 330 of file MqContextC_py.c.
#define ServiceCreate_doc "ctx.ServiceCreate(token:string[4], callback:callable)" |
Definition at line 333 of file MqContextC_py.c.
#define ServiceDelete_doc "ctx.ServiceDelete(token:string[4])" |
Definition at line 334 of file MqContextC_py.c.
#define ServiceIsTransaction_doc "bool ctx.ServiceIsTransaction()" |
Definition at line 335 of file MqContextC_py.c.
#define ServiceProxy_doc "ctx.ServiceProxy(token:string[4], ?id:MqSlaveE|int32=MQ_SLAVE_OTHER?)" |
Definition at line 336 of file MqContextC_py.c.
#define ServiceProxyCtx_doc "ctx.ServiceProxyCtx(token:string[4], target:MqContextC)" |
Definition at line 337 of file MqContextC_py.c.
#define ServiceProxyCtxExists_doc "bool ctx.ServiceProxyCtxExists(token:string[4], target:MqContextC)" |
Definition at line 338 of file MqContextC_py.c.
#define ServiceProxyRoundRobin_doc "ctx.ServiceProxyRoundRobin(token:string[4], ident:string)" |
Definition at line 339 of file MqContextC_py.c.
#define ServiceStorage_doc "ctx.ServiceStorage(token:string[4])" |
Definition at line 340 of file MqContextC_py.c.
#define ServiceTokenCheck_doc "bool ctx.ServiceTokenCheck(token:string[4])" |
Definition at line 341 of file MqContextC_py.c.
#define ServiceTokenExists_doc "bool ctx.ServiceTokenExists(token:string[4])" |
Definition at line 342 of file MqContextC_py.c.
#define ServiceTokenGet_doc "string[4] ctx.ServiceTokenGet()" |
Definition at line 343 of file MqContextC_py.c.
#define SetupRtFromObj_X | ( | hdl | ) |
Definition at line 37 of file MqContextC_py.c.
#define SetupRtFromObj_XN | ( | hdl | ) |
Definition at line 38 of file MqContextC_py.c.
#define SlaveCheck_doc "bool ctx.SlaveCheck(id:MqSlaveE|int32) (const)" |
Definition at line 354 of file MqContextC_py.c.
#define SlaveCreate_doc "ctx.SlaveCreate(id:MqSlaveE|int32, slave:MqContextC)" |
Definition at line 355 of file MqContextC_py.c.
#define SlaveDelete_doc "ctx.SlaveDelete(id:MqSlaveE|int32)" |
Definition at line 356 of file MqContextC_py.c.
#define SlaveGet_doc "MqContextC ctx.SlaveGet(id:MqSlaveE|int32)" |
Definition at line 349 of file MqContextC_py.c.
#define SlaveGetFilter_doc "MqContextC ctx.SlaveGetFilter()" |
Definition at line 350 of file MqContextC_py.c.
#define SlaveGetMaster_doc "MqContextC ctx.SlaveGetMaster()" |
Definition at line 346 of file MqContextC_py.c.
#define SlaveGetProxy_doc "MqContextC ctx.SlaveGetProxy(id:MqSlaveE|int32)" |
Definition at line 351 of file MqContextC_py.c.
#define SlaveIs_doc "bool ctx.SlaveIs() (const)" |
Definition at line 357 of file MqContextC_py.c.
#define SlaveWorker_doc "ctx.SlaveWorker(id:MqSlaveE|int32, ?fct:string=\"WORKER\"?, ?args:MkBufferListC...=None?)" |
Definition at line 358 of file MqContextC_py.c.
#define StorageClose_doc "ctx.StorageClose()" |
Definition at line 365 of file MqContextC_py.c.
#define StorageCount_doc "int32 ctx.StorageCount()" |
Definition at line 372 of file MqContextC_py.c.
#define StorageDecrRef_doc "ctx.StorageDecrRef(transLId:int32)" |
Definition at line 366 of file MqContextC_py.c.
#define StorageDelete_doc "int32 ctx.StorageDelete(?*transLIdP_inout:int32=0?)" |
Definition at line 361 of file MqContextC_py.c.
#define StorageErrCnt_doc "int32 ctx.StorageErrCnt(transLId:int32)" |
Definition at line 373 of file MqContextC_py.c.
#define StorageExport_doc "int32 ctx.StorageExport()" |
Definition at line 374 of file MqContextC_py.c.
#define StorageImport_doc "int32 ctx.StorageImport(?*transLIdP_inout:int32=0?)" |
Definition at line 362 of file MqContextC_py.c.
#define StorageIncrRef_doc "ctx.StorageIncrRef(transLId:int32)" |
Definition at line 367 of file MqContextC_py.c.
#define StorageLog_doc "ctx.StorageLog(?callfunc:string=\"MK_NULL\"?)" |
Definition at line 368 of file MqContextC_py.c.
#define StorageOpen_doc "ctx.StorageOpen(storageFile:string)" |
Definition at line 369 of file MqContextC_py.c.
#define StorageResolve_doc "{otherCtxP:MqContextC otherLIdP:int32} ctx.StorageResolve()" |
Definition at line 375 of file MqContextC_py.c.
#define ToString_doc "string ctx.ToString() (const)" |
Definition at line 213 of file MqContextC_py.c.
Definition at line 47 of file MqContextC_py.c.
|
static |
Definition at line 402 of file MqContextC_py.c.
|
static |
Definition at line 427 of file MqContextC_py.c.
|
static |
Definition at line 54 of file MqContextC_py.c.
Definition at line 58 of file MqContextC_py.c.
Definition at line 62 of file MqContextC_py.c.
int py_mqmsgque_pMqContextC_Init | ( | MQ_RT_ARGS OT_LNG_T | m | ) |
Definition at line 3949 of file MqContextC_py.c.
Definition at line 3869 of file MqContextC_py.c.
Definition at line 3880 of file MqContextC_py.c.
Definition at line 3875 of file MqContextC_py.c.
|
static |
Definition at line 3905 of file MqContextC_py.c.
|
static |
Definition at line 3900 of file MqContextC_py.c.
Definition at line 3865 of file MqContextC_py.c.
Definition at line 3861 of file MqContextC_py.c.
|
static |
Definition at line 3885 of file MqContextC_py.c.
Definition at line 3890 of file MqContextC_py.c.
|
static |
Object definition
Definition at line 3597 of file MqContextC_py.c.
OT_CLASS_TYPE_REF py_mqmsgque_MqContextCR |
Public API
Definition at line 3934 of file MqContextC_py.c.