tag: nhi1-release-250425 More...

#include "LibMkKernel_py.h"
#include "LibMqMsgque_mq.h"
#include "tmpl/mq_type_S_lng.h"
#include "tmpl/mq_misc_check_lng.h"

Include dependency graph for LibMqMsgque_py.h:

This graph shows which files directly or indirectly include this file:

Go to the source code of this file.

Data Structures
struct	MqMsgqueThreadStateS

struct	MqContextC_Obj

struct	MqDumpC_Obj

struct	MqFactoryC_Obj

Macros
#define	HEADER

#define	MQ_PY_EXTERN
	static library

#define	MQ_PY_EXTERN_DATA extern

#define	MQ(n)

#define	NS(n)

#define	MqContextC_lngO (&MQ(MqContextCR))

#define	MqContextC_base (&MK(MkObjectCR))

#define	MqContextC_MK_NULL MQ(MqMsgqueThreadState).MqContextC_MK_NULL

#define	MqContextC_ARGS MqContextC_Obj self, PyObject objv

#define	MqContextC_ARGS_CALL self, objv

#define	OT_retObj_SET_CTX(nat)

#define	OT_TMP_CTX_OBJ(val)

#define	VAL2CTX(val)

#define	MqDumpC_lngO (&MQ(MqDumpCR))

#define	MqDumpC_base (&MK(MkObjectCR))

#define	MqDumpC_MK_NULL MQ(MqMsgqueThreadState).MqDumpC_MK_NULL

#define	MqDumpC_ARGS MqDumpC_Obj self, PyObject objv

#define	MqDumpC_ARGS_CALL self, objv

#define	OT_retObj_SET_DMP(nat)

#define	OT_TMP_DMP_OBJ(val)

#define	VAL2DMP(val)

#define	MqFactoryC_lngO (&MQ(MqFactoryCR))

#define	MqFactoryC_base (&MK(MkObjectCR))

#define	MqFactoryC_MK_NULL MQ(MqMsgqueThreadState).MqFactoryC_MK_NULL

#define	MqFactoryC_ARGS MqFactoryC_Obj self, PyObject objv

#define	MqFactoryC_ARGS_CALL self, objv

#define	OT_retObj_SET_FCT(nat)

#define	OT_TMP_FCT_OBJ(val)

#define	VAL2FCT(val)

#define	OT_CTX (((MqContextC_Obj*)self)->hdl)

#define	OT_SETUP_self MqContextC_Obj* self = OT_MqCFromMqS(META_CONTEXT_S);

#define	OT_MqCFromMqS(ctx)

#define	OT_NEW_Mq_enum_OBJ(typ, val)

#define	MqIdentE_lngO (MQ(MqMsgqueThreadState).MqIdentE)

#define	MqSlaveE_lngO (MQ(MqMsgqueThreadState).MqSlaveE)

#define	MqStartE_lngO (MQ(MqMsgqueThreadState).MqStartE)

#define	MqStatusIsEF_lngO (MQ(MqMsgqueThreadState).MqStatusIsEF)

#define	MqWaitOnEventE_lngO (MQ(MqMsgqueThreadState).MqWaitOnEventE)

#define	printSelf(o)

Typedefs
typedef struct MqContextC_Obj	MqContextC_Obj

typedef struct MqDumpC_Obj	MqDumpC_Obj

typedef struct MqFactoryC_Obj	MqFactoryC_Obj

Functions
int	pymqmsgque_pMqFactoryC_Init (MK_RT mkrt, OT_OBJ_T)

int	pymqmsgque_pMqDumpC_Init (MK_RT mkrt, OT_OBJ_T)

int	pymqmsgque_pMqContextC_Init (MK_RT mkrt, OT_OBJ_T)

static MK_ARTIFICIAL OT_OBJ_T	pymqmsgque_MqContextC_ObjNew (MK_RT mkrt, OT_CLS_T type, MQ_CTX hdl)

static MK_ARTIFICIAL OT_OBJ_T	pymqmsgque_MqDumpC_ObjNew (MK_RT mkrt, OT_CLS_T type, MQ_DMP hdl)

static MK_ARTIFICIAL OT_OBJ_T	pymqmsgque_MqFactoryC_ObjNew (MK_RT mkrt, OT_CLS_T type, MQ_FCT hdl)

Variables
MK_PY_EXTERN_DATA __thread MqMsgqueThreadStateS	pymqmsgque_MqMsgqueThreadState

MQ_PY_EXTERN_DATA OT_CLASS_TYPE_REF	pymqmsgque_MqContextCR

MQ_PY_EXTERN_DATA OT_CLASS_TYPE_REF	pymqmsgque_MqDumpCR

MQ_PY_EXTERN_DATA 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 LibMqMsgque_py.h.

Macro Definition Documentation

◆ HEADER

#define HEADER

Definition at line 22 of file LibMqMsgque_py.h.

◆ MQ

#define MQ ( n )

Value:

pymqmsgque_ ## n

Definition at line 73 of file LibMqMsgque_py.h.

◆ MQ_PY_EXTERN

#define MQ_PY_EXTERN

static library

Definition at line 46 of file LibMqMsgque_py.h.

◆ MQ_PY_EXTERN_DATA

#define MQ_PY_EXTERN_DATA extern

Definition at line 69 of file LibMqMsgque_py.h.

◆ MqContextC_ARGS

#define MqContextC_ARGS MqContextC_Obj *self, PyObject *objv

Definition at line 147 of file LibMqMsgque_py.h.

◆ MqContextC_ARGS_CALL

#define MqContextC_ARGS_CALL self, objv

Definition at line 148 of file LibMqMsgque_py.h.

◆ MqContextC_base

#define MqContextC_base (&MK(MkObjectCR))

Definition at line 141 of file LibMqMsgque_py.h.

◆ MqContextC_lngO

#define MqContextC_lngO (&MQ(MqContextCR))

Definition at line 140 of file LibMqMsgque_py.h.

◆ MqContextC_MK_NULL

#define MqContextC_MK_NULL MQ(MqMsgqueThreadState).MqContextC_MK_NULL

Definition at line 144 of file LibMqMsgque_py.h.

◆ MqDumpC_ARGS

#define MqDumpC_ARGS MqDumpC_Obj *self, PyObject *objv

Definition at line 180 of file LibMqMsgque_py.h.

◆ MqDumpC_ARGS_CALL

#define MqDumpC_ARGS_CALL self, objv

Definition at line 181 of file LibMqMsgque_py.h.

◆ MqDumpC_base

#define MqDumpC_base (&MK(MkObjectCR))

Definition at line 174 of file LibMqMsgque_py.h.

◆ MqDumpC_lngO

#define MqDumpC_lngO (&MQ(MqDumpCR))

Definition at line 173 of file LibMqMsgque_py.h.

◆ MqDumpC_MK_NULL

#define MqDumpC_MK_NULL MQ(MqMsgqueThreadState).MqDumpC_MK_NULL

Definition at line 177 of file LibMqMsgque_py.h.

◆ MqFactoryC_ARGS

#define MqFactoryC_ARGS MqFactoryC_Obj *self, PyObject *objv

Definition at line 213 of file LibMqMsgque_py.h.

◆ MqFactoryC_ARGS_CALL

#define MqFactoryC_ARGS_CALL self, objv

Definition at line 214 of file LibMqMsgque_py.h.

◆ MqFactoryC_base

#define MqFactoryC_base (&MK(MkObjectCR))

Definition at line 207 of file LibMqMsgque_py.h.

◆ MqFactoryC_lngO

#define MqFactoryC_lngO (&MQ(MqFactoryCR))

Definition at line 206 of file LibMqMsgque_py.h.

◆ MqFactoryC_MK_NULL

#define MqFactoryC_MK_NULL MQ(MqMsgqueThreadState).MqFactoryC_MK_NULL

Definition at line 210 of file LibMqMsgque_py.h.

◆ MqIdentE_lngO

#define MqIdentE_lngO (MQ(MqMsgqueThreadState).MqIdentE)

Definition at line 253 of file LibMqMsgque_py.h.

◆ MqSlaveE_lngO

#define MqSlaveE_lngO (MQ(MqMsgqueThreadState).MqSlaveE)

Definition at line 254 of file LibMqMsgque_py.h.

◆ MqStartE_lngO

#define MqStartE_lngO (MQ(MqMsgqueThreadState).MqStartE)

Definition at line 255 of file LibMqMsgque_py.h.

◆ MqStatusIsEF_lngO

#define MqStatusIsEF_lngO (MQ(MqMsgqueThreadState).MqStatusIsEF)

Definition at line 256 of file LibMqMsgque_py.h.

◆ MqWaitOnEventE_lngO

#define MqWaitOnEventE_lngO (MQ(MqMsgqueThreadState).MqWaitOnEventE)

Definition at line 257 of file LibMqMsgque_py.h.

◆ NS

#define NS ( n )

Value:

pymqmsgque_ ## n

Definition at line 75 of file LibMqMsgque_py.h.

◆ OT_CTX

#define OT_CTX (((MqContextC_Obj*)self)->hdl)

Definition at line 239 of file LibMqMsgque_py.h.

◆ OT_MqCFromMqS

#define OT_MqCFromMqS ( ctx )

Value:

((MqContextC_Obj*)(MkOBJ_R(ctx).self))

MkOBJ_R

#define MkOBJ_R(x)

MqContextC_Obj

Definition LibMqMsgque_py.h:134

Definition at line 241 of file LibMqMsgque_py.h.

◆ OT_NEW_Mq_enum_OBJ

#define OT_NEW_Mq_enum_OBJ	(		typ,
			val )

Value:

PyObject_CallFunction((PyObject*)(Mq ## typ ## _lngO),"i",val)

Definition at line 249 of file LibMqMsgque_py.h.

◆ OT_retObj_SET_CTX

#define OT_retObj_SET_CTX ( nat )

Value:

retObj = MQ(MqContextC_ObjNew) (MK_RT_CALL &MQ(MqContextCR),nat)

MQ

#define MQ(n)

Definition LibMqMsgque_py.h:73

MK_RT_CALL

#define MK_RT_CALL

MqContextS

PUBLIC data structure for the pymqmsgque-specific-data

Definition LibMqMsgque_mq.h:4110

Definition at line 151 of file LibMqMsgque_py.h.

◆ OT_retObj_SET_DMP

#define OT_retObj_SET_DMP ( nat )

Value:

retObj = MQ(MqDumpC_ObjNew) (MK_RT_CALL &MQ(MqDumpCR),nat)

MqDumpS

MqDumpC - the class known as dmp or dump is used to export a pymqmsgque data package as binary …

Definition LibMqMsgque_mq.h:8661

Definition at line 184 of file LibMqMsgque_py.h.

◆ OT_retObj_SET_FCT

#define OT_retObj_SET_FCT ( nat )

Value:

retObj = MQ(MqFactoryC_ObjNew) (MK_RT_CALL &MQ(MqFactoryCR),nat)

MqFactoryS

data used to define a factory

Definition LibMqMsgque_mq.h:3169

Definition at line 217 of file LibMqMsgque_py.h.

◆ OT_SETUP_self

#define OT_SETUP_self MqContextC_Obj* self = OT_MqCFromMqS(META_CONTEXT_S);

Definition at line 240 of file LibMqMsgque_py.h.

◆ OT_TMP_CTX_OBJ

#define OT_TMP_CTX_OBJ ( val )

Value:

MQ(MqContextC_ObjNew)(MK_RT_CALL &MQ(MqContextCR),val)

Definition at line 154 of file LibMqMsgque_py.h.

◆ OT_TMP_DMP_OBJ

#define OT_TMP_DMP_OBJ ( val )

Value:

MQ(MqDumpC_ObjNew)(MK_RT_CALL &MQ(MqDumpCR),val)

Definition at line 187 of file LibMqMsgque_py.h.

◆ OT_TMP_FCT_OBJ

#define OT_TMP_FCT_OBJ ( val )

Value:

MQ(MqFactoryC_ObjNew)(MK_RT_CALL &MQ(MqFactoryCR),val)

Definition at line 220 of file LibMqMsgque_py.h.

◆ printSelf

#define printSelf ( o )

Value:

printXSObj(((MqContextC_Obj*)o)->ctx,#o,(o!=NULL?(PyObject*)o:(PyObject*)Py_None))

printXSObj

#define printXSObj(ctx, s, o)

Definition LibMkKernel_py.h:963

Definition at line 267 of file LibMqMsgque_py.h.

◆ VAL2CTX

#define VAL2CTX ( val )

Value:

((MqContextC_Obj*) (val))->hdl

Definition at line 161 of file LibMqMsgque_py.h.

◆ VAL2DMP

#define VAL2DMP ( val )

Value:

((MqDumpC_Obj*) (val))->hdl

MqDumpC_Obj

Definition LibMqMsgque_py.h:167

Definition at line 194 of file LibMqMsgque_py.h.

◆ VAL2FCT

#define VAL2FCT ( val )

Value:

((MqFactoryC_Obj*) (val))->hdl

MqFactoryC_Obj

Definition LibMqMsgque_py.h:200

Definition at line 227 of file LibMqMsgque_py.h.

Typedef Documentation

◆ MqContextC_Obj

typedef struct MqContextC_Obj MqContextC_Obj

◆ MqDumpC_Obj

typedef struct MqDumpC_Obj MqDumpC_Obj

◆ MqFactoryC_Obj

typedef struct MqFactoryC_Obj MqFactoryC_Obj

Function Documentation

◆ pymqmsgque_MqContextC_ObjNew()

static MK_ARTIFICIAL OT_OBJ_T pymqmsgque_MqContextC_ObjNew	(	MK_RT	mkrt,
		OT_CLS_T	type,
		MQ_CTX	hdl )

inlinestatic

Definition at line 156 of file LibMqMsgque_py.h.

                                                                                     {
    return hdl ? MK(AtomObjNew)(MK_RT_CALL type,MqContextC_X2obj(hdl)) : Py_NewRef(MqContextC_MK_NULL);
  }

◆ pymqmsgque_MqDumpC_ObjNew()

static MK_ARTIFICIAL OT_OBJ_T pymqmsgque_MqDumpC_ObjNew	(	MK_RT	mkrt,
		OT_CLS_T	type,
		MQ_DMP	hdl )

inlinestatic

Definition at line 189 of file LibMqMsgque_py.h.

                                                                                  {
    return hdl ? MK(AtomObjNew)(MK_RT_CALL type,MqDumpC_X2obj(hdl)) : Py_NewRef(MqDumpC_MK_NULL);
  }

◆ pymqmsgque_MqFactoryC_ObjNew()

static MK_ARTIFICIAL OT_OBJ_T pymqmsgque_MqFactoryC_ObjNew	(	MK_RT	mkrt,
		OT_CLS_T	type,
		MQ_FCT	hdl )

inlinestatic

Definition at line 222 of file LibMqMsgque_py.h.

                                                                                     {
    return hdl ? MK(AtomObjNew)(MK_RT_CALL type,MqFactoryC_X2obj(hdl)) : Py_NewRef(MqFactoryC_MK_NULL);
  }

◆ pymqmsgque_pMqContextC_Init()

int pymqmsgque_pMqContextC_Init	(	MK_RT	mkrt,
		OT_OBJ_T	m )

Definition at line 3954 of file MqContextC_py.c.

                                            {
  MQ_STATIC_RT;
 
  // define type
  MqContextCTT = MkTypeDup2(MqContextC_TT,"PyMqContextC");
  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->MqProcessExitCB = NS(sProcessExit);
  MqContextCT->MqThreadExitCB = NS(sThreadExit);
  //MqContextCT->ignoreDisasterSetup = true;
  MqContextCT->ignoreThread = true;
 
  ClassInit
 
  return 0;
error:
  return -1;
}

◆ pymqmsgque_pMqDumpC_Init()

int pymqmsgque_pMqDumpC_Init	(	MK_RT	mkrt,
		OT_OBJ_T	m )

Public API

Definition at line 457 of file MqDumpC_py.c.

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

◆ 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;
}

Variable Documentation

◆ pymqmsgque_MqContextCR

MQ_PY_EXTERN_DATA OT_CLASS_TYPE_REF pymqmsgque_MqContextCR

Definition at line 139 of file LibMqMsgque_py.h.

◆ pymqmsgque_MqDumpCR

MQ_PY_EXTERN_DATA OT_CLASS_TYPE_REF pymqmsgque_MqDumpCR

Definition at line 172 of file LibMqMsgque_py.h.

◆ pymqmsgque_MqFactoryCR

MQ_PY_EXTERN_DATA OT_CLASS_TYPE_REF pymqmsgque_MqFactoryCR

Definition at line 205 of file LibMqMsgque_py.h.

◆ pymqmsgque_MqMsgqueThreadState

MK_PY_EXTERN_DATA __thread MqMsgqueThreadStateS pymqmsgque_MqMsgqueThreadState

Definition at line 120 of file LibMqMsgque_py.h.

Data Structures

Macros

Typedefs

Functions

Variables

Detailed Description

Macro Definition Documentation

◆ HEADER

◆ MQ

◆ MQ_PY_EXTERN

◆ MQ_PY_EXTERN_DATA

◆ MqContextC_ARGS

◆ MqContextC_ARGS_CALL

◆ MqContextC_base

◆ MqContextC_lngO

◆ MqContextC_MK_NULL

◆ MqDumpC_ARGS

◆ MqDumpC_ARGS_CALL

◆ MqDumpC_base

◆ MqDumpC_lngO

◆ MqDumpC_MK_NULL

◆ MqFactoryC_ARGS

◆ MqFactoryC_ARGS_CALL

◆ MqFactoryC_base

◆ MqFactoryC_lngO

◆ MqFactoryC_MK_NULL

◆ MqIdentE_lngO

◆ MqSlaveE_lngO

◆ MqStartE_lngO

◆ MqStatusIsEF_lngO

◆ MqWaitOnEventE_lngO

◆ NS

◆ OT_CTX

◆ OT_MqCFromMqS

◆ OT_NEW_Mq_enum_OBJ

◆ OT_retObj_SET_CTX

◆ OT_retObj_SET_DMP

◆ OT_retObj_SET_FCT

◆ OT_SETUP_self

◆ OT_TMP_CTX_OBJ

◆ OT_TMP_DMP_OBJ

◆ OT_TMP_FCT_OBJ

◆ printSelf

◆ VAL2CTX

◆ VAL2DMP

◆ VAL2FCT

Typedef Documentation

◆ MqContextC_Obj

◆ MqDumpC_Obj

◆ MqFactoryC_Obj

Function Documentation

◆ pymqmsgque_MqContextC_ObjNew()

◆ pymqmsgque_MqDumpC_ObjNew()

◆ pymqmsgque_MqFactoryC_ObjNew()

◆ pymqmsgque_pMqContextC_Init()

◆ pymqmsgque_pMqDumpC_Init()

◆ pymqmsgque_pMqFactoryC_Init()

Variable Documentation

◆ pymqmsgque_MqContextCR

◆ pymqmsgque_MqDumpCR

◆ pymqmsgque_MqFactoryCR

◆ pymqmsgque_MqMsgqueThreadState