LibMqMsgque_private_py.h File Reference

tag: nhi1-release-250425 More...

#include "LibMqMsgque_py.h"

Include dependency graph for LibMqMsgque_private_py.h:

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

Go to the source code of this file.

Macros
#define	Send_doc_extra   "[…] ctx.Send(\"CALL-SIGNATUR\",call-args …,\"TOKEN-SIGNATURE\",send-args …)"

Functions
enum MkErrorE	pymqmsgque_ServiceCall (MQ_SERVICE_CALL_ARGS)
void	pymqmsgque_ServiceFree (MQ_SERVICE_FREE_ARGS)
void	pymqmsgque_ServiceCopy (MQ_SERVICE_COPY_ARGS)
OT_ProcRet	pymqmsgque_MqContextC_ReadLIST (MqContextC_ARGS)
	Python: [list...] ctx.ReadLIST() → C-API get all arguments as native list …
OT_ProcRet	pymqmsgque_MqContextC_Send (MqContextC_ARGS)

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_private_py.h.

Macro Definition Documentation

Send_doc_extra

#define Send_doc_extra   "[…] ctx.Send(\"CALL-SIGNATUR\",call-args …,\"TOKEN-SIGNATURE\",send-args …)"

Definition at line 27 of file LibMqMsgque_private_py.h.

Function Documentation

pymqmsgque_MqContextC_ReadLIST()

OT_ProcRet pymqmsgque_MqContextC_ReadLIST

(

MqContextC_ARGS

)

Python: [list...] ctx.ReadLIST() → C-API
get all arguments as native list …

Definition at line 17 of file MqContextC_ReadLIST_lng.h.

                                                     {
  OT_SETUP_hdl;
  OT_SETUP_NOARG(ReadLIST_doc);
  OT_CHECK_NOARGS;
  OT_retObj_SET_List;
  OT_OBJ_T RET = OT_LNG_NULL;
  MK_BUF buf = NULL;
  while (MqReadItemExists(hdl)) {
    MqReadBUF (hdl, &buf);
    switch (buf->var.type) {
      case MK_I8T:  { RET = OT_TMP_I8_OBJ(MkBuf2I8(buf)); break; }
      case MK_BOLT: { RET = OT_TMP_BOL_OBJ(MkBuf2BOL(buf)); break; }
      case MK_I16T: { RET = OT_TMP_I16_OBJ(MkBuf2I16(buf)); break; }
      case MK_I32T: { RET = OT_TMP_I32_OBJ(MkBuf2I32(buf)); break; }
      case MK_FLTT: { RET = OT_TMP_FLT_OBJ(MkBuf2FLT(buf)); break; }
      case MK_I64T: { RET = OT_TMP_I64_OBJ(MkBuf2I64(buf)); break; }
      case MK_DBLT: { RET = OT_TMP_DBL_OBJ(MkBuf2DBL(buf)); break; }
      case MK_BINT: { RET = OT_TMP_BIN_OBJ(buf->storage.first.B,buf->var.cursize); break; }
      case MK_STRT: { RET = OT_TMP_STR_OBJ(buf->storage.first.C); break; }
      case MK_LSTT: {
        MK_BFL bfl = MkBufferListCreate(5);
        MkErrorC_Check(hdl,MkBufferGetBFL (buf, &bfl));
        OT_MK_CALL_0(bfl,MkBufferListC,ToList,RET);
        MkRefDecr_X(bfl);
        break;
      }
/*
      case MQ_ROUT:
      case MQ_LTRT: {
        OT_ERROR_TYPE("unable to convert an 'internal' object into a 'public' object");
        RET = OT_LNG_NULL;
      }
*/
    }
    if (RET == OT_LNG_NULL) goto error;
    OT_retObj_APPEND(RET);
  }
  goto end;
  error:
  OT_retObj_SET_Error;
  end:
  OT_retObj_RETURN;
}

pymqmsgque_MqContextC_Send()

OT_ProcRet pymqmsgque_MqContextC_Send

(

MqContextC_ARGS

)

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

(

MQ_SERVICE_COPY_ARGS

)

pymqmsgque_ServiceFree()

void pymqmsgque_ServiceFree

(

MQ_SERVICE_FREE_ARGS

)