MqFactoryC_py.c File Reference

tag: nhi1-release-250425 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	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)"

Functions
static OT_OBJ_T	pymqmsgque_MqFactoryC_CTOR (MK_RT mkrt, OT_CLS_T type, MQ_FCT hdl)
static MK_PTR	pymqmsgque_MqFactoryC_selfCreate (MK_RT mkrt, MK_OBJ const obj, MK_PTR const env)
static void	pymqmsgque_MqFactoryC_selfDelete (MK_RT mkrt, MK_PTR self, MK_PTR const env)
static void	pymqmsgque_MqFactoryC_selfUnlink (MK_RT mkrt, MK_PTR self, MK_PTR const env)
static enum MkErrorE	pymqmsgque_sFactoryCTor (MQ_CALLBACK_FACTORY_CTOR_ARGS)
static void	pymqmsgque_sFactoryDTor (MK_RT mkrt, MQ_CTX context, bool doFactoryDelete, MQ_FCT const data)
static void	pymqmsgque_sFactoryDataFree (MK_RT mkrt, MK_PTR *dataP)
static void	pymqmsgque_sFactoryDataCopy (MK_RT mkrt, MK_PTR *dataP)
static OT_ProcRet	pymqmsgque_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…
MK_DEPRECATED static MK_UNUSED OT_ProcRet	pymqmsgque_MqFactoryC_HandleGet (MqFactoryC_ARGS)
static OT_ProcRet	pymqmsgque_MqFactoryC_Next (MqFactoryC_ARGS)
	Python: MqFactoryC fct.Next() → C-API get next instance from linked-list of MqFactoryS type
static OT_ProcRet	pymqmsgque_MqFactoryC_Prev (MqFactoryC_ARGS)
	Python: MqFactoryC fct.Prev() → C-API get previous instance from linked-list of MqFactoryS type
static OT_ProcRet	pymqmsgque_MqFactoryC_Instances (OtClass_ARGS)
	Python: [static] MqFactoryC MqFactoryC.Instances() → C-API get head-instance from linked-list of MqFactoryS type …
static OT_ProcRet	pymqmsgque_MqFactoryC_GetNull (OtClass_ARGS)
	Python: [static] MqFactoryC MqFactoryC.GetNull() → C-API Null-Slot - return a MqFactoryC typed NULL instance …
static OT_ProcRet	pymqmsgque_MqFactoryC_Get (OtClass_ARGS)
	Python: [static] MqFactoryC MqFactoryC.Get(?ident:string=""?) → C-API return the MqFactoryC
static OT_ProcRet	pymqmsgque_MqFactoryC_GetCalled (OtClass_ARGS)
	Python: [static] MqFactoryC MqFactoryC.GetCalled(?ident:string=""?) → C-API returns the MqFactoryC identified by ident …
static OT_ProcRet	pymqmsgque_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	pymqmsgque_MqFactoryC_GetOriginalIdent (MqFactoryC_ARGS)
	Python: string fct.GetOriginalIdent() → C-API helper function to return MqFactoryS::originalIdent
static OT_ProcRet	pymqmsgque_MqFactoryC_Default (MqFactoryC_ARGS)
	Python: MqFactoryC fct.Default() → C-API set the default-attribute to the factory …
static OT_ProcRet	pymqmsgque_MqFactoryC_Initial (MqFactoryC_ARGS)
	Python: MqFactoryC fct.Initial() → C-API set the initial-attribut to fct …
static OT_ProcRet	pymqmsgque_MqFactoryC_New (MqFactoryC_ARGS)
	Python: MqContextC fct.New() → C-API create a new MqContextC from a MqFactoryC …
MK_DEPRECATED static MK_UNUSED OT_ProcRet	pymqmsgque_MqFactoryC_Log (MqFactoryC_ARGS)
static OT_ProcRet	pymqmsgque_MqFactoryC_DefaultIdent (OtClass_ARGS)
	Python: [static] string MqFactoryC.DefaultIdent() → C-API return the factory-identifier of the default MqFactoryC
static OT_ProcRet	pymqmsgque_MqFactoryC_InitialIdent (OtClass_ARGS)
	Python: [static] string MqFactoryC.InitialIdent() → C-API return the factory-identifier of the initial MqFactoryC
static OT_ProcRet	pymqmsgque_MqFactoryC_LogAll (OtClass_ARGS)
	Python: [static] MqFactoryC.LogAll(?callfunc:string="MK_NULL"?) → C-API log all "factories" to stderr
static OT_ProcRet	pymqmsgque_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	pymqmsgque_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	pymqmsgque_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 *	pymqmsgque_sMqFactoryC_Str (MqFactoryC_Obj *self)
int	pymqmsgque_pMqFactoryC_Setup (MK_RT mkrt, MQ_RT mqrt, OT_OBJ_T m)
int	pymqmsgque_pMqFactoryC_Init (MK_RT mkrt, OT_OBJ_T m)

Variables
static PyMethodDef	pymqmsgque_MqFactoryC_Methods []
OT_CLASS_TYPE_REF	pymqmsgque_MqFactoryCR

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 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 128 of file MqFactoryC_py.c.

ClassInit

#define ClassInit

Value:

  /* if not already done, initialize NEW META 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 META-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 = MqFactoryC_base; \
    OtErrorCheckLng (PyType_Ready(OT_CLASS)); \
  } \
  OtErrorCheckLng(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*/));

Definition at line 65 of file MqFactoryC_py.c.

#define   ClassInit \
  /* if not already done, initialize NEW META 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 META-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 = MqFactoryC_base; \
    OtErrorCheckLng (PyType_Ready(OT_CLASS)); \
  } \
  OtErrorCheckLng(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*/));

Default_doc

#define Default_doc   "MqFactoryC fct.Default()"

Definition at line 148 of file MqFactoryC_py.c.

DefaultIdent_doc

#define DefaultIdent_doc   "string MqFactoryC.DefaultIdent()"

Definition at line 140 of file MqFactoryC_py.c.

Dup2_doc

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

Definition at line 145 of file MqFactoryC_py.c.

Get_doc

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

Definition at line 132 of file MqFactoryC_py.c.

GetCalled_doc

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

Definition at line 133 of file MqFactoryC_py.c.

GetCalledL_doc

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

Definition at line 134 of file MqFactoryC_py.c.

GetNull_doc

#define GetNull_doc   "MqFactoryC MqFactoryC.GetNull()"

Definition at line 135 of file MqFactoryC_py.c.

GetOriginalIdent_doc

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

Definition at line 157 of file MqFactoryC_py.c.

HandleResolve_doc

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

Definition at line 136 of file MqFactoryC_py.c.

Initial_doc

#define Initial_doc   "MqFactoryC fct.Initial()"

Definition at line 149 of file MqFactoryC_py.c.

InitialIdent_doc

#define InitialIdent_doc   "string MqFactoryC.InitialIdent()"

Definition at line 141 of file MqFactoryC_py.c.

Instances_doc

#define Instances_doc   "MqFactoryC MqFactoryC.Instances()"

Definition at line 137 of file MqFactoryC_py.c.

LogAll_doc

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

Definition at line 142 of file MqFactoryC_py.c.

META_FILE_NAME

#define META_FILE_NAME   "MqFactoryC_py.c"

Definition at line 11 of file MqFactoryC_py.c.

MqFactoryCTT

#define MqFactoryCTT   MQ(MqMsgqueThreadState).MqFactoryCTT

Definition at line 40 of file MqFactoryC_py.c.

New_doc

#define New_doc   "MqContextC fct.New()"

Definition at line 154 of file MqFactoryC_py.c.

new_doc

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

Definition at line 129 of file MqFactoryC_py.c.

Next_doc

#define Next_doc   "MqFactoryC fct.Next()"

Definition at line 150 of file MqFactoryC_py.c.

OT_CLASS

#define OT_CLASS   (&NS(MqFactoryCR))

Definition at line 16 of file MqFactoryC_py.c.

OT_CLASS_NAME

#define OT_CLASS_NAME   "MqFactoryC"

Definition at line 17 of file MqFactoryC_py.c.

OT_LNG2META

#define OT_LNG2META

(

O

)

Value:

MqFct(VAL2MNG(O))

Definition at line 19 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 21 of file MqFactoryC_py.c.

OT_SETUP_hdl

#define OT_SETUP_hdl   OT_SETUP_hdl_tmpl(MqFactoryC)

Definition at line 23 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 24 of file MqFactoryC_py.c.

OT_SETUP_hdl_constr

#define OT_SETUP_hdl_constr

Value:

                                    MK_RT_UNUSED AllRtSetup_NULL; \
                                    MQ_FCT hdl = (MQ_FCT) OT_CLASS;

Definition at line 25 of file MqFactoryC_py.c.

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

OT_SETUP_hdl_destr

#define OT_SETUP_hdl_destr   OT_SETUP_hdl_tmpl__null_allow(MqFactoryC)

Definition at line 27 of file MqFactoryC_py.c.

OT_SETUP_hdl_static

#define OT_SETUP_hdl_static

Value:

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

Definition at line 28 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

#define OT_SETUP_hdl_static_constr   OT_SETUP_hdl_static

Definition at line 31 of file MqFactoryC_py.c.

Prev_doc

#define Prev_doc   "MqFactoryC fct.Prev()"

Definition at line 151 of file MqFactoryC_py.c.

SetupRtFromObj_X

#define SetupRtFromObj_X

(

hdl

)

Value:

AllRtSetup_X(hdl)

Definition at line 34 of file MqFactoryC_py.c.

SetupRtFromObj_XN

#define SetupRtFromObj_XN

(

hdl

)

Value:

AllRtSetup_XN(hdl)

Definition at line 35 of file MqFactoryC_py.c.

Function Documentation

pymqmsgque_MqFactoryC_CTOR()

static OT_OBJ_T pymqmsgque_MqFactoryC_CTOR ( MK_RT mkrt, OT_CLS_T type, MQ_FCT hdl )

inlinestatic

Definition at line 44 of file MqFactoryC_py.c.

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

pymqmsgque_MqFactoryC_selfCreate()

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

static

Definition at line 51 of file MqFactoryC_py.c.

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

pymqmsgque_MqFactoryC_selfDelete()

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

static

Definition at line 55 of file MqFactoryC_py.c.

                                                                                 {
  MK(AtomDeleteHard) (MK_RT_CALL OT_SELF);
}

pymqmsgque_MqFactoryC_selfUnlink()

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

static

Definition at line 59 of file MqFactoryC_py.c.

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

pymqmsgque_pMqFactoryC_Init()

int pymqmsgque_pMqFactoryC_Init	(	MK_RT	mkrt,
		OT_OBJ_T	m )

Definition at line 837 of file MqFactoryC_py.c.

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

pymqmsgque_pMqFactoryC_Setup()

int pymqmsgque_pMqFactoryC_Setup	(	MK_RT	mkrt,
		MQ_RT	mqrt,
		OT_OBJ_T	m )

Public API

Definition at line 798 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;
}

pymqmsgque_sFactoryCTor()

static enum MkErrorE pymqmsgque_sFactoryCTor ( MQ_CALLBACK_FACTORY_CTOR_ARGS )

static

Helper definition

Definition at line 170 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);
    if (MK_RT_REF.mkThreadData.ptr == NULL) {
      MK_RT_REF.mkThreadData = (MkThreadDataS) { "pymqmsgque", tstate } ;
    } else if (strcmp(MK_RT_REF.mkThreadData.name,"pymqmsgque") == 0) {
      MkErrorSetC_1E("'MK_RT_REF.mkThreadData' not NULL as expected");
    } else {
      MkErrorSetV_1E("MK_RT_REF.mkThreadData' already in use with extension: %s", MK_RT_REF.mkThreadData.name);
    }
 
mk_dbg_color_ln(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));
 
    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_META(MK_ERROR_DEFAULT);
  ret = MkErrorStack_0E();
  goto end;
}

pymqmsgque_sFactoryDataCopy()

static void pymqmsgque_sFactoryDataCopy ( MK_RT mkrt, MK_PTR * dataP )

static

Definition at line 353 of file MqFactoryC_py.c.

  {
  PyObject *arg = *dataP;
  Py_INCREF(arg);   // THREAD → no DEEP copy
}

pymqmsgque_sFactoryDataFree()

static void pymqmsgque_sFactoryDataFree ( MK_RT mkrt, MK_PTR * dataP )

static

Definition at line 344 of file MqFactoryC_py.c.

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

pymqmsgque_sFactoryDTor()

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

static

Definition at line 326 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_OBJ_T selfO = OT_SELF_X(context);
    Py_CLEAR (selfO);
  }
 
  // do a 'hard'-delete if 'Py_CLEAR' does NOT call the destructor
  MqContextDelete (context);
}

pymqmsgque_sMqFactoryC_Str()

static PyObject * pymqmsgque_sMqFactoryC_Str ( MqFactoryC_Obj * self )

static

Definition at line 785 of file MqFactoryC_py.c.

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

Variable Documentation

pymqmsgque_MqFactoryC_Methods

PyMethodDef pymqmsgque_MqFactoryC_Methods[]

static

Object definition

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

pymqmsgque_MqFactoryCR

OT_CLASS_TYPE_REF pymqmsgque_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)      pymqmsgque_MqFactoryC_new ,
  .tp_methods     =  pymqmsgque_MqFactoryC_Methods ,
  .tp_flags       = Py_TPFLAGS_DEFAULT,
  .tp_base        = NULL,
  .tp_str         = (reprfunc)  pymqmsgque_sMqFactoryC_Str 
}

Definition at line 823 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)
};