LibMqMsgque_cc.cc

Go to the documentation of this file.

 
/* LABEL-NO */
 
#define META_FILE_NAME "LibMqMsgque_cc.cc"
 
#include <typeinfo>
#include <stdexcept>
 
#include "private_cc.hh"
#define META_CONTEXT_S hdl
 
namespace ccmqmsgque {
 
/* No longer used, PROBLEM: The order in which the STATIC destructors are called is NOT predictable
 
  MqStaticC MqMsgque::mq_sta;
 
  MqStaticC::MqStaticC() {
    MqMsgque::Setup();
  }
 
  MqStaticC::~MqStaticC() {
    MqMsgque::Cleanup();
  }
*/
 
  void MqMsgque::mq_static_init_callback ( MK_RT_ARGS_ONLY ) {
    MqRtSetup_NULL_RT;
 
    // BUG FIX : 2 apr 2025 → read more at "pFactoryThreadDupCheck"
    /* add new default factory */
    if (!strcmp(MqFactoryCT<MqContextC>::InitialIdent(),"libmqmsgque")) {
      MqFactoryCT<MqContextC>::Add("ccmqmsgque")->Default()->Initial();
    }
 
    // update the basic-types
    // BEGIN-MqMsgque-self - created by 'cc_MqC.tcl -i NHI1_HOME/theLink/c/gen/c_mqmsgque.meta' - DO NOT change
 
    MqFactoryC_TT->selfCreate = MqFactoryC::MqFactoryC_selfCreate ;
    MqFactoryC_TT->selfDelete = MqFactoryC::MqFactoryC_selfDelete ;
    MqFactoryC_TT->selfUnlink = MqFactoryC::MqFactoryC_selfUnlink ;
    MqDumpC_TT->selfCreate    = MqDumpC::MqDumpC_selfCreate       ;
    MqDumpC_TT->selfDelete    = MqDumpC::MqDumpC_selfDelete       ;
    MqDumpC_TT->selfUnlink    = MqDumpC::MqDumpC_selfUnlink       ;
    MqContextC_TT->selfCreate = MqContextC::MqContextC_selfCreate ;
    MqContextC_TT->selfDelete = MqContextC::MqContextC_selfDelete ;
    MqContextC_TT->selfUnlink = MqContextC::MqContextC_selfUnlink ;
 
    // END-MqMsgque-self - created by 'cc_MqC.tcl -i NHI1_HOME/theLink/c/gen/c_mqmsgque.meta' - DO NOT change
  }
 
  static MkRuntimeCallbackS sMqRuntimeCallback = {0};
 
 
  // doc-key: MqMsgque,MqMsgque-Setup,sm_
 
  void MqMsgque::CcMqCleanup ()  {
    MkRtSetup_NULL;
    MkRuntimeCallbackDel( MK_RT_CALL &sMqRuntimeCallback );
    MqCleanup();
  }
  #define MqCleanupTmpl() CcMqCleanup()
 
  void MqMsgque::CcMqSetup ()  {
    MqSetup();
    AllRtSetup_NULL;
 
    MkRuntimeCallbackAdd( MK_RT_CALL &sMqRuntimeCallback, mq_static_init_callback, "CcMqMsgque" );
  }
  #define MqSetupTmpl() CcMqSetup()
 
  // MqMsgque_Setup_CC_API
 
  // BEGIN-MqMsgque - created by 'cc_MqC.tcl -i NHI1_HOME/theLink/c/gen/c_mqmsgque.meta' - DO NOT change
 
 
  // doc-key: MqMsgque,MqMsgque-Setup,sm_
 
  void MqMsgque::Cleanup ()  {
    MkRtSetup_NULL;
    MqCleanupTmpl();
  }
 
  void MqMsgque::Setup ()  {
    MkRtSetup_NULL;
    MqSetupTmpl();
  }
 
  // MqMsgque_Setup_CC_API
 
  // END-MqMsgque - created by 'cc_MqC.tcl -i NHI1_HOME/theLink/c/gen/c_mqmsgque.meta' - DO NOT change
  
  // BEGIN-MqMsgque-null - created by 'cc_MqC.tcl -i NHI1_HOME/theLink/c/gen/c_mqmsgque.meta' - DO NOT change
 
  thread_local MqFactoryC MqFactoryC::MK_NULL_REF = {(MK_OBJ)0};
  thread_local MqDumpC       MqDumpC::MK_NULL_REF = {(MK_OBJ)0};
  thread_local MqContextC MqContextC::MK_NULL_REF = {(MK_OBJ)0};
 
  // END-MqMsgque-null - created by 'cc_MqC.tcl -i NHI1_HOME/theLink/c/gen/c_mqmsgque.meta' - DO NOT change
 
  // *******************************************************************************************************
  // MqContextC
 
  void MqContextC::Init(MK_STRN caller) {
    MQ_CTX ctx = reinterpret_cast<MQ_CTX>(hdl);
    MkRtSetup_X(ctx);
 
    // use "ctx->setup.Parent.fCreate" to ckeck in context was initialized
    if (ctx->bits.Init_LOCK == true) return;
    ctx->bits.Init_LOCK = true;
 
    // init the server interface
    MqServerSetupIF * const iSetup = dynamic_cast<MqServerSetupIF*const>(this);
    if (iSetup != NULL) {
      MqConfigSetServerSetup (ctx, MqServiceCallbackC::Call, MqServiceCallbackC::Create(MK_RT_CALL iSetup), \
        MqServiceCallbackC::Free, MqServiceCallbackC::Copy);
    }
    MqServerCleanupIF * const iCleanup = dynamic_cast<MqServerCleanupIF*const>(this);
    if (iCleanup != NULL) {
      MqConfigSetServerCleanup (ctx, MqServiceCallbackC::Call, MqServiceCallbackC::Create(MK_RT_CALL iCleanup), \
        MqServiceCallbackC::Free, MqServiceCallbackC::Copy);
    }
 
    // init the error interface
    MqBgErrorIF * const iBgError = dynamic_cast<MqBgErrorIF*const>(this);
    if (iBgError != NULL) {
      MqConfigSetBgError (ctx, MqServiceCallbackC::Call, MqServiceCallbackC::Create(MK_RT_CALL iBgError), \
        MqServiceCallbackC::Free, MqServiceCallbackC::Copy);
    }
 
    // init the event interface
    MqEventIF * const iEvent = dynamic_cast<MqEventIF*const>(this);
    if (iEvent != NULL) {
      MqConfigSetEvent (ctx, MqServiceCallbackC::Call, MqServiceCallbackC::Create(MK_RT_CALL iEvent), \
        MqServiceCallbackC::Free, MqServiceCallbackC::Copy);
    }
  }
 
  void MqContextC::LinkCheckOptionI32 (MK_STRN opt, MK_I32 *val) {
    MkRtSetup_NULL;
    ErrorCheck (MkBufferListCheckOptionI32 (reinterpret_cast<MQ_CTX>(hdl)->link.alfa, opt, 0, true, val));
  }
 
} // END - namespace "ccmqmsgque"
 
#if defined(_MSC_VER)
 
BOOL WINAPI DllMain(
    HINSTANCE hModule,
    DWORD  ul_reason_for_call,
    LPVOID lpReserved
)
{
  switch (ul_reason_for_call)
  {
    case DLL_THREAD_ATTACH:
    case DLL_THREAD_DETACH:
      return FALSE;
    case DLL_PROCESS_ATTACH:
      ccmqmsgque::MqMsgque::Setup();
      break;
    case DLL_PROCESS_DETACH:
      ccmqmsgque::MqMsgque::Cleanup();
      break;
  }
  return TRUE;
}
#endif