theLink 10.0
|
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.