theLink 10.0
|
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 binary … More... | |
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-link … More... | |
struct | MqIoLoopConfigS |
Configure a context to use a loop-client-server-link … More... | |
struct | MqIoPipeConfigS |
configure a context to use a pipe-client-server-link … More... | |
struct | MqIoTcpConfigS |
configure a context to use a tcp-client-server-link … More... | |
struct | MqIoUdsConfigS |
configure a context to use a uds-client-server-link … More... | |
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 link … More... | |
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 MqContextC … More... | |
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 MqErrorS * | MQ_ERR |
class-shortcut for struct MqErrorS * , all shortcut using the XX_YYY syntax (only for public API) … | |
typedef const struct MqErrorS * | MQ_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 MqRuntimeS * | MQ_RT |
class-shortcut for struct MqRuntimeS * , all shortcut using the XX_YYY syntax (only for public API) … | |
typedef const struct MqRuntimeS * | MQ_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 MqTypeCtxS * | MQ_CTXTYP |
class-shortcut for struct MqTypeCtxS * , all shortcut using the XX_YYY syntax (only for public API) … | |
typedef const struct MqTypeCtxS * | MQ_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 MqFactoryS * | MQ_FCT |
class-shortcut for struct MqFactoryS * , all shortcut using the XX_YYY syntax (only for public API) … | |
typedef const struct MqFactoryS * | MQ_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 MqContextS * | MQ_CTX |
class-shortcut for struct MqContextS * , all shortcut using the XX_YYY syntax (only for public API) … | |
typedef const struct MqContextS * | MQ_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 MqDumpS * | MQ_DMP |
class-shortcut for struct MqDumpS * , all shortcut using the XX_YYY syntax (only for public API) … | |
typedef const struct MqDumpS * | MQ_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 MqEnvS * | MQ_ENV |
class-shortcut for struct MqEnvS * , all shortcut using the XX_YYY syntax (only for public API) … | |
typedef const struct MqEnvS * | MQ_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 MqTypeCtxS * | MQ_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_t * | MqConfigGetConfigFile (MQ_CTX const ctx) | ||||||||||||||
get the config-file handle used for libconfig API funtions | |||||||||||||||
config_setting_t * | MqConfigGetConfigRoot (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.
| |||||||||||||||
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 MkBufferListS * | MqInitArg0 |
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-call … More... | |
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 factory … More... | |
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 … | |
cleanup MkRuntimeRLS
Do not call this function directly, because ccmqmsgque types will be cleared.
Only call this function via MqCleanup.
inline from MqRuntimeSetup
Definition at line 9439 of file LibMqMsgque_mq.h.
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 …
[in] | mkrt | the MkRuntimeS instance to work on - the runtime argument, used by MK_RT_CALL (C-only) |
[in] | mqrt | the MqRuntimeS instance to work on - the runtime argument, used by MQ_RT_CALL (C-only) |
[in] | fmtobj | managed object used to format the log-message (default=MK_NULL → use default-format) |
[in] | debug | the debug level from MkRuntimeS::debug, use 0 <= debug <= 9 (default=0 ) |
[in] | callfunc | a user-defined postfix to identify the calling-function or the environment (default = name-of-function, MK_NULL = resolve-own-name) |
[in] | lvl | a user-defined prefix starting with "" for lvl=0 and increase with " " for lvl+1 (default=0 ) |
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.
|
extern |
identify the custom runtime
|
extern |
RLS.