LibMqMsgque_mq.h

Go to the documentation of this file.

 
#pragma once
 
#include "LibMkKernel_mk.h"
 
// =========================================================================
// global __parser__ definition :
 
__parser__(library=MqMsgque@internal@Mq);
 
// MARK_D ################################################################
// -----------------------------------------------------------------------
// documentation order
 
 
 
 
 
 
 
 
 
// =========================================================================================
// Makefile:    CPPFLAGS definitions
// Config:      configure definitions
 
// define:      META_TCP_ONLY_IPV4
// source:      msgque_mq.h
// default:     not set, use IPV8
// definition:  Force the IPV4 support and disable IPV8
 
// define:      META_COMPILE_AS_CC
// source:      Makefile
// target:      kernel_mk.h
// default:     only set by "ccmqmsgque" to compile "C" code as "C++" code
// definition:  By default, the "C" code is compiled as "C" code into a "C" library and eventually linked 
//              to the library of the target programming language. With the "META_COMPILE_AS_CC" preprocessor
//              flag, the "C" code is not compiled into an independent library but is translated directly 
//              into the target programming language (C++) library along with the additional C++ code as C++ 
//              code in the "ccmqmsgque::libmkkernel" namespace.
//              The following changes are done:
//              1. "BEGIN_MK_C_DECLS" is set to "namespace libmsgque {"
 
// define:      META_HAVE_LIBCONFIG
// source:      user defind at build using '-DMETA_HAVE_LIBCONFIG=1/0' or set with the "configure" script
// default:     the default is "1 = set" - other value is "0 = not set"
// definition:  1. Add the 'libconfig' library to the build to support config-files
//              2. If the extension is build ontop of libmqmsgque the extension have to set META_HAVE_LIBCONFIG
//                 according to libmqmsgque. If META_HAVE_LIBCONFIG differs from libmqmsgque than compile-error occure.
//              3. autoconf example is at: NHI1/theLink/phpmsgque/MqMsgque/config.m4
 
#ifndef META_HAVE_LIBCONFIG
  #error "META_HAVE_LIBCONFIG was NOT defined, require 1 or 0"
#endif
 
// define:      META_USE_GLOBAL_EVENT
// source:      only libmqmsgque build
// default:     do NOT(0) use META_USE_GLOBAL_EVENT
// definition:  1. Add the "geDat" array to collect all "MqEventS" in all "MqRuntimeS"
//              2. Protected by semaphore "geSem"
//              3. NOT really usefull, free some data on exit
//              4. In the PAST the "MqContectS" related to the "MqEventS" was freed also, BUT this is very buggy.
 
#ifndef META_USE_GLOBAL_EVENT
# define META_USE_GLOBAL_EVENT 0
#endif
 
// define:      META_BROKEN_LINK_SEND_FAIL_COUNTER
// source:      only libmqmsgque build
// default:     fail after 16 attemp to send a data package
// definition:  1. used in "pSendEND" -> "pIoCheckLast"
 
#define META_BROKEN_LINK_SEND_FAIL_COUNTER  16
 
// define:      META_STATIC
// reference:   META_STATIC from kernel_mk.h
 
#ifdef META_STATIC
# undef MQ_C_BUILD_DLL
# define MQ_C_BUILD_DLL
#endif
 
#if META_DEBUG
# define MQ_DEBUG_RUNTIME mk_dbg_color_ln(MK_COLOR_YELLOW,"mkrt<%p:%p>, mqrt<%p:%p>", mkrt, MkRT, mqrt, MqRT)
#else
# define MQ_DEBUG_RUNTIME
#endif
 
// =========================================================================
#if META_HAS_THREAD
#  define MQ_RT_ARGS_ONLY         MK_RT mkrt, MQ_RT mqrt
#  define MQ_RT_ARGS              MQ_RT_ARGS_ONLY,
#  define MQ_RT_CALL_ONLY         mkrt, mqrt
#  define MQ_RT_CALL              MQ_RT_CALL_ONLY,
#  define MQ_RT_PTR               mqrt
#  define MQ_RT_REF               (*mqrt)
#else
#  define MQ_RT_ARGS_ONLY         void
#  define MQ_RT_ARGS
#  define MQ_RT_CALL_ONLY
#  define MQ_RT_CALL
#  define MQ_RT_PTR               &MqRuntimeRLS
#  define MQ_RT_REF               MqRuntimeRLS
#endif
 
// ".c" file
#define MQ_INSTANCE_RT_X(x)       MK_INSTANCE_RT_X(x)       ; MqRtSetup_XN(x)
#define MQ_INSTANCE_RT_X_NULL(x)  MK_INSTANCE_RT_X_NULL(x)  ; MqRtSetup_X(x)
#define MQ_INSTANCE_RT_O(o)       MK_INSTANCE_RT_O(o)       ; MqRtSetup_ON(o)
#define MQ_INSTANCE_RT_O_NULL(o)  MK_INSTANCE_RT_O_NULL(o)  ; MqRtSetup_O(o)
#define MQ_DESTRUCTOR_RT_X(c,x)   MK_DESTRUCTOR_RT_X(c,x)   ; MqRtSetup_XN(x)
#define MQ_STATIC_RT              MK_STATIC_RT              ; MqRtSetup_NULL
//  MqRuntimeC_C_API
 
/*  BEGIN_MQ_C_DECLS should be used at the beginning of your declarations,
    so that C++ compilers don't mangle their names.  Use END_MQ_C_DECLS at
    the end of C declarations. 
*/
 
#undef BEGIN_MQ_C_DECLS
#undef END_MQ_C_DECLS
#if defined(META_COMPILE_AS_CC)
# define BEGIN_MQ_C_DECLS namespace libmqmsgque { using namespace libmkkernel;
# define END_MQ_C_DECLS }
#elif defined(__cplusplus)
# define BEGIN_MQ_C_DECLS extern "C" {
# define END_MQ_C_DECLS }
#else
# define BEGIN_MQ_C_DECLS /* empty */
# define END_MQ_C_DECLS /* empty */
#endif
 
// MARK_O
#ifndef PARSE_C_HEADER_TO_META
# include "gen/msgque_overload_mq.h"
#endif
 
BEGIN_MQ_C_DECLS
 
// +++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++
 
/* ####################################################################### */
/* ###                                                                 ### */
/* ###                      K E R N A L - A P I                        ### */
/* ###                                                                 ### */
/* ####################################################################### */
 
/*****************************************************************************/
/*                                                                           */
/*                          windows conform extern                           */
/*                                                                           */
/*****************************************************************************/
 
 
// BEGIN-HEADER - created by 'c_Class.tcl -i NHI1_HOME/theLink/c/gen/c_mqmsgque.meta' - DO NOT change
 
// If the source of libmqmsgque is direct used in an external library
// (without dynamic linking) and this library should *not* export
// the symbol's of libmqmsgque then the flag META_IGNORE_EXTERN have
// to be set
#undef MQ_EXTERN
#if defined(META_IGNORE_EXTERN)
#   define MQ_EXTERN
#elif defined(PIC)
   // does we build a DLL ?
#  if defined(DLL_EXPORT)
       // does we build the libmqmsgque library ?
#      if defined(MQ_C_BUILD_DLL)
#        define MQ_EXTERN __declspec(dllexport)
#      else
#        define MQ_EXTERN __declspec(dllimport)
#      endif
#  else
   // no DLL - architecture specific extern specifier
#    define MQ_EXTERN __attribute__ ((visibility("default")))
#  endif
#else
#   define MQ_EXTERN
#endif
 
// external data lookup
#undef MQ_EXTERN_DATA
#if defined(META_PRIVATE)
#  define MQ_EXTERN_DATA extern
#elif defined(META_IGNORE_EXTERN)
#  define MQ_EXTERN_DATA extern
#elif defined(PIC)
   // does we build a DLL ?
#  if defined(DLL_EXPORT)
       // does we build the libmqmsgque library ?
#      if defined(MQ_C_BUILD_DLL)
#        define MQ_EXTERN_DATA __declspec(dllexport)
#      else
#        define MQ_EXTERN_DATA __declspec(dllimport)
#      endif
#  else
   // no DLL - architecture specific extern specifier
#    define MQ_EXTERN_DATA __attribute__ ((visibility("default"))) extern
#  endif
#else
#  define MQ_EXTERN_DATA extern
#endif
 
// END-HEADER - created by 'c_Class.tcl -i NHI1_HOME/theLink/c/gen/c_mqmsgque.meta' - DO NOT change
 
// MqMsgque_Compiler_C_API
 
/*****************************************************************************/
/*                                                                           */
/*                            types/generic                                  */
/*                                                                           */
/*****************************************************************************/
 
 
typedef struct config_t config_t;
typedef struct config_setting_t config_setting_t;
 
struct MqContextS;
struct MqTransS;
struct MqConfigS;
struct MqEventS;
struct MqFactoryS;
struct MqDumpS;
 
__parser__(type=ME_NI4_MQ_LTR)
typedef int MQ_LTR;
__parser__(type=ME_NI4_MQ_ROU)
typedef int MQ_ROU;
__parser__(type=ME_NI4_MQ_SLAVE_ID)
typedef MK_NUM  MQ_SLAVE_ID;
 
__parser__(type=ME_NI4_MQ_HDL:"handle data-type")
typedef int MQ_HDL;
 
// MqMsgque_Type_C_API
 
/* MARK_C ********************************************************************/
/*                                                                           */
/*                            class types                                    */
/*                                                                           */
/*****************************************************************************/
 
// BEGIN-ShortDef - created by 'c_Class.tcl -i NHI1_HOME/theLink/c/gen/c_mqmsgque.meta' - DO NOT change
 
  __parser__(internal,type=ME_CCC_MqErrorC:"extension management class for MqErrorS":internal)
  typedef struct MqErrorS * MQ_ERR;
  __parser__(internal,type=ME_CCN_MqErrorC:"const - extension management class for MqErrorS":internal)
  typedef const struct MqErrorS * MQ_ERRN;
  __parser__(ignore)
  typedef struct MqErrorS   MQ_ERRR;
// MqErrorC_Class_C_API
 
  __parser__(internal,type=ME_CCC_MqRuntimeC:"MqRuntimeC class handle":internal)
  typedef struct MqRuntimeS * MQ_RT;
  __parser__(internal,type=ME_CCN_MqRuntimeC:"const - MqRuntimeC class handle":internal)
  typedef const struct MqRuntimeS * MQ_RTN;
  __parser__(ignore)
  typedef struct MqRuntimeS   MQ_RTR;
// MqRuntimeC_Class_C_API
 
  __parser__(internal,type=ME_CCC_MqTypeCtxC:"MqContextS type":internal)
  typedef struct MqTypeCtxS * MQ_CTXTYP;
  __parser__(internal,type=ME_CCN_MqTypeCtxC:"const - MqContextS type":internal)
  typedef const struct MqTypeCtxS * MQ_CTXTYPN;
  __parser__(ignore)
  typedef struct MqTypeCtxS   MQ_CTXTYPR;
// MqTypeCtxC_Class_C_API
 
  __parser__(type=ME_CCC_MqFactoryC:"MqFactoryC class handle":primary)
  typedef struct MqFactoryS * MQ_FCT;
  __parser__(type=ME_CCN_MqFactoryC:"const - MqFactoryC class handle":primary)
  typedef const struct MqFactoryS * MQ_FCTN;
  __parser__(ignore)
  typedef struct MqFactoryS   MQ_FCTR;
// MqFactoryC_Class_C_API
 
  __parser__(type=ME_CCC_MqContextC:"MqContextC class handle":primary)
  typedef struct MqContextS * MQ_CTX;
  __parser__(type=ME_CCN_MqContextC:"const - MqContextC class handle":primary)
  typedef const struct MqContextS * MQ_CTXN;
  __parser__(ignore)
  typedef struct MqContextS   MQ_CTXR;
// MqContextC_Class_C_API
 
  __parser__(type=ME_CCC_MqDumpC:"MqDumpC class handle":primary)
  typedef struct MqDumpS * MQ_DMP;
  __parser__(type=ME_CCN_MqDumpC:"const - MqDumpC class handle":primary)
  typedef const struct MqDumpS * MQ_DMPN;
  __parser__(ignore)
  typedef struct MqDumpS   MQ_DMPR;
// MqDumpC_Class_C_API
 
  __parser__(internal,type=ME_CCC_MqEnvC:"MqEnvC class handle":internal)
  typedef struct MqEnvS * MQ_ENV;
  __parser__(internal,type=ME_CCN_MqEnvC:"const - MqEnvC class handle":internal)
  typedef const struct MqEnvS * MQ_ENVN;
  __parser__(ignore)
  typedef struct MqEnvS   MQ_ENVR;
// MqEnvC_Class_C_API
 
// END-ShortDef - created by 'c_Class.tcl -i NHI1_HOME/theLink/c/gen/c_mqmsgque.meta' - DO NOT change
 
__parser__(type=ME_ACX_MqContextC:"ARRAY of MQ_CTX")
typedef struct {
  MK_NUM  size;
  MQ_CTX  *data;
} MQ_CTX_A;
 
/*****************************************************************************/
/*                                                                           */
/*                            sockets                                        */
/*                                                                           */
/*****************************************************************************/
 
 
#if defined(__MINGW32__) || defined(_MSC_VER)
typedef   SOCKET  MQ_SOCK_HDL;
# define MK_FORMAT_SOCK "%I64u"
#else
__parser__(type=ME_NI4_MQ_SOCK_HDL)
typedef   int     MQ_SOCK_HDL;
# define MK_FORMAT_SOCK "%i"
#endif
 
// MqMsgque_Type_C_API
 
/*****************************************************************************/
/*                                                                           */
/*                            type definitions                               */
/*                                                                           */
/*****************************************************************************/
 
 
__parser__push__(doc-group=Enum);
 
 
__parser__(internal)
enum MqHandShakeE {
  MQ_HANDSHAKE_START        = 'S',  
  MQ_HANDSHAKE_OK           = 'O',  
  MQ_HANDSHAKE_ERROR        = 'E',  
};
 
// BEGIN-MqHandShakeE - created by 'c_MqS.tcl -i NHI1_HOME/theLink/c/gen/c_mqmsgque.meta' - DO NOT change
 
__parser__(internal,no-rpc,prefix=EnumFunc,return-type-default-no)
MQ_EXTERN MK_STRN MK_DECL MqHandShakeE_ToString  ( enum MqHandShakeE value ) MK_ATTR_STATIC ;
 
__parser__(internal,no-rpc,prefix=EnumFunc,return-type-default-no)
MK_ATTR_STATIC
mk_inline MK_I32 MqHandShakeE_ToInt ( enum MqHandShakeE value ) {
  return (MK_I32) value;
}
 
__parser__(internal,no-rpc,prefix=EnumFunc)
MQ_EXTERN enum MkErrorE MqHandShakeE_FromInt ( MK_I32 const value, enum MqHandShakeE * value_out ) MK_ATTR_STATIC ;
 
// END-MqHandShakeE - created by 'c_MqS.tcl -i NHI1_HOME/theLink/c/gen/c_mqmsgque.meta' - DO NOT change
 
// MqHandShakeE
 
 
__parser__(internal)
enum MqTransTypeE {
  MQ_TRANS_TYPE_WAIT  = 'W' ,   
  MQ_TRANS_TYPE_SUB   = 'S' ,   
  MQ_TRANS_TYPE_CB    = 'C' ,   
  MQ_TRANS_TYPE_TRANS = 'T' ,   
  MQ_TRANS_TYPE_NO    = 'N' ,   
};
 
// BEGIN-MqTransTypeE - created by 'c_MqS.tcl -i NHI1_HOME/theLink/c/gen/c_mqmsgque.meta' - DO NOT change
 
__parser__(internal,no-rpc,prefix=EnumFunc,return-type-default-no)
MQ_EXTERN MK_STRN MK_DECL MqTransTypeE_ToString  ( enum MqTransTypeE value ) MK_ATTR_STATIC ;
 
__parser__(internal,no-rpc,prefix=EnumFunc,return-type-default-no)
MK_ATTR_STATIC
mk_inline MK_I32 MqTransTypeE_ToInt ( enum MqTransTypeE value ) {
  return (MK_I32) value;
}
 
__parser__(internal,no-rpc,prefix=EnumFunc)
MQ_EXTERN enum MkErrorE MqTransTypeE_FromInt ( MK_I32 const value, enum MqTransTypeE * value_out ) MK_ATTR_STATIC ;
 
// END-MqTransTypeE - created by 'c_MqS.tcl -i NHI1_HOME/theLink/c/gen/c_mqmsgque.meta' - DO NOT change
 
// MqTransTypeE
 
 
// [MqIdentE]
enum MqIdentE {
  MQ_IDENT_PREFIX     = 0   ,   
  MQ_IDENT_FACTORY    = 1       
};
// [MqIdentE]
 
// BEGIN-MqIdentE - created by 'c_MqS.tcl -i NHI1_HOME/theLink/c/gen/c_mqmsgque.meta' - DO NOT change
 
__parser__(doc-group=Enum,doc-index=_ignore_,class=MqMsgque,no-rpc,prefix=EnumFunc,return-type-default-no)
MQ_EXTERN MK_STRN MK_DECL MqIdentE_ToString  ( enum MqIdentE value ) MK_ATTR_STATIC ;
 
__parser__(doc-group=Enum,doc-index=_ignore_,class=MqMsgque,no-rpc,prefix=EnumFunc,return-type-default-no)
MK_ATTR_STATIC
mk_inline MK_I32 MqIdentE_ToInt ( enum MqIdentE value ) {
  return (MK_I32) value;
}
 
__parser__(doc-group=Enum,doc-index=_ignore_,class=MqMsgque,no-rpc,prefix=EnumFunc)
MQ_EXTERN enum MkErrorE MqIdentE_FromInt ( MK_I32 const value, enum MqIdentE * value_out ) MK_ATTR_STATIC ;
 
// END-MqIdentE - created by 'c_MqS.tcl -i NHI1_HOME/theLink/c/gen/c_mqmsgque.meta' - DO NOT change
 
// MqIdentE
 
__parser__pop__;
 
// MqMsgque_Enum_C_API
 
 
struct MqTypeCtxS;
 
//__parser__(type=ME_TYC:"a managed object class type pointer")
__parser__(internal)
typedef struct MqTypeCtxS * MQ_CTXT;
 
// MqTypeCtxC_C_API
 
// #######################################################################
// -----------------------------------------------------------------------
 
__parser__(ignore)
struct MqEnvS {
  // BEGIN-MqEnvS-super - created by 'c_Class.tcl -i NHI1_HOME/theLink/c/gen/c_mqmsgque.meta' - DO NOT change
 
  union {
    struct MkObjectS            obj;          // instance-base MkObjectS
  } super;
 
  // END-MqEnvS-super - created by 'c_Class.tcl -i NHI1_HOME/theLink/c/gen/c_mqmsgque.meta' - DO NOT change
 
  MQ_HDL              transSId;     
  enum MqHandShakeE   handShake;    
  enum MqTransTypeE   transType;    
  MQ_LTR              transLId;     
  MQ_LTR              rmtTransLId;  
  MQ_HDL              routeId;      
  struct MqEnvS       *link;        
  struct {
    bool              SIdLck  : 1;  
    bool              LIdLck  : 1;  
  } bits;
};
 
// BEGIN-MqEnvS-Definition - created by 'c_Class.tcl -i NHI1_HOME/theLink/c/gen/c_mqmsgque.meta' - DO NOT change
 
  __parser__push__(prefix=Class, doc-group=Define, doc-index=Class);
 
// Signature --------------------------------------------------------------
 
  #define MqEnvC_SIGNATURE               (MkObjectC_SIGNATURE ^ (15u<<10))
  #define MqEnvC_MASK                    (((1u<<22)-1)<<10)
 
 
// CompileTimeCast --------------------------------------------------------------
 
  #define MqEnvC_X2env(x)                (x)
  #define MqEnvC_X2obj(x)                MkOBJ(x)
 
 
// TypeDef --------------------------------------------------------------
 
  __parser__(ignore) typedef struct MqEnvS MqEnvCR;
  __parser__(ignore) typedef const struct MqEnvS MqEnvCNR;
  #define MqEnvC_T                       (&MQ_RT_REF._MqEnvC_T)
  #define MqEnvC_TT                      (MkTYP(MqEnvC_T))
  #define MqEnvST                        MqEnvC_T
  #define MqEnvSTT                       (MkTYP(MqEnvST))
  #define MqEnvC_type                    MQ_ENV
  #define MqEnvCT_X(instance)            ( (struct MkTypeDefS *) (MkOBJ_R(instance).type) )
  #define MqEnvCTT_X(instance)           (MkOBJ_R(instance).type)
  #define MqEnvCT_TT(typ)                ( (struct MkTypeDefS *) (typ) )
  #define MqEnvC_NS                      MQ
  #define MqEnvCTT                       MqEnvCTT
  #define MqEnvCT                        ( (struct MkTypeDefS *) MqEnvCTT )
 
 
// TypeCheck --------------------------------------------------------------
 
  #pragma GCC diagnostic push
  #pragma GCC diagnostic ignored "-Wattributes"
 
  __parser__(class=MqEnvC,static,ignore)
  MK_ATTR_STATIC
  mk_inline bool MqEnvCheck (MK_MNGN mng) {
    return MkSanitizeCheck(MqEnvC,mng);
  }
 
  __parser__(class=MqEnvC,static,ignore)
  MK_ATTR_STATIC
  mk_inline bool MqEnvCheckO (MK_OBJN obj) {
    return MkSanitizeCheckO(MqEnvC,obj);
  }
 
  #pragma GCC diagnostic pop
  #define MqEnvC_Check(mng)              MqEnvCheck(mng)
 
 
// RunTimeCast --------------------------------------------------------------
 
  __parser__(class=MqEnvC,ignore,static)
  META_ATTRIBUTE_SANITIZE
  MK_ATTR_STATIC
  mk_inline MQ_ENV MqEnv(MK_MNG mng) {
    return (MqEnvCheck(mng) ? (MQ_ENV)mng : NULL);
  }
 
  __parser__(class=MqEnvC,ignore,static)
  META_ATTRIBUTE_SANITIZE
  MK_ATTR_STATIC
  mk_inline MQ_ENVN MqEnvN(MK_MNGN mng) {
    return (MqEnvCheck(mng) ? (MQ_ENVN)mng : NULL);
  }
 
  #define MqEnvRaise(_env) if (!_MkCheckX(MqEnvC,_env)) { \
    MkErrorSetC_1E("'MqEnvC' hdl is NULL"); \
    goto error ; \
  }
 
  #define   MqENV_R(x)        (*(x)).super.env
  #define   MqENV(x)          (&MqENV_R(x))
 
 
  __parser__pop__;
// MqEnvC_Class_Define_C_API
 
// END-MqEnvS-Definition - created by 'c_Class.tcl -i NHI1_HOME/theLink/c/gen/c_mqmsgque.meta' - DO NOT change
 
// MqEnvC_C_API
 
 
// \brief check service call environment at the beginning of the service call
#define MQ_SERVICE_CALL_CHECK do { \
  assert (__data__ != NULL); \
  if (MqCtxCheck(mqctx) == false || MkOBJ_R(mqctx).self == NULL) return MK_OK; \
} while (0)
 
// [MqTokenF]
#define MQ_SERVICE_CALL_ARGS  MK_RT_ARGS MQ_CTX const mqctx, MK_PTR const __data__
#define MQ_SERVICE_CALL  MK_RT_CALL mqctx, __data__
 
__parser__(flags=public-internal)
typedef enum MkErrorE ( MK_DECL *MqTokenF ) ( MQ_SERVICE_CALL_ARGS );
// [MqTokenF]
 
// [MqDataFreeF]
#define MQ_SERVICE_FREE_ARGS  MK_RT_ARGS MQ_CTX const mqctx, MK_PTR *dataP __parser__(inout)
 
__parser__(flags=public-internal)
typedef void ( MK_DECL *MqDataFreeF ) ( MQ_SERVICE_FREE_ARGS );
// [MqDataFreeF]
 
// [MqDataCopyF]
#define MQ_SERVICE_COPY_ARGS  MK_RT_ARGS MQ_CTX const mqctx, MK_PTR *dataP __parser__(inout)
 
__parser__(flags=public-internal)
typedef void ( MK_DECL *MqDataCopyF ) ( MQ_SERVICE_COPY_ARGS );
// [MqDataCopyF]
 
// MqContextC_ConfigApi_C_API
 
__parser__(ignore)
struct MqCallbackS {
  MqTokenF              fCall;      
  MK_PTR                data;       
  MqDataFreeF           fFree;      
  MqDataCopyF           fCopy;      
  MkMarkF               fMark;      
};
 
struct MqLinkSlaveS {
  MQ_CTX  context;          
 
  // slaves link
  MQ_CTX  *slaves;          
  MK_NUM  used;             
  MK_NUM  size;             
};
 
#if defined(MQ_C_BUILD_DLL)
 
  #define   META_SECTION_DEFINE
  #include  "MqLinkS_mq.h"
  #undef    META_SECTION_DEFINE
 
#else   // MQ_C_BUILD_DLL
 
__parser__(ignore)
struct MqLinkS {
 
  // PUBLIC variables
 
  #define MqLinkS_targetIdent_size  64
  MK_STRB             targetIdent[MqLinkS_targetIdent_size];
 
  // context-management variables
  MK_NUM              ctxId;        
  MQ_CTX              ctxIdP;       
 
  // protected environment
  struct MqEnvS protect;            
  struct MqEnvS *protectStack;      
 
  // master/slave relationship
  struct MqLinkSlaveS   slave;      
 
  // offset calculated by "Nhi1InternalSize"
  MK_BINB private_variables[40656];
};
 
#endif  // MQ_C_BUILD_DLL
 
/* MARK_F ################################################################ */
/* ###                                                                 ### */
/* ###                 C T X - C O N F I G - A P I                     ### */
/* ###                                                                 ### */
/* ####################################################################### */
 
// MqContextC_ConfigApi_C_API
 
// #######################################################################
// -----------------------------------------------------------------------
 
__parser__push__(doc-group=Misc,doc-index=ConfigApi);
 
typedef enum MkErrorE ( MK_DECL
  *MqCreateF
) (
  MK_RT_ARGS                
  MQ_CTX  const ctx,        
  MK_BFL  const args        
);
 
#define MQ_CALLBACK_CREATE_ARGS      MK_RT_ARGS MQ_CTX const mqctx, MK_BFL const argv
#define MQ_CALLBACK_CREATE_CALL      MK_RT_CALL              mqctx,              argv
 
typedef void ( MK_DECL
  *MqDeleteF
) (
  MQ_CTX const ctx
);
 
typedef void ( MK_DECL
  *MqHelpF
) (
  MK_STRN basename      
) __attribute__ ((noreturn));
 
typedef int ( MK_DECL
  *MqExitF
) (
  MK_RT_ARGS
  int num
);
 
typedef bool ( MK_DECL
  *MqWaitForPipeF
) (
  MK_RT_ARGS
  MQ_CTX const          ctx,
  const struct MkIdS  * idP __parser__(in)
);
 
typedef void (MK_DECL *MqSetupF) ( MQ_CTX const ctx ) ;
 
typedef void (MK_DECL *MqRefCountF) ( MK_RT_ARGS MQ_CTX ctx , MK_PTR const env) ;
 
__parser__(ignore)
struct MqIoUdsConfigS {
  MK_STR file;
};
 
__parser__(ignore)
struct MqIoTcpConfigS {
  MK_STR host;
  MK_STR port;
  MK_STR myhost;
  MK_STR myport;
};
 
__parser__(ignore)
struct MqIoPipeConfigS {
  MQ_SOCK_HDL hdl ; 
};
 
__parser__(ignore)
struct MqIoLoopConfigS {
};
 
__parser__(ignore)
struct MqIoInitConfigS {
};
 
/*****************************************************************************/
/*                                                                           */
/*                           create / delete                                 */
/*                                                                           */
/*****************************************************************************/
 
MQ_EXTERN void MK_DECL MqConfigReset_RT (
  MK_PARSER_RT
  MQ_CTX const ctx
) MK_ATTR_RT_INSTANCE;
 
__parser__(internal)
MQ_EXTERN void MK_DECL MqConfigDup_RT (
  MK_PARSER_RT
  MQ_CTX const to,
  MQ_CTX const from
) MK_ATTR_RT_INSTANCE;
 
// from being overwritten.
__parser__(hide)
MQ_EXTERN void MK_DECL MqSetupDup_RT (
  MK_PARSER_RT
  MQ_CTX const to,
  MQ_CTXN const from
) MK_ATTR_RT_INSTANCE;
 
__parser__pop__;
 
// MqContextC_ConfigApi_Misc_C_API
 
// #######################################################################
// -----------------------------------------------------------------------
__parser__push__(no-rpc,template-overload,doc-group=Setup,prefix=Setup);
 
#ifndef META_COMPILE_AS_CC
__attribute__ ((constructor(300)))
#endif
__parser__(no-inline)
MQ_EXTERN void MK_DECL MqSetup (void) MK_ATTR_STATIC ;
 
#ifndef META_COMPILE_AS_CC
__attribute__ ((destructor(300)))
#endif
__parser__(no-inline)
MQ_EXTERN void MK_DECL MqCleanup (void) MK_ATTR_STATIC ;
 
__parser__(ignore)
MQ_EXTERN_DATA bool MqCleanupActive;
 
__parser__pop__;
 
// MqMsgque_Setup_C_API
 
 
// #######################################################################
// -----------------------------------------------------------------------
 
__parser__push__(doc-group=Enum,doc-index=_ignore_,class=MqMsgque);
 
 
// [MqStartE]
enum MqStartE {
  MQ_START_DEFAULT     = 0,         
  MQ_START_FORK        = 1,         
  MQ_START_THREAD      = 2,         
  MQ_START_SPAWN       = 3,         
};
// [MqStartE]
 
// BEGIN-MqStartE - created by 'c_MqS.tcl -i NHI1_HOME/theLink/c/gen/c_mqmsgque.meta' - DO NOT change
 
__parser__(doc-group=Enum,doc-index=_ignore_,class=MqMsgque,no-rpc,prefix=EnumFunc,return-type-default-no)
MQ_EXTERN MK_STRN MK_DECL MqStartE_ToString  ( enum MqStartE value ) MK_ATTR_STATIC ;
 
__parser__(doc-group=Enum,doc-index=_ignore_,class=MqMsgque,no-rpc,prefix=EnumFunc,return-type-default-no)
MK_ATTR_STATIC
mk_inline MK_I32 MqStartE_ToInt ( enum MqStartE value ) {
  return (MK_I32) value;
}
 
__parser__(doc-group=Enum,doc-index=_ignore_,class=MqMsgque,no-rpc,prefix=EnumFunc)
MQ_EXTERN enum MkErrorE MqStartE_FromInt ( MK_I32 const value, enum MqStartE * value_out ) MK_ATTR_STATIC ;
 
// END-MqStartE - created by 'c_MqS.tcl -i NHI1_HOME/theLink/c/gen/c_mqmsgque.meta' - DO NOT change
 
 
 
// [MqStatusIsEF]
__parser__(enum-is-flag)
enum MqStatusIsEF {
  MQ_STATUS_IS_INITIAL = 0,         
  MQ_STATUS_IS_DUP     = 1<<0,      
  MQ_STATUS_IS_THREAD  = 1<<1,      
  MQ_STATUS_IS_FORK    = 1<<2,      
  MQ_STATUS_IS_SPAWN   = 1<<3,      
};
// [MqStatusIsEF]
 
// BEGIN-MqStatusIsEF - created by 'c_MqS.tcl -i NHI1_HOME/theLink/c/gen/c_mqmsgque.meta' - DO NOT change
 
__parser__(doc-group=Enum,doc-index=_ignore_,class=MqMsgque,no-rpc,prefix=EnumFunc,return-type-default-no)
MQ_EXTERN MK_STRN MK_DECL MqStatusIsEF_ToString  ( enum MqStatusIsEF value ) MK_ATTR_STATIC ;
 
__parser__(doc-group=Enum,doc-index=_ignore_,class=MqMsgque,no-rpc,prefix=EnumFunc,return-type-default-no)
MK_ATTR_STATIC
mk_inline MK_I32 MqStatusIsEF_ToInt ( enum MqStatusIsEF value ) {
  return (MK_I32) value;
}
 
__parser__(doc-group=Enum,doc-index=_ignore_,class=MqMsgque,no-rpc,prefix=EnumFunc)
MQ_EXTERN enum MkErrorE MqStatusIsEF_FromInt ( MK_I32 const value, enum MqStatusIsEF * value_out ) MK_ATTR_STATIC ;
 
// END-MqStatusIsEF - created by 'c_MqS.tcl -i NHI1_HOME/theLink/c/gen/c_mqmsgque.meta' - DO NOT change
 
// MqStatusIsEF
 
 
__parser__(internal,enum-is-flag)
enum MqFactoryE {
  MQ_FACTORY_NEW_INIT   = 1<<0,     
  MQ_FACTORY_NEW_CHILD  = 1<<1,     
  MQ_FACTORY_NEW_SLAVE  = 1<<2,     
  MQ_FACTORY_NEW_FORK   = 1<<3,     
  MQ_FACTORY_NEW_THREAD = 1<<4,     
  MQ_FACTORY_NEW_FILTER = 1<<5      
};
 
// BEGIN-MqFactoryE - created by 'c_MqS.tcl -i NHI1_HOME/theLink/c/gen/c_mqmsgque.meta' - DO NOT change
 
__parser__(internal,no-rpc,prefix=EnumFunc,return-type-default-no)
MQ_EXTERN MK_STRN MK_DECL MqFactoryE_ToString  ( enum MqFactoryE value ) MK_ATTR_STATIC ;
 
__parser__(internal,no-rpc,prefix=EnumFunc,return-type-default-no)
MK_ATTR_STATIC
mk_inline MK_I32 MqFactoryE_ToInt ( enum MqFactoryE value ) {
  return (MK_I32) value;
}
 
__parser__(internal,no-rpc,prefix=EnumFunc)
MQ_EXTERN enum MkErrorE MqFactoryE_FromInt ( MK_I32 const value, enum MqFactoryE * value_out ) MK_ATTR_STATIC ;
 
// END-MqFactoryE - created by 'c_MqS.tcl -i NHI1_HOME/theLink/c/gen/c_mqmsgque.meta' - DO NOT change
 
// MqFactoryE
 
 
__parser__(internal)
enum MqIoComE {
  MQ_IO_PIPE = 0,                   
  MQ_IO_UDS  = 1,                   
  MQ_IO_TCP  = 2,                   
  MQ_IO_INIT = 3,                   
  MQ_IO_LOOP = 4,                   
};
 
// BEGIN-MqIoComE - created by 'c_MqS.tcl -i NHI1_HOME/theLink/c/gen/c_mqmsgque.meta' - DO NOT change
 
__parser__(internal,no-rpc,prefix=EnumFunc,return-type-default-no)
MQ_EXTERN MK_STRN MK_DECL MqIoComE_ToString  ( enum MqIoComE value ) MK_ATTR_STATIC ;
 
__parser__(internal,no-rpc,prefix=EnumFunc,return-type-default-no)
MK_ATTR_STATIC
mk_inline MK_I32 MqIoComE_ToInt ( enum MqIoComE value ) {
  return (MK_I32) value;
}
 
__parser__(internal,no-rpc,prefix=EnumFunc)
MQ_EXTERN enum MkErrorE MqIoComE_FromInt ( MK_I32 const value, enum MqIoComE * value_out ) MK_ATTR_STATIC ;
 
// END-MqIoComE - created by 'c_MqS.tcl -i NHI1_HOME/theLink/c/gen/c_mqmsgque.meta' - DO NOT change
 
// MqIoComE
 
 
// [MqWaitOnEventE]
enum MqWaitOnEventE {
  MQ_WAIT_NO      = 0,
  MQ_WAIT_ONCE    = 1,
  MQ_WAIT_OWN     = 2,
  MQ_WAIT_FOREVER = 3,
};
// [MqWaitOnEventE]
 
// BEGIN-MqWaitOnEventE - created by 'c_MqS.tcl -i NHI1_HOME/theLink/c/gen/c_mqmsgque.meta' - DO NOT change
 
__parser__(doc-group=Enum,doc-index=_ignore_,class=MqMsgque,no-rpc,prefix=EnumFunc,return-type-default-no)
MQ_EXTERN MK_STRN MK_DECL MqWaitOnEventE_ToString  ( enum MqWaitOnEventE value ) MK_ATTR_STATIC ;
 
__parser__(doc-group=Enum,doc-index=_ignore_,class=MqMsgque,no-rpc,prefix=EnumFunc,return-type-default-no)
MK_ATTR_STATIC
mk_inline MK_I32 MqWaitOnEventE_ToInt ( enum MqWaitOnEventE value ) {
  return (MK_I32) value;
}
 
__parser__(doc-group=Enum,doc-index=_ignore_,class=MqMsgque,no-rpc,prefix=EnumFunc)
MQ_EXTERN enum MkErrorE MqWaitOnEventE_FromInt ( MK_I32 const value, enum MqWaitOnEventE * value_out ) MK_ATTR_STATIC ;
 
// END-MqWaitOnEventE - created by 'c_MqS.tcl -i NHI1_HOME/theLink/c/gen/c_mqmsgque.meta' - DO NOT change
 
// MqWaitOnEventE
 
 
// [MqSlaveE]
__parser__(enum-accept-integer=int32)
enum MqSlaveE {
  MQ_SLAVE_LOOPBACK =   0,      
  MQ_SLAVE_FILTER   =   1,      
  MQ_SLAVE_MASTER   =   1,      
  MQ_SLAVE_OTHER    =   1,      
  MQ_SLAVE_USER     =   10,     
 
  MQ_SLAVE_MAX      =   1024,
};
// [MqSlaveE]
 
// BEGIN-MqSlaveE - created by 'c_MqS.tcl -i NHI1_HOME/theLink/c/gen/c_mqmsgque.meta' - DO NOT change
 
__parser__(doc-group=Enum,doc-index=_ignore_,class=MqMsgque,no-rpc,prefix=EnumFunc,return-type-default-no)
MQ_EXTERN MK_STRN MK_DECL MqSlaveE_ToString  ( enum MqSlaveE value ) MK_ATTR_STATIC ;
 
__parser__(doc-group=Enum,doc-index=_ignore_,class=MqMsgque,no-rpc,prefix=EnumFunc,return-type-default-no)
MK_ATTR_STATIC
mk_inline MK_I32 MqSlaveE_ToInt ( enum MqSlaveE value ) {
  return (MK_I32) value;
}
 
__parser__(doc-group=Enum,doc-index=_ignore_,class=MqMsgque,no-rpc,prefix=EnumFunc)
MQ_EXTERN enum MkErrorE MqSlaveE_FromInt ( MK_I32 const value, enum MqSlaveE * value_out ) MK_ATTR_STATIC ;
 
// END-MqSlaveE - created by 'c_MqS.tcl -i NHI1_HOME/theLink/c/gen/c_mqmsgque.meta' - DO NOT change
 
// MqSlaveE
 
__parser__pop__;
 
// MqMsgque_Enum_C_API
 
__parser__(ignore)
struct MqLinkSetupS {
  MqCreateF             fCreate;    
  MqDeleteF             fDelete;    
};
 
// #######################################################################
// -----------------------------------------------------------------------
 
__parser__(ignore)
struct MqIoConfigS {
 
  MK_TIME_T timeout;
 
  MK_I32 buffersize;
 
  MK_I32 pkgsize;
 
  enum MqIoComE com;
 
  struct MqIoUdsConfigS   uds;
 
  struct MqIoTcpConfigS   tcp;
 
  struct MqIoPipeConfigS  pipe;
 
  struct MqIoLoopConfigS  loop;
 
  struct MqIoInitConfigS  init;
};
 
__parser__(ignore)
struct MqConfigS {
 
  enum MkNativeIsE native;
 
  enum MqStartE startAs;
 
  #define MqConfigS_dispName_size 64       
  MK_STRB  dispName[MqConfigS_dispName_size];
 
  #define MqConfigS_dispPrefix_size 64
  MK_STRB  dispPrefix[MqConfigS_dispPrefix_size];
 
  #define MqConfigS_dispPostfix_size 64
  MK_STRB  dispPostfix[MqConfigS_dispPostfix_size];
 
  MQ_CTX parent;
 
  MQ_CTX master;
 
  MK_NUM master_id;
 
  struct MqIoConfigS io;
 
  #define MqConfigS_storageFile_size 256
  MK_STRB storageFile[MqConfigS_storageFile_size];
 
  struct {
    bool  dispNameLOCK    :1  ;  
    bool  storageFileLOCK :1  ;  
    bool  dispPrefixLOCK  :1  ;  
    bool  dispPostfixLOCK :1  ;  
  } bits;                      
 
 
  enum MqIdentE identFrom;
 
#if META_HAVE_LIBCONFIG
  config_t *cfg;
 
  config_setting_t *rootH;
 
  config_setting_t *filterH;
#else
  void * cfg_dummy;         
  void * rootH_dummy;       
  void * filterH_dummy;     
#endif // META_HAVE_LIBCONFIG
 
};
 
__parser__(ignore)
struct MqSetupS {
 
  //MK_STRN ident;
  MQ_FCT factory;
 
  enum MqFactoryE factoryCall;
 
  struct MqCallbackS BgError;
 
  bool isServer;
 
  // PRIVATE: \attention the \RMKNS{BFL} commandline-arguments are available at \RCNs{LinkS::alfa} in \RCNs{ContextS::link}
  struct MqCallbackS ServerSetup;
 
  struct MqCallbackS ServerCleanup;
 
  // misc
 
  struct MqCallbackS Event;
 
  bool EventIsServer;
 
  bool ignoreExit;
};
 
// MqContextC_ConfigApi_Misc_C_API
 
// #######################################################################
// -----------------------------------------------------------------------
 
__parser__push__(doc-group=Set,doc-index=ConfigApi);
 
MQ_EXTERN void
MK_DECL MqConfigSetName_RT (
  MK_PARSER_RT
  MQ_CTX const ctx,
  MK_STRN  data
) MK_ATTR_RT_INSTANCE;
 
__parser__(internal)
MQ_EXTERN void
MK_DECL MqConfigSetPrefixWithNoLock_RT (
  MK_PARSER_RT
  MQ_CTX const ctx,
  MK_STRN  data
) MK_ATTR_RT_INSTANCE;
 
MQ_EXTERN void
MK_DECL MqConfigSetPrefix_RT (
  MK_PARSER_RT
  MQ_CTX const ctx,
  MK_STRN  data
) MK_ATTR_RT_INSTANCE;
 
MQ_EXTERN void
MK_DECL MqConfigSetPostfix_RT (
  MK_PARSER_RT
  MQ_CTX const ctx,
  MK_STRN  data
) MK_ATTR_RT_INSTANCE;
 
MQ_EXTERN void
MK_DECL MqConfigSetStorage_RT (
  MK_PARSER_RT
  MQ_CTX const ctx,
  MK_STRN  data
) MK_ATTR_RT_INSTANCE;
 
 
__parser__(internal)
MQ_EXTERN void
MK_DECL MqConfigSetAllTimeout (
  MQ_CTX const ctx,
  MK_TIME_T  data
) MK_ATTR_INSTANCE ;
 
MQ_EXTERN enum MkErrorE
MK_DECL MqConfigSetAllDebug_RT (
  MK_PARSER_RT
  MQ_CTX  const ctx,
  MK_I32  const data
) MK_ATTR_RT_INSTANCE;
 
MQ_EXTERN void
MK_DECL MqConfigSetIsString (
  MQ_CTX const ctx,
  bool  data
) MK_ATTR_INSTANCE ;
 
MQ_EXTERN enum MkErrorE
MK_DECL MqConfigSetStartAs (
  MQ_CTX const ctx,
  enum MqStartE data
) MK_ATTR_INSTANCE ;
 
MQ_EXTERN enum MkErrorE
MK_DECL MqConfigSetStartAsString (
  MQ_CTX const ctx,
  MK_STRN data
) MK_ATTR_INSTANCE ;
 
MQ_EXTERN bool
MK_DECL MqConfigCheckStartAs (
  MQ_CTX const ctx,
  enum MqStartE data
) MK_ATTR_INSTANCE ;
 
MQ_EXTERN enum MkErrorE
MK_DECL MqConfigSetIoUds_RT (
  MK_PARSER_RT
  MQ_CTX const ctx,
  MK_STRN file
) MK_ATTR_RT_INSTANCE;
 
__parser__(flags=public-internal)
MQ_EXTERN enum MkErrorE
MK_DECL MqConfigSetIoTcp_RT (
  MK_PARSER_RT
  MQ_CTX const  ctx,
  MK_STRN        host      __parser__(default=F#STRING_NULL),
  MK_STRN        port      __parser__(default=F#STRING_NULL),
  MK_STRN        myhost    __parser__(default=F#STRING_NULL),
  MK_STRN        myport    __parser__(default=F#STRING_NULL)
) MK_ATTR_RT_INSTANCE;
 
//
__parser__(no-type-extension,overload=MqConfigSetIoTcp)
MQ_EXTERN enum MkErrorE
MK_DECL MqConfigSetIoTcpL_RT (
  MK_PARSER_RT
  MQ_CTX const  ctx,
  MK_BFL const  vals
) MK_ATTR_RT_INSTANCE;
 
//
MQ_EXTERN enum MkErrorE
MK_DECL MqConfigSetIoPipe_RT (
  MK_PARSER_RT
  MQ_CTX const ctx,
  MQ_SOCK_HDL fh
) MK_ATTR_RT_INSTANCE;
 
MQ_EXTERN enum MkErrorE
MK_DECL MqConfigSetDaemon_RT (
  MK_PARSER_RT
  MQ_CTX const ctx,
  MK_STRN pidfile
) MK_ATTR_RT_INSTANCE;
 
MQ_EXTERN void
MK_DECL MqConfigSetBuffersize (
  MQ_CTX const ctx,
  MK_I32 data
) MK_ATTR_INSTANCE ;
 
MQ_EXTERN void
MK_DECL MqConfigSetPkgsize (
  MQ_CTX const ctx,
  MK_I32  data
) MK_ATTR_INSTANCE ;
 
MQ_EXTERN void
MqConfigSetTimeout (
  MQ_CTX const ctx,
  MK_TIME_T data
) MK_ATTR_INSTANCE ;
 
MQ_EXTERN void
MqConfigSetIsServer (
  MQ_CTX const ctx,
  bool data
) MK_ATTR_INSTANCE ;
 
MQ_EXTERN void
MqConfigSetIdentFrom (
  MQ_CTX const ctx,
  enum MqIdentE data
) MK_ATTR_INSTANCE ;
 
MQ_EXTERN void
MqConfigSetIgnoreExit (
  MQ_CTX const ctx,
  bool data
) MK_ATTR_INSTANCE ;
__parser__pop__;
 
// MqContextC_ConfigApi_Set_C_API
 
 
// #######################################################################
// -----------------------------------------------------------------------
 
__parser__push__(doc-group=Interface,doc-index=ConfigApi);
 
#define MqInterfaceDoc(mkrt,ctx,fCall,callback,fFree,fCopy)
 
__parser__(no-rpc,callback-name=ServerSetup,callback-null,flags=public-internal)
MQ_EXTERN void
MK_DECL MqConfigSetServerSetup_RT (
  MK_PARSER_RT
  MQ_CTX const  ctx,
  MqTokenF            fCall       __parser__(callback-call),
  MK_CBP              callback    __parser__(callback-data,null-allowed),
  MqDataFreeF         fFree       __parser__(callback-free,null-allowed),
  MqDataCopyF         fCopy       __parser__(callback-copy,null-allowed)
) MK_ATTR_RT_INSTANCE;
 
__parser__(no-rpc,callback-name=ServerCleanup,callback-null,flags=public-internal)
MQ_EXTERN void
MK_DECL MqConfigSetServerCleanup_RT (
  MK_PARSER_RT
  MQ_CTX const  ctx,
  MqTokenF            fCall       __parser__(callback-call),
  MK_CBP              callback    __parser__(callback-data),
  MqDataFreeF         fFree       __parser__(callback-free),
  MqDataCopyF         fCopy       __parser__(callback-copy)
) MK_ATTR_RT_INSTANCE;
 
__parser__(no-rpc,callback-name=BgError,callback-null,flags=public-internal)
MQ_EXTERN void
MK_DECL MqConfigSetBgError_RT (
  MK_PARSER_RT
  MQ_CTX const  ctx,
  MqTokenF            fCall     __parser__(callback-call),
  MK_CBP              callback  __parser__(callback-data),
  MqDataFreeF         fFree     __parser__(callback-free),
  MqDataCopyF         fCopy     __parser__(callback-copy)
) MK_ATTR_RT_INSTANCE;
 
__parser__(no-rpc,callback-name=Event,callback-null,flags=public-internal)
MQ_EXTERN void
MK_DECL MqConfigSetEvent_RT (
  MK_PARSER_RT
  MQ_CTX const  ctx,
  MqTokenF      fCall       __parser__(callback-call),
  MK_CBP        callback    __parser__(callback-data),
  MqDataFreeF   fFree       __parser__(callback-free),
  MqDataCopyF   fCopy       __parser__(callback-copy)
) MK_ATTR_RT_INSTANCE;
 
__parser__pop__;
 
// MqContextC_ConfigApi_Interface_C_API
 
// #######################################################################
// -----------------------------------------------------------------------
 
#define MQ_IS_SERVER(ctx)         (ctx->setup.isServer == true)
#define MQ_IS_SERVER_PARENT(ctx)  (MQ_IS_SERVER(ctx) && MQ_IS_PARENT(ctx))
#define MQ_IS_CLIENT(ctx)         (ctx->setup.isServer == false)
#define MQ_IS_CLIENT_PARENT(ctx)  (MQ_IS_CLIENT(ctx) && MQ_IS_PARENT(ctx))
#define MQ_IS_CHILD(ctx)          ((ctx)->config.parent != NULL)
#define MQ_IS_PARENT(ctx)         ((ctx)->config.parent == NULL)
#define MQ_IS_SLAVE(ctx)          ((ctx)->config.master != NULL)
#define MQ_IS_MASTER(ctx)         ((ctx)->config.master == NULL)
#define MQ_IS_LOOPBACK(ctx)       ((ctx)->config.io.com == MQ_IO_LOOP)
 
#define MQ_GET_PARENT(ctx)        (MQ_IS_CHILD(ctx) ? ctx->link.ctxIdP : ctx)
#define MQ_GET_MASTER(ctx)        (MQ_IS_SLAVE(ctx) ? ctx->config.master : ctx)
 
#define MQ_IS_ON_EXIT(ctx)        (MQ_GET_PARENT(ctx)->bits.onExit == true)
 
 
/* ####################################################################### */
/* ###                                                                 ### */
/* ###                    C T X - L O G - A P I                        ### */
/* ###                                                                 ### */
/* ####################################################################### */
 
 
__parser__push__(doc-group=Log,doc-index=LogApi);
 
__parser__(const,class-overload=MkObjectLog)
MQ_EXTERN void MK_DECL MqContextLog_RT (
  MK_PARSER_RT
  MQ_CTXN const ctx       ,
  MK_PARSER_fmtobj        ,
  MK_DBG  const debug     __parser__(default=0),
  MK_STRN const callfunc  __parser__(default=F#FUNC),
  MK_I32  const lvl       __parser__(default=0)
) MK_ATTR_RT_INSTANCE;
 
__parser__(const)
MQ_EXTERN void MK_DECL MqContextLogShort_RT (
  MK_PARSER_RT
  MQ_CTXN const ctx       ,
  MK_PARSER_fmtobj        ,
  MK_DBG  const debug     __parser__(default=0),
  MK_STRN const callfunc  __parser__(default=F#FUNC),
  MK_I32  const lvl       __parser__(default=0),
  MK_STRN const label     __parser__(default=F#STRING_NULL)
) MK_ATTR_RT_INSTANCE;
 
__parser__(const)
MQ_EXTERN void MK_DECL MqContextLogConfig_RT (
  MK_PARSER_RT
  MQ_CTXN const ctx       ,
  MK_PARSER_fmtobj        ,
  MK_DBG  const debug     __parser__(default=0),
  MK_STRN const callfunc  __parser__(default=F#FUNC),
  MK_I32  const lvl       __parser__(default=0)
) MK_ATTR_RT_INSTANCE;
 
__parser__(const)
MQ_EXTERN void MK_DECL MqContextLogSetup_RT (
  MK_PARSER_RT
  MQ_CTXN const ctx       ,
  MK_PARSER_fmtobj        ,
  MK_DBG  const debug     __parser__(default=0),
  MK_STRN const callfunc  __parser__(default=F#FUNC),
  MK_I32  const lvl       __parser__(default=0)
) MK_ATTR_RT_INSTANCE;
 
__parser__(const)
MQ_EXTERN void MK_DECL MqContextLogLink_RT (
  MK_PARSER_RT
  MQ_CTXN       ctx       ,
  MK_PARSER_fmtobj        ,
  MK_DBG  const debug     __parser__(default=0),
  MK_STRN const callfunc  __parser__(default=F#FUNC),
  MK_I32  const lvl       __parser__(default=0)
) MK_ATTR_RT_INSTANCE;
 
__parser__(const)
MQ_EXTERN void MK_DECL MqContextLogEnv_RT (
  MK_PARSER_RT
  MQ_CTX  const ctx       ,
  MK_PARSER_fmtobj        ,
  MK_DBG  const debug     __parser__(default=0),
  MK_STRN const callfunc  __parser__(default=F#FUNC),
  MK_I32  const lvl       __parser__(default=0)
) MK_ATTR_RT_INSTANCE;
 
__parser__(const,flags=new)
MQ_EXTERN void MK_DECL MqContextLogType_RT (
  MK_PARSER_RT
  MQ_CTX  const ctx       ,
  MK_PARSER_fmtobj        ,
  MK_DBG  const debug     __parser__(default=0),
  MK_STRN const callfunc  __parser__(default=F#FUNC),
  MK_I32  const lvl       __parser__(default=0)
) MK_ATTR_RT_INSTANCE;
 
__parser__(ignore)
MQ_EXTERN void MK_DECL MqContextLogDebug (MQ_CTX const ctx);
 
// end of class=MqContextC,doc-group=Log
__parser__pop__;
 
// MqContextC_LogApi_Log_C_API
 
// #######################################################################
// -----------------------------------------------------------------------
 
typedef int (*MqSysSelectF) (int max, void* read, void* write, void* except, struct timeval* timeout);
 
struct MqSysServerThreadMainS {
  bool                  isUsed;       
  MQ_CTX                tmpl;         
  MQ_FCT                factory;      
  MkBufferStream16384R  argvR;        
 
  // config data from MqRuntimeS
  MK_RT                 mkrt;         
  MQ_RT                 mqrt;         
  MK_TYP                typ;          
  MQ_FCT                fct;          
  MQ_SOCK_HDL           socket;       
 
  MkThreadDataS         mkThreadData; 
};
 
__parser__(hide)
MQ_EXTERN void MK_DECL MqSysServerThreadMain (
  struct MqSysServerThreadMainS *data __parser__(in,silent)
);
 
typedef enum MkErrorE (*MqSysServerSpawnF) (
  MQ_RT_ARGS
  MQ_CTX const    ctx,
  char *const   * argv,
  MK_STRN         name,
  struct MkIdS *  idPtrOut
);
 
typedef enum MkErrorE (*MqSysServerThreadF) (
  MK_RT_ARGS
  MQ_CTX const    ctx,
  struct MqSysServerThreadMainS * const   argP __parser__(in) ,
  MK_STRN         name,
  int             state,
  struct MkIdS *  idPtrOut  __parser__(in)
);
 
typedef enum MkErrorE (*MqSysServerForkF) (
  MQ_RT_ARGS
  MQ_CTX const    ctx,
  MQ_FCT          factory,
  MK_BFL*         argsP,
  MK_STRN         name,
  MQ_SOCK_HDL     socket,
  struct MkIdS *  idPtrOut   __parser__(in)
);
 
__parser__(ignore)
struct MqLalS {
  MqSysSelectF            SysSelect;
 
  MqSysServerSpawnF       MqSysServerSpawnCB;
 
  MqSysServerThreadF      MqSysServerThreadCB;      // sSysServerThread
 
  MqSysServerForkF        MqSysServerForkCB;
};
 
__parser__(ignore)
MQ_EXTERN_DATA struct MqLalS MqLal;
 
// - MqMsgque_Sys_C_API
 
/* MARK_E ################################################################ */
/* ###                                                                 ### */
/* ###                     E R R O R - A P I                           ### */
/* ###                                                                 ### */
/* ####################################################################### */
 
 
__parser__(internal)
struct MqErrorS {
  // BEGIN-MqErrorS-super - created by 'c_Class.tcl -i NHI1_HOME/theLink/c/gen/c_mqmsgque.meta' - DO NOT change
 
  union {
    struct MkObjectS            obj;          // instance-base MkObjectS
    struct MkExtensionS         ext;          // instance-base MkExtensionS
    struct MkErrExtS            errext;       // instance-base MkErrExtS
  } super;
 
  // END-MqErrorS-super - created by 'c_Class.tcl -i NHI1_HOME/theLink/c/gen/c_mqmsgque.meta' - DO NOT change
 
  // instance attributes
  char                errhint;            // the TYPE if the \e errobj U=undefined, C=client, S=server
 
  MQ_CTXN             client_ctx;         // context source of the error, NULL = current context
 
  // The \e error_protect is used in \RCNs{SendERROR} to restructure the environment at
  // the time of the error. The data is a copy of the \RCNs{LinkS::protect} data
  struct MqEnvS       client_protect;
 
  MQ_CTXN             server_ctx;         // context source of the error, NULL = current context
 
  // The \e error_protect is used in \RCNs{SendERROR} to restructure the environment at
  // the time of the error. The data is a copy of the \RCNs{LinkS::protect} data
  struct MqEnvS       server_protect;
};
 
// BEGIN-MqErrorS-Definition - created by 'c_Class.tcl -i NHI1_HOME/theLink/c/gen/c_mqmsgque.meta' - DO NOT change
 
  __parser__push__(prefix=Class, doc-group=Define, doc-index=Class);
 
// Signature --------------------------------------------------------------
 
  #define MqErrorC_SIGNATURE             (MkErrExtC_SIGNATURE ^ (1u<<3))
  #define MqErrorC_MASK                  (((1u<<29)-1)<<3)
 
 
// CompileTimeCast --------------------------------------------------------------
 
  #define MqErrorC_X2err(x)              (x)
  #define MqErrorC_X2errext(x)           MkERREXT(x)
  #define MqErrorC_X2ext(x)              MkEXT(x)
  #define MqErrorC_X2obj(x)              MkOBJ(x)
 
 
// TypeDef --------------------------------------------------------------
 
  __parser__(ignore) typedef struct MqErrorS MqErrorCR;
  __parser__(ignore) typedef const struct MqErrorS MqErrorCNR;
  #define MqErrorC_T                     (&MQ_RT_REF._MqErrorC_T)
  #define MqErrorC_TT                    (MkTYP(MqErrorC_T))
  #define MqErrorST                      MqErrorC_T
  #define MqErrorSTT                     (MkTYP(MqErrorST))
  #define MqErrorC_type                  MQ_ERR
  #define MqErrorCT_X(instance)          ( (struct MkTypeDefS *) (MkOBJ_R(instance).type) )
  #define MqErrorCTT_X(instance)         (MkOBJ_R(instance).type)
  #define MqErrorCT_TT(typ)              ( (struct MkTypeDefS *) (typ) )
  #define MqErrorC_NS                    MQ
  #define MqErrorCTT                     MqErrorCTT
  #define MqErrorCT                      ( (struct MkTypeDefS *) MqErrorCTT )
 
 
// TypeCheck --------------------------------------------------------------
 
  #pragma GCC diagnostic push
  #pragma GCC diagnostic ignored "-Wattributes"
 
  __parser__(class=MqErrorC,static,ignore)
  MK_ATTR_STATIC
  mk_inline bool MqErrCheck (MK_MNGN mng) {
    return MkSanitizeCheck(MqErrorC,mng);
  }
 
  __parser__(class=MqErrorC,static,ignore)
  MK_ATTR_STATIC
  mk_inline bool MqErrCheckO (MK_OBJN obj) {
    return MkSanitizeCheckO(MqErrorC,obj);
  }
 
  #pragma GCC diagnostic pop
  #define MqErrorC_Check(mng)            MqErrCheck(mng)
 
 
// RunTimeCast --------------------------------------------------------------
 
  __parser__(class=MqErrorC,ignore,static)
  META_ATTRIBUTE_SANITIZE
  MK_ATTR_STATIC
  mk_inline MQ_ERR MqErr(MK_MNG mng) {
    return (MqErrCheck(mng) ? (MQ_ERR)mng : NULL);
  }
 
  __parser__(class=MqErrorC,ignore,static)
  META_ATTRIBUTE_SANITIZE
  MK_ATTR_STATIC
  mk_inline MQ_ERRN MqErrN(MK_MNGN mng) {
    return (MqErrCheck(mng) ? (MQ_ERRN)mng : NULL);
  }
 
  #define MqErrRaise(_err) if (!_MkCheckX(MqErrorC,_err)) { \
    MkErrorSetC_1E("'MqErrorC' hdl is NULL"); \
    goto error ; \
  }
 
  #define   MqERR_R(x)        (*(x)).super.err
  #define   MqERR(x)          (&MqERR_R(x))
 
 
  __parser__pop__;
// MqErrorC_Class_Define_C_API
 
// END-MqErrorS-Definition - created by 'c_Class.tcl -i NHI1_HOME/theLink/c/gen/c_mqmsgque.meta' - DO NOT change
 
#define   MqERROR_R(r)      ((*r).error_mq)
#define   MqERROR_RT        MqERROR_R(&MQ_RT_REF)
#define   MqERROR_O(o)      MqERROR_R(MqRT_O(o))
#define   MqERROR_X(x)      MqERROR_R(MqRT_X(x))
#define   MqERROR_XN(x)     MqERROR_R(MqRT_XN(x))
#define   MqERROR           MqERROR_R(&MqRuntimeRLS)
 
 
__parser__(ignore)
MQ_EXTERN void MK_DECL MqErrorEnvReset (
  MQ_ERR const err
) MK_ATTR_INSTANCE ;
 
// MqErrorC_C_API
 
/* ####################################################################### */
/* ###                                                                 ### */
/* ###                    F A C T O R Y - A P I                        ### */
/* ###                                                                 ### */
/* ####################################################################### */
 
 
#define MqFactoryPanic(fct) if (fct == NULL) MkPanicC(MK_ERROR_PANIC, __func__, -1, "MqFactoryS exception");
 
typedef enum MkErrorE ( MK_DECL
  *MqFactoryCTorF
) ( 
  MQ_RT_ARGS
  MQ_CTX const tmpl,
  enum MqFactoryE create,
  MQ_FCT const fct,
  MQ_CTX * ctx_out
);
 
#define MQ_CALLBACK_FACTORY_CTOR_ARGS    \
  MQ_RT_ARGS                             \
  MQ_CTX const tmpl,                     \
  enum MqFactoryE create,                \
  struct MqFactoryS * const fct,         \
  MQ_CTX *contextP                       \
 
#define MQ_CALLBACK_FACTORY_CTOR_CALL    MQ_RT_CALL tmpl, create, fct, contextP
 
typedef void ( MK_DECL
  *MqFactoryDTorF
) (
  MK_RT_ARGS
  MQ_CTX ctx,
  bool doFactoryCleanup,
  MQ_FCT const fct
) ;
 
#define MQ_CALLBACK_FACTORY_DTOR_ARGS    \
  MQ_RT_ARGS                             \
  MQ_CTX ctx,                            \
  bool doFactoryCleanup,                 \
  MQ_FCT const fct                       \
 
typedef void ( MK_DECL
  *MqFactoryDataFreeF
) (
  MK_RT_ARGS
  MK_PTR *dataP __parser__(inout)
) ;
 
typedef void ( MK_DECL
  *MqFactoryDataCopyF
) (
  MK_RT_ARGS
  MK_PTR *dataP __parser__(inout)
) ;
 
__parser__(ignore)
struct MqFactoryCTorS {
  MqFactoryCTorF      fCall;        
  MK_PTR              data;         
  MqFactoryDataFreeF  fFree;        
  MqFactoryDataCopyF  fCopy;        
};
 
__parser__(ignore)
struct MqFactoryDTorS {
  MqFactoryDTorF      fCall;        
  MK_PTR              data;         
  MqFactoryDataFreeF  fFree;        
  MqFactoryDataCopyF  fCopy;        
};
 
#define MqDbgFct_2(f,c) \
  mk_dbg_color_ln(c,"MqDbgFct[%-16s]: fct<P=%p:T=%p:R=%p>, MqFactoryC_TT<%p>", \
    MK_TRIM_LEFT(16,f->originalIdent), f, MkTYP_X(f), MkRT_X(f), MqFactoryC_TT)
#define MqDbgFct(f) MqDbgFct_2(f,MK_COLOR_YELLOW)
 
struct MqFactoryS {
  // BEGIN-MqFactoryS-super - created by 'c_Class.tcl -i NHI1_HOME/theLink/c/gen/c_mqmsgque.meta' - DO NOT change
 
  union {
    struct MkObjectS            obj;          // instance-base MkObjectS
  } super;
 
  // END-MqFactoryS-super - created by 'c_Class.tcl -i NHI1_HOME/theLink/c/gen/c_mqmsgque.meta' - DO NOT change
 
  // instance attributes
  bool    isDeleted;                
  #define MqFactoryS_originalIdent_size 63
  MK_STRB originalIdent[MqFactoryS_originalIdent_size+1];           
  bool    factoryCalled;            
  struct  MqFactoryCTorS fct_ctor;  
  struct  MqFactoryDTorS fct_dtor;  
};
 
// BEGIN-MqFactoryS-Definition - created by 'c_Class.tcl -i NHI1_HOME/theLink/c/gen/c_mqmsgque.meta' - DO NOT change
 
  __parser__push__(prefix=Class, doc-group=Define, doc-index=Class);
 
// Signature --------------------------------------------------------------
 
  #define MqFactoryC_SIGNATURE           (MkObjectC_SIGNATURE ^ (12u<<10))
  #define MqFactoryC_MASK                (((1u<<22)-1)<<10)
 
 
// CompileTimeCast --------------------------------------------------------------
 
  #define MqFactoryC_X2fct(x)            (x)
  #define MqFactoryC_X2obj(x)            MkOBJ(x)
 
 
// TypeDef --------------------------------------------------------------
 
  __parser__(ignore) typedef struct MqFactoryS MqFactoryCR;
  __parser__(ignore) typedef const struct MqFactoryS MqFactoryCNR;
  #define MqFactoryC_T                   (&MQ_RT_REF._MqFactoryC_T)
  #define MqFactoryC_TT                  (MkTYP(MqFactoryC_T))
  #define MqFactoryST                    MqFactoryC_T
  #define MqFactorySTT                   (MkTYP(MqFactoryST))
  #define MqFactoryC_type                MQ_FCT
  #define MqFactoryCT_X(instance)        ( (struct MkTypeDefS *) (MkOBJ_R(instance).type) )
  #define MqFactoryCTT_X(instance)       (MkOBJ_R(instance).type)
  #define MqFactoryCT_TT(typ)            ( (struct MkTypeDefS *) (typ) )
  #define MqFactoryC_NS                  MQ
  #define MqFactoryCTT                   MqFactoryCTT
  #define MqFactoryCT                    ( (struct MkTypeDefS *) MqFactoryCTT )
 
 
// TypeCheck --------------------------------------------------------------
 
  #pragma GCC diagnostic push
  #pragma GCC diagnostic ignored "-Wattributes"
 
  __parser__(class=MqFactoryC,static,hide)
  MK_ATTR_STATIC
  mk_inline bool MqFctCheck (MK_MNGN mng) {
    return MkSanitizeCheck(MqFactoryC,mng);
  }
 
  __parser__(class=MqFactoryC,static,hide)
  MK_ATTR_STATIC
  mk_inline bool MqFctCheckO (MK_OBJN obj) {
    return MkSanitizeCheckO(MqFactoryC,obj);
  }
 
  #pragma GCC diagnostic pop
  #define MqFactoryC_Check(mng)          MqFctCheck(mng)
 
 
// RunTimeCast --------------------------------------------------------------
 
  __parser__(class=MqFactoryC,hide,static)
  META_ATTRIBUTE_SANITIZE
  MK_ATTR_STATIC
  mk_inline MQ_FCT MqFct(MK_MNG mng) {
    return (MqFctCheck(mng) ? (MQ_FCT)mng : NULL);
  }
 
  __parser__(class=MqFactoryC,hide,static)
  META_ATTRIBUTE_SANITIZE
  MK_ATTR_STATIC
  mk_inline MQ_FCTN MqFctN(MK_MNGN mng) {
    return (MqFctCheck(mng) ? (MQ_FCTN)mng : NULL);
  }
 
  #define MqFctRaise(_fct) if (!_MkCheckX(MqFactoryC,_fct)) { \
    MkErrorSetC_1E("'MqFactoryC' hdl is NULL"); \
    goto error ; \
  }
 
  #define   MqFCT_R(x)        (*(x)).super.fct
  #define   MqFCT(x)          (&MqFCT_R(x))
 
 
  __parser__pop__;
// MqFactoryC_Class_Define_C_API
 
// END-MqFactoryS-Definition - created by 'c_Class.tcl -i NHI1_HOME/theLink/c/gen/c_mqmsgque.meta' - DO NOT change
 
// =========================================================================
// BEGIN-MqFactoryS-Export - created by 'c_Class.tcl -i NHI1_HOME/theLink/c/gen/c_mqmsgque.meta' - DO NOT change
 
 
 
__parser__push__(doc-group=_ignore_,doc-index=Class,doc-name=Export,class=MqFactoryC);
 
__parser__(class-overload=MkObjectHandleGet)
MK_ATTR_RT_INSTANCE
mk_inline MK_HDL MK_DECL MqFactoryHandleGet_RT ( 
  MK_PARSER_RT
  MQ_FCT const fct  __parser__(null-allowed)
) {
  return MkObjectHandleGet(fct?MkOBJ(fct):NULL);
}
 
__parser__(flags=new)
MK_ATTR_RT_STATIC
mk_inline MQ_FCT MqFactoryHandleResolve_RT (
  MK_PARSER_RT
  MK_HDL const netHdl 
) {
  return MqFct(MkObjectHandleResolve(netHdl));
}
 
#define MqFactoryHandleResolve_e(netHdl) ({ \
  MK_HDL tmpHdl=netHdl; \
  MQ_FCT tmp; \
  if (tmpHdl==0) { \
    tmp=NULL; \
  } else { \
    tmp=MqFactoryHandleResolve(tmpHdl); \
    if (tmp==NULL) { \
      MkErrorSetC_1_NULL("ERROR: 'MqFactoryC' handle is 'NULL'"); \
      goto error; \
    }; \
  }; \
  tmp; \
})
 
__parser__pop__;
 
// Class export & import
 
  __parser__(flags=new,doc-group=_ignore_,doc-index=Class,doc-name=Misc,class=MqFactoryC,null-return-allow)
  MK_ATTR_STATIC
  mk_inline MQ_FCT MqFactoryGetNull ( void ) {
    return (MQ_FCT)MK_NULL;
  }
// MqFactoryC - Misc - function
 
// MqFactoryC_Class_C_API
 
// END-MqFactoryS-Export - created by 'c_Class.tcl -i NHI1_HOME/theLink/c/gen/c_mqmsgque.meta' - DO NOT change
 
// #######################################################################
// -----------------------------------------------------------------------
 
__parser__push__(doc-group=Get);
 
__parser__(hide)
MQ_EXTERN MK_PTR MK_DECL MqFactoryItemGetCreateData (
  MQ_FCTN const fct
) MK_ATTR_INSTANCE ;
 
__parser__(internal)
MQ_EXTERN MK_PTR MK_DECL MqFactoryItemGetDeleteData (
  MQ_FCTN const fct
) MK_ATTR_INSTANCE ;
 
MQ_EXTERN MK_STRN MK_DECL MqFactoryGetOriginalIdent (
  MQ_FCTN const fct
) MK_ATTR_INSTANCE ;
 
MQ_EXTERN MQ_FCT MK_DECL MqFactoryGet_RT (
  MK_PARSER_RT
  MK_STRN const  ident   __parser__(default=S#"")
) MK_ATTR_RT_STATIC ;
 
MQ_EXTERN MQ_FCT MK_DECL MqFactoryGetCalled_RT (
  MK_PARSER_RT
  MK_STRN const  ident   __parser__(default=S#"")
) MK_ATTR_RT_STATIC ;
 
// [MqFactoryGetCalledL_RT]
__parser__(no-type-extension,overload=MqFactoryGetCalled)
MQ_EXTERN MQ_FCT MK_DECL MqFactoryGetCalledL_RT (
  MK_PARSER_RT
  MK_BFLN largs   __parser__(argument)
) MK_ATTR_RT_INSTANCE;
// [MqFactoryGetCalledL_RT]
 
__parser__pop__;
 
// MqFactoryC_Get_C_API
 
// #######################################################################
// -----------------------------------------------------------------------
 
__parser__push__(doc-group=TOR);
 
__parser__(hide)
MQ_EXTERN void MK_DECL MqFactoryFree_RT (
  MK_PARSER_RT
  MQ_FCT const fct
) MK_ATTR_RT_INSTANCE;
 
 
__parser__(destructor)
MQ_EXTERN void MK_DECL MqFactoryDelete_RT (
  MK_PARSER_RT
  MQ_FCT fct
) MK_ATTR_RT_INSTANCE;
 
 
__parser__(constructor,lng-constr,no-rpc,overload-c-no)
MQ_EXTERN MQ_FCT MK_DECL MqFactoryAdd_RT (
  MK_PARSER_RT
  MK_OBJN               const error             __parser__(internal,default=NULL), //C# reguire non "ERROR" name
// constructor
  MqFactoryCTorF        const createCallF       __parser__(internal,default=FactoryObjCreate),
  MK_CCP                const constructor       __parser__(constructor),
  MqFactoryDataFreeF    const createDataFreeF   __parser__(internal,default=FactoryFree),
  MqFactoryDataCopyF    const createDataCopyF   __parser__(internal,default=FactoryDup2),
// destructor
  MqFactoryDTorF        const deleteCallF       __parser__(internal,default=FactoryObjDelete),
  MK_CCP                const destructor        __parser__(internal,default=NULL),
  MqFactoryDataFreeF    const deleteDataFreeF   __parser__(internal,default=NULL),
  MqFactoryDataCopyF    const deleteDataCopyF   __parser__(internal,default=NULL),
 
  MK_STRN               const ident             __parser__(default=F#CTOR#constructor)
) MK_ATTR_RT_STATIC;
 
#define MqFactoryAdd_1(fct)       MqFactoryAdd(MK_ERROR_PANIC,fct,NULL, NULL, NULL, NULL, NULL, NULL, NULL, #fct)
#define MqFactoryAdd_2(fct,ident) MqFactoryAdd(MK_ERROR_PANIC,fct,NULL, NULL, NULL, NULL, NULL, NULL, NULL, ident)
#define MqFactoryAdd_3(ctor,dtor,ident) MqFactoryAdd(MK_ERROR_PANIC,ctor,NULL, NULL, NULL, dtor, NULL, NULL, NULL, ident)
 
__parser__(constructor,internal)
MQ_EXTERN MQ_FCT MK_DECL MqFactoryTypeAdd_RT (
  MK_PARSER_RT
  MK_OBJN         const error,
  MK_STRN         const ident,
  MkSelfCreateF   const fctCreate,
  MkSelfDeleteF   const fctDelete,
  MkConstructorF  const constructor,
  MkSelfDeleteF   const selfDelete
) MK_ATTR_RT_STATIC;
 
__parser__(constructor)
MQ_EXTERN MQ_FCT MK_DECL MqFactoryDup2_RT (
  MK_PARSER_RT
  MQ_FCTN const fct,
  MK_STRN const ident
) MK_ATTR_RT_INSTANCE;
 
__parser__pop__;
 
// MqFactoryC_TOR_C_API
 
// #######################################################################
// -----------------------------------------------------------------------
 
__parser__push__(doc-group=Misc);
 
MQ_EXTERN MQ_FCT MK_DECL MqFactoryDefault_RT (
  MK_PARSER_RT
  MQ_FCT const fct
) MK_ATTR_RT_INSTANCE ;
 
MQ_EXTERN MQ_FCT MK_DECL MqFactoryInitial_RT (
  MK_PARSER_RT
  MQ_FCT const fct
) MK_ATTR_RT_INSTANCE ;
 
MQ_EXTERN MK_STRN MK_DECL MqFactoryDefaultIdent_RT (
  MK_PARSER_RT_ONLY
) MK_ATTR_RT_STATIC ;
 
MQ_EXTERN MK_STRN MK_DECL MqFactoryInitialIdent_RT (
  MK_PARSER_RT_ONLY
) MK_ATTR_RT_STATIC ;
 
__parser__(class=MqFactoryC,flags=virtual)
MQ_EXTERN enum MkErrorE MK_DECL MqFactoryNew_RT (
  MK_PARSER_RT
  MQ_FCT  const fct,
  MQ_CTX  const tmpl    __parser__(internal,default=NULL),
  MQ_CTX* const val_out
) MK_ATTR_RT_INSTANCE;
 
MQ_EXTERN void MK_DECL MqFactoryLogAll_RT (
  MK_PARSER_RT
  MK_STRN const  callfunc  __parser__(default=F#FUNC)
) MK_ATTR_RT_INSTANCE ;
 
 
__parser__(const,class-overload=MkObjectLog)
MQ_EXTERN void MK_DECL MqFactoryLog_RT (
  MK_PARSER_RT
  MQ_FCTN const fct       ,
  MK_PARSER_fmtobj        ,
  MK_DBG  const debug     __parser__(default=0),
  MK_STRN const callfunc  __parser__(default=F#FUNC),
  MK_I32  const lvl       __parser__(default=0)
) MK_ATTR_RT_INSTANCE;
 
#define MqFactoryLog_2M(fct,m)    MqFactoryLog(fct,MkObj(m),0,__func__,0)
 
// MqFactoryLog
 
__parser__pop__;
 
// MqFactoryC_Misc_C_API
 
// MqFactoryC_C_API
 
// #######################################################################
// -----------------------------------------------------------------------
 
__parser__(ignore)
struct MqTypeCtxS {
  // BEGIN-MqTypeCtxS-super - created by 'c_Class.tcl -i NHI1_HOME/theLink/c/gen/c_mqmsgque.meta' - DO NOT change
 
  union {
    struct MkObjectS            obj;          // instance-base MkObjectS
    struct MkTypeS              typ;          // instance-base MkTypeS
  } super;
 
  // END-MqTypeCtxS-super - created by 'c_Class.tcl -i NHI1_HOME/theLink/c/gen/c_mqmsgque.meta' - DO NOT change
 
  // instance attributes
 
  bool argvFix;
 
  bool ignoreThread;
 
  bool ignoreSpawn;
 
  bool ignoreFork;
 
  MqRefCountF   fIncrSelf;
 
  MqRefCountF   fDecrSelf;
 
  MqSetupF      fParentBeforeFork;
 
  MqSetupF      fParentAfterFork;
 
  MqSetupF      fChildAfterFork;
 
  MqExitF       MqProcessExitCB;
 
  MqExitF       MqThreadExitCB;
 
  MqWaitForPipeF MqWaitForPipeCB;
 
  struct MqLinkSetupS Child;
 
  struct MqLinkSetupS Parent;
 
  struct MqCallbackS Idle;
 
  MkMarkF       dataMF;
 
  MkMarkF       callbackMF;
 
  MqHelpF fHelp;
 
  MqSetupF      fThreadInit;
 
  MqSetupF      fSpawnInit;
 
  bool          ignoreDisasterSetup;
};
 
// BEGIN-MqTypeCtxS-Definition - created by 'c_Class.tcl -i NHI1_HOME/theLink/c/gen/c_mqmsgque.meta' - DO NOT change
 
  __parser__push__(prefix=Class, doc-group=Define, doc-index=Class);
 
// Signature --------------------------------------------------------------
 
  #define MqTypeCtxC_SIGNATURE           (MkTypeC_SIGNATURE ^ (2u<<6))
  #define MqTypeCtxC_MASK                (((1u<<26)-1)<<6)
 
 
// CompileTimeCast --------------------------------------------------------------
 
  #define MqTypeCtxC_X2ctxtyp(x)         (x)
  #define MqTypeCtxC_X2typ(x)            MkTYP(x)
  #define MqTypeCtxC_X2obj(x)            MkOBJ(x)
 
 
// TypeDef --------------------------------------------------------------
 
  __parser__(ignore) typedef struct MqTypeCtxS MqTypeCtxCR;
  __parser__(ignore) typedef const struct MqTypeCtxS MqTypeCtxCNR;
  #define MqTypeCtxSTT                   (&MQ_RT_REF._MqTypeCtxC_TT)
  #define MqTypeCtxC_TT                  (&MQ_RT_REF._MqTypeCtxC_TT)
  #define MqTypeCtxC_type                MQ_CTXTYP
  #define MqTypeCtxCT_X(instance)        ( (struct MkTypeS *) (MkOBJ_R(instance).type) )
  #define MqTypeCtxCTT_X(instance)       (MkOBJ_R(instance).type)
  #define MqTypeCtxCT_TT(typ)            ( (struct MkTypeS *) (typ) )
  #define MqTypeCtxC_NS                  MQ
  #define MqTypeCtxCTT                   MqTypeCtxCTT
  #define MqTypeCtxCT                    ( (struct MkTypeS *) MqTypeCtxCTT )
 
 
// TypeCheck --------------------------------------------------------------
 
  #pragma GCC diagnostic push
  #pragma GCC diagnostic ignored "-Wattributes"
 
  __parser__(class=MqTypeCtxC,static,ignore)
  MK_ATTR_STATIC
  mk_inline bool MqCtxTypCheck (MK_MNGN mng) {
    return MkSanitizeCheck(MqTypeCtxC,mng);
  }
 
  __parser__(class=MqTypeCtxC,static,ignore)
  MK_ATTR_STATIC
  mk_inline bool MqCtxTypCheckO (MK_OBJN obj) {
    return MkSanitizeCheckO(MqTypeCtxC,obj);
  }
 
  #pragma GCC diagnostic pop
  #define MqTypeCtxC_Check(mng)          MqCtxTypCheck(mng)
 
 
  __parser__pop__;
// MqTypeCtxC_Class_Define_C_API
 
// END-MqTypeCtxS-Definition - created by 'c_Class.tcl -i NHI1_HOME/theLink/c/gen/c_mqmsgque.meta' - DO NOT change
 
__parser__(class=MqContextC,internal,static)
mk_inline MQ_CTXT MqCtxTyp(MK_MNG mng) {
  if (!MkObjCheck(mng)) return NULL;
  MK_OBJ obj = (MK_OBJ) mng;
  if (MqCtxTypCheck(obj)) return (MQ_CTXT)obj;
  MQ_CTXT typ = (MQ_CTXT) obj->type;
  if (MqCtxTypCheck(typ)) return typ;
  return NULL;
}
 
__parser__(ignore,const,class-overload=MkObjectLog)
MQ_EXTERN void MK_DECL MqTypeCtxLog_RT (
  MK_PARSER_RT
  MQ_CTXT const ctxtype   ,
  MK_PARSER_fmtobj        ,
  MK_DBG  const debug     __parser__(default=0),
  MK_STRN const callfunc  __parser__(default=F#FUNC),
  MK_I32  const lvl       __parser__(default=0)
) MK_ATTR_RT_INSTANCE;
 
#define MqTypeCtxLog_1(typ) MqTypeCtxLog_RT(MK_RT_CALL typ,NULL,0,__func__,0)
 
// MqTypeCtxC_C_API
 
/* ####################################################################### */
/* ###                                                                 ### */
/* ###                    C O N T E X T - A P I                        ### */
/* ###                                                                 ### */
/* ####################################################################### */
 
 
// ===================================================================================================
 
#if defined(MQ_C_BUILD_DLL)
 
  #define   META_SECTION_DEFINE
  #include "MqContextS_mq.h"
  #undef    META_SECTION_DEFINE
 
#else   // MQ_C_BUILD_DLL
 
struct MqContextS {
  // BEGIN-MqContextS-super - created by 'c_Class.tcl -i NHI1_HOME/theLink/c/gen/c_mqmsgque.meta' - DO NOT change
 
  union {
    struct MkObjectS            obj;          // instance-base MkObjectS
  } super;
 
  // END-MqContextS-super - created by 'c_Class.tcl -i NHI1_HOME/theLink/c/gen/c_mqmsgque.meta' - DO NOT change
 
  // instance attributes
  const
  struct MqConfigS      config;     
  struct MqSetupS       setup;      
  struct MkBuffer64S    ctxbuf;     
  enum   MqStatusIsEF   statusIs;   
  struct MqLinkS        link;       
 
  // offset calculated by "Nhi1InternalSize"
  MK_BINB private_variables[16];
};
 
#endif  // MQ_C_BUILD_DLL
 
// BEGIN-MqContextS-Definition - created by 'c_Class.tcl -i NHI1_HOME/theLink/c/gen/c_mqmsgque.meta' - DO NOT change
 
  __parser__push__(prefix=Class, doc-group=Define, doc-index=Class);
 
// Signature --------------------------------------------------------------
 
  #define MqContextC_SIGNATURE           (MkObjectC_SIGNATURE ^ (13u<<10))
  #define MqContextC_MASK                (((1u<<22)-1)<<10)
 
 
// CompileTimeCast --------------------------------------------------------------
 
  #define MqContextC_X2ctx(x)            (x)
  #define MqContextC_X2obj(x)            MkOBJ(x)
 
 
// TypeDef --------------------------------------------------------------
 
  __parser__(ignore) typedef struct MqContextS MqContextCR;
  __parser__(ignore) typedef const struct MqContextS MqContextCNR;
  #define MqContextC_T                   (&MQ_RT_REF._MqContextC_T)
  #define MqContextC_TT                  (MkTYP(MqContextC_T))
  #define MqContextST                    MqContextC_T
  #define MqContextSTT                   (MkTYP(MqContextST))
  #define MqContextC_type                MQ_CTX
  #define MqContextCT_X(instance)        ( (struct MqTypeCtxS *) (MkOBJ_R(instance).type) )
  #define MqContextCTT_X(instance)       (MkOBJ_R(instance).type)
  #define MqContextCT_TT(typ)            ( (struct MqTypeCtxS *) (typ) )
  #define MqContextC_NS                  MQ
  #define MqContextCTT                   MqContextCTT
  #define MqContextCT                    ( (struct MqTypeCtxS *) MqContextCTT )
 
 
// TypeCheck --------------------------------------------------------------
 
  #pragma GCC diagnostic push
  #pragma GCC diagnostic ignored "-Wattributes"
 
  __parser__(class=MqContextC,static,hide)
  MK_ATTR_STATIC
  mk_inline bool MqCtxCheck (MK_MNGN mng) {
    return MkSanitizeCheck(MqContextC,mng);
  }
 
  __parser__(class=MqContextC,static,hide)
  MK_ATTR_STATIC
  mk_inline bool MqCtxCheckO (MK_OBJN obj) {
    return MkSanitizeCheckO(MqContextC,obj);
  }
 
  #pragma GCC diagnostic pop
  #define MqContextC_Check(mng)          MqCtxCheck(mng)
 
 
// RunTimeCast --------------------------------------------------------------
 
  __parser__(class=MqContextC,hide,static)
  META_ATTRIBUTE_SANITIZE
  MK_ATTR_STATIC
  mk_inline MQ_CTX MqCtx(MK_MNG mng) {
    return (MqCtxCheck(mng) ? (MQ_CTX)mng : NULL);
  }
 
  __parser__(class=MqContextC,hide,static)
  META_ATTRIBUTE_SANITIZE
  MK_ATTR_STATIC
  mk_inline MQ_CTXN MqCtxN(MK_MNGN mng) {
    return (MqCtxCheck(mng) ? (MQ_CTXN)mng : NULL);
  }
 
  #define MqCtxRaise(_ctx) if (!_MkCheckX(MqContextC,_ctx)) { \
    MkErrorSetC_1E("'MqContextC' hdl is NULL"); \
    goto error ; \
  }
 
  #define   MqCTX_R(x)        (*(x)).super.ctx
  #define   MqCTX(x)          (&MqCTX_R(x))
 
 
  __parser__pop__;
// MqContextC_Class_Define_C_API
 
// END-MqContextS-Definition - created by 'c_Class.tcl -i NHI1_HOME/theLink/c/gen/c_mqmsgque.meta' - DO NOT change
 
// =========================================================================
// BEGIN-MqContextS-Export - created by 'c_Class.tcl -i NHI1_HOME/theLink/c/gen/c_mqmsgque.meta' - DO NOT change
 
 
 
__parser__push__(doc-group=_ignore_,doc-index=Class,doc-name=Export,class=MqContextC);
 
__parser__(class-overload=MkObjectHandleGet)
MK_ATTR_RT_INSTANCE
mk_inline MK_HDL MK_DECL MqContextHandleGet_RT ( 
  MK_PARSER_RT
  MQ_CTX const ctx  __parser__(null-allowed)
) {
  return MkObjectHandleGet(ctx?MkOBJ(ctx):NULL);
}
 
__parser__(flags=new)
MK_ATTR_RT_STATIC
mk_inline MQ_CTX MqContextHandleResolve_RT (
  MK_PARSER_RT
  MK_HDL const netHdl 
) {
  return MqCtx(MkObjectHandleResolve(netHdl));
}
 
#define MqContextHandleResolve_e(netHdl) ({ \
  MK_HDL tmpHdl=netHdl; \
  MQ_CTX tmp; \
  if (tmpHdl==0) { \
    tmp=NULL; \
  } else { \
    tmp=MqContextHandleResolve(tmpHdl); \
    if (tmp==NULL) { \
      MkErrorSetC_1_NULL("ERROR: 'MqContextC' handle is 'NULL'"); \
      goto error; \
    }; \
  }; \
  tmp; \
})
 
__parser__pop__;
 
// Class export & import
 
  __parser__(flags=new,doc-group=_ignore_,doc-index=Class,doc-name=Misc,class=MqContextC,null-return-allow)
  MK_ATTR_STATIC
  mk_inline MQ_CTX MqContextGetNull ( void ) {
    return (MQ_CTX)MK_NULL;
  }
// MqContextC - Misc - function
 
// MqContextC_Class_C_API
 
// END-MqContextS-Export - created by 'c_Class.tcl -i NHI1_HOME/theLink/c/gen/c_mqmsgque.meta' - DO NOT change
 
// MqContextC_C_API
 
// #######################################################################
// -----------------------------------------------------------------------
 
__parser__push__(doc-group=TOR);
 
__parser__(internal)
MQ_EXTERN void MK_DECL MqContextInit_RT (
  MK_PARSER_RT
  MQ_CTX const ctx,
  MK_TYP       type,
  MQ_CTX const tmpl
) MK_ATTR_RT_INSTANCE;
 
__parser__(internal)
MQ_EXTERN void MK_DECL MqContextFree_RT (
  MK_PARSER_RT
  MQ_CTX const ctx
) MK_ATTR_RT_INSTANCE;
 
__parser__(constructor,lng-constr)
MQ_EXTERN MQ_CTX MK_DECL MqContextCreate_RT (
  MK_PARSER_RT
  MK_TYP        type    __parser__(internal,default=NULL),
  MQ_CTX const  tmpl    __parser__(default=NULL)
) MK_ATTR_RT_STATIC ;
 
__parser__(internal,constructor)
MQ_EXTERN MQ_CTX MK_DECL MqContextSetup_RT (
  MK_PARSER_RT
  MK_TYP        type    __parser__(internal,default=NULL),
  MQ_CTX const  tmpl    __parser__(default=NULL),
  MQ_CTX        *ctx_out
) MK_ATTR_RT_STATIC ;
 
 
__parser__(destructor)
MQ_EXTERN void MK_DECL MqContextDelete_RT (
  MK_PARSER_RT
  MQ_CTX ctx
) MK_ATTR_RT_INSTANCE;
 
 
__parser__pop__;
 
// MqContextC_TOR_C_API
 
// #######################################################################
// -----------------------------------------------------------------------
 
__parser__push__(doc-group=Error,doc-index=ErrorApi);
 
__parser__(error-ignore,no-static)
MQ_EXTERN enum MkErrorE MK_DECL MqContextErrorCopy_RT (
  MK_PARSER_RT
  MQ_CTXN const targetCtx  ,
  MQ_CTXN const sourceCtx
) MK_ATTR_RT_INSTANCE;
 
__parser__(error-ignore,no-static)
MQ_EXTERN enum MkErrorE MK_DECL MqContextErrorMove_RT (
  MK_PARSER_RT
  MQ_CTXN const targetCtx  ,
  MQ_CTXN const sourceCtx
) MK_ATTR_RT_INSTANCE;
 
MK_ATTR_INSTANCE
mk_inline MK_ERR MqContextErrorFORMAT (
  MQ_CTXN const fmtobj  __parser__(default=NULL)
) {
  return MkErrorFORMAT(MkOBJ(fmtobj));
} 
 
__parser__pop__;
 
// MqContextC_ErrorApi_Error_C_API
 
 
// #######################################################################
// -----------------------------------------------------------------------
 
__parser__push__(doc-group=Misc,doc-index=MiscApi);
 
MK_ATTR_INSTANCE
mk_inline MQ_CTX MqGetRoot(MQ_CTX ctx) {
  return ctx ? (MQ_IS_SLAVE(ctx) ? MqGetRoot(ctx->config.master) : MQ_GET_PARENT(ctx)) : NULL;
} 
 
__parser__(ignore)
MK_ATTR_INSTANCE
mk_inline MQ_CTXN MqGetRootN(MQ_CTXN ctx) {
  return ctx ? (MQ_IS_SLAVE(ctx) ? MqGetRoot(ctx->config.master) : MQ_GET_PARENT(ctx)) : NULL;
} 
 
MQ_EXTERN int MK_DECL MqExit_RT (
  MK_PARSER_RT
  MQ_CTX  const    ctx         __parser__(null-allowed),
  MK_STRN const    callfunc    __parser__(default=F#FUNC),
  MK_STRN const    callfile    __parser__(default=F#FILE),
  MK_I32  const    callline    __parser__(default=F#LINE)
) MK_ATTR_RT_INSTANCE;
 
__parser__(internal)
MQ_EXTERN void MK_DECL MqContextMark_RT (
  MK_PARSER_RT
  MQ_CTX const ctx
) MK_ATTR_RT_INSTANCE;
 
__parser__(hide)
MQ_EXTERN enum MkErrorE MK_DECL MqCheckForLeftOverArguments_RT (
  MK_PARSER_RT
  MQ_CTX const ctx,
  MK_BFLN args
) MK_ATTR_RT_INSTANCE;
 
MQ_EXTERN MK_BUF  MqContextGetBuffer_RT (
  MK_PARSER_RT
  MQ_CTX const ctx
) MK_ATTR_RT_INSTANCE;
 
 
MQ_EXTERN enum MkErrorE MK_DECL MqProcessEvent_RT (
  MK_PARSER_RT
  MQ_CTX const                ctx,
  enum MqWaitOnEventE const   wait      __parser__(default=MQ_WAIT_NO),
  MK_TIME_T                   timeout   __parser__(default=MK_TIMEOUT_DEFAULT)
) MK_ATTR_RT_INSTANCE;
 
// sync with: MkObjectToString
//
__parser__(class-overload=MkObjectToString)
MQ_EXTERN MK_STRN MK_DECL MqContextToString_RT (
  MK_PARSER_RT
  MQ_CTXN const  ctx
) MK_ATTR_RT_INSTANCE;
 
/*
__parser__(internal)
MQ_EXTERN bool MK_DECL MqContextCheckLock (
  MQ_CTX ctx
) MK_ATTR_INSTANCE ;
*/
 
__parser__pop__;
 
// MqContextC_MiscApi_Misc_C_API
 
// #######################################################################
// -----------------------------------------------------------------------
 
__parser__push__(doc-group=Env,doc-index=EnvApi);
 
MQ_EXTERN void MK_DECL MqEnvProtect_RT (
  MK_PARSER_RT
  MQ_CTX ctx
) MK_ATTR_RT_INSTANCE;
 
MQ_EXTERN void MK_DECL MqEnvRestore (
  MQ_CTX ctx
) MK_ATTR_INSTANCE ;
 
 
__parser__(const,ignore,class-overload=MkObjectLog)
MQ_EXTERN void MK_DECL MqEnvLog_RT (
  MK_PARSER_RT
  MQ_ENVN const env       ,
  MK_PARSER_fmtobj        ,
  MK_DBG  const debug     __parser__(default=0),
  MK_STRN const callfunc  __parser__(default=F#FUNC),
  MK_I32  const lvl       __parser__(default=0),
  MK_STRN const label     __parser__(default=S#"ENV")
) MK_ATTR_RT_INSTANCE;
 
#define MqEnvLog_0()             MqEnvLog(&(META_CONTEXT_S)->link.protect,META_CONTEXT_S,NULL,0,__func__,0,"ENV")
#define MqEnvLog_1(env)          MqEnvLog(env,NULL,NULL,0,__func__,0,"ENV")
#define MqEnvLog_2(env,fmt)      MqEnvLog(env,fmt,NULL,0,__func__,0,"ENV")
#define MqEnvLog_3(env,fmt,lbl)  MqEnvLog(env,fmt,lbl,0,__func__,0,"ENV")
 
 
__parser__pop__;
 
// MqContextC_EnvApi_Env_C_API
 
// #######################################################################
// -----------------------------------------------------------------------
 
 
__parser__push__(doc-group=Storage,doc-index=StorageApi);
 
MQ_EXTERN enum MkErrorE MK_DECL MqStorageErrCnt_RT (
  MK_PARSER_RT
  MQ_CTX const ctx,
  MQ_LTR transLId,
  MK_I32 *cnt_out
) MK_ATTR_RT_INSTANCE;
 
MQ_EXTERN enum MkErrorE MK_DECL MqStorageOpen_RT (
  MK_PARSER_RT
  MQ_CTX const ctx,
  MK_STRN const storageFile
) MK_ATTR_RT_INSTANCE;
 
MQ_EXTERN enum MkErrorE MK_DECL MqStorageClose_RT (
  MK_PARSER_RT
  MQ_CTX const ctx
) MK_ATTR_RT_INSTANCE;
 
MQ_EXTERN enum MkErrorE MK_DECL MqStorageExport_RT (
  MK_PARSER_RT
  MQ_CTX const ctx,
  MQ_LTR *ltid_out
) MK_ATTR_RT_INSTANCE;
 
MQ_EXTERN enum MkErrorE MK_DECL MqStorageImport_RT (
  MK_PARSER_RT
  MQ_CTX const ctx,
  MQ_LTR *transLIdP_inout   __parser__(default=0)
) MK_ATTR_RT_INSTANCE;
 
MQ_EXTERN enum MkErrorE MK_DECL MqStorageIncrRef_RT (
  MK_PARSER_RT
  MQ_CTX const ctx,
  MQ_LTR transLId
) MK_ATTR_RT_INSTANCE;
 
MQ_EXTERN enum MkErrorE MK_DECL MqStorageDecrRef_RT (
  MK_PARSER_RT
  MQ_CTX const ctx,
  MQ_LTR transLId
) MK_ATTR_RT_INSTANCE;
 
MQ_EXTERN enum MkErrorE MK_DECL MqStorageDelete_RT (
  MK_PARSER_RT
  MQ_CTX const ctx,
  MQ_LTR *transLIdP_inout     __parser__(default=0)
) MK_ATTR_RT_INSTANCE;
 
MQ_EXTERN enum MkErrorE MK_DECL MqStorageCount_RT (
  MK_PARSER_RT
  MQ_CTX const ctx,
  MQ_LTR *cnt_out
) MK_ATTR_RT_INSTANCE;
 
 
MQ_EXTERN enum MkErrorE MK_DECL MqStorageLog_RT (
  MK_PARSER_RT
  MQ_CTX const  ctx,
  MK_STRN const  callfunc    __parser__(default=F#FUNC)
) MK_ATTR_RT_INSTANCE;
 
#define MqStorageLog_1(ctx) MqStorageLog(ctx,__func__)
 
 
__parser__(no-rpc)
MQ_EXTERN enum MkErrorE MK_DECL MqStorageResolve_RT (
  MK_PARSER_RT
  MQ_CTX const  ctx,
  MQ_CTX        *otherCtxP_out,
  MQ_LTR        *otherLIdP_out
) MK_ATTR_RT_INSTANCE;
 
__parser__pop__;
 
// MqContextC_StorageApi_Storage_C_API
 
// #######################################################################
// -----------------------------------------------------------------------
__parser__push__(doc-group=Link,doc-index=LinkApi);
 
MQ_EXTERN enum MkErrorE MK_DECL MqLinkCreate_RT (
  MK_PARSER_RT
  MQ_CTX const ctx,
  MK_BAC args           __parser__(default=NULL)
) MK_ATTR_RT_INSTANCE;
 
MQ_EXTERN enum MkErrorE MK_DECL MqLinkConnect_RT (
  MK_PARSER_RT
  MQ_CTX const ctx
) MK_ATTR_RT_INSTANCE;
 
MQ_EXTERN enum MkErrorE MK_DECL MqLinkShutdown_RT (
  MK_PARSER_RT
  MQ_CTX const ctx
) MK_ATTR_RT_INSTANCE;
 
MQ_EXTERN enum MkErrorE MK_DECL MqLinkCreateChild_RT (
  MK_PARSER_RT
  MQ_CTX  const ctx,
  MQ_CTX  const parent,
  MK_BAC  const args       __parser__(default=NULL)
) MK_ATTR_RT_INSTANCE;
 
__parser__(hide,overload-c-no)
MQ_EXTERN enum MkErrorE MK_DECL MqLinkDefault_RT (
  MK_PARSER_RT
  MQ_CTX  const   ctx,
  MK_BAC  const   args      __parser__(default=NULL)
) MK_ATTR_RT_INSTANCE;
 
MQ_EXTERN void MK_DECL MqLinkDelete_RT (
  MK_PARSER_RT
  MQ_CTX const ctx
) MK_ATTR_RT_INSTANCE;
 
MQ_EXTERN bool MK_DECL MqLinkIsConnected (
  MQ_CTX const ctx
) MK_ATTR_INSTANCE ;
 
MK_ATTR_INSTANCE
mk_inline MQ_CTX MqLinkGetParent ( MQ_CTX const ctx) {
  // BUF FIX: result always a context id "ctx" is valid
  // test:  Nhi1Exec lcconfig.test --block-2 --fast-testing --lang-tcl -verbose e 
  //          -match lcconfig-2-5-* --num "1 3 1" --com-uds
  //        RPC send "object-delete-message" on server-parent-context which can be
  //          a client-child. The MqLinkGetParent is used to resolve this
  // file:  LibLcConfigRpcClient.tcl
  return ctx ? MQ_GET_PARENT(ctx) : NULL;
} 
 
MK_ATTR_INSTANCE
mk_inline bool MqLinkIsParent ( MQ_CTX const ctx) {
  return ctx ? MQ_IS_PARENT(ctx) : false;
} 
 
MK_ATTR_INSTANCE
mk_inline MK_NUM MqLinkGetCtxId ( MQ_CTX const ctx) {
  return ctx ? ctx->link.ctxId : 0;
} 
 
MK_ATTR_INSTANCE
mk_inline MK_STRN MqLinkGetTargetIdent ( MQ_CTX const ctx) {
  return ctx && ctx->link.ctxIdP ? ctx->link.ctxIdP->link.targetIdent : "";
} 
 
__parser__pop__;
 
// MqContextC_LinkApi_Link_C_API
 
 
// #######################################################################
// -----------------------------------------------------------------------
 
__parser__push__(doc-group=Route,doc-index=RouteApi);
 
MQ_EXTERN enum MkErrorE MK_DECL MqRouteCreate_RT (
  MK_PARSER_RT
  MQ_CTX  ctx,
  MK_STRN route,
  MK_STRN service,
  bool    overwrite             __parser__(default=false)
) MK_ATTR_RT_INSTANCE;
 
MQ_EXTERN enum MkErrorE MK_DECL MqRouteDelete_RT (
  MK_PARSER_RT
  MQ_CTX  ctx,
  MK_STRN route,
  MK_STRN service,
  bool    overwrite             __parser__(default=false)
) MK_ATTR_RT_INSTANCE;
 
MQ_EXTERN enum MkErrorE MK_DECL MqRouteTraverse_RT (
  MK_PARSER_RT
  MQ_CTX  ctx,
  MK_STRN service,
  MK_BAC  args                  __parser__(default=NULL)
) MK_ATTR_RT_INSTANCE;
 
#define MQ_ROUTE_CTX_MAX 50
 
 
MQ_EXTERN MQ_CTX_A MK_DECL MqRouteResolve_RT (
  MK_PARSER_RT
  MQ_CTX  const  ctx,
  MK_STRN const  ident,
  MK_NUM  const  retnum  __parser__(default=-1)
) MK_ATTR_RT_INSTANCE;
 
MQ_EXTERN enum MkErrorE MK_DECL MqRouteGetPath_RT (
  MK_PARSER_RT
  MQ_CTX const  ctx,
  MK_STRN *      path_out
) MK_ATTR_RT_INSTANCE;
 
MQ_EXTERN enum MkErrorE MK_DECL MqRouteGetTree_RT (
  MK_PARSER_RT
  MQ_CTX const  ctx,
  MK_BFL        *treeP_out
) MK_ATTR_RT_INSTANCE;
 
__parser__pop__;
 
// MqContextC_RouteApi_Route_C_API
 
 
// #######################################################################
// -----------------------------------------------------------------------
 
__parser__push__(doc-group=Service,doc-index=ServiceApi);
 
__parser__(type=ME_PSN_MQ_TOKEN:"token identifer") 
typedef MK_STRN MQ_TOK;
 
#define MQ_TOK_SIZE (8+1)
 
// [MqServiceCallbackF]
typedef MqTokenF MqServiceCallbackF;
// [MqServiceCallbackF]
 
MK_ATTR_INSTANCE
mk_inline bool MqServiceIsTransaction (
  MQ_CTX const ctx
) {
  MK_INSTANCE_HDL(ctx);
  return (ctx->link.protect.transSId != 0);
} 
 
MQ_EXTERN MQ_TOK MK_DECL MqServiceTokenGet (
  MQ_CTX const ctx
) MK_ATTR_INSTANCE ;
 
MQ_EXTERN bool MK_DECL MqServiceTokenCheck (
  MQ_CTX const ctx,
  MQ_TOK const token
) MK_ATTR_INSTANCE ;
 
MQ_EXTERN bool MK_DECL MqServiceTokenExists (
  MQ_CTX const ctx,
  MQ_TOK const token
) MK_ATTR_INSTANCE ;
 
__parser__(no-rpc,callback-name=Service)
MQ_EXTERN enum MkErrorE MK_DECL MqServiceCreate_RT (
  MK_PARSER_RT
  MQ_CTX const              ctx,
  MQ_TOK const              token,
  MqServiceCallbackF const  fCall     __parser__(callback-call),
  MK_CBP                    callback  __parser__(callback-data),
  MqDataFreeF               fFree     __parser__(callback-free),
  MkMarkF                   fMark     __parser__(internal,default=NULL)
) MK_ATTR_RT_INSTANCE;
 
// \anchor \NS{StorageService}
MQ_EXTERN enum MkErrorE MK_DECL MqServiceStorage_RT (
  MK_PARSER_RT
  MQ_CTX const        ctx,
  MQ_TOK const        token
) MK_ATTR_RT_INSTANCE;
 
MQ_EXTERN enum MkErrorE MK_DECL MqServiceDelete_RT (
  MK_PARSER_RT
  MQ_CTX const        ctx,
  MQ_TOK const        token
) MK_ATTR_RT_INSTANCE;
 
 
MQ_EXTERN enum MkErrorE MK_DECL MqServiceProxy_RT (
  MK_PARSER_RT
  MQ_CTX const        ctx,
  MQ_TOK const        token,
  MQ_SLAVE_ID const   id      __parser__(default=MQ_SLAVE_OTHER)
) MK_ATTR_RT_INSTANCE;
 
MQ_EXTERN enum MkErrorE MK_DECL MqServiceProxyCtx_RT (
  MK_PARSER_RT
  MQ_CTX const        ctx,
  MQ_TOK const        token,
  MQ_CTX const        target
) MK_ATTR_RT_INSTANCE;
 
MQ_EXTERN enum MkErrorE MK_DECL MqServiceProxyRoundRobin_RT (
  MK_PARSER_RT
  MQ_CTX const        ctx,
  MQ_TOK const        token,
  MK_STRN const       ident
) MK_ATTR_RT_INSTANCE;
 
MQ_EXTERN bool MK_DECL MqServiceProxyCtxExists (
  MQ_CTX const        ctx,
  MQ_TOK const        token,
  MQ_CTX const        target
) MK_ATTR_INSTANCE;
 
// MqServiceProxy
 
__parser__pop__;
 
// MqContextC_ServiceApi_Service_C_API
 
// #######################################################################
// -----------------------------------------------------------------------
// MqContextC_ReadApi_C_API
 
// #######################################################################
// -----------------------------------------------------------------------
 
__parser__push__(doc-group=Block,doc-index=ReadApi);
 
MQ_EXTERN enum MkErrorE MK_DECL MqReadL_START_RT (
  MK_PARSER_RT
  MQ_CTX const    ctx,
  MK_BUF          buf     __parser__(default=NULL)
) MK_ATTR_RT_INSTANCE;
 
MQ_EXTERN enum MkErrorE MK_DECL MqReadL_END_RT (
  MK_PARSER_RT
  MQ_CTX const    ctx
) MK_ATTR_RT_INSTANCE;
 
MQ_EXTERN enum MkErrorE MK_DECL MqReadT_START_RT (
  MK_PARSER_RT
  MQ_CTX const ctx
) MK_ATTR_RT_INSTANCE;
 
MQ_EXTERN enum MkErrorE MK_DECL MqReadT_END_RT (
  MK_PARSER_RT
  MQ_CTX const ctx
) MK_ATTR_RT_INSTANCE;
 
__parser__pop__;
 
// MqContextC_ReadApi_Block_C_API
 
// #######################################################################
// -----------------------------------------------------------------------
 
__parser__push__(doc-group=Atom,doc-index=ReadApi);
 
MQ_EXTERN enum MkErrorE MK_DECL MqReadI8_RT (
  MK_PARSER_RT
  MQ_CTX const ctx,
  MK_I8 * const val_out
) MK_ATTR_RT_INSTANCE;
 
MQ_EXTERN enum MkErrorE MK_DECL MqReadBOL_RT (
  MK_PARSER_RT
  MQ_CTX const ctx,
  MK_BOL * const val_out
) MK_ATTR_RT_INSTANCE;
 
MQ_EXTERN enum MkErrorE MK_DECL MqReadI16_RT (
  MK_PARSER_RT
  MQ_CTX const ctx,
  MK_I16 * const val_out
) MK_ATTR_RT_INSTANCE;
 
MQ_EXTERN enum MkErrorE MK_DECL MqReadI32_RT (
  MK_PARSER_RT
  MQ_CTX const ctx,
  MK_I32 * const val_out
) MK_ATTR_RT_INSTANCE;
 
MQ_EXTERN enum MkErrorE MK_DECL MqReadFLT_RT (
  MK_PARSER_RT
  MQ_CTX const ctx,
  MK_FLT * const val_out
) MK_ATTR_RT_INSTANCE;
 
MQ_EXTERN enum MkErrorE MK_DECL MqReadI64_RT (
  MK_PARSER_RT
  MQ_CTX const ctx,
  MK_I64 * const val_out
) MK_ATTR_RT_INSTANCE;
 
MQ_EXTERN enum MkErrorE MK_DECL MqReadDBL_RT (
  MK_PARSER_RT
  MQ_CTX const ctx,
  MK_DBL * const val_out
) MK_ATTR_RT_INSTANCE;
 
MQ_EXTERN enum MkErrorE MK_DECL MqReadBUF_RT (
  MK_PARSER_RT
  MQ_CTX const ctx,
  MK_BUF* const val_out
) MK_ATTR_RT_INSTANCE;
 
MQ_EXTERN enum MkErrorE MK_DECL MqReadBFL_RT (
  MK_PARSER_RT
  MQ_CTX const ctx,
  MK_BFL* const val_out
) MK_ATTR_RT_INSTANCE;
 
MQ_EXTERN enum MkErrorE MK_DECL MqReadALL_RT (
  MK_PARSER_RT
  MQ_CTX const ctx,
  MK_BFL* const val_inout 
) MK_ATTR_RT_INSTANCE;
 
__parser__(template-required,no-rpc,keep,no-static)
MQ_EXTERN enum MkErrorE MK_DECL MqReadLIST_RT (
  MK_PARSER_RT
  MQ_CTX const ctx,
  MK_NAT_LIST* const val_out
) MK_ATTR_RT_INSTANCE;
 
__parser__(template-required,no-rpc,keep,no-static)
MQ_EXTERN enum MkErrorE MK_DECL MqReadNEXT_RT (
  MK_PARSER_RT
  MQ_CTX const ctx,
  MK_NAT_OBJECT* const val_out
) MK_ATTR_RT_INSTANCE;
 
MQ_EXTERN enum MkErrorE MK_DECL MqReadLONG_RT (
  MK_PARSER_RT
  MQ_CTX const ctx,
  MK_LONG* const val_out
) MK_ATTR_RT_INSTANCE;
 
MQ_EXTERN enum MkErrorE MK_DECL MqReadHDL_RT (
  MK_PARSER_RT
  MQ_CTX const ctx,
  MK_HDL* const val_out
) MK_ATTR_RT_INSTANCE;
 
MQ_EXTERN enum MkErrorE MK_DECL MqReadSTR_RT (
  MK_PARSER_RT
  MQ_CTX const ctx,
  MK_STRN * const val_out
) MK_ATTR_RT_INSTANCE;
 
MQ_EXTERN enum MkErrorE MK_DECL MqReadBIN_RT (
  MK_PARSER_RT
  MQ_CTX const ctx,
  MkBinaryR * const val_out
) MK_ATTR_RT_INSTANCE;
 
MQ_EXTERN enum MkErrorE MK_DECL MqReadStringR_RT (
  MK_PARSER_RT
  MQ_CTX const ctx,
  MkStringR * const val_out
) MK_ATTR_RT_INSTANCE;
 
MQ_EXTERN enum MkErrorE MK_DECL MqReadBinaryR_RT (
  MK_PARSER_RT
  MQ_CTX const ctx,
  MkBinaryR * const val_out
) MK_ATTR_RT_INSTANCE;
 
__parser__pop__;
 
// MqContextC_ReadApi_Atom_C_API
 
// #######################################################################
// -----------------------------------------------------------------------
 
__parser__push__(doc-group=Misc,doc-index=ReadApi);
 
__parser__(doc-no)
MQ_EXTERN void MK_DECL MqReadDbg_RT (
  MK_PARSER_RT
  MQ_CTX const ctx
) MK_ATTR_RT_INSTANCE;
 
MQ_EXTERN enum MkErrorE MK_DECL MqReadUndo_RT (
  MK_PARSER_RT
  MQ_CTX const ctx
) MK_ATTR_RT_INSTANCE;
 
MQ_EXTERN MK_NUM MK_DECL MqReadGetNumItems (
  MQ_CTX const ctx
) MK_ATTR_INSTANCE ;
 
MQ_EXTERN enum MkTypeE MK_DECL MqReadGetNextType (
  MQ_CTX const ctx
) MK_ATTR_INSTANCE ;
 
MQ_EXTERN bool MK_DECL MqReadItemExists (
  MQ_CTX const ctx
) MK_ATTR_INSTANCE ;
 
__parser__(internal)
MQ_EXTERN enum MqTransTypeE MK_DECL MqReadGetTransType (
  MQ_CTX const ctx
) MK_ATTR_INSTANCE ;
 
__parser__(internal)
MQ_EXTERN enum MqHandShakeE MK_DECL MqReadGetHandShake (
  MQ_CTX const ctx
) MK_ATTR_INSTANCE ;
 
__parser__pop__;
 
// MqContextC_ReadApi_Misc_C_API
 
// #######################################################################
// -----------------------------------------------------------------------
 
__parser__push__(doc-group=Proxy,doc-index=ProxyApi);
 
MQ_EXTERN enum MkErrorE MK_DECL MqProxyItem_RT (
  MK_PARSER_RT
  MQ_CTX const sourceCtx,
  MQ_CTX const targetCtx
) MK_ATTR_RT_INSTANCE;
 
__parser__(internal)
MQ_EXTERN enum MkErrorE MK_DECL MqProxyPackage_RT (
  MK_PARSER_RT
  MQ_CTX const  sourceCtx,
  MQ_CTX const  targetCtx,
  MQ_DMP const  dump        __parser__(default=NULL)
) MK_ATTR_RT_INSTANCE;
 
MQ_EXTERN enum MkErrorE MK_DECL MqProxyForward_RT (
  MK_PARSER_RT
  MQ_CTX const  sourceCtx,
  MQ_CTX const  targetCtx,
  MQ_DMP const  dump        __parser__(default=NULL),
  MK_TIME_T const timeout   __parser__(default=MK_TIMEOUT_DEFAULT)
) MK_ATTR_RT_INSTANCE;
 
__parser__pop__;
 
// MqContextC_ProxyApi_Proxy_C_API
 
// #######################################################################
// -----------------------------------------------------------------------
 
__parser__(internal,doc-no,doc-group=Atom,doc-index=SendApi)
MQ_EXTERN enum MkErrorE MK_DECL MqSendSetHandShake (
  MQ_CTX const  ctx,
  enum MqHandShakeE   handShake
) MK_ATTR_INSTANCE ;
 
// MqContextC_SendApi_C_API
 
// #######################################################################
// -----------------------------------------------------------------------
 
__parser__push__(doc-group=Atom,doc-index=SendApi);
 
MQ_EXTERN enum MkErrorE MK_DECL MqSendI8_RT (
  MK_PARSER_RT
  MQ_CTX const ctx,
  MK_I8 const val
) MK_ATTR_RT_INSTANCE;
 
MQ_EXTERN enum MkErrorE MK_DECL MqSendBOL_RT (
  MK_PARSER_RT
  MQ_CTX const ctx,
  MK_BOL const val
) MK_ATTR_RT_INSTANCE;
 
MQ_EXTERN enum MkErrorE MK_DECL MqSendI16_RT (
  MK_PARSER_RT
  MQ_CTX const ctx,
  MK_I16 const val
) MK_ATTR_RT_INSTANCE;
 
MQ_EXTERN enum MkErrorE MK_DECL MqSendI32_RT (
  MK_PARSER_RT
  MQ_CTX const ctx,
  MK_I32 const val
) MK_ATTR_RT_INSTANCE;
 
MQ_EXTERN enum MkErrorE MK_DECL MqSendFLT_RT (
  MK_PARSER_RT
  MQ_CTX const ctx,
  MK_FLT const val
) MK_ATTR_RT_INSTANCE;
 
MQ_EXTERN enum MkErrorE MK_DECL MqSendI64_RT (
  MK_PARSER_RT
  MQ_CTX const ctx,
  MK_I64 const val
) MK_ATTR_RT_INSTANCE;
 
MQ_EXTERN enum MkErrorE MK_DECL MqSendDBL_RT (
  MK_PARSER_RT
  MQ_CTX const ctx,
  MK_DBL const val
) MK_ATTR_RT_INSTANCE;
 
// \param[in] len  the string leagth of \arg{val} or \arg{-1} to calculate with \c strlen
MQ_EXTERN enum MkErrorE MK_DECL MqSendSTR_RT (
  MK_PARSER_RT
  MQ_CTX const ctx,
  MK_STRN const val
) MK_ATTR_RT_INSTANCE;
 
MQ_EXTERN enum MkErrorE MK_DECL MqSendStringR_RT (
  MK_PARSER_RT
  MQ_CTX const ctx,
  MkStringR const val
) MK_ATTR_RT_INSTANCE;
 
MQ_EXTERN enum MkErrorE MK_DECL MqSendBIN_RT (
  MK_PARSER_RT
  MQ_CTX    const ctx,
  MkBinaryR const val
) MK_ATTR_RT_INSTANCE;
 
MK_ATTR_RT_INSTANCE
mk_inline enum MkErrorE MqSendBinaryR_RT (
  MK_PARSER_RT
  MQ_CTX    const ctx,
  MkBinaryR const val
) {
  return MqSendBIN_RT(MK_RT_CALL ctx, val);
} 
 
MQ_EXTERN enum MkErrorE MK_DECL MqSendBUF_RT (
  MK_PARSER_RT
  MQ_CTX const ctx,
  MK_BUFN const val
) MK_ATTR_RT_INSTANCE;
 
MQ_EXTERN enum MkErrorE MK_DECL MqSendBFL_RT (
  MK_PARSER_RT
  MQ_CTX const ctx,
  MK_BFLN const val
) MK_ATTR_RT_INSTANCE;
 
MQ_EXTERN enum MkErrorE MK_DECL MqSendL_FLAT_RT (
  MK_PARSER_RT
  MQ_CTX const ctx,
  MK_BFLN const val
) MK_ATTR_RT_INSTANCE;
 
MQ_EXTERN enum MkErrorE MK_DECL MqSendBUS_FLAT_RT (
  MK_PARSER_RT
  MQ_CTX const ctx,
  MK_BUSN const val
) MK_ATTR_RT_INSTANCE;
 
MQ_EXTERN enum MkErrorE MK_DECL MqSendV_RT (
  MK_PARSER_RT
  MQ_CTX const ctx,
  MK_FST const printfmt,
  ...
) MK_ATTR_RT_INSTANCE MK_RT_ATTR_FORMAT_2;
 
MQ_EXTERN enum MkErrorE MK_DECL MqSendVL_RT (
  MK_PARSER_RT
  MQ_CTX const ctx,
  MK_FST const printfmt,
  va_list var_list
) MK_ATTR_RT_INSTANCE;
 
__parser__(doc-no)
MQ_EXTERN enum MkErrorE MK_DECL MqSendLTR_RT (
  MK_PARSER_RT
  MQ_CTX const ctx,
  MQ_LTR const transLId
) MK_ATTR_RT_INSTANCE;
 
MQ_EXTERN enum MkErrorE MK_DECL MqSendLONG_RT (
  MK_PARSER_RT
  MQ_CTX const ctx,
  MK_LONG const val
) MK_ATTR_RT_INSTANCE;
 
MQ_EXTERN enum MkErrorE MK_DECL MqSendHDL_RT (
  MK_PARSER_RT
  MQ_CTX const ctx,
  MK_HDL const val
) MK_ATTR_RT_INSTANCE;
 
__parser__pop__;
 
// MqContextC_SendApi_Atom_C_API
 
// #######################################################################
// -----------------------------------------------------------------------
 
__parser__push__(doc-group=Basics,doc-index=SendApi);
 
MQ_EXTERN enum MkErrorE MK_DECL MqSendEND_RT (
  MK_PARSER_RT
  MQ_CTX const    ctx,
  MQ_TOK const    token,
  MK_TIME_T       timeout     __parser__(default=MK_TIMEOUT_DEFAULT)
) MK_ATTR_RT_INSTANCE;
 
MQ_EXTERN enum MkErrorE MK_DECL MqSendSTART_RT (
  MK_PARSER_RT
  MQ_CTX const  ctx
) MK_ATTR_RT_INSTANCE;
 
MQ_EXTERN enum MkErrorE MK_DECL MqSendEND_AND_WAIT_RT (
  MK_PARSER_RT
  MQ_CTX const    ctx,
  MQ_TOK const    token,
  MK_TIME_T       timeout     __parser__(default=MK_TIMEOUT_DEFAULT)
) MK_ATTR_RT_INSTANCE;
 
 
__parser__(no-rpc)
MQ_EXTERN enum MkErrorE MK_DECL MqSendEND_AND_TRANSACTION_RT (
  MK_PARSER_RT
  MQ_CTX const  ctx,
  MQ_TOK const  token,
  MQ_TOK const  callback,
  MK_TIME_T     timeout       __parser__(default=MK_TIMEOUT_DEFAULT)
) MK_ATTR_RT_INSTANCE;
 
__parser__(no-rpc,callback-name=Service)
MQ_EXTERN enum MkErrorE MK_DECL MqSendEND_AND_SUB_RT (
  MK_PARSER_RT
  MQ_CTX const              ctx,
  MQ_TOK const              token,
  MqServiceCallbackF const  fCall       __parser__(callback-call),
  MK_CBP                    callback    __parser__(callback-data),
  MqDataFreeF               fFree       __parser__(callback-free),
  MK_TIME_T                 timeout     __parser__(default=MK_TIMEOUT_DEFAULT)
) MK_ATTR_RT_INSTANCE;
 
__parser__(no-rpc,callback-name=Service)
MQ_EXTERN enum MkErrorE MK_DECL MqSendEND_AND_CALLBACK_RT (
  MK_PARSER_RT
  MQ_CTX const              ctx,
  MQ_TOK const              token,
  MqServiceCallbackF const  fCall       __parser__(callback-call),
  MK_CBP                    callback    __parser__(callback-data),
  MqDataFreeF               fFree       __parser__(callback-free),
  MK_TIME_T const           timeout     __parser__(default=MK_TIMEOUT_DEFAULT)
) MK_ATTR_RT_INSTANCE;
 
MQ_EXTERN enum MkErrorE MK_DECL MqSendSYNC_RT (
  MK_PARSER_RT
  MQ_CTX const ctx
) MK_ATTR_RT_INSTANCE;
 
__parser__pop__;
 
// MqContextC_SendApi_Basics_C_API
 
// #######################################################################
// -----------------------------------------------------------------------
 
__parser__push__(doc-group=Return,doc-index=SendApi);
 
MQ_EXTERN enum MkErrorE MK_DECL MqSendRETURN_RT (
  MK_PARSER_RT
  MQ_CTX const ctx
) MK_ATTR_RT_INSTANCE;
 
//#define MqSendRETURN(ctx) (dbg(ctx),MqSendRETURNx(ctx))
 
MQ_EXTERN enum MkErrorE MK_DECL MqSendRETURN_SUB_RT (
  MK_PARSER_RT
  MQ_CTX const ctx
) MK_ATTR_RT_INSTANCE;
 
MQ_EXTERN enum MkErrorE MK_DECL MqSendERROR_RT (
  MK_PARSER_RT
  MQ_CTX const ctx
) MK_ATTR_RT_INSTANCE;
 
__parser__pop__;
 
// MqContextC_SendApi_Return_C_API
 
// #######################################################################
// -----------------------------------------------------------------------
 
__parser__push__(doc-group=Block,doc-index=SendApi);
 
MQ_EXTERN enum MkErrorE MK_DECL MqSendL_START_RT (
  MK_PARSER_RT
  MQ_CTX const ctx
) MK_ATTR_RT_INSTANCE;
 
MQ_EXTERN enum MkErrorE MK_DECL MqSendL_END_RT (
  MK_PARSER_RT
  MQ_CTX const ctx
) MK_ATTR_RT_INSTANCE;
 
MQ_EXTERN enum MkErrorE MK_DECL MqSendT_START_RT (
  MK_PARSER_RT
  MQ_CTX const ctx
) MK_ATTR_RT_INSTANCE;
 
MQ_EXTERN enum MkErrorE MK_DECL MqSendT_END_RT (
  MK_PARSER_RT
  MQ_CTX const ctx
) MK_ATTR_RT_INSTANCE;
 
__parser__pop__;
 
// MqContextC_SendApi_Block_C_API
 
/* ####################################################################### */
/* ###                                                                 ### */
/* ###                       S L A V E - A P I                         ### */
/* ###                                                                 ### */
/* ####################################################################### */
 
__parser__push__(doc-group=Slave,doc-index=SlaveApi);
 
MQ_EXTERN enum MkErrorE
MK_DECL MqSlaveWorker_RT (
  MK_PARSER_RT
  MQ_CTX const  ctx,
  MQ_SLAVE_ID const   id,
  MK_STRN             fct       __parser__(default=S#"WORKER"),
  MK_BAC              args      __parser__(default=NULL)
) MK_ATTR_RT_INSTANCE;
 
MQ_EXTERN enum MkErrorE
MK_DECL MqSlaveCreate_RT (
  MK_PARSER_RT
  MQ_CTX      const   ctx,
  MQ_SLAVE_ID const   id,
  MQ_CTX      const   slave
) MK_ATTR_RT_INSTANCE;
 
MQ_EXTERN enum MkErrorE
MK_DECL MqSlaveDelete_RT (
  MK_PARSER_RT
  MQ_CTX const  ctx,
  MQ_SLAVE_ID const   id
) MK_ATTR_RT_INSTANCE;
 
MK_ATTR_INSTANCE
mk_inline bool MqSlaveCheck ( MQ_CTXN const ctx, MQ_SLAVE_ID const id )
{
  return ctx ? id >= 0 && id < ctx->link.slave.used && ctx->link.slave.slaves[id] != NULL : false;
} 
 
MQ_EXTERN enum MkErrorE
MK_DECL MqSlaveGet_RT (
  MK_PARSER_RT
  MQ_CTX const ctx,
  MQ_SLAVE_ID const id,
  MQ_CTX* ctx_out
) MK_ATTR_RT_INSTANCE;
 
MQ_EXTERN enum MkErrorE
MK_DECL MqSlaveGetProxy_RT (
  MK_PARSER_RT
  MQ_CTX const ctx,
  MQ_SLAVE_ID const id,
  MQ_CTX* ctx_out
) MK_ATTR_RT_INSTANCE;
 
MQ_EXTERN enum MkErrorE MK_DECL MqSlaveGetFilter_RT (
  MK_PARSER_RT
  MQ_CTX const ctx,
  MQ_CTX* ctx_out
) MK_ATTR_RT_INSTANCE;
 
MK_ATTR_RT_INSTANCE
mk_inline MQ_CTX MqSlaveGetMaster ( MQ_CTX const ctx )
{
  return ctx ? (MQ_IS_MASTER(ctx) ? ctx : ctx->config.master) : NULL;
} 
 
MK_ATTR_RT_INSTANCE
mk_inline bool MqSlaveIs ( MQ_CTXN const ctx)
{
  return ctx ? (ctx->config.master != NULL) : false;
} 
 
__parser__pop__;
 
// MqContextC_SlaveApi_Slave_C_API
 
// #######################################################################
// -----------------------------------------------------------------------
 
__parser__push__(doc-group=High,doc-index=HighApi);
 
__parser__(template-required)
MQ_EXTERN enum MkErrorE MK_DECL MqSend_RT (
  MK_PARSER_RT
  MQ_CTX const   ctx   ,
  MK_STRN        cstr  ,
  ...
) MK_ATTR_RT_INSTANCE;
 
#define MQ_SEND_TRANSACTION_TOKEN_SIZE    10
#define MQ_SEND_TOKEN_SIGNATURE_SIZE      50
 
#define MqHigh_O  BOL
#define MqHigh_Y  I8
#define MqHigh_S  I16
#define MqHigh_I  I32
#define MqHigh_W  I64
#define MqHigh_H  HDL
#define MqHigh_F  FLT
#define MqHigh_D  DBL
#define MqHigh_C  STR
#define MqHigh_B  BIN
#define MqHigh_U  BUF
#define MqHigh_L  BFL
#define MqHigh_A  BAC
 
MQ_EXTERN enum MkErrorE MK_DECL MqSendVL2_RT (
  MK_PARSER_RT
  MQ_CTX const   ctx   ,
  MK_STRN        cstr  ,
  va_list        var_list
) MK_ATTR_RT_INSTANCE;
 
__parser__pop__;
 
// MqContextC_HighApi_High_C_API
 
/* ####################################################################### */
/* ###                                                                 ### */
/* ###                     F I L T E R - A P I                         ### */
/* ###                                                                 ### */
/* ####################################################################### */
 
/* ####################################################################### */
/* ###                                                                 ### */
/* ###                      C L A S S - A P I                          ### */
/* ###                                                                 ### */
/* ####################################################################### */
 
 
__parser__push__(doc-group=Class,doc-index=ClassApi);
 
MQ_EXTERN MQ_FCT const MK_DECL MqClassFactoryGet (
  MQ_CTXN const ctx
) MK_ATTR_INSTANCE ;
 
MQ_EXTERN enum MkErrorE MK_DECL MqClassFactorySet_RT (
  MK_PARSER_RT
  MQ_CTX const ctx,
  MQ_FCT const item
) MK_ATTR_RT_INSTANCE;
 
MQ_EXTERN enum MkErrorE MK_DECL MqClassIdentSet_RT (
  MK_PARSER_RT
  MQ_CTX const ctx,
  MK_STRN ident
) MK_ATTR_RT_INSTANCE;
 
MQ_EXTERN MK_STRN MK_DECL MqClassIdentGet (
  MQ_CTXN const ctx
) MK_ATTR_INSTANCE ;
 
MQ_EXTERN MK_STRN MK_DECL MqClassOriginalIdentGet (
  MQ_CTXN const ctx
) MK_ATTR_INSTANCE ;
 
__parser__pop__;
 
// MqContextC_ClassApi_Class_C_API
 
// #######################################################################
// only - inline ---------------------------------------------------------
 
__parser__push__(doc-group=Get,doc-index=ConfigApi);
 
MK_ATTR_INSTANCE
mk_inline bool MK_DECL MqConfigGetIsServer (
  MQ_CTX const ctx
) {
  MK_INSTANCE_HDL(ctx);
  return MQ_IS_SERVER(ctx);
} 
 
MK_ATTR_INSTANCE
mk_inline enum MqIdentE MqConfigGetIdentFrom (
  MQ_CTX const ctx
) {
  MK_INSTANCE_HDL(ctx);
  return ctx->config.identFrom;
} 
 
MK_ATTR_INSTANCE
mk_inline bool MqConfigGetIsParent (
  MQ_CTX const ctx
) {
  MK_INSTANCE_HDL(ctx);
  return MQ_IS_PARENT(ctx);
} 
 
MK_ATTR_INSTANCE
mk_inline bool MqConfigGetIsString (
  MQ_CTX const ctx
) {
  MK_INSTANCE_HDL(ctx);
  return (ctx->config.native == MK_NATIVE_IS_STRING);
} 
 
MK_ATTR_INSTANCE
mk_inline MK_STRN MqConfigGetName (
  MQ_CTXN const ctx
) {
  MK_INSTANCE_HDL(ctx);
  return MkSysStringGetNoNULL((ctx)->config.dispName);
} 
 
MK_ATTR_INSTANCE
mk_inline MK_STRN MqConfigGetPrefix (
  MQ_CTXN const ctx
) {
  MK_INSTANCE_HDL(ctx);
  return MkSysStringGetNoNULL((ctx)->config.dispPrefix);
} 
 
MK_ATTR_INSTANCE
mk_inline MK_STRN MqConfigGetPostfix (
  MQ_CTXN const ctx
) {
  MK_INSTANCE_HDL(ctx);
  return MkSysStringGetNoNULL((ctx)->config.dispPostfix);
} 
 
MK_ATTR_INSTANCE
mk_inline MK_STRN MqConfigGetStorage (
  MQ_CTXN const ctx
) {
  MK_INSTANCE_HDL(ctx);
  return MkSysStringGetNoNULL((ctx)->config.storageFile);
} 
 
MK_ATTR_INSTANCE
mk_inline MK_I32 MqConfigGetBuffersize (
  MQ_CTXN const ctx
) {
  MK_INSTANCE_HDL(ctx);
  return (ctx)->config.io.buffersize;
} 
 
MK_ATTR_INSTANCE
mk_inline MK_I32 MqConfigGetPkgsize (
  MQ_CTXN const ctx
) {
  MK_INSTANCE_HDL(ctx);
  return (ctx)->config.io.pkgsize;
} 
 
MK_ATTR_INSTANCE
mk_inline MK_TIME_T MqConfigGetTimeout (
  MQ_CTXN const ctx
) {
  MK_INSTANCE_HDL(ctx);
  return (ctx)->config.io.timeout;
} 
 
MK_ATTR_INSTANCE
mk_inline MK_STRN MqConfigGetIoUds (
  MQ_CTXN const ctx
) {
  MK_INSTANCE_HDL(ctx);
  return MkSysStringGetNoNULL(ctx->config.io.uds.file);
} 
 
__parser__(no-rpc)
MQ_EXTERN enum MkErrorE
MK_DECL MqConfigGetIoTcp (
  MQ_CTX const ctx,
  MK_STRN *host_out,
  MK_STRN *port_out,
  MK_STRN *myhost_out,
  MK_STRN *myport_out
) MK_ATTR_INSTANCE ;
 
__parser__(no-type-extension)
MQ_EXTERN enum MkErrorE
MK_DECL MqConfigGetIoTcpL_RT (
  MK_PARSER_RT
  MQ_CTX const ctx,
  MK_BFL *vals_out
) MK_ATTR_RT_INSTANCE ;
 
MK_ATTR_INSTANCE
mk_inline MQ_SOCK_HDL MqConfigGetIoPipe (
  MQ_CTX const ctx
) {
  MK_INSTANCE_HDL(ctx);
  return ctx->config.io.pipe.hdl;
} 
 
MK_ATTR_INSTANCE
mk_inline enum MqStartE MqConfigGetStartAs (
  MQ_CTX const ctx
) {
  MK_INSTANCE_HDL(ctx);
  return ctx->config.startAs;
} 
 
MK_ATTR_INSTANCE
mk_inline enum MqStatusIsEF MqConfigGetStatusIs (
  MQ_CTX const ctx
) {
  MK_INSTANCE_HDL(ctx);
  return ctx->statusIs;
} 
 
__parser__(internal)
MQ_EXTERN config_t * MK_DECL MqConfigGetConfigFile (
  MQ_CTX const ctx
) MK_ATTR_INSTANCE ;
 
__parser__(internal)
MQ_EXTERN config_setting_t * MK_DECL MqConfigGetConfigRoot (
  MQ_CTX const ctx
) MK_ATTR_INSTANCE ;
 
MQ_EXTERN enum MkErrorE MK_DECL MqConfigSetConfigFile_RT (
  MK_PARSER_RT
  MQ_CTX const ctx,
  MK_STRN const filename
) MK_ATTR_RT_INSTANCE;
 
__parser__pop__;
 
// MqContextC_ConfigApi_Get_C_API
 
/* ####################################################################### */
/* ###                                                                 ### */
/* ###                        D U M P - A P I                          ### */
/* ###                                                                 ### */
/* ####################################################################### */
 
 
#if defined(MQ_C_BUILD_DLL)
 
  #define   META_SECTION_DEFINE
  #include "MqDumpS_mq.h"
  #undef    META_SECTION_DEFINE
 
#else
 
struct MqDumpS {
  // BEGIN-MqDumpS-super - created by 'c_Class.tcl -i NHI1_HOME/theLink/c/gen/c_mqmsgque.meta' - DO NOT change
 
  union {
    struct MkObjectS            obj;          // instance-base MkObjectS
  } super;
 
  // END-MqDumpS-super - created by 'c_Class.tcl -i NHI1_HOME/theLink/c/gen/c_mqmsgque.meta' - DO NOT change
 
  // missing PRIVATE instance attributes
  MK_BINN dummy[];
};
 
#endif
 
// BEGIN-MqDumpS-Definition - created by 'c_Class.tcl -i NHI1_HOME/theLink/c/gen/c_mqmsgque.meta' - DO NOT change
 
  __parser__push__(prefix=Class, doc-group=Define, doc-index=Class);
 
// Signature --------------------------------------------------------------
 
  #define MqDumpC_SIGNATURE              (MkObjectC_SIGNATURE ^ (14u<<10))
  #define MqDumpC_MASK                   (((1u<<22)-1)<<10)
 
 
// CompileTimeCast --------------------------------------------------------------
 
  #define MqDumpC_X2dmp(x)               (x)
  #define MqDumpC_X2obj(x)               MkOBJ(x)
 
 
// TypeDef --------------------------------------------------------------
 
  __parser__(ignore) typedef struct MqDumpS MqDumpCR;
  __parser__(ignore) typedef const struct MqDumpS MqDumpCNR;
  #define MqDumpC_T                      (&MQ_RT_REF._MqDumpC_T)
  #define MqDumpC_TT                     (MkTYP(MqDumpC_T))
  #define MqDumpST                       MqDumpC_T
  #define MqDumpSTT                      (MkTYP(MqDumpST))
  #define MqDumpC_type                   MQ_DMP
  #define MqDumpCT_X(instance)           ( (struct MkTypeDefS *) (MkOBJ_R(instance).type) )
  #define MqDumpCTT_X(instance)          (MkOBJ_R(instance).type)
  #define MqDumpCT_TT(typ)               ( (struct MkTypeDefS *) (typ) )
  #define MqDumpC_NS                     MQ
  #define MqDumpCTT                      MqDumpCTT
  #define MqDumpCT                       ( (struct MkTypeDefS *) MqDumpCTT )
 
 
// TypeCheck --------------------------------------------------------------
 
  #pragma GCC diagnostic push
  #pragma GCC diagnostic ignored "-Wattributes"
 
  __parser__(class=MqDumpC,static,hide)
  MK_ATTR_STATIC
  mk_inline bool MqDmpCheck (MK_MNGN mng) {
    return MkSanitizeCheck(MqDumpC,mng);
  }
 
  __parser__(class=MqDumpC,static,hide)
  MK_ATTR_STATIC
  mk_inline bool MqDmpCheckO (MK_OBJN obj) {
    return MkSanitizeCheckO(MqDumpC,obj);
  }
 
  #pragma GCC diagnostic pop
  #define MqDumpC_Check(mng)             MqDmpCheck(mng)
 
 
// RunTimeCast --------------------------------------------------------------
 
  __parser__(class=MqDumpC,hide,static)
  META_ATTRIBUTE_SANITIZE
  MK_ATTR_STATIC
  mk_inline MQ_DMP MqDmp(MK_MNG mng) {
    return (MqDmpCheck(mng) ? (MQ_DMP)mng : NULL);
  }
 
  __parser__(class=MqDumpC,hide,static)
  META_ATTRIBUTE_SANITIZE
  MK_ATTR_STATIC
  mk_inline MQ_DMPN MqDmpN(MK_MNGN mng) {
    return (MqDmpCheck(mng) ? (MQ_DMPN)mng : NULL);
  }
 
  #define MqDmpRaise(_dmp) if (!_MkCheckX(MqDumpC,_dmp)) { \
    MkErrorSetC_1E("'MqDumpC' hdl is NULL"); \
    goto error ; \
  }
 
  #define   MqDMP_R(x)        (*(x)).super.dmp
  #define   MqDMP(x)          (&MqDMP_R(x))
 
 
  __parser__pop__;
// MqDumpC_Class_Define_C_API
 
// END-MqDumpS-Definition - created by 'c_Class.tcl -i NHI1_HOME/theLink/c/gen/c_mqmsgque.meta' - DO NOT change
 
// =========================================================================
// BEGIN-MqDumpS-Export - created by 'c_Class.tcl -i NHI1_HOME/theLink/c/gen/c_mqmsgque.meta' - DO NOT change
 
 
 
__parser__push__(doc-group=_ignore_,doc-index=Class,doc-name=Export,class=MqDumpC);
 
__parser__(class-overload=MkObjectHandleGet)
MK_ATTR_RT_INSTANCE
mk_inline MK_HDL MK_DECL MqDumpHandleGet_RT ( 
  MK_PARSER_RT
  MQ_DMP const dmp  __parser__(null-allowed)
) {
  return MkObjectHandleGet(dmp?MkOBJ(dmp):NULL);
}
 
__parser__(flags=new)
MK_ATTR_RT_STATIC
mk_inline MQ_DMP MqDumpHandleResolve_RT (
  MK_PARSER_RT
  MK_HDL const netHdl 
) {
  return MqDmp(MkObjectHandleResolve(netHdl));
}
 
#define MqDumpHandleResolve_e(netHdl) ({ \
  MK_HDL tmpHdl=netHdl; \
  MQ_DMP tmp; \
  if (tmpHdl==0) { \
    tmp=NULL; \
  } else { \
    tmp=MqDumpHandleResolve(tmpHdl); \
    if (tmp==NULL) { \
      MkErrorSetC_1_NULL("ERROR: 'MqDumpC' handle is 'NULL'"); \
      goto error; \
    }; \
  }; \
  tmp; \
})
 
__parser__pop__;
 
// Class export & import
 
  __parser__(flags=new,doc-group=_ignore_,doc-index=Class,doc-name=Misc,class=MqDumpC,null-return-allow)
  MK_ATTR_STATIC
  mk_inline MQ_DMP MqDumpGetNull ( void ) {
    return (MQ_DMP)MK_NULL;
  }
// MqDumpC - Misc - function
 
// MqDumpC_Class_C_API
 
// END-MqDumpS-Export - created by 'c_Class.tcl -i NHI1_HOME/theLink/c/gen/c_mqmsgque.meta' - DO NOT change
 
__parser__(const,class-overload=MkObjectLog)
MQ_EXTERN void MK_DECL MqDumpLog_RT (
  MK_PARSER_RT
  MQ_DMP  const dmp       ,
  MK_PARSER_fmtobj        ,
  MK_I32  const debug     __parser__(default=0),
  MK_STRN const callfunc  __parser__(default=F#FUNC),
  MK_I32  const lvl       __parser__(default=0)
) MK_ATTR_RT_INSTANCE;
 
#define MqDumpLog_1XS(dump)  MqDumpLog(dump,0,__func__,0,MkOBJ(META_CONTEXT_S))
 
// #######################################################################
// -----------------------------------------------------------------------
 
__parser__push__(doc-group=TOR);
 
__parser__(constructor,lng-constr)
MQ_EXTERN enum MkErrorE MK_DECL MqDumpExport_RT (
  MK_PARSER_RT
  MQ_CTX const    ctx             __parser__(argument),
  MQ_DMP * const  dumpP_inout 
) MK_ATTR_RT_INSTANCE;
 
 
__parser__(constructor)
MQ_EXTERN enum MkErrorE MK_DECL MqDumpError_RT (
  MK_PARSER_RT
  MQ_CTX  const   error         __parser__(argument),
  MQ_DMP * const  dumpP_inout
) MK_ATTR_RT_INSTANCE;
 
MQ_EXTERN enum MkErrorE MK_DECL MqDumpImport_RT (
  MK_PARSER_RT
  MQ_DMP const  dump,
  MQ_CTX const  ctx
) MK_ATTR_RT_INSTANCE;
 
__parser__(constructor)
MQ_EXTERN enum MkErrorE MK_DECL MqDumpBinSet_RT (
  MK_PARSER_RT
  MkBinaryR  data,
  MQ_DMP  *dmp_out
) MK_ATTR_RT_INSTANCE;
 
MQ_EXTERN MkBinaryR MK_DECL MqDumpBinGet (
  MQ_DMPN const dump
) MK_ATTR_INSTANCE ;
 
 
__parser__(destructor)
MQ_EXTERN void MK_DECL MqDumpDelete_RT (
  MK_PARSER_RT
  MQ_DMP dmp
) MK_ATTR_INSTANCE ;
 
 
__parser__pop__;
 
// MqDumpC_TOR_C_API
 
// #######################################################################
// -----------------------------------------------------------------------
 
__parser__push__(doc-group=Misc);
 
MQ_EXTERN MK_SIZE MK_DECL MqDumpSizeGet (
  MQ_DMPN const dump
) MK_ATTR_INSTANCE ;
 
__parser__(internal)
MQ_EXTERN void MK_DECL MqDumpTransLIdSet (
  MQ_DMP const dump,
  MQ_LTR transLId
) MK_ATTR_INSTANCE ;
 
__parser__(internal)
MQ_EXTERN void MK_DECL MqDumpRmtTransLIdSet (
  MQ_DMP const dump,
  MQ_LTR rmtTransLId
) MK_ATTR_INSTANCE ;
 
__parser__(internal)
MQ_EXTERN void MK_DECL MqDumpAllocSizeSet (
  MQ_DMP const dump,
  MK_SIZE allocsize
) MK_ATTR_INSTANCE ;
 
__parser__(internal)
MQ_EXTERN MK_SIZE MK_DECL MqDumpAllocSizeGet (
  MQ_DMPN const dump
) MK_ATTR_INSTANCE ;
 
__parser__(internal)
MQ_EXTERN enum MqHandShakeE MK_DECL MqDumpHandShakeGet (
  MQ_DMPN const dump
) MK_ATTR_INSTANCE ;
 
MQ_EXTERN MK_STRN MK_DECL MqDumpTokenGet (
  MQ_DMPN const dump
) MK_ATTR_INSTANCE ;
 
__parser__pop__;
 
// MqDumpC_Misc_C_API
 
// MqDumpC_C_API
 
/* MARK_R ################################################################ */
/* ###                                                                 ### */
/* ###                   R U N T I M E - A P I                         ### */
/* ###                                                                 ### */
/* ####################################################################### */
 
__parser__global__(prefix2class:MqRuntime=MqRuntimeC);
 
 
#define MqDbgRt() mk_dbg_color_ln(MK_COLOR_PURPLE,"mkrt<%p>, MkRT<%p>, mqrt<%p>, MqRT<%p>", mkrt, MkRT, mqrt, MqRT)
 
__parser__(ignore)
MQ_EXTERN_DATA bool MqRuntimeThreadPoolUse;
 
#pragma GCC diagnostic push
#pragma GCC diagnostic ignored "-Wlto-type-mismatch"
 
#if defined(MQ_C_BUILD_DLL)
 
  #define   META_SECTION_DEFINE
  #include "MqRuntimeS_mq.h"
  #undef    META_SECTION_DEFINE
 
#else
 
__parser__(internal)
struct MqRuntimeS {
 
  // ======================================================================================
  // PUBLIC variables -> sync with MqRuntimeS_mk.h !!
 
  // by default \ref __MqRtCheckX is \e false and will be set in \RMkNs{RuntimeSetup} .
 
  // BEGIN-MqRuntimeS-super - created by 'c_Class.tcl -i NHI1_HOME/theLink/c/gen/c_mqmsgque.meta' - DO NOT change
 
  union {
    struct MkObjectS            obj;          // instance-base MkObjectS
    struct MkExtensionS         ext;          // instance-base MkExtensionS
    struct MkRtExtS             rtext;        // instance-base MkRtExtS
  } super;
 
  // END-MqRuntimeS-super - created by 'c_Class.tcl -i NHI1_HOME/theLink/c/gen/c_mqmsgque.meta' - DO NOT change
 
  // instance attributes
  struct  MqErrorS        error_mq                 ;
  MkThreadDataS           mqThreadData             ;    
 
  // ======================================================================================
  // TYPES
 
  // BEGIN-rtDef - created by 'c_Class.tcl -i NHI1_HOME/theLink/c/gen/c_mqmsgque.meta' - DO NOT change
 
  struct  MkTypeDefS       _MqErrorC_T              ;
  struct  MkTypeDefS       _MqRuntimeC_T            ;
  struct  MkTypeS          _MqTypeCtxC_TT           ;
  struct  MkTypeDefS       _MqFactoryC_T            ;
  struct  MqTypeCtxS       _MqContextC_T            ;
  struct  MkTypeDefS       _MqDumpC_T               ;
  struct  MkTypeDefS       _MqEnvC_T                ;
 
  // END-rtDef - created by 'c_Class.tcl -i NHI1_HOME/theLink/c/gen/c_mqmsgque.meta' - DO NOT change
 
  // offset calculated by "Nhi1InternalSize"
  MK_BINB private_variables[291096];
}; 
 
#endif
 
#pragma GCC diagnostic pop
 
// BEGIN-MqRuntimeS-Definition - created by 'c_Class.tcl -i NHI1_HOME/theLink/c/gen/c_mqmsgque.meta' - DO NOT change
 
  __parser__push__(prefix=Class, doc-group=Define, doc-index=Class);
 
// Signature --------------------------------------------------------------
 
  #define MqRuntimeC_SIGNATURE           (MkRtExtC_SIGNATURE ^ (1u<<3))
  #define MqRuntimeC_MASK                (((1u<<29)-1)<<3)
 
 
// CompileTimeCast --------------------------------------------------------------
 
  #define MqRuntimeC_X2rt(x)             (x)
  #define MqRuntimeC_X2rtext(x)          MkRTEXT(x)
  #define MqRuntimeC_X2ext(x)            MkEXT(x)
  #define MqRuntimeC_X2obj(x)            MkOBJ(x)
 
 
// TypeDef --------------------------------------------------------------
 
  __parser__(ignore) typedef struct MqRuntimeS MqRuntimeCR;
  __parser__(ignore) typedef const struct MqRuntimeS MqRuntimeCNR;
  #define MqRuntimeC_T                   (&MQ_RT_REF._MqRuntimeC_T)
  #define MqRuntimeC_TT                  (MkTYP(MqRuntimeC_T))
  #define MqRuntimeST                    MqRuntimeC_T
  #define MqRuntimeSTT                   (MkTYP(MqRuntimeST))
  #define MqRuntimeC_type                MQ_RT
  #define MqRuntimeCT_X(instance)        ( (struct MkTypeDefS *) (MkOBJ_R(instance).type) )
  #define MqRuntimeCTT_X(instance)       (MkOBJ_R(instance).type)
  #define MqRuntimeCT_TT(typ)            ( (struct MkTypeDefS *) (typ) )
  #define MqRuntimeC_NS                  MQ
  #define MqRuntimeCTT                   MqRuntimeCTT
  #define MqRuntimeCT                    ( (struct MkTypeDefS *) MqRuntimeCTT )
 
 
// TypeCheck --------------------------------------------------------------
 
  #pragma GCC diagnostic push
  #pragma GCC diagnostic ignored "-Wattributes"
 
  __parser__(class=MqRuntimeC,static,ignore)
  MK_ATTR_STATIC
  mk_inline bool MqRtCheck (MK_MNGN mng) {
    return MkSanitizeCheck(MqRuntimeC,mng);
  }
 
  __parser__(class=MqRuntimeC,static,ignore)
  MK_ATTR_STATIC
  mk_inline bool MqRtCheckO (MK_OBJN obj) {
    return MkSanitizeCheckO(MqRuntimeC,obj);
  }
 
  #pragma GCC diagnostic pop
  #define MqRuntimeC_Check(mng)          MqRtCheck(mng)
 
 
// RunTimeCast --------------------------------------------------------------
 
  __parser__(class=MqRuntimeC,ignore,static)
  META_ATTRIBUTE_SANITIZE
  MK_ATTR_STATIC
  mk_inline MQ_RT MqRt(MK_MNG mng) {
    return (MqRtCheck(mng) ? (MQ_RT)mng : NULL);
  }
 
  __parser__(class=MqRuntimeC,ignore,static)
  META_ATTRIBUTE_SANITIZE
  MK_ATTR_STATIC
  mk_inline MQ_RTN MqRtN(MK_MNGN mng) {
    return (MqRtCheck(mng) ? (MQ_RTN)mng : NULL);
  }
 
  #define MqRtRaise(_rt) if (!_MkCheckX(MqRuntimeC,_rt)) { \
    MkErrorSetC_1E("'MqRuntimeC' hdl is NULL"); \
    goto error ; \
  }
 
 
  __parser__pop__;
// MqRuntimeC_Class_Define_C_API
 
// END-MqRuntimeS-Definition - created by 'c_Class.tcl -i NHI1_HOME/theLink/c/gen/c_mqmsgque.meta' - DO NOT change
 
// MqRuntime_C_API
 
#define   MqRT              &MqRuntimeRLS
#if 0
  #define   MqRT_O(o)         MqRuntimeGet( MK_RT_CALL_ONLY )
  #define   MqRT_X(x)         MqRuntimeGet( MK_RT_CALL_ONLY )
  #define   MqRT_ON(o)        MqRuntimeGet( MK_RT_CALL_ONLY )
  #define   MqRT_XN(x)        MqRuntimeGet( MK_RT_CALL_ONLY )
#else
  #define   MqRT_O(o)         ((o) && (*o).objRtExt        ? (MQ_RT)(*o).objRtExt        : MqRuntimeGet( MK_RT_CALL_ONLY ))
  #define   MqRT_X(x)         ((x) && MkOBJ_R(x).objRtExt  ? (MQ_RT)MkOBJ_R(x).objRtExt  : MqRuntimeGet( MK_RT_CALL_ONLY ))
  #define   MqRT_ON(o)        (       (*o).objRtExt        ? (MQ_RT)(*o).objRtExt        : MqRuntimeGet( MK_RT_CALL_ONLY ))
  #define   MqRT_XN(x)        (       MkOBJ_R(x).objRtExt  ? (MQ_RT)MkOBJ_R(x).objRtExt  : MqRuntimeGet( MK_RT_CALL_ONLY ))
#endif
 
#if META_HAS_THREAD
  #define   MqRtSetup_O(o)          MK_RT_UNUSED MQ_RT const mqrt = MqRT_O(o)
  #define   MqRtSetup_ON(o)         MK_RT_UNUSED MQ_RT const mqrt = MqRT_ON(o)
  #define   MqRtSetup_X(x)          MK_RT_UNUSED MQ_RT const mqrt = MqRT_X(x)
  #define   MqRtSetup_XN(x)         MK_RT_UNUSED MQ_RT const mqrt = MqRT_XN(x)
  #define   MqRtSetup_RT(r)         MK_RT_UNUSED MQ_RT const mqrt = r
  #define   MqRtSetup_NULL          MK_RT_UNUSED MQ_RT const mqrt = MqRuntimeGet( MK_RT_CALL_ONLY )
 
  #define   MqRtSetup_O_RT(o)       MkRtSetup_O_RT(o)   ; MqRtSetup_O(o)
  #define   MqRtSetup_ON_RT(o)      MkRtSetup_ON_RT(o)  ; MqRtSetup_ON(o)
  #define   MqRtSetup_X_RT(x)       MkRtSetup_X_RT(x)   ; MqRtSetup_X(x)
  #define   MqRtSetup_XN_RT(x)      MkRtSetup_XN_RT(x)  ; MqRtSetup_XN(x)
  #define   MqRtSetup_NULL_RT       MkRtSetup_NULL_RT   ; MqRtSetup_NULL
 
  #undef    AllRtSetup_O
  #undef    AllRtSetup_ON
  #undef    AllRtSetup_X
  #undef    AllRtSetup_XN
  #undef    AllRtSetup_NULL
 
  #define   AllRtSetup_O(o)         MkRtSetup_O(o)    ; MqRtSetup_O(o)
  #define   AllRtSetup_ON(o)        MkRtSetup_ON(o)   ; MqRtSetup_ON(o)
  #define   AllRtSetup_X(x)         MkRtSetup_X(x)    ; MqRtSetup_X(x)
  #define   AllRtSetup_XN(x)        MkRtSetup_XN(x)   ; MqRtSetup_XN(x)
  #define   AllRtSetup_NULL         MkRtSetup_NULL    ; MqRtSetup_NULL
#else
  #define   MqRtSetup_O(o)
  #define   MqRtSetup_ON(o)
  #define   MqRtSetup_X(x)
  #define   MqRtSetup_XN(x)
  #define   MqRtSetup_RT(r)
  #define   MqRtSetup_NULL
 
  #define   MqRtSetup_O_RT(o)
  #define   MqRtSetup_ON_RT(o)
  #define   MqRtSetup_X_RT(x)
  #define   MqRtSetup_XN_RT(x)
  #define   MqRtSetup_NULL_RT
#endif
 
__parser__(ignore)
MQ_EXTERN_DATA MkThreadLocal struct MqRuntimeS MqRuntimeRLS;
 
__parser__(ignore)
MQ_EXTERN MQ_RT MK_DECL MqRuntimeSetup ( MK_RT const mkrt, MQ_RT const mqrt );
 
__parser__(ignore)
MQ_EXTERN void MK_DECL MqRuntimeCleanup ( MQ_RT_ARGS_ONLY );
 
MQ_EXTERN_DATA size_t MqRuntimeId;
 
__parser__(ignore)
mk_inline MQ_RT MqRuntimeGet ( MK_RT_ARGS_ONLY ) {
  return  MK_RT_REF.mkRtExtAry[MqRuntimeId] ? (MQ_RT)MK_RT_REF.mkRtExtAry[MqRuntimeId] :
            __MkCheckX(MqRuntimeC,&MqRuntimeRLS) ? MqRT : MqRuntimeSetup( MK_RT_PTR, MqRT );
}
 
 
__parser__(ignore,const)
MQ_EXTERN void MK_DECL MqRuntimeLog_RT (
  MK_PARSER_RT
  MQ_RTN  const mqrt       ,
  MK_PARSER_fmtobj        ,
  MK_DBG  const debug     __parser__(default=0),
  MK_STRN const callfunc  __parser__(default=F#FUNC),
  MK_I32  const lvl       __parser__(default=0)
) MK_ATTR_RT_INSTANCE;
 
#define MqRuntimeLog_2M(mqrt,m)    MqRuntimeLog_2(mqrt,MkObj(m))
 
// MqRuntimeLog
 
/* ####################################################################### */
/* ###                                                                 ### */
/* ###                   P A C K A G E - A P I                         ### */
/* ###                                                                 ### */
/* ####################################################################### */
 
// MqMsgque_C_API
 
// #######################################################################
// -----------------------------------------------------------------------
 
__parser__global__(doc-force=MqMsgque@Item);
 
// MqMsgque_Item_C_API
 
// #######################################################################
// -----------------------------------------------------------------------
__parser__global__(doc-force=MqMsgque@Main);
__parser__push__(doc-group=Main,class=MqMsgque);
 
__parser__(hide,template-required,class=MqMsgque)
MQ_EXTERN void MK_DECL MqMain (
  void * code
) MK_ATTR_INSTANCE ;
 
__parser__pop__;
 
// MqMsgque_Main_C_API
 
// #######################################################################
// -----------------------------------------------------------------------
 
__parser__push__(doc-group=Help,class=MqMsgque);
 
MQ_EXTERN MK_STR MK_DECL MqHelp (
  MK_STRN  tool
) MK_ATTR_STATIC ;
 
MQ_EXTERN MK_STR MK_DECL MqHelpMsgque (
  void
) MK_ATTR_STATIC ;
 
__parser__pop__;
 
// MqMsgque_Help_C_API
 
// #######################################################################
// -----------------------------------------------------------------------
 
__parser__push__(doc-group=Init,class=MqMsgque);
 
__parser__(ignore)
MQ_EXTERN_DATA struct MkBufferListS * MqInitArg0;
 
MQ_EXTERN MK_BFL MK_DECL MqInitResetArg0 (void) MK_ATTR_STATIC ;
 
MQ_EXTERN void MK_DECL MqInitSetArg0 (
  MK_BAC  bfl   __parser__(argument,default=NULL)
) MK_ATTR_STATIC ;
 
MQ_EXTERN void MK_DECL MqInitSetArg0VA (
  MK_STRN  arg0,
  ...
) MK_ATTR_STATIC ;
 
MQ_EXTERN void MK_DECL MqInitSetArg0VAL (
  MK_STRN  arg0,
  va_list var_list
) MK_ATTR_STATIC ;
 
MQ_EXTERN MK_BFL MK_DECL MqInitGetArg0 (
  void
) MK_ATTR_STATIC ;
 
__parser__pop__;
 
// MqMsgque_Init_C_API
 
// #######################################################################
// MARK_D ----------------------------------------------------------------
 
 
 
 
// BEGIN-Class-Doc-Order - created by 'c_Class.tcl -i NHI1_HOME/theLink/c/gen/c_mqmsgque.meta' - DO NOT change
 
// external
 
// external
 
// internal
 
// internal
 
// external
 
// internal
 
// internal
 
// END-Class-Doc-Order - created by 'c_Class.tcl -i NHI1_HOME/theLink/c/gen/c_mqmsgque.meta' - DO NOT change
 
// #######################################################################
// -----------------------------------------------------------------------
__parser__global__(doc-force=MqMsgque@Enum@local);
 
// BEGIN-Class-Introspection - created by 'c_Class.tcl -i NHI1_HOME/theLink/c/gen/c_mqmsgque.meta' - DO NOT change
 
 
__parser__push__(doc-name=Introspection,doc-index=Class,class=MqContextC,no-rpc,null-return-allow,flags=new);
 
MK_ATTR_RT_STATIC
mk_inline MQ_CTX MqContextInstances_RT( MK_PARSER_RT_ONLY ) {
  MQ_STATIC_RT;
  return (MQ_CTX)MkTypeInstances(MqContextC_TT);
}
 
MK_ATTR_INSTANCE
mk_inline MQ_CTX MqContextNext(MQ_CTX const ctx) {
  MK_INSTANCE_HDL(ctx);
  return (MQ_CTX)MqContextC_X2obj(ctx)->obj_protect.next;
}
 
MK_ATTR_INSTANCE
mk_inline MQ_CTX MqContextPrev(MQ_CTX const ctx) {
  MK_INSTANCE_HDL(ctx);
  return (MQ_CTX)MqContextC_X2obj(ctx)->obj_protect.prev;
}
 
__parser__pop__;
 
// MqContextC_Class_C_API
 
 
__parser__push__(doc-name=Introspection,doc-index=Class,class=MqDumpC,no-rpc,null-return-allow,flags=new);
 
MK_ATTR_RT_STATIC
mk_inline MQ_DMP MqDumpInstances_RT( MK_PARSER_RT_ONLY ) {
  MQ_STATIC_RT;
  return (MQ_DMP)MkTypeInstances(MqDumpC_TT);
}
 
MK_ATTR_INSTANCE
mk_inline MQ_DMP MqDumpNext(MQ_DMP const dmp) {
  MK_INSTANCE_HDL(dmp);
  return (MQ_DMP)MqDumpC_X2obj(dmp)->obj_protect.next;
}
 
MK_ATTR_INSTANCE
mk_inline MQ_DMP MqDumpPrev(MQ_DMP const dmp) {
  MK_INSTANCE_HDL(dmp);
  return (MQ_DMP)MqDumpC_X2obj(dmp)->obj_protect.prev;
}
 
__parser__pop__;
 
// MqDumpC_Class_C_API
 
 
__parser__push__(doc-name=Introspection,doc-index=Class,class=MqFactoryC,no-rpc,null-return-allow,flags=new);
 
MK_ATTR_RT_STATIC
mk_inline MQ_FCT MqFactoryInstances_RT( MK_PARSER_RT_ONLY ) {
  MQ_STATIC_RT;
  return (MQ_FCT)MkTypeInstances(MqFactoryC_TT);
}
 
MK_ATTR_INSTANCE
mk_inline MQ_FCT MqFactoryNext(MQ_FCT const fct) {
  MK_INSTANCE_HDL(fct);
  return (MQ_FCT)MqFactoryC_X2obj(fct)->obj_protect.next;
}
 
MK_ATTR_INSTANCE
mk_inline MQ_FCT MqFactoryPrev(MQ_FCT const fct) {
  MK_INSTANCE_HDL(fct);
  return (MQ_FCT)MqFactoryC_X2obj(fct)->obj_protect.prev;
}
 
__parser__pop__;
 
// MqFactoryC_Class_C_API
 
// END-Class-Introspection - created by 'c_Class.tcl -i NHI1_HOME/theLink/c/gen/c_mqmsgque.meta' - DO NOT change
 
// +++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++
 
 
__parser__push__(doc-group=Log,doc-index=LogApi);
 
MK_ATTR_INSTANCE
mk_inline MK_STRN MqLogServerOrClient (
  MQ_CTXN const ctx
) {
  MK_INSTANCE_HDL(ctx);
  return (MQ_IS_SERVER (ctx) ? "SERVER" : "CLIENT");
} 
 
MK_ATTR_INSTANCE
mk_inline MK_STRN MqLogParentOrChild (
  MQ_CTXN ctx
) {
  MK_INSTANCE_HDL(ctx);
  return (MQ_IS_PARENT (ctx) ? "PARENT" : "CHILD");
} 
 
__parser__pop__;
 
 
// end c++ save definition
END_MQ_C_DECLS
 
// vim:nowrap