MqHigh_atl.c

Go to the documentation of this file.

 
/* LABEL-NO */
 
#define   META_FILE_NAME      "MqHigh_atl.c"
 
#include  "LibMqMsgque_private_atl.h"
 
#define   OT_CLASS            amqrt->AtlMqContextC
#define   OT_NULL             amqrt->AtlMqContextC_MK_NULL
#define   OT_CLASS_NAME       "MqContextC"
 
#define   SELF2HDL(O)          MqCtx(VAL2MNG(O))
 
#define   OT_SETUP_hdl        SetupHdlFromMetaData_2(MQ_CTX);
 
#if !defined(SetupRtFromHdl_XN)
  #define SetupRtFromHdl_XN(hdl)  AllRtSetup_XN(hdl)
  #define SetupRtFromHdl_X(hdl)   AllRtSetup_X(hdl)
#endif
 
/* LABEL-END */
 
#define META_CONTEXT_S hdl
 
int NS(MqContextC_Send) (MqContextC_ARGS) {
  //static const MK_STRN doc="[list…] [$ctx Send…]";
 
#define highSELF                "MqContextC::Send $ctx"
 
#define highSKIP                __skip
#define highSKIP_SHIFT          1
#define highSIZE                objc
 
#define highSIZE_AVAILABLE      1
#define highREAD_RETURN_LIST    1
#define highREAD_HAS_REFERENCE  1
 
#define highINITcstr            OT_CHECK_STR(cstr)
#define highCMD                 "%s '%s' ... '%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)
 
// Tcl has no "easy way" to check for an TCL error set with Tcl_SetObjErrorCode - dito - 
// if it is not a MQ error -> it is an TCL error
#define highERRORnative         if (!MkErrorCheckE_0E()) OT_ERROR_LNG_2_META(mqctx)
 
#define highRETerror            OT_ERROR_META_2_LNG(hdl); retObj = NULL
 
#define highRETURN              highRETURN_type_S
#define highRETok               goto end
 
#define highSend(T) {                      \
  high_T_##T val;                          \
  OT_CHECK_REQUIRED(OT_CHECK_##T(val));    \
  MkErrorCheck(MqSend##T(mqctx,val));      \
  break;                                   \
}
 
#define highSendObj(T) {                         \
  high_T_##T val;                                \
  OT_CHECK_REQUIRED(OT_CHECK_##T(val,false));    \
  MkErrorCheck(MqSend##T(mqctx,val));            \
  break;                                         \
}
 
/*
#define highSendBUF(T) {                   \
  high_T_##T val;                          \
printObjv;                                 \
  OT_CHECK_REQUIRED(OT_CHECK_##T(val));    \
printU(val);                               \
  MkErrorCheck(MqSend##T(mqctx,val));      \
  break;                                   \
}
*/
 
#define highSend_BOL  highSend(BOL)
#define highSend_I8   highSend(I8)
#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  highSendObj(BUF)
#define highSend_BFL  {                         \
  MkBufferListCreateTLS_T(bfl,5);               \
  OT_CHECK_REQUIRED(OT_CHECK_BFL(bfl,false))    \
  MqSendBFL_E(mqctx, bfl);                      \
  break;                                        \
}
#define highSend_BIN {                                  \
  MkBinaryR cbi={0};                                    \
  OT_CHECK_REQUIRED(OT_CHECK__ME_REF_MkBinaryR(cbi))    \
  MqSendBIN_E(mqctx, cbi);                              \
  break;                                                \
}
 
#define highReadRef(T) {                          \
  high_T_##T val = 0;                             \
  OT_CHECK_REQUIRED(OT_CHECK_LNG_T(readVal));     \
  MkErrorCheck(MqRead##T(mqctx,&val));            \
  if (readVal != NULL) {                          \
    OT_LNG_SET_VAR(readVal, high_C_##T (val));    \
  }                                               \
  break;                                          \
}
 
#define highREADprepare
#define highREADinit    readVal=NULL
 
#define highReadRef_I8  highReadRef(I8);
#define highReadRef_BOL highReadRef(BOL);
#define highReadRef_I16 highReadRef(I16);
#define highReadRef_I32 highReadRef(I32);
#define highReadRef_I64 highReadRef(I64);
#define highReadRef_HDL highReadRef(HDL);
#define highReadRef_FLT highReadRef(FLT);
#define highReadRef_DBL highReadRef(DBL);
#define highReadRef_STR highReadRef(STR);
#define highReadRef_BUF highReadRef(BUF);
#define highReadRef_BFL highReadRef(BFL);
#define highReadRef_ARGS highReadRef(A);
#define highReadRef_BIN {                                               \
  MkBinaryR cbi;                                                        \
  OT_CHECK_REQUIRED(OT_CHECK_LNG_T(readVal));                           \
  MqReadBIN_E(mqctx, &cbi);                                             \
  if (readVal) {                                                        \
    OT_LNG_SET_VAR(readVal, OT_TMP_BIN_OBJ(cbi.data,(int)cbi.size));    \
  }                                                                     \
  break;                                                                \
}
 
  OT_SETUP_hdl
  #define error error1
  OT_SETUP_VARARGS(1,99,highSELF "...");
  #undef error
#define mqctx hdl
  //Tcl_ResetResult(interp);
  Tcl_Obj *readVal;
 
  MK_CBP  fCall = NULL;
  MK_STRN  cstr = NULL;
 
// **************************************************************************************************
#define error high_error
  #include "tmpl/high_lng.h"
#undef error
// ********************************************************************************************
 
end:
  OT_retObj_RETURN;
error1:
  return TCL_ERROR;
}
 
 
// vim: nowrap