MqHigh_py.c

Go to the documentation of this file.

 
/* LABEL-NO */
 
#define META_FILE_NAME            "MqHigh_py.c"
 
#include "LibMqMsgque_private_py.h"
 
#define OT_SETUP_CONSTR
#define OT_retObj_CONSTR(mng)     OT_retObj_SET(NS(MqContextC_New)((PyTypeObject*)class,mng))
 
#define SetupRtFromObj_XN(hdl)    MkRtSetup_XN(hdl)
#define OT_SETUP_hdl              OT_SETUP_hdl_tmpl(MqContextC)
 
/* LABEL-END */
 
#define META_CONTEXT_S              hdl
 
OT_ProcRet NS(MqContextC_Send) (MqContextC_ARGS) {
 
#define highSELF                "ctx.Send"
 
#define highSKIP                ((MK_NUM)__skip)
#define highSKIP_SHIFT          0
#define highSIZE                ((MK_NUM)objc)
 
#define highSIZE_AVAILABLE      1
#define highREAD_RETURN_LIST    1
#define highREAD_HAS_REFERENCE  0
 
#define highINITcstr            OT_CHECK_STR(cstr)
#define highRETok               goto end;
#define highRETerror            OT_ERROR_META_2_LNG(mqctx); \
                                retObj = NULL;
 
#define highCMD                 "%s '%s' ... '%s' ..."
 
#define highTRAN(str)           OT_CHECK_C_COPY(str,MQ_SEND_TRANSACTION_TOKEN_SIZE)
#define highTOKEN(str)          OT_CHECK_C_COPY(str,MQ_SEND_TOKEN_SIGNATURE_SIZE)
#define highTIME(t)             OT_CHECK_TIME_T(timeout) 
#define highCALL(f)             OT_CHECK_CALLABLE(f)
 
#define highERRORnative         if (PyErr_Occurred()) {OT_ERROR_LNG_2_META(mqctx);}
 
#define highRETURN              highRETURN_type_S
#define highFARGS(f)            NS(ServiceCall),f,NS(ServiceFree)
 
#define highSend(T) { \
    high_T_##T val = 0;\
    OT_CHECK_REQUIRED(OT_CHECK_##T(val)); \
    MkErrorCheck(MqSend##T(mqctx,val));\
    break; \
}
 
#define highSend2(T) { \
    high_T_##T val = 0;\
    OT_CHECK_REQUIRED(OT_CHECK_##T(val,MK_NULL_NO)); \
    MkErrorCheck(MqSend##T(mqctx,val));\
    break; \
}
 
#define highSend_I8  highSend(I8)
#define highSend_BOL highSend(BOL)
#define highSend_I16 highSend(I16)
#define highSend_I32 highSend(I32)
#define highSend_I64 highSend(I64)
#define highSend_HDL highSend(HDL)
#define highSend_FLT highSend(FLT)
#define highSend_DBL highSend(DBL)
#define highSend_STR highSend(STR)
#define highSend_BUF highSend2(BUF);
#define highSend_BFL { \
  MkBufferListCreateTLS_T(bfl,5); \
  OT_CHECK_REQUIRED(OT_CHECK_BFL(bfl,MK_NULL_NO)) \
  enum MkErrorE ret = MqSendBFL(mqctx, bfl); \
  MkErrorCheck(ret); \
  break; \
}
#define highSend_BIN { \
  MkBinaryR cbi = {0}; \
  OT_CHECK_REQUIRED(OT_CHECK__ME_REF_MkBinaryR(cbi)) \
  MkErrorCheck(MqSendBIN(mqctx, cbi)); \
  break; \
}
 
#define highREADprepare     OT_CHECK_NOARGS
#define highREADinit
 
/* python does NOT support references
 
#define highReadRef(T,TT) { \
  high_T_##T val; \
  MkErrorCheck(MqRead##T(mqctx,&val)); \
  OtErrorCheckLng(PyList_Append(RET, TT (val))) \
  break; \
}
 
#define highYread highReadRef(Y, OT_TMP_BYT_OBJ);
#define highOread highReadRef(O, OT_TMP_BOL_OBJ);
#define highSread highReadRef(S, OT_TMP_I16_OBJ);
#define highIread highReadRef(I, OT_TMP_I32_OBJ);
#define highFread highReadRef(F, OT_TMP_FLT_OBJ);
#define highWread highReadRef(W, OT_TMP_I64_OBJ);
#define highDread highReadRef(D, OT_TMP_DBL_OBJ);
#define highCread highReadRef(C, OT_TMP_STR_OBJ);
#define highUread highReadRef(U, OT_TMP_BUF_OBJ);
#define highLread highReadRef(L, OT_TMP_BFL_OBJ);
#define highAread highReadRef(A, OT_TMP_BFL_OBJ);
 
#define highBread { \
  MK_BINN cbi; \
  MK_SIZE siz; \
  MkErrorCheck(MqReadBIN(mqctx, &cbi, &siz)); \
  OtErrorCheckLng(PyList_Append(RET, OT_TMP_BIN_OBJ(cbi,siz))); \
  break; \
}
*/
 
  #define error error1
  OT_SETUP_hdl
  // BUG: no jump to error -> error: ‘ptr’ may be used uninitialized ...
  OT_SETUP_VARARGS(1,99,highSELF "...");
  #undef error
#define mqctx hdl
 
  PyErr_Clear();
 
  MK_CBP  fCall = NULL;
  MK_STRN  cstr = NULL;
 
// **************************************************************************************************
#include "tmpl/high_lng.h"
// ********************************************************************************************
 
  end:
    OT_retObj_RETURN
  error1:
    return NULL;
}
 
// vim: nowrap