MqHigh_rb.c

Go to the documentation of this file.

 
/* LABEL-NO */
 
#define META_FILE_NAME "high_rb.c"
 
#include "LibMqMsgque_private_rb.h"
 
/* LABEL-END */
 
#define SetupRtFromObj_XN(o)    AllRtSetup_XN(o)
 
OT_ProcRet NS(MqContextC_Send) (MqContextC_ARGS) {
 
#define highSELF                "ctx.Send"
 
#define highSKIP                __skip
#define highSKIP_SHIFT          0
#define highSIZE                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); OT_retObj_SET_Error
#define highCMD                 "%s '%s' ... '%s' ..."
 
#define highRETURN              highRETURN_type_S 
#define highFARGS(f)            NS(ServiceCall),f,NS(ServiceFree)
 
#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)
 
// ruby has "long-jump" on error → there is NO error to retrieve !!
#define highERRORnative
 
// same as "OT_CHECK_xxx" on "LibMkKernel_rb.h" bit without "long-jump" in "MkErrorC_CheckD"
#undef MkErrorC_CheckD
#define MkErrorC_CheckD(p)  MkErrorCheck(p)
 
#define highSend(T) {                      \
  high_T_##T val;                          \
  OT_CHECK_REQUIRED(OT_CHECK_##T(val));    \
  MkErrorCheck(MqSend##T(mqctx,val));      \
  break;                                   \
}
 
#define highSend2(T) {                                \
  high_T_##T val;                                     \
  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);                                 \
}
 
#define highSend_BIN {                                  \
  MkBinaryR cbi = {0};                                  \
  OT_CHECK_REQUIRED(OT_CHECK__ME_REF_MkBinaryR(cbi))    \
  MkErrorCheck(MqSendBIN(mqctx, cbi));                  \
}
 
#define highREADprepare   OT_CHECK_NOARGS
#define highREADinit
 
/*
#define highReadRef(T) {                      \
  gigh_T_##T val;                             \
  MkErrorCheck(MqRead##T(mqctx,&val));        \
  OT_LNG_ARRAY_PUSH(RET, high_C_##T(val));    \
  break;                                      \
}
 
#define highReadRef_I8 highReadRef(Y);
#define highReadRef_BOL highReadRef(O);
#define highReadRef_I16 highReadRef(S);
#define highReadRef_I32 highReadRef(I);
#define highReadRef_FLT highReadRef(F);
#define highReadRef_I64 highReadRef(W);
#define highReadRef_DBL highReadRef(D);
#define highReadRef_STR highReadRef(C);
#define highReadRef_BUF highReadRef(U);
 
#define highReadRef_BFL { \
  VALUE val = (VALUE) NULL; \
  LngErrorCheckNG(val = NS(MqContextC_ReadLIST)(0,NULL,self)); \
  OT_LNG_ARRAY_PUSH(RET, val); \
  break; \
}
 
#define highReadRef_BIN { \
  MK_BINN cbi; \
  MK_SIZE siz; \
  MkErrorCheck(MqReadBIN(mqctx, &cbi, &siz)); \
  OT_LNG_ARRAY_PUSH(RET, OT_TMP_BIN_OBJ(cbi,siz)); \
  break; \
}
*/
 
  OT_SETUP_hdl_tmpl(MqContextC);
  OT_SETUP_VARARGS(0,99,"Send(...)");
 
  #define mqctx hdl
  MK_CBP  fCall = NULL;
  MK_STRN  cstr  = NULL;
 
// **************************************************************************************************
#include "tmpl/high_lng.h"
// **************************************************************************************************
 
  end:
  OT_retObj_RETURN
}
 
// vim: nowrap