LibMqMsgque_py.c File Reference

tag: nhi1-release-250425 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	pymqmsgque_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	pymqmsgque_pMqFactoryC_Setup (MK_RT mkrt, OT_OBJ_T)
enum MkErrorE	pymqmsgque_CheckConstructor (OT_Check_ARGS, MK_CCP *retP)
static OT_ProcRet	pymqmsgque_MqMsgque_IdentE_FromInt (OtClass_ARGS)
	Python: [static] MqIdentE IdentE_FromInt(value:int32) → C-API return the MqIdentE from integer …
static OT_ProcRet	pymqmsgque_MqMsgque_SlaveE_FromInt (OtClass_ARGS)
	Python: [static] MqSlaveE SlaveE_FromInt(value:int32) → C-API return the MqSlaveE from integer …
static OT_ProcRet	pymqmsgque_MqMsgque_StartE_FromInt (OtClass_ARGS)
	Python: [static] MqStartE StartE_FromInt(value:int32) → C-API return the MqStartE from integer …
static OT_ProcRet	pymqmsgque_MqMsgque_StatusIsEF_FromInt (OtClass_ARGS)
	Python: [static] MqStatusIsEF StatusIsEF_FromInt(value:int32) → C-API return the MqStatusIsEF from integer …
static OT_ProcRet	pymqmsgque_MqMsgque_WaitOnEventE_FromInt (OtClass_ARGS)
	Python: [static] MqWaitOnEventE WaitOnEventE_FromInt(value:int32) → C-API return the MqWaitOnEventE from integer …
static OT_ProcRet	pymqmsgque_MqMsgque_IdentE_ToInt (OtClass_ARGS)
	Python: [static] int32 IdentE_ToInt(value:MqIdentE) → C-API return the MqIdentE as integer …
static OT_ProcRet	pymqmsgque_MqMsgque_IdentE_ToString (OtClass_ARGS)
	Python: [static] string IdentE_ToString(value:MqIdentE) → C-API return the MqIdentE as string …
static OT_ProcRet	pymqmsgque_MqMsgque_SlaveE_ToInt (OtClass_ARGS)
	Python: [static] int32 SlaveE_ToInt(value:MqSlaveE) → C-API return the MqSlaveE as integer …
static OT_ProcRet	pymqmsgque_MqMsgque_SlaveE_ToString (OtClass_ARGS)
	Python: [static] string SlaveE_ToString(value:MqSlaveE) → C-API return the MqSlaveE as string …
static OT_ProcRet	pymqmsgque_MqMsgque_StartE_ToInt (OtClass_ARGS)
	Python: [static] int32 StartE_ToInt(value:MqStartE) → C-API return the MqStartE as integer …
static OT_ProcRet	pymqmsgque_MqMsgque_StartE_ToString (OtClass_ARGS)
	Python: [static] string StartE_ToString(value:MqStartE) → C-API return the MqStartE as string …
static OT_ProcRet	pymqmsgque_MqMsgque_StatusIsEF_ToInt (OtClass_ARGS)
	Python: [static] int32 StatusIsEF_ToInt(value:MqStatusIsEF) → C-API return the MqStatusIsEF as integer …
static OT_ProcRet	pymqmsgque_MqMsgque_StatusIsEF_ToString (OtClass_ARGS)
	Python: [static] string StatusIsEF_ToString(value:MqStatusIsEF) → C-API return the MqStatusIsEF as string …
static OT_ProcRet	pymqmsgque_MqMsgque_WaitOnEventE_ToInt (OtClass_ARGS)
	Python: [static] int32 WaitOnEventE_ToInt(value:MqWaitOnEventE) → C-API return the MqWaitOnEventE as integer …
static OT_ProcRet	pymqmsgque_MqMsgque_WaitOnEventE_ToString (OtClass_ARGS)
	Python: [static] string WaitOnEventE_ToString(value:MqWaitOnEventE) → C-API return the MqWaitOnEventE as string …
static OT_ProcRet	pymqmsgque_MqMsgque_Help (OtClass_ARGS)
	Python: [static] string Help(tool:string) → C-API write pymqmsgque specific user-help to stderr
static OT_ProcRet	pymqmsgque_MqMsgque_HelpMsgque (OtClass_ARGS)
	Python: [static] string HelpMsgque() → C-API return a page with the usage of all pymqmsgque specific options
static OT_ProcRet	pymqmsgque_MqMsgque_InitGetArg0 (OtClass_ARGS)
	Python: [static] MkBufferListC InitGetArg0() → C-API get the process startup-prefix argument
static OT_ProcRet	pymqmsgque_MqMsgque_InitResetArg0 (OtClass_ARGS)
	Python: [static] MkBufferListC InitResetArg0() → C-API Reset the process-startup-prefix argument to an empty list …
static OT_ProcRet	pymqmsgque_MqMsgque_InitSetArg0 (OtClass_ARGS)
	Python: [static] InitSetArg0(?bfl:MkBufferListC...=None?) → C-API set the process startup-prefix argument to bfl
static OT_ProcRet	pymqmsgque_MqMsgque_Cleanup (OtClass_ARGS)
	Python: [static] Cleanup() → C-API cleanup pymqmsgque internal memory …
static OT_ProcRet	pymqmsgque_MqMsgque_Setup (OtClass_ARGS)
	Python: [static] Setup() → C-API setup pymqmsgque internal memory …
static	typeof (MqLal.MqSysServerThreadCB) save_MqSysServerThreadF
static MK_UNUSED enum MkErrorE	pymqmsgque_PyServerThread (MK_RT mkrt, MQ_CTX const context, struct MqSysServerThreadMainS *const argP, MK_STRN name, int thread_status, struct MkIdS *idP)
static MK_UNUSED pymqmsgque_sMqMsgqueStateS *	pymqmsgque_sMqMsgqueGetState (PyObject *module)
static MK_UNUSED int	pymqmsgque_sMqMsgqueTraverse (PyObject *module, visitproc visit, void *arg)
static MK_UNUSED int	pymqmsgque_sMqMsgqueClear (PyObject *module)
static void	pymqmsgque_sMqMsgqueFree (void *module)
static int	pymqmsgque_sMqMsgqueExec (PyObject *module)
PyMODINIT_FUNC	LibMqMsgque (void)

Variables
static PyMethodDef	pymqmsgque_sMqMsgqueMethods []
static MK_UNUSED int	num = 0
__thread MqMsgqueThreadStateS	pymqmsgque_MqMsgqueThreadState = {0}
static MK_UNUSED PyModuleDef_Slot	pymqmsgque_sMqMsgqueDefSlots []
static PyModuleDef	pymqmsgque_sMqMsgqueDef

Detailed Description

tag: nhi1-release-250425

Copyright

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

Definition in file LibMqMsgque_py.c.

Macro Definition Documentation

Cleanup_doc

#define Cleanup_doc   "Cleanup()"

Definition at line 164 of file LibMqMsgque_py.c.

Debug_doc

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

Definition at line 169 of file LibMqMsgque_py.c.

Help_doc

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

Definition at line 155 of file LibMqMsgque_py.c.

HelpMsgque_doc

#define HelpMsgque_doc   "string HelpMsgque()"

Definition at line 156 of file LibMqMsgque_py.c.

IdentE_FromInt_doc

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

doc definition

Definition at line 136 of file LibMqMsgque_py.c.

IdentE_ToInt_doc

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

Definition at line 143 of file LibMqMsgque_py.c.

IdentE_ToString_doc

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

Definition at line 144 of file LibMqMsgque_py.c.

InitGetArg0_doc

#define InitGetArg0_doc   "MkBufferListC InitGetArg0()"

Definition at line 159 of file LibMqMsgque_py.c.

InitResetArg0_doc

#define InitResetArg0_doc   "MkBufferListC InitResetArg0()"

Definition at line 160 of file LibMqMsgque_py.c.

InitSetArg0_doc

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

Definition at line 161 of file LibMqMsgque_py.c.

MqCleanupTmpl

#define MqCleanupTmpl

(

)

Definition at line 20 of file LibMqMsgque_py.c.

MqSetupTmpl

#define MqSetupTmpl

(

)

Definition at line 19 of file LibMqMsgque_py.c.

myTrace

#define myTrace

(

str

)

Definition at line 703 of file LibMqMsgque_py.c.

myTrace2

#define myTrace2	(		col,
			str )

Definition at line 702 of file LibMqMsgque_py.c.

OT_SETUP_hdl

#define OT_SETUP_hdl

Value:

                                AllRtSetup_NULL; \
                                MK_OBJ hdl = MK_ERROR_PRINT;

Definition at line 14 of file LibMqMsgque_py.c.

#define OT_SETUP_hdl            AllRtSetup_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 16 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 165 of file LibMqMsgque_py.c.

SlaveE_FromInt_doc

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

Definition at line 137 of file LibMqMsgque_py.c.

SlaveE_ToInt_doc

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

Definition at line 145 of file LibMqMsgque_py.c.

SlaveE_ToString_doc

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

Definition at line 146 of file LibMqMsgque_py.c.

StartE_FromInt_doc

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

Definition at line 138 of file LibMqMsgque_py.c.

StartE_ToInt_doc

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

Definition at line 147 of file LibMqMsgque_py.c.

StartE_ToString_doc

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

Definition at line 148 of file LibMqMsgque_py.c.

StatusIsEF_FromInt_doc

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

Definition at line 139 of file LibMqMsgque_py.c.

StatusIsEF_ToInt_doc

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

Definition at line 149 of file LibMqMsgque_py.c.

StatusIsEF_ToString_doc

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

Definition at line 150 of file LibMqMsgque_py.c.

WaitOnEventE_FromInt_doc

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

Definition at line 140 of file LibMqMsgque_py.c.

WaitOnEventE_ToInt_doc

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

Definition at line 151 of file LibMqMsgque_py.c.

WaitOnEventE_ToString_doc

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

Definition at line 152 of file LibMqMsgque_py.c.

Function Documentation

LibMqMsgque()

PyMODINIT_FUNC LibMqMsgque

(

void

)

Public API

Definition at line 920 of file LibMqMsgque_py.c.

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

pymqmsgque_CheckConstructor()

enum MkErrorE pymqmsgque_CheckConstructor	(	OT_Check_ARGS	,
		MK_CCP *	retP )

Definition at line 179 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_OBJ_T)&NS(MqContextCR)) == 1) {
    Py_INCREF(objV);
    *retP = (MK_CCP)objV;
  } else if (PyObject_IsSubclass(objV,(OT_OBJ_T)&MK(MkObjectCR)) == 1) {
    WrongTypeOfArgError(OT_LNG_NAME_FROM_CLASS(&NS(MqContextCR)), OT_LNG_NAME_FROM_CLASS((OT_CLS_T)objV));
  } else {
    WrongTypeOfArgError(OT_LNG_NAME_FROM_CLASS(&NS(MqContextCR)), OT_OBJ_TYPE_STRING(objV));
  }
  return MK_OK;
error:
  return OT_ERROR_STACK;
}

pymqmsgque_pMqFactoryC_Setup()

int pymqmsgque_pMqFactoryC_Setup	(	MK_RT	mkrt,
		OT_OBJ_T	)

pymqmsgque_PyServerThread()

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

static

Definition at line 642 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_MqSysServerThreadF)(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;
}

pymqmsgque_sMqMsgqueClear()

static MK_UNUSED int pymqmsgque_sMqMsgqueClear ( PyObject * module )

static

Definition at line 732 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(MqIdentE_lngO);
  Py_CLEAR(MqSlaveE_lngO);
  Py_CLEAR(MqStartE_lngO);
  Py_CLEAR(MqStatusIsEF_lngO);
  Py_CLEAR(MqWaitOnEventE_lngO);
 
  // 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(MqFactoryC_MK_NULL);
  Py_CLEAR(MqDumpC_MK_NULL);
  Py_CLEAR(MqContextC_MK_NULL);
 
  // END-ClassClear - created by 'py_MqS.tcl -i NHI1_HOME/theLink/c/gen/c_mqmsgque.meta' - DO NOT change
 
  return 0;
}

pymqmsgque_sMqMsgqueExec()

static int pymqmsgque_sMqMsgqueExec ( PyObject * module )

static

Definition at line 769 of file LibMqMsgque_py.c.

{
myTrace2(MK_COLOR_BLUE,"START")
//printV("#1 PyThreadState_Get<%p>", PyThreadState_Get())
 
  MqSetup();
  MkRtSetup_NULL;
 
  NS(sMqMsgqueStateS) *state = NS(sMqMsgqueGetState)(module);
  state->mkrt = MK_RT_PTR;
 
  PyObject *mainM = PyImport_AddModule("__main__");
 
  PyObject *mkM;
  LngErrorCheckN(mkM = PyImport_ImportModule("pymkkernel"));
  OtErrorCheckLng(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
 
  OtErrorCheckLng( NS(pMqFactoryC_Init) (MK_RT_CALL module) ) ;
  OtErrorCheckLng( NS(pMqDumpC_Init)    (MK_RT_CALL module) ) ;
  OtErrorCheckLng( NS(pMqContextC_Init) (MK_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
 
  MqIdentE_lngO = (PyTypeObject*) Py_NewRef(PyDict_GetItemString(myD,"MqIdentE"));
  MqSlaveE_lngO = (PyTypeObject*) Py_NewRef(PyDict_GetItemString(myD,"MqSlaveE"));
  MqStartE_lngO = (PyTypeObject*) Py_NewRef(PyDict_GetItemString(myD,"MqStartE"));
  MqStatusIsEF_lngO = (PyTypeObject*) Py_NewRef(PyDict_GetItemString(myD,"MqStatusIsEF"));
  MqWaitOnEventE_lngO = (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_MqSysServerThreadF = 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
    OtErrorCheckLng (NS(pMqFactoryC_Setup) (MK_RT_CALL module));
  }
 
  //PyErr_SetString(PyExc_RuntimeError,"this is a test");
 
//mk_dbg_color_ln(MK_COLOR_BLUE,"END module<%p>",module);
  return 0;
error:
  return -1;
}

pymqmsgque_sMqMsgqueFree()

static void pymqmsgque_sMqMsgqueFree ( void * module )

static

Definition at line 757 of file LibMqMsgque_py.c.

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

pymqmsgque_sMqMsgqueGetState()

static MK_UNUSED pymqmsgque_sMqMsgqueStateS * pymqmsgque_sMqMsgqueGetState ( PyObject * module )

inlinestatic

Definition at line 691 of file LibMqMsgque_py.c.

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

pymqmsgque_sMqMsgqueTraverse()

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

static

Definition at line 707 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(MqIdentE_lngO);
  Py_VISIT(MqSlaveE_lngO);
  Py_VISIT(MqStartE_lngO);
  Py_VISIT(MqStatusIsEF_lngO);
  Py_VISIT(MqWaitOnEventE_lngO);
 
  // 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(MqFactoryC_MK_NULL);
  Py_VISIT(MqDumpC_MK_NULL);
  Py_VISIT(MqContextC_MK_NULL);
 
  // END-ClassTraverse - created by 'py_MqS.tcl -i NHI1_HOME/theLink/c/gen/c_mqmsgque.meta' - DO NOT change
 
  return 0;
}

typeof()

static typeof ( MqLal. MqSysServerThreadCB )

static

Variable Documentation

num

MK_UNUSED int num = 0

static

Definition at line 640 of file LibMqMsgque_py.c.

pymqmsgque_MqMsgqueThreadState

__thread MqMsgqueThreadStateS pymqmsgque_MqMsgqueThreadState = {0}

Definition at line 684 of file LibMqMsgque_py.c.

{0};

pymqmsgque_sMqMsgqueDef

PyModuleDef pymqmsgque_sMqMsgqueDef

static

Initial value:

= {
  PyModuleDef_HEAD_INIT,
  .m_name     = "pymqmsgque",
  .m_doc      = "python language binding for 'theLink'",
  .m_size     = sizeof( pymqmsgque_sMqMsgqueStateS ),
  .m_methods  =  pymqmsgque_sMqMsgqueMethods ,
  .m_slots    =  pymqmsgque_sMqMsgqueDefSlots ,
  .m_traverse =  pymqmsgque_sMqMsgqueTraverse ,    
  .m_clear    =  pymqmsgque_sMqMsgqueClear ,
  .m_free     =  pymqmsgque_sMqMsgqueFree ,
}

Definition at line 900 of file LibMqMsgque_py.c.

                                      {
  PyModuleDef_HEAD_INIT,
  .m_name     = "pymqmsgque",
  .m_doc      = "python language binding for 'theLink'",
  .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),
};

pymqmsgque_sMqMsgqueDefSlots

MK_UNUSED PyModuleDef_Slot pymqmsgque_sMqMsgqueDefSlots[]

static

Initial value:

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

Definition at line 894 of file LibMqMsgque_py.c.

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

pymqmsgque_sMqMsgqueMethods

PyMethodDef pymqmsgque_sMqMsgqueMethods[]

static

Type definition

Definition at line 589 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 */
};