MqCall_py.c File Reference

tag: nhi1-release-250425 More...

#include "LibMqMsgque_private_py.h"
#include "misc_check_py.h"

Include dependency graph for MqCall_py.c:

Go to the source code of this file.

Functions
enum MkErrorE	pymqmsgque_ServiceCall (MQ_SERVICE_CALL_ARGS)
void	pymqmsgque_ServiceFree (MK_RT mkrt, MQ_CTX const context, MK_PTR *dataP)
void	pymqmsgque_ServiceCopy (MK_RT mkrt, MQ_CTX const context, MK_PTR *dataP)

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 MqCall_py.c.

Function Documentation

pymqmsgque_ServiceCall()

enum MkErrorE pymqmsgque_ServiceCall

(

MQ_SERVICE_CALL_ARGS

)

Definition at line 28 of file MqCall_py.c.

{
  MQ_SERVICE_CALL_CHECK;
 
  PyObject * const callable = (PyObject*) __data__;
  PyObject * selfarg = OT_SELF_X(mqctx);
  PyObject * resultO = NULL;
 
  // test if already deleted
  if (VAL2CTX(selfarg) == NULL) {
    return MkErrorSetC_2M(mqctx, "object is NULL");
  } else if (Py_REFCNT(selfarg) == 0) {
    return MK_OK;
  }
 
//  PyThreadState* ts = PyThreadState_Swap(MK_RT_REF.mkThreadData.ptr);
//printV("ts start: %p → %p", ts, MK_RT_REF.mkThreadData.ptr);
 
  PyErr_Clear();
 
  // for methods of the instance 'self' the argument 'self' is already set
  if (PyMethod_Check(callable)) {
    PyObject* mself = PyMethod_Self(callable);
    if (mself == selfarg) {
      selfarg = NULL;
    }
  }
 
  // call the function
  resultO = PyObject_CallFunctionObjArgs(callable, selfarg, NULL);
 
  // no error return OK
  if (resultO == NULL) goto error;
 
  Py_CLEAR(resultO);
  return MkErrorGetCodeI(&MkERROR);   /* MkErrorGetCode_0E() */
 
error:
  OT_ERROR_LNG_2_META(mqctx);
 
  return MkErrorStack_0E_Check();
}

pymqmsgque_ServiceCopy()

void pymqmsgque_ServiceCopy	(	MK_RT	mkrt,
		MQ_CTX const	context,
		MK_PTR *	dataP )

Definition at line 82 of file MqCall_py.c.

{
  PyObject* self = (PyObject*)MkOBJ_R(context).self;
 
//printSelf(self)
 
  PyObject* callable = (PyObject*)(*dataP);
  if (PyMethod_Check(callable)) {
    //PyObject* oldself = PyMethod_Self(callable);
//printSelf(oldself)
    PyObject* const function = PyMethod_Function(callable);
    if (function == NULL) {
      MkPanicC_4M(context,__func__,-1,"unable to 'PyMethod_Function'");
    } else {
      callable = PyMethod_New(function, self);
      if (callable == NULL) {
        MkPanicC_4M(context,__func__,-1,"unable to 'PyMethod_New'");
      } else {
        *dataP = callable;
      }
    }
  }
  Py_INCREF(*dataP);
}

pymqmsgque_ServiceFree()

void pymqmsgque_ServiceFree	(	MK_RT	mkrt,
		MQ_CTX const	context,
		MK_PTR *	dataP )

Definition at line 72 of file MqCall_py.c.

{
  MK(CallFree)(dataP);
}