LibMqMsgque_atl.c

Go to the documentation of this file.

 
/* LABEL-NO */
 
#define   META_FILE_NAME          "MqMsgque_atl.c"
 
#include  "LibMqMsgque_private_atl.h"
 
#undef OtClass_ARGS
#define OtClass_ARGS  OBJCMD_ARGS
 
#define OT_SETUP_hdl_static \
  int __skip=1;\
  /* printAry2("cmd",objc,objv); */ \
  MK_UNUSED OT_MQ_RT_T  amqrt = clientData; \
  MK_UNUSED OT_MK_RT_T  amkrt = amqrt->amkrt; \
  MK_UNUSED MK_RT       mkrt  = amqrt->mkrt; \
  MK_UNUSED MK_ERR      hdl   = &MkERROR;
 
/* LABEL-END */
 
#include <limits.h>
#include <float.h>
 
#include "mk_check_atl.h"
 
#define MqSetupTmpl()
#define MqCleanupTmpl()
 
#define META_CONTEXT_S hdl
 
// MARK_D ################################################################
// -----------------------------------------------------------------------
// documentation order
 
 
 
 
 
 
 
 
 
// --------------------------------------------------------------------------------
 
typedef int (
  *LookupObjSF
) (
  Tcl_Interp              *interp,
  int                     objc,
  struct Tcl_Obj *const * objv
);
 
struct LookupObjS {
  const char      *key;
  LookupObjSF  keyF;
};
 
MkThreadLocal bool NS(inMain) = false;
 
// --------------------------------------------------------------------------------
 
// BEGIN-DOC - created by 'atl_MqS.tcl -i NHI1_HOME/theLink/c/gen/c_mqmsgque.meta' - DO NOT change
 
// doc-key: MqMsgque,EnumFunc,sco,func
#define IdentE_FromInt_doc "MqIdentE [MqMsgque::IdentE_FromInt value:int32]"
#define SlaveE_FromInt_doc "MqSlaveE [MqMsgque::SlaveE_FromInt value:int32]"
#define StartE_FromInt_doc "MqStartE [MqMsgque::StartE_FromInt value:int32]"
#define StatusIsEF_FromInt_doc "MqStatusIsEF [MqMsgque::StatusIsEF_FromInt value:int32]"
#define WaitOnEventE_FromInt_doc "MqWaitOnEventE [MqMsgque::WaitOnEventE_FromInt value:int32]"
 
// doc-key: MqMsgque,EnumFunc,sm_,func
#define IdentE_ToInt_doc "int32 [MqMsgque::IdentE_ToInt value:MqIdentE]"
#define IdentE_ToString_doc "string [MqMsgque::IdentE_ToString value:MqIdentE]"
#define SlaveE_ToInt_doc "int32 [MqMsgque::SlaveE_ToInt value:MqSlaveE]"
#define SlaveE_ToString_doc "string [MqMsgque::SlaveE_ToString value:MqSlaveE]"
#define StartE_ToInt_doc "int32 [MqMsgque::StartE_ToInt value:MqStartE]"
#define StartE_ToString_doc "string [MqMsgque::StartE_ToString value:MqStartE]"
#define StatusIsEF_ToInt_doc "int32 [MqMsgque::StatusIsEF_ToInt value:MqStatusIsEF]"
#define StatusIsEF_ToString_doc "string [MqMsgque::StatusIsEF_ToString value:MqStatusIsEF]"
#define WaitOnEventE_ToInt_doc "int32 [MqMsgque::WaitOnEventE_ToInt value:MqWaitOnEventE]"
#define WaitOnEventE_ToString_doc "string [MqMsgque::WaitOnEventE_ToString value:MqWaitOnEventE]"
 
// doc-key: MqMsgque,MqHelp,sm_,func
#define Help_doc "string [MqMsgque::Help tool:string]"
#define HelpMsgque_doc "string [MqMsgque::HelpMsgque]"
 
// doc-key: MqMsgque,MqInit,sm_,func
#define InitGetArg0_doc "MkBufferListC [MqMsgque::InitGetArg0]"
#define InitResetArg0_doc "MkBufferListC [MqMsgque::InitResetArg0]"
#define InitSetArg0_doc "MqMsgque::InitSetArg0 ?bfl:MkBufferListC...=NULL?"
 
// doc-key: MqMsgque,MqMain,sm_,func
#define Main_doc "MqMsgque::Main code:..."
 
// doc-key: MqMsgque,Setup,sm_,func
#define Cleanup_doc "MqMsgque::Cleanup"
#define Setup_doc "MqMsgque::Setup"
 
// END-DOC - created by 'atl_MqS.tcl -i NHI1_HOME/theLink/c/gen/c_mqmsgque.meta' - DO NOT change
 
/*****************************************************************************/
/*                                                                           */
/*                                enum                                       */
/*                                                                           */
/*****************************************************************************/
 
// ===============================================================================================
 
// BEGIN-Enum-ToString - created by 'atl_MqC.tcl -i NHI1_HOME/theLink/c/gen/c_mqmsgque.meta' - DO NOT change
 
 
OT_OBJ_T MQ(MqFactoryE_ToString) ( const  enum MqFactoryE type ) 
{
  OT_OBJ_T tmpO = Tcl_NewObj();
  if (mk_bit_compare(type,MQ_FACTORY_NEW_INIT  )) ot_enum_append(tmpO,"INIT"  ) ;
  if (mk_bit_compare(type,MQ_FACTORY_NEW_CHILD )) ot_enum_append(tmpO,"CHILD" ) ;
  if (mk_bit_compare(type,MQ_FACTORY_NEW_SLAVE )) ot_enum_append(tmpO,"SLAVE" ) ;
  if (mk_bit_compare(type,MQ_FACTORY_NEW_FORK  )) ot_enum_append(tmpO,"FORK"  ) ;
  if (mk_bit_compare(type,MQ_FACTORY_NEW_THREAD)) ot_enum_append(tmpO,"THREAD") ;
  if (mk_bit_compare(type,MQ_FACTORY_NEW_FILTER)) ot_enum_append(tmpO,"FILTER") ;
  return tmpO;
}
 
OT_OBJ_T MQ(MqHandShakeE_ToString) ( const enum MqHandShakeE type ) 
{
  switch (type) {
    case MQ_HANDSHAKE_START : return ot_fixstrobj("START") ;
    case MQ_HANDSHAKE_OK    : return ot_fixstrobj("OK"   ) ;
    case MQ_HANDSHAKE_ERROR : return ot_fixstrobj("ERROR") ;
  }
  return ot_fixstrobj("NOTHING");
}
 
OT_OBJ_T MQ(MqIdentE_ToString) ( const enum MqIdentE type ) 
{
  switch (type) {
    case MQ_IDENT_PREFIX  : return ot_fixstrobj("PREFIX" ) ;
    case MQ_IDENT_FACTORY : return ot_fixstrobj("FACTORY") ;
  }
  return ot_fixstrobj("NOTHING");
}
 
OT_OBJ_T MQ(MqIoComE_ToString) ( const enum MqIoComE type ) 
{
  switch (type) {
    case MQ_IO_PIPE : return ot_fixstrobj("PIPE") ;
    case MQ_IO_UDS  : return ot_fixstrobj("UDS" ) ;
    case MQ_IO_TCP  : return ot_fixstrobj("TCP" ) ;
    case MQ_IO_INIT : return ot_fixstrobj("INIT") ;
    case MQ_IO_LOOP : return ot_fixstrobj("LOOP") ;
  }
  return ot_fixstrobj("NOTHING");
}
 
OT_OBJ_T MQ(MqSlaveE_ToString) ( const enum MqSlaveE type ) 
{
  switch (type) {
    case MQ_SLAVE_LOOPBACK : return ot_fixstrobj("LOOPBACK") ;
    case MQ_SLAVE_FILTER   : return ot_fixstrobj("FILTER"  ) ;
    case MQ_SLAVE_USER     : return ot_fixstrobj("USER"    ) ;
    case MQ_SLAVE_MAX      : return ot_fixstrobj("MAX"     ) ;
  }
  return ot_fixstrobj("NOTHING");
}
 
OT_OBJ_T MQ(MqStartE_ToString) ( const enum MqStartE type ) 
{
  switch (type) {
    case MQ_START_DEFAULT : return ot_fixstrobj("DEFAULT") ;
    case MQ_START_FORK    : return ot_fixstrobj("FORK"   ) ;
    case MQ_START_THREAD  : return ot_fixstrobj("THREAD" ) ;
    case MQ_START_SPAWN   : return ot_fixstrobj("SPAWN"  ) ;
  }
  return ot_fixstrobj("NOTHING");
}
 
OT_OBJ_T MQ(MqStatusIsEF_ToString) ( const  enum MqStatusIsEF type ) 
{
  if (type == MQ_STATUS_IS_INITIAL) {
    return ot_fixstrobj("INITIAL");
  } else {
    OT_OBJ_T tmpO = Tcl_NewObj();
    if (mk_bit_compare(type,MQ_STATUS_IS_DUP    )) ot_enum_append(tmpO,"DUP"    ) ;
    if (mk_bit_compare(type,MQ_STATUS_IS_THREAD )) ot_enum_append(tmpO,"THREAD" ) ;
    if (mk_bit_compare(type,MQ_STATUS_IS_FORK   )) ot_enum_append(tmpO,"FORK"   ) ;
    if (mk_bit_compare(type,MQ_STATUS_IS_SPAWN  )) ot_enum_append(tmpO,"SPAWN"  ) ;
    return tmpO;
  }
}
 
OT_OBJ_T MQ(MqTransTypeE_ToString) ( const enum MqTransTypeE type ) 
{
  switch (type) {
    case MQ_TRANS_TYPE_WAIT  : return ot_fixstrobj("WAIT" ) ;
    case MQ_TRANS_TYPE_SUB   : return ot_fixstrobj("SUB"  ) ;
    case MQ_TRANS_TYPE_CB    : return ot_fixstrobj("CB"   ) ;
    case MQ_TRANS_TYPE_TRANS : return ot_fixstrobj("TRANS") ;
    case MQ_TRANS_TYPE_NO    : return ot_fixstrobj("NO"   ) ;
  }
  return ot_fixstrobj("NOTHING");
}
 
OT_OBJ_T MQ(MqWaitOnEventE_ToString) ( const enum MqWaitOnEventE type ) 
{
  switch (type) {
    case MQ_WAIT_NO      : return ot_fixstrobj("NO"     ) ;
    case MQ_WAIT_ONCE    : return ot_fixstrobj("ONCE"   ) ;
    case MQ_WAIT_OWN     : return ot_fixstrobj("OWN"    ) ;
    case MQ_WAIT_FOREVER : return ot_fixstrobj("FOREVER") ;
  }
  return ot_fixstrobj("NOTHING");
}
 
// END-Enum-ToString - created by 'atl_MqC.tcl -i NHI1_HOME/theLink/c/gen/c_mqmsgque.meta' - DO NOT change
 
// BEGIN-enum - created by 'atl_MqS.tcl -i NHI1_HOME/theLink/c/gen/c_mqmsgque.meta' - DO NOT change
 
 
int MQ(Get_MqIdentE_FromObj) (MK_RT_ARGS OT_ENV_T interp, OT_OBJ_T enumE, enum MqIdentE *ret) {
  const static struct LookupEnumE keys[] = {
    { "PREFIX"           , MQ_IDENT_PREFIX  },
    { "FACTORY"          , MQ_IDENT_FACTORY },
    { "IDENT_PREFIX"     , MQ_IDENT_PREFIX  },
    { "IDENT_FACTORY"    , MQ_IDENT_FACTORY },
    { "MQ_IDENT_PREFIX"  , MQ_IDENT_PREFIX  },
    { "MQ_IDENT_FACTORY" , MQ_IDENT_FACTORY },
    { NULL               , 0                },
  };
 
  int index;
  check_LNG(Tcl_GetIndexFromObjStruct (interp, enumE, &keys,
      sizeof(struct LookupClassS), "enum", TCL_EXACT, &index)) return TCL_ERROR;
  *ret = keys[index].val;
  return TCL_OK;
}
 
int MQ(Get_MqSlaveE_FromObj) (MK_RT_ARGS OT_ENV_T interp, OT_OBJ_T enumE, enum MqSlaveE *ret) {
  const static struct LookupEnumE keys[] = {
    { "MAX"               , MQ_SLAVE_MAX      },
    { "USER"              , MQ_SLAVE_USER     },
    { "OTHER"             , MQ_SLAVE_OTHER    },
    { "MASTER"            , MQ_SLAVE_MASTER   },
    { "FILTER"            , MQ_SLAVE_FILTER   },
    { "LOOPBACK"          , MQ_SLAVE_LOOPBACK },
    { "SLAVE_MAX"         , MQ_SLAVE_MAX      },
    { "SLAVE_USER"        , MQ_SLAVE_USER     },
    { "SLAVE_OTHER"       , MQ_SLAVE_OTHER    },
    { "SLAVE_FILTER"      , MQ_SLAVE_FILTER   },
    { "SLAVE_MASTER"      , MQ_SLAVE_MASTER   },
    { "MQ_SLAVE_MAX"      , MQ_SLAVE_MAX      },
    { "MQ_SLAVE_USER"     , MQ_SLAVE_USER     },
    { "MQ_SLAVE_OTHER"    , MQ_SLAVE_OTHER    },
    { "SLAVE_LOOPBACK"    , MQ_SLAVE_LOOPBACK },
    { "MQ_SLAVE_FILTER"   , MQ_SLAVE_FILTER   },
    { "MQ_SLAVE_MASTER"   , MQ_SLAVE_MASTER   },
    { "MQ_SLAVE_LOOPBACK" , MQ_SLAVE_LOOPBACK },
    { NULL                , 0                 },
  };
 
  int index;
  check_LNG(Tcl_GetIndexFromObjStruct (interp, enumE, &keys,
      sizeof(struct LookupClassS), "enum", TCL_EXACT, &index)) return TCL_ERROR;
  *ret = keys[index].val;
  return TCL_OK;
}
 
int MQ(Get_MqStartE_FromObj) (MK_RT_ARGS OT_ENV_T interp, OT_OBJ_T enumE, enum MqStartE *ret) {
  const static struct LookupEnumE keys[] = {
    { "FORK"             , MQ_START_FORK    },
    { "SPAWN"            , MQ_START_SPAWN   },
    { "THREAD"           , MQ_START_THREAD  },
    { "DEFAULT"          , MQ_START_DEFAULT },
    { "START_FORK"       , MQ_START_FORK    },
    { "START_SPAWN"      , MQ_START_SPAWN   },
    { "START_THREAD"     , MQ_START_THREAD  },
    { "MQ_START_FORK"    , MQ_START_FORK    },
    { "START_DEFAULT"    , MQ_START_DEFAULT },
    { "MQ_START_SPAWN"   , MQ_START_SPAWN   },
    { "MQ_START_THREAD"  , MQ_START_THREAD  },
    { "MQ_START_DEFAULT" , MQ_START_DEFAULT },
    { NULL               , 0                },
  };
 
  int index;
  check_LNG(Tcl_GetIndexFromObjStruct (interp, enumE, &keys,
      sizeof(struct LookupClassS), "enum", TCL_EXACT, &index)) return TCL_ERROR;
  *ret = keys[index].val;
  return TCL_OK;
}
 
int MQ(Get_MqStatusIsEF_FromObj) (MK_RT_ARGS OT_ENV_T interp, OT_OBJ_T enumE, enum MqStatusIsEF *ret) {
  const static struct LookupEnumE keys[] = {
    { "DUP"                  , MQ_STATUS_IS_DUP     },
    { "FORK"                 , MQ_STATUS_IS_FORK    },
    { "SPAWN"                , MQ_STATUS_IS_SPAWN   },
    { "THREAD"               , MQ_STATUS_IS_THREAD  },
    { "IS_DUP"               , MQ_STATUS_IS_DUP     },
    { "INITIAL"              , MQ_STATUS_IS_INITIAL },
    { "IS_FORK"              , MQ_STATUS_IS_FORK    },
    { "IS_SPAWN"             , MQ_STATUS_IS_SPAWN   },
    { "IS_THREAD"            , MQ_STATUS_IS_THREAD  },
    { "IS_INITIAL"           , MQ_STATUS_IS_INITIAL },
    { "STATUS_IS_DUP"        , MQ_STATUS_IS_DUP     },
    { "STATUS_IS_FORK"       , MQ_STATUS_IS_FORK    },
    { "STATUS_IS_SPAWN"      , MQ_STATUS_IS_SPAWN   },
    { "MQ_STATUS_IS_DUP"     , MQ_STATUS_IS_DUP     },
    { "STATUS_IS_THREAD"     , MQ_STATUS_IS_THREAD  },
    { "STATUS_IS_INITIAL"    , MQ_STATUS_IS_INITIAL },
    { "MQ_STATUS_IS_FORK"    , MQ_STATUS_IS_FORK    },
    { "MQ_STATUS_IS_SPAWN"   , MQ_STATUS_IS_SPAWN   },
    { "MQ_STATUS_IS_THREAD"  , MQ_STATUS_IS_THREAD  },
    { "MQ_STATUS_IS_INITIAL" , MQ_STATUS_IS_INITIAL },
    { NULL                   , 0                    },
  };
 
  int index;
  check_LNG(MK(EnumFlagWorker)(MK_RT_CALL interp,keys,enumE,&index)) return TCL_ERROR;
  *ret = (enum MqStatusIsEF) index;
  return TCL_OK;
}
 
int MQ(Get_MqWaitOnEventE_FromObj) (MK_RT_ARGS OT_ENV_T interp, OT_OBJ_T enumE, enum MqWaitOnEventE *ret) {
  const static struct LookupEnumE keys[] = {
    { "NO"              , MQ_WAIT_NO      },
    { "OWN"             , MQ_WAIT_OWN     },
    { "ONCE"            , MQ_WAIT_ONCE    },
    { "FOREVER"         , MQ_WAIT_FOREVER },
    { "WAIT_NO"         , MQ_WAIT_NO      },
    { "WAIT_OWN"        , MQ_WAIT_OWN     },
    { "WAIT_ONCE"       , MQ_WAIT_ONCE    },
    { "MQ_WAIT_NO"      , MQ_WAIT_NO      },
    { "MQ_WAIT_OWN"     , MQ_WAIT_OWN     },
    { "WAIT_FOREVER"    , MQ_WAIT_FOREVER },
    { "MQ_WAIT_ONCE"    , MQ_WAIT_ONCE    },
    { "MQ_WAIT_FOREVER" , MQ_WAIT_FOREVER },
    { NULL              , 0               },
  };
 
  int index;
  check_LNG(Tcl_GetIndexFromObjStruct (interp, enumE, &keys,
      sizeof(struct LookupClassS), "enum", TCL_EXACT, &index)) return TCL_ERROR;
  *ret = keys[index].val;
  return TCL_OK;
}
 
// END-enum - created by 'atl_MqS.tcl -i NHI1_HOME/theLink/c/gen/c_mqmsgque.meta' - DO NOT change
 
/*****************************************************************************/
/*                                                                           */
/*                                 Check                                     */
/*                                                                           */
/*****************************************************************************/
 
#include "tmpl/mq_misc_check_lng.h"
 
enum MkErrorE MQ(CheckConstructor) (OT_Check_ARGS, MK_CCP* constrP)
{
  SETUP_moxrt;
  if ((*skipP) >= objc) {
    WrongNumArgs(hdl,(*skipP), objc, -999, +999, arg);
    goto error;
  }
  OT_OBJ_T classO = OT_LNG_OBJV((*skipP)++);
 
  if (MoxClsIsN(classO)) {
    OT_REF_INCR(classO);    // OT_REF_DECR in: sFactoryDataFree
    *constrP = classO;
  } else {
    WrongTypeOfArgError("Class",VAL2STR(classO));
  }
 
  return MK_OK;
error:
  return MkErrorStack_0E();
}
 
/*****************************************************************************/
/*                                                                           */
/*                               subcommands                                 */
/*                                                                           */
/*****************************************************************************/
 
 
static OT_ProcRet NS(MqMsgque_Main) (OtClass_ARGS)
{
  OT_SETUP_hdl_static
  WNA(1,1,"code")
 
  if (Tcl_GetVar2Ex(interp,"MQ_STARTUP_IS_THREAD",NULL,TCL_GLOBAL_ONLY) == NULL) {
    NS(inMain) = true;
    int ret = Tcl_EvalObjEx (interp, objv[__skip], TCL_EVAL_GLOBAL);
    NS(inMain) = false;
    check_LNG (ret) return TCL_ERROR;
  }
  return TCL_OK;
}
 
 
// BEGIN-MqMsgque - created by 'atl_MqC.tcl -i NHI1_HOME/theLink/c/gen/c_mqmsgque.meta' - DO NOT change
 
 
// doc-key: MqMsgque,MqMsgque-Enum,sco
 
static OT_ProcRet NS(MqMsgque_IdentE_FromInt) (OtClass_ARGS) {
  OT_SETUP_hdl_static;
  OT_SETUP_ONEARG(IdentE_FromInt_doc);
  MK_I32 value = 0;
  OT_CHECK_REQUIRED(OT_CHECK_NI4 (value))
  OT_CHECK_NOARGS;
  enum MqIdentE value_out;
  MkErrorC_Check(MK_ERROR_FORMAT,MqIdentE_FromInt (value, &value_out));
  OT_retObj_SET(OT_NEW_Mq_enum_OBJ(IdentE,value_out));
  goto end;
  error:
  OT_retObj_SET_Error;
  end:
  OT_retObj_RETURN;
}
 
static OT_ProcRet NS(MqMsgque_SlaveE_FromInt) (OtClass_ARGS) {
  OT_SETUP_hdl_static;
  OT_SETUP_ONEARG(SlaveE_FromInt_doc);
  MK_I32 value = 0;
  OT_CHECK_REQUIRED(OT_CHECK_NI4 (value))
  OT_CHECK_NOARGS;
  enum MqSlaveE value_out;
  MkErrorC_Check(MK_ERROR_FORMAT,MqSlaveE_FromInt (value, &value_out));
  OT_retObj_SET(OT_NEW_Mq_enum_OBJ(SlaveE,value_out));
  goto end;
  error:
  OT_retObj_SET_Error;
  end:
  OT_retObj_RETURN;
}
 
static OT_ProcRet NS(MqMsgque_StartE_FromInt) (OtClass_ARGS) {
  OT_SETUP_hdl_static;
  OT_SETUP_ONEARG(StartE_FromInt_doc);
  MK_I32 value = 0;
  OT_CHECK_REQUIRED(OT_CHECK_NI4 (value))
  OT_CHECK_NOARGS;
  enum MqStartE value_out;
  MkErrorC_Check(MK_ERROR_FORMAT,MqStartE_FromInt (value, &value_out));
  OT_retObj_SET(OT_NEW_Mq_enum_OBJ(StartE,value_out));
  goto end;
  error:
  OT_retObj_SET_Error;
  end:
  OT_retObj_RETURN;
}
 
static OT_ProcRet NS(MqMsgque_StatusIsEF_FromInt) (OtClass_ARGS) {
  OT_SETUP_hdl_static;
  OT_SETUP_ONEARG(StatusIsEF_FromInt_doc);
  MK_I32 value = 0;
  OT_CHECK_REQUIRED(OT_CHECK_NI4 (value))
  OT_CHECK_NOARGS;
  enum MqStatusIsEF value_out;
  MkErrorC_Check(MK_ERROR_FORMAT,MqStatusIsEF_FromInt (value, &value_out));
  OT_retObj_SET(OT_NEW_Mq_enum_OBJ(StatusIsEF,value_out));
  goto end;
  error:
  OT_retObj_SET_Error;
  end:
  OT_retObj_RETURN;
}
 
static OT_ProcRet NS(MqMsgque_WaitOnEventE_FromInt) (OtClass_ARGS) {
  OT_SETUP_hdl_static;
  OT_SETUP_ONEARG(WaitOnEventE_FromInt_doc);
  MK_I32 value = 0;
  OT_CHECK_REQUIRED(OT_CHECK_NI4 (value))
  OT_CHECK_NOARGS;
  enum MqWaitOnEventE value_out;
  MkErrorC_Check(MK_ERROR_FORMAT,MqWaitOnEventE_FromInt (value, &value_out));
  OT_retObj_SET(OT_NEW_Mq_enum_OBJ(WaitOnEventE,value_out));
  goto end;
  error:
  OT_retObj_SET_Error;
  end:
  OT_retObj_RETURN;
}
 
// doc-key: MqMsgque,MqMsgque-Enum,sm_
 
static OT_ProcRet NS(MqMsgque_IdentE_ToInt) (OtClass_ARGS) {
  OT_SETUP_hdl_static;
  OT_SETUP_ONEARG(IdentE_ToInt_doc);
  enum MqIdentE value = 0;
  OT_CHECK_REQUIRED(OT_CHECK_ENUM (MqIdentE,value))
  OT_CHECK_NOARGS;
  OT_retObj_SET_I32(MqIdentE_ToInt (value));
  goto end;
  error:
  OT_retObj_SET_Error;
  end:
  OT_retObj_RETURN;
}
 
static OT_ProcRet NS(MqMsgque_IdentE_ToString) (OtClass_ARGS) {
  OT_SETUP_hdl_static;
  OT_SETUP_ONEARG(IdentE_ToString_doc);
  enum MqIdentE value = 0;
  OT_CHECK_REQUIRED(OT_CHECK_ENUM (MqIdentE,value))
  OT_CHECK_NOARGS;
  OT_retObj_SET_STR(MqIdentE_ToString (value));
  goto end;
  error:
  OT_retObj_SET_Error;
  end:
  OT_retObj_RETURN;
}
 
static OT_ProcRet NS(MqMsgque_SlaveE_ToInt) (OtClass_ARGS) {
  OT_SETUP_hdl_static;
  OT_SETUP_ONEARG(SlaveE_ToInt_doc);
  enum MqSlaveE value = 0;
  OT_CHECK_REQUIRED(OT_CHECK_ENUM (MqSlaveE,value))
  OT_CHECK_NOARGS;
  OT_retObj_SET_I32(MqSlaveE_ToInt (value));
  goto end;
  error:
  OT_retObj_SET_Error;
  end:
  OT_retObj_RETURN;
}
 
static OT_ProcRet NS(MqMsgque_SlaveE_ToString) (OtClass_ARGS) {
  OT_SETUP_hdl_static;
  OT_SETUP_ONEARG(SlaveE_ToString_doc);
  enum MqSlaveE value = 0;
  OT_CHECK_REQUIRED(OT_CHECK_ENUM (MqSlaveE,value))
  OT_CHECK_NOARGS;
  OT_retObj_SET_STR(MqSlaveE_ToString (value));
  goto end;
  error:
  OT_retObj_SET_Error;
  end:
  OT_retObj_RETURN;
}
 
static OT_ProcRet NS(MqMsgque_StartE_ToInt) (OtClass_ARGS) {
  OT_SETUP_hdl_static;
  OT_SETUP_ONEARG(StartE_ToInt_doc);
  enum MqStartE value = 0;
  OT_CHECK_REQUIRED(OT_CHECK_ENUM (MqStartE,value))
  OT_CHECK_NOARGS;
  OT_retObj_SET_I32(MqStartE_ToInt (value));
  goto end;
  error:
  OT_retObj_SET_Error;
  end:
  OT_retObj_RETURN;
}
 
static OT_ProcRet NS(MqMsgque_StartE_ToString) (OtClass_ARGS) {
  OT_SETUP_hdl_static;
  OT_SETUP_ONEARG(StartE_ToString_doc);
  enum MqStartE value = 0;
  OT_CHECK_REQUIRED(OT_CHECK_ENUM (MqStartE,value))
  OT_CHECK_NOARGS;
  OT_retObj_SET_STR(MqStartE_ToString (value));
  goto end;
  error:
  OT_retObj_SET_Error;
  end:
  OT_retObj_RETURN;
}
 
static OT_ProcRet NS(MqMsgque_StatusIsEF_ToInt) (OtClass_ARGS) {
  OT_SETUP_hdl_static;
  OT_SETUP_ONEARG(StatusIsEF_ToInt_doc);
  enum MqStatusIsEF value = 0;
  OT_CHECK_REQUIRED(OT_CHECK_ENUM (MqStatusIsEF,value))
  OT_CHECK_NOARGS;
  OT_retObj_SET_I32(MqStatusIsEF_ToInt (value));
  goto end;
  error:
  OT_retObj_SET_Error;
  end:
  OT_retObj_RETURN;
}
 
static OT_ProcRet NS(MqMsgque_StatusIsEF_ToString) (OtClass_ARGS) {
  OT_SETUP_hdl_static;
  OT_SETUP_ONEARG(StatusIsEF_ToString_doc);
  enum MqStatusIsEF value = 0;
  OT_CHECK_REQUIRED(OT_CHECK_ENUM (MqStatusIsEF,value))
  OT_CHECK_NOARGS;
  OT_retObj_SET_STR(MqStatusIsEF_ToString (value));
  goto end;
  error:
  OT_retObj_SET_Error;
  end:
  OT_retObj_RETURN;
}
 
static OT_ProcRet NS(MqMsgque_WaitOnEventE_ToInt) (OtClass_ARGS) {
  OT_SETUP_hdl_static;
  OT_SETUP_ONEARG(WaitOnEventE_ToInt_doc);
  enum MqWaitOnEventE value = 0;
  OT_CHECK_REQUIRED(OT_CHECK_ENUM (MqWaitOnEventE,value))
  OT_CHECK_NOARGS;
  OT_retObj_SET_I32(MqWaitOnEventE_ToInt (value));
  goto end;
  error:
  OT_retObj_SET_Error;
  end:
  OT_retObj_RETURN;
}
 
static OT_ProcRet NS(MqMsgque_WaitOnEventE_ToString) (OtClass_ARGS) {
  OT_SETUP_hdl_static;
  OT_SETUP_ONEARG(WaitOnEventE_ToString_doc);
  enum MqWaitOnEventE value = 0;
  OT_CHECK_REQUIRED(OT_CHECK_ENUM (MqWaitOnEventE,value))
  OT_CHECK_NOARGS;
  OT_retObj_SET_STR(MqWaitOnEventE_ToString (value));
  goto end;
  error:
  OT_retObj_SET_Error;
  end:
  OT_retObj_RETURN;
}
 
// MqMsgque_Enum_ATL_API
 
 
// doc-key: MqMsgque,MqMsgque-Help,sm_
 
static OT_ProcRet NS(MqMsgque_Help) (OtClass_ARGS) {
  OT_SETUP_hdl_static;
  OT_SETUP_ONEARG(Help_doc);
  MK_STRN tool = 0;
  OT_CHECK_REQUIRED(OT_CHECK_STRN (tool))
  OT_CHECK_NOARGS;
  OT_retObj_SET_STR(MqHelp (tool));
  goto end;
  error:
  OT_retObj_SET_Error;
  end:
  OT_retObj_RETURN;
}
 
static OT_ProcRet NS(MqMsgque_HelpMsgque) (OtClass_ARGS) {
  OT_SETUP_hdl_static;
  OT_SETUP_NOARG(HelpMsgque_doc);
  OT_CHECK_NOARGS;
  OT_retObj_SET_STR(MqHelpMsgque ());
  goto end;
  error:
  OT_retObj_SET_Error;
  end:
  OT_retObj_RETURN;
}
 
// MqMsgque_Help_ATL_API
 
 
// doc-key: MqMsgque,MqMsgque-Init,sm_
 
static OT_ProcRet NS(MqMsgque_InitGetArg0) (OtClass_ARGS) {
  OT_SETUP_hdl_static;
  OT_SETUP_NOARG(InitGetArg0_doc);
  OT_CHECK_NOARGS;
  OT_retObj_SET_BFL(MqInitGetArg0 ());
  goto end;
  error:
  OT_retObj_SET_Error;
  end:
  OT_retObj_RETURN;
}
 
static OT_ProcRet NS(MqMsgque_InitResetArg0) (OtClass_ARGS) {
  OT_SETUP_hdl_static;
  OT_SETUP_NOARG(InitResetArg0_doc);
  OT_CHECK_NOARGS;
  OT_retObj_SET_BFL(MqInitResetArg0 ());
  goto end;
  error:
  OT_retObj_SET_Error;
  end:
  OT_retObj_RETURN;
}
 
static OT_ProcRet NS(MqMsgque_InitSetArg0) (OtClass_ARGS) {
  OT_SETUP_hdl_static;
  OT_SETUP_VARARGS(0,99,InitSetArg0_doc);
  MkBufferListCreateTLS_T(bfl,10);
  OT_CHECK_OPTIONAL(OT_CHECK_BAC (bfl))
  OT_CHECK_NOARGS;
  MqInitSetArg0 (bfl);
  OT_retObj_SET_None;
  goto end;
  error:
  OT_retObj_SET_Error;
  end:
  OT_retObj_RETURN;
}
 
// MqMsgque_Init_ATL_API
 
 
// doc-key: MqMsgque,MqMsgque-Main,sm_
 
static OT_ProcRet NS(MqMsgque_Main) (OtClass_ARGS) ; // skip template-required
 
// MqMsgque_Main_ATL_API
 
 
// doc-key: MqMsgque,MqMsgque-Setup,sm_
 
static OT_ProcRet NS(MqMsgque_Cleanup) (OtClass_ARGS) {
  OT_SETUP_hdl_static;
  OT_SETUP_NOARG(Cleanup_doc);
  OT_CHECK_NOARGS;
  MqCleanupTmpl ();
  OT_retObj_SET_None;
  goto end;
  error:
  OT_retObj_SET_Error;
  end:
  OT_retObj_RETURN;
}
 
static OT_ProcRet NS(MqMsgque_Setup) (OtClass_ARGS) {
  OT_SETUP_hdl_static;
  OT_SETUP_NOARG(Setup_doc);
  OT_CHECK_NOARGS;
  MqSetupTmpl ();
  OT_retObj_SET_None;
  goto end;
  error:
  OT_retObj_SET_Error;
  end:
  OT_retObj_RETURN;
}
 
// MqMsgque_Setup_ATL_API
 
// END-MqMsgque - created by 'atl_MqC.tcl -i NHI1_HOME/theLink/c/gen/c_mqmsgque.meta' - DO NOT change
 
 
// ---------------------------------------------------------------------------------------
 
__attribute__((unused)) const static OtObjProcDefS NS(sOtClassDef)[] = {
  // BEGIN-CLASS - created by 'atl_MqS.tcl -i NHI1_HOME/theLink/c/gen/c_mqmsgque.meta' - DO NOT change
 
  // doc-key: MqMsgque,EnumFunc,sco
  { "::MqMsgque::IdentE_FromInt"        , NS(MqMsgque_IdentE_FromInt)        },
  { "::MqMsgque::SlaveE_FromInt"        , NS(MqMsgque_SlaveE_FromInt)        },
  { "::MqMsgque::StartE_FromInt"        , NS(MqMsgque_StartE_FromInt)        },
  { "::MqMsgque::StatusIsEF_FromInt"    , NS(MqMsgque_StatusIsEF_FromInt)    },
  { "::MqMsgque::WaitOnEventE_FromInt"  , NS(MqMsgque_WaitOnEventE_FromInt)  },
 
  // doc-key: MqMsgque,EnumFunc,sm_
  { "::MqMsgque::IdentE_ToInt"          , NS(MqMsgque_IdentE_ToInt)          },
  { "::MqMsgque::IdentE_ToString"       , NS(MqMsgque_IdentE_ToString)       },
  { "::MqMsgque::SlaveE_ToInt"          , NS(MqMsgque_SlaveE_ToInt)          },
  { "::MqMsgque::SlaveE_ToString"       , NS(MqMsgque_SlaveE_ToString)       },
  { "::MqMsgque::StartE_ToInt"          , NS(MqMsgque_StartE_ToInt)          },
  { "::MqMsgque::StartE_ToString"       , NS(MqMsgque_StartE_ToString)       },
  { "::MqMsgque::StatusIsEF_ToInt"      , NS(MqMsgque_StatusIsEF_ToInt)      },
  { "::MqMsgque::StatusIsEF_ToString"   , NS(MqMsgque_StatusIsEF_ToString)   },
  { "::MqMsgque::WaitOnEventE_ToInt"    , NS(MqMsgque_WaitOnEventE_ToInt)    },
  { "::MqMsgque::WaitOnEventE_ToString" , NS(MqMsgque_WaitOnEventE_ToString) },
 
  // doc-key: MqMsgque,MqHelp,sm_
  { "::MqMsgque::Help"                  , NS(MqMsgque_Help)                  },
  { "::MqMsgque::HelpMsgque"            , NS(MqMsgque_HelpMsgque)            },
 
  // doc-key: MqMsgque,MqInit,sm_
  { "::MqMsgque::InitGetArg0"           , NS(MqMsgque_InitGetArg0)           },
  { "::MqMsgque::InitResetArg0"         , NS(MqMsgque_InitResetArg0)         },
  { "::MqMsgque::InitSetArg0"           , NS(MqMsgque_InitSetArg0)           },
 
  // doc-key: MqMsgque,MqMain,sm_
  { "::MqMsgque::Main"                  , NS(MqMsgque_Main)                  },
 
  // doc-key: MqMsgque,Setup,sm_
  { "::MqMsgque::Cleanup"               , NS(MqMsgque_Cleanup)               },
  { "::MqMsgque::Setup"                 , NS(MqMsgque_Setup)                 },
 
  // END-CLASS - created by 'atl_MqS.tcl -i NHI1_HOME/theLink/c/gen/c_mqmsgque.meta' - DO NOT change
  { NULL }
};
 
// ---------------------------------------------------------------------------------------
// not used.
 
__attribute__((unused))  const static OtObjProcDefS NS(sInstanceDef)[] = {
  // BEGIN-OBJ - created by 'atl_MqS.tcl -i NHI1_HOME/theLink/c/gen/c_mqmsgque.meta' - DO NOT change
 
  // → no data
 
  // END-OBJ - created by 'atl_MqS.tcl -i NHI1_HOME/theLink/c/gen/c_mqmsgque.meta' - DO NOT change
  { NULL }
};
 
// ---------------------------------------------------------------------------------------
 
static Tcl_ThreadCreateType
NS(ThreadMain) ( ClientData clientData ) {   
  MqSysServerThreadMain(clientData);
  TCL_THREAD_CREATE_RETURN;
}
 
// MqSysServerThreadF
static enum MkErrorE NS(MqSysServerThreadCB) ( 
  MK_RT_ARGS
  MQ_CTX const    ctx,
  struct MqSysServerThreadMainS * const   argP,
  MK_STRN         name,
  int             state,
  struct MkIdS *  idP
) {
  Tcl_ThreadId id;
 
  if (idP->ioIsPipe) {
    check_LNG( Tcl_CreateThread(&id, NS(ThreadMain), argP, TCL_THREAD_STACK_DEFAULT,TCL_THREAD_JOINABLE)) {
     return  MkErrorSetV_2M(ctx,"[ThreadError] start pipe thread '%s' failed", name);
    }
 
    idP->type = MK_ID_THREAD;
    idP->val  = (MK_IDNT) id;
    idP->setByExtern = true;
 
  } else {
    check_LNG( Tcl_CreateThread(&id, NS(ThreadMain), argP, TCL_THREAD_STACK_DEFAULT,0)) {
     return  MkErrorSetV_2M(ctx,"[ThreadError] start server thread '%s' failed", name);
    }
 
    idP->type = MK_ID_THREAD;
    idP->val  = (MK_IDNT) 0x1;
  }
 
  return MkErrorStack_1M_Check(ctx);
}
 
void NS(MqMsgque_ns_delete)(ClientData clientData) 
{
  OT_MQ_RT_T amqrt = clientData;
    assert(amqrt != NULL);
  MkRtSetup_RT(amqrt->mkrt);
 
#ifdef OT_DEBUG_NAMESPACE_DELETE
  OT_DEBUG_NAMESPACE_DELETE(MK_COLOR_YELLOW,"::MqMsgque with amqrt<%p>","MQ",amqrt);
#endif
  OT_ENV_T interp = amqrt->interp;
 
  // BEGIN-CLASS-delete-2 - created by 'atl_MqS.tcl -i NHI1_HOME/theLink/c/gen/c_mqmsgque.meta' - DO NOT change
 
  OT_NS_T ns;
    ns = Tcl_FindNamespace(interp,"::MqDumpC",NULL,TCL_GLOBAL_ONLY);
      if (ns) Tcl_DeleteNamespace(ns);
    ns = Tcl_FindNamespace(interp,"::MqContextC",NULL,TCL_GLOBAL_ONLY);
      if (ns) Tcl_DeleteNamespace(ns);
    ns = Tcl_FindNamespace(interp,"::MqFactoryC",NULL,TCL_GLOBAL_ONLY);
      if (ns) Tcl_DeleteNamespace(ns);
 
  // END-CLASS-delete-2 - created by 'atl_MqS.tcl -i NHI1_HOME/theLink/c/gen/c_mqmsgque.meta' - DO NOT change
 
    #define AtlRtFree(tok) if (amqrt->tok) { Tcl_DecrRefCount(amqrt->tok); amqrt->tok = NULL; }
      #define regTclObj2(t,v)   AtlRtFree(t)
      #define regTclObj(t)      AtlRtFree(t)
      #define regTclCmd(t)      AtlRtFree(t)
      #include "LibMqMsgque_registry_atl.h"
      #undef regTclCmd
      #undef regTclObj
      #undef regTclObj2
 
  // BEGIN-CLASS-delete - created by 'atl_MqS.tcl -i NHI1_HOME/theLink/c/gen/c_mqmsgque.meta' - DO NOT change
 
  if (amqrt->AtlMqDumpC)            Tcl_DecrRefCount(amqrt->AtlMqDumpC)            ;
  if (amqrt->AtlMqDumpC_MK_NULL)    Tcl_DecrRefCount(amqrt->AtlMqDumpC_MK_NULL)    ;
  if (amqrt->AtlMqContextC)         Tcl_DecrRefCount(amqrt->AtlMqContextC)         ;
  if (amqrt->AtlMqContextC_MK_NULL) Tcl_DecrRefCount(amqrt->AtlMqContextC_MK_NULL) ;
  if (amqrt->AtlMqFactoryC)         Tcl_DecrRefCount(amqrt->AtlMqFactoryC)         ;
  if (amqrt->AtlMqFactoryC_MK_NULL) Tcl_DecrRefCount(amqrt->AtlMqFactoryC_MK_NULL) ;
 
  // END-CLASS-delete - created by 'atl_MqS.tcl -i NHI1_HOME/theLink/c/gen/c_mqmsgque.meta' - DO NOT change
 
  amqrt->signature = 0x0;
}
 
MkThreadLocal OT_MQ_RT_S amqrtR = {0};
 
OT_ATL_EXTERN int
Atlmqmsgque_Init (
  Tcl_Interp * interp
)
{
  // check for the right tcl version
  if (Tcl_InitStubs (interp, "8.5", 0) == NULL) {
    return TCL_ERROR;
  }
 
//colorYELLOW("interp<%p>", interp);
 
  // setup libmqmsgque
  MqSetup();
  MkRtSetup_NULL;
  MqRtSetup_NULL;
 
  // announce my package
  check_LNG (Tcl_PkgProvide (interp, "atlmqmsgque", META_VERSION)) return TCL_ERROR;
 
  // pkg_mkIndex hack → only "Tcl_PkgProvide" is required
  if (Tcl_GetVar(interp,"::tcl::newPkgs", TCL_GLOBAL_ONLY) != NULL) return TCL_OK;
 
  // dependency.
  OT_MK_RT_T amkrt = NULL;
  MK_STRN ver = Tcl_PkgRequireEx(interp, "atlmkkernel", META_VERSION, 1, (ClientData*) &amkrt);
    check_NULL(ver) return TCL_ERROR;
 
  // create local runtime
  OT_MQ_RT_T amqrt = &amqrtR;
    amqrt->amkrt = amkrt;
    if (amqrt->signature && amqrt->signature != OT_MQ_RT_SIG) {
      Tcl_SetErrorCode(interp, "ATLMQ", "INIT", "SIGNATURE", "INVALID", NULL);
      Tcl_SetResult(interp,"error: ATLMQ setup failed with INVALID signature", TCL_STATIC);
      return TCL_ERROR;
    } else {
      amqrt->signature = OT_MQ_RT_SIG;
    }
    if (amqrt->interp && amqrt->interp != interp) {
      Tcl_SetErrorCode(interp, "ATLMQ", "INIT", "INTERPRETER", "INVALID", NULL);
      Tcl_SetResult(interp,"error: ATLMQ setup failed with INVALID interpreter", TCL_STATIC);
      return TCL_ERROR;
    } else {
      amqrt->interp = interp;
    }
    if (amqrt->mkrt && amqrt->mkrt != MK_RT_PTR) {
      Tcl_SetErrorCode(interp, "ATLMQ", "INIT", "MK_RT", "INVALID", NULL);
      Tcl_SetResult(interp,"error: ATLMQ setup failed with INVALID MkRuntimeS", TCL_STATIC);
      return TCL_ERROR;
    } else {
      amqrt->mkrt = MK_RT_PTR;
    }
    if (amqrt->mqrt && amqrt->mqrt != MQ_RT_PTR) {
      Tcl_SetErrorCode(interp, "ATLMQ", "INIT", "MQ_RT", "INVALID", NULL);
      Tcl_SetResult(interp,"error: ATLMQ setup failed with INVALID MqRuntimeS", TCL_STATIC);
      return TCL_ERROR;
    } else {
      amqrt->mqrt = MQ_RT_PTR;
    }
 
  // cleanup "access" objects
  #define regTclObj2(t,v)   if (amqrt->t) OT_REF_DECR(amqrt->t)
  #define regTclObj(t)      regTclObj2(t,#t)
  #define regTclCmd(t)      regTclObj2(t,#t)
  #include "LibMqMsgque_registry_atl.h"
  #undef regTclCmd
  #undef regTclObj
  #undef regTclObj2
 
  // register "access" objects
  #define regTclObj2(t,v)   amqrt->t = amqrt->t ? amqrt->t : ({ OT_OBJ_T val=STR2VAL(v); OT_REF_INCR(val); val;})
  #define regTclObj(t)      regTclObj2(t,#t)
  #define regTclCmd(t)      regTclObj2(t,#t)
  #include "LibMqMsgque_registry_atl.h"
  #undef regTclCmd
  #undef regTclObj
  #undef regTclObj2
 
  // create ::MqMsgque
  OT_NS_T ns = Tcl_FindNamespace(interp,"::MqMsgque",NULL,TCL_GLOBAL_ONLY);
    if (ns == NULL) {
      ns = Tcl_CreateNamespace(interp,"::MqMsgque",amqrt,NS(MqMsgque_ns_delete));
        if (ns == NULL) return TCL_ERROR;
    }
 
  // add PACKAGE commands
  check_LNG( MK(FillNamespace)    (interp,MQ(sOtClassDef),amqrt)) return TCL_ERROR;
 
  // BEGIN-CLASS-call-init - created by 'atl_MqS.tcl -i NHI1_HOME/theLink/c/gen/c_mqmsgque.meta' - DO NOT change
 
  check_LNG( NS(pMqFactoryC_Init) (OT_MQ_CALL ns) ) return TCL_ERROR;
  check_LNG( NS(pMqContextC_Init) (OT_MQ_CALL ns) ) return TCL_ERROR;
  check_LNG( NS(pMqDumpC_Init)    (OT_MQ_CALL ns) ) return TCL_ERROR;
 
  // END-CLASS-call-init - created by 'atl_MqS.tcl -i NHI1_HOME/theLink/c/gen/c_mqmsgque.meta' - DO NOT change
 
  // init NULL object… on EVERY thread
  NS(inMain) = false;
 
  // every new thread source the script
  // "package require atlmqmsgque" is calling "Atlmqmsgque_Init"
  // → check if we on "thread" : NULL=initial, POINTER=thread
  Tcl_Obj *MQ_STARTUP_IS_THREAD = Tcl_GetVar2Ex(interp,"MQ_STARTUP_IS_THREAD",NULL,TCL_GLOBAL_ONLY);
 
  // only ONCE on INITIAL setup
  if (MQ_STARTUP_IS_THREAD == NULL) {
 
    // setup MkInitGetArg0
    if (MqInitGetArg0() == NULL && Tcl_GetNameOfExecutable() != NULL) {
      Tcl_Eval(interp, "dict get [info frame 1] file");
      MqInitSetArg0VA(Tcl_GetNameOfExecutable(), Tcl_GetStringResult(interp), NULL);
    }
 
    // create the default-factory
    check_LNG (NS(MqFactoryC_Setup) (MK_RT_CALL interp)) return TCL_ERROR;
  }
 
  MqLal.MqSysServerThreadCB = NS(MqSysServerThreadCB);
 
  return TCL_OK;
}
 
OT_ATL_EXTERN int
Atlmqmsgque_Unload ( OT_ENV_T interp, int flags ) {
  OT_NS_T ns = Tcl_FindNamespace(interp,"::MqMsgque",NULL,TCL_GLOBAL_ONLY);
    if (ns) Tcl_DeleteNamespace(ns);
 
  MqCleanup();
 
  return TCL_OK;
}