|
theLink 10.0
|
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-link … More... | |
| struct | libmqmsgque::MqIoTcpConfigS |
| configure a context to use a tcp-client-server-link … More... | |
| struct | libmqmsgque::MqIoPipeConfigS |
| configure a context to use a pipe-client-server-link … More... | |
| 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-link … More... | |
| struct | libmqmsgque::MqLinkSetupS |
| MqContextC - used to create or delete a instance to manage a link … More... | |
| 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 MqContextC … More... | |
| 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 binary … More... | |
| 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 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 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 "->".
| |
| #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 MqErrorS * | libmqmsgque::MQ_ERR |
class-shortcut for struct MqErrorS *, all shortcut using the XX_YYY syntax (only for public API) … | |
| typedef const struct MqErrorS * | libmqmsgque::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 MqRuntimeS * | libmqmsgque::MQ_RT |
class-shortcut for struct MqRuntimeS *, all shortcut using the XX_YYY syntax (only for public API) … | |
| typedef const struct MqRuntimeS * | libmqmsgque::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 MqTypeCtxS * | libmqmsgque::MQ_CTXTYP |
class-shortcut for struct MqTypeCtxS *, all shortcut using the XX_YYY syntax (only for public API) … | |
| typedef const struct MqTypeCtxS * | libmqmsgque::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 MqFactoryS * | libmqmsgque::MQ_FCT |
class-shortcut for struct MqFactoryS *, all shortcut using the XX_YYY syntax (only for public API) … | |
| typedef const struct MqFactoryS * | libmqmsgque::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 MqContextS * | libmqmsgque::MQ_CTX |
class-shortcut for struct MqContextS *, all shortcut using the XX_YYY syntax (only for public API) … | |
| typedef const struct MqContextS * | libmqmsgque::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 MqDumpS * | libmqmsgque::MQ_DMP |
class-shortcut for struct MqDumpS *, all shortcut using the XX_YYY syntax (only for public API) … | |
| typedef const struct MqDumpS * | libmqmsgque::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 MqEnvS * | libmqmsgque::MQ_ENV |
class-shortcut for struct MqEnvS *, all shortcut using the XX_YYY syntax (only for public API) … | |
| typedef const struct MqEnvS * | libmqmsgque::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 MqTypeCtxS * | libmqmsgque::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_t * | libmqmsgque::MqConfigGetConfigFile (MQ_CTX const ctx) | ||||||||||||||
| get the config-file handle used for libconfig API funtions | |||||||||||||||
| config_setting_t * | libmqmsgque::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.
| |||||||||||||||
| 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 MkBufferListS * | libmqmsgque::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-call … More... | |
| 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 factory … More... | |
| 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 … | |
| #define AllRtSetup_NULL MkRtSetup_NULL ; MqRtSetup_NULL |
Definition at line 9397 of file LibMqMsgque_mq.h.
| #define AllRtSetup_O | ( | o | ) |
Definition at line 9393 of file LibMqMsgque_mq.h.
| #define AllRtSetup_ON | ( | o | ) |
Definition at line 9394 of file LibMqMsgque_mq.h.
| #define AllRtSetup_X | ( | x | ) |
Definition at line 9395 of file LibMqMsgque_mq.h.
| #define AllRtSetup_XN | ( | x | ) |
Definition at line 9396 of file LibMqMsgque_mq.h.
| #define BEGIN_MQ_C_DECLS namespace libmqmsgque { using namespace libmkkernel; |
Definition at line 248 of file LibMqMsgque_mq.h.
| #define END_MQ_C_DECLS } |
Definition at line 249 of file LibMqMsgque_mq.h.
| #define META_BROKEN_LINK_SEND_FAIL_COUNTER 16 |
Definition at line 167 of file LibMqMsgque_mq.h.
| #define META_USE_GLOBAL_EVENT 0 |
Definition at line 159 of file LibMqMsgque_mq.h.
| #define MQ_DEBUG_RUNTIME |
Definition at line 180 of file LibMqMsgque_mq.h.
| #define MqConfigS_dispName_size 64 |
MqConfigS_dispPrefix_size + MqConfigS_dispPostfix_size
Definition at line 1782 of file LibMqMsgque_mq.h.
| #define MqConfigS_dispPostfix_size 64 |
Definition at line 1829 of file LibMqMsgque_mq.h.
| #define MqConfigS_dispPrefix_size 64 |
Definition at line 1812 of file LibMqMsgque_mq.h.
| #define MqConfigS_storageFile_size 256 |
storage file used as default if a database is requested
more at MqContextC STORAGE API
Definition at line 1863 of file LibMqMsgque_mq.h.
| #define MqFactoryS_originalIdent_size 63 |
Definition at line 3180 of file LibMqMsgque_mq.h.
| #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.
| #define MqRT &MqRuntimeRLS |
Definition at line 9360 of file LibMqMsgque_mq.h.
| #define MqRT_O | ( | o | ) |
Definition at line 9367 of file LibMqMsgque_mq.h.
| #define MqRT_ON | ( | o | ) |
Definition at line 9369 of file LibMqMsgque_mq.h.
| #define MqRT_X | ( | x | ) |
Definition at line 9368 of file LibMqMsgque_mq.h.
| #define MqRT_XN | ( | x | ) |
Definition at line 9370 of file LibMqMsgque_mq.h.
| #define MqRtSetup_NULL MK_RT_UNUSED MQ_RT const mqrt = MqRuntimeGet( MK_RT_CALL_ONLY ) |
Definition at line 9379 of file LibMqMsgque_mq.h.
| #define MqRtSetup_NULL_RT MkRtSetup_NULL_RT ; MqRtSetup_NULL |
Definition at line 9385 of file LibMqMsgque_mq.h.
| #define MqRtSetup_O | ( | o | ) |
Definition at line 9374 of file LibMqMsgque_mq.h.
| #define MqRtSetup_O_RT | ( | o | ) |
Definition at line 9381 of file LibMqMsgque_mq.h.
| #define MqRtSetup_ON | ( | o | ) |
Definition at line 9375 of file LibMqMsgque_mq.h.
| #define MqRtSetup_ON_RT | ( | o | ) |
Definition at line 9382 of file LibMqMsgque_mq.h.
| #define MqRtSetup_RT | ( | r | ) |
Definition at line 9378 of file LibMqMsgque_mq.h.
| #define MqRtSetup_X | ( | x | ) |
Definition at line 9376 of file LibMqMsgque_mq.h.
| #define MqRtSetup_X_RT | ( | x | ) |
Definition at line 9383 of file LibMqMsgque_mq.h.
| #define MqRtSetup_XN | ( | x | ) |
Definition at line 9377 of file LibMqMsgque_mq.h.
| #define MqRtSetup_XN_RT | ( | x | ) |
Definition at line 9384 of file LibMqMsgque_mq.h.
| #define MqRuntimeLog_2M | ( | mqrt, | |
| m ) |
Definition at line 9467 of file LibMqMsgque_mq.h.