123 MkErrorC_Check(ctx, errVal);
132 MkErrorC_Check(ctx, errVal);
148 MkErrorC_Check(ctx, errVal);
155 const MK_STRN ident_hdl = ident.c_str();
157 MkErrorC_Check(ctx, errVal);
183 MkErrorC_Check(ctx, errVal);
314 MkErrorC_Check(ctx, errVal);
321 const MK_STRN filename_hdl = filename.c_str();
323 MkErrorC_Check(ctx, errVal);
337 MkErrorC_Check(ctx, errVal);
338 std::tuple<MK_STRN,MK_STRN,MK_STRN,MK_STRN> __retVal__L = {host_out,port_out,myhost_out,myport_out};
357 if (callback_ptr == NULL) fCall = NULL;
367 if (callback_ptr == NULL) fCall = NULL;
377 if (callback_ptr == NULL) fCall = NULL;
387 if (callback_ptr == NULL) fCall = NULL;
397 if (callback_ptr == NULL) fCall = NULL;
407 if (callback_ptr == NULL) fCall = NULL;
417 if (callback_ptr == NULL) fCall = NULL;
427 if (callback_ptr == NULL) fCall = NULL;
437 if (callback_ptr == NULL) fCall = NULL;
447 if (callback_ptr == NULL) fCall = NULL;
457 if (callback_ptr == NULL) fCall = NULL;
467 if (callback_ptr == NULL) fCall = NULL;
509 MkErrorC_Check(ctx, errVal);
524 MkErrorC_Check(ctx, errVal);
531 const MK_STRN pidfile_hdl = pidfile.c_str();
533 MkErrorC_Check(ctx, errVal);
555 MkErrorC_Check(ctx, errVal);
563 MkErrorC_Check(ctx, errVal);
572 MkErrorC_Check(ctx, errVal);
581 MkErrorC_Check(ctx, errVal);
589 MkErrorC_Check(ctx, errVal);
596 const MK_STRN file_hdl = file.c_str();
598 MkErrorC_Check(ctx, errVal);
626 const MK_STRN data_hdl = data.c_str();
648 const MK_STRN data_hdl = data.c_str();
663 const MK_STRN data_hdl = data.c_str();
672 MkErrorC_Check(ctx, errVal);
680 MkErrorC_Check(ctx, errVal);
687 const MK_STRN data_hdl = data.c_str();
689 MkErrorC_Check(ctx, errVal);
703 const MK_STRN data_hdl = data.c_str();
806 MkErrorC_Check(ctx, errVal);
813 const MK_STRN cstr_hdl = cstr.c_str();
815 MkErrorC_Check(ctx, errVal);
842 MkErrorC_Check(ctx, errVal);
851 MkErrorC_Check(ctx, errVal);
860 MkErrorC_Check(ctx, errVal);
870 MkErrorC_Check(ctx, errVal);
880 MkErrorC_Check(ctx, errVal);
927 MkErrorC_Check(ctx, errVal);
948 if (callfunc == NULL) {callfunc = __builtin_FUNCTION();}
958 if (callfunc == NULL) {callfunc = __builtin_FUNCTION();}
968 if (callfunc == NULL) {callfunc = __builtin_FUNCTION();}
978 if (callfunc == NULL) {callfunc = __builtin_FUNCTION();}
988 if (callfunc == NULL) {callfunc = __builtin_FUNCTION();}
998 if (callfunc == NULL) {callfunc = __builtin_FUNCTION();}
1008 if (callfunc == NULL) {callfunc = __builtin_FUNCTION();}
1018 if (callfunc == NULL) {callfunc = __builtin_FUNCTION();}
1028 if (callfunc == NULL) {callfunc = __builtin_FUNCTION();}
1038 if (callfunc == NULL) {callfunc = __builtin_FUNCTION();}
1048 if (callfunc == NULL) {callfunc = __builtin_FUNCTION();}
1058 if (callfunc == NULL) {callfunc = __builtin_FUNCTION();}
1112 if (callline == -1) {callline = __builtin_LINE();}
1113 if (callfile == NULL) {callfile = __builtin_FILE();}
1114 if (callfunc == NULL) {callfunc = __builtin_FUNCTION();}
1115 MqExit(ctx, callfunc, callfile, callline);
1123 MkErrorC_Check(ctx, errVal);
1142 MkErrorC_Check(sourceCtx, errVal);
1152 MkErrorC_Check(sourceCtx, errVal);
1161 MkErrorC_Check(sourceCtx, errVal);
1170 MkErrorC_Check(sourceCtx, errVal);
1188 MkErrorC_Check(ctx, errVal);
1200 MkErrorC_Check(ctx, errVal);
1210 MkErrorC_Check(ctx, errVal);
1223 MK_BNP val_out = std::make_pair(val_out_ref.
size,val_out_ref.
data);
1233 MkErrorC_Check(ctx, errVal);
1234 return val_out != 0;
1244 MK_BNP val_out = std::make_pair(val_out_ref.
size,val_out_ref.
data);
1254 MkErrorC_Check(ctx, errVal);
1264 MkErrorC_Check(ctx, errVal);
1274 MkErrorC_Check(ctx, errVal);
1284 MkErrorC_Check(ctx, errVal);
1294 MkErrorC_Check(ctx, errVal);
1304 MkErrorC_Check(ctx, errVal);
1314 MkErrorC_Check(ctx, errVal);
1315 return (
MK_I8)val_out;
1327 MkErrorC_Check(ctx, errVal);
1340 MkErrorC_Check(ctx, errVal);
1351 const std::string& val_out = std::string(val_out_ref.
ptr,val_out_ref.
len);
1369 MkErrorC_Check(ctx, errVal);
1378 MkErrorC_Check(ctx, errVal);
1387 MkErrorC_Check(ctx, errVal);
1395 MkErrorC_Check(ctx, errVal);
1403 MkErrorC_Check(ctx, errVal);
1451 MkErrorC_Check(ctx, errVal);
1469 MkErrorC_Check(ctx, errVal);
1480 MkErrorC_Check(ctx, errVal);
1487 const MK_STRN route_hdl = route.c_str();
1488 const MK_STRN service_hdl = service.c_str();
1490 MkErrorC_Check(ctx, errVal);
1498 MkErrorC_Check(ctx, errVal);
1505 const MK_STRN route_hdl = route.c_str();
1506 const MK_STRN service_hdl = service.c_str();
1508 MkErrorC_Check(ctx, errVal);
1516 static __thread
MK_NUM szret = 0;
1518 if (__retVal__L.
size+1 > szret) {
1519 szret=__retVal__L.
size*2+1;
1523 for (num=0; num<__retVal__L.
size; num++) {
1534 const MK_STRN ident_hdl = ident.c_str();
1536 static __thread
MK_NUM szret = 0;
1538 if (__retVal__L.
size+1 > szret) {
1539 szret=__retVal__L.
size*2+1;
1543 for (num=0; num<__retVal__L.
size; num++) {
1556 MkErrorC_Check(ctx, errVal);
1565 MkErrorC_Check(ctx, errVal);
1572 const MK_STRN service_hdl = service.c_str();
1575 MkErrorC_Check(ctx, errVal);
1582 const MK_STRN service_hdl = service.c_str();
1585 MkErrorC_Check(ctx, errVal);
1596 MkErrorC_Check(ctx, errVal);
1615 MkErrorC_Check(ctx, errVal);
1624 MkErrorC_Check(ctx, errVal);
1633 MkErrorC_Check(ctx, errVal);
1641 MkErrorC_Check(ctx, errVal);
1650 MkErrorC_Check(ctx, errVal);
1659 MkErrorC_Check(ctx, errVal);
1668 MkErrorC_Check(ctx, errVal);
1677 MkErrorC_Check(ctx, errVal);
1686 MkErrorC_Check(ctx, errVal);
1694 MkErrorC_Check(ctx, errVal);
1702 MkErrorC_Check(ctx, errVal);
1710 MkErrorC_Check(ctx, errVal);
1718 MkErrorC_Check(ctx, errVal);
1726 MkErrorC_Check(ctx, errVal);
1734 MkErrorC_Check(ctx, errVal);
1742 MkErrorC_Check(ctx, errVal);
1750 MkErrorC_Check(ctx, errVal);
1758 MkErrorC_Check(ctx, errVal);
1767 MkErrorC_Check(ctx, errVal);
1776 MkErrorC_Check(ctx, errVal);
1784 MkErrorC_Check(ctx, errVal);
1791 const MK_STRN val_hdl = val.c_str();
1793 MkErrorC_Check(ctx, errVal);
1802 MkErrorC_Check(ctx, errVal);
1810 va_start (ap, printfmt);
1813 MkErrorC_Check(ctx, errVal);
1821 MkErrorC_Check(ctx, errVal);
1838 MkErrorC_Check(ctx, errVal);
1845 const MK_STRN token_hdl = token.c_str();
1847 MkErrorC_Check(ctx, errVal);
1856 MkErrorC_Check(ctx, errVal);
1863 const MK_STRN token_hdl = token.c_str();
1866 MkErrorC_Check(ctx, errVal);
1875 MkErrorC_Check(ctx, errVal);
1882 const MK_STRN token_hdl = token.c_str();
1885 MkErrorC_Check(ctx, errVal);
1894 MkErrorC_Check(ctx, errVal);
1901 const MK_STRN token_hdl = token.c_str();
1904 MkErrorC_Check(ctx, errVal);
1913 MkErrorC_Check(ctx, errVal);
1920 const MK_STRN token_hdl = token.c_str();
1923 MkErrorC_Check(ctx, errVal);
1932 MkErrorC_Check(ctx, errVal);
1939 const MK_STRN token_hdl = token.c_str();
1942 MkErrorC_Check(ctx, errVal);
1951 MkErrorC_Check(ctx, errVal);
1958 const MK_STRN token_hdl = token.c_str();
1961 MkErrorC_Check(ctx, errVal);
1969 MkErrorC_Check(ctx, errVal);
1976 const MK_STRN token_hdl = token.c_str();
1977 const MK_STRN callback_hdl = callback.c_str();
1979 MkErrorC_Check(ctx, errVal);
1987 MkErrorC_Check(ctx, errVal);
1994 const MK_STRN token_hdl = token.c_str();
1996 MkErrorC_Check(ctx, errVal);
2004 MkErrorC_Check(ctx, errVal);
2012 MkErrorC_Check(ctx, errVal);
2029 MkErrorC_Check(ctx, errVal);
2037 MkErrorC_Check(ctx, errVal);
2045 MkErrorC_Check(ctx, errVal);
2053 MkErrorC_Check(ctx, errVal);
2070 MkErrorC_Check(ctx, errVal);
2078 MkErrorC_Check(ctx, errVal);
2086 MkErrorC_Check(ctx, errVal);
2104 MkErrorC_Check(ctx, errVal);
2111 const MK_STRN token_hdl = token.c_str();
2114 MkErrorC_Check(ctx, errVal);
2123 MkErrorC_Check(ctx, errVal);
2130 const MK_STRN token_hdl = token.c_str();
2133 MkErrorC_Check(ctx, errVal);
2142 MkErrorC_Check(ctx, errVal);
2149 const MK_STRN token_hdl = token.c_str();
2152 MkErrorC_Check(ctx, errVal);
2160 MkErrorC_Check(ctx, errVal);
2167 const MK_STRN token_hdl = token.c_str();
2169 MkErrorC_Check(ctx, errVal);
2185 MkErrorC_Check(ctx, errVal);
2192 const MK_STRN token_hdl = token.c_str();
2194 MkErrorC_Check(ctx, errVal);
2203 MkErrorC_Check(ctx, errVal);
2212 MkErrorC_Check(ctx, errVal);
2219 const MK_STRN token_hdl = token.c_str();
2222 MkErrorC_Check(ctx, errVal);
2229 const MK_STRN token_hdl = token.c_str();
2232 MkErrorC_Check(ctx, errVal);
2257 const MK_STRN token_hdl = token.c_str();
2267 const MK_STRN token_hdl = token.c_str();
2278 MkErrorC_Check(ctx, errVal);
2285 const MK_STRN token_hdl = token.c_str();
2286 const MK_STRN ident_hdl = ident.c_str();
2288 MkErrorC_Check(ctx, errVal);
2296 MkErrorC_Check(ctx, errVal);
2303 const MK_STRN token_hdl = token.c_str();
2305 MkErrorC_Check(ctx, errVal);
2320 const MK_STRN token_hdl = token.c_str();
2337 const MK_STRN token_hdl = token.c_str();
2375 MkErrorC_Check(ctx, errVal);
2385 MkErrorC_Check(ctx, errVal);
2395 MkErrorC_Check(ctx, errVal);
2415 MkErrorC_Check(ctx, errVal);
2424 MkErrorC_Check(ctx, errVal);
2432 MkErrorC_Check(ctx, errVal);
2449 MkErrorC_Check(ctx, errVal);
2465 MQ_LTR transLIdP_inout_val = transLIdP_inout == NULL ? 0 : (
MQ_LTR)(*transLIdP_inout);
2467 if (transLIdP_inout != NULL) {*transLIdP_inout = (
MQ_LTR)(transLIdP_inout_val);}
2468 MkErrorC_Check(ctx, errVal);
2469 return transLIdP_inout_val;
2476 MQ_LTR transLIdP_inout_val = transLIdP_inout == NULL ? 0 : (
MQ_LTR)(*transLIdP_inout);
2478 if (transLIdP_inout != NULL) {*transLIdP_inout = (
MQ_LTR)(transLIdP_inout_val);}
2479 MkErrorC_Check(ctx, errVal);
2480 return transLIdP_inout_val;
2490 MkErrorC_Check(ctx, errVal);
2498 MkErrorC_Check(ctx, errVal);
2506 MkErrorC_Check(ctx, errVal);
2513 if (callfunc == NULL) {callfunc = __builtin_FUNCTION();}
2515 MkErrorC_Check(ctx, errVal);
2523 MkErrorC_Check(ctx, errVal);
2530 const MK_STRN storageFile_hdl = storageFile.c_str();
2532 MkErrorC_Check(ctx, errVal);
2543 MkErrorC_Check(ctx, errVal);
2553 MkErrorC_Check(ctx, errVal);
2563 MkErrorC_Check(ctx, errVal);
2574 MkErrorC_Check(ctx, errVal);
2593 if (__retVal__L == NULL) {
2596 return (
MK_OBJ)__retVal__L;
2604 if (__retVal__L == NULL) {
2621 if (__retVal__L == NULL) {
2624 return (
MK_OBJ)__retVal__L;
MqCall_cc.hh - 17 Nov 2024 - aotto1968.
implements the ccmqmsgque API object: ConfigSetBgError
PUBLIC data structure for the ccmqmsgque-specific-data → C-API: libmqmsgque::MqContextS
MqDumpC - the class known as dmp or dump is used to export a ccmqmsgque data package as binary … ...
implements the ccmqmsgque API object: ConfigSetEvent
data used to define a factory → C-API: libmqmsgque::MqFactoryS
implements the ccmqmsgque API object: ConfigSetServerCleanup
implements the ccmqmsgque API object: ConfigSetServerSetup
static MkBufferC * MkBufferC_ObjNew(MK_RT_ARGS MK_BUF hdl)
MK_BUF getBUF__null_allow() const
static MkBufferListC * MkBufferListC_ObjNew(MK_RT_ARGS MK_BFL hdl)
MK_BFL getBFL__null_allow() const
static MkErrorC * MkErrorC_ObjNew(MK_RT_ARGS MK_ERR hdl)
static MkBinaryR MkBinaryCreate(MK_SIZE size, MK_BINN data)
static MkStringR MkStringCreate(MK_NUM len, MK_STRN str)
void ErrorCheck(enum MkErrorE err, MK_STRN const caller=__builtin_FUNCTION(), MK_I32 const line=__builtin_LINE()) const
MK_OBJN getOBJN__null_allow() const
MK_PTR MkSysRealloc(MK_OBJN fmtobj, MK_PTR const buf, size_t const size)
static MK_I32 MkRuntimeGetDebug(void)
MQ_CTX getCTX() const
return the LibMsgqueObject from current MqContextC instance
MqTokenCCB MqServerSetupCCB
MQ_CTXN getCTXN__null_allow() const
(const) return the LibMsgqueObject from current MqContextC instance
MQ_CTX getCTX__null_allow() const
return the LibMsgqueObject from current MqContextC instance
MqTokenCCB MqServerCleanupCCB
MqTokenICB MqServerSetupICB
MQ_CTXN getCTXN() const
(const) return the LibMsgqueObject from current MqContextC instance
static MqContextC * MqContextC_ObjNew(MK_RT_ARGS MQ_CTX hdl)
return MqContextC from LibMsgqueObject
MqTokenICB MqServerCleanupICB
static MK_PTR MqContextC_selfCreate(MK_RT_ARGS MK_OBJ obj, MK_PTR const env)
static MqContextC * MqContextC_ObjCreate(MK_RT_ARGS MQ_CTX hdl)
static MK_ERR MqContextErrorFORMAT(MQ_CTXN const fmtobj)
helper used to access MkErrorDEFAULT from MqContextC
void ClassIdentSet(MK_STRN ident)
C++: ctx.ClassIdentSet(MK_STRN ident) → C-API link the MqContextC to a new MqFactoryC identifie...
void ClassFactorySet(MqFactoryC *item)
C++: ctx.ClassFactorySet(MqFactoryC* item) → C-API link the MqContextC to a new MqFactoryC
MK_STRN ClassOriginalIdentGet() const
C++: MK_STRN ctx.ClassOriginalIdentGet() → C-API get the libmqmsgque::MqFactoryS::originalIdent...
MK_STRN ClassIdentGet() const
C++: MK_STRN ctx.ClassIdentGet() → C-API get the application-identification …
MqFactoryC * ClassFactoryGet() const
C++: MqFactoryC* ctx.ClassFactoryGet() → C-API get the MqFactoryC used by the MqContextC
#define MqClassFactorySet(...)
MK_STRN MqClassIdentGet(MQ_CTXN const ctx)
get the application-identification …
#define MqClassIdentSet(...)
MQ_FCT const MqClassFactoryGet(MQ_CTXN const ctx)
get the MqFactoryC used by the MqContextC
MK_STRN MqClassOriginalIdentGet(MQ_CTXN const ctx)
get the libmqmsgque::MqFactoryS::originalIdent from the MqContextC
static MqContextC * HandleResolve(MK_HDL netHdl)
C++: [static] MqContextC* MqContextC::HandleResolve(MK_HDL netHdl) → C-API Handle-Resolve-Slot -...
MqContextC * Prev()
C++: MqContextC* ctx.Prev() → C-API get previous instance from linked-list of MqContextS type
static MqContextC * Instances()
C++: [static] MqContextC* MqContextC::Instances() → C-API get head-instance from linked-list of ...
MqContextC * Next()
C++: MqContextC* ctx.Next() → C-API get next instance from linked-list of MqContextS type
static MqContextC * GetNull()
C++: [static] MqContextC* MqContextC::GetNull() → C-API Null-Slot - return a MqContextC typed NU...
#define MqContextHandleResolve(...)
static MQ_CTX MqContextGetNull(void)
Null-Slot - return a MqContextC typed NULL instance …
#define MqContextInstances()
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
MqStatusIsEF ConfigGetStatusIs()
C++: MqStatusIsEF ctx.ConfigGetStatusIs() → C-API return the libmqmsgque::MqContextS::statusIs ...
MqStartE ConfigGetStartAs()
C++: MqStartE ctx.ConfigGetStartAs() → C-API return the libmqmsgque::MqConfigS::startAs value
MK_STRN ConfigGetStorage() const
C++: MK_STRN ctx.ConfigGetStorage() → C-API get the storage of the context object
MK_I32 ConfigGetPkgsize() const
C++: MK_I32 ctx.ConfigGetPkgsize() → C-API get the maximun size of a BDY package
MQ_SOCK_HDL ConfigGetIoPipe()
C++: MQ_SOCK_HDL ctx.ConfigGetIoPipe() → C-API return the libmqmsgque::MqIoPipeConfigS
MK_TIME_T ConfigGetTimeout() const
C++: MK_TIME_T ctx.ConfigGetTimeout() → C-API get the timeout value of the context object
MkBufferListC * ConfigGetIoTcpL()
C++: MkBufferListC* ctx.ConfigGetIoTcpL() → C-API get the configuration-data of the tcp-client-...
void ConfigSetConfigFile(MK_STRN filename)
C++: ctx.ConfigSetConfigFile(MK_STRN filename) → C-API set the config-file and parse for well-k...
MK_I32 ConfigGetBuffersize() const
C++: MK_I32 ctx.ConfigGetBuffersize() → C-API get the minimum of the read/send buffersize of th...
MK_BOOL ConfigGetIsParent()
C++: MK_BOOL ctx.ConfigGetIsParent() → C-API does the context object is a parent ?...
MK_STRN ConfigGetPostfix() const
C++: MK_STRN ctx.ConfigGetPostfix() → C-API get the libmqmsgque::MqConfigS::dispPostfix
MK_BOOL ConfigGetIsString()
C++: MK_BOOL ctx.ConfigGetIsString() → C-API does the context object is using the string-mode ?
MK_STRN ConfigGetName() const
C++: MK_STRN ctx.ConfigGetName() → C-API get the name of the context object
MqIdentE ConfigGetIdentFrom()
C++: MqIdentE ctx.ConfigGetIdentFrom() → C-API get the libmqmsgque::MqConfigS::identFrom
std::tuple< MK_STRN, MK_STRN, MK_STRN, MK_STRN > ConfigGetIoTcp()
C++: {host:MK_STRN port:MK_STRN myhost:MK_STRN myport:MK_STRN} ctx.ConfigGetIoTcp() → C-API get...
MK_BOOL ConfigGetIsServer()
C++: MK_BOOL ctx.ConfigGetIsServer() → C-API does the context object is a server ?
MK_STRN ConfigGetPrefix() const
C++: MK_STRN ctx.ConfigGetPrefix() → C-API get the libmqmsgque::MqConfigS::dispPrefix
MK_STRN ConfigGetIoUds() const
C++: MK_STRN ctx.ConfigGetIoUds() → C-API return the libmqmsgque::MqIoUdsConfigS
static bool MqConfigGetIsString(MQ_CTX const ctx)
does the context object is using the string-mode ?
static bool MqConfigGetIsParent(MQ_CTX const ctx)
does the context object is a parent ? An objext is a parent id the libmqmsgque::MqConfigS::parent att...
static bool MqConfigGetIsServer(MQ_CTX const ctx)
does the context object is a server ?
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_TIME_T MqConfigGetTimeout(MQ_CTXN const ctx)
get the timeout value of the context object
#define MqConfigSetConfigFile(...)
static MQ_SOCK_HDL MqConfigGetIoPipe(MQ_CTX const ctx)
return the libmqmsgque::MqIoPipeConfigS
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 …
static enum MqStartE MqConfigGetStartAs(MQ_CTX const ctx)
return the libmqmsgque::MqConfigS::startAs value
static MK_STRN MqConfigGetName(MQ_CTXN const ctx)
get the name of the context object
static enum MqIdentE MqConfigGetIdentFrom(MQ_CTX const ctx)
get the libmqmsgque::MqConfigS::identFrom
static MK_STRN MqConfigGetIoUds(MQ_CTXN const ctx)
return the libmqmsgque::MqIoUdsConfigS
static MK_I32 MqConfigGetPkgsize(MQ_CTXN const ctx)
get the maximun size of a BDY package
static MK_I32 MqConfigGetBuffersize(MQ_CTXN const ctx)
get the minimum of the read/send buffersize of the socket
static enum MqStatusIsEF MqConfigGetStatusIs(MQ_CTX const ctx)
return the libmqmsgque::MqContextS::statusIs value
#define MqConfigGetIoTcpL(...)
static MK_STRN MqConfigGetPrefix(MQ_CTXN const ctx)
get the libmqmsgque::MqConfigS::dispPrefix
void ConfigSetServerCleanup(MqServerCleanupCCB callback=NULL)
C++: ctx.ConfigSetServerCleanup(MqServerCleanupICB MqServerCleanupCCB MqServerCleanupIF* callback = ...
void ConfigSetServerSetup(MqServerSetupCCB callback=NULL)
C++: ctx.ConfigSetServerSetup(MqServerSetupICB MqServerSetupCCB MqServerSetupIF* callback = NULL) →...
void ConfigSetBgError(MqBgErrorCCB callback=NULL)
C++: ctx.ConfigSetBgError(MqBgErrorICB MqBgErrorCCB MqBgErrorIF* callback = NULL) → C-API set t...
void ConfigSetEvent(MqEventCCB callback=NULL)
C++: ctx.ConfigSetEvent(MqEventICB MqEventCCB MqEventIF* callback = NULL) → C-API set the libmq...
#define MqConfigSetBgError(...)
#define MqConfigSetServerSetup(...)
#define MqConfigSetServerCleanup(...)
#define MqConfigSetEvent(...)
void ConfigReset()
C++: ctx.ConfigReset() → C-API clean the libmqmsgque::MqContextS::config data
#define MqConfigReset(...)
void ConfigSetBuffersize(MK_I32 data)
C++: ctx.ConfigSetBuffersize(MK_I32 data) → C-API set the libmqmsgque::MqIoConfigS::buffersize ...
void ConfigSetPrefix(MK_STRN data)
C++: ctx.ConfigSetPrefix(MK_STRN data) → C-API set the server-part (1) of the application-ide...
MK_BOOL ConfigCheckStartAs(MqStartE data)
C++: MK_BOOL ctx.ConfigCheckStartAs(MqStartE data) → C-API check if libmqmsgque::MqConfigS::sta...
void ConfigSetPostfix(MK_STRN data)
C++: ctx.ConfigSetPostfix(MK_STRN data) → C-API set the client-part (2) of the application-id...
void ConfigSetIgnoreExit(MK_BOOL data)
C++: ctx.ConfigSetIgnoreExit(MK_BOOL data) → C-API set the libmqmsgque::MqSetupS::ignoreExit va...
void ConfigSetIdentFrom(MqIdentE data)
C++: ctx.ConfigSetIdentFrom(MqIdentE data) → C-API set the libmqmsgque::MqConfigS::identFrom va...
void ConfigSetStartAsString(MK_STRN data)
C++: ctx.ConfigSetStartAsString(MK_STRN data) → C-API set the libmqmsgque::MqConfigS::startAs v...
void ConfigSetAllDebug(MK_I32 data)
C++: ctx.ConfigSetAllDebug(MK_I32 data) → C-API set the MkRuntimeS::debug value
void ConfigSetStartAs(MqStartE data)
C++: ctx.ConfigSetStartAs(MqStartE data) → C-API set the libmqmsgque::MqConfigS::startAs value
void ConfigSetDaemon(MK_STRN pidfile)
C++: ctx.ConfigSetDaemon(MK_STRN pidfile) → C-API start the server-context as daemon …
void ConfigSetPkgsize(MK_I32 data)
C++: ctx.ConfigSetPkgsize(MK_I32 data) → C-API set the libmqmsgque::MqIoConfigS::pkgsize value
void ConfigSetStorage(MK_STRN data)
C++: ctx.ConfigSetStorage(MK_STRN data) → C-API set the Storage value and cleanup old value
void ConfigSetIsString(MK_BOOL data)
C++: ctx.ConfigSetIsString(MK_BOOL data) → C-API set the libmqmsgque::MqConfigS::native value '...
void ConfigSetName(MK_STRN data)
C++: ctx.ConfigSetName(MK_STRN data) → C-API set the libmqmsgque::MqConfigS::dispName value and...
void ConfigSetIoTcp(MK_STRN host=NULL, MK_STRN port=NULL, MK_STRN myhost=NULL, MK_STRN myport=NULL)
C++: ctx.ConfigSetIoTcp(MK_STRN host = NULL, MK_STRN port = NULL, MK_STRN myhost = NULL,...
void ConfigSetIoUds(MK_STRN file)
C++: ctx.ConfigSetIoUds(MK_STRN file) → C-API configure a context to use a uds-client-server-...
void ConfigSetTimeout(MK_TIME_T data)
C++: ctx.ConfigSetTimeout(MK_TIME_T data) → C-API set the libmqmsgque::MqIoConfigS::timeout val...
void ConfigSetIoPipe(MQ_SOCK_HDL fh)
C++: ctx.ConfigSetIoPipe(MQ_SOCK_HDL fh) → C-API set the pipe configuration data …
void ConfigSetIsServer(MK_BOOL data)
C++: ctx.ConfigSetIsServer(MK_BOOL data) → C-API set the libmqmsgque::MqSetupS::isServer value
#define MqConfigSetDaemon(...)
void MqConfigSetIsServer(MQ_CTX const ctx, bool data)
set the libmqmsgque::MqSetupS::isServer 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
#define MqConfigSetPrefix(...)
void MqConfigSetBuffersize(MQ_CTX const ctx, MK_I32 data)
set the libmqmsgque::MqIoConfigS::buffersize value
void MqConfigSetIgnoreExit(MQ_CTX const ctx, bool data)
set the libmqmsgque::MqSetupS::ignoreExit value
#define MqConfigSetIoPipe(...)
#define MqConfigSetIoTcp(...)
void MqConfigSetIsString(MQ_CTX const ctx, bool data)
set the libmqmsgque::MqConfigS::native value 'S'string or 'L'owEndian or 'B'igEndian
#define MqConfigSetPostfix(...)
#define MqConfigSetName(...)
void MqConfigSetTimeout(MQ_CTX const ctx, MK_TIME_T data)
set the libmqmsgque::MqIoConfigS::timeout value
void MqConfigSetIdentFrom(MQ_CTX const ctx, enum MqIdentE data)
set the libmqmsgque::MqConfigS::identFrom value
#define MqConfigSetIoUds(...)
enum MkErrorE MqConfigSetStartAs(MQ_CTX const ctx, enum MqStartE data)
set the libmqmsgque::MqConfigS::startAs value
void MqConfigSetPkgsize(MQ_CTX const ctx, MK_I32 data)
set the libmqmsgque::MqIoConfigS::pkgsize value
#define MqConfigSetAllDebug(...)
#define MqConfigSetIoTcpL(...)
#define MqConfigSetStorage(...)
void EnvProtect()
C++: ctx.EnvProtect() → C-API protect the service-environment
void EnvRestore()
C++: ctx.EnvRestore() → C-API restore the service-environment
#define MqEnvProtect(...)
void MqEnvRestore(MQ_CTX ctx)
restore the service-environment
MkErrorC * ErrorFORMAT() const
C++: MkErrorC* fmtobj.ErrorFORMAT() → C-API helper used to access MkErrorDEFAULT from MqContext...
MkErrorE ErrorCopy(const MqContextC *sourceCtx) const
C++: MkErrorE targetCtx.ErrorCopy(const MqContextC* sourceCtx) → C-API copy a MkErrorS from the...
MkErrorE ErrorMove(const MqContextC *sourceCtx) const
C++: MkErrorE targetCtx.ErrorMove(const MqContextC* sourceCtx) → C-API move a MkErrorS from the...
#define MqContextErrorMove(...)
#define MqContextErrorCopy(...)
void SendVL2(MK_STRN cstr, va_list var_list)
C++: ctx.SendVL2(MK_STRN cstr, va_list var_list) → C-API A version of MqSend with va_list suppo...
void LinkCreate(MkBufferListC *args=NULL)
C++: ctx.LinkCreate(MkBufferListC* args = NULL) → C-API make ctx to a parent-context and setup ...
MK_BOOL LinkIsParent()
C++: MK_BOOL ctx.LinkIsParent() → C-API is the context a parent-context? …
void LinkDelete()
C++: ctx.LinkDelete() → C-API close the client-server-link …
void LinkShutdown()
C++: ctx.LinkShutdown() → C-API shutdown the communication with a server
MK_STRN LinkGetTargetIdent()
C++: MK_STRN ctx.LinkGetTargetIdent() → C-API get the ident of the link-target …
MK_BOOL LinkIsConnected()
C++: MK_BOOL ctx.LinkIsConnected() → C-API is the context connected? …
MqContextC * LinkGetParent()
C++: MqContextC* ctx.LinkGetParent() → C-API get the initial parent-context from a client/serve...
void LinkConnect()
C++: ctx.LinkConnect() → C-API re-connect a client-server-link after a server crash or a networ...
MK_NUM LinkGetCtxId()
C++: MK_NUM ctx.LinkGetCtxId() → C-API get an identifier which is unique per parent-or-child-co...
void LinkCreateChild(MqContextC *parent, MkBufferListC *args=NULL)
C++: ctx.LinkCreateChild(MqContextC* parent, MkBufferListC* args = NULL) → C-API make a context...
#define MqLinkShutdown(...)
#define MqLinkCreateChild(...)
#define MqLinkDelete(...)
#define MqLinkCreate(...)
static MQ_CTX MqLinkGetParent(MQ_CTX const ctx)
get the initial parent-context from a client/server link …
#define MqLinkConnect(...)
static MK_STRN MqLinkGetTargetIdent(MQ_CTX const ctx)
get the ident of the link-target …
static MK_NUM MqLinkGetCtxId(MQ_CTX const ctx)
get an identifier which is unique per parent-or-child-context …
bool MqLinkIsConnected(MQ_CTX const ctx)
is the context connected? …
static bool MqLinkIsParent(MQ_CTX const ctx)
is the context a parent-context? …
MK_STRN LogParentOrChild() const
C++: MK_STRN ctx.LogParentOrChild() → C-API is ctx a PARENT or a CHILD ? …
void LogType(const MkObjectC *fmtobj=NULL, MK_DBG debug=0, MK_STRN callfunc=__builtin_FUNCTION(), MK_I32 lvl=0) const
C++: ctx.LogType(const MkObjectC* fmtobj = NULL, MK_DBG debug = 0, MK_STRN callfunc = __builtin_FUNC...
void LogShort(const MkObjectC *fmtobj=NULL, MK_DBG debug=0, MK_STRN callfunc=__builtin_FUNCTION(), MK_I32 lvl=0, MK_STRN label=NULL) const
C++: ctx.LogShort(const MkObjectC* fmtobj = NULL, MK_DBG debug = 0, MK_STRN callfunc = __builtin_FUN...
void LogLink(const MkObjectC *fmtobj=NULL, MK_DBG debug=0, MK_STRN callfunc=__builtin_FUNCTION(), MK_I32 lvl=0) const
C++: ctx.LogLink(const MkObjectC* fmtobj = NULL, MK_DBG debug = 0, MK_STRN callfunc = __builtin_FUNC...
void LogEnv(const MkObjectC *fmtobj=NULL, MK_DBG debug=0, MK_STRN callfunc=__builtin_FUNCTION(), MK_I32 lvl=0) const
C++: ctx.LogEnv(const MkObjectC* fmtobj = NULL, MK_DBG debug = 0, MK_STRN callfunc = __builtin_FUNCT...
void LogConfig(const MkObjectC *fmtobj=NULL, MK_DBG debug=0, MK_STRN callfunc=__builtin_FUNCTION(), MK_I32 lvl=0) const
C++: ctx.LogConfig(const MkObjectC* fmtobj = NULL, MK_DBG debug = 0, MK_STRN callfunc = __builtin_FU...
void LogSetup(const MkObjectC *fmtobj=NULL, MK_DBG debug=0, MK_STRN callfunc=__builtin_FUNCTION(), MK_I32 lvl=0) const
C++: ctx.LogSetup(const MkObjectC* fmtobj = NULL, MK_DBG debug = 0, MK_STRN callfunc = __builtin_FUN...
MK_STRN LogServerOrClient() const
C++: MK_STRN ctx.LogServerOrClient() → C-API is ctx a SERVER or a CLIENT ? …
#define MqContextLogShort(...)
#define MqContextLogEnv(...)
#define MqContextLogConfig(...)
#define MqContextLogSetup(...)
#define MqContextLogLink(...)
#define MqContextLogType(...)
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 ? …
void ProcessEvent(MqWaitOnEventE wait=MQ_WAIT_NO, MK_TIME_T timeout=MK_TIMEOUT_DEFAULT)
C++: ctx.ProcessEvent(MqWaitOnEventE wait = MQ_WAIT_NO, MK_TIME_T timeout = MK_TIMEOUT_DEFAULT) → C...
MkBufferC * GetBuffer()
C++: MkBufferC* ctx.GetBuffer() → C-API get the libmqmsgque::MqContextS::ctxbuf object
MqContextC * GetRoot()
C++: MqContextC* ctx.GetRoot() → C-API get the Root (toplevel initial context)
void Exit(MK_STRN callfunc=__builtin_FUNCTION(), MK_STRN callfile=__builtin_FILE(), MK_I32 callline=__builtin_LINE())
C++: ctx.Exit(MK_STRN callfunc = __builtin_FUNCTION(), MK_STRN callfile = __builtin_FILE(),...
#define MqProcessEvent(...)
#define MqContextGetBuffer(...)
static MQ_CTX MqGetRoot(MQ_CTX ctx)
get the Root (toplevel initial context)
void ProxyForward(MqContextC *targetCtx, MqDumpC *dump=NULL, MK_TIME_T timeout=MK_TIMEOUT_DEFAULT)
C++: sourceCtx.ProxyForward(MqContextC* targetCtx, MqDumpC* dump = NULL, MK_TIME_T timeout = MK_TIME...
void ProxyItem(MqContextC *targetCtx)
C++: sourceCtx.ProxyItem(MqContextC* targetCtx) → C-API Copy a single-data-item from the source...
#define MqProxyForward(...)
MK_BNP ReadBinaryR()
C++: MK_BNP ctx.ReadBinaryR() → C-API read a MkBinaryR from the read-data-package …
std::string ReadStringR()
C++: std::string ctx.ReadStringR() → C-API read a MkStringR from the read-data-package …
MK_HDL ReadHDL()
C++: MK_HDL ctx.ReadHDL() → C-API read the handle from the read-data-package
MK_BNP ReadBIN()
C++: doc_mq_cc_ReadBIN → C-API generic function to read an libmkkernel::MK_BIN object from the r...
MK_BOL ReadBOL()
C++: doc_mq_cc_ReadBOL → C-API read a PRIMITIVE TYPE from the read-data-package …
MkBufferC * ReadBUF()
C++: MkBufferC* ctx.ReadBUF() → C-API get a temporary MkBufferC from the read-data-package …
MkBufferListC * ReadBFL()
C++: MkBufferListC* ctx.ReadBFL() → C-API get a temporary MkBufferListC from next list-item in ...
MkBufferListC * ReadALL(MkBufferListC *val_inout=NULL)
C++: MkBufferListC* ctx.ReadALL(MkBufferListC* val_inout = NULL) → C-API get a temporary MkBuff...
MK_I32 ReadI32()
C++: doc_mq_cc_ReadI32 → C-API read a PRIMITIVE TYPE from the read-data-package …
MK_I64 ReadI64()
C++: doc_mq_cc_ReadI64 → C-API read a PRIMITIVE TYPE from the read-data-package …
MK_LONG ReadLONG()
C++: MK_LONG ctx.ReadLONG() → C-API read the long native object from the read-data-package
MK_I16 ReadI16()
C++: doc_mq_cc_ReadI16 → C-API read a PRIMITIVE TYPE from the read-data-package …
MK_FLT ReadFLT()
C++: doc_mq_cc_ReadFLT → C-API read a PRIMITIVE TYPE from the read-data-package …
MK_DBL ReadDBL()
C++: doc_mq_cc_ReadDBL → C-API read a PRIMITIVE TYPE from the read-data-package …
MK_STRN ReadSTR()
C++: doc_mq_cc_ReadSTR → C-API read a PRIMITIVE TYPE from the read-data-package …
MK_I8 ReadI8()
C++: doc_mq_cc_ReadI8 → C-API read a PRIMITIVE TYPE from the read-data-package …
#define MqReadBinaryR(...)
#define MqReadStringR(...)
void ReadT_END()
C++: ctx.ReadT_END() → C-API finish to extract a longterm-transaction-item from the read-data-p...
void ReadL_END()
C++: ctx.ReadL_END() → C-API finish to extract a list-items from the read-data-package....
void ReadT_START()
C++: ctx.ReadT_START() → C-API start to extract a longterm-transaction-item from the read-data-...
void ReadL_START(MkBufferC *buf=NULL)
C++: ctx.ReadL_START(MkBufferC* buf = NULL) → C-API start to extract a list-items from the read...
#define MqReadT_START(...)
#define MqReadL_START(...)
MK_BOOL ReadItemExists()
C++: MK_BOOL ctx.ReadItemExists() → C-API check if an item exists in the read-data-package …
void ReadUndo()
C++: ctx.ReadUndo() → C-API undo the last MqContextC READ API function call …
MkTypeE ReadGetNextType()
C++: MkTypeE ctx.ReadGetNextType() → C-API get the type (MkTypeE) of the next Item in the read-...
MK_NUM ReadGetNumItems()
C++: MK_NUM ctx.ReadGetNumItems() → C-API get the number of items left in the read-data-package...
MK_NUM MqReadGetNumItems(MQ_CTX const ctx)
get the number of items left in the read-data-package …
bool MqReadItemExists(MQ_CTX const ctx)
check if an item exists 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
MK_STRN RouteGetPath()
C++: MK_STRN ctx.RouteGetPath() → C-API return the absolut route-connection-string up to the cu...
MqContextC_A RouteResolve(MK_STRN ident, MK_NUM retnum=-1)
C++: MqContextC_A ctx.RouteResolve(MK_STRN ident, MK_NUM retnum = -1) → C-API return a list of ...
MkBufferListC * RouteGetTree()
C++: MkBufferListC* ctx.RouteGetTree() → C-API create an overview about all available routing-t...
void RouteCreate(MK_STRN route, MK_STRN service, MK_BOOL overwrite=false)
C++: ctx.RouteCreate(MK_STRN route, MK_STRN service, MK_BOOL overwrite = false) → C-API create/...
void RouteDelete(MK_STRN route, MK_STRN service, MK_BOOL overwrite=false)
C++: ctx.RouteDelete(MK_STRN route, MK_STRN service, MK_BOOL overwrite = false) → C-API delete ...
void RouteTraverse(MK_STRN service, MkBufferListC *args=NULL)
C++: ctx.RouteTraverse(MK_STRN service, MkBufferListC* args = NULL) → C-API traverse a tree dow...
#define MqRouteDelete(...)
#define MqRouteTraverse(...)
#define MqRouteGetTree(...)
#define MqRouteCreate(...)
#define MqRouteGetPath(...)
#define MqRouteResolve(...)
void SendBOL(MK_BOL val)
C++: doc_mq_cc_SendBOL → C-API MqContextC - append a native PRIMITIVE TYPE value to the send-d...
void SendVL(MK_FST printfmt, va_list var_list)
C++: ctx.SendVL(MK_FST printfmt, va_list var_list) → C-API append a vararg string as va_list to...
void SendStringR(const std::string &val)
C++: ctx.SendStringR(const std::string& val) → C-API MqContextC - append a native PRIMITIVE T...
void SendBFL(const MkBufferListC *val)
C++: ctx.SendBFL(const MkBufferListC* val) → C-API append a MkBufferListC object to the send-da...
void SendBinaryR(MK_BNP val)
C++: ctx.SendBinaryR(MK_BNP val) → C-API append a MkBinaryR object to the send-data-package....
void SendBUS_FLAT(const MkBufferStreamC *val)
C++: ctx.SendBUS_FLAT(const MkBufferStreamC* val) → C-API append a MkBufferStreamC object to th...
void SendLONG(MK_LONG val)
C++: ctx.SendLONG(MK_LONG val) → C-API send the long native object to the send-data-package
void SendDBL(MK_DBL val)
C++: doc_mq_cc_SendDBL → C-API MqContextC - append a native PRIMITIVE TYPE value to the send-d...
void SendI64(MK_I64 val)
C++: doc_mq_cc_SendI64 → C-API MqContextC - append a native PRIMITIVE TYPE value to the send-d...
void SendBIN(MK_BNP val)
C++: doc_mq_cc_SendBIN → C-API append a libmkkernel::MK_BIN object to the send-data-package....
void SendHDL(MK_HDL val)
C++: ctx.SendHDL(MK_HDL val) → C-API send the handle to the send-data-package
void SendL_FLAT(const MkBufferListC *val)
C++: ctx.SendL_FLAT(const MkBufferListC* val) → C-API append a MkBufferListC object as flat lis...
void SendI16(MK_I16 val)
C++: doc_mq_cc_SendI16 → C-API MqContextC - append a native PRIMITIVE TYPE value to the send-d...
void SendLTR(MQ_LTR transLId)
SendLTR
void SendFLT(MK_FLT val)
C++: doc_mq_cc_SendFLT → C-API MqContextC - append a native PRIMITIVE TYPE value to the send-d...
void SendV(MK_FST printfmt,...)
C++: ctx.SendV(MK_FST printfmt, ... ) → C-API append a vararg string to the send-data-package o...
void SendBUF(const MkBufferC *val)
C++: ctx.SendBUF(const MkBufferC* val) → C-API append a MkBufferC object to the send-data-packa...
void SendI8(MK_I8 val)
C++: doc_mq_cc_SendI8 → C-API MqContextC - append a native PRIMITIVE TYPE value to the send-data...
void SendSTR(MK_STRN val)
C++: doc_mq_cc_SendSTR → C-API MqContextC - append a native PRIMITIVE TYPE value to the send-d...
void SendI32(MK_I32 val)
C++: doc_mq_cc_SendI32 → C-API MqContextC - append a native PRIMITIVE TYPE value to the send-d...
#define MqSendStringR(...)
#define MqSendL_FLAT(...)
#define MqSendBUS_FLAT(...)
#define MqSendBinaryR(...)
void SendEND_AND_SUB(MQ_TOK token, MqServiceCCB callback, MK_TIME_T timeout=MK_TIMEOUT_DEFAULT)
C++: ctx.SendEND_AND_SUB(MQ_TOK token, MqServiceICB MqServiceCCB MqServiceIF* callback,...
void SendEND_AND_CALLBACK(MQ_TOK token, MqServiceCCB callback, MK_TIME_T timeout=MK_TIMEOUT_DEFAULT)
C++: ctx.SendEND_AND_CALLBACK(MQ_TOK token, MqServiceICB MqServiceCCB MqServiceIF* callback,...
void SendSTART()
C++: ctx.SendSTART() → C-API initialize the send-data-package. …
void SendEND_AND_WAIT(MQ_TOK token, MK_TIME_T timeout=MK_TIMEOUT_DEFAULT)
C++: ctx.SendEND_AND_WAIT(MQ_TOK token, MK_TIME_T timeout = MK_TIMEOUT_DEFAULT) → C-API finish ...
void SendSYNC()
C++: ctx.SendSYNC() → C-API garantee that all pending asynchronous-service-calls are processed....
void SendEND_AND_TRANSACTION(MQ_TOK token, MQ_TOK callback, MK_TIME_T timeout=MK_TIMEOUT_DEFAULT)
C++: ctx.SendEND_AND_TRANSACTION(MQ_TOK token, MQ_TOK callback, MK_TIME_T timeout = MK_TIMEOUT_DEFAU...
void SendEND(MQ_TOK token, MK_TIME_T timeout=MK_TIMEOUT_DEFAULT)
C++: ctx.SendEND(MQ_TOK token, MK_TIME_T timeout = MK_TIMEOUT_DEFAULT) → C-API MqContextC - fin...
#define MqSendEND_AND_TRANSACTION(...)
#define MqSendEND_AND_CALLBACK(...)
#define MqSendEND_AND_SUB(...)
#define MqSendEND_AND_WAIT(...)
void SendL_END()
C++: ctx.SendL_END() → C-API finish to append an embedded body-list-item to the send-data-packa...
void SendT_START()
C++: ctx.SendT_START() → C-API open a longterm-transaction-item …
void SendL_START()
C++: ctx.SendL_START() → C-API start to append an embedded body-list-item to the send-data-pack...
void SendT_END()
C++: ctx.SendT_END() → C-API closed a longterm-transaction-item …
#define MqSendL_START(...)
#define MqSendT_START(...)
void SendRETURN_SUB()
C++: ctx.SendRETURN_SUB() → C-API return Sub-Data-Blocks required by MqSendEND_AND_SUB …
void SendERROR()
C++: ctx.SendERROR() → C-API send the data from the MkErrorC to the link target ....
void SendRETURN()
C++: ctx.SendRETURN() → C-API MqContextC - finish the send-data-block on the server and optiona...
#define MqSendRETURN_SUB(...)
#define MqSendRETURN(...)
MK_BOOL ServiceIsTransaction()
C++: MK_BOOL ctx.ServiceIsTransaction() → C-API check if the ongoing-service-call belongs to a ...
void ServiceProxyCtx(MQ_TOK token, MqContextC *target)
C++: ctx.ServiceProxyCtx(MQ_TOK token, MqContextC* target) → C-API same as MqServiceProxy but u...
MK_BOOL ServiceProxyCtxExists(MQ_TOK token, MqContextC *target)
C++: MK_BOOL ctx.ServiceProxyCtxExists(MQ_TOK token, MqContextC* target) → C-API check if servi...
void ServiceProxyRoundRobin(MQ_TOK token, MK_STRN ident)
C++: ctx.ServiceProxyRoundRobin(MQ_TOK token, MK_STRN ident) → C-API create a proxy-service usi...
void ServiceProxy(MQ_TOK token, MQ_SLAVE_ID id=MQ_SLAVE_OTHER)
C++: ctx.ServiceProxy(MQ_TOK token, MQ_SLAVE_ID id = MQ_SLAVE_OTHER) → C-API create a service t...
void ServiceStorage(MQ_TOK token)
C++: ctx.ServiceStorage(MQ_TOK token) → C-API setup a service listen on a MqContextC_ServiceApi...
MK_BOOL ServiceTokenExists(MQ_TOK token)
C++: MK_BOOL ctx.ServiceTokenExists(MQ_TOK token) → C-API check if the MqContextC_ServiceApi_Id...
void ServiceDelete(MQ_TOK token)
C++: ctx.ServiceDelete(MQ_TOK token) → C-API delete a service. …
MK_BOOL ServiceTokenCheck(MQ_TOK token)
C++: MK_BOOL ctx.ServiceTokenCheck(MQ_TOK token) → C-API in an ongoing-service-call check if th...
MQ_TOK ServiceTokenGet()
C++: MQ_TOK ctx.ServiceTokenGet() → C-API in an ongoing-service-call get the current MqContextC...
void ServiceCreate(MQ_TOK token, MqServiceCCB callback)
C++: ctx.ServiceCreate(MQ_TOK token, MqServiceICB MqServiceCCB MqServiceIF* cal...
#define MqServiceStorage(...)
#define MqServiceProxyCtx(...)
static bool MqServiceIsTransaction(MQ_CTX const ctx)
check if the ongoing-service-call belongs to a transaction …
#define MqServiceCreate(...)
MK_STRN MQ_TOK
MqContextC - a char[4+1] or hex[8+1] string used to unique identify a service …
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
#define MqServiceProxy(...)
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 …
#define MqServiceProxyRoundRobin(...)
bool MqServiceTokenExists(MQ_CTX const ctx, MQ_TOK const token)
check if the MqContextC_ServiceApi_Identifer token is defined as ctx service …
#define MqServiceDelete(...)
MK_BOOL SlaveCheck(MQ_SLAVE_ID id) const
C++: MK_BOOL ctx.SlaveCheck(MQ_SLAVE_ID id) → C-API check if slave-id is valid
MqContextC * SlaveGetProxy(MQ_SLAVE_ID id)
C++: MqContextC* ctx.SlaveGetProxy(MQ_SLAVE_ID id) → C-API on slave return the master and on ma...
void SlaveCreate(MQ_SLAVE_ID id, MqContextC *slave)
C++: ctx.SlaveCreate(MQ_SLAVE_ID id, MqContextC* slave) → C-API create a master/slave link betw...
MqContextC * SlaveGet(MQ_SLAVE_ID id)
C++: MqContextC* ctx.SlaveGet(MQ_SLAVE_ID id) → C-API get the slave-context from a master-conte...
void SlaveDelete(MQ_SLAVE_ID id)
C++: ctx.SlaveDelete(MQ_SLAVE_ID id) → C-API Delete a slave object from a master/slave link ide...
MqContextC * SlaveGetFilter()
C++: MqContextC* ctx.SlaveGetFilter() → C-API get the filter-ctx or the master-ctx …
MK_BOOL SlaveIs() const
C++: MK_BOOL ctx.SlaveIs() → C-API is the context a slave-context ? …
MqContextC * SlaveGetMaster()
C++: MqContextC* ctx.SlaveGetMaster() → C-API opposite function of MqSlaveGetFilter
void SlaveWorker(MQ_SLAVE_ID id, MK_STRN fct="WORKER", MkBufferListC *args=NULL)
C++: ctx.SlaveWorker(MQ_SLAVE_ID id, MK_STRN fct = "WORKER", MkBufferListC* args = NULL) → C-API ...
static bool MqSlaveCheck(MQ_CTXN const ctx, MQ_SLAVE_ID const id)
check if slave-id is valid
#define MqSlaveGetProxy(...)
#define MqSlaveCreate(...)
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 ? …
#define MqSlaveGetFilter(...)
#define MqSlaveDelete(...)
#define MqSlaveWorker(...)
MK_I32 StorageErrCnt(MQ_LTR transLId)
C++: MK_I32 ctx.StorageErrCnt(MQ_LTR transLId) → C-API increment and return the database row-er...
void StorageClose()
C++: ctx.StorageClose() → C-API close the storage. …
void StorageOpen(MK_STRN storageFile)
C++: ctx.StorageOpen(MK_STRN storageFile) → C-API switch to a file-based-transaction-database …
std::tuple< MqContextC *, MQ_LTR > StorageResolve()
C++: {otherCtxP:MqContextC* otherLIdP:MQ_LTR} ctx.StorageResolve() → C-API extract the context-...
MQ_LTR StorageDelete(MQ_LTR *transLIdP_inout=0)
C++: MQ_LTR ctx.StorageDelete(MQ_LTR *transLIdP_inout = 0) → C-API delete the storage-row ident...
MQ_LTR StorageExport()
C++: MQ_LTR ctx.StorageExport() → C-API export the read-data-package into the STORAGE …
void StorageDecrRef(MQ_LTR transLId)
C++: ctx.StorageDecrRef(MQ_LTR transLId) → C-API decrease the internal refCount lock of the dat...
MQ_LTR StorageCount()
C++: MQ_LTR ctx.StorageCount() → C-API count the number of storage-rows …
MQ_LTR StorageImport(MQ_LTR *transLIdP_inout=0)
C++: MQ_LTR ctx.StorageImport(MQ_LTR *transLIdP_inout = 0) → C-API import the storage-package i...
void StorageLog(MK_STRN callfunc=__builtin_FUNCTION())
C++: ctx.StorageLog(MK_STRN callfunc = __builtin_FUNCTION()) → C-API log the storage the status...
void StorageIncrRef(MQ_LTR transLId)
C++: ctx.StorageIncrRef(MQ_LTR transLId) → C-API increase the internal refCount lock of the dat...
#define MqStorageIncrRef(...)
#define MqStorageResolve(...)
#define MqStorageLog(...)
#define MqStorageExport(...)
#define MqStorageDecrRef(...)
#define MqStorageClose(...)
#define MqStorageOpen(...)
#define MqStorageImport(...)
#define MqStorageCount(...)
#define MqStorageDelete(...)
#define MqStorageErrCnt(...)
static MK_OBJ CTOR(MqContextC *tmpl=NULL)
C++: [constructor,static] MqContextC* MqContextC::Create(MqContextC* tmpl = NULL) → C-API create...
static MqContextC * Create(MqContextC *tmpl=NULL)
C++: [constructor,static] MqContextC* MqContextC::Create(MqContextC* tmpl = NULL) → C-API create...
#define MqContextCreate(...)
MQ_DMP getDMP__null_allow() const
return the LibMsgqueObject from current MqDumpC instance
MQ_DMP getDMP() const
return the LibMsgqueObject from current MqDumpC instance
MQ_FCT getFCT() const
return the LibMsgqueObject from current MqFactoryC instance
static MqFactoryC * MqFactoryC_ObjNew(MK_RT_ARGS MQ_FCT hdl)
return MqFactoryC from LibMsgqueObject
MqIdentE
identify the application using prefix (default) or factory …
MqWaitOnEventE
wait for an event? …
MqStatusIsEF
Information about how the context was created.
MqStartE
User preferences on HOWTO start a new entity.
MK_NUM MQ_SLAVE_ID
a slave identiver
int MQ_LTR
32bit longterm transaction token because PHP-32 does NOT support long long
std::pair< MK_SIZE, MK_BINN > MK_BNP
namespace for the CcMqMsgque "C++"-API
PUBLIC data structure for the ccmqmsgque-specific-data → C-API: libmqmsgque::MqContextS
static MK_CBP Create(MK_RT mkrt, MqContextC::MqTokenICB const callback, MqContextC *self=NULL)
static enum MkErrorE Call(MQ_SERVICE_CALL_ARGS)
static void Copy(MQ_SERVICE_COPY_ARGS)
static void Free(MQ_SERVICE_FREE_ARGS)
array of MqContextC instances
PUBLIC data structure for the ccmqmsgque-specific-data
MqDumpC - the class known as dmp or dump is used to export a ccmqmsgque data package as binary …
data used to define a factory