MqFactoryC_py.c File Reference

MqFactoryC_py.c - 28 Oct 2024 - aotto1968. More...

#include "LibMqMsgque_private_py.h"

Include dependency graph for MqFactoryC_py.c:

Go to the source code of this file.

Macros
#define	META_FILE_NAME   "MqFactoryC_py.c"
#define	OT_CLASS   (&NS(MqFactoryCR))
#define	OT_CLASS_NAME   "MqFactoryC"
#define	OT_LNG2META(O)
#define	OT_retObj_CONSTR(mng)
#define	OT_SETUP_hdl   OT_SETUP_hdl_tmpl(MqFactoryC)
#define	OT_SETUP_hdl__null_allow   OT_SETUP_hdl_tmpl__null_allow(MqFactoryC)
#define	OT_SETUP_hdl_constr
#define	OT_SETUP_hdl_destr   OT_SETUP_hdl_tmpl__null_allow(MqFactoryC)
#define	OT_SETUP_hdl_static
#define	OT_SETUP_hdl_static_constr   OT_SETUP_hdl_static
#define	SetupRtFromObj_X(hdl)
#define	SetupRtFromObj_XN(hdl)
#define	MqFactoryCTT   MQ(MqMsgqueThreadState).MqFactoryCTT
#define	ClassInit
#define	SetupRtFromObj_XN(hdl)
#define	OT_SETUP_hdl
#define	OT_SETUP_hdl_constr
#define	OT_SETUP_hdl_static
#define	OT_SETUP_hdl_static_constr
#define	OT_retObj_RETURN
#define	Add_doc   "MqFactoryC MqFactoryC.Add(constructor:class, ?ident:string=\"MK_NULL\"?)"
#define	new_doc   "MqFactoryC MqFactoryC.new(constructor:class, ?ident:string=\"MK_NULL\"?)"
#define	Get_doc   "MqFactoryC MqFactoryC.Get(?ident:string=\"\"?)"
#define	GetCalled_doc   "MqFactoryC MqFactoryC.GetCalled(?ident:string=\"\"?)"
#define	GetCalledL_doc   "MqFactoryC MqFactoryC.GetCalledL(largs:MkBufferListC)"
#define	GetNull_doc   "MqFactoryC MqFactoryC.GetNull()"
#define	HandleResolve_doc   "MqFactoryC MqFactoryC.HandleResolve(netHdl:MK_HDL)"
#define	Instances_doc   "MqFactoryC MqFactoryC.Instances()"
#define	DefaultIdent_doc   "string MqFactoryC.DefaultIdent()"
#define	InitialIdent_doc   "string MqFactoryC.InitialIdent()"
#define	LogAll_doc   "MqFactoryC.LogAll(?callfunc:string=\"MK_NULL\"?)"
#define	Dup2_doc   "MqFactoryC fct.Dup2(ident:string) (const)"
#define	Default_doc   "MqFactoryC fct.Default()"
#define	Initial_doc   "MqFactoryC fct.Initial()"
#define	Next_doc   "MqFactoryC fct.Next()"
#define	Prev_doc   "MqFactoryC fct.Prev()"
#define	New_doc   "MqContextC fct.New()"
#define	GetOriginalIdent_doc   "string fct.GetOriginalIdent() (const)"
#define	HandleGet_doc   "MK_HDL fct.HandleGet()"
#define	Log_doc   "fct.Log(?fmtobj:MkObjectC=None?, ?debug:int32=0?, ?callfunc:string=\"MK_NULL\"?, ?lvl:int32=0?) (const)"

Functions
OT_LNG_T	py_mqmsgque_MqFactoryC_CTOR (MK_RT mkrt, OT_LNG_CLASS_T type, MQ_FCT hdl)
static MK_PTR	py_mqmsgque_MqFactoryC_selfCreate (MK_RT mkrt, MK_OBJ const obj, MK_PTR const env)
static void	py_mqmsgque_MqFactoryC_selfDelete (MK_RT mkrt, MK_PTR self, MK_PTR const env)
static void	py_mqmsgque_MqFactoryC_selfUnlink (MK_RT mkrt, MK_PTR self, MK_PTR const env)
static enum MkErrorE	py_mqmsgque_sFactoryCTor (MQ_CALLBACK_FACTORY_CTOR_ARGS)
static void	py_mqmsgque_sFactoryDTor (MK_RT mkrt, MQ_CTX context, bool doFactoryDelete, MQ_FCT const data)
static void	py_mqmsgque_sFactoryDataFree (MK_RT mkrt, MK_PTR *dataP)
static void	py_mqmsgque_sFactoryDataCopy (MK_RT mkrt, MK_PTR *dataP)
static OT_ProcRet	py_mqmsgque_MqFactoryC_HandleResolve (OtClass_ARGS)
	Python: [static] MqFactoryC MqFactoryC.HandleResolve(netHdl:MK_HDL) → C-API Handle-Resolve-Slot - return a MqFactoryC from netHdl or None if invalid…
static OT_ProcRet	py_mqmsgque_MqFactoryC_Next (MqFactoryC_ARGS)
	Python: MqFactoryC fct.Next() → C-API get next instance from linked-list of MqFactoryS type
static OT_ProcRet	py_mqmsgque_MqFactoryC_Prev (MqFactoryC_ARGS)
	Python: MqFactoryC fct.Prev() → C-API get previous instance from linked-list of MqFactoryS type
static OT_ProcRet	py_mqmsgque_MqFactoryC_Instances (OtClass_ARGS)
	Python: [static] MqFactoryC MqFactoryC.Instances() → C-API get head-instance from linked-list of MqFactoryS type …
static OT_ProcRet	py_mqmsgque_MqFactoryC_GetNull (OtClass_ARGS)
	Python: [static] MqFactoryC MqFactoryC.GetNull() → C-API Null-Slot - return a MqFactoryC typed NULL instance …
static OT_ProcRet	py_mqmsgque_MqFactoryC_Get (OtClass_ARGS)
	Python: [static] MqFactoryC MqFactoryC.Get(?ident:string=""?) → C-API return the MqFactoryC
static OT_ProcRet	py_mqmsgque_MqFactoryC_GetCalled (OtClass_ARGS)
	Python: [static] MqFactoryC MqFactoryC.GetCalled(?ident:string=""?) → C-API returns the MqFactoryC identified by ident …
static OT_ProcRet	py_mqmsgque_MqFactoryC_GetCalledL (OtClass_ARGS)
	Python: [static] MqFactoryC MqFactoryC.GetCalledL(largs:MkBufferListC) → C-API returns the MqFactoryC identified as first argument in the largs MkBufferListC …
static OT_ProcRet	py_mqmsgque_MqFactoryC_GetOriginalIdent (MqFactoryC_ARGS)
	Python: string fct.GetOriginalIdent() → C-API helper function to return MqFactoryS::originalIdent
static OT_ProcRet	py_mqmsgque_MqFactoryC_Default (MqFactoryC_ARGS)
	Python: MqFactoryC fct.Default() → C-API set the default-attribute to the factory …
static OT_ProcRet	py_mqmsgque_MqFactoryC_Initial (MqFactoryC_ARGS)
	Python: MqFactoryC fct.Initial() → C-API set the initial-attribut to fct …
static OT_ProcRet	py_mqmsgque_MqFactoryC_New (MqFactoryC_ARGS)
	Python: MqContextC fct.New() → C-API create a new MqContextC from a MqFactoryC …
static OT_ProcRet	py_mqmsgque_MqFactoryC_DefaultIdent (OtClass_ARGS)
	Python: [static] string MqFactoryC.DefaultIdent() → C-API return the factory-identifier of the default MqFactoryC
static OT_ProcRet	py_mqmsgque_MqFactoryC_InitialIdent (OtClass_ARGS)
	Python: [static] string MqFactoryC.InitialIdent() → C-API return the factory-identifier of the initial MqFactoryC
static OT_ProcRet	py_mqmsgque_MqFactoryC_LogAll (OtClass_ARGS)
	Python: [static] MqFactoryC.LogAll(?callfunc:string="MK_NULL"?) → C-API log all "factories" to stderr
static OT_ProcRet	py_mqmsgque_MqFactoryC_Dup2 (MqFactoryC_ARGS)
	Python: [constructor] MqFactoryC fct.Dup2(ident:string) → C-API create a duplicate of the singleton object MqFactoryC using a new factory-identifer
static OT_ProcRet	py_mqmsgque_MqFactoryC_Add (OtClass_ARGS)
	Python: [constructor,static] MqFactoryC MqFactoryC.Add(constructor:class, ?ident:string="MK_NULL"?) → C-API add a new MqFactoryC identified by factory-identifier and defined by factory-constructor …
static OT_ProcRet	py_mqmsgque_MqFactoryC_new (CONSTR_ARGS)
	Python: [constructor,static] MqFactoryC MqFactoryC.new(constructor:class, ?ident:string="MK_NULL"?) → C-API add a new MqFactoryC identified by factory-identifier and defined by factory-constructor …
static PyObject *	py_mqmsgque_sMqFactoryC_Str (MqFactoryC_Obj *self)
int	py_mqmsgque_pMqFactoryC_Setup (MQ_RT_ARGS OT_LNG_T m)
int	py_mqmsgque_pMqFactoryC_Init (MQ_RT_ARGS OT_LNG_T m)

Variables
static PyMethodDef	py_mqmsgque_MqFactoryC_Methods []
OT_CLASS_TYPE_REF	py_mqmsgque_MqFactoryCR

Detailed Description

MqFactoryC_py.c - 28 Oct 2024 - aotto1968.

Copyright

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

Version

4e6c32f3af53681cacea88a16b83548bfa0ad66f

Date

Mon Oct 28 23:08:55 2024 +0100

Author

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

Definition in file MqFactoryC_py.c.

Macro Definition Documentation

Add_doc

#define Add_doc   "MqFactoryC MqFactoryC.Add(constructor:class, ?ident:string=\"MK_NULL\"?)"

doc definition

Definition at line 129 of file MqFactoryC_py.c.

ClassInit

#define ClassInit

Value:

  /* if not already done, initialize NEW MQ type */ \
  if (MqFactoryCTT == NULL) MqFactoryCTT = MqFactorySTT; \
  \
  /* protect against double call */ \
  if (MqFactoryCTT->selfCreate == NS(MqFactoryC_selfCreate)) return MK_OK; \
  \
  /* add "selfCreate" and "selfDelete" feature to the MQ-Class */ \
  MqFactoryCTT->selfCreate    = NS(MqFactoryC_selfCreate); \
  MqFactoryCTT->selfDelete    = NS(MqFactoryC_selfDelete); \
  MqFactoryCTT->selfUnlink    = NS(MqFactoryC_selfUnlink); \
  \
  if (!PyType_HasFeature(OT_CLASS,Py_TPFLAGS_READY)) { \
    NS(MqFactoryCR).tp_base = OT_MqFactoryC_base; \
    LngErrorCheck (PyType_Ready(OT_CLASS)); \
  } \
  LngErrorCheck(PyModule_AddObjectRef(m, "MqFactoryC", (PyObject *)OT_CLASS)); \
  \
  /* define the "NULL" object */ \
  MqFactoryC_MK_NULL = Py_NewRef(MK(AtomCreate) (MK_RT_CALL OT_CLASS, NULL /*obj*/, false));

Definition at line 68 of file MqFactoryC_py.c.

#define   ClassInit \
  /* if not already done, initialize NEW MQ type */ \
  if (MqFactoryCTT == NULL) MqFactoryCTT = MqFactorySTT; \
  \
  /* protect against double call */ \
  if (MqFactoryCTT->selfCreate == NS(MqFactoryC_selfCreate)) return MK_OK; \
  \
  /* add "selfCreate" and "selfDelete" feature to the MQ-Class */ \
  MqFactoryCTT->selfCreate    = NS(MqFactoryC_selfCreate); \
  MqFactoryCTT->selfDelete    = NS(MqFactoryC_selfDelete); \
  MqFactoryCTT->selfUnlink    = NS(MqFactoryC_selfUnlink); \
  \
  if (!PyType_HasFeature(OT_CLASS,Py_TPFLAGS_READY)) { \
    NS(MqFactoryCR).tp_base = OT_MqFactoryC_base; \
    LngErrorCheck (PyType_Ready(OT_CLASS)); \
  } \
  LngErrorCheck(PyModule_AddObjectRef(m, "MqFactoryC", (PyObject *)OT_CLASS)); \
  \
  /* define the "NULL" object */ \
  MqFactoryC_MK_NULL = Py_NewRef(MK(AtomCreate) (MK_RT_CALL OT_CLASS, NULL /*obj*/, false));

Default_doc

#define Default_doc   "MqFactoryC fct.Default()"

Definition at line 149 of file MqFactoryC_py.c.

DefaultIdent_doc

#define DefaultIdent_doc   "string MqFactoryC.DefaultIdent()"

Definition at line 141 of file MqFactoryC_py.c.

Dup2_doc

#define Dup2_doc   "MqFactoryC fct.Dup2(ident:string) (const)"

Definition at line 146 of file MqFactoryC_py.c.

Get_doc

#define Get_doc   "MqFactoryC MqFactoryC.Get(?ident:string=\"\"?)"

Definition at line 133 of file MqFactoryC_py.c.

GetCalled_doc

#define GetCalled_doc   "MqFactoryC MqFactoryC.GetCalled(?ident:string=\"\"?)"

Definition at line 134 of file MqFactoryC_py.c.

GetCalledL_doc

#define GetCalledL_doc   "MqFactoryC MqFactoryC.GetCalledL(largs:MkBufferListC)"

Definition at line 135 of file MqFactoryC_py.c.

GetNull_doc

#define GetNull_doc   "MqFactoryC MqFactoryC.GetNull()"

Definition at line 136 of file MqFactoryC_py.c.

GetOriginalIdent_doc

#define GetOriginalIdent_doc   "string fct.GetOriginalIdent() (const)"

Definition at line 158 of file MqFactoryC_py.c.

HandleGet_doc

#define HandleGet_doc   "MK_HDL fct.HandleGet()"

Definition at line 159 of file MqFactoryC_py.c.

HandleResolve_doc

#define HandleResolve_doc   "MqFactoryC MqFactoryC.HandleResolve(netHdl:MK_HDL)"

Definition at line 137 of file MqFactoryC_py.c.

Initial_doc

#define Initial_doc   "MqFactoryC fct.Initial()"

Definition at line 150 of file MqFactoryC_py.c.

InitialIdent_doc

#define InitialIdent_doc   "string MqFactoryC.InitialIdent()"

Definition at line 142 of file MqFactoryC_py.c.

Instances_doc

#define Instances_doc   "MqFactoryC MqFactoryC.Instances()"

Definition at line 138 of file MqFactoryC_py.c.

Log_doc

#define Log_doc   "fct.Log(?fmtobj:MkObjectC=None?, ?debug:int32=0?, ?callfunc:string=\"MK_NULL\"?, ?lvl:int32=0?) (const)"

Definition at line 160 of file MqFactoryC_py.c.

LogAll_doc

#define LogAll_doc   "MqFactoryC.LogAll(?callfunc:string=\"MK_NULL\"?)"

Definition at line 143 of file MqFactoryC_py.c.

META_FILE_NAME

#define META_FILE_NAME   "MqFactoryC_py.c"

Definition at line 14 of file MqFactoryC_py.c.

MqFactoryCTT

#define MqFactoryCTT   MQ(MqMsgqueThreadState).MqFactoryCTT

Definition at line 43 of file MqFactoryC_py.c.

New_doc

#define New_doc   "MqContextC fct.New()"

Definition at line 155 of file MqFactoryC_py.c.

new_doc

#define new_doc   "MqFactoryC MqFactoryC.new(constructor:class, ?ident:string=\"MK_NULL\"?)"

Definition at line 130 of file MqFactoryC_py.c.

Next_doc

#define Next_doc   "MqFactoryC fct.Next()"

Definition at line 151 of file MqFactoryC_py.c.

OT_CLASS

#define OT_CLASS   (&NS(MqFactoryCR))

Definition at line 19 of file MqFactoryC_py.c.

OT_CLASS_NAME

#define OT_CLASS_NAME   "MqFactoryC"

Definition at line 20 of file MqFactoryC_py.c.

OT_LNG2META

#define OT_LNG2META

(

O

)

Value:

MqFct(VAL2MNG(O))

Definition at line 22 of file MqFactoryC_py.c.

OT_retObj_CONSTR

#define OT_retObj_CONSTR

(

mng

)

Value:

OT_retObj_SET(NS(MqFactoryC_CTOR)(MK_RT_CALL (PyTypeObject*)class,mng))

Definition at line 24 of file MqFactoryC_py.c.

OT_retObj_RETURN

#define OT_retObj_RETURN

Value:

if (is_constr_hard) {                                                            \
  /* BUG-FIX */                                                                  \
  /* the factory is always global and has NO link to an external variable… */    \
  /* need "Py_INCREF" to keep the factory alive */                               \
  /* test: Nhi1Exec server.py */                                                 \
                                    Py_INCREF (retObj);                          \
}                                                                                \
                                    return ((PyObject*)retObj);

Definition at line 110 of file MqFactoryC_py.c.

#define OT_retObj_RETURN                                                         \
if (is_constr_hard) {                                                            \
  /* BUG-FIX */                                                                  \
  /* the factory is always global and has NO link to an external variable… */    \
  /* need "Py_INCREF" to keep the factory alive */                               \
  /* test: Nhi1Exec server.py */                                                 \
                                    Py_INCREF (retObj);                          \
}                                                                                \
                                    return ((PyObject*)retObj);

OT_SETUP_hdl [1/2]

#define OT_SETUP_hdl   OT_SETUP_hdl_tmpl(MqFactoryC)

Definition at line 26 of file MqFactoryC_py.c.

OT_SETUP_hdl [2/2]

#define OT_SETUP_hdl

Value:

                                    OT_SETUP_hdl_tmpl(MqFactoryC) \
                                    bool is_constr_hard = false;

Definition at line 26 of file MqFactoryC_py.c.

OT_SETUP_hdl__null_allow

#define OT_SETUP_hdl__null_allow   OT_SETUP_hdl_tmpl__null_allow(MqFactoryC)

Definition at line 27 of file MqFactoryC_py.c.

OT_SETUP_hdl_constr [1/2]

#define OT_SETUP_hdl_constr

Value:

                                    MK_RT_UNUSED AllRtSetup_NULL; \
                                    MQ_FCT hdl = (MQ_FCT) &MkERROR;

Definition at line 28 of file MqFactoryC_py.c.

#define OT_SETUP_hdl_constr         MK_RT_UNUSED AllRtSetup_NULL; \
                                    MQ_FCT hdl = (MQ_FCT) &MkERROR;

OT_SETUP_hdl_constr [2/2]

#define OT_SETUP_hdl_constr

Value:

                                    MK_RT_UNUSED AllRtSetup_NULL; \
                                    __attribute__((unused)) MK_TYP hdl = MqFactoryC##_TT; \
                                    bool is_constr_hard = true;

Definition at line 28 of file MqFactoryC_py.c.

#define OT_SETUP_hdl_constr         MK_RT_UNUSED AllRtSetup_NULL; \
                                    MQ_FCT hdl = (MQ_FCT) &MkERROR;

OT_SETUP_hdl_destr

#define OT_SETUP_hdl_destr   OT_SETUP_hdl_tmpl__null_allow(MqFactoryC)

Definition at line 30 of file MqFactoryC_py.c.

OT_SETUP_hdl_static [1/2]

#define OT_SETUP_hdl_static

Value:

                                    MK_RT_UNUSED AllRtSetup_NULL; \
                                    __attribute__((unused)) MK_TYP hdl = MqFactoryC##_TT;

Definition at line 31 of file MqFactoryC_py.c.

#define OT_SETUP_hdl_static         MK_RT_UNUSED AllRtSetup_NULL; \
                                    __attribute__((unused)) MK_TYP hdl = MqFactoryC##_TT;

OT_SETUP_hdl_static [2/2]

#define OT_SETUP_hdl_static

Value:

                                    MK_RT_UNUSED AllRtSetup_NULL; \
                                    __attribute__((unused)) MK_TYP hdl = MqFactoryC##_TT; \
                                    bool is_constr_hard = false;

Definition at line 31 of file MqFactoryC_py.c.

#define OT_SETUP_hdl_static         MK_RT_UNUSED AllRtSetup_NULL; \
                                    __attribute__((unused)) MK_TYP hdl = MqFactoryC##_TT;

OT_SETUP_hdl_static_constr [1/2]

#define OT_SETUP_hdl_static_constr   OT_SETUP_hdl_static

Definition at line 34 of file MqFactoryC_py.c.

OT_SETUP_hdl_static_constr [2/2]

#define OT_SETUP_hdl_static_constr

Value:

                                    MK_RT_UNUSED AllRtSetup_NULL; \
                                    __attribute__((unused)) MK_TYP hdl = MqFactoryC##_TT; \
                                    bool is_constr_hard = true;

Definition at line 34 of file MqFactoryC_py.c.

Prev_doc

#define Prev_doc   "MqFactoryC fct.Prev()"

Definition at line 152 of file MqFactoryC_py.c.

SetupRtFromObj_X

#define SetupRtFromObj_X

(

hdl

)

Value:

AllRtSetup_X(hdl)

Definition at line 37 of file MqFactoryC_py.c.

SetupRtFromObj_XN [1/2]

#define SetupRtFromObj_XN

(

hdl

)

Value:

AllRtSetup_XN(hdl)

Definition at line 38 of file MqFactoryC_py.c.

SetupRtFromObj_XN [2/2]

#define SetupRtFromObj_XN

(

hdl

)

Value:

AllRtSetup_XN(hdl)

Definition at line 38 of file MqFactoryC_py.c.

Function Documentation

py_mqmsgque_MqFactoryC_CTOR()

OT_LNG_T py_mqmsgque_MqFactoryC_CTOR ( MK_RT mkrt, OT_LNG_CLASS_T type, MQ_FCT hdl )

inline

Definition at line 47 of file MqFactoryC_py.c.

                                                                          {
  return MK(AtomCreate)(MK_RT_CALL type,MqFactoryC_X2obj(hdl),true);
}

py_mqmsgque_MqFactoryC_selfCreate()

static MK_PTR py_mqmsgque_MqFactoryC_selfCreate ( MK_RT mkrt, MK_OBJ const obj, MK_PTR const env )

static

Definition at line 54 of file MqFactoryC_py.c.

                                                                                        {
  return MK(AtomCreate) (MK_RT_CALL OT_CLASS,obj,true);
}

py_mqmsgque_MqFactoryC_selfDelete()

static void py_mqmsgque_MqFactoryC_selfDelete ( MK_RT mkrt, MK_PTR self, MK_PTR const env )

static

Definition at line 58 of file MqFactoryC_py.c.

                                                                                 {
  OT_OBJECT_DELETE_HARD(OT_SELF);
}

py_mqmsgque_MqFactoryC_selfUnlink()

static void py_mqmsgque_MqFactoryC_selfUnlink ( MK_RT mkrt, MK_PTR self, MK_PTR const env )

static

Definition at line 62 of file MqFactoryC_py.c.

                                                                                 {
  MkObjectC_Obj *selfO = (MkObjectC_Obj*) self;
  selfO->hdl = NULL;
}

py_mqmsgque_pMqFactoryC_Init()

int py_mqmsgque_pMqFactoryC_Init

(

MQ_RT_ARGS OT_LNG_T

m

)

Definition at line 828 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_ARGS OT_LNG_T

m

)

Public API

Definition at line 789 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_sFactoryCTor()

static enum MkErrorE py_mqmsgque_sFactoryCTor ( MQ_CALLBACK_FACTORY_CTOR_ARGS )

static

Helper definition

Definition at line 171 of file MqFactoryC_py.c.

{
  MQ_CTX        mqctx = NULL;
  enum MkErrorE ret = MK_OK;
  PyObject*     argsO=NULL, *resultO=NULL;
  PyObject*     typeO = fct->fct_ctor.data;
  PyObject*     tmplO = (tmpl ? MkOBJ_R(tmpl).self : NULL);
 
//printXV(tmpl, "PYTH: Factory[%s] -> %s\n", MqFactoryGetOriginalIdent(fct), MqLogFactoryE(create))
  if (create == MQ_FACTORY_NEW_THREAD) {
#if 0
    ret = MkErrorSetC_1E("internal error: MQ_FACTORY_NEW_THREAD not supported");
    goto error;
#else
 
    static PyInterpreterConfig config = {
        .use_main_obmalloc = 0,
        .allow_fork = 0,
        .allow_exec = 0,
        .allow_threads = 1,
        .allow_daemon_threads = 0,
        .check_multi_interp_extensions = 1,
        .gil = PyInterpreterConfig_OWN_GIL,
    };
 
    PyThreadState *tstate = NULL;
    PyStatus status = Py_NewInterpreterFromConfig(&tstate, &config);
    MK_RT_REF.threadData = tstate;
 
mk_debug_color(MK_COLOR_YELLOW,"MQ_FACTORY_NEW_THREAD -> thread<%p>", tstate);
 
    if (PyStatus_Exception(status)) {
      return MkErrorSetC_3_NULL(status.err_msg, status.func, 300+status.exitcode);
    }
 
    Py_XINCREF(typeO);
    Py_XINCREF(tmplO);
 
    // mark new interpreter as "MQ_STARTUP_IS_THREAD"
    PyObject *mainM = PyImport_AddModule("__main__");
    PyObject *strO = PyUnicode_FromString("MQ_STARTUP_IS_THREAD");
    PyObject_SetAttrString(mainM,"__name__", strO);
    Py_CLEAR(strO);
 
    // source initial script
    MK_STRN fn = MqInitGetArg0()->data[1]->storage.first.C;
    FILE *FH = fopen(fn, "r");
    PyObject * mD = PyModule_GetDict(mainM);
    PyObject *retO = PyRun_FileEx(FH,fn,Py_file_input,mD,mD,true);
    if (retO == NULL) {
      ret = MkErrorSetC_1E("MQ_FACTORY_NEW_THREAD failed");
      //PyGILState_Release(gilstate);
      goto error3;
    }
    Py_CLEAR(retO);
 
    // type is from the "wrong" interpreter → try to figure out the right one
    PyObject* QualNameO = PyType_GetQualName((PyTypeObject*)typeO);
    if (QualNameO == NULL) goto error2;
 
    Py_CLEAR(typeO);
    typeO = PyObject_GetAttr(mainM,QualNameO);
    Py_CLEAR(QualNameO);
 
    if (typeO == NULL) goto error2;
 
    // need a NEW template class because the OLD class has a TYPE in the WRONG interpreter.
    Py_CLEAR(tmplO);
    tmplO = MK(AtomCreate)(MK_RT_CALL (PyTypeObject*)typeO,MkOBJ(tmpl),false);
 
    goto cont;
 
  error2:
    ret = MkErrorSetC_1E("internal error: unable to resolve type");
  error3:
    goto error;
  cont:
#endif
  } else {
 
    Py_XINCREF(typeO);
    Py_XINCREF(tmplO);
  }
 
  // get typeO from "parent"
  if (tmplO && create & (MQ_FACTORY_NEW_CHILD|MQ_FACTORY_NEW_SLAVE|MQ_FACTORY_NEW_FILTER)) {
    Py_CLEAR(typeO);
    typeO = Py_NewRef(Py_TYPE(tmplO));
  }
 
  // setup argsO
  if (create & MQ_FACTORY_NEW_INIT) {
    argsO = PyTuple_New(0);
  } else {
    argsO = PyTuple_New(1);
    PyTuple_SET_ITEM(argsO, 0, tmplO);
    Py_INCREF(tmplO);
  }
 
  if (typeO == NULL) {
    PyErr_SetString(PyExc_RuntimeError,"internal error: factory object constructor is 'NULL'");
    goto error;
  } else {
    // call constructor
    resultO = PyObject_Call(typeO, argsO, NULL);
    check_NULL(resultO) goto error;
  }
 
  // right typeO?
  if (!PyObject_IsInstance(resultO, (PyObject*) &NS(MqContextCR))) goto error;
  mqctx = VAL2CTX(resultO);
 
  // check for MQ error
  MkErrorCheck(MkErrorGetCode_0E());
 
  // copy and initialize "setup" data
  if (create & (MQ_FACTORY_NEW_CHILD)) {
    // !Attention!. the ctxId would be set later… in MqLinkCreate…
    MqSetupDup(mqctx, tmpl);
  }
 
  // a MQ_FACTORY_NEW_FILTER has "MkOBJ_R(mqctx).self" as ONLY reference… incr "refCnt"
  // related to "NS(sFactoryDTor)→MQ_FACTORY_NEW_INIT→Py_XINCREF"
  if (create & MQ_FACTORY_NEW_FILTER) {
    Py_XINCREF(resultO);
  }
 
  *contextP = mqctx;
 
end:
//printTxt("OK")
  // not used anymore because "Py_INCREF(self)" in "MqContextC_New" was deleted
  //Py_CLEAR(resultO);
  Py_CLEAR(argsO);
  Py_CLEAR(tmplO);
  Py_CLEAR(typeO);
//printXLngObj(mqctx,resultO)
 
  return ret;
 
error:
//printTxt("ERROR")
  Py_CLEAR(resultO);
  *contextP = NULL;
  OT_ERROR_LNG_2_MQ(MK_ERROR_DEFAULT);
  ret = MkErrorStack_0E();
  goto end;
}

py_mqmsgque_sFactoryDataCopy()

static void py_mqmsgque_sFactoryDataCopy ( MK_RT mkrt, MK_PTR * dataP )

static

Definition at line 348 of file MqFactoryC_py.c.

  {
  PyObject *arg = *dataP;
  Py_INCREF(arg);
}

py_mqmsgque_sFactoryDataFree()

static void py_mqmsgque_sFactoryDataFree ( MK_RT mkrt, MK_PTR * dataP )

static

Definition at line 339 of file MqFactoryC_py.c.

  {
  if (_Py_IsFinalizing()) return;
  Py_CLEAR(*dataP);
}

py_mqmsgque_sFactoryDTor()

static void py_mqmsgque_sFactoryDTor ( MK_RT mkrt, MQ_CTX context, bool doFactoryDelete, MQ_FCT const data )

static

Definition at line 321 of file MqFactoryC_py.c.

  {
 
  // related to "NS(sFactoryCTor)→MQ_FACTORY_NEW_INIT→Py_XINCREF"
  if (doFactoryDelete && context->setup.factoryCall == MQ_FACTORY_NEW_FILTER) {
    OT_LNG_T selfO = OT_SELF_X(context);
    Py_CLEAR (selfO);
  }
 
  // do a 'hard'-delete if 'Py_CLEAR' does NOT call the destructor
  MqContextDelete (context);
}

py_mqmsgque_sMqFactoryC_Str()

static PyObject * py_mqmsgque_sMqFactoryC_Str ( MqFactoryC_Obj * self )

static

Definition at line 776 of file MqFactoryC_py.c.

                                                            {
  MkRtSetup_X(self->hdl);
  return STRN2VAL(MkSysPrintF("MqFactoryC[%s]", self->hdl ? self->hdl->originalIdent : NULL));
}

Variable Documentation

py_mqmsgque_MqFactoryC_Methods

PyMethodDef py_mqmsgque_MqFactoryC_Methods[]

static

Object definition

Definition at line 731 of file MqFactoryC_py.c.

                                              {
  // BEGIN-CLASS - created by 'py_MqS.tcl -i NHI1_HOME/theLink/c/gen/c_mqmsgque.meta' - DO NOT change
 
    // doc-key: MqFactoryC,MqFactory,sCc
    { "Add"              , (PyCFunction) NS(MqFactoryC_Add)              , METH_VARARGS|METH_CLASS , Add_doc },
    
    // doc-key: MqFactoryC,MqFactory,sc_
    { "Get"              , (PyCFunction) NS(MqFactoryC_Get)              , METH_VARARGS|METH_CLASS , Get_doc },
    { "GetCalled"        , (PyCFunction) NS(MqFactoryC_GetCalled)        , METH_VARARGS|METH_CLASS , GetCalled_doc },
    { "GetCalledL"       , (PyCFunction) NS(MqFactoryC_GetCalledL)       , METH_O|METH_CLASS       , GetCalledL_doc },
    { "GetNull"          , (PyCFunction) NS(MqFactoryC_GetNull)          , METH_NOARGS|METH_CLASS  , GetNull_doc },
    { "HandleResolve"    , (PyCFunction) NS(MqFactoryC_HandleResolve)    , METH_O|METH_CLASS       , HandleResolve_doc },
    { "Instances"        , (PyCFunction) NS(MqFactoryC_Instances)        , METH_NOARGS|METH_CLASS  , Instances_doc },
    
    // doc-key: MqFactoryC,MqFactory,sm_
    { "DefaultIdent"     , (PyCFunction) NS(MqFactoryC_DefaultIdent)     , METH_NOARGS|METH_CLASS  , DefaultIdent_doc },
    { "InitialIdent"     , (PyCFunction) NS(MqFactoryC_InitialIdent)     , METH_NOARGS|METH_CLASS  , InitialIdent_doc },
    { "LogAll"           , (PyCFunction) NS(MqFactoryC_LogAll)           , METH_VARARGS|METH_CLASS , LogAll_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
 
    // doc-key: MqFactoryC,MqFactory,oCx
    { "Dup2"             , (PyCFunction) NS(MqFactoryC_Dup2)             , METH_O                  , Dup2_doc },
    
    // doc-key: MqFactoryC,MqFactory,oc_
    { "Default"          , (PyCFunction) NS(MqFactoryC_Default)          , METH_NOARGS             , Default_doc },
    { "Initial"          , (PyCFunction) NS(MqFactoryC_Initial)          , METH_NOARGS             , Initial_doc },
    { "Next"             , (PyCFunction) NS(MqFactoryC_Next)             , METH_NOARGS             , Next_doc },
    { "Prev"             , (PyCFunction) NS(MqFactoryC_Prev)             , METH_NOARGS             , Prev_doc },
    
    // doc-key: MqFactoryC,MqFactory,oco
    { "New"              , (PyCFunction) NS(MqFactoryC_New)              , METH_NOARGS             , New_doc },
    
    // doc-key: MqFactoryC,MqFactory,om_
    { "GetOriginalIdent" , (PyCFunction) NS(MqFactoryC_GetOriginalIdent) , METH_NOARGS             , GetOriginalIdent_doc },
    // skip class-overload: MqFactoryHandleGet → HandleGet, NS(MqFactoryC_HandleGet)
    // skip class-overload: MqFactoryLog → Log, NS(MqFactoryC_Log)
 
  // END-OBJ - created by 'py_MqS.tcl -i NHI1_HOME/theLink/c/gen/c_mqmsgque.meta' - DO NOT change
 
    {NULL, NULL, 0, NULL}        /* Sentinel */
};

py_mqmsgque_MqFactoryCR

OT_CLASS_TYPE_REF py_mqmsgque_MqFactoryCR

Initial value:

= {
  PyVarObject_HEAD_INIT(NULL, 0)
  .tp_name        = "pymqmsgque.MqFactoryC",
  .tp_doc         = "PyMqMsgque MqFactoryC Type",
  .tp_itemsize    = sizeof(MqFactoryC_Obj),
  .tp_itemsize    = 0,
  .tp_new         = (newfunc)      py_mqmsgque_MqFactoryC_new ,
  .tp_methods     =  py_mqmsgque_MqFactoryC_Methods ,
  .tp_flags       = Py_TPFLAGS_DEFAULT,
  .tp_base        = NULL,
  .tp_str         = (reprfunc)  py_mqmsgque_sMqFactoryC_Str 
}

Definition at line 814 of file MqFactoryC_py.c.

                                    {
  PyVarObject_HEAD_INIT(NULL, 0)
  .tp_name        = "pymqmsgque.MqFactoryC",
  .tp_doc         = "PyMqMsgque MqFactoryC Type",
  .tp_itemsize    = sizeof(MqFactoryC_Obj),
  .tp_itemsize    = 0,
  .tp_new         = (newfunc)     NS(MqFactoryC_new),
  .tp_methods     = NS(MqFactoryC_Methods),
  .tp_flags       = Py_TPFLAGS_DEFAULT,
  .tp_base        = NULL,
  .tp_str         = (reprfunc) NS(sMqFactoryC_Str)
};