theLink 10.0
Loading...
Searching...
No Matches
libmqmsgque Namespace Reference

Classes

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

Typedefs

typedef struct config_t config_t
 libconfig struct
 
typedef struct config_setting_t config_setting_t
 libconfig struct
 
typedef int MQ_LTR
 32bit longterm transaction token because PHP-32 does NOT support long long
 
typedef int MQ_ROU
 32bit routing token because PHP-32 does NOT support long long
 
typedef MK_NUM MQ_SLAVE_ID
 a slave identiver
 
typedef int MQ_HDL
 handle data-type
 
typedef struct MqErrorSMQ_ERR
 class-shortcut for struct MqErrorS *, all shortcut using the XX_YYY syntax (only for public API) …
 
typedef const struct MqErrorSMQ_ERRN
 class-shortcut for const struct MqErrorS *, all const shortcut using the XX_YYYC syntax (only for public API) …
 
typedef struct MqErrorS MQ_ERRR
 reference-shortcut for struct MqErrorS, all shortcut using the XX_YYYR syntax (only for public API) …
 
typedef struct MqRuntimeSMQ_RT
 class-shortcut for struct MqRuntimeS *, all shortcut using the XX_YYY syntax (only for public API) …
 
typedef const struct MqRuntimeSMQ_RTN
 class-shortcut for const struct MqRuntimeS *, all const shortcut using the XX_YYYC syntax (only for public API) …
 
typedef struct MqRuntimeS MQ_RTR
 reference-shortcut for struct MqRuntimeS, all shortcut using the XX_YYYR syntax (only for public API) …
 
typedef struct MqTypeCtxSMQ_CTXTYP
 class-shortcut for struct MqTypeCtxS *, all shortcut using the XX_YYY syntax (only for public API) …
 
typedef const struct MqTypeCtxSMQ_CTXTYPN
 class-shortcut for const struct MqTypeCtxS *, all const shortcut using the XX_YYYC syntax (only for public API) …
 
typedef struct MqTypeCtxS MQ_CTXTYPR
 reference-shortcut for struct MqTypeCtxS, all shortcut using the XX_YYYR syntax (only for public API) …
 
typedef struct MqFactorySMQ_FCT
 class-shortcut for struct MqFactoryS *, all shortcut using the XX_YYY syntax (only for public API) …
 
typedef const struct MqFactorySMQ_FCTN
 class-shortcut for const struct MqFactoryS *, all const shortcut using the XX_YYYC syntax (only for public API) …
 
typedef struct MqFactoryS MQ_FCTR
 reference-shortcut for struct MqFactoryS, all shortcut using the XX_YYYR syntax (only for public API) …
 
typedef struct MqContextSMQ_CTX
 class-shortcut for struct MqContextS *, all shortcut using the XX_YYY syntax (only for public API) …
 
typedef const struct MqContextSMQ_CTXN
 class-shortcut for const struct MqContextS *, all const shortcut using the XX_YYYC syntax (only for public API) …
 
typedef struct MqContextS MQ_CTXR
 reference-shortcut for struct MqContextS, all shortcut using the XX_YYYR syntax (only for public API) …
 
typedef struct MqDumpSMQ_DMP
 class-shortcut for struct MqDumpS *, all shortcut using the XX_YYY syntax (only for public API) …
 
typedef const struct MqDumpSMQ_DMPN
 class-shortcut for const struct MqDumpS *, all const shortcut using the XX_YYYC syntax (only for public API) …
 
typedef struct MqDumpS MQ_DMPR
 reference-shortcut for struct MqDumpS, all shortcut using the XX_YYYR syntax (only for public API) …
 
typedef struct MqEnvSMQ_ENV
 class-shortcut for struct MqEnvS *, all shortcut using the XX_YYY syntax (only for public API) …
 
typedef const struct MqEnvSMQ_ENVN
 class-shortcut for const struct MqEnvS *, all const shortcut using the XX_YYYC syntax (only for public API) …
 
typedef struct MqEnvS MQ_ENVR
 reference-shortcut for struct MqEnvS, all shortcut using the XX_YYYR syntax (only for public API) …
 
typedef int MQ_SOCK_HDL
 
typedef struct MqTypeCtxSMQ_CTXT
 object context type datatype, use &XX->type to cast to MK_TYP
 
typedef enum MkErrorE(* MqTokenF) (MQ_SERVICE_CALL_ARGS)
 prototype for an object method function …
 
typedef void(* MqDataFreeF) (MQ_SERVICE_FREE_ARGS)
 prototype for a free additional token data function …
 
typedef void(* MqDataCopyF) (MQ_SERVICE_COPY_ARGS)
 prototype for a copy additional token data function …
 
typedef enum MkErrorE(* MqCreateF) (MK_RT mkrt, MQ_CTX const ctx, MK_BFL const args)
 the prototype for the ContextCreate function …
 
typedef void(* MqDeleteF) (MQ_CTX const ctx)
 the prototype for a ContextDelete function …
 
typedef void(* MqHelpF) (MK_STRN basename)
 application specific help function type …
 
typedef int(* MqExitF) (MK_RT mkrt, int num)
 prototype for exit a process or thread …
 
typedef bool(* MqWaitForPipeF) (MK_RT mkrt, MQ_CTX const ctx, const struct MkIdS *idP)
 Wait for a pipe-server to finish …
 
typedef void(* MqSetupF) (MQ_CTX const ctx)
 used to setup (initialize) a new thread/fork/process created by ccmqmsgque using the SysServer? style commands
 
typedef void(* 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(* MqSysSelectF) (int max, void *read, void *write, void *except, struct timeval *timeout)
 select syscall …
 
typedef enum MkErrorE(* 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(* 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(* 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(* 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(* MqFactoryDTorF) (MK_RT mkrt, MQ_CTX ctx, bool doFactoryCleanup, MQ_FCT const fct)
 type of a MqFactoryC destructor
 
typedef void(* MqFactoryDataFreeF) (MK_RT mkrt, MK_PTR *dataP)
 prototype for a free additional factory data function
 
typedef void(* MqFactoryDataCopyF) (MK_RT mkrt, MK_PTR *dataP)
 prototype for a copy additional factory data function
 
typedef MK_STRN MQ_TOK
 MqContextC - a char[4+1] or hex[8+1] string used to unique identify a service …
 
typedef MqTokenF MqServiceCallbackF
 MqContextC - the callback-function is used as a service-handle or as a event-handle
 
MqEnvC - type definition
typedef struct MqEnvS MqEnvCR
 instance-struct-reference same as struct MqEnvS, useable in a class-macro as: class##R
 
typedef const struct MqEnvS MqEnvCNR
 const instance-struct-reference same as const struct MqEnvS, useable in a class-macro as: class##R
 
MqErrorC - type definition
typedef struct MqErrorS MqErrorCR
 instance-struct-reference same as struct MqErrorS, useable in a class-macro as: class##R
 
typedef const struct MqErrorS MqErrorCNR
 const instance-struct-reference same as const struct MqErrorS, useable in a class-macro as: class##R
 
MqFactoryC - type definition
typedef struct MqFactoryS MqFactoryCR
 instance-struct-reference same as struct MqFactoryS, useable in a class-macro as: class##R
 
typedef const struct MqFactoryS MqFactoryCNR
 const instance-struct-reference same as const struct MqFactoryS, useable in a class-macro as: class##R
 
MqTypeCtxC - type definition
typedef struct MqTypeCtxS MqTypeCtxCR
 instance-struct-reference same as struct MqTypeCtxS, useable in a class-macro as: class##R
 
typedef const struct MqTypeCtxS MqTypeCtxCNR
 const instance-struct-reference same as const struct MqTypeCtxS, useable in a class-macro as: class##R
 
MqContextC - type definition
typedef struct MqContextS MqContextCR
 instance-struct-reference same as struct MqContextS, useable in a class-macro as: class##R
 
typedef const struct MqContextS MqContextCNR
 const instance-struct-reference same as const struct MqContextS, useable in a class-macro as: class##R
 
MqDumpC - type definition
typedef struct MqDumpS MqDumpCR
 instance-struct-reference same as struct MqDumpS, useable in a class-macro as: class##R
 
typedef const struct MqDumpS MqDumpCNR
 const instance-struct-reference same as const struct MqDumpS, useable in a class-macro as: class##R
 
MqRuntimeC - type definition
typedef struct MqRuntimeS MqRuntimeCR
 instance-struct-reference same as struct MqRuntimeS, useable in a class-macro as: class##R
 
typedef const struct MqRuntimeS MqRuntimeCNR
 const instance-struct-reference same as const struct MqRuntimeS, useable in a class-macro as: class##R
 

Functions

void MqConfigReset_RT (MK_RT mkrt, MQ_CTX const ctx)
 clean the libmqmsgque::MqContextS::config data
 
void MqConfigDup_RT (MK_RT mkrt, MQ_CTX const to, MQ_CTX const from)
 copy the libmqmsgque::MqContextS::config data
 
void MqSetupDup_RT (MK_RT mkrt, MQ_CTX const to, MQ_CTXN const from)
 copy the libmqmsgque::MqContextS::setup data …
 
void MqSetup (void)
 setup ccmqmsgque internal memory …
 
void MqCleanup (void)
 cleanup ccmqmsgque internal memory …
 
void MqConfigSetName_RT (MK_RT mkrt, MQ_CTX const ctx, MK_STRN data)
 set the libmqmsgque::MqConfigS::dispName value and cleanup old value
 
void MqConfigSetPrefixWithNoLock_RT (MK_RT mkrt, MQ_CTX const ctx, MK_STRN data)
 set the libmqmsgque::MqConfigS::dispPrefix with low-priority
 
void 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 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 MqConfigSetStorage_RT (MK_RT mkrt, MQ_CTX const ctx, MK_STRN data)
 set the Storage value and cleanup old value
 
void MqConfigSetAllTimeout (MQ_CTX const ctx, MK_TIME_T data)
 set the libmqmsgque::MqIoConfigS::timeout value
 
enum MkErrorE MqConfigSetAllDebug_RT (MK_RT mkrt, MQ_CTX const ctx, MK_I32 const data)
 set the MkRuntimeS::debug value
 
void MqConfigSetIsString (MQ_CTX const ctx, bool data)
 set the libmqmsgque::MqConfigS::native value 'S'string or 'L'owEndian or 'B'igEndian
 
enum MkErrorE MqConfigSetStartAs (MQ_CTX const ctx, enum MqStartE data)
 set the libmqmsgque::MqConfigS::startAs value
 
enum MkErrorE MqConfigSetStartAsString (MQ_CTX const ctx, MK_STRN data)
 set the libmqmsgque::MqConfigS::startAs value using string default, thread, fork or spawn
 
bool MqConfigCheckStartAs (MQ_CTX const ctx, enum MqStartE data)
 check if libmqmsgque::MqConfigS::startAs can be set to data
 
enum MkErrorE MqConfigSetIoUds_RT (MK_RT mkrt, MQ_CTX const ctx, MK_STRN file)
 configure a context to use a uds-client-server-link
 
enum MkErrorE 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 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 MqConfigSetIoPipe_RT (MK_RT mkrt, MQ_CTX const ctx, MQ_SOCK_HDL fh)
 set the pipe configuration data …
 
enum MkErrorE MqConfigSetDaemon_RT (MK_RT mkrt, MQ_CTX const ctx, MK_STRN pidfile)
 start the server-context as daemon …
 
void MqConfigSetBuffersize (MQ_CTX const ctx, MK_I32 data)
 set the libmqmsgque::MqIoConfigS::buffersize value
 
void MqConfigSetPkgsize (MQ_CTX const ctx, MK_I32 data)
 set the libmqmsgque::MqIoConfigS::pkgsize value
 
void MqConfigSetTimeout (MQ_CTX const ctx, MK_TIME_T data)
 set the libmqmsgque::MqIoConfigS::timeout value
 
void MqConfigSetIsServer (MQ_CTX const ctx, bool data)
 set the libmqmsgque::MqSetupS::isServer value
 
void MqConfigSetIdentFrom (MQ_CTX const ctx, enum MqIdentE data)
 set the libmqmsgque::MqConfigS::identFrom value
 
void MqConfigSetIgnoreExit (MQ_CTX const ctx, bool data)
 set the libmqmsgque::MqSetupS::ignoreExit value
 
void MqConfigSetServerSetup_RT (MK_RT mkrt, MQ_CTX const ctx, MqTokenF fCall, MK_CBP callback, MqDataFreeF fFree, MqDataCopyF fCopy)
 set the libmqmsgque::MqSetupS::ServerSetup
 
void MqConfigSetServerCleanup_RT (MK_RT mkrt, MQ_CTX const ctx, MqTokenF fCall, MK_CBP callback, MqDataFreeF fFree, MqDataCopyF fCopy)
 set the libmqmsgque::MqSetupS::ServerCleanup
 
void MqConfigSetBgError_RT (MK_RT mkrt, MQ_CTX const ctx, MqTokenF fCall, MK_CBP callback, MqDataFreeF fFree, MqDataCopyF fCopy)
 set the libmqmsgque::MqSetupS::BgError
 
void MqConfigSetEvent_RT (MK_RT mkrt, MQ_CTX const ctx, MqTokenF fCall, MK_CBP callback, MqDataFreeF fFree, MqDataCopyF fCopy)
 set the libmqmsgque::MqSetupS::Event
 
void 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 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 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 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 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 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 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 MqContextLogDebug (MQ_CTX const ctx)
 
void MqSysServerThreadMain (struct MqSysServerThreadMainS *data)
 initialize a new thread …
 
void MqErrorEnvReset (MQ_ERR const err)
 reset the libmqmsgque::MqErrorS::client_protect and the libmqmsgque::MqErrorS::server_protect
 
MK_PTR MqFactoryItemGetCreateData (MQ_FCTN const fct)
 helper function to return MqFactoryS::Create::data
 
MK_PTR MqFactoryItemGetDeleteData (MQ_FCTN const fct)
 helper function to return MqFactoryS::Delete::data
 
MK_STRN MqFactoryGetOriginalIdent (MQ_FCTN const fct)
 helper function to return MqFactoryS::originalIdent
 
MQ_FCT MqFactoryGet_RT (MK_RT mkrt, MK_STRN const ident)
 return the MqFactoryC
 
MQ_FCT MqFactoryGetCalled_RT (MK_RT mkrt, MK_STRN const ident)
 returns the MqFactoryC identified by ident
 
MQ_FCT MqFactoryGetCalledL_RT (MK_RT mkrt, MK_BFLN largs)
 returns the MqFactoryC identified as first argument in the largs MkBufferListC
 
void MqFactoryFree_RT (MK_RT mkrt, MQ_FCT const fct)
 free internal factory memory and call libmqmsgque::MqFactoryDTorS::fFree + libmqmsgque::MqFactoryCTorS::fFree
 
MQ_FCT 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 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 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 MqFactoryDefault_RT (MK_RT mkrt, MQ_FCT const fct)
 set the default-attribute to the factory
 
MQ_FCT MqFactoryInitial_RT (MK_RT mkrt, MQ_FCT const fct)
 set the initial-attribut to fct
 
MK_STRN MqFactoryDefaultIdent_RT (MK_RT mkrt)
 return the factory-identifier of the default MqFactoryC
 
MK_STRN MqFactoryInitialIdent_RT (MK_RT mkrt)
 return the factory-identifier of the initial MqFactoryC
 
enum MkErrorE 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 MqFactoryLogAll_RT (MK_RT mkrt, MK_STRN const callfunc)
 log all "factories" to stderr
 
static MQ_CTXT MqCtxTyp (MK_MNG mng)
 type-check and cast a managed-pointer into an libmqmsgque::MqTypeCtxS pointer or MK_NULL if not possible
 
void 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 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 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 MqContextCreate_RT (MK_RT mkrt, MK_TYP type, MQ_CTX const tmpl)
 create and initialize the MqContextC ...
 
MQ_CTX MqContextSetup_RT (MK_RT mkrt, MK_TYP type, MQ_CTX const tmpl, MQ_CTX *ctx_out)
 
enum MkErrorE MqContextErrorCopy_RT (MK_RT mkrt, MQ_CTXN const targetCtx, MQ_CTXN const sourceCtx)
 copy a MkErrorS from the sourceCtx to the targetCtx
 
enum MkErrorE 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 MqContextErrorFORMAT (MQ_CTXN const fmtobj)
 helper used to access MkErrorDEFAULT from MqContextC
 
static MQ_CTX MqGetRoot (MQ_CTX ctx)
 get the Root (toplevel initial context)
 
static MQ_CTXN MqGetRootN (MQ_CTXN ctx)
 (const) get the Root (toplevel initial context)
 
int 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 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 MqCheckForLeftOverArguments_RT (MK_RT mkrt, MQ_CTX const ctx, MK_BFLN args)
 check for left over arguments from parameter args of MqLinkCreate
 
MK_BUF MqContextGetBuffer_RT (MK_RT mkrt, MQ_CTX const ctx)
 get the libmqmsgque::MqContextS::ctxbuf object
 
enum MkErrorE 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 MqContextToString_RT (MK_RT mkrt, MQ_CTXN const ctx)
 String-Slot - returns the string representation of the inst
 
void MqEnvProtect_RT (MK_RT mkrt, MQ_CTX ctx)
 protect the service-environment
 
void MqEnvRestore (MQ_CTX ctx)
 restore the service-environment
 
enum MkErrorE 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 MqStorageOpen_RT (MK_RT mkrt, MQ_CTX const ctx, MK_STRN const storageFile)
 switch to a file-based-transaction-database
 
enum MkErrorE MqStorageClose_RT (MK_RT mkrt, MQ_CTX const ctx)
 close the storage. …
 
enum MkErrorE MqStorageExport_RT (MK_RT mkrt, MQ_CTX const ctx, MQ_LTR *ltid_out)
 export the read-data-package into the STORAGE
 
enum MkErrorE MqStorageImport_RT (MK_RT mkrt, MQ_CTX const ctx, MQ_LTR *transLIdP_inout)
 import the storage-package into the read-data-package
 
enum MkErrorE MqStorageIncrRef_RT (MK_RT mkrt, MQ_CTX const ctx, MQ_LTR transLId)
 increase the internal refCount lock of the database-entry
 
enum MkErrorE MqStorageDecrRef_RT (MK_RT mkrt, MQ_CTX const ctx, MQ_LTR transLId)
 decrease the internal refCount lock of the database-entry
 
enum MkErrorE MqStorageDelete_RT (MK_RT mkrt, MQ_CTX const ctx, MQ_LTR *transLIdP_inout)
 delete the storage-row identified by the transLIdP_inout
 
enum MkErrorE MqStorageCount_RT (MK_RT mkrt, MQ_CTX const ctx, MQ_LTR *cnt_out)
 count the number of storage-rows
 
enum MkErrorE 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 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 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 MqLinkShutdown_RT (MK_RT mkrt, MQ_CTX const ctx)
 shutdown the communication with a server
 
enum MkErrorE 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 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 MqLinkDelete_RT (MK_RT mkrt, MQ_CTX const ctx)
 close the client-server-link
 
bool MqLinkIsConnected (MQ_CTX const ctx)
 is the context connected? …
 
static MQ_CTX MqLinkGetParent (MQ_CTX const ctx)
 get the initial parent-context from a client/server link …
 
static bool MqLinkIsParent (MQ_CTX const ctx)
 is the context a parent-context? …
 
static MK_NUM MqLinkGetCtxId (MQ_CTX const ctx)
 get an identifier which is unique per parent-or-child-context
 
static MK_STRN MqLinkGetTargetIdent (MQ_CTX const ctx)
 get the ident of the link-target
 
enum MkErrorE 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 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 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 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 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 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 MqServiceIsTransaction (MQ_CTX const ctx)
 check if the ongoing-service-call belongs to a transaction …
 
MQ_TOK MqServiceTokenGet (MQ_CTX const ctx)
 in an ongoing-service-call get the current MqContextC_ServiceApi_Identifer
 
bool MqServiceTokenCheck (MQ_CTX const ctx, MQ_TOK const token)
 in an ongoing-service-call check if the current MqContextC_ServiceApi_Identifer is token
 
bool MqServiceTokenExists (MQ_CTX const ctx, MQ_TOK const token)
 check if the MqContextC_ServiceApi_Identifer token is defined as ctx service …
 
enum MkErrorE 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 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 MqServiceDelete_RT (MK_RT mkrt, MQ_CTX const ctx, MQ_TOK const token)
 delete a service. …
 
enum MkErrorE 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 MqReadL_END_RT (MK_RT mkrt, MQ_CTX const ctx)
 finish to extract a list-items from the read-data-package. …
 
enum MkErrorE MqReadT_START_RT (MK_RT mkrt, MQ_CTX const ctx)
 start to extract a longterm-transaction-item from the read-data-package. …
 
enum MkErrorE MqReadT_END_RT (MK_RT mkrt, MQ_CTX const ctx)
 finish to extract a longterm-transaction-item from the read-data-package. …
 
enum MkErrorE 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 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 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 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 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 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 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 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 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 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 MqReadLIST_RT (MK_RT mkrt, MQ_CTX const ctx, MK_NAT_LIST *const val_out)
 get all arguments as native list …
 
enum MkErrorE MqReadNEXT_RT (MK_RT mkrt, MQ_CTX const ctx, MK_NAT_OBJECT *const val_out)
 get the next argument as native object …
 
enum MkErrorE 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 MqReadHDL_RT (MK_RT mkrt, MQ_CTX const ctx, MK_HDL *const val_out)
 read the handle from the read-data-package
 
enum MkErrorE 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 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 MqReadStringR_RT (MK_RT mkrt, MQ_CTX const ctx, MkStringR *const val_out)
 read a MkStringR from the read-data-package
 
enum MkErrorE MqReadBinaryR_RT (MK_RT mkrt, MQ_CTX const ctx, MkBinaryR *const val_out)
 read a MkBinaryR from the read-data-package
 
void MqReadDbg_RT (MK_RT mkrt, MQ_CTX const ctx)
 
enum MkErrorE MqReadUndo_RT (MK_RT mkrt, MQ_CTX const ctx)
 undo the last MqContextC READ API function call …
 
MK_NUM MqReadGetNumItems (MQ_CTX const ctx)
 get the number of items left in the read-data-package
 
enum MkTypeE MqReadGetNextType (MQ_CTX const ctx)
 get the type (MkTypeE) of the next Item in the read-data-buffer or "0" if not available
 
bool MqReadItemExists (MQ_CTX const ctx)
 check if an item exists in the read-data-package
 
enum MqTransTypeE MqReadGetTransType (MQ_CTX const ctx)
 return the TransactionType identifer …
 
enum MqHandShakeE MqReadGetHandShake (MQ_CTX const ctx)
 return the HandShake identifer …
 
enum MkErrorE 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 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 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 MqSendSetHandShake (MQ_CTX const ctx, enum MqHandShakeE handShake)
 set the hand-shake of the send-data-package
 
enum MkErrorE 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 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 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 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 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 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 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 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 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 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 MqSendBinaryR_RT (MK_RT mkrt, MQ_CTX const ctx, MkBinaryR const val)
 append a MkBinaryR object to the send-data-package. …
 
enum MkErrorE 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 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 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 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 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 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 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 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 MqSendHDL_RT (MK_RT mkrt, MQ_CTX const ctx, MK_HDL const val)
 send the handle to the send-data-package
 
enum MkErrorE 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 MqSendSTART_RT (MK_RT mkrt, MQ_CTX const ctx)
 initialize the send-data-package. …
 
enum MkErrorE 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 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 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 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 MqSendSYNC_RT (MK_RT mkrt, MQ_CTX const ctx)
 garantee that all pending asynchronous-service-calls are processed. …
 
enum MkErrorE 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 MqSendRETURN_SUB_RT (MK_RT mkrt, MQ_CTX const ctx)
 return Sub-Data-Blocks required by MqSendEND_AND_SUB
 
enum MkErrorE MqSendERROR_RT (MK_RT mkrt, MQ_CTX const ctx)
 send the data from the MkErrorC to the link target . …
 
enum MkErrorE 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 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 MqSendT_START_RT (MK_RT mkrt, MQ_CTX const ctx)
 open a longterm-transaction-item
 
enum MkErrorE MqSendT_END_RT (MK_RT mkrt, MQ_CTX const ctx)
 closed a longterm-transaction-item
 
enum MkErrorE 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 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 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 MqSlaveCheck (MQ_CTXN const ctx, MQ_SLAVE_ID const id)
 check if slave-id is valid
 
enum MkErrorE 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 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 MqSlaveGetFilter_RT (MK_RT mkrt, MQ_CTX const ctx, MQ_CTX *ctx_out)
 get the filter-ctx or the master-ctx
 
static MQ_CTX MqSlaveGetMaster (MQ_CTX const ctx)
 opposite function of MqSlaveGetFilter
 
static bool MqSlaveIs (MQ_CTXN const ctx)
 is the context a slave-context ? …
 
enum MkErrorE MqSend_RT (MK_RT mkrt, MQ_CTX const ctx, MK_STRN cstr,...)
 user friendly replacement for the MqContextC_SendApi_C_API
 
enum MkErrorE 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 MqClassFactoryGet (MQ_CTXN const ctx)
 get the MqFactoryC used by the MqContextC
 
enum MkErrorE MqClassFactorySet_RT (MK_RT mkrt, MQ_CTX const ctx, MQ_FCT const item)
 link the MqContextC to a new MqFactoryC
 
enum MkErrorE MqClassIdentSet_RT (MK_RT mkrt, MQ_CTX const ctx, MK_STRN ident)
 link the MqContextC to a new MqFactoryC identified by ident
 
MK_STRN MqClassIdentGet (MQ_CTXN const ctx)
 get the application-identification
 
MK_STRN MqClassOriginalIdentGet (MQ_CTXN const ctx)
 get the libmqmsgque::MqFactoryS::originalIdent from the MqContextC
 
static bool MqConfigGetIsServer (MQ_CTX const ctx)
 does the context object is a server ?
 
static enum MqIdentE MqConfigGetIdentFrom (MQ_CTX const ctx)
 get the libmqmsgque::MqConfigS::identFrom
 
static bool 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 MqConfigGetIsString (MQ_CTX const ctx)
 does the context object is using the string-mode ?
 
static MK_STRN MqConfigGetName (MQ_CTXN const ctx)
 get the name of the context object
 
static MK_STRN MqConfigGetPrefix (MQ_CTXN const ctx)
 get the libmqmsgque::MqConfigS::dispPrefix
 
static MK_STRN MqConfigGetPostfix (MQ_CTXN const ctx)
 get the libmqmsgque::MqConfigS::dispPostfix
 
static MK_STRN MqConfigGetStorage (MQ_CTXN const ctx)
 get the storage of the context object
 
static MK_I32 MqConfigGetBuffersize (MQ_CTXN const ctx)
 get the minimum of the read/send buffersize of the socket
 
static MK_I32 MqConfigGetPkgsize (MQ_CTXN const ctx)
 get the maximun size of a BDY package
 
static MK_TIME_T MqConfigGetTimeout (MQ_CTXN const ctx)
 get the timeout value of the context object
 
static MK_STRN MqConfigGetIoUds (MQ_CTXN const ctx)
 return the libmqmsgque::MqIoUdsConfigS
 
enum MkErrorE 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 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 MqConfigGetIoPipe (MQ_CTX const ctx)
 return the libmqmsgque::MqIoPipeConfigS
 
static enum MqStartE MqConfigGetStartAs (MQ_CTX const ctx)
 return the libmqmsgque::MqConfigS::startAs value
 
static enum MqStatusIsEF MqConfigGetStatusIs (MQ_CTX const ctx)
 return the libmqmsgque::MqContextS::statusIs value
 
config_tMqConfigGetConfigFile (MQ_CTX const ctx)
 get the config-file handle used for libconfig API funtions
 
config_setting_tMqConfigGetConfigRoot (MQ_CTX const ctx)
 get the config-root handle used for libconfig API funtions
 
enum MkErrorE 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 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 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 MqDumpError_RT (MK_RT mkrt, MQ_CTX const error, MQ_DMP *const dumpP_inout)
 export the context->error into the dump-package
 
enum MkErrorE 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 MqDumpBinSet_RT (MK_RT mkrt, MkBinaryR data, MQ_DMP *dmp_out)
 create an MqDumpS object from binary data
 
MkBinaryR MqDumpBinGet (MQ_DMPN const dump)
 export the binary data from an MqDumpS object
 
MK_SIZE MqDumpSizeGet (MQ_DMPN const dump)
 report the binary data size from an MqDumpS object
 
void MqDumpTransLIdSet (MQ_DMP const dump, MQ_LTR transLId)
 set the libmqmsgque::MqEnvS::transLId
 
void MqDumpRmtTransLIdSet (MQ_DMP const dump, MQ_LTR rmtTransLId)
 set the libmqmsgque::MqEnvS::rmtTransLId
 
void MqDumpAllocSizeSet (MQ_DMP const dump, MK_SIZE allocsize)
 set the allocated buffer of the MqDumpC
 
MK_SIZE MqDumpAllocSizeGet (MQ_DMPN const dump)
 return the allocated buffer of the MqDumpC
 
enum MqHandShakeE MqDumpHandShakeGet (MQ_DMPN const dump)
 return the libmqmsgque::MqHandShakeE as character …
 
MK_STRN MqDumpTokenGet (MQ_DMPN const dump)
 return the MqContextC_ServiceApi_Identifer
 
MQ_RT MqRuntimeSetup (MK_RT const mkrt, MQ_RT const mqrt)
 initialize MqRuntimeRLS
 
void MqRuntimeCleanup (MK_RT mkrt, MQ_RT mqrt)
 cleanup MkRuntimeRLS
 
static MQ_RT MqRuntimeGet (MK_RT mkrt)
 inline from MqRuntimeSetup
 
void MqMain (void *code)
 Main entrypoint - start the application
 
MK_STR MqHelp (MK_STRN tool)
 write ccmqmsgque specific user-help to stderr
 
MK_STR MqHelpMsgque (void)
 return a page with the usage of all ccmqmsgque specific options
 
MK_BFL MqInitResetArg0 (void)
 Reset the process-startup-prefix argument to an empty list …
 
void MqInitSetArg0 (MK_BAC bfl)
 set the process startup-prefix argument to bfl
 
void MqInitSetArg0VA (MK_STRN arg0,...)
 set the process startup-prefix to a args
 
void MqInitSetArg0VAL (MK_STRN arg0, va_list var_list)
 set the process startup-prefix to var_list
 
MK_BFL MqInitGetArg0 (void)
 get the process startup-prefix argument
 
static MK_STRN MqLogServerOrClient (MQ_CTXN const ctx)
 is ctx a SERVER or a CLIENT ? …
 
static MK_STRN MqLogParentOrChild (MQ_CTXN ctx)
 is ctx a PARENT or a CHILD ? …
 
MqEnvC - signature check
static bool MqEnvCheck (MK_MNGN mng)
 check MqEnvS -> libmkkernel::MkObjectS::signature
 
static bool MqEnvCheckO (MK_OBJN obj)
 check MqEnvS -> libmkkernel::MkObjectS::signature
 
MqEnvC - cast from a defined or a undefined instance
static MQ_ENV MqEnv (MK_MNG mng)
 cast a unknown-object into an MqEnvS pointer or NULL if not possible
 
static MQ_ENVN MqEnvN (MK_MNGN mng)
 (const) cast a unknown-object into an MqEnvS pointer or NULL if not possible
 
MqErrorC - signature check
static bool MqErrCheck (MK_MNGN mng)
 check MqErrorS -> libmkkernel::MkObjectS::signature
 
static bool MqErrCheckO (MK_OBJN obj)
 check MqErrorS -> libmkkernel::MkObjectS::signature
 
MqErrorC - cast from a defined or a undefined instance
static MQ_ERR MqErr (MK_MNG mng)
 cast a unknown-object into an MqErrorS pointer or NULL if not possible
 
static MQ_ERRN MqErrN (MK_MNGN mng)
 (const) cast a unknown-object into an MqErrorS pointer or NULL if not possible
 
MqFactoryC - signature check
static bool MqFctCheck (MK_MNGN mng)
 check MqFactoryS -> libmkkernel::MkObjectS::signature
 
static bool MqFctCheckO (MK_OBJN obj)
 check MqFactoryS -> libmkkernel::MkObjectS::signature
 
MqFactoryC - cast from a defined or a undefined instance
static MQ_FCT MqFct (MK_MNG mng)
 cast a unknown-object into an MqFactoryS pointer or NULL if not possible
 
static MQ_FCTN 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
static MK_HDL 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 MqFactoryHandleResolve_RT (MK_RT mkrt, MK_HDL const netHdl)
 Handle-Resolve-Slot - return a MqFactoryC from netHdl or MK_NULL if invalid…
 
MqFactoryC - Misc - function - unspecified functions to perform different tasks
static MQ_FCT MqFactoryGetNull (void)
 Null-Slot - return a MqFactoryC typed NULL instance …
 
MqFactoryDelete
void MqFactoryDelete_RT (MK_RT mkrt, MQ_FCT fct)
 Destructor - delete a MqFactoryC instance …
 
MqFactoryLog
void 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 - signature check
static bool MqCtxTypCheck (MK_MNGN mng)
 check MqTypeCtxS -> libmkkernel::MkObjectS::signature
 
static bool MqCtxTypCheckO (MK_OBJN obj)
 check MqTypeCtxS -> libmkkernel::MkObjectS::signature
 
MqContextC - signature check
static bool MqCtxCheck (MK_MNGN mng)
 check MqContextS -> libmkkernel::MkObjectS::signature
 
static bool MqCtxCheckO (MK_OBJN obj)
 check MqContextS -> libmkkernel::MkObjectS::signature
 
MqContextC - cast from a defined or a undefined instance
static MQ_CTX MqCtx (MK_MNG mng)
 cast a unknown-object into an MqContextS pointer or NULL if not possible
 
static MQ_CTXN 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
static MK_HDL 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 MqContextHandleResolve_RT (MK_RT mkrt, MK_HDL const netHdl)
 Handle-Resolve-Slot - return a MqContextC from netHdl or MK_NULL if invalid…
 
MqContextC - Misc - function - unspecified functions to perform different tasks
static MQ_CTX MqContextGetNull (void)
 Null-Slot - return a MqContextC typed NULL instance …
 
MqContextDelete
void MqContextDelete_RT (MK_RT mkrt, MQ_CTX ctx)
 Destructor - delete a MqContextC instance …
 
MqEnvLog
void 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
 
MqStorageLog
enum MkErrorE MqStorageLog_RT (MK_RT mkrt, MQ_CTX const ctx, MK_STRN const callfunc)
 log the storage the status of the open transactions
 
MqServiceProxy

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

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

Parameters
[in]mkrtthe MkRuntimeS instance to work on - the runtime argument, used by MK_RT_CALL (C-only)
[in]ctxthe MqContextS instance to work on
[in]tokenthe MqContextC SERVICE API to identify the service
[in]idthe SlaveId to unique identify the master/slave link, the id < libmqmsgque::MQ_SLAVE_USER is internal.
Exceptions
MkExceptionC→ The default-exception from the Programming-Language-Micro-Kernel (PLMK)
enum MkErrorE 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 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 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 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 - signature check
static bool MqDmpCheck (MK_MNGN mng)
 check MqDumpS -> libmkkernel::MkObjectS::signature
 
static bool MqDmpCheckO (MK_OBJN obj)
 check MqDumpS -> libmkkernel::MkObjectS::signature
 
MqDumpC - cast from a defined or a undefined instance
static MQ_DMP MqDmp (MK_MNG mng)
 cast a unknown-object into an MqDumpS pointer or NULL if not possible
 
static MQ_DMPN 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
static MK_HDL 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 MqDumpHandleResolve_RT (MK_RT mkrt, MK_HDL const netHdl)
 Handle-Resolve-Slot - return a MqDumpC from netHdl or MK_NULL if invalid…
 
MqDumpC - Misc - function - unspecified functions to perform different tasks
static MQ_DMP MqDumpGetNull (void)
 Null-Slot - return a MqDumpC typed NULL instance …
 
MqDumpDelete
void MqDumpDelete_RT (MK_RT mkrt, MQ_DMP dmp)
 Destructor - delete a MqDumpC instance …
 
MqRuntimeC - signature check
static bool MqRtCheck (MK_MNGN mng)
 check MqRuntimeS -> libmkkernel::MkObjectS::signature
 
static bool MqRtCheckO (MK_OBJN obj)
 check MqRuntimeS -> libmkkernel::MkObjectS::signature
 
MqRuntimeC - cast from a defined or a undefined instance
static MQ_RT MqRt (MK_MNG mng)
 cast a unknown-object into an MqRuntimeS pointer or NULL if not possible
 
static MQ_RTN MqRtN (MK_MNGN mng)
 (const) cast a unknown-object into an MqRuntimeS pointer or NULL if not possible
 
MqRuntimeLog
void 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
 
MqContextC - Introspection - inline - access to all instances created by class starting with the last one
static MQ_CTX MqContextInstances_RT (MK_RT mkrt)
 get head-instance from linked-list of MqContextS type …
 
static MQ_CTX MqContextNext (MQ_CTX const ctx)
 get next instance from linked-list of MqContextS type
 
static MQ_CTX 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 MqDumpInstances_RT (MK_RT mkrt)
 get head-instance from linked-list of MqDumpS type …
 
static MQ_DMP MqDumpNext (MQ_DMP const dmp)
 get next instance from linked-list of MqDumpS type
 
static MQ_DMP 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 MqFactoryInstances_RT (MK_RT mkrt)
 get head-instance from linked-list of MqFactoryS type …
 
static MQ_FCT MqFactoryNext (MQ_FCT const fct)
 get next instance from linked-list of MqFactoryS type
 
static MQ_FCT MqFactoryPrev (MQ_FCT const fct)
 get previous instance from linked-list of MqFactoryS type
 

Variables

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

MqHandShakeE

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

MqTransTypeE

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

MqIdentE

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

MqStartE

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

MqStatusIsEF

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

MqFactoryE

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

MqIoComE

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

MqWaitOnEventE

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

MqSlaveE

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

Function Documentation

◆ MqRuntimeCleanup()

void libmqmsgque::MqRuntimeCleanup ( MK_RT mkrt,
MQ_RT mqrt )

cleanup MkRuntimeRLS

Do not call this function directly, because ccmqmsgque types will be cleared.

Only call this function via MqCleanup.

◆ MqRuntimeGet()

static MQ_RT libmqmsgque::MqRuntimeGet ( MK_RT mkrt)
inlinestatic

inline from MqRuntimeSetup

Definition at line 9439 of file LibMqMsgque_mq.h.

9439 {
9440 return MK_RT_REF.mkRtExtAry[MqRuntimeId] ? (MQ_RT)MK_RT_REF.mkRtExtAry[MqRuntimeId] :
9442}
#define MqRT
#define __MkCheckX(cls, x)
#define MK_RT_PTR
#define MK_RT_REF
MQ_RT MqRuntimeSetup(MK_RT const mkrt, MQ_RT const mqrt)
initialize MqRuntimeRLS
__thread struct MqRuntimeS MqRuntimeRLS
RLS.
size_t MqRuntimeId
identify the custom runtime
Extend the MkRuntimeS wie ccmqmsgque specific features …

◆ MqRuntimeLog_RT()

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

Parameters
[in]mkrtthe MkRuntimeS instance to work on - the runtime argument, used by MK_RT_CALL (C-only)
[in]mqrtthe MqRuntimeS instance to work on - the runtime argument, used by MQ_RT_CALL (C-only)
[in]fmtobjmanaged object used to format the log-message (default=MK_NULL → use default-format)
[in]debugthe debug level from MkRuntimeS::debug, use 0 <= debug <= 9 (default=0)
[in]callfunca user-defined postfix to identify the calling-function or the environment (default = name-of-function, MK_NULL = resolve-own-name)
[in]lvla user-defined prefix starting with "" for lvl=0 and increase with " " for lvl+1 (default=0)
See also
MkRuntimeLog0

◆ MqRuntimeSetup()

MQ_RT libmqmsgque::MqRuntimeSetup ( MK_RT const mkrt,
MQ_RT const mqrt )

initialize MqRuntimeRLS

Do not call this function directly, because if MqRuntimeRLS is already initialized, MqRuntimeCleanup will be called first and all ccmqmsgque types will be cleared.

Only call MqRuntimeGet to get the mqrt and use MqSetup to setup the MqRuntimeRLS.

+ Here is the caller graph for this function:

Variable Documentation

◆ MqRuntimeId

size_t libmqmsgque::MqRuntimeId
extern

identify the custom runtime

◆ MqRuntimeRLS

__thread struct MqRuntimeS libmqmsgque::MqRuntimeRLS
extern

RLS.