MqHigh_cc.cc

Go to the documentation of this file.

 
/* LABEL-NO */
 
#define META_FILE_NAME "MqHigh_cc.cc"
 
#include "private_cc.hh"
#include "MqCall_cc.hh"
//#include <iostream>
 
namespace ccmqmsgque {
 
  MkBufferListC* MqContextC::SendVA ( 
    MK_STRN          cstr, 
    MqTokenF const  fCall, 
    MK_PTR          data, 
    MqDataFreeF     fFree, 
    va_list         ap
  ) {
    MK_PTR va_val   = NULL;
    MQ_CTX mqctx = getCTX();
    MkRtSetup_XN(mqctx);
 
#define META_CONTEXT_S            mqctx
 
#define highSELF                "Send"
 
#define highSKIP                skip
    MK_I32 skip                 = 3;
#define highSKIP_SHIFT          0
#define highSIZE                4
 
#define highSIZE_AVAILABLE      0
#define highREAD_RETURN_LIST    1
#define highREAD_HAS_REFERENCE  1
 
#define highINITcstr          
#define highCMD                 "%s('%s', ..., '%s', ...)"
#define highFARGS(f)            f,data,fFree
 
#define highRETURN
#define highRETok               goto end
 
#define highERRORnative         /* c++ has long-jump */
#define highRETerror            MkExceptionC::Raise(mqctx);
 
#define highTIME(t)             t = va_arg(ap, MK_I32)
#define highCALL(f)             /* not used */
#define highTRAN(str)           strncpy(str,va_arg(ap, MK_STRN),MQ_SEND_TRANSACTION_TOKEN_SIZE)
#define highTOKEN(str)          do {                                             \
  MK_STRN tstr = va_arg(ap, MK_STRN);                                              \
  /* problem, C++ use 'va_args' and this does NOT provide any length-check */    \
  /* Send("R") is valid but 'high' read token and get "random" data */           \
  /* workaround 'isalnum' just check for useable character */                    \
  if (!isprint(*tstr)) goto call; /* A-Z0-9%.. */                                \
  strncpy(str,tstr,MQ_SEND_TOKEN_SIGNATURE_SIZE);                                \
} while (0)
 
#define high_N_BOL  int
#define high_N_I8   int
#define high_N_I16  int
#define high_N_I32  MK_I32
#define high_N_I64  MK_I64
#define high_N_HDL  MK_HDL
#define high_N_FLT  double
#define high_N_DBL  MK_DBL
#define high_N_STR  MK_STRN
#define high_N_BIN  MK_BNP
#define high_N_BUF  MkBufferC*
#define high_N_BFL  MkBufferListC*
 
#define high_T_BIN  MK_BNP
#define high_T_BUF  MkBufferC* 
#define high_T_BFL  MkBufferListC*
#define high_T_A    MkBufferListC*
 
#define highSend(T)             Send##T((high_T_##T)va_arg(ap, high_N_##T)); 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 highSend(BUF)
#define highSend_BFL highSend(BFL)
#define highSend_BIN highSend(BIN)
 
#define highREADprepare
#define highREADinit            va_val = (highSKIP < highSIZE ? va_arg(ap, MK_PTR*) : NULL); \
                                if (va_val == NULL) highSKIP = highSIZE;
 
#define ReadA ReadALL
 
#define highReadRef(T)          *(high_T_##T*)va_val = Read##T(); break;
 
#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(H)
#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 highReadRef(BIN)
 
// **************************************************************************************************
#define compile_as_cc_method
#include "tmpl/high_lng.h"
#undef  compile_as_cc_method
 
end:
  return MkBufferListC::MkBufferListC_ObjNew(MK_RT_CALL RET);
// **************************************************************************************************
 
  }
 
  MkBufferListC* MqContextC::Send (MK_STRN cstr, ...) {
    MkBufferListC*   ret;
    va_list       va;
    va_start(va, cstr);
    try {
      ret = SendVA(cstr, NULL, NULL, NULL, va);
    } catch (...) {
      va_end(va);
      throw;
    }
    va_end(va);
    return ret;
  }
 
  MkBufferListC* MqContextC::Send (const std::string& str, ...) {
    MkBufferListC*   ret;
    va_list       va;
    va_start(va, str);
    try {
      ret = SendVA(str.c_str(), NULL, NULL, NULL, va);
    } catch (...) {
      va_end(va);
      throw;
    }
    va_end(va);
    return ret;
  }
 
#define sendCB(cbt)                                                                        \
  MkBufferListC* MqContextC::Send (MK_STRN cstr, cbt const callback, ...) {                \
    MkRtSetup_O(hdl);                                                                      \
    MkBufferListC*   ret;                                                                  \
    va_list       va;                                                                      \
    va_start(va, callback);                                                                \
    try {                                                                                  \
      ret = SendVA(cstr, MqServiceCallbackC::Call,                                         \
        MqServiceCallbackC::Create(MK_RT_CALL callback), MqServiceCallbackC::Free, va);    \
    } catch (...) {                                                                        \
      va_end(va);                                                                          \
      throw;                                                                               \
    }                                                                                      \
    va_end(va);                                                                            \
    return ret;                                                                            \
  }                                                                                        \
  MkBufferListC* MqContextC::Send (const std::string& str, cbt const callback, ...) {    \
    MkRtSetup_O(hdl);                                                                      \
    MkBufferListC*   ret;                                                                  \
    va_list       va;                                                                      \
    va_start(va, callback);                                                                \
    try {                                                                                  \
      ret = SendVA(str.c_str(), MqServiceCallbackC::Call,                                  \
        MqServiceCallbackC::Create(MK_RT_CALL callback), MqServiceCallbackC::Free, va);    \
    } catch (...) {                                                                        \
      va_end(va);                                                                          \
      throw;                                                                               \
    }                                                                                      \
    va_end(va);                                                                            \
    return ret;                                                                            \
  }
 
  sendCB(MqTokenICB)
  sendCB(MqTokenCCB)
  sendCB(MqServiceIF*)
 
} // END - namespace "ccmqmsgque"