LibMqMsgque_py.c File Reference

LibMqMsgque_py.c - 02 Sep 2024 - aotto1968. More...

#include "LibMqMsgque_py.h"
#include "misc_check_py.h"
#include "tmpl/mq_misc_check_lng.h"

Include dependency graph for LibMqMsgque_py.c:

Go to the source code of this file.

Data Structures
struct	py_mqmsgque_sMqMsgqueStateS

Macros
#define	OT_SETUP_hdl
#define	OT_SETUP_hdl_static
#define	MqSetupTmpl()
#define	MqCleanupTmpl()
#define	IdentE_FromInt_doc   "MqIdentE IdentE_FromInt(value:int32)"
#define	SlaveE_FromInt_doc   "MqSlaveE SlaveE_FromInt(value:int32)"
#define	StartE_FromInt_doc   "MqStartE StartE_FromInt(value:int32)"
#define	StatusIsEF_FromInt_doc   "MqStatusIsEF StatusIsEF_FromInt(value:int32)"
#define	WaitOnEventE_FromInt_doc   "MqWaitOnEventE WaitOnEventE_FromInt(value:int32)"
#define	IdentE_ToInt_doc   "int32 IdentE_ToInt(value:MqIdentE)"
#define	IdentE_ToString_doc   "string IdentE_ToString(value:MqIdentE)"
#define	SlaveE_ToInt_doc   "int32 SlaveE_ToInt(value:MqSlaveE)"
#define	SlaveE_ToString_doc   "string SlaveE_ToString(value:MqSlaveE)"
#define	StartE_ToInt_doc   "int32 StartE_ToInt(value:MqStartE)"
#define	StartE_ToString_doc   "string StartE_ToString(value:MqStartE)"
#define	StatusIsEF_ToInt_doc   "int32 StatusIsEF_ToInt(value:MqStatusIsEF)"
#define	StatusIsEF_ToString_doc   "string StatusIsEF_ToString(value:MqStatusIsEF)"
#define	WaitOnEventE_ToInt_doc   "int32 WaitOnEventE_ToInt(value:MqWaitOnEventE)"
#define	WaitOnEventE_ToString_doc   "string WaitOnEventE_ToString(value:MqWaitOnEventE)"
#define	Help_doc   "string Help(tool:string)"
#define	HelpMsgque_doc   "string HelpMsgque()"
#define	InitGetArg0_doc   "MkBufferListC InitGetArg0()"
#define	InitResetArg0_doc   "MkBufferListC InitResetArg0()"
#define	InitSetArg0_doc   "InitSetArg0(?bfl:MkBufferListC...=None?)"
#define	Cleanup_doc   "Cleanup()"
#define	Setup_doc   "Setup()"
#define	Debug_doc   "Debug(prefix:str, ?obj:object?"
#define	myTrace2(col, str)
#define	myTrace(str)

Functions
int	py_mqmsgque_pMqDumpC_Init (MQ_RT const mqrt, OT_LNG_T)
int	py_mqmsgque_pMqContextC_Init (MQ_RT const mqrt, OT_LNG_T)
int	py_mqmsgque_pMqFactoryC_Init (MQ_RT const mqrt, OT_LNG_T)
int	py_mqmsgque_pMqFactoryC_Setup (MQ_RT const mqrt, OT_LNG_T)
enum MkErrorE	py_mqmsgque_CheckConstructor (OT_Check_ARGS, MK_CCP *retP)
static OT_ProcRet	py_mqmsgque_MqMsgque_IdentE_FromInt (OtClass_ARGS)
	Python: [static] MqIdentE IdentE_FromInt(value:int32) → C-API return the MqIdentE from integer …
static OT_ProcRet	py_mqmsgque_MqMsgque_SlaveE_FromInt (OtClass_ARGS)
	Python: [static] MqSlaveE SlaveE_FromInt(value:int32) → C-API return the MqSlaveE from integer …
static OT_ProcRet	py_mqmsgque_MqMsgque_StartE_FromInt (OtClass_ARGS)
	Python: [static] MqStartE StartE_FromInt(value:int32) → C-API return the MqStartE from integer …
static OT_ProcRet	py_mqmsgque_MqMsgque_StatusIsEF_FromInt (OtClass_ARGS)
	Python: [static] MqStatusIsEF StatusIsEF_FromInt(value:int32) → C-API return the MqStatusIsEF from integer …
static OT_ProcRet	py_mqmsgque_MqMsgque_WaitOnEventE_FromInt (OtClass_ARGS)
	Python: [static] MqWaitOnEventE WaitOnEventE_FromInt(value:int32) → C-API return the MqWaitOnEventE from integer …
static OT_ProcRet	py_mqmsgque_MqMsgque_IdentE_ToInt (OtClass_ARGS)
	Python: [static] int32 IdentE_ToInt(value:MqIdentE) → C-API return the MqIdentE as integer …
static OT_ProcRet	py_mqmsgque_MqMsgque_IdentE_ToString (OtClass_ARGS)
	Python: [static] string IdentE_ToString(value:MqIdentE) → C-API return the MqIdentE as string …
static OT_ProcRet	py_mqmsgque_MqMsgque_SlaveE_ToInt (OtClass_ARGS)
	Python: [static] int32 SlaveE_ToInt(value:MqSlaveE) → C-API return the MqSlaveE as integer …
static OT_ProcRet	py_mqmsgque_MqMsgque_SlaveE_ToString (OtClass_ARGS)
	Python: [static] string SlaveE_ToString(value:MqSlaveE) → C-API return the MqSlaveE as string …
static OT_ProcRet	py_mqmsgque_MqMsgque_StartE_ToInt (OtClass_ARGS)
	Python: [static] int32 StartE_ToInt(value:MqStartE) → C-API return the MqStartE as integer …
static OT_ProcRet	py_mqmsgque_MqMsgque_StartE_ToString (OtClass_ARGS)
	Python: [static] string StartE_ToString(value:MqStartE) → C-API return the MqStartE as string …
static OT_ProcRet	py_mqmsgque_MqMsgque_StatusIsEF_ToInt (OtClass_ARGS)
	Python: [static] int32 StatusIsEF_ToInt(value:MqStatusIsEF) → C-API return the MqStatusIsEF as integer …
static OT_ProcRet	py_mqmsgque_MqMsgque_StatusIsEF_ToString (OtClass_ARGS)
	Python: [static] string StatusIsEF_ToString(value:MqStatusIsEF) → C-API return the MqStatusIsEF as string …
static OT_ProcRet	py_mqmsgque_MqMsgque_WaitOnEventE_ToInt (OtClass_ARGS)
	Python: [static] int32 WaitOnEventE_ToInt(value:MqWaitOnEventE) → C-API return the MqWaitOnEventE as integer …
static OT_ProcRet	py_mqmsgque_MqMsgque_WaitOnEventE_ToString (OtClass_ARGS)
	Python: [static] string WaitOnEventE_ToString(value:MqWaitOnEventE) → C-API return the MqWaitOnEventE as string …
static OT_ProcRet	py_mqmsgque_MqMsgque_Help (OtClass_ARGS)
	Python: [static] string Help(tool:string) → C-API write pymqmsgque specific user-help to stderr
static OT_ProcRet	py_mqmsgque_MqMsgque_HelpMsgque (OtClass_ARGS)
	Python: [static] string HelpMsgque() → C-API return a page with the usage of all pymqmsgque specific options
static OT_ProcRet	py_mqmsgque_MqMsgque_InitGetArg0 (OtClass_ARGS)
	Python: [static] MkBufferListC InitGetArg0() → C-API get the process startup-prefix argument
static OT_ProcRet	py_mqmsgque_MqMsgque_InitResetArg0 (OtClass_ARGS)
	Python: [static] MkBufferListC InitResetArg0() → C-API Reset the process-startup-prefix argument to an empty list …
static OT_ProcRet	py_mqmsgque_MqMsgque_InitSetArg0 (OtClass_ARGS)
	Python: [static] InitSetArg0(?bfl:MkBufferListC...=None?) → C-API set the process startup-prefix argument to bfl
static OT_ProcRet	py_mqmsgque_MqMsgque_Cleanup (OtClass_ARGS)
	Python: [static] Cleanup() → C-API cleanup pymqmsgque internal memory …
static OT_ProcRet	py_mqmsgque_MqMsgque_Setup (OtClass_ARGS)
	Python: [static] Setup() → C-API setup pymqmsgque internal memory …
static	typeof (MqLal.SysServerThread) save_SysServerThread
static MK_UNUSED enum MkErrorE	py_mqmsgque_PyServerThread (MK_RT const mkrt, MQ_CTX const context, struct MqSysServerThreadMainS *const argP, MK_STRN name, int thread_status, struct MkIdS *idP)
static MK_UNUSED py_mqmsgque_sMqMsgqueStateS *	py_mqmsgque_sMqMsgqueGetState (PyObject *module)
static MK_UNUSED int	py_mqmsgque_sMqMsgqueTraverse (PyObject *module, visitproc visit, void *arg)
static MK_UNUSED int	py_mqmsgque_sMqMsgqueClear (PyObject *module)
static void	py_mqmsgque_sMqMsgqueFree (void *module)
static int	py_mqmsgque_sMqMsgqueExec (PyObject *module)
PyMODINIT_FUNC	PyInit_pymqmsgque (void)

Variables
static PyMethodDef	py_mqmsgque_sMqMsgqueMethods []
static MK_UNUSED int	num = 0
MkThreadLocal MqMsgqueThreadStateS	py_mqmsgque_MqMsgqueThreadState = {0}
static MK_UNUSED PyModuleDef_Slot	py_mqmsgque_sMqMsgqueDefSlots []
static PyModuleDef	py_mqmsgque_sMqMsgqueDef

Detailed Description

LibMqMsgque_py.c - 02 Sep 2024 - aotto1968.

Copyright

(C) NHI - #1 - Project - Group This software has NO permissions to copy, please contact AUTHOR for additional information

Version

da57c4217ee2f4cc968feed995e6defee7f5b374

Date

Mon Sep 2 08:50:15 2024 +0200

Author

aotto1968 aotto.nosp@m.1968.nosp@m.@t-on.nosp@m.line.nosp@m..de

Definition in file LibMqMsgque_py.c.

Macro Definition Documentation

Cleanup_doc

#define Cleanup_doc   "Cleanup()"

Definition at line 175 of file LibMqMsgque_py.c.

Debug_doc

#define Debug_doc   "Debug(prefix:str, ?obj:object?"

Definition at line 180 of file LibMqMsgque_py.c.

Help_doc

#define Help_doc   "string Help(tool:string)"

Definition at line 166 of file LibMqMsgque_py.c.

HelpMsgque_doc

#define HelpMsgque_doc   "string HelpMsgque()"

Definition at line 167 of file LibMqMsgque_py.c.

IdentE_FromInt_doc

#define IdentE_FromInt_doc   "MqIdentE IdentE_FromInt(value:int32)"

doc definition

Definition at line 147 of file LibMqMsgque_py.c.

IdentE_ToInt_doc

#define IdentE_ToInt_doc   "int32 IdentE_ToInt(value:MqIdentE)"

Definition at line 154 of file LibMqMsgque_py.c.

IdentE_ToString_doc

#define IdentE_ToString_doc   "string IdentE_ToString(value:MqIdentE)"

Definition at line 155 of file LibMqMsgque_py.c.

InitGetArg0_doc

#define InitGetArg0_doc   "MkBufferListC InitGetArg0()"

Definition at line 170 of file LibMqMsgque_py.c.

InitResetArg0_doc

#define InitResetArg0_doc   "MkBufferListC InitResetArg0()"

Definition at line 171 of file LibMqMsgque_py.c.

InitSetArg0_doc

#define InitSetArg0_doc   "InitSetArg0(?bfl:MkBufferListC...=None?)"

Definition at line 172 of file LibMqMsgque_py.c.

MqCleanupTmpl

#define MqCleanupTmpl

(

)

Definition at line 23 of file LibMqMsgque_py.c.

MqSetupTmpl

#define MqSetupTmpl

(

)

Definition at line 22 of file LibMqMsgque_py.c.

myTrace

#define myTrace

(

str

)

Definition at line 714 of file LibMqMsgque_py.c.

myTrace2

#define myTrace2	(		col,
			str )

Definition at line 713 of file LibMqMsgque_py.c.

OT_SETUP_hdl

#define OT_SETUP_hdl

Value:

                                MqRtSetup_NULL; \
                                MK_OBJ hdl = MK_ERROR_PRINT;

Definition at line 17 of file LibMqMsgque_py.c.

#define OT_SETUP_hdl            MqRtSetup_NULL; \
                                MK_OBJ hdl = MK_ERROR_PRINT;

OT_SETUP_hdl_static

#define OT_SETUP_hdl_static

Value:

                                __attribute__((unused)) MK_RT mkrt = MkRT; \
                                __attribute__((unused)) MK_ERR hdl = &MkERROR;

Definition at line 19 of file LibMqMsgque_py.c.

#define OT_SETUP_hdl_static     __attribute__((unused)) MK_RT mkrt = MkRT; \
                                __attribute__((unused)) MK_ERR hdl = &MkERROR;

Setup_doc

#define Setup_doc   "Setup()"

Definition at line 176 of file LibMqMsgque_py.c.

SlaveE_FromInt_doc

#define SlaveE_FromInt_doc   "MqSlaveE SlaveE_FromInt(value:int32)"

Definition at line 148 of file LibMqMsgque_py.c.

SlaveE_ToInt_doc

#define SlaveE_ToInt_doc   "int32 SlaveE_ToInt(value:MqSlaveE)"

Definition at line 156 of file LibMqMsgque_py.c.

SlaveE_ToString_doc

#define SlaveE_ToString_doc   "string SlaveE_ToString(value:MqSlaveE)"

Definition at line 157 of file LibMqMsgque_py.c.

StartE_FromInt_doc

#define StartE_FromInt_doc   "MqStartE StartE_FromInt(value:int32)"

Definition at line 149 of file LibMqMsgque_py.c.

StartE_ToInt_doc

#define StartE_ToInt_doc   "int32 StartE_ToInt(value:MqStartE)"

Definition at line 158 of file LibMqMsgque_py.c.

StartE_ToString_doc

#define StartE_ToString_doc   "string StartE_ToString(value:MqStartE)"

Definition at line 159 of file LibMqMsgque_py.c.

StatusIsEF_FromInt_doc

#define StatusIsEF_FromInt_doc   "MqStatusIsEF StatusIsEF_FromInt(value:int32)"

Definition at line 150 of file LibMqMsgque_py.c.

StatusIsEF_ToInt_doc

#define StatusIsEF_ToInt_doc   "int32 StatusIsEF_ToInt(value:MqStatusIsEF)"

Definition at line 160 of file LibMqMsgque_py.c.

StatusIsEF_ToString_doc

#define StatusIsEF_ToString_doc   "string StatusIsEF_ToString(value:MqStatusIsEF)"

Definition at line 161 of file LibMqMsgque_py.c.

WaitOnEventE_FromInt_doc

#define WaitOnEventE_FromInt_doc   "MqWaitOnEventE WaitOnEventE_FromInt(value:int32)"

Definition at line 151 of file LibMqMsgque_py.c.

WaitOnEventE_ToInt_doc

#define WaitOnEventE_ToInt_doc   "int32 WaitOnEventE_ToInt(value:MqWaitOnEventE)"

Definition at line 162 of file LibMqMsgque_py.c.

WaitOnEventE_ToString_doc

#define WaitOnEventE_ToString_doc   "string WaitOnEventE_ToString(value:MqWaitOnEventE)"

Definition at line 163 of file LibMqMsgque_py.c.

Function Documentation

py_mqmsgque_CheckConstructor()

enum MkErrorE py_mqmsgque_CheckConstructor	(	OT_Check_ARGS	,
		MK_CCP *	retP )

Definition at line 190 of file LibMqMsgque_py.c.

  {
  if ((*skipP) >= objc) {
    WrongNumArgs(hdl,(*skipP), objc, -999, +999, arg);
    goto error;
  }
  PyObject  *objV = OT_LNG_OBJV((*skipP)++);
  if (PyObject_IsSubclass(objV,(OT_LNG_T)&NS(MqContextCR)) == 1) {
    Py_INCREF(objV);
    *retP = (MK_CCP)objV;
  } else if (PyObject_IsSubclass(objV,(OT_LNG_T)&MK(MkObjectCR)) == 1) {
    WrongTypeOfArgError(OT_LNG_NAME_FROM_CLASS(&NS(MqContextCR)), OT_LNG_NAME_FROM_CLASS((OT_LNG_CLASS_T)objV));
  } else {
    WrongTypeOfArgError(OT_LNG_NAME_FROM_CLASS(&NS(MqContextCR)), OT_LNG_TYPE_STRING(objV));
  }
  return MK_OK;
error:
  return OT_ERROR_STACK;
}

py_mqmsgque_pMqContextC_Init()

int py_mqmsgque_pMqContextC_Init	(	MQ_RT const	mqrt,
		OT_LNG_T	m )

Definition at line 3976 of file MqContextC_py.c.

                                            {
 
  // define type
  MqContextCTT = MkTypeDup2(MqContextC_TT,"pymqmsgque_MqContextC");
  MqContextCT->fIncrSelf = NS(sIncrSelf);
  MqContextCT->fDecrSelf = NS(sDecrSelf);
//  >> replaced by os_fork
//  MqContextCT->fParentBeforeFork = NS(sParentBeforeFork);
//  MqContextCT->fParentAfterFork = NS(sParentAfterFork);
//  MqContextCT->fChildAfterFork = NS(sChildAfterFork);
  MqContextCT->fProcessExit = NS(sProcessExit);
  MqContextCT->fThreadExit = NS(sThreadExit);
  //MqContextCT->ignoreDisasterSetup = true;
  MqContextCT->ignoreThread = true;
 
  ClassInit
 
  return 0;
error:
  return -1;
}

py_mqmsgque_pMqDumpC_Init()

int py_mqmsgque_pMqDumpC_Init	(	MQ_RT const	mqrt,
		OT_LNG_T	m )

Public API

Definition at line 470 of file MqDumpC_py.c.

                                         {
 
  ClassInit
 
  return 0;
error:
  return -1;
}

py_mqmsgque_pMqFactoryC_Init()

int py_mqmsgque_pMqFactoryC_Init	(	MQ_RT const	mqrt,
		OT_LNG_T	m )

Definition at line 844 of file MqFactoryC_py.c.

{
  ClassInit
  MqFactoryCTT->noSelf = true;
 
  return 0;
error:
  return -1;
}

py_mqmsgque_pMqFactoryC_Setup()

int py_mqmsgque_pMqFactoryC_Setup	(	MQ_RT const	mqrt,
		OT_LNG_T	m )

Public API

Definition at line 805 of file MqFactoryC_py.c.

{
  if (!strcmp(MqFactoryDefaultIdent(), "libmqmsgque")) {
    if  ( MqFactoryDefault(
            MqFactoryInitial(
              MqFactoryAdd (MK_ERROR_FORMAT,
                NS(sFactoryCTor), (MK_PTR)&NS(MqContextCR), NULL, NULL, 
                  NS(sFactoryDTor), NULL, NULL, NULL,
                    "pymqmsgque"
              )
            )
          ) == NULL
        ) 
    {
      PyErr_SetString(PyExc_RuntimeError, "MqFactoryS exception");
      goto error;
    }
  }
 
  return 0;
error:
  return -1;
}

py_mqmsgque_PyServerThread()

static MK_UNUSED enum MkErrorE py_mqmsgque_PyServerThread ( MK_RT const mkrt, MQ_CTX const context, struct MqSysServerThreadMainS *const argP, MK_STRN name, int thread_status, struct MkIdS * idP )

static

Definition at line 653 of file LibMqMsgque_py.c.

  {
  enum MkErrorE ret;
  PyGILState_STATE gilstate;
 
  gilstate = PyGILState_Ensure();
  Py_BEGIN_ALLOW_THREADS
 
//num++;
//printV("START num<%d>, ts<%p>, gil<%o>",num,_save,gilstate);
  ret = (*save_SysServerThread)(MK_RT_CALL context, argP, name, thread_status, idP);
//printV("END   num<%d>, ts<%p>, gil<%o>",num,_save,gilstate);
 
  Py_END_ALLOW_THREADS
  PyGILState_Release(gilstate);
 
  return ret;
}

py_mqmsgque_sMqMsgqueClear()

static MK_UNUSED int py_mqmsgque_sMqMsgqueClear ( PyObject * module )

static

Definition at line 743 of file LibMqMsgque_py.c.

{
myTrace("CLEAR")
 
  // BEGIN-EnumClear - created by 'py_MqS.tcl -i NHI1_HOME/theLink/c/gen/c_mqmsgque.meta' - DO NOT change
 
  Py_CLEAR(OT_MqIdentE);
  Py_CLEAR(OT_MqSlaveE);
  Py_CLEAR(OT_MqStartE);
  Py_CLEAR(OT_MqStatusIsEF);
  Py_CLEAR(OT_MqWaitOnEventE);
 
  // END-EnumClear - created by 'py_MqS.tcl -i NHI1_HOME/theLink/c/gen/c_mqmsgque.meta' - DO NOT change
  // BEGIN-ClassClear - created by 'py_MqS.tcl -i NHI1_HOME/theLink/c/gen/c_mqmsgque.meta' - DO NOT change
 
  Py_CLEAR(MqDumpC_MK_NULL);
  Py_CLEAR(MqContextC_MK_NULL);
  Py_CLEAR(MqFactoryC_MK_NULL);
 
  // END-ClassClear - created by 'py_MqS.tcl -i NHI1_HOME/theLink/c/gen/c_mqmsgque.meta' - DO NOT change
 
  return 0;
}

py_mqmsgque_sMqMsgqueExec()

static int py_mqmsgque_sMqMsgqueExec ( PyObject * module )

static

Definition at line 780 of file LibMqMsgque_py.c.

{
myTrace2(MK_BLUE,"START")
//printV("#1 PyThreadState_Get<%p>", PyThreadState_Get())
 
  MqSetup();
  MqRtSetup_NULL;
 
  NS(sMqMsgqueStateS) *state = NS(sMqMsgqueGetState)(module);
  state->mkrt = MK_RT_PTR;
 
//  MK_RT_REF.threadData = PyThreadState_Get();
 
  PyObject *mainM = PyImport_AddModule("__main__");
 
  PyObject *mkM;
  LngErrorCheckN(mkM = PyImport_ImportModule("pymkkernel"));
  LngErrorCheck(PyObject_SetAttrString(mainM,"pymkkernel",mkM));
  Py_CLEAR(mkM);
 
  // BEGIN-CLASS-DEF - created by 'py_MqS.tcl -i NHI1_HOME/theLink/c/gen/c_mqmsgque.meta' - DO NOT change
 
  LngErrorCheck( NS(pMqDumpC_Init)    (MQ_RT_CALL module) ) ;
  LngErrorCheck( NS(pMqContextC_Init) (MQ_RT_CALL module) ) ;
  LngErrorCheck( NS(pMqFactoryC_Init) (MQ_RT_CALL module) ) ;
 
  // END-CLASS-DEF - created by 'py_MqS.tcl -i NHI1_HOME/theLink/c/gen/c_mqmsgque.meta' - DO NOT change
 
  // init ENUM
  MK_STR enumCode =
    "from enum import IntEnum, IntFlag\n"
 
  // BEGIN-EnumCode - created by 'py_MqS.tcl -i NHI1_HOME/theLink/c/gen/c_mqmsgque.meta' - DO NOT change
 
    "class MqIdentE(IntEnum):\n"
    "  PREFIX  = 0\n"
    "  FACTORY = 1\n"
  
    "class MqSlaveE(IntEnum):\n"
    "  LOOPBACK = 0\n"
    "  FILTER   = 1\n"
    "  MASTER   = 1\n"
    "  OTHER    = 1\n"
    "  USER     = 10\n"
    "  MAX      = 1024\n"
  
    "class MqStartE(IntEnum):\n"
    "  DEFAULT = 0\n"
    "  FORK    = 1\n"
    "  THREAD  = 2\n"
    "  SPAWN   = 3\n"
  
    "class MqStatusIsEF(IntFlag):\n"
    "  INITIAL = 0\n"
    "  DUP     = 1\n"
    "  THREAD  = 2\n"
    "  FORK    = 4\n"
    "  SPAWN   = 8\n"
  
    "class MqWaitOnEventE(IntEnum):\n"
    "  NO      = 0\n"
    "  ONCE    = 1\n"
    "  OWN     = 2\n"
    "  FOREVER = 3\n"
 
  // END-EnumCode - created by 'py_MqS.tcl -i NHI1_HOME/theLink/c/gen/c_mqmsgque.meta' - DO NOT change
  ;
 
  PyObject *myD, *mainD, *tmpO;
  mainD = PyModule_GetDict(mainM);
  myD   = PyModule_GetDict(module);
  tmpO  = PyRun_String(enumCode, Py_file_input, mainD, myD);
  LngErrorCheckN(tmpO);
  Py_CLEAR(tmpO);
 
  // BEGIN-EnumSet - created by 'py_MqS.tcl -i NHI1_HOME/theLink/c/gen/c_mqmsgque.meta' - DO NOT change
 
  OT_MqIdentE = (PyTypeObject*) Py_NewRef(PyDict_GetItemString(myD,"MqIdentE"));
  OT_MqSlaveE = (PyTypeObject*) Py_NewRef(PyDict_GetItemString(myD,"MqSlaveE"));
  OT_MqStartE = (PyTypeObject*) Py_NewRef(PyDict_GetItemString(myD,"MqStartE"));
  OT_MqStatusIsEF = (PyTypeObject*) Py_NewRef(PyDict_GetItemString(myD,"MqStatusIsEF"));
  OT_MqWaitOnEventE = (PyTypeObject*) Py_NewRef(PyDict_GetItemString(myD,"MqWaitOnEventE"));
 
  // END-EnumSet - created by 'py_MqS.tcl -i NHI1_HOME/theLink/c/gen/c_mqmsgque.meta' - DO NOT change
 
  // every new thread source the script
  // "from pymqmsgque import" is calling "PyInit_pymqmsgque"
  // → check if we on "thread" : __name__=__main__
 
  // only ONCE on INITIAL setup
  if (strcmp(PyModule_GetName(mainM),"__main__") == 0) {
 
    // set the thread startup 
    //save_SysServerThread = MqLal.SysServerThread;
    //MqLal.SysServerThread = NS(PyServerThread);
    //MkLal.SysExit = NS(PyExit);
 
    // init libmqmsgque global data
    if (MqInitGetArg0() == NULL && Py_GetProgramName() != NULL) {
      char *py = Py_EncodeLocale(Py_GetProgramName(),NULL);
 
      PyObject *sysO = PyImport_ImportModule("sys");
      LngErrorCheckN(sysO);
      PyObject *argvO = PyObject_GetAttrString(sysO, "argv");
      LngErrorCheckN(argvO);
      PyObject *itmO = PyList_GetItem(argvO, 0);
      LngErrorCheckN(itmO);
 
      MqInitSetArg0VA(py, PyUnicode_AsUTF8(itmO), NULL);
 
      Py_CLEAR(argvO);
      Py_CLEAR(sysO);
      PyMem_Free(py);
    }
 
    // create the default-factory
    LngErrorCheck (NS(pMqFactoryC_Setup) (MQ_RT_CALL module));
  }
 
  //PyErr_SetString(PyExc_RuntimeError,"this is a test");
 
//mk_debug_color(MK_BLUE,"END module<%p>",module);
  return 0;
error:
  return -1;
}

py_mqmsgque_sMqMsgqueFree()

static void py_mqmsgque_sMqMsgqueFree ( void * module )

static

Definition at line 768 of file LibMqMsgque_py.c.

{
myTrace("FREE")
  NS(sMqMsgqueStateS) *state = NS(sMqMsgqueGetState)(module);
  NS(sMqMsgqueClear)((PyObject *)module);
  if (state && state->mkrt) {
    state->mkrt->threadData = NULL;
    state->mkrt=NULL;
  }
}

py_mqmsgque_sMqMsgqueGetState()

static MK_UNUSED py_mqmsgque_sMqMsgqueStateS * py_mqmsgque_sMqMsgqueGetState ( PyObject * module )

inlinestatic

Definition at line 702 of file LibMqMsgque_py.c.

{
  void *state = PyModule_GetState(module);
  assert(state != NULL);
  return (NS(sMqMsgqueStateS)*)state;
}

py_mqmsgque_sMqMsgqueTraverse()

static MK_UNUSED int py_mqmsgque_sMqMsgqueTraverse ( PyObject * module, visitproc visit, void * arg )

static

Definition at line 718 of file LibMqMsgque_py.c.

{
myTrace("TRAVERSE")
 
  // BEGIN-EnumTraverse - created by 'py_MqS.tcl -i NHI1_HOME/theLink/c/gen/c_mqmsgque.meta' - DO NOT change
 
  Py_VISIT(OT_MqIdentE);
  Py_VISIT(OT_MqSlaveE);
  Py_VISIT(OT_MqStartE);
  Py_VISIT(OT_MqStatusIsEF);
  Py_VISIT(OT_MqWaitOnEventE);
 
  // END-EnumTraverse - created by 'py_MqS.tcl -i NHI1_HOME/theLink/c/gen/c_mqmsgque.meta' - DO NOT change
  // BEGIN-ClassTraverse - created by 'py_MqS.tcl -i NHI1_HOME/theLink/c/gen/c_mqmsgque.meta' - DO NOT change
 
  Py_VISIT(MqDumpC_MK_NULL);
  Py_VISIT(MqContextC_MK_NULL);
  Py_VISIT(MqFactoryC_MK_NULL);
 
  // END-ClassTraverse - created by 'py_MqS.tcl -i NHI1_HOME/theLink/c/gen/c_mqmsgque.meta' - DO NOT change
 
  return 0;
}

PyInit_pymqmsgque()

PyMODINIT_FUNC PyInit_pymqmsgque

(

void

)

Public API

Definition at line 933 of file LibMqMsgque_py.c.

{
  // Multi-phase initialization
  return PyModuleDef_Init(&NS(sMqMsgqueDef));
}

typeof()

static typeof ( MqLal. SysServerThread )

static

Variable Documentation

num

MK_UNUSED int num = 0

static

Definition at line 651 of file LibMqMsgque_py.c.

py_mqmsgque_MqMsgqueThreadState

MkThreadLocal MqMsgqueThreadStateS py_mqmsgque_MqMsgqueThreadState = {0}

Definition at line 695 of file LibMqMsgque_py.c.

{0};

py_mqmsgque_sMqMsgqueDef

PyModuleDef py_mqmsgque_sMqMsgqueDef

static

Initial value:

= {
  PyModuleDef_HEAD_INIT,
  .m_name     = "pymqmsgque",
  .m_doc      = "python language binding 'MqMsgque'",
  .m_size     = sizeof( py_mqmsgque_sMqMsgqueStateS ),
  .m_methods  =  py_mqmsgque_sMqMsgqueMethods ,
  .m_slots    =  py_mqmsgque_sMqMsgqueDefSlots ,
  .m_traverse =  py_mqmsgque_sMqMsgqueTraverse ,    
  .m_clear    =  py_mqmsgque_sMqMsgqueClear ,
  .m_free     =  py_mqmsgque_sMqMsgqueFree ,
}

Definition at line 913 of file LibMqMsgque_py.c.

                                      {
  PyModuleDef_HEAD_INIT,
  .m_name     = "pymqmsgque",
  .m_doc      = "python language binding 'MqMsgque'",
  .m_size     = sizeof(NS(sMqMsgqueStateS)),
  .m_methods  = NS(sMqMsgqueMethods),
  .m_slots    = NS(sMqMsgqueDefSlots),
  .m_traverse = NS(sMqMsgqueTraverse),    // garbage collection
  .m_clear    = NS(sMqMsgqueClear),
  .m_free     = NS(sMqMsgqueFree),
};

py_mqmsgque_sMqMsgqueDefSlots

MK_UNUSED PyModuleDef_Slot py_mqmsgque_sMqMsgqueDefSlots[]

static

Initial value:

= {
  {Py_mod_exec,  py_mqmsgque_sMqMsgqueExec },
  {Py_mod_multiple_interpreters, Py_MOD_PER_INTERPRETER_GIL_SUPPORTED},
  {0, NULL}
}

Definition at line 907 of file LibMqMsgque_py.c.

                                                            {
  {Py_mod_exec, NS(sMqMsgqueExec)},
  {Py_mod_multiple_interpreters, Py_MOD_PER_INTERPRETER_GIL_SUPPORTED},
  {0, NULL}
};

py_mqmsgque_sMqMsgqueMethods

PyMethodDef py_mqmsgque_sMqMsgqueMethods[]

static

Type definition

Definition at line 600 of file LibMqMsgque_py.c.

                                            {
 
  // BEGIN-CLASS - created by 'py_MqS.tcl -i NHI1_HOME/theLink/c/gen/c_mqmsgque.meta' - DO NOT change
 
    // doc-key: MqMsgque,EnumFunc,sco
    { "IdentE_FromInt"        , (PyCFunction) NS(MqMsgque_IdentE_FromInt)        , METH_O       , IdentE_FromInt_doc },
    { "SlaveE_FromInt"        , (PyCFunction) NS(MqMsgque_SlaveE_FromInt)        , METH_O       , SlaveE_FromInt_doc },
    { "StartE_FromInt"        , (PyCFunction) NS(MqMsgque_StartE_FromInt)        , METH_O       , StartE_FromInt_doc },
    { "StatusIsEF_FromInt"    , (PyCFunction) NS(MqMsgque_StatusIsEF_FromInt)    , METH_O       , StatusIsEF_FromInt_doc },
    { "WaitOnEventE_FromInt"  , (PyCFunction) NS(MqMsgque_WaitOnEventE_FromInt)  , METH_O       , WaitOnEventE_FromInt_doc },
    
    // doc-key: MqMsgque,EnumFunc,sm_
    { "IdentE_ToInt"          , (PyCFunction) NS(MqMsgque_IdentE_ToInt)          , METH_O       , IdentE_ToInt_doc },
    { "IdentE_ToString"       , (PyCFunction) NS(MqMsgque_IdentE_ToString)       , METH_O       , IdentE_ToString_doc },
    { "SlaveE_ToInt"          , (PyCFunction) NS(MqMsgque_SlaveE_ToInt)          , METH_O       , SlaveE_ToInt_doc },
    { "SlaveE_ToString"       , (PyCFunction) NS(MqMsgque_SlaveE_ToString)       , METH_O       , SlaveE_ToString_doc },
    { "StartE_ToInt"          , (PyCFunction) NS(MqMsgque_StartE_ToInt)          , METH_O       , StartE_ToInt_doc },
    { "StartE_ToString"       , (PyCFunction) NS(MqMsgque_StartE_ToString)       , METH_O       , StartE_ToString_doc },
    { "StatusIsEF_ToInt"      , (PyCFunction) NS(MqMsgque_StatusIsEF_ToInt)      , METH_O       , StatusIsEF_ToInt_doc },
    { "StatusIsEF_ToString"   , (PyCFunction) NS(MqMsgque_StatusIsEF_ToString)   , METH_O       , StatusIsEF_ToString_doc },
    { "WaitOnEventE_ToInt"    , (PyCFunction) NS(MqMsgque_WaitOnEventE_ToInt)    , METH_O       , WaitOnEventE_ToInt_doc },
    { "WaitOnEventE_ToString" , (PyCFunction) NS(MqMsgque_WaitOnEventE_ToString) , METH_O       , WaitOnEventE_ToString_doc },
    
    // doc-key: MqMsgque,MqHelp,sm_
    { "Help"                  , (PyCFunction) NS(MqMsgque_Help)                  , METH_O       , Help_doc },
    { "HelpMsgque"            , (PyCFunction) NS(MqMsgque_HelpMsgque)            , METH_NOARGS  , HelpMsgque_doc },
    
    // doc-key: MqMsgque,MqInit,sm_
    { "InitGetArg0"           , (PyCFunction) NS(MqMsgque_InitGetArg0)           , METH_NOARGS  , InitGetArg0_doc },
    { "InitResetArg0"         , (PyCFunction) NS(MqMsgque_InitResetArg0)         , METH_NOARGS  , InitResetArg0_doc },
    { "InitSetArg0"           , (PyCFunction) NS(MqMsgque_InitSetArg0)           , METH_VARARGS , InitSetArg0_doc },
    
    // doc-key: MqMsgque,Setup,sm_
    { "Cleanup"               , (PyCFunction) NS(MqMsgque_Cleanup)               , METH_NOARGS  , Cleanup_doc },
    { "Setup"                 , (PyCFunction) NS(MqMsgque_Setup)                 , METH_NOARGS  , Setup_doc },
 
  // END-CLASS - created by 'py_MqS.tcl -i NHI1_HOME/theLink/c/gen/c_mqmsgque.meta' - DO NOT change
 
  // BEGIN-OBJ - created by 'py_MqS.tcl -i NHI1_HOME/theLink/c/gen/c_mqmsgque.meta' - DO NOT change
 
// → no data
 
  // END-OBJ - created by 'py_MqS.tcl -i NHI1_HOME/theLink/c/gen/c_mqmsgque.meta' - DO NOT change
 
    {NULL, NULL, 0, NULL}        /* Sentinel */
};