theLink 10.0
Loading...
Searching...
No Matches
LibMqMsgque_mq.h File Reference
#include "LibMkKernel_mk.h"
#include "gen/msgque_overload_mq.h"
+ Include dependency graph for LibMqMsgque_mq.h:
+ This graph shows which files directly or indirectly include this file:

Go to the source code of this file.

Classes

struct  libmqmsgque::MQ_CTX_A
 array of MqContextC instances More...
 
struct  libmqmsgque::MqEnvS
 MqEnvS - the class known as env or environment is used to store the protected environment in an service-call … More...
 
struct  libmqmsgque::MqCallbackS
 used for callback function pointer management More...
 
struct  libmqmsgque::MqLinkSlaveS
 needed to "run-over-all-slaves" → example: MqRouteGetTree More...
 
struct  libmqmsgque::MqLinkS
 object responsible to manage a client/server link data More...
 
struct  libmqmsgque::MqIoUdsConfigS
 configure a context to use a uds-client-server-linkMore...
 
struct  libmqmsgque::MqIoTcpConfigS
 configure a context to use a tcp-client-server-linkMore...
 
struct  libmqmsgque::MqIoPipeConfigS
 configure a context to use a pipe-client-server-linkMore...
 
struct  libmqmsgque::MqIoLoopConfigS
 Configure a context to use a loop-client-server-link … More...
 
struct  libmqmsgque::MqIoInitConfigS
 configure a context to use a init-client-server-linkMore...
 
struct  libmqmsgque::MqLinkSetupS
 MqContextC - used to create or delete a instance to manage a linkMore...
 
struct  libmqmsgque::MqIoConfigS
 Basic configuration of a context … More...
 
struct  libmqmsgque::MqConfigS
 end-user configuration data, also available as command-line options More...
 
struct  libmqmsgque::MqSetupS
 application-programmer configuration data More...
 
struct  libmqmsgque::MqSysServerThreadMainS
 data used to initialize a new created thread … More...
 
struct  libmqmsgque::MqLalS
 Interface between libmqmsgque::MqContextS and the Operating-System … More...
 
struct  libmqmsgque::MqErrorS
 Extend the MkErrorS with ccmqmsgque specific features … More...
 
struct  libmqmsgque::MqFactoryCTorS
 interface for the constructor More...
 
struct  libmqmsgque::MqFactoryDTorS
 interface for the destructor More...
 
struct  libmqmsgque::MqFactoryS
 data used to define a factory More...
 
struct  libmqmsgque::MqTypeCtxS
 MqTypeCtxS - the instance-base for the MqContextCMore...
 
struct  libmqmsgque::MqContextS
 PUBLIC data structure for the ccmqmsgque-specific-data More...
 
struct  libmqmsgque::MqDumpS
 MqDumpC - the class known as dmp or dump is used to export a ccmqmsgque data package as binaryMore...
 
struct  libmqmsgque::MqRuntimeS
 Extend the MkRuntimeS wie ccmqmsgque specific features … More...
 

Namespaces

namespace  libmqmsgque
 

Macros

#define META_USE_GLOBAL_EVENT   0
 
#define META_BROKEN_LINK_SEND_FAIL_COUNTER   16
 
#define MQ_DEBUG_RUNTIME
 
#define MQ_INSTANCE_RT_X(x)
 
#define MQ_INSTANCE_RT_X_NULL(x)
 
#define MQ_INSTANCE_RT_O(o)
 
#define MQ_INSTANCE_RT_O_NULL(o)
 
#define MQ_DESTRUCTOR_RT_X(c, x)
 
#define MQ_STATIC_RT   MK_STATIC_RT ; MqRtSetup_NULL
 
#define BEGIN_MQ_C_DECLS   namespace libmqmsgque { using namespace libmkkernel;
 
#define END_MQ_C_DECLS   }
 
#define MQ_EXTERN
 static library
 
#define MQ_EXTERN_DATA   extern
 
#define MK_FORMAT_SOCK   "%i"
 
#define MQ_SERVICE_CALL_CHECK
 
#define MQ_SERVICE_CALL_ARGS   MK_RT_ARGS MQ_CTX const mqctx, MK_PTR const __data__
 the libmqmsgque::MqTokenF arguments with default names
 
#define MQ_SERVICE_CALL   MK_RT_CALL mqctx, __data__
 the libmqmsgque::MqTokenF arguments CALL with default names
 
#define MQ_SERVICE_FREE_ARGS   MK_RT_ARGS MQ_CTX const mqctx, MK_PTR *dataP __parser__(inout)
 the libmqmsgque::MqDataFreeF arguments with default names
 
#define MQ_SERVICE_COPY_ARGS   MK_RT_ARGS MQ_CTX const mqctx, MK_PTR *dataP __parser__(inout)
 the libmqmsgque::MqDataFreeF arguments with default names
 
#define MqLinkS_targetIdent_size   64
 MqClassIdentGet of the link target, only valid on parent-context
 
#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
 
#define MqConfigS_dispName_size   64
 
#define MqConfigS_dispPrefix_size   64
 
#define MqConfigS_dispPostfix_size   64
 
#define MqConfigS_storageFile_size   256
 storage file used as default if a database is requested
 
#define MqInterfaceDoc(mkrt, ctx, fCall, callback, fFree, fCopy)
 placeholder for interface docomentation
 
#define MqFactoryPanic(fct)
 
#define MQ_CALLBACK_FACTORY_CTOR_ARGS
 the libmqmsgque::MqFactoryCTorF arguments with default names
 
#define MQ_CALLBACK_FACTORY_CTOR_CALL   MQ_RT_CALL tmpl, create, fct, contextP
 
#define MQ_CALLBACK_FACTORY_DTOR_ARGS
 the libmqmsgque::MqFactoryCTorF arguments with default names
 
#define MqDbgFct_2(f, c)
 
#define MqDbgFct(f)
 
#define MqFactoryS_originalIdent_size   63
 
#define MqFactoryAdd_1(fct)
 
#define MqFactoryAdd_2(fct, ident)
 
#define MqFactoryAdd_3(ctor, dtor, ident)
 
#define MqTypeCtxLog_1(typ)
 
#define MQ_ROUTE_CTX_MAX   50
 maximum number of context-items in the return-array from MqRouteResolve
 
#define MQ_TOK_SIZE   (8+1)
 maximum size of the libmqmsgque::MQ_TOK
 
#define MqDumpLog_1XS(dump)
 
#define MqDbgRt()
 
#define MqRT   &MqRuntimeRLS
 
#define MqRT_O(o)
 
#define MqRT_X(x)
 
#define MqRT_ON(o)
 
#define MqRT_XN(x)
 
#define MqRtSetup_O(o)
 
#define MqRtSetup_ON(o)
 
#define MqRtSetup_X(x)
 
#define MqRtSetup_XN(x)
 
#define MqRtSetup_RT(r)
 
#define MqRtSetup_NULL   MK_RT_UNUSED MQ_RT const mqrt = MqRuntimeGet( MK_RT_CALL_ONLY )
 
#define MqRtSetup_O_RT(o)
 
#define MqRtSetup_ON_RT(o)
 
#define MqRtSetup_X_RT(x)
 
#define MqRtSetup_XN_RT(x)
 
#define MqRtSetup_NULL_RT   MkRtSetup_NULL_RT ; MqRtSetup_NULL
 
#define AllRtSetup_O(o)
 
#define AllRtSetup_ON(o)
 
#define AllRtSetup_X(x)
 
#define AllRtSetup_XN(x)
 
#define AllRtSetup_NULL   MkRtSetup_NULL ; MqRtSetup_NULL
 
definition

use the thread-enabled-api by using the META_HAS_THREAD preprocessor define

In a thread-environment (ccmqmsgque is build with thread support) every thread has its own runtime. This runtime is created as T)hread-L)ocal-S)torage (TLS) and is available using the MkRt call. Using the MkRt call is an expensive task, because it is a function-call. Multiple usage of MkRt create multiple function-calls and this is expensive.

To speed this up, two additional technologies are available: #1 the runtime is saved into the object of an instance at obj->runtime #1 instance->path.to.obj.runtime // this is typesafe #2 the runtime is added as first parameter (called "mkrt") to the callback call #1 example: callback( MQ_SERVICE_CALL_ARGS )

If ccmqmsgque was not build with thread support than the API changes #1 the first argument "mkrt" is missing #2 the MkRt is always the fastest access to the runtime.

To join the two different styles (with/without thread) into one API the MQ_RT_* style macros are available. The most important one is the MQ_RT_REF. The MQ_RT_REF always return a reference (not a pointer) to the runtime. The access-qualifier for a reference is "." and for a pointer is "->".

  • MQ_RT_REF = reference, &MQ_RT_REF = pointer
#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)
 
MqEnvC - signature define
#define MqEnvC_SIGNATURE   (MkObjectC_SIGNATURE ^ (15u<<10))
 
#define MqEnvC_MASK   (((1u<<22)-1)<<10)
 
MqEnvC - cast to superclass
#define MqEnvC_X2env(x)
 
#define MqEnvC_X2obj(x)
 
#define MQ_IS_SERVER(ctx)
 extract boolean information from context
 
#define MQ_IS_SERVER_PARENT(ctx)
 
#define MQ_IS_CLIENT(ctx)
 
#define MQ_IS_CLIENT_PARENT(ctx)
 
#define MQ_IS_CHILD(ctx)
 
#define MQ_IS_PARENT(ctx)
 
#define MQ_IS_SLAVE(ctx)
 
#define MQ_IS_MASTER(ctx)
 
#define MQ_IS_LOOPBACK(ctx)
 
#define MQ_GET_PARENT(ctx)
 
#define MQ_GET_MASTER(ctx)
 
#define MQ_IS_ON_EXIT(ctx)
 
MqErrorC - signature define
#define MqErrorC_SIGNATURE   (MkErrExtC_SIGNATURE ^ (1u<<3))
 
#define MqErrorC_MASK   (((1u<<29)-1)<<3)
 
MqErrorC - cast to superclass
#define MqErrorC_X2err(x)
 
#define MqErrorC_X2errext(x)
 
#define MqErrorC_X2ext(x)
 
#define MqErrorC_X2obj(x)
 
access the predefined error from \ref doc_mk_cc_MkRuntimeC
#define MqERROR_R(r)
 
#define MqERROR_RT   MqERROR_R(&MQ_RT_REF)
 
#define MqERROR_O(o)
 
#define MqERROR_X(x)
 
#define MqERROR_XN(x)
 
#define MqERROR   MqERROR_R(&MqRuntimeRLS)
 
MqFactoryC - signature define
#define MqFactoryC_SIGNATURE   (MkObjectC_SIGNATURE ^ (12u<<10))
 
#define MqFactoryC_MASK   (((1u<<22)-1)<<10)
 
MqFactoryC - cast to superclass
#define MqFactoryC_X2fct(x)
 
#define MqFactoryC_X2obj(x)
 
MqTypeCtxC - signature define
#define MqTypeCtxC_SIGNATURE   (MkTypeC_SIGNATURE ^ (2u<<6))
 
#define MqTypeCtxC_MASK   (((1u<<26)-1)<<6)
 
MqTypeCtxC - cast to superclass
#define MqTypeCtxC_X2ctxtyp(x)
 
#define MqTypeCtxC_X2typ(x)
 
#define MqTypeCtxC_X2obj(x)
 
MqContextC - signature define
#define MqContextC_SIGNATURE   (MkObjectC_SIGNATURE ^ (13u<<10))
 
#define MqContextC_MASK   (((1u<<22)-1)<<10)
 
MqContextC - cast to superclass
#define MqContextC_X2ctx(x)
 
#define MqContextC_X2obj(x)
 
MqContextC - MqContextC_StorageApi_Storage_C_API - overload
#define MqStorageLog_1(ctx)
 
size of internal buffer to store strings for \e MqSend
#define MQ_SEND_TRANSACTION_TOKEN_SIZE   10
 
#define MQ_SEND_TOKEN_SIGNATURE_SIZE   50
 
type cast \e short to \e long
#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
 
MqDumpC - signature define
#define MqDumpC_SIGNATURE   (MkObjectC_SIGNATURE ^ (14u<<10))
 
#define MqDumpC_MASK   (((1u<<22)-1)<<10)
 
MqDumpC - cast to superclass
#define MqDumpC_X2dmp(x)
 
#define MqDumpC_X2obj(x)
 
MqRuntimeC - signature define
#define MqRuntimeC_SIGNATURE   (MkRtExtC_SIGNATURE ^ (1u<<3))
 
#define MqRuntimeC_MASK   (((1u<<29)-1)<<3)
 
MqRuntimeC - cast to superclass
#define MqRuntimeC_X2rt(x)
 
#define MqRuntimeC_X2rtext(x)
 
#define MqRuntimeC_X2ext(x)
 
#define MqRuntimeC_X2obj(x)
 

Typedefs

typedef struct config_t libmqmsgque::config_t
 libconfig struct
 
typedef struct config_setting_t libmqmsgque::config_setting_t
 libconfig struct
 
typedef int libmqmsgque::MQ_LTR
 32bit longterm transaction token because PHP-32 does NOT support long long
 
typedef int libmqmsgque::MQ_ROU
 32bit routing token because PHP-32 does NOT support long long
 
typedef MK_NUM libmqmsgque::MQ_SLAVE_ID
 a slave identiver
 
typedef int libmqmsgque::MQ_HDL
 handle data-type
 
typedef struct MqErrorSlibmqmsgque::MQ_ERR
 class-shortcut for struct MqErrorS *, all shortcut using the XX_YYY syntax (only for public API) …
 
typedef const struct MqErrorSlibmqmsgque::MQ_ERRN
 class-shortcut for const struct MqErrorS *, all const shortcut using the XX_YYYC syntax (only for public API) …
 
typedef struct MqErrorS libmqmsgque::MQ_ERRR
 reference-shortcut for struct MqErrorS, all shortcut using the XX_YYYR syntax (only for public API) …
 
typedef struct MqRuntimeSlibmqmsgque::MQ_RT
 class-shortcut for struct MqRuntimeS *, all shortcut using the XX_YYY syntax (only for public API) …
 
typedef const struct MqRuntimeSlibmqmsgque::MQ_RTN
 class-shortcut for const struct MqRuntimeS *, all const shortcut using the XX_YYYC syntax (only for public API) …
 
typedef struct MqRuntimeS libmqmsgque::MQ_RTR
 reference-shortcut for struct MqRuntimeS, all shortcut using the XX_YYYR syntax (only for public API) …
 
typedef struct MqTypeCtxSlibmqmsgque::MQ_CTXTYP
 class-shortcut for struct MqTypeCtxS *, all shortcut using the XX_YYY syntax (only for public API) …
 
typedef const struct MqTypeCtxSlibmqmsgque::MQ_CTXTYPN
 class-shortcut for const struct MqTypeCtxS *, all const shortcut using the XX_YYYC syntax (only for public API) …
 
typedef struct MqTypeCtxS libmqmsgque::MQ_CTXTYPR
 reference-shortcut for struct MqTypeCtxS, all shortcut using the XX_YYYR syntax (only for public API) …
 
typedef struct MqFactorySlibmqmsgque::MQ_FCT
 class-shortcut for struct MqFactoryS *, all shortcut using the XX_YYY syntax (only for public API) …
 
typedef const struct MqFactorySlibmqmsgque::MQ_FCTN
 class-shortcut for const struct MqFactoryS *, all const shortcut using the XX_YYYC syntax (only for public API) …
 
typedef struct MqFactoryS libmqmsgque::MQ_FCTR
 reference-shortcut for struct MqFactoryS, all shortcut using the XX_YYYR syntax (only for public API) …
 
typedef struct MqContextSlibmqmsgque::MQ_CTX
 class-shortcut for struct MqContextS *, all shortcut using the XX_YYY syntax (only for public API) …
 
typedef const struct MqContextSlibmqmsgque::MQ_CTXN
 class-shortcut for const struct MqContextS *, all const shortcut using the XX_YYYC syntax (only for public API) …
 
typedef struct MqContextS libmqmsgque::MQ_CTXR
 reference-shortcut for struct MqContextS, all shortcut using the XX_YYYR syntax (only for public API) …
 
typedef struct MqDumpSlibmqmsgque::MQ_DMP
 class-shortcut for struct MqDumpS *, all shortcut using the XX_YYY syntax (only for public API) …
 
typedef const struct MqDumpSlibmqmsgque::MQ_DMPN
 class-shortcut for const struct MqDumpS *, all const shortcut using the XX_YYYC syntax (only for public API) …
 
typedef struct MqDumpS libmqmsgque::MQ_DMPR
 reference-shortcut for struct MqDumpS, all shortcut using the XX_YYYR syntax (only for public API) …
 
typedef struct MqEnvSlibmqmsgque::MQ_ENV
 class-shortcut for struct MqEnvS *, all shortcut using the XX_YYY syntax (only for public API) …
 
typedef const struct MqEnvSlibmqmsgque::MQ_ENVN
 class-shortcut for const struct MqEnvS *, all const shortcut using the XX_YYYC syntax (only for public API) …
 
typedef struct MqEnvS libmqmsgque::MQ_ENVR
 reference-shortcut for struct MqEnvS, all shortcut using the XX_YYYR syntax (only for public API) …
 
typedef int libmqmsgque::MQ_SOCK_HDL
 
typedef struct MqTypeCtxSlibmqmsgque::MQ_CTXT
 object context type datatype, use &XX->type to cast to MK_TYP
 
typedef enum MkErrorE(* libmqmsgque::MqTokenF) (MQ_SERVICE_CALL_ARGS)
 prototype for an object method function …
 
typedef void(* libmqmsgque::MqDataFreeF) (MQ_SERVICE_FREE_ARGS)
 prototype for a free additional token data function …
 
typedef void(* libmqmsgque::MqDataCopyF) (MQ_SERVICE_COPY_ARGS)
 prototype for a copy additional token data function …
 
typedef enum MkErrorE(* libmqmsgque::MqCreateF) (MK_RT mkrt, MQ_CTX const ctx, MK_BFL const args)
 the prototype for the ContextCreate function …
 
typedef void(* libmqmsgque::MqDeleteF) (MQ_CTX const ctx)
 the prototype for a ContextDelete function …
 
typedef void(* libmqmsgque::MqHelpF) (MK_STRN basename)
 application specific help function type …
 
typedef int(* libmqmsgque::MqExitF) (MK_RT mkrt, int num)
 prototype for exit a process or thread …
 
typedef bool(* libmqmsgque::MqWaitForPipeF) (MK_RT mkrt, MQ_CTX const ctx, const struct MkIdS *idP)
 Wait for a pipe-server to finish …
 
typedef void(* libmqmsgque::MqSetupF) (MQ_CTX const ctx)
 used to setup (initialize) a new thread/fork/process created by ccmqmsgque using the SysServer? style commands
 
typedef void(* libmqmsgque::MqRefCountF) (MK_RT mkrt, MQ_CTX ctx, MK_PTR const env)
 used in libmqmsgque::MqTypeCtxS::fIncrSelf and libmqmsgque::MqTypeCtxS::fDecrSelf to protect an "embedded" self on deletion
 
typedef int(* libmqmsgque::MqSysSelectF) (int max, void *read, void *write, void *except, struct timeval *timeout)
 select syscall …
 
typedef enum MkErrorE(* libmqmsgque::MqSysServerSpawnF) (MK_RT mkrt, MQ_RT mqrt, MQ_CTX const ctx, char *const *argv, MK_STRN name, struct MkIdS *idPtrOut)
 spawn server create syscall with ccmqmsgque error plugin
 
typedef enum MkErrorE(* libmqmsgque::MqSysServerThreadF) (MK_RT mkrt, MQ_CTX const ctx, struct MqSysServerThreadMainS *const argP, MK_STRN name, int state, struct MkIdS *idPtrOut)
 thread server create syscall with ccmqmsgque error plugin
 
typedef enum MkErrorE(* libmqmsgque::MqSysServerForkF) (MK_RT mkrt, MQ_RT mqrt, MQ_CTX const ctx, MQ_FCT factory, MK_BFL *argsP, MK_STRN name, MQ_SOCK_HDL socket, struct MkIdS *idPtrOut)
 fork server create syscall with ccmqmsgque error plugin
 
typedef enum MkErrorE(* libmqmsgque::MqFactoryCTorF) (MK_RT mkrt, MQ_RT mqrt, MQ_CTX const tmpl, enum MqFactoryE create, MQ_FCT const fct, MQ_CTX *ctx_out)
 type of a MqFactoryC constructor
 
typedef void(* libmqmsgque::MqFactoryDTorF) (MK_RT mkrt, MQ_CTX ctx, bool doFactoryCleanup, MQ_FCT const fct)
 type of a MqFactoryC destructor
 
typedef void(* libmqmsgque::MqFactoryDataFreeF) (MK_RT mkrt, MK_PTR *dataP)
 prototype for a free additional factory data function
 
typedef void(* libmqmsgque::MqFactoryDataCopyF) (MK_RT mkrt, MK_PTR *dataP)
 prototype for a copy additional factory data function
 
typedef MK_STRN libmqmsgque::MQ_TOK
 MqContextC - a char[4+1] or hex[8+1] string used to unique identify a service …
 
typedef MqTokenF libmqmsgque::MqServiceCallbackF
 MqContextC - the callback-function is used as a service-handle or as a event-handle
 

Functions

void libmqmsgque::MqConfigReset_RT (MK_RT mkrt, MQ_CTX const ctx)
 clean the libmqmsgque::MqContextS::config data
 
void libmqmsgque::MqConfigDup_RT (MK_RT mkrt, MQ_CTX const to, MQ_CTX const from)
 copy the libmqmsgque::MqContextS::config data
 
void libmqmsgque::MqSetupDup_RT (MK_RT mkrt, MQ_CTX const to, MQ_CTXN const from)
 copy the libmqmsgque::MqContextS::setup data …
 
void libmqmsgque::MqSetup (void)
 setup ccmqmsgque internal memory …
 
void libmqmsgque::MqCleanup (void)
 cleanup ccmqmsgque internal memory …
 
void libmqmsgque::MqConfigSetName_RT (MK_RT mkrt, MQ_CTX const ctx, MK_STRN data)
 set the libmqmsgque::MqConfigS::dispName value and cleanup old value
 
void libmqmsgque::MqConfigSetPrefixWithNoLock_RT (MK_RT mkrt, MQ_CTX const ctx, MK_STRN data)
 set the libmqmsgque::MqConfigS::dispPrefix with low-priority
 
void libmqmsgque::MqConfigSetPrefix_RT (MK_RT mkrt, MQ_CTX const ctx, MK_STRN data)
 set the server-part (1) of the application-identifer libmqmsgque::MqConfigS::dispName
 
void libmqmsgque::MqConfigSetPostfix_RT (MK_RT mkrt, MQ_CTX const ctx, MK_STRN data)
 set the client-part (2) of the application-identifer libmqmsgque::MqConfigS::dispName
 
void libmqmsgque::MqConfigSetStorage_RT (MK_RT mkrt, MQ_CTX const ctx, MK_STRN data)
 set the Storage value and cleanup old value
 
void libmqmsgque::MqConfigSetAllTimeout (MQ_CTX const ctx, MK_TIME_T data)
 set the libmqmsgque::MqIoConfigS::timeout value
 
enum MkErrorE libmqmsgque::MqConfigSetAllDebug_RT (MK_RT mkrt, MQ_CTX const ctx, MK_I32 const data)
 set the MkRuntimeS::debug value
 
void libmqmsgque::MqConfigSetIsString (MQ_CTX const ctx, bool data)
 set the libmqmsgque::MqConfigS::native value 'S'string or 'L'owEndian or 'B'igEndian
 
enum MkErrorE libmqmsgque::MqConfigSetStartAs (MQ_CTX const ctx, enum MqStartE data)
 set the libmqmsgque::MqConfigS::startAs value
 
enum MkErrorE libmqmsgque::MqConfigSetStartAsString (MQ_CTX const ctx, MK_STRN data)
 set the libmqmsgque::MqConfigS::startAs value using string default, thread, fork or spawn
 
bool libmqmsgque::MqConfigCheckStartAs (MQ_CTX const ctx, enum MqStartE data)
 check if libmqmsgque::MqConfigS::startAs can be set to data
 
enum MkErrorE libmqmsgque::MqConfigSetIoUds_RT (MK_RT mkrt, MQ_CTX const ctx, MK_STRN file)
 configure a context to use a uds-client-server-link
 
enum MkErrorE libmqmsgque::MqConfigSetIoTcp_RT (MK_RT mkrt, MQ_CTX const ctx, MK_STRN host, MK_STRN port, MK_STRN myhost, MK_STRN myport)
 configure a context to use a tcp-client-server-link
 
enum MkErrorE libmqmsgque::MqConfigSetIoTcpL_RT (MK_RT mkrt, MQ_CTX const ctx, MK_BFL const vals)
 configure a context to use a tcp-client-server-link
 
enum MkErrorE libmqmsgque::MqConfigSetIoPipe_RT (MK_RT mkrt, MQ_CTX const ctx, MQ_SOCK_HDL fh)
 set the pipe configuration data …
 
enum MkErrorE libmqmsgque::MqConfigSetDaemon_RT (MK_RT mkrt, MQ_CTX const ctx, MK_STRN pidfile)
 start the server-context as daemon …
 
void libmqmsgque::MqConfigSetBuffersize (MQ_CTX const ctx, MK_I32 data)
 set the libmqmsgque::MqIoConfigS::buffersize value
 
void libmqmsgque::MqConfigSetPkgsize (MQ_CTX const ctx, MK_I32 data)
 set the libmqmsgque::MqIoConfigS::pkgsize value
 
void libmqmsgque::MqConfigSetTimeout (MQ_CTX const ctx, MK_TIME_T data)
 set the libmqmsgque::MqIoConfigS::timeout value
 
void libmqmsgque::MqConfigSetIsServer (MQ_CTX const ctx, bool data)
 set the libmqmsgque::MqSetupS::isServer value
 
void libmqmsgque::MqConfigSetIdentFrom (MQ_CTX const ctx, enum MqIdentE data)
 set the libmqmsgque::MqConfigS::identFrom value
 
void libmqmsgque::MqConfigSetIgnoreExit (MQ_CTX const ctx, bool data)
 set the libmqmsgque::MqSetupS::ignoreExit value
 
void libmqmsgque::MqConfigSetServerSetup_RT (MK_RT mkrt, MQ_CTX const ctx, MqTokenF fCall, MK_CBP callback, MqDataFreeF fFree, MqDataCopyF fCopy)
 set the libmqmsgque::MqSetupS::ServerSetup
 
void libmqmsgque::MqConfigSetServerCleanup_RT (MK_RT mkrt, MQ_CTX const ctx, MqTokenF fCall, MK_CBP callback, MqDataFreeF fFree, MqDataCopyF fCopy)
 set the libmqmsgque::MqSetupS::ServerCleanup
 
void libmqmsgque::MqConfigSetBgError_RT (MK_RT mkrt, MQ_CTX const ctx, MqTokenF fCall, MK_CBP callback, MqDataFreeF fFree, MqDataCopyF fCopy)
 set the libmqmsgque::MqSetupS::BgError
 
void libmqmsgque::MqConfigSetEvent_RT (MK_RT mkrt, MQ_CTX const ctx, MqTokenF fCall, MK_CBP callback, MqDataFreeF fFree, MqDataCopyF fCopy)
 set the libmqmsgque::MqSetupS::Event
 
void libmqmsgque::MqContextLog_RT (MK_RT mkrt, MQ_CTXN const ctx, MK_OBJN fmtobj, MK_DBG const debug, MK_STRN const callfunc, MK_I32 const lvl)
 log the MqContextC
 
void libmqmsgque::MqContextLogShort_RT (MK_RT mkrt, MQ_CTXN const ctx, MK_OBJN fmtobj, MK_DBG const debug, MK_STRN const callfunc, MK_I32 const lvl, MK_STRN const label)
 log the MqContextC with less info then MqContextLog
 
void libmqmsgque::MqContextLogConfig_RT (MK_RT mkrt, MQ_CTXN const ctx, MK_OBJN fmtobj, MK_DBG const debug, MK_STRN const callfunc, MK_I32 const lvl)
 log the MqContextC part libmqmsgque::MqConfigS
 
void libmqmsgque::MqContextLogSetup_RT (MK_RT mkrt, MQ_CTXN const ctx, MK_OBJN fmtobj, MK_DBG const debug, MK_STRN const callfunc, MK_I32 const lvl)
 log the MqContextC part libmqmsgque::MqSetupS
 
void libmqmsgque::MqContextLogLink_RT (MK_RT mkrt, MQ_CTXN ctx, MK_OBJN fmtobj, MK_DBG const debug, MK_STRN const callfunc, MK_I32 const lvl)
 log the MqContextC part libmqmsgque::MqLinkS
 
void libmqmsgque::MqContextLogEnv_RT (MK_RT mkrt, MQ_CTX const ctx, MK_OBJN fmtobj, MK_DBG const debug, MK_STRN const callfunc, MK_I32 const lvl)
 log the MqContextC part libmqmsgque::MqEnvS
 
void libmqmsgque::MqContextLogType_RT (MK_RT mkrt, MQ_CTX const ctx, MK_OBJN fmtobj, MK_DBG const debug, MK_STRN const callfunc, MK_I32 const lvl)
 log the MqContextC part MkTypeS
 
void libmqmsgque::MqContextLogDebug (MQ_CTX const ctx)
 
void libmqmsgque::MqSysServerThreadMain (struct MqSysServerThreadMainS *data)
 initialize a new thread …
 
void libmqmsgque::MqErrorEnvReset (MQ_ERR const err)
 reset the libmqmsgque::MqErrorS::client_protect and the libmqmsgque::MqErrorS::server_protect
 
MK_PTR libmqmsgque::MqFactoryItemGetCreateData (MQ_FCTN const fct)
 helper function to return MqFactoryS::Create::data
 
MK_PTR libmqmsgque::MqFactoryItemGetDeleteData (MQ_FCTN const fct)
 helper function to return MqFactoryS::Delete::data
 
MK_STRN libmqmsgque::MqFactoryGetOriginalIdent (MQ_FCTN const fct)
 helper function to return MqFactoryS::originalIdent
 
MQ_FCT libmqmsgque::MqFactoryGet_RT (MK_RT mkrt, MK_STRN const ident)
 return the MqFactoryC
 
MQ_FCT libmqmsgque::MqFactoryGetCalled_RT (MK_RT mkrt, MK_STRN const ident)
 returns the MqFactoryC identified by ident
 
MQ_FCT libmqmsgque::MqFactoryGetCalledL_RT (MK_RT mkrt, MK_BFLN largs)
 returns the MqFactoryC identified as first argument in the largs MkBufferListC
 
void libmqmsgque::MqFactoryFree_RT (MK_RT mkrt, MQ_FCT const fct)
 free internal factory memory and call libmqmsgque::MqFactoryDTorS::fFree + libmqmsgque::MqFactoryCTorS::fFree
 
MQ_FCT libmqmsgque::MqFactoryAdd_RT (MK_RT mkrt, MK_OBJN const error, MqFactoryCTorF const createCallF, MK_CCP const constructor, MqFactoryDataFreeF const createDataFreeF, MqFactoryDataCopyF const createDataCopyF, MqFactoryDTorF const deleteCallF, MK_CCP const destructor, MqFactoryDataFreeF const deleteDataFreeF, MqFactoryDataCopyF const deleteDataCopyF, MK_STRN const ident)
 Add a new MqFactoryC identified by factory-identifier and defined by factory-constructor
 
MQ_FCT libmqmsgque::MqFactoryTypeAdd_RT (MK_RT mkrt, MK_OBJN const error, MK_STRN const ident, MkSelfCreateF const fctCreate, MkSelfDeleteF const fctDelete, MkConstructorF const constructor, MkSelfDeleteF const selfDelete)
 add a new MqFactoryS-Object identified by a fctT
 
MQ_FCT libmqmsgque::MqFactoryDup2_RT (MK_RT mkrt, MQ_FCTN const fct, MK_STRN const ident)
 create a duplicate of the singleton object MqFactoryC using a new factory-identifer
 
MQ_FCT libmqmsgque::MqFactoryDefault_RT (MK_RT mkrt, MQ_FCT const fct)
 set the default-attribute to the factory
 
MQ_FCT libmqmsgque::MqFactoryInitial_RT (MK_RT mkrt, MQ_FCT const fct)
 set the initial-attribut to fct
 
MK_STRN libmqmsgque::MqFactoryDefaultIdent_RT (MK_RT mkrt)
 return the factory-identifier of the default MqFactoryC
 
MK_STRN libmqmsgque::MqFactoryInitialIdent_RT (MK_RT mkrt)
 return the factory-identifier of the initial MqFactoryC
 
enum MkErrorE libmqmsgque::MqFactoryNew_RT (MK_RT mkrt, MQ_FCT const fct, MQ_CTX const tmpl, MQ_CTX *const val_out)
 create a new MqContextC from a MqFactoryC
 
void libmqmsgque::MqFactoryLogAll_RT (MK_RT mkrt, MK_STRN const callfunc)
 log all "factories" to stderr
 
static MQ_CTXT libmqmsgque::MqCtxTyp (MK_MNG mng)
 type-check and cast a managed-pointer into an libmqmsgque::MqTypeCtxS pointer or MK_NULL if not possible
 
void libmqmsgque::MqTypeCtxLog_RT (MK_RT mkrt, MQ_CTXT const ctxtype, MK_OBJN fmtobj, MK_DBG const debug, MK_STRN const callfunc, MK_I32 const lvl)
 log the libmqmsgque::MqTypeCtxS
 
void libmqmsgque::MqContextInit_RT (MK_RT mkrt, MQ_CTX const ctx, MK_TYP type, MQ_CTX const tmpl)
 initialize the MqContextC object related data but do not create the object self
 
void libmqmsgque::MqContextFree_RT (MK_RT mkrt, MQ_CTX const ctx)
 free the MqContextC object related data but do not free the toplevel object self …
 
MQ_CTX libmqmsgque::MqContextCreate_RT (MK_RT mkrt, MK_TYP type, MQ_CTX const tmpl)
 create and initialize the MqContextC ...
 
MQ_CTX libmqmsgque::MqContextSetup_RT (MK_RT mkrt, MK_TYP type, MQ_CTX const tmpl, MQ_CTX *ctx_out)
 
enum MkErrorE libmqmsgque::MqContextErrorCopy_RT (MK_RT mkrt, MQ_CTXN const targetCtx, MQ_CTXN const sourceCtx)
 copy a MkErrorS from the sourceCtx to the targetCtx
 
enum MkErrorE libmqmsgque::MqContextErrorMove_RT (MK_RT mkrt, MQ_CTXN const targetCtx, MQ_CTXN const sourceCtx)
 move a MkErrorS from the sourceCtx to the targetCtx
 
static MK_ERR libmqmsgque::MqContextErrorFORMAT (MQ_CTXN const fmtobj)
 helper used to access MkErrorDEFAULT from MqContextC
 
static MQ_CTX libmqmsgque::MqGetRoot (MQ_CTX ctx)
 get the Root (toplevel initial context)
 
static MQ_CTXN libmqmsgque::MqGetRootN (MQ_CTXN ctx)
 (const) get the Root (toplevel initial context)
 
int libmqmsgque::MqExit_RT (MK_RT mkrt, MQ_CTX const ctx, MK_STRN const callfunc, MK_STRN const callfile, MK_I32 const callline)
 delete the context and exit the current process or thread …
 
void libmqmsgque::MqContextMark_RT (MK_RT mkrt, MQ_CTX const ctx)
 Mark objects as used to avoid the freeing of used external memory in an external Garbage-Collection …
 
enum MkErrorE libmqmsgque::MqCheckForLeftOverArguments_RT (MK_RT mkrt, MQ_CTX const ctx, MK_BFLN args)
 check for left over arguments from parameter args of MqLinkCreate
 
MK_BUF libmqmsgque::MqContextGetBuffer_RT (MK_RT mkrt, MQ_CTX const ctx)
 get the libmqmsgque::MqContextS::ctxbuf object
 
enum MkErrorE libmqmsgque::MqProcessEvent_RT (MK_RT mkrt, MQ_CTX const ctx, enum MqWaitOnEventE const wait, MK_TIME_T timeout)
 enter the event-loop and wait for an incoming service-request. …
 
MK_STRN libmqmsgque::MqContextToString_RT (MK_RT mkrt, MQ_CTXN const ctx)
 String-Slot - returns the string representation of the inst
 
void libmqmsgque::MqEnvProtect_RT (MK_RT mkrt, MQ_CTX ctx)
 protect the service-environment
 
void libmqmsgque::MqEnvRestore (MQ_CTX ctx)
 restore the service-environment
 
enum MkErrorE libmqmsgque::MqStorageErrCnt_RT (MK_RT mkrt, MQ_CTX const ctx, MQ_LTR transLId, MK_I32 *cnt_out)
 increment and return the database row-error-count for the row defined with transLId
 
enum MkErrorE libmqmsgque::MqStorageOpen_RT (MK_RT mkrt, MQ_CTX const ctx, MK_STRN const storageFile)
 switch to a file-based-transaction-database
 
enum MkErrorE libmqmsgque::MqStorageClose_RT (MK_RT mkrt, MQ_CTX const ctx)
 close the storage. …
 
enum MkErrorE libmqmsgque::MqStorageExport_RT (MK_RT mkrt, MQ_CTX const ctx, MQ_LTR *ltid_out)
 export the read-data-package into the STORAGE
 
enum MkErrorE libmqmsgque::MqStorageImport_RT (MK_RT mkrt, MQ_CTX const ctx, MQ_LTR *transLIdP_inout)
 import the storage-package into the read-data-package
 
enum MkErrorE libmqmsgque::MqStorageIncrRef_RT (MK_RT mkrt, MQ_CTX const ctx, MQ_LTR transLId)
 increase the internal refCount lock of the database-entry
 
enum MkErrorE libmqmsgque::MqStorageDecrRef_RT (MK_RT mkrt, MQ_CTX const ctx, MQ_LTR transLId)
 decrease the internal refCount lock of the database-entry
 
enum MkErrorE libmqmsgque::MqStorageDelete_RT (MK_RT mkrt, MQ_CTX const ctx, MQ_LTR *transLIdP_inout)
 delete the storage-row identified by the transLIdP_inout
 
enum MkErrorE libmqmsgque::MqStorageCount_RT (MK_RT mkrt, MQ_CTX const ctx, MQ_LTR *cnt_out)
 count the number of storage-rows
 
enum MkErrorE libmqmsgque::MqStorageResolve_RT (MK_RT mkrt, MQ_CTX const ctx, MQ_CTX *otherCtxP_out, MQ_LTR *otherLIdP_out)
 extract the context->link.protect.rmtTransLId entry from the database
 
enum MkErrorE libmqmsgque::MqLinkCreate_RT (MK_RT mkrt, MQ_CTX const ctx, MK_BAC args)
 make ctx to a parent-context and setup a new client-server-link
 
enum MkErrorE libmqmsgque::MqLinkConnect_RT (MK_RT mkrt, MQ_CTX const ctx)
 re-connect a client-server-link after a server crash or a network downtime …
 
enum MkErrorE libmqmsgque::MqLinkShutdown_RT (MK_RT mkrt, MQ_CTX const ctx)
 shutdown the communication with a server
 
enum MkErrorE libmqmsgque::MqLinkCreateChild_RT (MK_RT mkrt, MQ_CTX const ctx, MQ_CTX const parent, MK_BAC const args)
 make a context to a child-context on-top of an existing parent-client-server-link
 
enum MkErrorE libmqmsgque::MqLinkDefault_RT (MK_RT mkrt, MQ_CTX const ctx, MK_BAC const args)
 callback as wrapper for MqLinkCreate or MqLinkCreateChild with additional error-check code …
 
void libmqmsgque::MqLinkDelete_RT (MK_RT mkrt, MQ_CTX const ctx)
 close the client-server-link
 
bool libmqmsgque::MqLinkIsConnected (MQ_CTX const ctx)
 is the context connected? …
 
static MQ_CTX libmqmsgque::MqLinkGetParent (MQ_CTX const ctx)
 get the initial parent-context from a client/server link …
 
static bool libmqmsgque::MqLinkIsParent (MQ_CTX const ctx)
 is the context a parent-context? …
 
static MK_NUM libmqmsgque::MqLinkGetCtxId (MQ_CTX const ctx)
 get an identifier which is unique per parent-or-child-context
 
static MK_STRN libmqmsgque::MqLinkGetTargetIdent (MQ_CTX const ctx)
 get the ident of the link-target
 
enum MkErrorE libmqmsgque::MqRouteCreate_RT (MK_RT mkrt, MQ_CTX ctx, MK_STRN route, MK_STRN service, bool overwrite)
 create/delete a routing-link between context an a service using route
 
enum MkErrorE libmqmsgque::MqRouteDelete_RT (MK_RT mkrt, MQ_CTX ctx, MK_STRN route, MK_STRN service, bool overwrite)
 delete a routing-link created with MqRouteCreate
 
enum MkErrorE libmqmsgque::MqRouteTraverse_RT (MK_RT mkrt, MQ_CTX ctx, MK_STRN service, MK_BAC args)
 traverse a tree down and call service if available.
 
MQ_CTX_A libmqmsgque::MqRouteResolve_RT (MK_RT mkrt, MQ_CTX const ctx, MK_STRN const ident, MK_NUM const retnum)
 return a list of all context belonging to ident
 
enum MkErrorE libmqmsgque::MqRouteGetPath_RT (MK_RT mkrt, MQ_CTX const ctx, MK_STRN *path_out)
 return the absolut route-connection-string up to the current ctx
 
enum MkErrorE libmqmsgque::MqRouteGetTree_RT (MK_RT mkrt, MQ_CTX const ctx, MK_BFL *treeP_out)
 create an overview about all available routing-target and services …
 
static bool libmqmsgque::MqServiceIsTransaction (MQ_CTX const ctx)
 check if the ongoing-service-call belongs to a transaction …
 
MQ_TOK libmqmsgque::MqServiceTokenGet (MQ_CTX const ctx)
 in an ongoing-service-call get the current MqContextC_ServiceApi_Identifer
 
bool libmqmsgque::MqServiceTokenCheck (MQ_CTX const ctx, MQ_TOK const token)
 in an ongoing-service-call check if the current MqContextC_ServiceApi_Identifer is token
 
bool libmqmsgque::MqServiceTokenExists (MQ_CTX const ctx, MQ_TOK const token)
 check if the MqContextC_ServiceApi_Identifer token is defined as ctx service …
 
enum MkErrorE libmqmsgque::MqServiceCreate_RT (MK_RT mkrt, MQ_CTX const ctx, MQ_TOK const token, MqServiceCallbackF const fCall, MK_CBP callback, MqDataFreeF fFree, MkMarkF fMark)
 create a link between a service-token and a service-callback
 
enum MkErrorE libmqmsgque::MqServiceStorage_RT (MK_RT mkrt, MQ_CTX const ctx, MQ_TOK const token)
 setup a service listen on a MqContextC_ServiceApi_Identifer and save all read-data-package into the STORAGE
 
enum MkErrorE libmqmsgque::MqServiceDelete_RT (MK_RT mkrt, MQ_CTX const ctx, MQ_TOK const token)
 delete a service. …
 
enum MkErrorE libmqmsgque::MqReadL_START_RT (MK_RT mkrt, MQ_CTX const ctx, MK_BUF buf)
 start to extract a list-items from the read-data-package. …
 
enum MkErrorE libmqmsgque::MqReadL_END_RT (MK_RT mkrt, MQ_CTX const ctx)
 finish to extract a list-items from the read-data-package. …
 
enum MkErrorE libmqmsgque::MqReadT_START_RT (MK_RT mkrt, MQ_CTX const ctx)
 start to extract a longterm-transaction-item from the read-data-package. …
 
enum MkErrorE libmqmsgque::MqReadT_END_RT (MK_RT mkrt, MQ_CTX const ctx)
 finish to extract a longterm-transaction-item from the read-data-package. …
 
enum MkErrorE libmqmsgque::MqReadI8_RT (MK_RT mkrt, MQ_CTX const ctx, MK_I8 *const val_out)
 read a PRIMITIVE TYPE from the read-data-package
 
enum MkErrorE libmqmsgque::MqReadBOL_RT (MK_RT mkrt, MQ_CTX const ctx, MK_BOL *const val_out)
 read a PRIMITIVE TYPE from the read-data-package
 
enum MkErrorE libmqmsgque::MqReadI16_RT (MK_RT mkrt, MQ_CTX const ctx, MK_I16 *const val_out)
 read a PRIMITIVE TYPE from the read-data-package
 
enum MkErrorE libmqmsgque::MqReadI32_RT (MK_RT mkrt, MQ_CTX const ctx, MK_I32 *const val_out)
 read a PRIMITIVE TYPE from the read-data-package
 
enum MkErrorE libmqmsgque::MqReadFLT_RT (MK_RT mkrt, MQ_CTX const ctx, MK_FLT *const val_out)
 read a PRIMITIVE TYPE from the read-data-package
 
enum MkErrorE libmqmsgque::MqReadI64_RT (MK_RT mkrt, MQ_CTX const ctx, MK_I64 *const val_out)
 read a PRIMITIVE TYPE from the read-data-package
 
enum MkErrorE libmqmsgque::MqReadDBL_RT (MK_RT mkrt, MQ_CTX const ctx, MK_DBL *const val_out)
 read a PRIMITIVE TYPE from the read-data-package
 
enum MkErrorE libmqmsgque::MqReadBUF_RT (MK_RT mkrt, MQ_CTX const ctx, MK_BUF *const val_out)
 get a temporary MkBufferC from the read-data-package
 
enum MkErrorE libmqmsgque::MqReadBFL_RT (MK_RT mkrt, MQ_CTX const ctx, MK_BFL *const val_out)
 get a temporary MkBufferListC from next list-item in the read-data-package
 
enum MkErrorE libmqmsgque::MqReadALL_RT (MK_RT mkrt, MQ_CTX const ctx, MK_BFL *const val_inout)
 get a temporary MkBufferListC from all data in the read-data-package
 
enum MkErrorE libmqmsgque::MqReadLIST_RT (MK_RT mkrt, MQ_CTX const ctx, MK_NAT_LIST *const val_out)
 get all arguments as native list …
 
enum MkErrorE libmqmsgque::MqReadNEXT_RT (MK_RT mkrt, MQ_CTX const ctx, MK_NAT_OBJECT *const val_out)
 get the next argument as native object …
 
enum MkErrorE libmqmsgque::MqReadLONG_RT (MK_RT mkrt, MQ_CTX const ctx, MK_LONG *const val_out)
 read the long native object from the read-data-package
 
enum MkErrorE libmqmsgque::MqReadHDL_RT (MK_RT mkrt, MQ_CTX const ctx, MK_HDL *const val_out)
 read the handle from the read-data-package
 
enum MkErrorE libmqmsgque::MqReadSTR_RT (MK_RT mkrt, MQ_CTX const ctx, MK_STRN *const val_out)
 read a PRIMITIVE TYPE from the read-data-package
 
enum MkErrorE libmqmsgque::MqReadBIN_RT (MK_RT mkrt, MQ_CTX const ctx, MkBinaryR *const val_out)
 generic function to read an libmkkernel::MK_BIN object from the read-data-package object …
 
enum MkErrorE libmqmsgque::MqReadStringR_RT (MK_RT mkrt, MQ_CTX const ctx, MkStringR *const val_out)
 read a MkStringR from the read-data-package
 
enum MkErrorE libmqmsgque::MqReadBinaryR_RT (MK_RT mkrt, MQ_CTX const ctx, MkBinaryR *const val_out)
 read a MkBinaryR from the read-data-package
 
void libmqmsgque::MqReadDbg_RT (MK_RT mkrt, MQ_CTX const ctx)
 
enum MkErrorE libmqmsgque::MqReadUndo_RT (MK_RT mkrt, MQ_CTX const ctx)
 undo the last MqContextC READ API function call …
 
MK_NUM libmqmsgque::MqReadGetNumItems (MQ_CTX const ctx)
 get the number of items left in the read-data-package
 
enum MkTypeE libmqmsgque::MqReadGetNextType (MQ_CTX const ctx)
 get the type (MkTypeE) of the next Item in the read-data-buffer or "0" if not available
 
bool libmqmsgque::MqReadItemExists (MQ_CTX const ctx)
 check if an item exists in the read-data-package
 
enum MqTransTypeE libmqmsgque::MqReadGetTransType (MQ_CTX const ctx)
 return the TransactionType identifer …
 
enum MqHandShakeE libmqmsgque::MqReadGetHandShake (MQ_CTX const ctx)
 return the HandShake identifer …
 
enum MkErrorE libmqmsgque::MqProxyItem_RT (MK_RT mkrt, MQ_CTX const sourceCtx, MQ_CTX const targetCtx)
 Copy a single-data-item from the sourceCtx to the targetCtx.
 
enum MkErrorE libmqmsgque::MqProxyPackage_RT (MK_RT mkrt, MQ_CTX const sourceCtx, MQ_CTX const targetCtx, MQ_DMP const dump)
 copy all package-items from the sourceCtx to the targetCtx
 
enum MkErrorE libmqmsgque::MqProxyForward_RT (MK_RT mkrt, MQ_CTX const sourceCtx, MQ_CTX const targetCtx, MQ_DMP const dump, MK_TIME_T const timeout)
 send the entire read-data-package-data to the link-target
 
enum MkErrorE libmqmsgque::MqSendSetHandShake (MQ_CTX const ctx, enum MqHandShakeE handShake)
 set the hand-shake of the send-data-package
 
enum MkErrorE libmqmsgque::MqSendI8_RT (MK_RT mkrt, MQ_CTX const ctx, MK_I8 const val)
 MqContextC - append a native PRIMITIVE TYPE value to the send-data-package
 
enum MkErrorE libmqmsgque::MqSendBOL_RT (MK_RT mkrt, MQ_CTX const ctx, MK_BOL const val)
 MqContextC - append a native PRIMITIVE TYPE value to the send-data-package
 
enum MkErrorE libmqmsgque::MqSendI16_RT (MK_RT mkrt, MQ_CTX const ctx, MK_I16 const val)
 MqContextC - append a native PRIMITIVE TYPE value to the send-data-package
 
enum MkErrorE libmqmsgque::MqSendI32_RT (MK_RT mkrt, MQ_CTX const ctx, MK_I32 const val)
 MqContextC - append a native PRIMITIVE TYPE value to the send-data-package
 
enum MkErrorE libmqmsgque::MqSendFLT_RT (MK_RT mkrt, MQ_CTX const ctx, MK_FLT const val)
 MqContextC - append a native PRIMITIVE TYPE value to the send-data-package
 
enum MkErrorE libmqmsgque::MqSendI64_RT (MK_RT mkrt, MQ_CTX const ctx, MK_I64 const val)
 MqContextC - append a native PRIMITIVE TYPE value to the send-data-package
 
enum MkErrorE libmqmsgque::MqSendDBL_RT (MK_RT mkrt, MQ_CTX const ctx, MK_DBL const val)
 MqContextC - append a native PRIMITIVE TYPE value to the send-data-package
 
enum MkErrorE libmqmsgque::MqSendSTR_RT (MK_RT mkrt, MQ_CTX const ctx, MK_STRN const val)
 MqContextC - append a native PRIMITIVE TYPE value to the send-data-package
 
enum MkErrorE libmqmsgque::MqSendStringR_RT (MK_RT mkrt, MQ_CTX const ctx, MkStringR const val)
 MqContextC - append a native PRIMITIVE TYPE value to the send-data-package
 
enum MkErrorE libmqmsgque::MqSendBIN_RT (MK_RT mkrt, MQ_CTX const ctx, MkBinaryR const val)
 append a libmkkernel::MK_BIN object to the send-data-package. …
 
static enum MkErrorE libmqmsgque::MqSendBinaryR_RT (MK_RT mkrt, MQ_CTX const ctx, MkBinaryR const val)
 append a MkBinaryR object to the send-data-package. …
 
enum MkErrorE libmqmsgque::MqSendBUF_RT (MK_RT mkrt, MQ_CTX const ctx, MK_BUFN const val)
 append a MkBufferC object to the send-data-package object …
 
enum MkErrorE libmqmsgque::MqSendBFL_RT (MK_RT mkrt, MQ_CTX const ctx, MK_BFLN const val)
 append a MkBufferListC object to the send-data-package object …
 
enum MkErrorE libmqmsgque::MqSendL_FLAT_RT (MK_RT mkrt, MQ_CTX const ctx, MK_BFLN const val)
 append a MkBufferListC object as flat list of items to the send-data-package object …
 
enum MkErrorE libmqmsgque::MqSendBUS_FLAT_RT (MK_RT mkrt, MQ_CTX const ctx, MK_BUSN const val)
 append a MkBufferStreamC object to the send-data-package object …
 
enum MkErrorE libmqmsgque::MqSendV_RT (MK_RT mkrt, MQ_CTX const ctx, MK_FST const printfmt,...)
 append a vararg string to the send-data-package object …
 
enum MkErrorE libmqmsgque::MqSendVL_RT (MK_RT mkrt, MQ_CTX const ctx, MK_FST const printfmt, va_list var_list)
 append a vararg string as va_list to the send-data-package object …
 
enum MkErrorE libmqmsgque::MqSendLTR_RT (MK_RT mkrt, MQ_CTX const ctx, MQ_LTR const transLId)
 set the Longterm-Transaction-Id (LTT) in the send-data-package
 
enum MkErrorE libmqmsgque::MqSendLONG_RT (MK_RT mkrt, MQ_CTX const ctx, MK_LONG const val)
 send the long native object to the send-data-package
 
enum MkErrorE libmqmsgque::MqSendHDL_RT (MK_RT mkrt, MQ_CTX const ctx, MK_HDL const val)
 send the handle to the send-data-package
 
enum MkErrorE libmqmsgque::MqSendEND_RT (MK_RT mkrt, MQ_CTX const ctx, MQ_TOK const token, MK_TIME_T timeout)
 MqContextC - finish the send-data-block and call synchronous/asynchronous a remote-service
 
enum MkErrorE libmqmsgque::MqSendSTART_RT (MK_RT mkrt, MQ_CTX const ctx)
 initialize the send-data-package. …
 
enum MkErrorE libmqmsgque::MqSendEND_AND_WAIT_RT (MK_RT mkrt, MQ_CTX const ctx, MQ_TOK const token, MK_TIME_T timeout)
 finish the send-data-block, call the remote service and wait for result…
 
enum MkErrorE libmqmsgque::MqSendEND_AND_TRANSACTION_RT (MK_RT mkrt, MQ_CTX const ctx, MQ_TOK const token, MQ_TOK const callback, MK_TIME_T timeout)
 finish the send-data-block, call the remote service to do a longterm-transaction-call
 
enum MkErrorE libmqmsgque::MqSendEND_AND_SUB_RT (MK_RT mkrt, MQ_CTX const ctx, MQ_TOK const token, MqServiceCallbackF const fCall, MK_CBP callback, MqDataFreeF fFree, MK_TIME_T timeout)
 finish the send-data-block, call the remote service, do wait for the result and expect multiple sub-results on a callback
 
enum MkErrorE libmqmsgque::MqSendEND_AND_CALLBACK_RT (MK_RT mkrt, MQ_CTX const ctx, MQ_TOK const token, MqServiceCallbackF const fCall, MK_CBP callback, MqDataFreeF fFree, MK_TIME_T const timeout)
 finish the send-data-block, call the remote service, do not-wait for the result but expect the result on a callback
 
enum MkErrorE libmqmsgque::MqSendSYNC_RT (MK_RT mkrt, MQ_CTX const ctx)
 garantee that all pending asynchronous-service-calls are processed. …
 
enum MkErrorE libmqmsgque::MqSendRETURN_RT (MK_RT mkrt, MQ_CTX const ctx)
 MqContextC - finish the send-data-block on the server and optional return the results. …
 
enum MkErrorE libmqmsgque::MqSendRETURN_SUB_RT (MK_RT mkrt, MQ_CTX const ctx)
 return Sub-Data-Blocks required by MqSendEND_AND_SUB
 
enum MkErrorE libmqmsgque::MqSendERROR_RT (MK_RT mkrt, MQ_CTX const ctx)
 send the data from the MkErrorC to the link target . …
 
enum MkErrorE libmqmsgque::MqSendL_START_RT (MK_RT mkrt, MQ_CTX const ctx)
 start to append an embedded body-list-item to the send-data-package. …
 
enum MkErrorE libmqmsgque::MqSendL_END_RT (MK_RT mkrt, MQ_CTX const ctx)
 finish to append an embedded body-list-item to the send-data-package. …
 
enum MkErrorE libmqmsgque::MqSendT_START_RT (MK_RT mkrt, MQ_CTX const ctx)
 open a longterm-transaction-item
 
enum MkErrorE libmqmsgque::MqSendT_END_RT (MK_RT mkrt, MQ_CTX const ctx)
 closed a longterm-transaction-item
 
enum MkErrorE libmqmsgque::MqSlaveWorker_RT (MK_RT mkrt, MQ_CTX const ctx, MQ_SLAVE_ID const id, MK_STRN fct, MK_BAC args)
 create a master/slave link using the image of the ctx object self. …
 
enum MkErrorE libmqmsgque::MqSlaveCreate_RT (MK_RT mkrt, MQ_CTX const ctx, MQ_SLAVE_ID const id, MQ_CTX const slave)
 create a master/slave link between the master-parent-context and the slave-parent-context …
 
enum MkErrorE libmqmsgque::MqSlaveDelete_RT (MK_RT mkrt, MQ_CTX const ctx, MQ_SLAVE_ID const id)
 Delete a slave object from a master/slave link identified by id. …
 
static bool libmqmsgque::MqSlaveCheck (MQ_CTXN const ctx, MQ_SLAVE_ID const id)
 check if slave-id is valid
 
enum MkErrorE libmqmsgque::MqSlaveGet_RT (MK_RT mkrt, MQ_CTX const ctx, MQ_SLAVE_ID const id, MQ_CTX *ctx_out)
 get the slave-context from a master-context
 
enum MkErrorE libmqmsgque::MqSlaveGetProxy_RT (MK_RT mkrt, MQ_CTX const ctx, MQ_SLAVE_ID const id, MQ_CTX *ctx_out)
 on slave return the master and on master return the slave identified by id.
 
enum MkErrorE libmqmsgque::MqSlaveGetFilter_RT (MK_RT mkrt, MQ_CTX const ctx, MQ_CTX *ctx_out)
 get the filter-ctx or the master-ctx
 
static MQ_CTX libmqmsgque::MqSlaveGetMaster (MQ_CTX const ctx)
 opposite function of MqSlaveGetFilter
 
static bool libmqmsgque::MqSlaveIs (MQ_CTXN const ctx)
 is the context a slave-context ? …
 
enum MkErrorE libmqmsgque::MqSend_RT (MK_RT mkrt, MQ_CTX const ctx, MK_STRN cstr,...)
 user friendly replacement for the MqContextC_SendApi_C_API
 
enum MkErrorE libmqmsgque::MqSendVL2_RT (MK_RT mkrt, MQ_CTX const ctx, MK_STRN cstr, va_list var_list)
 A version of MqSend with va_list support …
 
MQ_FCT const libmqmsgque::MqClassFactoryGet (MQ_CTXN const ctx)
 get the MqFactoryC used by the MqContextC
 
enum MkErrorE libmqmsgque::MqClassFactorySet_RT (MK_RT mkrt, MQ_CTX const ctx, MQ_FCT const item)
 link the MqContextC to a new MqFactoryC
 
enum MkErrorE libmqmsgque::MqClassIdentSet_RT (MK_RT mkrt, MQ_CTX const ctx, MK_STRN ident)
 link the MqContextC to a new MqFactoryC identified by ident
 
MK_STRN libmqmsgque::MqClassIdentGet (MQ_CTXN const ctx)
 get the application-identification
 
MK_STRN libmqmsgque::MqClassOriginalIdentGet (MQ_CTXN const ctx)
 get the libmqmsgque::MqFactoryS::originalIdent from the MqContextC
 
static bool libmqmsgque::MqConfigGetIsServer (MQ_CTX const ctx)
 does the context object is a server ?
 
static enum MqIdentE libmqmsgque::MqConfigGetIdentFrom (MQ_CTX const ctx)
 get the libmqmsgque::MqConfigS::identFrom
 
static bool libmqmsgque::MqConfigGetIsParent (MQ_CTX const ctx)
 does the context object is a parent ? An objext is a parent id the libmqmsgque::MqConfigS::parent attribute is MK_NULL
 
static bool libmqmsgque::MqConfigGetIsString (MQ_CTX const ctx)
 does the context object is using the string-mode ?
 
static MK_STRN libmqmsgque::MqConfigGetName (MQ_CTXN const ctx)
 get the name of the context object
 
static MK_STRN libmqmsgque::MqConfigGetPrefix (MQ_CTXN const ctx)
 get the libmqmsgque::MqConfigS::dispPrefix
 
static MK_STRN libmqmsgque::MqConfigGetPostfix (MQ_CTXN const ctx)
 get the libmqmsgque::MqConfigS::dispPostfix
 
static MK_STRN libmqmsgque::MqConfigGetStorage (MQ_CTXN const ctx)
 get the storage of the context object
 
static MK_I32 libmqmsgque::MqConfigGetBuffersize (MQ_CTXN const ctx)
 get the minimum of the read/send buffersize of the socket
 
static MK_I32 libmqmsgque::MqConfigGetPkgsize (MQ_CTXN const ctx)
 get the maximun size of a BDY package
 
static MK_TIME_T libmqmsgque::MqConfigGetTimeout (MQ_CTXN const ctx)
 get the timeout value of the context object
 
static MK_STRN libmqmsgque::MqConfigGetIoUds (MQ_CTXN const ctx)
 return the libmqmsgque::MqIoUdsConfigS
 
enum MkErrorE libmqmsgque::MqConfigGetIoTcp (MQ_CTX const ctx, MK_STRN *host_out, MK_STRN *port_out, MK_STRN *myhost_out, MK_STRN *myport_out)
 get the configuration-data of the tcp-client-server-link
 
enum MkErrorE libmqmsgque::MqConfigGetIoTcpL_RT (MK_RT mkrt, MQ_CTX const ctx, MK_BFL *vals_out)
 get the configuration-data of the tcp-client-server-link as MkBufferListC
 
static MQ_SOCK_HDL libmqmsgque::MqConfigGetIoPipe (MQ_CTX const ctx)
 return the libmqmsgque::MqIoPipeConfigS
 
static enum MqStartE libmqmsgque::MqConfigGetStartAs (MQ_CTX const ctx)
 return the libmqmsgque::MqConfigS::startAs value
 
static enum MqStatusIsEF libmqmsgque::MqConfigGetStatusIs (MQ_CTX const ctx)
 return the libmqmsgque::MqContextS::statusIs value
 
config_tlibmqmsgque::MqConfigGetConfigFile (MQ_CTX const ctx)
 get the config-file handle used for libconfig API funtions
 
config_setting_tlibmqmsgque::MqConfigGetConfigRoot (MQ_CTX const ctx)
 get the config-root handle used for libconfig API funtions
 
enum MkErrorE libmqmsgque::MqConfigSetConfigFile_RT (MK_RT mkrt, MQ_CTX const ctx, MK_STRN const filename)
 set the config-file and parse for well-known config-items
 
void libmqmsgque::MqDumpLog_RT (MK_RT mkrt, MQ_DMP const dmp, MK_OBJN fmtobj, MK_I32 const debug, MK_STRN const callfunc, MK_I32 const lvl)
 log the MqDumpC
 
enum MkErrorE libmqmsgque::MqDumpExport_RT (MK_RT mkrt, MQ_CTX const ctx, MQ_DMP *const dumpP_inout)
 create a MqDumpC as export of the ctx-read-data-package
 
enum MkErrorE libmqmsgque::MqDumpError_RT (MK_RT mkrt, MQ_CTX const error, MQ_DMP *const dumpP_inout)
 export the context->error into the dump-package
 
enum MkErrorE libmqmsgque::MqDumpImport_RT (MK_RT mkrt, MQ_DMP const dump, MQ_CTX const ctx)
 import the dump-package into the ctx-read-data-package
 
enum MkErrorE libmqmsgque::MqDumpBinSet_RT (MK_RT mkrt, MkBinaryR data, MQ_DMP *dmp_out)
 create an MqDumpS object from binary data
 
MkBinaryR libmqmsgque::MqDumpBinGet (MQ_DMPN const dump)
 export the binary data from an MqDumpS object
 
MK_SIZE libmqmsgque::MqDumpSizeGet (MQ_DMPN const dump)
 report the binary data size from an MqDumpS object
 
void libmqmsgque::MqDumpTransLIdSet (MQ_DMP const dump, MQ_LTR transLId)
 set the libmqmsgque::MqEnvS::transLId
 
void libmqmsgque::MqDumpRmtTransLIdSet (MQ_DMP const dump, MQ_LTR rmtTransLId)
 set the libmqmsgque::MqEnvS::rmtTransLId
 
void libmqmsgque::MqDumpAllocSizeSet (MQ_DMP const dump, MK_SIZE allocsize)
 set the allocated buffer of the MqDumpC
 
MK_SIZE libmqmsgque::MqDumpAllocSizeGet (MQ_DMPN const dump)
 return the allocated buffer of the MqDumpC
 
enum MqHandShakeE libmqmsgque::MqDumpHandShakeGet (MQ_DMPN const dump)
 return the libmqmsgque::MqHandShakeE as character …
 
MK_STRN libmqmsgque::MqDumpTokenGet (MQ_DMPN const dump)
 return the MqContextC_ServiceApi_Identifer
 
MQ_RT libmqmsgque::MqRuntimeSetup (MK_RT const mkrt, MQ_RT const mqrt)
 initialize MqRuntimeRLS
 
void libmqmsgque::MqRuntimeCleanup (MK_RT mkrt, MQ_RT mqrt)
 cleanup MkRuntimeRLS
 
static MQ_RT libmqmsgque::MqRuntimeGet (MK_RT mkrt)
 inline from MqRuntimeSetup
 
void libmqmsgque::MqMain (void *code)
 Main entrypoint - start the application
 
MK_STR libmqmsgque::MqHelp (MK_STRN tool)
 write ccmqmsgque specific user-help to stderr
 
MK_STR libmqmsgque::MqHelpMsgque (void)
 return a page with the usage of all ccmqmsgque specific options
 
MK_BFL libmqmsgque::MqInitResetArg0 (void)
 Reset the process-startup-prefix argument to an empty list …
 
void libmqmsgque::MqInitSetArg0 (MK_BAC bfl)
 set the process startup-prefix argument to bfl
 
void libmqmsgque::MqInitSetArg0VA (MK_STRN arg0,...)
 set the process startup-prefix to a args
 
void libmqmsgque::MqInitSetArg0VAL (MK_STRN arg0, va_list var_list)
 set the process startup-prefix to var_list
 
MK_BFL libmqmsgque::MqInitGetArg0 (void)
 get the process startup-prefix argument
 
static MK_STRN libmqmsgque::MqLogServerOrClient (MQ_CTXN const ctx)
 is ctx a SERVER or a CLIENT ? …
 
static MK_STRN libmqmsgque::MqLogParentOrChild (MQ_CTXN ctx)
 is ctx a PARENT or a CHILD ? …
 
MqFactoryC - Misc - function - unspecified functions to perform different tasks
static MQ_FCT libmqmsgque::MqFactoryGetNull (void)
 Null-Slot - return a MqFactoryC typed NULL instance …
 
MqFactoryDelete
void libmqmsgque::MqFactoryDelete_RT (MK_RT mkrt, MQ_FCT fct)
 Destructor - delete a MqFactoryC instance …
 
MqContextC - Misc - function - unspecified functions to perform different tasks
static MQ_CTX libmqmsgque::MqContextGetNull (void)
 Null-Slot - return a MqContextC typed NULL instance …
 
MqContextDelete
void libmqmsgque::MqContextDelete_RT (MK_RT mkrt, MQ_CTX ctx)
 Destructor - delete a MqContextC instance …
 
MqStorageLog
enum MkErrorE libmqmsgque::MqStorageLog_RT (MK_RT mkrt, MQ_CTX const ctx, MK_STRN const callfunc)
 log the storage the status of the open transactions
 
MqServiceProxy

create a service to link a master-context with a slave-context. …

This function is used to create a proxy-service to forward the body-data from the read-data-package of the master to the send-data-package of the slave. The data is not changed. This function support the reverse-operation also. If the ctx is a master-context than the data is send to slave identified by id. If the ctx is a slave-context than the data is send to the master of the slave.

Parameters
[in]mkrtthe MkRuntimeS instance to work on - the runtime argument, used by MK_RT_CALL (C-only)
[in]ctxthe MqContextS instance to work on
[in]tokenthe MqContextC SERVICE API to identify the service
[in]idthe SlaveId to unique identify the master/slave link, the id < libmqmsgque::MQ_SLAVE_USER is internal.
Exceptions
MkExceptionC→ The default-exception from the Programming-Language-Micro-Kernel (PLMK)
enum MkErrorE libmqmsgque::MqServiceProxy_RT (MK_RT mkrt, MQ_CTX const ctx, MQ_TOK const token, MQ_SLAVE_ID const id)
 create a service to link a master-context with a slave-context. …
 
enum MkErrorE libmqmsgque::MqServiceProxyCtx_RT (MK_RT mkrt, MQ_CTX const ctx, MQ_TOK const token, MQ_CTX const target)
 same as MqServiceProxy but use an MqContextC as input.
 
enum MkErrorE libmqmsgque::MqServiceProxyRoundRobin_RT (MK_RT mkrt, MQ_CTX const ctx, MQ_TOK const token, MK_STRN const ident)
 create a proxy-service using Round-Robin as load-balancer …
 
bool libmqmsgque::MqServiceProxyCtxExists (MQ_CTX const ctx, MQ_TOK const token, MQ_CTX const target)
 check if service who belongs to token is a proxy-service
 
MqDumpC - Misc - function - unspecified functions to perform different tasks
static MQ_DMP libmqmsgque::MqDumpGetNull (void)
 Null-Slot - return a MqDumpC typed NULL instance …
 
MqDumpDelete
void libmqmsgque::MqDumpDelete_RT (MK_RT mkrt, MQ_DMP dmp)
 Destructor - delete a MqDumpC instance …
 
MqContextC - Introspection - inline - access to all instances created by class starting with the last one
static MQ_CTX libmqmsgque::MqContextInstances_RT (MK_RT mkrt)
 get head-instance from linked-list of MqContextS type …
 
static MQ_CTX libmqmsgque::MqContextNext (MQ_CTX const ctx)
 get next instance from linked-list of MqContextS type
 
static MQ_CTX libmqmsgque::MqContextPrev (MQ_CTX const ctx)
 get previous instance from linked-list of MqContextS type
 
MqDumpC - Introspection - inline - access to all instances created by class starting with the last one
static MQ_DMP libmqmsgque::MqDumpInstances_RT (MK_RT mkrt)
 get head-instance from linked-list of MqDumpS type …
 
static MQ_DMP libmqmsgque::MqDumpNext (MQ_DMP const dmp)
 get next instance from linked-list of MqDumpS type
 
static MQ_DMP libmqmsgque::MqDumpPrev (MQ_DMP const dmp)
 get previous instance from linked-list of MqDumpS type
 
MqFactoryC - Introspection - inline - access to all instances created by class starting with the last one
static MQ_FCT libmqmsgque::MqFactoryInstances_RT (MK_RT mkrt)
 get head-instance from linked-list of MqFactoryS type …
 
static MQ_FCT libmqmsgque::MqFactoryNext (MQ_FCT const fct)
 get next instance from linked-list of MqFactoryS type
 
static MQ_FCT libmqmsgque::MqFactoryPrev (MQ_FCT const fct)
 get previous instance from linked-list of MqFactoryS type
 

Variables

bool libmqmsgque::MqCleanupActive
 signal that code was triggert by libmqmsgque::MqCleanup
 
struct MqLalS libmqmsgque::MqLal
 Language Abstraction Layer in duty.
 
bool libmqmsgque::MqRuntimeThreadPoolUse
 
__thread struct MqRuntimeS libmqmsgque::MqRuntimeRLS
 RLS.
 
size_t libmqmsgque::MqRuntimeId
 identify the custom runtime
 
struct MkBufferListSlibmqmsgque::MqInitArg0
 the process-startup-prefix argument …
 

MqEnvC - type definition

#define MqEnvC_T   (&MQ_RT_REF._MqEnvC_T)
 class as MkTypeDefS-class-type, useable in a class-macro as: class##_T
 
#define MqEnvC_TT   (MkTYP(MqEnvC_T))
 class as MkTypeS-class-type, useable in a class-macro as: class##_TT
 
#define MqEnvST   MqEnvC_T
 instance-type as MkTypeDefS-class-type …
 
#define MqEnvSTT   (MkTYP(MqEnvST))
 instance-type as MkTypeS-class-type (cast from MqEnvST into MkTypeS) …
 
#define MqEnvC_type   MQ_ENV
 same as MqEnvS but useable in a class-macro as: class##_type
 
#define MqEnvCT_X(instance)
 cast from an instance into the MkTypeDefS-class-type …
 
#define MqEnvCTT_X(instance)
 cast from an instance into the MkTypeS-class-type …
 
#define MqEnvCT_TT(typ)
 cast from an MkTypeS-class-type into an MkTypeDefS-class-type …
 
#define MqEnvC_NS   MQ
 map class to namespace …
 
#define MqEnvCTT   MqEnvCTT
 class as MkTypeS-class-type for MqEnvC in the Target-Programming-Language (TPL)
 
#define MqEnvCT   ( (struct MkTypeDefS *) MqEnvCTT )
 class as MkTypeDefS-class-type for MqEnvC in the Target-Programming-Language (TPL)
 
typedef struct MqEnvS libmqmsgque::MqEnvCR
 instance-struct-reference same as struct MqEnvS, useable in a class-macro as: class##R
 
typedef const struct MqEnvS libmqmsgque::MqEnvCNR
 const instance-struct-reference same as const struct MqEnvS, useable in a class-macro as: class##R
 

MqEnvC - signature check

#define MqEnvC_Check(mng)
 
static bool libmqmsgque::MqEnvCheck (MK_MNGN mng)
 check MqEnvS -> libmkkernel::MkObjectS::signature
 
static bool libmqmsgque::MqEnvCheckO (MK_OBJN obj)
 check MqEnvS -> libmkkernel::MkObjectS::signature
 

MqEnvC - cast from a defined or a undefined instance

#define MqEnvRaise(_env)
 raise an error if class-instance is not valid
 
#define MqENV_R(x)
 cast a known-object into an MqEnvS reference
 
#define MqENV(x)
 cast a known-object into an MqEnvS pointer
 
static MQ_ENV libmqmsgque::MqEnv (MK_MNG mng)
 cast a unknown-object into an MqEnvS pointer or NULL if not possible
 
static MQ_ENVN libmqmsgque::MqEnvN (MK_MNGN mng)
 (const) cast a unknown-object into an MqEnvS pointer or NULL if not possible
 

MqErrorC - type definition

#define MqErrorC_T   (&MQ_RT_REF._MqErrorC_T)
 class as MkTypeDefS-class-type, useable in a class-macro as: class##_T
 
#define MqErrorC_TT   (MkTYP(MqErrorC_T))
 class as MkTypeS-class-type, useable in a class-macro as: class##_TT
 
#define MqErrorST   MqErrorC_T
 instance-type as MkTypeDefS-class-type …
 
#define MqErrorSTT   (MkTYP(MqErrorST))
 instance-type as MkTypeS-class-type (cast from MqErrorST into MkTypeS) …
 
#define MqErrorC_type   MQ_ERR
 same as MqErrorS but useable in a class-macro as: class##_type
 
#define MqErrorCT_X(instance)
 cast from an instance into the MkTypeDefS-class-type …
 
#define MqErrorCTT_X(instance)
 cast from an instance into the MkTypeS-class-type …
 
#define MqErrorCT_TT(typ)
 cast from an MkTypeS-class-type into an MkTypeDefS-class-type …
 
#define MqErrorC_NS   MQ
 map class to namespace …
 
#define MqErrorCTT   MqErrorCTT
 class as MkTypeS-class-type for MqErrorC in the Target-Programming-Language (TPL)
 
#define MqErrorCT   ( (struct MkTypeDefS *) MqErrorCTT )
 class as MkTypeDefS-class-type for MqErrorC in the Target-Programming-Language (TPL)
 
typedef struct MqErrorS libmqmsgque::MqErrorCR
 instance-struct-reference same as struct MqErrorS, useable in a class-macro as: class##R
 
typedef const struct MqErrorS libmqmsgque::MqErrorCNR
 const instance-struct-reference same as const struct MqErrorS, useable in a class-macro as: class##R
 

MqErrorC - signature check

#define MqErrorC_Check(mng)
 
static bool libmqmsgque::MqErrCheck (MK_MNGN mng)
 check MqErrorS -> libmkkernel::MkObjectS::signature
 
static bool libmqmsgque::MqErrCheckO (MK_OBJN obj)
 check MqErrorS -> libmkkernel::MkObjectS::signature
 

MqErrorC - cast from a defined or a undefined instance

#define MqErrRaise(_err)
 raise an error if class-instance is not valid
 
#define MqERR_R(x)
 cast a known-object into an MqErrorS reference
 
#define MqERR(x)
 cast a known-object into an MqErrorS pointer
 
static MQ_ERR libmqmsgque::MqErr (MK_MNG mng)
 cast a unknown-object into an MqErrorS pointer or NULL if not possible
 
static MQ_ERRN libmqmsgque::MqErrN (MK_MNGN mng)
 (const) cast a unknown-object into an MqErrorS pointer or NULL if not possible
 

MqFactoryC - type definition

#define MqFactoryC_T   (&MQ_RT_REF._MqFactoryC_T)
 class as MkTypeDefS-class-type, useable in a class-macro as: class##_T
 
#define MqFactoryC_TT   (MkTYP(MqFactoryC_T))
 class as MkTypeS-class-type, useable in a class-macro as: class##_TT
 
#define MqFactoryST   MqFactoryC_T
 instance-type as MkTypeDefS-class-type …
 
#define MqFactorySTT   (MkTYP(MqFactoryST))
 instance-type as MkTypeS-class-type (cast from MqFactoryST into MkTypeS) …
 
#define MqFactoryC_type   MQ_FCT
 same as MqFactoryS but useable in a class-macro as: class##_type
 
#define MqFactoryCT_X(instance)
 cast from an instance into the MkTypeDefS-class-type …
 
#define MqFactoryCTT_X(instance)
 cast from an instance into the MkTypeS-class-type …
 
#define MqFactoryCT_TT(typ)
 cast from an MkTypeS-class-type into an MkTypeDefS-class-type …
 
#define MqFactoryC_NS   MQ
 map class to namespace …
 
#define MqFactoryCTT   MqFactoryCTT
 class as MkTypeS-class-type for MqFactoryC in the Target-Programming-Language (TPL)
 
#define MqFactoryCT   ( (struct MkTypeDefS *) MqFactoryCTT )
 class as MkTypeDefS-class-type for MqFactoryC in the Target-Programming-Language (TPL)
 
typedef struct MqFactoryS libmqmsgque::MqFactoryCR
 instance-struct-reference same as struct MqFactoryS, useable in a class-macro as: class##R
 
typedef const struct MqFactoryS libmqmsgque::MqFactoryCNR
 const instance-struct-reference same as const struct MqFactoryS, useable in a class-macro as: class##R
 

MqFactoryC - signature check

#define MqFactoryC_Check(mng)
 
static bool libmqmsgque::MqFctCheck (MK_MNGN mng)
 check MqFactoryS -> libmkkernel::MkObjectS::signature
 
static bool libmqmsgque::MqFctCheckO (MK_OBJN obj)
 check MqFactoryS -> libmkkernel::MkObjectS::signature
 

MqFactoryC - cast from a defined or a undefined instance

#define MqFctRaise(_fct)
 raise an error if class-instance is not valid
 
#define MqFCT_R(x)
 cast a known-object into an MqFactoryS reference
 
#define MqFCT(x)
 cast a known-object into an MqFactoryS pointer
 
static MQ_FCT libmqmsgque::MqFct (MK_MNG mng)
 cast a unknown-object into an MqFactoryS pointer or NULL if not possible
 
static MQ_FCTN libmqmsgque::MqFctN (MK_MNGN mng)
 (const) cast a unknown-object into an MqFactoryS pointer or NULL if not possible
 

MqFactoryC - Export - inline - interact with an external software

#define MqFactoryHandleResolve_e(netHdl)
 wrapper for MqFactoryHandleResolve with error-handline
 
static MK_HDL libmqmsgque::MqFactoryHandleGet_RT (MK_RT mkrt, MQ_FCT const fct)
 Handle-Get-Slot - returns a export-hdl to the MqFactoryC useable for external storage
 
static MQ_FCT libmqmsgque::MqFactoryHandleResolve_RT (MK_RT mkrt, MK_HDL const netHdl)
 Handle-Resolve-Slot - return a MqFactoryC from netHdl or MK_NULL if invalid…
 

MqFactoryLog

#define MqFactoryLog_2M(fct, m)
 
void libmqmsgque::MqFactoryLog_RT (MK_RT mkrt, MQ_FCTN const fct, MK_OBJN fmtobj, MK_DBG const debug, MK_STRN const callfunc, MK_I32 const lvl)
 log the MqFactoryC
 

MqTypeCtxC - type definition

#define MqTypeCtxSTT   (&MQ_RT_REF._MqTypeCtxC_TT)
 instance-type as MkTypeS-class-type
 
#define MqTypeCtxC_TT   (&MQ_RT_REF._MqTypeCtxC_TT)
 class as MkTypeS-class-type, useable in a class-macro as: class##_TT
 
#define MqTypeCtxC_type   MQ_CTXTYP
 same as MqTypeCtxS but useable in a class-macro as: class##_type
 
#define MqTypeCtxCT_X(instance)
 cast from an instance into the MkTypeS-class-type …
 
#define MqTypeCtxCTT_X(instance)
 cast from an instance into the MkTypeS-class-type …
 
#define MqTypeCtxCT_TT(typ)
 cast from an MkTypeS-class-type into an MkTypeS-class-type …
 
#define MqTypeCtxC_NS   MQ
 map class to namespace …
 
#define MqTypeCtxCTT   MqTypeCtxCTT
 class as MkTypeS-class-type for MqTypeCtxC in the Target-Programming-Language (TPL)
 
#define MqTypeCtxCT   ( (struct MkTypeS *) MqTypeCtxCTT )
 class as MkTypeS-class-type for MqTypeCtxC in the Target-Programming-Language (TPL)
 
typedef struct MqTypeCtxS libmqmsgque::MqTypeCtxCR
 instance-struct-reference same as struct MqTypeCtxS, useable in a class-macro as: class##R
 
typedef const struct MqTypeCtxS libmqmsgque::MqTypeCtxCNR
 const instance-struct-reference same as const struct MqTypeCtxS, useable in a class-macro as: class##R
 

MqTypeCtxC - signature check

#define MqTypeCtxC_Check(mng)
 
static bool libmqmsgque::MqCtxTypCheck (MK_MNGN mng)
 check MqTypeCtxS -> libmkkernel::MkObjectS::signature
 
static bool libmqmsgque::MqCtxTypCheckO (MK_OBJN obj)
 check MqTypeCtxS -> libmkkernel::MkObjectS::signature
 

MqContextC - type definition

#define MqContextC_T   (&MQ_RT_REF._MqContextC_T)
 class as MqTypeCtxS-class-type, useable in a class-macro as: class##_T
 
#define MqContextC_TT   (MkTYP(MqContextC_T))
 class as MkTypeS-class-type, useable in a class-macro as: class##_TT
 
#define MqContextST   MqContextC_T
 instance-type as MqTypeCtxS-class-type …
 
#define MqContextSTT   (MkTYP(MqContextST))
 instance-type as MkTypeS-class-type (cast from MqContextST into MkTypeS) …
 
#define MqContextC_type   MQ_CTX
 same as MqContextS but useable in a class-macro as: class##_type
 
#define MqContextCT_X(instance)
 cast from an instance into the MqTypeCtxS-class-type …
 
#define MqContextCTT_X(instance)
 cast from an instance into the MkTypeS-class-type …
 
#define MqContextCT_TT(typ)
 cast from an MkTypeS-class-type into an MqTypeCtxS-class-type …
 
#define MqContextC_NS   MQ
 map class to namespace …
 
#define MqContextCTT   MqContextCTT
 class as MkTypeS-class-type for MqContextC in the Target-Programming-Language (TPL)
 
#define MqContextCT   ( (struct MqTypeCtxS *) MqContextCTT )
 class as MqTypeCtxS-class-type for MqContextC in the Target-Programming-Language (TPL)
 
typedef struct MqContextS libmqmsgque::MqContextCR
 instance-struct-reference same as struct MqContextS, useable in a class-macro as: class##R
 
typedef const struct MqContextS libmqmsgque::MqContextCNR
 const instance-struct-reference same as const struct MqContextS, useable in a class-macro as: class##R
 

MqContextC - signature check

#define MqContextC_Check(mng)
 
static bool libmqmsgque::MqCtxCheck (MK_MNGN mng)
 check MqContextS -> libmkkernel::MkObjectS::signature
 
static bool libmqmsgque::MqCtxCheckO (MK_OBJN obj)
 check MqContextS -> libmkkernel::MkObjectS::signature
 

MqContextC - cast from a defined or a undefined instance

#define MqCtxRaise(_ctx)
 raise an error if class-instance is not valid
 
#define MqCTX_R(x)
 cast a known-object into an MqContextS reference
 
#define MqCTX(x)
 cast a known-object into an MqContextS pointer
 
static MQ_CTX libmqmsgque::MqCtx (MK_MNG mng)
 cast a unknown-object into an MqContextS pointer or NULL if not possible
 
static MQ_CTXN libmqmsgque::MqCtxN (MK_MNGN mng)
 (const) cast a unknown-object into an MqContextS pointer or NULL if not possible
 

MqContextC - Export - inline - interact with an external software

#define MqContextHandleResolve_e(netHdl)
 wrapper for MqContextHandleResolve with error-handline
 
static MK_HDL libmqmsgque::MqContextHandleGet_RT (MK_RT mkrt, MQ_CTX const ctx)
 Handle-Get-Slot - returns a export-hdl to the MqContextC useable for external storage
 
static MQ_CTX libmqmsgque::MqContextHandleResolve_RT (MK_RT mkrt, MK_HDL const netHdl)
 Handle-Resolve-Slot - return a MqContextC from netHdl or MK_NULL if invalid…
 

MqEnvLog

#define MqEnvLog_0()
 
#define MqEnvLog_1(env)
 
#define MqEnvLog_2(env, fmt)
 
#define MqEnvLog_3(env, fmt, lbl)
 
void libmqmsgque::MqEnvLog_RT (MK_RT mkrt, MQ_ENVN const env, MK_OBJN fmtobj, MK_DBG const debug, MK_STRN const callfunc, MK_I32 const lvl, MK_STRN const label)
 log the libmqmsgque::MqEnvS
 

MqDumpC - type definition

#define MqDumpC_T   (&MQ_RT_REF._MqDumpC_T)
 class as MkTypeDefS-class-type, useable in a class-macro as: class##_T
 
#define MqDumpC_TT   (MkTYP(MqDumpC_T))
 class as MkTypeS-class-type, useable in a class-macro as: class##_TT
 
#define MqDumpST   MqDumpC_T
 instance-type as MkTypeDefS-class-type …
 
#define MqDumpSTT   (MkTYP(MqDumpST))
 instance-type as MkTypeS-class-type (cast from MqDumpST into MkTypeS) …
 
#define MqDumpC_type   MQ_DMP
 same as MqDumpS but useable in a class-macro as: class##_type
 
#define MqDumpCT_X(instance)
 cast from an instance into the MkTypeDefS-class-type …
 
#define MqDumpCTT_X(instance)
 cast from an instance into the MkTypeS-class-type …
 
#define MqDumpCT_TT(typ)
 cast from an MkTypeS-class-type into an MkTypeDefS-class-type …
 
#define MqDumpC_NS   MQ
 map class to namespace …
 
#define MqDumpCTT   MqDumpCTT
 class as MkTypeS-class-type for MqDumpC in the Target-Programming-Language (TPL)
 
#define MqDumpCT   ( (struct MkTypeDefS *) MqDumpCTT )
 class as MkTypeDefS-class-type for MqDumpC in the Target-Programming-Language (TPL)
 
typedef struct MqDumpS libmqmsgque::MqDumpCR
 instance-struct-reference same as struct MqDumpS, useable in a class-macro as: class##R
 
typedef const struct MqDumpS libmqmsgque::MqDumpCNR
 const instance-struct-reference same as const struct MqDumpS, useable in a class-macro as: class##R
 

MqDumpC - signature check

#define MqDumpC_Check(mng)
 
static bool libmqmsgque::MqDmpCheck (MK_MNGN mng)
 check MqDumpS -> libmkkernel::MkObjectS::signature
 
static bool libmqmsgque::MqDmpCheckO (MK_OBJN obj)
 check MqDumpS -> libmkkernel::MkObjectS::signature
 

MqDumpC - cast from a defined or a undefined instance

#define MqDmpRaise(_dmp)
 raise an error if class-instance is not valid
 
#define MqDMP_R(x)
 cast a known-object into an MqDumpS reference
 
#define MqDMP(x)
 cast a known-object into an MqDumpS pointer
 
static MQ_DMP libmqmsgque::MqDmp (MK_MNG mng)
 cast a unknown-object into an MqDumpS pointer or NULL if not possible
 
static MQ_DMPN libmqmsgque::MqDmpN (MK_MNGN mng)
 (const) cast a unknown-object into an MqDumpS pointer or NULL if not possible
 

MqDumpC - Export - inline - interact with an external software

#define MqDumpHandleResolve_e(netHdl)
 wrapper for MqDumpHandleResolve with error-handline
 
static MK_HDL libmqmsgque::MqDumpHandleGet_RT (MK_RT mkrt, MQ_DMP const dmp)
 Handle-Get-Slot - returns a export-hdl to the MqDumpC useable for external storage
 
static MQ_DMP libmqmsgque::MqDumpHandleResolve_RT (MK_RT mkrt, MK_HDL const netHdl)
 Handle-Resolve-Slot - return a MqDumpC from netHdl or MK_NULL if invalid…
 

MqRuntimeC - type definition

#define MqRuntimeC_T   (&MQ_RT_REF._MqRuntimeC_T)
 class as MkTypeDefS-class-type, useable in a class-macro as: class##_T
 
#define MqRuntimeC_TT   (MkTYP(MqRuntimeC_T))
 class as MkTypeS-class-type, useable in a class-macro as: class##_TT
 
#define MqRuntimeST   MqRuntimeC_T
 instance-type as MkTypeDefS-class-type …
 
#define MqRuntimeSTT   (MkTYP(MqRuntimeST))
 instance-type as MkTypeS-class-type (cast from MqRuntimeST into MkTypeS) …
 
#define MqRuntimeC_type   MQ_RT
 same as MqRuntimeS but useable in a class-macro as: class##_type
 
#define MqRuntimeCT_X(instance)
 cast from an instance into the MkTypeDefS-class-type …
 
#define MqRuntimeCTT_X(instance)
 cast from an instance into the MkTypeS-class-type …
 
#define MqRuntimeCT_TT(typ)
 cast from an MkTypeS-class-type into an MkTypeDefS-class-type …
 
#define MqRuntimeC_NS   MQ
 map class to namespace …
 
#define MqRuntimeCTT   MqRuntimeCTT
 class as MkTypeS-class-type for MqRuntimeC in the Target-Programming-Language (TPL)
 
#define MqRuntimeCT   ( (struct MkTypeDefS *) MqRuntimeCTT )
 class as MkTypeDefS-class-type for MqRuntimeC in the Target-Programming-Language (TPL)
 
typedef struct MqRuntimeS libmqmsgque::MqRuntimeCR
 instance-struct-reference same as struct MqRuntimeS, useable in a class-macro as: class##R
 
typedef const struct MqRuntimeS libmqmsgque::MqRuntimeCNR
 const instance-struct-reference same as const struct MqRuntimeS, useable in a class-macro as: class##R
 

MqRuntimeC - signature check

#define MqRuntimeC_Check(mng)
 
static bool libmqmsgque::MqRtCheck (MK_MNGN mng)
 check MqRuntimeS -> libmkkernel::MkObjectS::signature
 
static bool libmqmsgque::MqRtCheckO (MK_OBJN obj)
 check MqRuntimeS -> libmkkernel::MkObjectS::signature
 

MqRuntimeC - cast from a defined or a undefined instance

#define MqRtRaise(_rt)
 raise an error if class-instance is not valid
 
static MQ_RT libmqmsgque::MqRt (MK_MNG mng)
 cast a unknown-object into an MqRuntimeS pointer or NULL if not possible
 
static MQ_RTN libmqmsgque::MqRtN (MK_MNGN mng)
 (const) cast a unknown-object into an MqRuntimeS pointer or NULL if not possible
 

MqRuntimeLog

#define MqRuntimeLog_2M(mqrt, m)
 
void libmqmsgque::MqRuntimeLog_RT (MK_RT mkrt, MQ_RTN const mqrt, MK_OBJN fmtobj, MK_DBG const debug, MK_STRN const callfunc, MK_I32 const lvl)
 log the MqRuntimeS
 

MqHandShakeE

enum  libmqmsgque::MqHandShakeE { libmqmsgque::MQ_HANDSHAKE_START = 'S' , libmqmsgque::MQ_HANDSHAKE_OK = 'O' , libmqmsgque::MQ_HANDSHAKE_ERROR = 'E' }
 the hand-shake of a service-callMore...
 
MK_STRN libmqmsgque::MqHandShakeE_ToString (enum MqHandShakeE value)
 return the MqHandShakeE as string …
 
static MK_I32 libmqmsgque::MqHandShakeE_ToInt (enum MqHandShakeE value)
 return the MqHandShakeE as integer …
 
enum MkErrorE libmqmsgque::MqHandShakeE_FromInt (MK_I32 const value, enum MqHandShakeE *value_out)
 return the MqHandShakeE from integer …
 

MqTransTypeE

enum  libmqmsgque::MqTransTypeE {
  libmqmsgque::MQ_TRANS_TYPE_WAIT = 'W' , libmqmsgque::MQ_TRANS_TYPE_SUB = 'S' , libmqmsgque::MQ_TRANS_TYPE_CB = 'C' , libmqmsgque::MQ_TRANS_TYPE_TRANS = 'T' ,
  libmqmsgque::MQ_TRANS_TYPE_NO = 'N'
}
 the type of the transaction … More...
 
MK_STRN libmqmsgque::MqTransTypeE_ToString (enum MqTransTypeE value)
 return the MqTransTypeE as string …
 
static MK_I32 libmqmsgque::MqTransTypeE_ToInt (enum MqTransTypeE value)
 return the MqTransTypeE as integer …
 
enum MkErrorE libmqmsgque::MqTransTypeE_FromInt (MK_I32 const value, enum MqTransTypeE *value_out)
 return the MqTransTypeE from integer …
 

MqIdentE

enum  libmqmsgque::MqIdentE { libmqmsgque::MQ_IDENT_PREFIX = 0 , libmqmsgque::MQ_IDENT_FACTORY = 1 }
 identify the application using prefix (default) or factoryMore...
 
MK_STRN libmqmsgque::MqIdentE_ToString (enum MqIdentE value)
 return the MqIdentE as string …
 
static MK_I32 libmqmsgque::MqIdentE_ToInt (enum MqIdentE value)
 return the MqIdentE as integer …
 
enum MkErrorE libmqmsgque::MqIdentE_FromInt (MK_I32 const value, enum MqIdentE *value_out)
 return the MqIdentE from integer …
 

MqStartE

enum  libmqmsgque::MqStartE { libmqmsgque::MQ_START_DEFAULT = 0 , libmqmsgque::MQ_START_FORK = 1 , libmqmsgque::MQ_START_THREAD = 2 , libmqmsgque::MQ_START_SPAWN = 3 }
 User preferences on HOWTO start a new entity. More...
 
MK_STRN libmqmsgque::MqStartE_ToString (enum MqStartE value)
 return the MqStartE as string …
 
static MK_I32 libmqmsgque::MqStartE_ToInt (enum MqStartE value)
 return the MqStartE as integer …
 
enum MkErrorE libmqmsgque::MqStartE_FromInt (MK_I32 const value, enum MqStartE *value_out)
 return the MqStartE from integer …
 

MqStatusIsEF

enum  libmqmsgque::MqStatusIsEF {
  libmqmsgque::MQ_STATUS_IS_INITIAL = 0 , libmqmsgque::MQ_STATUS_IS_DUP = 1<<0 , libmqmsgque::MQ_STATUS_IS_THREAD = 1<<1 , libmqmsgque::MQ_STATUS_IS_FORK = 1<<2 ,
  libmqmsgque::MQ_STATUS_IS_SPAWN = 1<<3
}
 Information about how the context was created. More...
 
MK_STRN libmqmsgque::MqStatusIsEF_ToString (enum MqStatusIsEF value)
 return the MqStatusIsEF as string …
 
static MK_I32 libmqmsgque::MqStatusIsEF_ToInt (enum MqStatusIsEF value)
 return the MqStatusIsEF as integer …
 
enum MkErrorE libmqmsgque::MqStatusIsEF_FromInt (MK_I32 const value, enum MqStatusIsEF *value_out)
 return the MqStatusIsEF from integer …
 

MqFactoryE

enum  libmqmsgque::MqFactoryE {
  libmqmsgque::MQ_FACTORY_NEW_INIT = 1<<0 , libmqmsgque::MQ_FACTORY_NEW_CHILD = 1<<1 , libmqmsgque::MQ_FACTORY_NEW_SLAVE = 1<<2 , libmqmsgque::MQ_FACTORY_NEW_FORK = 1<<3 ,
  libmqmsgque::MQ_FACTORY_NEW_THREAD = 1<<4 , libmqmsgque::MQ_FACTORY_NEW_FILTER = 1<<5
}
 the factory is called to create an object for ... More...
 
MK_STRN libmqmsgque::MqFactoryE_ToString (enum MqFactoryE value)
 return the MqFactoryE as string …
 
static MK_I32 libmqmsgque::MqFactoryE_ToInt (enum MqFactoryE value)
 return the MqFactoryE as integer …
 
enum MkErrorE libmqmsgque::MqFactoryE_FromInt (MK_I32 const value, enum MqFactoryE *value_out)
 return the MqFactoryE from integer …
 

MqIoComE

enum  libmqmsgque::MqIoComE {
  libmqmsgque::MQ_IO_PIPE = 0 , libmqmsgque::MQ_IO_UDS = 1 , libmqmsgque::MQ_IO_TCP = 2 , libmqmsgque::MQ_IO_INIT = 3 ,
  libmqmsgque::MQ_IO_LOOP = 4
}
 what kind of socket interface to use? … More...
 
MK_STRN libmqmsgque::MqIoComE_ToString (enum MqIoComE value)
 return the MqIoComE as string …
 
static MK_I32 libmqmsgque::MqIoComE_ToInt (enum MqIoComE value)
 return the MqIoComE as integer …
 
enum MkErrorE libmqmsgque::MqIoComE_FromInt (MK_I32 const value, enum MqIoComE *value_out)
 return the MqIoComE from integer …
 

MqWaitOnEventE

enum  libmqmsgque::MqWaitOnEventE { libmqmsgque::MQ_WAIT_NO = 0 , libmqmsgque::MQ_WAIT_ONCE = 1 , libmqmsgque::MQ_WAIT_OWN = 2 , libmqmsgque::MQ_WAIT_FOREVER = 3 }
 wait for an event? … More...
 
MK_STRN libmqmsgque::MqWaitOnEventE_ToString (enum MqWaitOnEventE value)
 return the MqWaitOnEventE as string …
 
static MK_I32 libmqmsgque::MqWaitOnEventE_ToInt (enum MqWaitOnEventE value)
 return the MqWaitOnEventE as integer …
 
enum MkErrorE libmqmsgque::MqWaitOnEventE_FromInt (MK_I32 const value, enum MqWaitOnEventE *value_out)
 return the MqWaitOnEventE from integer …
 

MqSlaveE

enum  libmqmsgque::MqSlaveE {
  libmqmsgque::MQ_SLAVE_LOOPBACK = 0 , libmqmsgque::MQ_SLAVE_FILTER = 1 , libmqmsgque::MQ_SLAVE_MASTER = 1 , libmqmsgque::MQ_SLAVE_OTHER = 1 ,
  libmqmsgque::MQ_SLAVE_USER = 10 , libmqmsgque::MQ_SLAVE_MAX = 1024
}
 predefined slave-id for well known slaves … More...
 
MK_STRN libmqmsgque::MqSlaveE_ToString (enum MqSlaveE value)
 return the MqSlaveE as string …
 
static MK_I32 libmqmsgque::MqSlaveE_ToInt (enum MqSlaveE value)
 return the MqSlaveE as integer …
 
enum MkErrorE libmqmsgque::MqSlaveE_FromInt (MK_I32 const value, enum MqSlaveE *value_out)
 return the MqSlaveE from integer …
 

Macro Definition Documentation

◆ AllRtSetup_NULL

#define AllRtSetup_NULL   MkRtSetup_NULL ; MqRtSetup_NULL

Definition at line 9397 of file LibMqMsgque_mq.h.

◆ AllRtSetup_O

#define AllRtSetup_O ( o)
Value:
#define MqRtSetup_O(o)
#define MkRtSetup_O(o)

Definition at line 9393 of file LibMqMsgque_mq.h.

◆ AllRtSetup_ON

#define AllRtSetup_ON ( o)
Value:
#define MqRtSetup_ON(o)
#define MkRtSetup_ON(o)

Definition at line 9394 of file LibMqMsgque_mq.h.

◆ AllRtSetup_X

#define AllRtSetup_X ( x)
Value:
#define MqRtSetup_X(x)
#define MkRtSetup_X(x)

Definition at line 9395 of file LibMqMsgque_mq.h.

◆ AllRtSetup_XN

#define AllRtSetup_XN ( x)
Value:
#define MqRtSetup_XN(x)
#define MkRtSetup_XN(x)

Definition at line 9396 of file LibMqMsgque_mq.h.

◆ BEGIN_MQ_C_DECLS

#define BEGIN_MQ_C_DECLS   namespace libmqmsgque { using namespace libmkkernel;

Definition at line 248 of file LibMqMsgque_mq.h.

◆ END_MQ_C_DECLS

#define END_MQ_C_DECLS   }

Definition at line 249 of file LibMqMsgque_mq.h.

◆ META_BROKEN_LINK_SEND_FAIL_COUNTER

#define META_BROKEN_LINK_SEND_FAIL_COUNTER   16

Definition at line 167 of file LibMqMsgque_mq.h.

◆ META_USE_GLOBAL_EVENT

#define META_USE_GLOBAL_EVENT   0

Definition at line 159 of file LibMqMsgque_mq.h.

◆ MQ_DEBUG_RUNTIME

#define MQ_DEBUG_RUNTIME

Definition at line 180 of file LibMqMsgque_mq.h.

◆ MqConfigS_dispName_size

#define MqConfigS_dispName_size   64

MqConfigS_dispPrefix_size + MqConfigS_dispPostfix_size

Definition at line 1782 of file LibMqMsgque_mq.h.

◆ MqConfigS_dispPostfix_size

#define MqConfigS_dispPostfix_size   64

Definition at line 1829 of file LibMqMsgque_mq.h.

◆ MqConfigS_dispPrefix_size

#define MqConfigS_dispPrefix_size   64

Definition at line 1812 of file LibMqMsgque_mq.h.

◆ MqConfigS_storageFile_size

#define MqConfigS_storageFile_size   256

storage file used as default if a database is requested

more at MqContextC STORAGE API

Attention
the real filename is: libmqmsgque::MqConfigS::storageFile-libmqmsgque::MqConfigS::dispPrefix

Definition at line 1863 of file LibMqMsgque_mq.h.

◆ MqFactoryS_originalIdent_size

#define MqFactoryS_originalIdent_size   63

Definition at line 3180 of file LibMqMsgque_mq.h.

◆ MqLinkS_targetIdent_size

#define MqLinkS_targetIdent_size   64

MqClassIdentGet of the link target, only valid on parent-context

use MqLinkGetTargetIdent or libmqmsgque::MqLinkGetTargetIdentI to access this value

Definition at line 1018 of file LibMqMsgque_mq.h.

◆ MqRT

#define MqRT   &MqRuntimeRLS

Definition at line 9360 of file LibMqMsgque_mq.h.

◆ MqRT_O

#define MqRT_O ( o)
Value:
((o) && (*o).objRtExt ? (MQ_RT)(*o).objRtExt : MqRuntimeGet( MK_RT_CALL_ONLY ))
#define MK_RT_CALL_ONLY

Definition at line 9367 of file LibMqMsgque_mq.h.

◆ MqRT_ON

#define MqRT_ON ( o)
Value:
( (*o).objRtExt ? (MQ_RT)(*o).objRtExt : MqRuntimeGet( MK_RT_CALL_ONLY ))

Definition at line 9369 of file LibMqMsgque_mq.h.

◆ MqRT_X

#define MqRT_X ( x)
Value:
((x) && MkOBJ_R(x).objRtExt ? (MQ_RT)MkOBJ_R(x).objRtExt : MqRuntimeGet( MK_RT_CALL_ONLY ))
#define MkOBJ_R(x)

Definition at line 9368 of file LibMqMsgque_mq.h.

◆ MqRT_XN

#define MqRT_XN ( x)
Value:
( MkOBJ_R(x).objRtExt ? (MQ_RT)MkOBJ_R(x).objRtExt : MqRuntimeGet( MK_RT_CALL_ONLY ))

Definition at line 9370 of file LibMqMsgque_mq.h.

◆ MqRtSetup_NULL

#define MqRtSetup_NULL   MK_RT_UNUSED MQ_RT const mqrt = MqRuntimeGet( MK_RT_CALL_ONLY )

Definition at line 9379 of file LibMqMsgque_mq.h.

◆ MqRtSetup_NULL_RT

#define MqRtSetup_NULL_RT   MkRtSetup_NULL_RT ; MqRtSetup_NULL

Definition at line 9385 of file LibMqMsgque_mq.h.

◆ MqRtSetup_O

#define MqRtSetup_O ( o)
Value:
MK_RT_UNUSED MQ_RT const mqrt = MqRT_O(o)
#define MqRT_O(o)
#define MK_RT_UNUSED

Definition at line 9374 of file LibMqMsgque_mq.h.

◆ MqRtSetup_O_RT

#define MqRtSetup_O_RT ( o)
Value:
#define MkRtSetup_O_RT(o)

Definition at line 9381 of file LibMqMsgque_mq.h.

◆ MqRtSetup_ON

#define MqRtSetup_ON ( o)
Value:
MK_RT_UNUSED MQ_RT const mqrt = MqRT_ON(o)
#define MqRT_ON(o)

Definition at line 9375 of file LibMqMsgque_mq.h.

◆ MqRtSetup_ON_RT

#define MqRtSetup_ON_RT ( o)
Value:
#define MkRtSetup_ON_RT(o)

Definition at line 9382 of file LibMqMsgque_mq.h.

◆ MqRtSetup_RT

#define MqRtSetup_RT ( r)
Value:
MK_RT_UNUSED MQ_RT const mqrt = r

Definition at line 9378 of file LibMqMsgque_mq.h.

◆ MqRtSetup_X

#define MqRtSetup_X ( x)
Value:
MK_RT_UNUSED MQ_RT const mqrt = MqRT_X(x)
#define MqRT_X(x)

Definition at line 9376 of file LibMqMsgque_mq.h.

◆ MqRtSetup_X_RT

#define MqRtSetup_X_RT ( x)
Value:
#define MkRtSetup_X_RT(x)

Definition at line 9383 of file LibMqMsgque_mq.h.

◆ MqRtSetup_XN

#define MqRtSetup_XN ( x)
Value:
MK_RT_UNUSED MQ_RT const mqrt = MqRT_XN(x)
#define MqRT_XN(x)

Definition at line 9377 of file LibMqMsgque_mq.h.

◆ MqRtSetup_XN_RT

#define MqRtSetup_XN_RT ( x)
Value:
#define MkRtSetup_XN_RT(x)

Definition at line 9384 of file LibMqMsgque_mq.h.

◆ MqRuntimeLog_2M

#define MqRuntimeLog_2M ( mqrt,
m )
Value:
MqRuntimeLog_2(mqrt,MkObj(m))

Definition at line 9467 of file LibMqMsgque_mq.h.