theLink 10.0
Loading...
Searching...
No Matches
Macros | Functions | Variables
MqContextC_rb.c File Reference

tag: nhi1-release-250425 More...

#include "LibMqMsgque_private_rb.h"
#include "tmpl/MqContextC_ReadNEXT_lng.h"
#include "tmpl/MqContextC_ReadLIST_lng.h"
+ Include dependency graph for MqContextC_rb.c:

Go to the source code of this file.

Macros

#define META_FILE_NAME   "MqContextC_rb.c"
 
#define OT_CLASS   NS(MqContextC)
 
#define OT_CLASS_NAME   "MqContextC"
 
#define OT_LNG2META(O)
 
#define S_INIT   NS(sInit)(MK_RT_CALL_ONLY)
 
#define OT_SETUP_hdl   OT_SETUP_hdl_tmpl(MqContextC);
 
#define OT_SETUP_hdl__null_allow   OT_SETUP_hdl_tmpl__null_allow(MqContextC);
 
#define OT_SETUP_hdl_constr
 
#define OT_SETUP_hdl_destr   OT_SETUP_hdl_tmpl__null_allow(MqContextC);
 
#define OT_SETUP_hdl_static
 
#define OT_SETUP_hdl_static_constr   OT_SETUP_hdl_static
 
#define SetupRtFromObj_X(hdl)
 
#define SetupRtFromObj_XN(hdl)
 
#define ClassFactoryGet_doc   "MqFactoryC ctx.ClassFactoryGet() (const)"
 
#define ClassFactorySet_doc   "ctx.ClassFactorySet(item:MqFactoryC)"
 
#define ClassIdentGet_doc   "string ctx.ClassIdentGet() (const)"
 
#define ClassIdentSet_doc   "ctx.ClassIdentSet(ident:string)"
 
#define ClassOriginalIdentGet_doc   "string ctx.ClassOriginalIdentGet() (const)"
 
#define ConfigGetIoTcpL_doc   "MkBufferListC ctx.ConfigGetIoTcpL()"
 
#define ConfigCheckStartAs_doc   "bool ctx.ConfigCheckStartAs(data:MqStartE)"
 
#define ConfigGetBuffersize_doc   "int32 ctx.ConfigGetBuffersize() (const)"
 
#define ConfigGetIdentFrom_doc   "MqIdentE ctx.ConfigGetIdentFrom()"
 
#define ConfigGetIoPipe_doc   "int32 ctx.ConfigGetIoPipe()"
 
#define ConfigGetIoUds_doc   "string ctx.ConfigGetIoUds() (const)"
 
#define ConfigGetIsParent_doc   "bool ctx.ConfigGetIsParent()"
 
#define ConfigGetIsServer_doc   "bool ctx.ConfigGetIsServer()"
 
#define ConfigGetIsString_doc   "bool ctx.ConfigGetIsString()"
 
#define ConfigGetName_doc   "string ctx.ConfigGetName() (const)"
 
#define ConfigGetPkgsize_doc   "int32 ctx.ConfigGetPkgsize() (const)"
 
#define ConfigGetPostfix_doc   "string ctx.ConfigGetPostfix() (const)"
 
#define ConfigGetPrefix_doc   "string ctx.ConfigGetPrefix() (const)"
 
#define ConfigGetStartAs_doc   "MqStartE ctx.ConfigGetStartAs()"
 
#define ConfigGetStatusIs_doc   "MqStatusIsEF ctx.ConfigGetStatusIs()"
 
#define ConfigGetStorage_doc   "string ctx.ConfigGetStorage() (const)"
 
#define ConfigGetTimeout_doc   "MkTimeoutE|int32 ctx.ConfigGetTimeout() (const)"
 
#define ConfigReset_doc   "ctx.ConfigReset()"
 
#define ConfigSetAllDebug_doc   "ctx.ConfigSetAllDebug(data:int32)"
 
#define ConfigSetBgError_doc   "ctx.ConfigSetBgError(?callback:callable=nil?)"
 
#define ConfigSetBuffersize_doc   "ctx.ConfigSetBuffersize(data:int32)"
 
#define ConfigSetConfigFile_doc   "ctx.ConfigSetConfigFile(filename:string)"
 
#define ConfigSetDaemon_doc   "ctx.ConfigSetDaemon(pidfile:string)"
 
#define ConfigSetEvent_doc   "ctx.ConfigSetEvent(?callback:callable=nil?)"
 
#define ConfigSetIdentFrom_doc   "ctx.ConfigSetIdentFrom(data:MqIdentE)"
 
#define ConfigSetIgnoreExit_doc   "ctx.ConfigSetIgnoreExit(data:bool)"
 
#define ConfigSetIoPipe_doc   "ctx.ConfigSetIoPipe(fh:int32)"
 
#define ConfigSetIoTcp_doc   "ctx.ConfigSetIoTcp(?host:string=\"nil\"?, ?port:string=\"nil\"?, ?myhost:string=\"nil\"?, ?myport:string=\"nil\"?)"
 
#define ConfigSetIoTcpL_doc   "ctx.ConfigSetIoTcpL(vals:MkBufferListC)"
 
#define ConfigSetIoUds_doc   "ctx.ConfigSetIoUds(file:string)"
 
#define ConfigSetIsServer_doc   "ctx.ConfigSetIsServer(data:bool)"
 
#define ConfigSetIsString_doc   "ctx.ConfigSetIsString(data:bool)"
 
#define ConfigSetName_doc   "ctx.ConfigSetName(data:string)"
 
#define ConfigSetPkgsize_doc   "ctx.ConfigSetPkgsize(data:int32)"
 
#define ConfigSetPostfix_doc   "ctx.ConfigSetPostfix(data:string)"
 
#define ConfigSetPrefix_doc   "ctx.ConfigSetPrefix(data:string)"
 
#define ConfigSetServerCleanup_doc   "ctx.ConfigSetServerCleanup(?callback:callable=nil?)"
 
#define ConfigSetServerSetup_doc   "ctx.ConfigSetServerSetup(?callback:callable=nil?)"
 
#define ConfigSetStartAs_doc   "ctx.ConfigSetStartAs(data:MqStartE)"
 
#define ConfigSetStartAsString_doc   "ctx.ConfigSetStartAsString(data:string)"
 
#define ConfigSetStorage_doc   "ctx.ConfigSetStorage(data:string)"
 
#define ConfigSetTimeout_doc   "ctx.ConfigSetTimeout(data:MkTimeoutE|int32)"
 
#define ConfigGetIoTcp_doc   "{host:string port:string myhost:string myport:string} ctx.ConfigGetIoTcp()"
 
#define Create_doc   "MqContextC MqContextC.Create(?tmpl:MqContextC=nil?)"
 
#define new_doc   "MqContextC MqContextC.new(?tmpl:MqContextC=nil?)"
 
#define GetNull_doc   "MqContextC MqContextC.GetNull()"
 
#define HandleResolve_doc   "MqContextC MqContextC.HandleResolve(netHdl:MK_HDL)"
 
#define Instances_doc   "MqContextC MqContextC.Instances()"
 
#define ErrorFORMAT_doc   "MkErrorC fmtobj.ErrorFORMAT() (const)"
 
#define GetBuffer_doc   "MkBufferC ctx.GetBuffer()"
 
#define Next_doc   "MqContextC ctx.Next()"
 
#define Prev_doc   "MqContextC ctx.Prev()"
 
#define ErrorCopy_doc   "MkErrorE targetCtx.ErrorCopy(sourceCtx:MqContextC) (const)"
 
#define ErrorMove_doc   "MkErrorE targetCtx.ErrorMove(sourceCtx:MqContextC) (const)"
 
#define LogConfig_doc   "ctx.LogConfig(?fmtobj:MkObjectC=nil?, ?debug:int32=0?, ?callfunc:string=\"MK_NULL\"?, ?lvl:int32=0?) (const)"
 
#define LogEnv_doc   "ctx.LogEnv(?fmtobj:MkObjectC=nil?, ?debug:int32=0?, ?callfunc:string=\"MK_NULL\"?, ?lvl:int32=0?) (const)"
 
#define LogLink_doc   "ctx.LogLink(?fmtobj:MkObjectC=nil?, ?debug:int32=0?, ?callfunc:string=\"MK_NULL\"?, ?lvl:int32=0?) (const)"
 
#define LogSetup_doc   "ctx.LogSetup(?fmtobj:MkObjectC=nil?, ?debug:int32=0?, ?callfunc:string=\"MK_NULL\"?, ?lvl:int32=0?) (const)"
 
#define LogShort_doc   "ctx.LogShort(?fmtobj:MkObjectC=nil?, ?debug:int32=0?, ?callfunc:string=\"MK_NULL\"?, ?lvl:int32=0?, ?label:string=\"nil\"?) (const)"
 
#define LogType_doc   "ctx.LogType(?fmtobj:MkObjectC=nil?, ?debug:int32=0?, ?callfunc:string=\"MK_NULL\"?, ?lvl:int32=0?) (const)"
 
#define EnvProtect_doc   "ctx.EnvProtect()"
 
#define EnvRestore_doc   "ctx.EnvRestore()"
 
#define Exit_doc   "int32 ctx.Exit(?callfunc:string=\"MK_NULL\"?, ?callfile:string=\"MK_NULL\"?, ?callline:int32=-1?)"
 
#define GetRoot_doc   "MqContextC ctx.GetRoot()"
 
#define LinkGetParent_doc   "MqContextC ctx.LinkGetParent()"
 
#define LinkConnect_doc   "ctx.LinkConnect()"
 
#define LinkCreate_doc   "ctx.LinkCreate(?args:MkBufferListC...=nil?)"
 
#define LinkCreateChild_doc   "ctx.LinkCreateChild(parent:MqContextC, ?args:MkBufferListC...=nil?)"
 
#define LinkDelete_doc   "ctx.LinkDelete()"
 
#define LinkGetCtxId_doc   "int32 ctx.LinkGetCtxId()"
 
#define LinkGetTargetIdent_doc   "string ctx.LinkGetTargetIdent()"
 
#define LinkIsConnected_doc   "bool ctx.LinkIsConnected()"
 
#define LinkIsParent_doc   "bool ctx.LinkIsParent()"
 
#define LinkShutdown_doc   "ctx.LinkShutdown()"
 
#define LogParentOrChild_doc   "string ctx.LogParentOrChild() (const)"
 
#define LogServerOrClient_doc   "string ctx.LogServerOrClient() (const)"
 
#define ProcessEvent_doc   "ctx.ProcessEvent(?wait:MqWaitOnEventE=NO?, ?timeout:MkTimeoutE|int32=DEFAULT?)"
 
#define ProxyForward_doc   "sourceCtx.ProxyForward(targetCtx:MqContextC, ?dump:MqDumpC=nil?, ?timeout:MkTimeoutE|int32=DEFAULT?)"
 
#define ProxyItem_doc   "sourceCtx.ProxyItem(targetCtx:MqContextC)"
 
#define ReadALL_doc   "MkBufferListC ctx.ReadALL(?val_inout:MkBufferListC=nil?)"
 
#define ReadBFL_doc   "MkBufferListC ctx.ReadBFL()"
 
#define ReadBUF_doc   "MkBufferC ctx.ReadBUF()"
 
#define ReadDbg_doc   "ctx.ReadDbg()"
 
#define ReadGetNextType_doc   "MkTypeE ctx.ReadGetNextType()"
 
#define ReadGetNumItems_doc   "int32 ctx.ReadGetNumItems()"
 
#define ReadItemExists_doc   "bool ctx.ReadItemExists()"
 
#define ReadL_END_doc   "ctx.ReadL_END()"
 
#define ReadL_START_doc   "ctx.ReadL_START(?buf:MkBufferC=nil?)"
 
#define ReadT_END_doc   "ctx.ReadT_END()"
 
#define ReadT_START_doc   "ctx.ReadT_START()"
 
#define ReadUndo_doc   "ctx.ReadUndo()"
 
#define ReadBIN_doc   "binary ctx.ReadBIN()"
 
#define ReadBOL_doc   "bool ctx.ReadBOL()"
 
#define ReadBinaryR_doc   "binary ctx.ReadBinaryR()"
 
#define ReadDBL_doc   "double ctx.ReadDBL()"
 
#define ReadFLT_doc   "float ctx.ReadFLT()"
 
#define ReadHDL_doc   "MK_HDL ctx.ReadHDL()"
 
#define ReadI16_doc   "int16 ctx.ReadI16()"
 
#define ReadI32_doc   "int32 ctx.ReadI32()"
 
#define ReadI64_doc   "int64 ctx.ReadI64()"
 
#define ReadI8_doc   "int8 ctx.ReadI8()"
 
#define ReadLIST_doc   "[list...] ctx.ReadLIST()"
 
#define ReadLONG_doc   "long ctx.ReadLONG()"
 
#define ReadNEXT_doc   "obj ctx.ReadNEXT()"
 
#define ReadSTR_doc   "string ctx.ReadSTR()"
 
#define ReadStringR_doc   "string ctx.ReadStringR()"
 
#define RouteGetTree_doc   "MkBufferListC ctx.RouteGetTree()"
 
#define RouteCreate_doc   "ctx.RouteCreate(route:string, service:string, ?overwrite:bool=false?)"
 
#define RouteDelete_doc   "ctx.RouteDelete(route:string, service:string, ?overwrite:bool=false?)"
 
#define RouteResolve_doc   "[MqContextC...] ctx.RouteResolve(ident:string, ?retnum:int32=-1?)"
 
#define RouteTraverse_doc   "ctx.RouteTraverse(service:string, ?args:MkBufferListC...=nil?)"
 
#define RouteGetPath_doc   "string ctx.RouteGetPath()"
 
#define Send_doc   "ctx.Send(cstr:string, args:args...)"
 
#define SendBFL_doc   "ctx.SendBFL(val:MkBufferListC)"
 
#define SendBIN_doc   "ctx.SendBIN(val:binary)"
 
#define SendBOL_doc   "ctx.SendBOL(val:bool)"
 
#define SendBUF_doc   "ctx.SendBUF(val:MkBufferC)"
 
#define SendBUS_FLAT_doc   "ctx.SendBUS_FLAT(val:MkBufferStreamC)"
 
#define SendBinaryR_doc   "ctx.SendBinaryR(val:binary)"
 
#define SendDBL_doc   "ctx.SendDBL(val:double)"
 
#define SendEND_doc   "ctx.SendEND(token:string[4], ?timeout:MkTimeoutE|int32=DEFAULT?)"
 
#define SendEND_AND_CALLBACK_doc   "ctx.SendEND_AND_CALLBACK(token:string[4], callback:callable, ?timeout:MkTimeoutE|int32=DEFAULT?)"
 
#define SendEND_AND_SUB_doc   "ctx.SendEND_AND_SUB(token:string[4], callback:callable, ?timeout:MkTimeoutE|int32=DEFAULT?)"
 
#define SendEND_AND_TRANSACTION_doc   "ctx.SendEND_AND_TRANSACTION(token:string[4], callback:string[4], ?timeout:MkTimeoutE|int32=DEFAULT?)"
 
#define SendEND_AND_WAIT_doc   "ctx.SendEND_AND_WAIT(token:string[4], ?timeout:MkTimeoutE|int32=DEFAULT?)"
 
#define SendERROR_doc   "ctx.SendERROR()"
 
#define SendFLT_doc   "ctx.SendFLT(val:float)"
 
#define SendHDL_doc   "ctx.SendHDL(val:MK_HDL)"
 
#define SendI16_doc   "ctx.SendI16(val:int16)"
 
#define SendI32_doc   "ctx.SendI32(val:int32)"
 
#define SendI64_doc   "ctx.SendI64(val:int64)"
 
#define SendI8_doc   "ctx.SendI8(val:int8)"
 
#define SendLONG_doc   "ctx.SendLONG(val:long)"
 
#define SendLTR_doc   "ctx.SendLTR(transLId:int32)"
 
#define SendL_END_doc   "ctx.SendL_END()"
 
#define SendL_FLAT_doc   "ctx.SendL_FLAT(val:MkBufferListC)"
 
#define SendL_START_doc   "ctx.SendL_START()"
 
#define SendRETURN_doc   "ctx.SendRETURN()"
 
#define SendRETURN_SUB_doc   "ctx.SendRETURN_SUB()"
 
#define SendSTART_doc   "ctx.SendSTART()"
 
#define SendSTR_doc   "ctx.SendSTR(val:string)"
 
#define SendSYNC_doc   "ctx.SendSYNC()"
 
#define SendStringR_doc   "ctx.SendStringR(val:string)"
 
#define SendT_END_doc   "ctx.SendT_END()"
 
#define SendT_START_doc   "ctx.SendT_START()"
 
#define ServiceCreate_doc   "ctx.ServiceCreate(token:string[4], callback:callable)"
 
#define ServiceDelete_doc   "ctx.ServiceDelete(token:string[4])"
 
#define ServiceIsTransaction_doc   "bool ctx.ServiceIsTransaction()"
 
#define ServiceProxy_doc   "ctx.ServiceProxy(token:string[4], ?id:MqSlaveE|int32=MQ_SLAVE_OTHER?)"
 
#define ServiceProxyCtx_doc   "ctx.ServiceProxyCtx(token:string[4], target:MqContextC)"
 
#define ServiceProxyCtxExists_doc   "bool ctx.ServiceProxyCtxExists(token:string[4], target:MqContextC)"
 
#define ServiceProxyRoundRobin_doc   "ctx.ServiceProxyRoundRobin(token:string[4], ident:string)"
 
#define ServiceStorage_doc   "ctx.ServiceStorage(token:string[4])"
 
#define ServiceTokenCheck_doc   "bool ctx.ServiceTokenCheck(token:string[4])"
 
#define ServiceTokenExists_doc   "bool ctx.ServiceTokenExists(token:string[4])"
 
#define ServiceTokenGet_doc   "string[4] ctx.ServiceTokenGet()"
 
#define SlaveGetMaster_doc   "MqContextC ctx.SlaveGetMaster()"
 
#define SlaveGet_doc   "MqContextC ctx.SlaveGet(id:MqSlaveE|int32)"
 
#define SlaveGetFilter_doc   "MqContextC ctx.SlaveGetFilter()"
 
#define SlaveGetProxy_doc   "MqContextC ctx.SlaveGetProxy(id:MqSlaveE|int32)"
 
#define SlaveCheck_doc   "bool ctx.SlaveCheck(id:MqSlaveE|int32) (const)"
 
#define SlaveCreate_doc   "ctx.SlaveCreate(id:MqSlaveE|int32, slave:MqContextC)"
 
#define SlaveDelete_doc   "ctx.SlaveDelete(id:MqSlaveE|int32)"
 
#define SlaveIs_doc   "bool ctx.SlaveIs() (const)"
 
#define SlaveWorker_doc   "ctx.SlaveWorker(id:MqSlaveE|int32, ?fct:string=\"WORKER\"?, ?args:MkBufferListC...=nil?)"
 
#define StorageDelete_doc   "int32 ctx.StorageDelete(?*transLIdP_inout:int32=0?)"
 
#define StorageImport_doc   "int32 ctx.StorageImport(?*transLIdP_inout:int32=0?)"
 
#define StorageClose_doc   "ctx.StorageClose()"
 
#define StorageDecrRef_doc   "ctx.StorageDecrRef(transLId:int32)"
 
#define StorageIncrRef_doc   "ctx.StorageIncrRef(transLId:int32)"
 
#define StorageLog_doc   "ctx.StorageLog(?callfunc:string=\"MK_NULL\"?)"
 
#define StorageOpen_doc   "ctx.StorageOpen(storageFile:string)"
 
#define StorageCount_doc   "int32 ctx.StorageCount()"
 
#define StorageErrCnt_doc   "int32 ctx.StorageErrCnt(transLId:int32)"
 
#define StorageExport_doc   "int32 ctx.StorageExport()"
 
#define StorageResolve_doc   "{otherCtxP:MqContextC otherLIdP:int32} ctx.StorageResolve()"
 

Functions

static void rbmqmsgque_sMark (MK_PTR)
 
static OT_OBJ_T rbmqmsgque_LNG_CONSTR (OT_CLS_T clazz, MK_MNG mng, int objc, VALUE *objv)
 
static MK_PTR rbmqmsgque_MqContextC_selfCreate (MK_RT mkrt, MK_OBJ obj, MK_PTR envP)
 
static void rbmqmsgque_MqContextC_selfDelete (MK_RT mkrt, MK_PTR ptr, MK_PTR envP)
 
static void rbmqmsgque_MqContextC_selfUnlink (MK_RT mkrt, MK_PTR ptr, MK_PTR envP)
 
static void rbmqmsgque_sInit (MK_RT mkrt)
 
OT_ProcRet rbmqmsgque_MqContextC_ReadNEXT (MqContextC_ARGS)
  Ruby: obj ctx.ReadNEXT() → C-API
get the next argument as native object …
 
OT_ProcRet rbmqmsgque_MqContextC_ReadLIST (MqContextC_ARGS)
  Ruby: [list...] ctx.ReadLIST() → C-API
get all arguments as native list …
 
static OT_ProcRet rbmqmsgque_MqContextC_HandleResolve (OtClass_ARGS)
  Ruby: (static) MqContextC MqContextC.HandleResolve(netHdl:MK_HDL) → C-API
Handle-Resolve-Slot - return a MqContextC from netHdl or nil if invalid…
 
MK_DEPRECATED static MK_UNUSED OT_ProcRet rbmqmsgque_MqContextC_HandleGet (MqContextC_ARGS)
 
static OT_ProcRet rbmqmsgque_MqContextC_Next (MqContextC_ARGS)
  Ruby: MqContextC ctx.Next() → C-API
get next instance from linked-list of MqContextS type
 
static OT_ProcRet rbmqmsgque_MqContextC_Prev (MqContextC_ARGS)
  Ruby: MqContextC ctx.Prev() → C-API
get previous instance from linked-list of MqContextS type
 
static OT_ProcRet rbmqmsgque_MqContextC_Instances (OtClass_ARGS)
  Ruby: (static) MqContextC MqContextC.Instances() → C-API
get head-instance from linked-list of MqContextS type …
 
static OT_ProcRet rbmqmsgque_MqContextC_GetNull (OtClass_ARGS)
  Ruby: (static) MqContextC MqContextC.GetNull() → C-API
Null-Slot - return a MqContextC typed NULL instance …
 
static OT_ProcRet rbmqmsgque_MqContextC_ClassFactoryGet (MqContextC_ARGS)
  Ruby: MqFactoryC ctx.ClassFactoryGet() → C-API
get the MqFactoryC used by the MqContextC
 
static OT_ProcRet rbmqmsgque_MqContextC_ClassFactorySet (MqContextC_ARGS)
  Ruby: ctx.ClassFactorySet(item:MqFactoryC) → C-API
link the MqContextC to a new MqFactoryC
 
static OT_ProcRet rbmqmsgque_MqContextC_ClassIdentGet (MqContextC_ARGS)
  Ruby: string ctx.ClassIdentGet() → C-API
get the application-identification …
 
static OT_ProcRet rbmqmsgque_MqContextC_ClassIdentSet (MqContextC_ARGS)
  Ruby: ctx.ClassIdentSet(ident:string) → C-API
link the MqContextC to a new MqFactoryC identified by ident
 
static OT_ProcRet rbmqmsgque_MqContextC_ClassOriginalIdentGet (MqContextC_ARGS)
  Ruby: string ctx.ClassOriginalIdentGet() → C-API
get the MqFactoryS::originalIdent from the MqContextC
 
static OT_ProcRet rbmqmsgque_MqContextC_ConfigGetIoTcpL (MqContextC_ARGS)
  Ruby: MkBufferListC ctx.ConfigGetIoTcpL() → C-API
get the configuration-data of the tcp-client-server-link as MkBufferListC …
 
static OT_ProcRet rbmqmsgque_MqContextC_ConfigGetBuffersize (MqContextC_ARGS)
  Ruby: int32 ctx.ConfigGetBuffersize() → C-API
get the minimum of the read/send buffersize of the socket
 
static OT_ProcRet rbmqmsgque_MqContextC_ConfigGetIdentFrom (MqContextC_ARGS)
  Ruby: MqIdentE ctx.ConfigGetIdentFrom() → C-API
get the MqConfigS::identFrom
 
static OT_ProcRet rbmqmsgque_MqContextC_ConfigGetIoPipe (MqContextC_ARGS)
  Ruby: int32 ctx.ConfigGetIoPipe() → C-API
return the MqIoPipeConfigS
 
static OT_ProcRet rbmqmsgque_MqContextC_ConfigGetIoUds (MqContextC_ARGS)
  Ruby: string ctx.ConfigGetIoUds() → C-API
return the MqIoUdsConfigS
 
static OT_ProcRet rbmqmsgque_MqContextC_ConfigGetIsParent (MqContextC_ARGS)
  Ruby: bool ctx.ConfigGetIsParent() → C-API
does the context object is a parent ? An objext is a parent id the MqConfigS::parent attribute is nil
 
static OT_ProcRet rbmqmsgque_MqContextC_ConfigGetIsServer (MqContextC_ARGS)
  Ruby: bool ctx.ConfigGetIsServer() → C-API
does the context object is a server ?
 
static OT_ProcRet rbmqmsgque_MqContextC_ConfigGetIsString (MqContextC_ARGS)
  Ruby: bool ctx.ConfigGetIsString() → C-API
does the context object is using the string-mode ?
 
static OT_ProcRet rbmqmsgque_MqContextC_ConfigGetName (MqContextC_ARGS)
  Ruby: string ctx.ConfigGetName() → C-API
get the name of the context object
 
static OT_ProcRet rbmqmsgque_MqContextC_ConfigGetPkgsize (MqContextC_ARGS)
  Ruby: int32 ctx.ConfigGetPkgsize() → C-API
get the maximun size of a BDY package
 
static OT_ProcRet rbmqmsgque_MqContextC_ConfigGetPostfix (MqContextC_ARGS)
  Ruby: string ctx.ConfigGetPostfix() → C-API
get the MqConfigS::dispPostfix
 
static OT_ProcRet rbmqmsgque_MqContextC_ConfigGetPrefix (MqContextC_ARGS)
  Ruby: string ctx.ConfigGetPrefix() → C-API
get the MqConfigS::dispPrefix
 
static OT_ProcRet rbmqmsgque_MqContextC_ConfigGetStartAs (MqContextC_ARGS)
  Ruby: MqStartE ctx.ConfigGetStartAs() → C-API
return the MqConfigS::startAs value
 
static OT_ProcRet rbmqmsgque_MqContextC_ConfigGetStatusIs (MqContextC_ARGS)
  Ruby: MqStatusIsEF ctx.ConfigGetStatusIs() → C-API
return the MqContextS::statusIs value
 
static OT_ProcRet rbmqmsgque_MqContextC_ConfigGetStorage (MqContextC_ARGS)
  Ruby: string ctx.ConfigGetStorage() → C-API
get the storage of the context object
 
static OT_ProcRet rbmqmsgque_MqContextC_ConfigGetTimeout (MqContextC_ARGS)
  Ruby: MkTimeoutE|int32 ctx.ConfigGetTimeout() → C-API
get the timeout value of the context object
 
static OT_ProcRet rbmqmsgque_MqContextC_ConfigSetConfigFile (MqContextC_ARGS)
  Ruby: ctx.ConfigSetConfigFile(filename:string) → C-API
set the config-file and parse for well-known config-items
 
static OT_ProcRet rbmqmsgque_MqContextC_ConfigGetIoTcp (MqContextC_ARGS)
  Ruby: {host:string port:string myhost:string myport:string} ctx.ConfigGetIoTcp() → C-API
get the configuration-data of the tcp-client-server-link …
 
static OT_ProcRet rbmqmsgque_MqContextC_ConfigSetBgError (MqContextC_ARGS)
  Ruby: ctx.ConfigSetBgError(?callback:callable=nil?) → C-API
set the MqSetupS::BgError
 
static OT_ProcRet rbmqmsgque_MqContextC_ConfigSetEvent (MqContextC_ARGS)
  Ruby: ctx.ConfigSetEvent(?callback:callable=nil?) → C-API
set the MqSetupS::Event
 
static OT_ProcRet rbmqmsgque_MqContextC_ConfigSetServerCleanup (MqContextC_ARGS)
  Ruby: ctx.ConfigSetServerCleanup(?callback:callable=nil?) → C-API
set the MqSetupS::ServerCleanup
 
static OT_ProcRet rbmqmsgque_MqContextC_ConfigSetServerSetup (MqContextC_ARGS)
  Ruby: ctx.ConfigSetServerSetup(?callback:callable=nil?) → C-API
set the MqSetupS::ServerSetup
 
static OT_ProcRet rbmqmsgque_MqContextC_ConfigReset (MqContextC_ARGS)
  Ruby: ctx.ConfigReset() → C-API
clean the MqContextS::config data
 
static OT_ProcRet rbmqmsgque_MqContextC_ConfigCheckStartAs (MqContextC_ARGS)
  Ruby: bool ctx.ConfigCheckStartAs(data:MqStartE) → C-API
check if MqConfigS::startAs can be set to data
 
static OT_ProcRet rbmqmsgque_MqContextC_ConfigSetAllDebug (MqContextC_ARGS)
  Ruby: ctx.ConfigSetAllDebug(data:int32) → C-API
set the MkRuntimeS::debug value
 
static OT_ProcRet rbmqmsgque_MqContextC_ConfigSetBuffersize (MqContextC_ARGS)
  Ruby: ctx.ConfigSetBuffersize(data:int32) → C-API
set the MqIoConfigS::buffersize value
 
static OT_ProcRet rbmqmsgque_MqContextC_ConfigSetDaemon (MqContextC_ARGS)
  Ruby: ctx.ConfigSetDaemon(pidfile:string) → C-API
start the server-context as daemon …
 
static OT_ProcRet rbmqmsgque_MqContextC_ConfigSetIdentFrom (MqContextC_ARGS)
  Ruby: ctx.ConfigSetIdentFrom(data:MqIdentE) → C-API
set the MqConfigS::identFrom value
 
static OT_ProcRet rbmqmsgque_MqContextC_ConfigSetIgnoreExit (MqContextC_ARGS)
  Ruby: ctx.ConfigSetIgnoreExit(data:bool) → C-API
set the MqSetupS::ignoreExit value
 
static OT_ProcRet rbmqmsgque_MqContextC_ConfigSetIoPipe (MqContextC_ARGS)
  Ruby: ctx.ConfigSetIoPipe(fh:int32) → C-API
set the pipe configuration data …
 
static OT_ProcRet rbmqmsgque_MqContextC_ConfigSetIoTcp (MqContextC_ARGS)
  Ruby: ctx.ConfigSetIoTcp(?host:string="nil"?, ?port:string="nil"?, ?myhost:string="nil"?, ?myport:string="nil"?) → C-API
configure a context to use a tcp-client-server-link …
 
static OT_ProcRet rbmqmsgque_MqContextC_ConfigSetIoTcpL (MqContextC_ARGS)
  Ruby: ctx.ConfigSetIoTcpL(vals:MkBufferListC) → C-API
configure a context to use a tcp-client-server-link …
 
static OT_ProcRet rbmqmsgque_MqContextC_ConfigSetIoUds (MqContextC_ARGS)
  Ruby: ctx.ConfigSetIoUds(file:string) → C-API
configure a context to use a uds-client-server-link …
 
static OT_ProcRet rbmqmsgque_MqContextC_ConfigSetIsServer (MqContextC_ARGS)
  Ruby: ctx.ConfigSetIsServer(data:bool) → C-API
set the MqSetupS::isServer value
 
static OT_ProcRet rbmqmsgque_MqContextC_ConfigSetIsString (MqContextC_ARGS)
  Ruby: ctx.ConfigSetIsString(data:bool) → C-API
set the MqConfigS::native value 'S'string or 'L'owEndian or 'B'igEndian
 
static OT_ProcRet rbmqmsgque_MqContextC_ConfigSetName (MqContextC_ARGS)
  Ruby: ctx.ConfigSetName(data:string) → C-API
set the MqConfigS::dispName value and cleanup old value
 
static OT_ProcRet rbmqmsgque_MqContextC_ConfigSetPkgsize (MqContextC_ARGS)
  Ruby: ctx.ConfigSetPkgsize(data:int32) → C-API
set the MqIoConfigS::pkgsize value
 
static OT_ProcRet rbmqmsgque_MqContextC_ConfigSetPostfix (MqContextC_ARGS)
  Ruby: ctx.ConfigSetPostfix(data:string) → C-API
set the client-part (2) of the application-identifer MqConfigS::dispName …
 
static OT_ProcRet rbmqmsgque_MqContextC_ConfigSetPrefix (MqContextC_ARGS)
  Ruby: ctx.ConfigSetPrefix(data:string) → C-API
set the server-part (1) of the application-identifer MqConfigS::dispName …
 
static OT_ProcRet rbmqmsgque_MqContextC_ConfigSetStartAs (MqContextC_ARGS)
  Ruby: ctx.ConfigSetStartAs(data:MqStartE) → C-API
set the MqConfigS::startAs value
 
static OT_ProcRet rbmqmsgque_MqContextC_ConfigSetStartAsString (MqContextC_ARGS)
  Ruby: ctx.ConfigSetStartAsString(data:string) → C-API
set the MqConfigS::startAs value using string default, thread, fork or spawn
 
static OT_ProcRet rbmqmsgque_MqContextC_ConfigSetStorage (MqContextC_ARGS)
  Ruby: ctx.ConfigSetStorage(data:string) → C-API
set the Storage value and cleanup old value
 
static OT_ProcRet rbmqmsgque_MqContextC_ConfigSetTimeout (MqContextC_ARGS)
  Ruby: ctx.ConfigSetTimeout(data:MkTimeoutE|int32) → C-API
set the MqIoConfigS::timeout value
 
static OT_ProcRet rbmqmsgque_MqContextC_EnvProtect (MqContextC_ARGS)
  Ruby: ctx.EnvProtect() → C-API
protect the service-environment
 
static OT_ProcRet rbmqmsgque_MqContextC_EnvRestore (MqContextC_ARGS)
  Ruby: ctx.EnvRestore() → C-API
restore the service-environment
 
static OT_ProcRet rbmqmsgque_MqContextC_ErrorFORMAT (MqContextC_ARGS)
  Ruby: MkErrorC fmtobj.ErrorFORMAT() → C-API
helper used to access MkErrorDEFAULT from MqContextC
 
OT_ProcRet rbmqmsgque_MqContextC_ErrorCopy (MqContextC_ARGS)
  Ruby: MkErrorE targetCtx.ErrorCopy(sourceCtx:MqContextC) → C-API
copy a MkErrorS from the sourceCtx to the targetCtx …
 
OT_ProcRet rbmqmsgque_MqContextC_ErrorMove (MqContextC_ARGS)
  Ruby: MkErrorE targetCtx.ErrorMove(sourceCtx:MqContextC) → C-API
move a MkErrorS from the sourceCtx to the targetCtx …
 
OT_ProcRet rbmqmsgque_MqContextC_Send (MqContextC_ARGS)
  Ruby: ctx.Send(cstr:string, args:args...) → C-API
user friendly replacement for the MqContextC_SendApi_C_API …
 
static OT_ProcRet rbmqmsgque_MqContextC_LinkGetParent (MqContextC_ARGS)
  Ruby: MqContextC ctx.LinkGetParent() → C-API
get the initial parent-context from a client/server link …
 
static OT_ProcRet rbmqmsgque_MqContextC_LinkConnect (MqContextC_ARGS)
  Ruby: ctx.LinkConnect() → C-API
re-connect a client-server-link after a server crash or a network downtime …
 
static OT_ProcRet rbmqmsgque_MqContextC_LinkCreate (MqContextC_ARGS)
  Ruby: ctx.LinkCreate(?args:MkBufferListC...=nil?) → C-API
make ctx to a parent-context and setup a new client-server-link …
 
static OT_ProcRet rbmqmsgque_MqContextC_LinkCreateChild (MqContextC_ARGS)
  Ruby: ctx.LinkCreateChild(parent:MqContextC, ?args:MkBufferListC...=nil?) → C-API
make a context to a child-context on-top of an existing parent-client-server-link …
 
static OT_ProcRet rbmqmsgque_MqContextC_LinkDelete (MqContextC_ARGS)
  Ruby: ctx.LinkDelete() → C-API
close the client-server-link …
 
static OT_ProcRet rbmqmsgque_MqContextC_LinkGetCtxId (MqContextC_ARGS)
  Ruby: int32 ctx.LinkGetCtxId() → C-API
get an identifier which is unique per parent-or-child-context …
 
static OT_ProcRet rbmqmsgque_MqContextC_LinkGetTargetIdent (MqContextC_ARGS)
  Ruby: string ctx.LinkGetTargetIdent() → C-API
get the ident of the link-target …
 
static OT_ProcRet rbmqmsgque_MqContextC_LinkIsConnected (MqContextC_ARGS)
  Ruby: bool ctx.LinkIsConnected() → C-API
is the context connected? …
 
static OT_ProcRet rbmqmsgque_MqContextC_LinkIsParent (MqContextC_ARGS)
  Ruby: bool ctx.LinkIsParent() → C-API
is the context a parent-context? …
 
static OT_ProcRet rbmqmsgque_MqContextC_LinkShutdown (MqContextC_ARGS)
  Ruby: ctx.LinkShutdown() → C-API
shutdown the communication with a server
 
MK_DEPRECATED static MK_UNUSED OT_ProcRet rbmqmsgque_MqContextC_Log (MqContextC_ARGS)
 
static OT_ProcRet rbmqmsgque_MqContextC_LogConfig (MqContextC_ARGS)
  Ruby: ctx.LogConfig(?fmtobj:MkObjectC=nil?, ?debug:int32=0?, ?callfunc:string="MK_NULL"?, ?lvl:int32=0?) → C-API
log the MqContextC part MqConfigS …
 
static OT_ProcRet rbmqmsgque_MqContextC_LogEnv (MqContextC_ARGS)
  Ruby: ctx.LogEnv(?fmtobj:MkObjectC=nil?, ?debug:int32=0?, ?callfunc:string="MK_NULL"?, ?lvl:int32=0?) → C-API
log the MqContextC part MqEnvS …
 
static OT_ProcRet rbmqmsgque_MqContextC_LogLink (MqContextC_ARGS)
  Ruby: ctx.LogLink(?fmtobj:MkObjectC=nil?, ?debug:int32=0?, ?callfunc:string="MK_NULL"?, ?lvl:int32=0?) → C-API
log the MqContextC part MqLinkS …
 
static OT_ProcRet rbmqmsgque_MqContextC_LogSetup (MqContextC_ARGS)
  Ruby: ctx.LogSetup(?fmtobj:MkObjectC=nil?, ?debug:int32=0?, ?callfunc:string="MK_NULL"?, ?lvl:int32=0?) → C-API
log the MqContextC part MqSetupS …
 
static OT_ProcRet rbmqmsgque_MqContextC_LogShort (MqContextC_ARGS)
  Ruby: ctx.LogShort(?fmtobj:MkObjectC=nil?, ?debug:int32=0?, ?callfunc:string="MK_NULL"?, ?lvl:int32=0?, ?label:string="nil"?) → C-API
log the MqContextC with less info then MqContextLog …
 
static OT_ProcRet rbmqmsgque_MqContextC_LogType (MqContextC_ARGS)
  Ruby: ctx.LogType(?fmtobj:MkObjectC=nil?, ?debug:int32=0?, ?callfunc:string="MK_NULL"?, ?lvl:int32=0?) → C-API
log the MqContextC part MkTypeS …
 
static OT_ProcRet rbmqmsgque_MqContextC_LogParentOrChild (MqContextC_ARGS)
  Ruby: string ctx.LogParentOrChild() → C-API
is ctx a PARENT or a CHILD ? …
 
static OT_ProcRet rbmqmsgque_MqContextC_LogServerOrClient (MqContextC_ARGS)
  Ruby: string ctx.LogServerOrClient() → C-API
is ctx a SERVER or a CLIENT ? …
 
static OT_ProcRet rbmqmsgque_MqContextC_GetBuffer (MqContextC_ARGS)
  Ruby: MkBufferC ctx.GetBuffer() → C-API
get the MqContextS::ctxbuf object
 
static OT_ProcRet rbmqmsgque_MqContextC_GetRoot (MqContextC_ARGS)
  Ruby: MqContextC ctx.GetRoot() → C-API
get the Root (toplevel initial context)
 
MK_DEPRECATED static MK_UNUSED OT_ProcRet rbmqmsgque_MqContextC_ToString (MqContextC_ARGS)
 
static OT_ProcRet rbmqmsgque_MqContextC_Exit (MqContextC_ARGS)
  Ruby: int32 ctx.Exit(?callfunc:string="MK_NULL"?, ?callfile:string="MK_NULL"?, ?callline:int32=-1?) → C-API
delete the context and exit the current process or thread …
 
static OT_ProcRet rbmqmsgque_MqContextC_ProcessEvent (MqContextC_ARGS)
  Ruby: ctx.ProcessEvent(?wait:MqWaitOnEventE=NO?, ?timeout:MkTimeoutE|int32=DEFAULT?) → C-API
enter the event-loop and wait for an incoming service-request. …
 
static OT_ProcRet rbmqmsgque_MqContextC_ProxyForward (MqContextC_ARGS)
  Ruby: sourceCtx.ProxyForward(targetCtx:MqContextC, ?dump:MqDumpC=nil?, ?timeout:MkTimeoutE|int32=DEFAULT?) → C-API
send the entire read-data-package-data to the link-target …
 
static OT_ProcRet rbmqmsgque_MqContextC_ProxyItem (MqContextC_ARGS)
  Ruby: sourceCtx.ProxyItem(targetCtx:MqContextC) → C-API
Copy a single-data-item from the sourceCtx to the targetCtx.
 
static OT_ProcRet rbmqmsgque_MqContextC_ReadALL (MqContextC_ARGS)
  Ruby: MkBufferListC ctx.ReadALL(?val_inout:MkBufferListC=nil?) → C-API
get a temporary MkBufferListC from all data in the read-data-package …
 
static OT_ProcRet rbmqmsgque_MqContextC_ReadBFL (MqContextC_ARGS)
  Ruby: MkBufferListC ctx.ReadBFL() → C-API
get a temporary MkBufferListC from next list-item in the read-data-package …
 
static OT_ProcRet rbmqmsgque_MqContextC_ReadBUF (MqContextC_ARGS)
  Ruby: MkBufferC ctx.ReadBUF() → C-API
get a temporary MkBufferC from the read-data-package …
 
static OT_ProcRet rbmqmsgque_MqContextC_ReadBIN (MqContextC_ARGS)
  Ruby: doc_mq_rb_ReadBIN → C-API
generic function to read an MK_BIN object from the read-data-package object …
 
static OT_ProcRet rbmqmsgque_MqContextC_ReadBOL (MqContextC_ARGS)
  Ruby: doc_mq_rb_ReadBOL → C-API
read a PRIMITIVE TYPE from the read-data-package …
 
static OT_ProcRet rbmqmsgque_MqContextC_ReadBinaryR (MqContextC_ARGS)
  Ruby: binary ctx.ReadBinaryR() → C-API
read a MkBinaryR from the read-data-package …
 
static OT_ProcRet rbmqmsgque_MqContextC_ReadDBL (MqContextC_ARGS)
  Ruby: doc_mq_rb_ReadDBL → C-API
read a PRIMITIVE TYPE from the read-data-package …
 
static OT_ProcRet rbmqmsgque_MqContextC_ReadFLT (MqContextC_ARGS)
  Ruby: doc_mq_rb_ReadFLT → C-API
read a PRIMITIVE TYPE from the read-data-package …
 
static OT_ProcRet rbmqmsgque_MqContextC_ReadHDL (MqContextC_ARGS)
  Ruby: MK_HDL ctx.ReadHDL() → C-API
read the handle from the read-data-package
 
static OT_ProcRet rbmqmsgque_MqContextC_ReadI16 (MqContextC_ARGS)
  Ruby: doc_mq_rb_ReadI16 → C-API
read a PRIMITIVE TYPE from the read-data-package …
 
static OT_ProcRet rbmqmsgque_MqContextC_ReadI32 (MqContextC_ARGS)
  Ruby: doc_mq_rb_ReadI32 → C-API
read a PRIMITIVE TYPE from the read-data-package …
 
static OT_ProcRet rbmqmsgque_MqContextC_ReadI64 (MqContextC_ARGS)
  Ruby: doc_mq_rb_ReadI64 → C-API
read a PRIMITIVE TYPE from the read-data-package …
 
static OT_ProcRet rbmqmsgque_MqContextC_ReadI8 (MqContextC_ARGS)
  Ruby: doc_mq_rb_ReadI8 → C-API
read a PRIMITIVE TYPE from the read-data-package …
 
static OT_ProcRet rbmqmsgque_MqContextC_ReadLONG (MqContextC_ARGS)
  Ruby: long ctx.ReadLONG() → C-API
read the long native object from the read-data-package
 
static OT_ProcRet rbmqmsgque_MqContextC_ReadSTR (MqContextC_ARGS)
  Ruby: doc_mq_rb_ReadSTR → C-API
read a PRIMITIVE TYPE from the read-data-package …
 
static OT_ProcRet rbmqmsgque_MqContextC_ReadStringR (MqContextC_ARGS)
  Ruby: string ctx.ReadStringR() → C-API
read a MkStringR from the read-data-package …
 
static OT_ProcRet rbmqmsgque_MqContextC_ReadL_END (MqContextC_ARGS)
  Ruby: ctx.ReadL_END() → C-API
finish to extract a list-items from the read-data-package. …
 
static OT_ProcRet rbmqmsgque_MqContextC_ReadL_START (MqContextC_ARGS)
  Ruby: ctx.ReadL_START(?buf:MkBufferC=nil?) → C-API
start to extract a list-items from the read-data-package. …
 
static OT_ProcRet rbmqmsgque_MqContextC_ReadT_END (MqContextC_ARGS)
  Ruby: ctx.ReadT_END() → C-API
finish to extract a longterm-transaction-item from the read-data-package. …
 
static OT_ProcRet rbmqmsgque_MqContextC_ReadT_START (MqContextC_ARGS)
  Ruby: ctx.ReadT_START() → C-API
start to extract a longterm-transaction-item from the read-data-package. …
 
static OT_ProcRet rbmqmsgque_MqContextC_ReadDbg (MqContextC_ARGS)
 internal function: MqReadDbg
 
static OT_ProcRet rbmqmsgque_MqContextC_ReadGetNextType (MqContextC_ARGS)
  Ruby: MkTypeE ctx.ReadGetNextType() → C-API
get the type (MkTypeE) of the next Item in the read-data-buffer or "0" if not available
 
static OT_ProcRet rbmqmsgque_MqContextC_ReadGetNumItems (MqContextC_ARGS)
  Ruby: int32 ctx.ReadGetNumItems() → C-API
get the number of items left in the read-data-package …
 
static OT_ProcRet rbmqmsgque_MqContextC_ReadItemExists (MqContextC_ARGS)
  Ruby: bool ctx.ReadItemExists() → C-API
check if an item exists in the read-data-package …
 
static OT_ProcRet rbmqmsgque_MqContextC_ReadUndo (MqContextC_ARGS)
  Ruby: ctx.ReadUndo() → C-API
undo the last MqContextC READ API function call …
 
static OT_ProcRet rbmqmsgque_MqContextC_RouteGetTree (MqContextC_ARGS)
  Ruby: MkBufferListC ctx.RouteGetTree() → C-API
create an overview about all available routing-target and services …
 
static OT_ProcRet rbmqmsgque_MqContextC_RouteCreate (MqContextC_ARGS)
  Ruby: ctx.RouteCreate(route:string, service:string, ?overwrite:bool=false?) → C-API
create/delete a routing-link between context an a service using route
 
static OT_ProcRet rbmqmsgque_MqContextC_RouteDelete (MqContextC_ARGS)
  Ruby: ctx.RouteDelete(route:string, service:string, ?overwrite:bool=false?) → C-API
delete a routing-link created with MqRouteCreate
 
static OT_ProcRet rbmqmsgque_MqContextC_RouteResolve (MqContextC_ARGS)
  Ruby: [MqContextC...] ctx.RouteResolve(ident:string, ?retnum:int32=-1?) → C-API
return a list of all context belonging to ident …
 
static OT_ProcRet rbmqmsgque_MqContextC_RouteTraverse (MqContextC_ARGS)
  Ruby: ctx.RouteTraverse(service:string, ?args:MkBufferListC...=nil?) → C-API
traverse a tree down and call service if available.
 
static OT_ProcRet rbmqmsgque_MqContextC_RouteGetPath (MqContextC_ARGS)
  Ruby: string ctx.RouteGetPath() → C-API
return the absolut route-connection-string up to the current ctx …
 
static OT_ProcRet rbmqmsgque_MqContextC_SendBFL (MqContextC_ARGS)
  Ruby: ctx.SendBFL(val:MkBufferListC) → C-API
append a MkBufferListC object to the send-data-package object …
 
static OT_ProcRet rbmqmsgque_MqContextC_SendBIN (MqContextC_ARGS)
  Ruby: doc_mq_rb_SendBIN → C-API
append a MK_BIN object to the send-data-package. …
 
static OT_ProcRet rbmqmsgque_MqContextC_SendBOL (MqContextC_ARGS)
  Ruby: doc_mq_rb_SendBOL → C-API
MqContextC - append a native PRIMITIVE TYPE value to the send-data-package …
 
static OT_ProcRet rbmqmsgque_MqContextC_SendBUF (MqContextC_ARGS)
  Ruby: ctx.SendBUF(val:MkBufferC) → C-API
append a MkBufferC object to the send-data-package object …
 
static OT_ProcRet rbmqmsgque_MqContextC_SendBUS_FLAT (MqContextC_ARGS)
  Ruby: ctx.SendBUS_FLAT(val:MkBufferStreamC) → C-API
append a MkBufferStreamC object to the send-data-package object …
 
static OT_ProcRet rbmqmsgque_MqContextC_SendBinaryR (MqContextC_ARGS)
  Ruby: ctx.SendBinaryR(val:binary) → C-API
append a MkBinaryR object to the send-data-package. …
 
static OT_ProcRet rbmqmsgque_MqContextC_SendDBL (MqContextC_ARGS)
  Ruby: doc_mq_rb_SendDBL → C-API
MqContextC - append a native PRIMITIVE TYPE value to the send-data-package …
 
static OT_ProcRet rbmqmsgque_MqContextC_SendFLT (MqContextC_ARGS)
  Ruby: doc_mq_rb_SendFLT → C-API
MqContextC - append a native PRIMITIVE TYPE value to the send-data-package …
 
static OT_ProcRet rbmqmsgque_MqContextC_SendHDL (MqContextC_ARGS)
  Ruby: ctx.SendHDL(val:MK_HDL) → C-API
send the handle to the send-data-package
 
static OT_ProcRet rbmqmsgque_MqContextC_SendI16 (MqContextC_ARGS)
  Ruby: doc_mq_rb_SendI16 → C-API
MqContextC - append a native PRIMITIVE TYPE value to the send-data-package …
 
static OT_ProcRet rbmqmsgque_MqContextC_SendI32 (MqContextC_ARGS)
  Ruby: doc_mq_rb_SendI32 → C-API
MqContextC - append a native PRIMITIVE TYPE value to the send-data-package …
 
static OT_ProcRet rbmqmsgque_MqContextC_SendI64 (MqContextC_ARGS)
  Ruby: doc_mq_rb_SendI64 → C-API
MqContextC - append a native PRIMITIVE TYPE value to the send-data-package …
 
static OT_ProcRet rbmqmsgque_MqContextC_SendI8 (MqContextC_ARGS)
  Ruby: doc_mq_rb_SendI8 → C-API
MqContextC - append a native PRIMITIVE TYPE value to the send-data-package …
 
static OT_ProcRet rbmqmsgque_MqContextC_SendLONG (MqContextC_ARGS)
  Ruby: ctx.SendLONG(val:long) → C-API
send the long native object to the send-data-package
 
static OT_ProcRet rbmqmsgque_MqContextC_SendLTR (MqContextC_ARGS)
 internal function: MqSendLTR
 
static OT_ProcRet rbmqmsgque_MqContextC_SendL_FLAT (MqContextC_ARGS)
  Ruby: ctx.SendL_FLAT(val:MkBufferListC) → C-API
append a MkBufferListC object as flat list of items to the send-data-package object …
 
static OT_ProcRet rbmqmsgque_MqContextC_SendSTR (MqContextC_ARGS)
  Ruby: doc_mq_rb_SendSTR → C-API
MqContextC - append a native PRIMITIVE TYPE value to the send-data-package …
 
static OT_ProcRet rbmqmsgque_MqContextC_SendStringR (MqContextC_ARGS)
  Ruby: ctx.SendStringR(val:string) → C-API
MqContextC - append a native PRIMITIVE TYPE value to the send-data-package …
 
static OT_ProcRet rbmqmsgque_MqContextC_SendEND (MqContextC_ARGS)
  Ruby: ctx.SendEND(token:string[4], ?timeout:MkTimeoutE|int32=DEFAULT?) → C-API
MqContextC - finish the send-data-block and call synchronous/asynchronous a remote-service …
 
static OT_ProcRet rbmqmsgque_MqContextC_SendEND_AND_CALLBACK (MqContextC_ARGS)
  Ruby: ctx.SendEND_AND_CALLBACK(token:string[4], callback:callable, ?timeout:MkTimeoutE|int32=DEFAULT?) → C-API
finish the send-data-block, call the remote service, do not-wait for the result but expect the result on a callback …
 
static OT_ProcRet rbmqmsgque_MqContextC_SendEND_AND_SUB (MqContextC_ARGS)
  Ruby: ctx.SendEND_AND_SUB(token:string[4], callback:callable, ?timeout:MkTimeoutE|int32=DEFAULT?) → C-API
finish the send-data-block, call the remote service, do wait for the result and expect multiple sub-results on a callback …
 
static OT_ProcRet rbmqmsgque_MqContextC_SendEND_AND_TRANSACTION (MqContextC_ARGS)
  Ruby: ctx.SendEND_AND_TRANSACTION(token:string[4], callback:string[4], ?timeout:MkTimeoutE|int32=DEFAULT?) → C-API
finish the send-data-block, call the remote service to do a longterm-transaction-call …
 
static OT_ProcRet rbmqmsgque_MqContextC_SendEND_AND_WAIT (MqContextC_ARGS)
  Ruby: ctx.SendEND_AND_WAIT(token:string[4], ?timeout:MkTimeoutE|int32=DEFAULT?) → C-API
finish the send-data-block, call the remote service and wait for result…
 
static OT_ProcRet rbmqmsgque_MqContextC_SendSTART (MqContextC_ARGS)
  Ruby: ctx.SendSTART() → C-API
initialize the send-data-package. …
 
static OT_ProcRet rbmqmsgque_MqContextC_SendSYNC (MqContextC_ARGS)
  Ruby: ctx.SendSYNC() → C-API
garantee that all pending asynchronous-service-calls are processed. …
 
static OT_ProcRet rbmqmsgque_MqContextC_SendL_END (MqContextC_ARGS)
  Ruby: ctx.SendL_END() → C-API
finish to append an embedded body-list-item to the send-data-package. …
 
static OT_ProcRet rbmqmsgque_MqContextC_SendL_START (MqContextC_ARGS)
  Ruby: ctx.SendL_START() → C-API
start to append an embedded body-list-item to the send-data-package. …
 
static OT_ProcRet rbmqmsgque_MqContextC_SendT_END (MqContextC_ARGS)
  Ruby: ctx.SendT_END() → C-API
closed a longterm-transaction-item …
 
static OT_ProcRet rbmqmsgque_MqContextC_SendT_START (MqContextC_ARGS)
  Ruby: ctx.SendT_START() → C-API
open a longterm-transaction-item …
 
static OT_ProcRet rbmqmsgque_MqContextC_SendERROR (MqContextC_ARGS)
  Ruby: ctx.SendERROR() → C-API
send the data from the MkErrorC to the link target . …
 
static OT_ProcRet rbmqmsgque_MqContextC_SendRETURN (MqContextC_ARGS)
  Ruby: ctx.SendRETURN() → C-API
MqContextC - finish the send-data-block on the server and optional return the results. …
 
static OT_ProcRet rbmqmsgque_MqContextC_SendRETURN_SUB (MqContextC_ARGS)
  Ruby: ctx.SendRETURN_SUB() → C-API
return Sub-Data-Blocks required by MqSendEND_AND_SUB …
 
static OT_ProcRet rbmqmsgque_MqContextC_ServiceCreate (MqContextC_ARGS)
  Ruby: ctx.ServiceCreate(token:string[4], callback:callable) → C-API
create a link between a service-token and a service-callback …
 
static OT_ProcRet rbmqmsgque_MqContextC_ServiceDelete (MqContextC_ARGS)
  Ruby: ctx.ServiceDelete(token:string[4]) → C-API
delete a service. …
 
static OT_ProcRet rbmqmsgque_MqContextC_ServiceIsTransaction (MqContextC_ARGS)
  Ruby: bool ctx.ServiceIsTransaction() → C-API
check if the ongoing-service-call belongs to a transaction …
 
static OT_ProcRet rbmqmsgque_MqContextC_ServiceProxy (MqContextC_ARGS)
  Ruby: ctx.ServiceProxy(token:string[4], ?id:MqSlaveE|int32=MQ_SLAVE_OTHER?) → C-API
create a service to link a master-context with a slave-context. …
 
static OT_ProcRet rbmqmsgque_MqContextC_ServiceProxyCtx (MqContextC_ARGS)
  Ruby: ctx.ServiceProxyCtx(token:string[4], target:MqContextC) → C-API
same as MqServiceProxy but use an MqContextC as input.
 
static OT_ProcRet rbmqmsgque_MqContextC_ServiceProxyCtxExists (MqContextC_ARGS)
  Ruby: bool ctx.ServiceProxyCtxExists(token:string[4], target:MqContextC) → C-API
check if service who belongs to token is a proxy-service
 
static OT_ProcRet rbmqmsgque_MqContextC_ServiceProxyRoundRobin (MqContextC_ARGS)
  Ruby: ctx.ServiceProxyRoundRobin(token:string[4], ident:string) → C-API
create a proxy-service using Round-Robin as load-balancer …
 
static OT_ProcRet rbmqmsgque_MqContextC_ServiceStorage (MqContextC_ARGS)
  Ruby: ctx.ServiceStorage(token:string[4]) → C-API
setup a service listen on a MqContextC_ServiceApi_Identifer and save all read-data-package into the STORAGE …
 
static OT_ProcRet rbmqmsgque_MqContextC_ServiceTokenCheck (MqContextC_ARGS)
  Ruby: bool ctx.ServiceTokenCheck(token:string[4]) → C-API
in an ongoing-service-call check if the current MqContextC_ServiceApi_Identifer is token …
 
static OT_ProcRet rbmqmsgque_MqContextC_ServiceTokenExists (MqContextC_ARGS)
  Ruby: bool ctx.ServiceTokenExists(token:string[4]) → C-API
check if the MqContextC_ServiceApi_Identifer token is defined as ctx service …
 
static OT_ProcRet rbmqmsgque_MqContextC_ServiceTokenGet (MqContextC_ARGS)
  Ruby: string[4] ctx.ServiceTokenGet() → C-API
in an ongoing-service-call get the current MqContextC_ServiceApi_Identifer …
 
static OT_ProcRet rbmqmsgque_MqContextC_SlaveGetMaster (MqContextC_ARGS)
  Ruby: MqContextC ctx.SlaveGetMaster() → C-API
opposite function of MqSlaveGetFilter
 
static OT_ProcRet rbmqmsgque_MqContextC_SlaveGet (MqContextC_ARGS)
  Ruby: MqContextC ctx.SlaveGet(id:MqSlaveE|int32) → C-API
get the slave-context from a master-context …
 
static OT_ProcRet rbmqmsgque_MqContextC_SlaveGetFilter (MqContextC_ARGS)
  Ruby: MqContextC ctx.SlaveGetFilter() → C-API
get the filter-ctx or the master-ctx …
 
static OT_ProcRet rbmqmsgque_MqContextC_SlaveGetProxy (MqContextC_ARGS)
  Ruby: MqContextC ctx.SlaveGetProxy(id:MqSlaveE|int32) → C-API
on slave return the master and on master return the slave identified by id.
 
static OT_ProcRet rbmqmsgque_MqContextC_SlaveCheck (MqContextC_ARGS)
  Ruby: bool ctx.SlaveCheck(id:MqSlaveE|int32) → C-API
check if slave-id is valid
 
static OT_ProcRet rbmqmsgque_MqContextC_SlaveCreate (MqContextC_ARGS)
  Ruby: ctx.SlaveCreate(id:MqSlaveE|int32, slave:MqContextC) → C-API
create a master/slave link between the master-parent-context and the slave-parent-context …
 
static OT_ProcRet rbmqmsgque_MqContextC_SlaveDelete (MqContextC_ARGS)
  Ruby: ctx.SlaveDelete(id:MqSlaveE|int32) → C-API
Delete a slave object from a master/slave link identified by id. …
 
static OT_ProcRet rbmqmsgque_MqContextC_SlaveIs (MqContextC_ARGS)
  Ruby: bool ctx.SlaveIs() → C-API
is the context a slave-context ? …
 
static OT_ProcRet rbmqmsgque_MqContextC_SlaveWorker (MqContextC_ARGS)
  Ruby: ctx.SlaveWorker(id:MqSlaveE|int32, ?fct:string="WORKER"?, ?args:MkBufferListC...=nil?) → C-API
create a master/slave link using the image of the ctx object self. …
 
static OT_ProcRet rbmqmsgque_MqContextC_StorageDelete (MqContextC_ARGS)
  Ruby: int32 ctx.StorageDelete(?*transLIdP_inout:int32=0?) → C-API
delete the storage-row identified by the transLIdP_inout …
 
static OT_ProcRet rbmqmsgque_MqContextC_StorageImport (MqContextC_ARGS)
  Ruby: int32 ctx.StorageImport(?*transLIdP_inout:int32=0?) → C-API
import the storage-package into the read-data-package …
 
static OT_ProcRet rbmqmsgque_MqContextC_StorageClose (MqContextC_ARGS)
  Ruby: ctx.StorageClose() → C-API
close the storage. …
 
static OT_ProcRet rbmqmsgque_MqContextC_StorageDecrRef (MqContextC_ARGS)
  Ruby: ctx.StorageDecrRef(transLId:int32) → C-API
decrease the internal refCount lock of the database-entry
 
static OT_ProcRet rbmqmsgque_MqContextC_StorageIncrRef (MqContextC_ARGS)
  Ruby: ctx.StorageIncrRef(transLId:int32) → C-API
increase the internal refCount lock of the database-entry
 
static OT_ProcRet rbmqmsgque_MqContextC_StorageLog (MqContextC_ARGS)
  Ruby: ctx.StorageLog(?callfunc:string="MK_NULL"?) → C-API
log the storage the status of the open transactions
 
static OT_ProcRet rbmqmsgque_MqContextC_StorageOpen (MqContextC_ARGS)
  Ruby: ctx.StorageOpen(storageFile:string) → C-API
switch to a file-based-transaction-database …
 
static OT_ProcRet rbmqmsgque_MqContextC_StorageCount (MqContextC_ARGS)
  Ruby: int32 ctx.StorageCount() → C-API
count the number of storage-rows …
 
static OT_ProcRet rbmqmsgque_MqContextC_StorageErrCnt (MqContextC_ARGS)
  Ruby: int32 ctx.StorageErrCnt(transLId:int32) → C-API
increment and return the database row-error-count for the row defined with transLId
 
static OT_ProcRet rbmqmsgque_MqContextC_StorageExport (MqContextC_ARGS)
  Ruby: int32 ctx.StorageExport() → C-API
export the read-data-package into the STORAGE …
 
static OT_ProcRet rbmqmsgque_MqContextC_StorageResolve (MqContextC_ARGS)
  Ruby: {otherCtxP:MqContextC otherLIdP:int32} ctx.StorageResolve() → C-API
extract the context->link.protect.rmtTransLId entry from the database
 
static OT_ProcRet rbmqmsgque_MqContextC_Create (OtClass_ARGS)
  Ruby: (constructor,static) MqContextC MqContextC.Create(?tmpl:MqContextC=nil?) → C-API
create and initialize the MqContextC ...
 
static OT_ProcRet rbmqmsgque_MqContextC_new (CONSTR_ARGS)
  Ruby: (constructor,static) MqContextC MqContextC.new(?tmpl:MqContextC=nil?) → C-API
create and initialize the MqContextC ...
 
static enum MkErrorE rbmqmsgque_Idle (MK_RT mkrt, MQ_CTX const ctx, MK_PTR const data)
 
static void rbmqmsgque_MarkData (MK_RT mkrt, MK_PTR data)
 
void rbmqmsgque_MqContextC_Init (MK_RT mkrt, MQ_RT mqrt)
 

Variables

OT_CLS_T OT_CLASS
 
static MK_TYP MqContextCTT = NULL
 
OT_OBJ_T rbmqmsgque_MqContextC_MK_NULL = 0
 
static rb_data_type_t rbmqmsgque_MqContextC_T
 

Detailed Description

tag: nhi1-release-250425

Copyright
(C) NHI - #1 - Project - Group This software has NO permission to copy, please contact AUTHOR for additional information

Definition in file MqContextC_rb.c.

Macro Definition Documentation

◆ ClassFactoryGet_doc

#define ClassFactoryGet_doc   "MqFactoryC ctx.ClassFactoryGet() (const)"

doc definition

Definition at line 113 of file MqContextC_rb.c.

◆ ClassFactorySet_doc

#define ClassFactorySet_doc   "ctx.ClassFactorySet(item:MqFactoryC)"

Definition at line 116 of file MqContextC_rb.c.

◆ ClassIdentGet_doc

#define ClassIdentGet_doc   "string ctx.ClassIdentGet() (const)"

Definition at line 117 of file MqContextC_rb.c.

◆ ClassIdentSet_doc

#define ClassIdentSet_doc   "ctx.ClassIdentSet(ident:string)"

Definition at line 118 of file MqContextC_rb.c.

◆ ClassOriginalIdentGet_doc

#define ClassOriginalIdentGet_doc   "string ctx.ClassOriginalIdentGet() (const)"

Definition at line 119 of file MqContextC_rb.c.

◆ ConfigCheckStartAs_doc

#define ConfigCheckStartAs_doc   "bool ctx.ConfigCheckStartAs(data:MqStartE)"

Definition at line 125 of file MqContextC_rb.c.

◆ ConfigGetBuffersize_doc

#define ConfigGetBuffersize_doc   "int32 ctx.ConfigGetBuffersize() (const)"

Definition at line 126 of file MqContextC_rb.c.

◆ ConfigGetIdentFrom_doc

#define ConfigGetIdentFrom_doc   "MqIdentE ctx.ConfigGetIdentFrom()"

Definition at line 127 of file MqContextC_rb.c.

◆ ConfigGetIoPipe_doc

#define ConfigGetIoPipe_doc   "int32 ctx.ConfigGetIoPipe()"

Definition at line 128 of file MqContextC_rb.c.

◆ ConfigGetIoTcp_doc

#define ConfigGetIoTcp_doc   "{host:string port:string myhost:string myport:string} ctx.ConfigGetIoTcp()"

Definition at line 168 of file MqContextC_rb.c.

◆ ConfigGetIoTcpL_doc

#define ConfigGetIoTcpL_doc   "MkBufferListC ctx.ConfigGetIoTcpL()"

Definition at line 122 of file MqContextC_rb.c.

◆ ConfigGetIoUds_doc

#define ConfigGetIoUds_doc   "string ctx.ConfigGetIoUds() (const)"

Definition at line 129 of file MqContextC_rb.c.

◆ ConfigGetIsParent_doc

#define ConfigGetIsParent_doc   "bool ctx.ConfigGetIsParent()"

Definition at line 130 of file MqContextC_rb.c.

◆ ConfigGetIsServer_doc

#define ConfigGetIsServer_doc   "bool ctx.ConfigGetIsServer()"

Definition at line 131 of file MqContextC_rb.c.

◆ ConfigGetIsString_doc

#define ConfigGetIsString_doc   "bool ctx.ConfigGetIsString()"

Definition at line 132 of file MqContextC_rb.c.

◆ ConfigGetName_doc

#define ConfigGetName_doc   "string ctx.ConfigGetName() (const)"

Definition at line 133 of file MqContextC_rb.c.

◆ ConfigGetPkgsize_doc

#define ConfigGetPkgsize_doc   "int32 ctx.ConfigGetPkgsize() (const)"

Definition at line 134 of file MqContextC_rb.c.

◆ ConfigGetPostfix_doc

#define ConfigGetPostfix_doc   "string ctx.ConfigGetPostfix() (const)"

Definition at line 135 of file MqContextC_rb.c.

◆ ConfigGetPrefix_doc

#define ConfigGetPrefix_doc   "string ctx.ConfigGetPrefix() (const)"

Definition at line 136 of file MqContextC_rb.c.

◆ ConfigGetStartAs_doc

#define ConfigGetStartAs_doc   "MqStartE ctx.ConfigGetStartAs()"

Definition at line 137 of file MqContextC_rb.c.

◆ ConfigGetStatusIs_doc

#define ConfigGetStatusIs_doc   "MqStatusIsEF ctx.ConfigGetStatusIs()"

Definition at line 138 of file MqContextC_rb.c.

◆ ConfigGetStorage_doc

#define ConfigGetStorage_doc   "string ctx.ConfigGetStorage() (const)"

Definition at line 139 of file MqContextC_rb.c.

◆ ConfigGetTimeout_doc

#define ConfigGetTimeout_doc   "MkTimeoutE|int32 ctx.ConfigGetTimeout() (const)"

Definition at line 140 of file MqContextC_rb.c.

◆ ConfigReset_doc

#define ConfigReset_doc   "ctx.ConfigReset()"

Definition at line 141 of file MqContextC_rb.c.

◆ ConfigSetAllDebug_doc

#define ConfigSetAllDebug_doc   "ctx.ConfigSetAllDebug(data:int32)"

Definition at line 142 of file MqContextC_rb.c.

◆ ConfigSetBgError_doc

#define ConfigSetBgError_doc   "ctx.ConfigSetBgError(?callback:callable=nil?)"

Definition at line 143 of file MqContextC_rb.c.

◆ ConfigSetBuffersize_doc

#define ConfigSetBuffersize_doc   "ctx.ConfigSetBuffersize(data:int32)"

Definition at line 144 of file MqContextC_rb.c.

◆ ConfigSetConfigFile_doc

#define ConfigSetConfigFile_doc   "ctx.ConfigSetConfigFile(filename:string)"

Definition at line 145 of file MqContextC_rb.c.

◆ ConfigSetDaemon_doc

#define ConfigSetDaemon_doc   "ctx.ConfigSetDaemon(pidfile:string)"

Definition at line 146 of file MqContextC_rb.c.

◆ ConfigSetEvent_doc

#define ConfigSetEvent_doc   "ctx.ConfigSetEvent(?callback:callable=nil?)"

Definition at line 147 of file MqContextC_rb.c.

◆ ConfigSetIdentFrom_doc

#define ConfigSetIdentFrom_doc   "ctx.ConfigSetIdentFrom(data:MqIdentE)"

Definition at line 148 of file MqContextC_rb.c.

◆ ConfigSetIgnoreExit_doc

#define ConfigSetIgnoreExit_doc   "ctx.ConfigSetIgnoreExit(data:bool)"

Definition at line 149 of file MqContextC_rb.c.

◆ ConfigSetIoPipe_doc

#define ConfigSetIoPipe_doc   "ctx.ConfigSetIoPipe(fh:int32)"

Definition at line 150 of file MqContextC_rb.c.

◆ ConfigSetIoTcp_doc

#define ConfigSetIoTcp_doc   "ctx.ConfigSetIoTcp(?host:string=\"nil\"?, ?port:string=\"nil\"?, ?myhost:string=\"nil\"?, ?myport:string=\"nil\"?)"

Definition at line 151 of file MqContextC_rb.c.

◆ ConfigSetIoTcpL_doc

#define ConfigSetIoTcpL_doc   "ctx.ConfigSetIoTcpL(vals:MkBufferListC)"

Definition at line 152 of file MqContextC_rb.c.

◆ ConfigSetIoUds_doc

#define ConfigSetIoUds_doc   "ctx.ConfigSetIoUds(file:string)"

Definition at line 153 of file MqContextC_rb.c.

◆ ConfigSetIsServer_doc

#define ConfigSetIsServer_doc   "ctx.ConfigSetIsServer(data:bool)"

Definition at line 154 of file MqContextC_rb.c.

◆ ConfigSetIsString_doc

#define ConfigSetIsString_doc   "ctx.ConfigSetIsString(data:bool)"

Definition at line 155 of file MqContextC_rb.c.

◆ ConfigSetName_doc

#define ConfigSetName_doc   "ctx.ConfigSetName(data:string)"

Definition at line 156 of file MqContextC_rb.c.

◆ ConfigSetPkgsize_doc

#define ConfigSetPkgsize_doc   "ctx.ConfigSetPkgsize(data:int32)"

Definition at line 157 of file MqContextC_rb.c.

◆ ConfigSetPostfix_doc

#define ConfigSetPostfix_doc   "ctx.ConfigSetPostfix(data:string)"

Definition at line 158 of file MqContextC_rb.c.

◆ ConfigSetPrefix_doc

#define ConfigSetPrefix_doc   "ctx.ConfigSetPrefix(data:string)"

Definition at line 159 of file MqContextC_rb.c.

◆ ConfigSetServerCleanup_doc

#define ConfigSetServerCleanup_doc   "ctx.ConfigSetServerCleanup(?callback:callable=nil?)"

Definition at line 160 of file MqContextC_rb.c.

◆ ConfigSetServerSetup_doc

#define ConfigSetServerSetup_doc   "ctx.ConfigSetServerSetup(?callback:callable=nil?)"

Definition at line 161 of file MqContextC_rb.c.

◆ ConfigSetStartAs_doc

#define ConfigSetStartAs_doc   "ctx.ConfigSetStartAs(data:MqStartE)"

Definition at line 162 of file MqContextC_rb.c.

◆ ConfigSetStartAsString_doc

#define ConfigSetStartAsString_doc   "ctx.ConfigSetStartAsString(data:string)"

Definition at line 163 of file MqContextC_rb.c.

◆ ConfigSetStorage_doc

#define ConfigSetStorage_doc   "ctx.ConfigSetStorage(data:string)"

Definition at line 164 of file MqContextC_rb.c.

◆ ConfigSetTimeout_doc

#define ConfigSetTimeout_doc   "ctx.ConfigSetTimeout(data:MkTimeoutE|int32)"

Definition at line 165 of file MqContextC_rb.c.

◆ Create_doc

#define Create_doc   "MqContextC MqContextC.Create(?tmpl:MqContextC=nil?)"

Definition at line 171 of file MqContextC_rb.c.

◆ EnvProtect_doc

#define EnvProtect_doc   "ctx.EnvProtect()"

Definition at line 199 of file MqContextC_rb.c.

◆ EnvRestore_doc

#define EnvRestore_doc   "ctx.EnvRestore()"

Definition at line 200 of file MqContextC_rb.c.

◆ ErrorCopy_doc

#define ErrorCopy_doc   "MkErrorE targetCtx.ErrorCopy(sourceCtx:MqContextC) (const)"

Definition at line 186 of file MqContextC_rb.c.

◆ ErrorFORMAT_doc

#define ErrorFORMAT_doc   "MkErrorC fmtobj.ErrorFORMAT() (const)"

Definition at line 180 of file MqContextC_rb.c.

◆ ErrorMove_doc

#define ErrorMove_doc   "MkErrorE targetCtx.ErrorMove(sourceCtx:MqContextC) (const)"

Definition at line 187 of file MqContextC_rb.c.

◆ Exit_doc

#define Exit_doc   "int32 ctx.Exit(?callfunc:string=\"MK_NULL\"?, ?callfile:string=\"MK_NULL\"?, ?callline:int32=-1?)"

Definition at line 203 of file MqContextC_rb.c.

◆ GetBuffer_doc

#define GetBuffer_doc   "MkBufferC ctx.GetBuffer()"

Definition at line 181 of file MqContextC_rb.c.

◆ GetNull_doc

#define GetNull_doc   "MqContextC MqContextC.GetNull()"

Definition at line 175 of file MqContextC_rb.c.

◆ GetRoot_doc

#define GetRoot_doc   "MqContextC ctx.GetRoot()"

Definition at line 206 of file MqContextC_rb.c.

◆ HandleResolve_doc

#define HandleResolve_doc   "MqContextC MqContextC.HandleResolve(netHdl:MK_HDL)"

Definition at line 176 of file MqContextC_rb.c.

◆ Instances_doc

#define Instances_doc   "MqContextC MqContextC.Instances()"

Definition at line 177 of file MqContextC_rb.c.

◆ LinkConnect_doc

#define LinkConnect_doc   "ctx.LinkConnect()"

Definition at line 212 of file MqContextC_rb.c.

◆ LinkCreate_doc

#define LinkCreate_doc   "ctx.LinkCreate(?args:MkBufferListC...=nil?)"

Definition at line 213 of file MqContextC_rb.c.

◆ LinkCreateChild_doc

#define LinkCreateChild_doc   "ctx.LinkCreateChild(parent:MqContextC, ?args:MkBufferListC...=nil?)"

Definition at line 214 of file MqContextC_rb.c.

◆ LinkDelete_doc

#define LinkDelete_doc   "ctx.LinkDelete()"

Definition at line 215 of file MqContextC_rb.c.

◆ LinkGetCtxId_doc

#define LinkGetCtxId_doc   "int32 ctx.LinkGetCtxId()"

Definition at line 216 of file MqContextC_rb.c.

◆ LinkGetParent_doc

#define LinkGetParent_doc   "MqContextC ctx.LinkGetParent()"

Definition at line 209 of file MqContextC_rb.c.

◆ LinkGetTargetIdent_doc

#define LinkGetTargetIdent_doc   "string ctx.LinkGetTargetIdent()"

Definition at line 217 of file MqContextC_rb.c.

◆ LinkIsConnected_doc

#define LinkIsConnected_doc   "bool ctx.LinkIsConnected()"

Definition at line 218 of file MqContextC_rb.c.

◆ LinkIsParent_doc

#define LinkIsParent_doc   "bool ctx.LinkIsParent()"

Definition at line 219 of file MqContextC_rb.c.

◆ LinkShutdown_doc

#define LinkShutdown_doc   "ctx.LinkShutdown()"

Definition at line 220 of file MqContextC_rb.c.

◆ LogConfig_doc

#define LogConfig_doc   "ctx.LogConfig(?fmtobj:MkObjectC=nil?, ?debug:int32=0?, ?callfunc:string=\"MK_NULL\"?, ?lvl:int32=0?) (const)"

Definition at line 190 of file MqContextC_rb.c.

◆ LogEnv_doc

#define LogEnv_doc   "ctx.LogEnv(?fmtobj:MkObjectC=nil?, ?debug:int32=0?, ?callfunc:string=\"MK_NULL\"?, ?lvl:int32=0?) (const)"

Definition at line 191 of file MqContextC_rb.c.

◆ LogLink_doc

#define LogLink_doc   "ctx.LogLink(?fmtobj:MkObjectC=nil?, ?debug:int32=0?, ?callfunc:string=\"MK_NULL\"?, ?lvl:int32=0?) (const)"

Definition at line 192 of file MqContextC_rb.c.

◆ LogParentOrChild_doc

#define LogParentOrChild_doc   "string ctx.LogParentOrChild() (const)"

Definition at line 223 of file MqContextC_rb.c.

◆ LogServerOrClient_doc

#define LogServerOrClient_doc   "string ctx.LogServerOrClient() (const)"

Definition at line 224 of file MqContextC_rb.c.

◆ LogSetup_doc

#define LogSetup_doc   "ctx.LogSetup(?fmtobj:MkObjectC=nil?, ?debug:int32=0?, ?callfunc:string=\"MK_NULL\"?, ?lvl:int32=0?) (const)"

Definition at line 193 of file MqContextC_rb.c.

◆ LogShort_doc

#define LogShort_doc   "ctx.LogShort(?fmtobj:MkObjectC=nil?, ?debug:int32=0?, ?callfunc:string=\"MK_NULL\"?, ?lvl:int32=0?, ?label:string=\"nil\"?) (const)"

Definition at line 194 of file MqContextC_rb.c.

◆ LogType_doc

#define LogType_doc   "ctx.LogType(?fmtobj:MkObjectC=nil?, ?debug:int32=0?, ?callfunc:string=\"MK_NULL\"?, ?lvl:int32=0?) (const)"

Definition at line 195 of file MqContextC_rb.c.

◆ META_FILE_NAME

#define META_FILE_NAME   "MqContextC_rb.c"

Definition at line 10 of file MqContextC_rb.c.

◆ new_doc

#define new_doc   "MqContextC MqContextC.new(?tmpl:MqContextC=nil?)"

Definition at line 172 of file MqContextC_rb.c.

◆ Next_doc

#define Next_doc   "MqContextC ctx.Next()"

Definition at line 182 of file MqContextC_rb.c.

◆ OT_CLASS

#define OT_CLASS   NS(MqContextC)

Definition at line 14 of file MqContextC_rb.c.

◆ OT_CLASS_NAME

#define OT_CLASS_NAME   "MqContextC"

Definition at line 15 of file MqContextC_rb.c.

◆ OT_LNG2META

#define OT_LNG2META ( O)
Value:
MqCtx(VAL2MNG(O))
VAL2MNG
#define VAL2MNG(val)
Definition LibMkKernel_rb.h:733
MqCtx
static MQ_CTX MqCtx(MK_MNG mng)
cast a unknown-object into an MqContextS pointer or NULL if not possible
Definition LibMqMsgque_mq.h:4227

Definition at line 17 of file MqContextC_rb.c.

◆ OT_SETUP_hdl

#define OT_SETUP_hdl   OT_SETUP_hdl_tmpl(MqContextC);

Definition at line 87 of file MqContextC_rb.c.

◆ OT_SETUP_hdl__null_allow

#define OT_SETUP_hdl__null_allow   OT_SETUP_hdl_tmpl__null_allow(MqContextC);

Definition at line 88 of file MqContextC_rb.c.

◆ OT_SETUP_hdl_constr

#define OT_SETUP_hdl_constr
Value:
AllRtSetup_NULL; \
OT_OBJ_T clazz = self; \
MqContextC_type hdl = (MqContextC_type) &MkERROR;
OT_OBJ_T
#define OT_OBJ_T
Definition LibMkKernel_rb.h:91
AllRtSetup_NULL
#define AllRtSetup_NULL
Definition LibMqMsgque_mq.h:9397
MkERROR
#define MkERROR
MqContextC_type
#define MqContextC_type
same as MqContextS but useable in a class-macro as: class##_type …
Definition LibMqMsgque_mq.h:4175

Definition at line 89 of file MqContextC_rb.c.

89#define OT_SETUP_hdl_constr AllRtSetup_NULL; \
90 OT_OBJ_T clazz = self; \
91 MqContextC_type hdl = (MqContextC_type) &MkERROR;

◆ OT_SETUP_hdl_destr

#define OT_SETUP_hdl_destr   OT_SETUP_hdl_tmpl__null_allow(MqContextC);

Definition at line 92 of file MqContextC_rb.c.

◆ OT_SETUP_hdl_static

#define OT_SETUP_hdl_static
Value:
AllRtSetup_NULL; \
__attribute__((unused)) MK_TYP hdl = MqContextC##_TT;

Definition at line 93 of file MqContextC_rb.c.

93#define OT_SETUP_hdl_static AllRtSetup_NULL; \
94 __attribute__((unused)) MK_TYP hdl = MqContextC##_TT;

◆ OT_SETUP_hdl_static_constr

#define OT_SETUP_hdl_static_constr   OT_SETUP_hdl_static

Definition at line 95 of file MqContextC_rb.c.

◆ Prev_doc

#define Prev_doc   "MqContextC ctx.Prev()"

Definition at line 183 of file MqContextC_rb.c.

◆ ProcessEvent_doc

#define ProcessEvent_doc   "ctx.ProcessEvent(?wait:MqWaitOnEventE=NO?, ?timeout:MkTimeoutE|int32=DEFAULT?)"

Definition at line 227 of file MqContextC_rb.c.

◆ ProxyForward_doc

#define ProxyForward_doc   "sourceCtx.ProxyForward(targetCtx:MqContextC, ?dump:MqDumpC=nil?, ?timeout:MkTimeoutE|int32=DEFAULT?)"

Definition at line 230 of file MqContextC_rb.c.

◆ ProxyItem_doc

#define ProxyItem_doc   "sourceCtx.ProxyItem(targetCtx:MqContextC)"

Definition at line 231 of file MqContextC_rb.c.

◆ ReadALL_doc

#define ReadALL_doc   "MkBufferListC ctx.ReadALL(?val_inout:MkBufferListC=nil?)"

Definition at line 234 of file MqContextC_rb.c.

◆ ReadBFL_doc

#define ReadBFL_doc   "MkBufferListC ctx.ReadBFL()"

Definition at line 237 of file MqContextC_rb.c.

◆ ReadBIN_doc

#define ReadBIN_doc   "binary ctx.ReadBIN()"

Definition at line 252 of file MqContextC_rb.c.

◆ ReadBinaryR_doc

#define ReadBinaryR_doc   "binary ctx.ReadBinaryR()"

Definition at line 254 of file MqContextC_rb.c.

◆ ReadBOL_doc

#define ReadBOL_doc   "bool ctx.ReadBOL()"

Definition at line 253 of file MqContextC_rb.c.

◆ ReadBUF_doc

#define ReadBUF_doc   "MkBufferC ctx.ReadBUF()"

Definition at line 238 of file MqContextC_rb.c.

◆ ReadDbg_doc

#define ReadDbg_doc   "ctx.ReadDbg()"

Definition at line 241 of file MqContextC_rb.c.

◆ ReadDBL_doc

#define ReadDBL_doc   "double ctx.ReadDBL()"

Definition at line 255 of file MqContextC_rb.c.

◆ ReadFLT_doc

#define ReadFLT_doc   "float ctx.ReadFLT()"

Definition at line 256 of file MqContextC_rb.c.

◆ ReadGetNextType_doc

#define ReadGetNextType_doc   "MkTypeE ctx.ReadGetNextType()"

Definition at line 242 of file MqContextC_rb.c.

◆ ReadGetNumItems_doc

#define ReadGetNumItems_doc   "int32 ctx.ReadGetNumItems()"

Definition at line 243 of file MqContextC_rb.c.

◆ ReadHDL_doc

#define ReadHDL_doc   "MK_HDL ctx.ReadHDL()"

Definition at line 257 of file MqContextC_rb.c.

◆ ReadI16_doc

#define ReadI16_doc   "int16 ctx.ReadI16()"

Definition at line 258 of file MqContextC_rb.c.

◆ ReadI32_doc

#define ReadI32_doc   "int32 ctx.ReadI32()"

Definition at line 259 of file MqContextC_rb.c.

◆ ReadI64_doc

#define ReadI64_doc   "int64 ctx.ReadI64()"

Definition at line 260 of file MqContextC_rb.c.

◆ ReadI8_doc

#define ReadI8_doc   "int8 ctx.ReadI8()"

Definition at line 261 of file MqContextC_rb.c.

◆ ReadItemExists_doc

#define ReadItemExists_doc   "bool ctx.ReadItemExists()"

Definition at line 244 of file MqContextC_rb.c.

◆ ReadL_END_doc

#define ReadL_END_doc   "ctx.ReadL_END()"

Definition at line 245 of file MqContextC_rb.c.

◆ ReadL_START_doc

#define ReadL_START_doc   "ctx.ReadL_START(?buf:MkBufferC=nil?)"

Definition at line 246 of file MqContextC_rb.c.

◆ ReadLIST_doc

#define ReadLIST_doc   "[list...] ctx.ReadLIST()"

Definition at line 262 of file MqContextC_rb.c.

◆ ReadLONG_doc

#define ReadLONG_doc   "long ctx.ReadLONG()"

Definition at line 263 of file MqContextC_rb.c.

◆ ReadNEXT_doc

#define ReadNEXT_doc   "obj ctx.ReadNEXT()"

Definition at line 264 of file MqContextC_rb.c.

◆ ReadSTR_doc

#define ReadSTR_doc   "string ctx.ReadSTR()"

Definition at line 265 of file MqContextC_rb.c.

◆ ReadStringR_doc

#define ReadStringR_doc   "string ctx.ReadStringR()"

Definition at line 266 of file MqContextC_rb.c.

◆ ReadT_END_doc

#define ReadT_END_doc   "ctx.ReadT_END()"

Definition at line 247 of file MqContextC_rb.c.

◆ ReadT_START_doc

#define ReadT_START_doc   "ctx.ReadT_START()"

Definition at line 248 of file MqContextC_rb.c.

◆ ReadUndo_doc

#define ReadUndo_doc   "ctx.ReadUndo()"

Definition at line 249 of file MqContextC_rb.c.

◆ RouteCreate_doc

#define RouteCreate_doc   "ctx.RouteCreate(route:string, service:string, ?overwrite:bool=false?)"

Definition at line 272 of file MqContextC_rb.c.

◆ RouteDelete_doc

#define RouteDelete_doc   "ctx.RouteDelete(route:string, service:string, ?overwrite:bool=false?)"

Definition at line 273 of file MqContextC_rb.c.

◆ RouteGetPath_doc

#define RouteGetPath_doc   "string ctx.RouteGetPath()"

Definition at line 278 of file MqContextC_rb.c.

◆ RouteGetTree_doc

#define RouteGetTree_doc   "MkBufferListC ctx.RouteGetTree()"

Definition at line 269 of file MqContextC_rb.c.

◆ RouteResolve_doc

#define RouteResolve_doc   "[MqContextC...] ctx.RouteResolve(ident:string, ?retnum:int32=-1?)"

Definition at line 274 of file MqContextC_rb.c.

◆ RouteTraverse_doc

#define RouteTraverse_doc   "ctx.RouteTraverse(service:string, ?args:MkBufferListC...=nil?)"

Definition at line 275 of file MqContextC_rb.c.

◆ S_INIT

#define S_INIT   NS(sInit)(MK_RT_CALL_ONLY)

Definition at line 69 of file MqContextC_rb.c.

◆ Send_doc

#define Send_doc   "ctx.Send(cstr:string, args:args...)"

Definition at line 281 of file MqContextC_rb.c.

◆ SendBFL_doc

#define SendBFL_doc   "ctx.SendBFL(val:MkBufferListC)"

Definition at line 282 of file MqContextC_rb.c.

◆ SendBIN_doc

#define SendBIN_doc   "ctx.SendBIN(val:binary)"

Definition at line 283 of file MqContextC_rb.c.

◆ SendBinaryR_doc

#define SendBinaryR_doc   "ctx.SendBinaryR(val:binary)"

Definition at line 287 of file MqContextC_rb.c.

◆ SendBOL_doc

#define SendBOL_doc   "ctx.SendBOL(val:bool)"

Definition at line 284 of file MqContextC_rb.c.

◆ SendBUF_doc

#define SendBUF_doc   "ctx.SendBUF(val:MkBufferC)"

Definition at line 285 of file MqContextC_rb.c.

◆ SendBUS_FLAT_doc

#define SendBUS_FLAT_doc   "ctx.SendBUS_FLAT(val:MkBufferStreamC)"

Definition at line 286 of file MqContextC_rb.c.

◆ SendDBL_doc

#define SendDBL_doc   "ctx.SendDBL(val:double)"

Definition at line 288 of file MqContextC_rb.c.

◆ SendEND_AND_CALLBACK_doc

#define SendEND_AND_CALLBACK_doc   "ctx.SendEND_AND_CALLBACK(token:string[4], callback:callable, ?timeout:MkTimeoutE|int32=DEFAULT?)"

Definition at line 290 of file MqContextC_rb.c.

◆ SendEND_AND_SUB_doc

#define SendEND_AND_SUB_doc   "ctx.SendEND_AND_SUB(token:string[4], callback:callable, ?timeout:MkTimeoutE|int32=DEFAULT?)"

Definition at line 291 of file MqContextC_rb.c.

◆ SendEND_AND_TRANSACTION_doc

#define SendEND_AND_TRANSACTION_doc   "ctx.SendEND_AND_TRANSACTION(token:string[4], callback:string[4], ?timeout:MkTimeoutE|int32=DEFAULT?)"

Definition at line 292 of file MqContextC_rb.c.

◆ SendEND_AND_WAIT_doc

#define SendEND_AND_WAIT_doc   "ctx.SendEND_AND_WAIT(token:string[4], ?timeout:MkTimeoutE|int32=DEFAULT?)"

Definition at line 293 of file MqContextC_rb.c.

◆ SendEND_doc

#define SendEND_doc   "ctx.SendEND(token:string[4], ?timeout:MkTimeoutE|int32=DEFAULT?)"

Definition at line 289 of file MqContextC_rb.c.

◆ SendERROR_doc

#define SendERROR_doc   "ctx.SendERROR()"

Definition at line 294 of file MqContextC_rb.c.

◆ SendFLT_doc

#define SendFLT_doc   "ctx.SendFLT(val:float)"

Definition at line 295 of file MqContextC_rb.c.

◆ SendHDL_doc

#define SendHDL_doc   "ctx.SendHDL(val:MK_HDL)"

Definition at line 296 of file MqContextC_rb.c.

◆ SendI16_doc

#define SendI16_doc   "ctx.SendI16(val:int16)"

Definition at line 297 of file MqContextC_rb.c.

◆ SendI32_doc

#define SendI32_doc   "ctx.SendI32(val:int32)"

Definition at line 298 of file MqContextC_rb.c.

◆ SendI64_doc

#define SendI64_doc   "ctx.SendI64(val:int64)"

Definition at line 299 of file MqContextC_rb.c.

◆ SendI8_doc

#define SendI8_doc   "ctx.SendI8(val:int8)"

Definition at line 300 of file MqContextC_rb.c.

◆ SendL_END_doc

#define SendL_END_doc   "ctx.SendL_END()"

Definition at line 303 of file MqContextC_rb.c.

◆ SendL_FLAT_doc

#define SendL_FLAT_doc   "ctx.SendL_FLAT(val:MkBufferListC)"

Definition at line 304 of file MqContextC_rb.c.

◆ SendL_START_doc

#define SendL_START_doc   "ctx.SendL_START()"

Definition at line 305 of file MqContextC_rb.c.

◆ SendLONG_doc

#define SendLONG_doc   "ctx.SendLONG(val:long)"

Definition at line 301 of file MqContextC_rb.c.

◆ SendLTR_doc

#define SendLTR_doc   "ctx.SendLTR(transLId:int32)"

Definition at line 302 of file MqContextC_rb.c.

◆ SendRETURN_doc

#define SendRETURN_doc   "ctx.SendRETURN()"

Definition at line 306 of file MqContextC_rb.c.

◆ SendRETURN_SUB_doc

#define SendRETURN_SUB_doc   "ctx.SendRETURN_SUB()"

Definition at line 307 of file MqContextC_rb.c.

◆ SendSTART_doc

#define SendSTART_doc   "ctx.SendSTART()"

Definition at line 308 of file MqContextC_rb.c.

◆ SendSTR_doc

#define SendSTR_doc   "ctx.SendSTR(val:string)"

Definition at line 309 of file MqContextC_rb.c.

◆ SendStringR_doc

#define SendStringR_doc   "ctx.SendStringR(val:string)"

Definition at line 311 of file MqContextC_rb.c.

◆ SendSYNC_doc

#define SendSYNC_doc   "ctx.SendSYNC()"

Definition at line 310 of file MqContextC_rb.c.

◆ SendT_END_doc

#define SendT_END_doc   "ctx.SendT_END()"

Definition at line 312 of file MqContextC_rb.c.

◆ SendT_START_doc

#define SendT_START_doc   "ctx.SendT_START()"

Definition at line 313 of file MqContextC_rb.c.

◆ ServiceCreate_doc

#define ServiceCreate_doc   "ctx.ServiceCreate(token:string[4], callback:callable)"

Definition at line 316 of file MqContextC_rb.c.

◆ ServiceDelete_doc

#define ServiceDelete_doc   "ctx.ServiceDelete(token:string[4])"

Definition at line 317 of file MqContextC_rb.c.

◆ ServiceIsTransaction_doc

#define ServiceIsTransaction_doc   "bool ctx.ServiceIsTransaction()"

Definition at line 318 of file MqContextC_rb.c.

◆ ServiceProxy_doc

#define ServiceProxy_doc   "ctx.ServiceProxy(token:string[4], ?id:MqSlaveE|int32=MQ_SLAVE_OTHER?)"

Definition at line 319 of file MqContextC_rb.c.

◆ ServiceProxyCtx_doc

#define ServiceProxyCtx_doc   "ctx.ServiceProxyCtx(token:string[4], target:MqContextC)"

Definition at line 320 of file MqContextC_rb.c.

◆ ServiceProxyCtxExists_doc

#define ServiceProxyCtxExists_doc   "bool ctx.ServiceProxyCtxExists(token:string[4], target:MqContextC)"

Definition at line 321 of file MqContextC_rb.c.

◆ ServiceProxyRoundRobin_doc

#define ServiceProxyRoundRobin_doc   "ctx.ServiceProxyRoundRobin(token:string[4], ident:string)"

Definition at line 322 of file MqContextC_rb.c.

◆ ServiceStorage_doc

#define ServiceStorage_doc   "ctx.ServiceStorage(token:string[4])"

Definition at line 323 of file MqContextC_rb.c.

◆ ServiceTokenCheck_doc

#define ServiceTokenCheck_doc   "bool ctx.ServiceTokenCheck(token:string[4])"

Definition at line 324 of file MqContextC_rb.c.

◆ ServiceTokenExists_doc

#define ServiceTokenExists_doc   "bool ctx.ServiceTokenExists(token:string[4])"

Definition at line 325 of file MqContextC_rb.c.

◆ ServiceTokenGet_doc

#define ServiceTokenGet_doc   "string[4] ctx.ServiceTokenGet()"

Definition at line 326 of file MqContextC_rb.c.

◆ SetupRtFromObj_X

#define SetupRtFromObj_X ( hdl)
Value:
AllRtSetup_X(hdl)
AllRtSetup_X
#define AllRtSetup_X(x)
Definition LibMqMsgque_mq.h:9395

Definition at line 98 of file MqContextC_rb.c.

◆ SetupRtFromObj_XN

#define SetupRtFromObj_XN ( hdl)
Value:
AllRtSetup_XN(hdl)
AllRtSetup_XN
#define AllRtSetup_XN(x)
Definition LibMqMsgque_mq.h:9396

Definition at line 99 of file MqContextC_rb.c.

◆ SlaveCheck_doc

#define SlaveCheck_doc   "bool ctx.SlaveCheck(id:MqSlaveE|int32) (const)"

Definition at line 337 of file MqContextC_rb.c.

◆ SlaveCreate_doc

#define SlaveCreate_doc   "ctx.SlaveCreate(id:MqSlaveE|int32, slave:MqContextC)"

Definition at line 338 of file MqContextC_rb.c.

◆ SlaveDelete_doc

#define SlaveDelete_doc   "ctx.SlaveDelete(id:MqSlaveE|int32)"

Definition at line 339 of file MqContextC_rb.c.

◆ SlaveGet_doc

#define SlaveGet_doc   "MqContextC ctx.SlaveGet(id:MqSlaveE|int32)"

Definition at line 332 of file MqContextC_rb.c.

◆ SlaveGetFilter_doc

#define SlaveGetFilter_doc   "MqContextC ctx.SlaveGetFilter()"

Definition at line 333 of file MqContextC_rb.c.

◆ SlaveGetMaster_doc

#define SlaveGetMaster_doc   "MqContextC ctx.SlaveGetMaster()"

Definition at line 329 of file MqContextC_rb.c.

◆ SlaveGetProxy_doc

#define SlaveGetProxy_doc   "MqContextC ctx.SlaveGetProxy(id:MqSlaveE|int32)"

Definition at line 334 of file MqContextC_rb.c.

◆ SlaveIs_doc

#define SlaveIs_doc   "bool ctx.SlaveIs() (const)"

Definition at line 340 of file MqContextC_rb.c.

◆ SlaveWorker_doc

#define SlaveWorker_doc   "ctx.SlaveWorker(id:MqSlaveE|int32, ?fct:string=\"WORKER\"?, ?args:MkBufferListC...=nil?)"

Definition at line 341 of file MqContextC_rb.c.

◆ StorageClose_doc

#define StorageClose_doc   "ctx.StorageClose()"

Definition at line 348 of file MqContextC_rb.c.

◆ StorageCount_doc

#define StorageCount_doc   "int32 ctx.StorageCount()"

Definition at line 355 of file MqContextC_rb.c.

◆ StorageDecrRef_doc

#define StorageDecrRef_doc   "ctx.StorageDecrRef(transLId:int32)"

Definition at line 349 of file MqContextC_rb.c.

◆ StorageDelete_doc

#define StorageDelete_doc   "int32 ctx.StorageDelete(?*transLIdP_inout:int32=0?)"

Definition at line 344 of file MqContextC_rb.c.

◆ StorageErrCnt_doc

#define StorageErrCnt_doc   "int32 ctx.StorageErrCnt(transLId:int32)"

Definition at line 356 of file MqContextC_rb.c.

◆ StorageExport_doc

#define StorageExport_doc   "int32 ctx.StorageExport()"

Definition at line 357 of file MqContextC_rb.c.

◆ StorageImport_doc

#define StorageImport_doc   "int32 ctx.StorageImport(?*transLIdP_inout:int32=0?)"

Definition at line 345 of file MqContextC_rb.c.

◆ StorageIncrRef_doc

#define StorageIncrRef_doc   "ctx.StorageIncrRef(transLId:int32)"

Definition at line 350 of file MqContextC_rb.c.

◆ StorageLog_doc

#define StorageLog_doc   "ctx.StorageLog(?callfunc:string=\"MK_NULL\"?)"

Definition at line 351 of file MqContextC_rb.c.

◆ StorageOpen_doc

#define StorageOpen_doc   "ctx.StorageOpen(storageFile:string)"

Definition at line 352 of file MqContextC_rb.c.

◆ StorageResolve_doc

#define StorageResolve_doc   "{otherCtxP:MqContextC otherLIdP:int32} ctx.StorageResolve()"

Definition at line 358 of file MqContextC_rb.c.

Function Documentation

◆ rbmqmsgque_Idle()

static enum MkErrorE rbmqmsgque_Idle ( MK_RT mkrt,
MQ_CTX const ctx,
MK_PTR const data )
static

Definition at line 2997 of file MqContextC_rb.c.

3001 {
3002 rb_thread_schedule();
3003 return MK_OK;
3004}
MK_OK
MK_OK

◆ rbmqmsgque_LNG_CONSTR()

static OT_OBJ_T rbmqmsgque_LNG_CONSTR ( OT_CLS_T clazz,
MK_MNG mng,
int objc,
VALUE * objv )
inlinestatic

Definition at line 46 of file MqContextC_rb.c.

46 {
47 return MK(AtomObjCrt)(clazz,&NS(MqContextC_T),mng,objc,objv);
48}
MK
#define MK(n)
Definition LibMkKernel_rb.h:80
NS
#define NS(n)
Definition LibMqMsgque_rb.h:76
MqContextC_T
#define MqContextC_T
class as MqTypeCtxS-class-type, useable in a class-macro as: class##_T …
Definition LibMqMsgque_mq.h:4167

◆ rbmqmsgque_MarkData()

static void rbmqmsgque_MarkData ( MK_RT mkrt,
MK_PTR data )
static

Definition at line 3013 of file MqContextC_rb.c.

3013 {
3014 rb_gc_mark((VALUE)data);
3015}

◆ rbmqmsgque_MqContextC_Init()

void rbmqmsgque_MqContextC_Init ( MK_RT mkrt,
MQ_RT mqrt )

Definition at line 3017 of file MqContextC_rb.c.

3017 {
3018
3019 // init type
3020 MqContextCTT = MkTypeDup2(MqContextC_TT, "RbMqContextC");
3021 MqContextCT->argvFix = true;
3022 // https://stackoverflow.com/questions/26488029/embeded-ruby-in-a-cpp-thread-crashes
3023 // It fails because the Ruby VM is not thread safe
3024 MqContextCT->ignoreThread = true;
3025 MqContextCT->Idle.fCall = NS(Idle);
3026 MqContextCT->dataMF = NS(MarkData);
3027 MqContextCT->callbackMF = NS(ProcMark);
3028
3029 S_INIT;
3030
3031 // init class
3032
3033// BEGIN-CLASS - created by 'rb_MqS.tcl -i NHI1_HOME/theLink/c/gen/c_mqmsgque.meta' - DO NOT change
3034
3035// doc-key: MqContextC,MqContext,sCc
3036OT_METH_S ( MqContextC, Create, MqContextC_Create )
3037OT_METH_C ( MqContextC, new, MqContextC_new )
3038
3039// doc-key: MqContextC,MqContext,sc_
3040OT_METH_O ( MqContextC, GetNull, MqContextC_GetNull )
3041OT_METH_S ( MqContextC, GetNull, MqContextC_GetNull )
3042OT_METH_O ( MqContextC, HandleResolve, MqContextC_HandleResolve )
3043OT_METH_S ( MqContextC, HandleResolve, MqContextC_HandleResolve )
3044OT_METH_O ( MqContextC, Instances, MqContextC_Instances )
3045OT_METH_S ( MqContextC, Instances, MqContextC_Instances )
3046
3047// END-CLASS - created by 'rb_MqS.tcl -i NHI1_HOME/theLink/c/gen/c_mqmsgque.meta' - DO NOT change
3048
3049// BEGIN-OBJ - created by 'rb_MqS.tcl -i NHI1_HOME/theLink/c/gen/c_mqmsgque.meta' - DO NOT change
3050
3051// doc-key: MqContextC,MqClass,oc_
3052OT_METH_O ( MqContextC, ClassFactoryGet, MqContextC_ClassFactoryGet )
3053
3054// doc-key: MqContextC,MqClass,om_
3055OT_METH_O ( MqContextC, ClassFactorySet, MqContextC_ClassFactorySet )
3056OT_METH_O ( MqContextC, ClassIdentGet, MqContextC_ClassIdentGet )
3057OT_METH_O ( MqContextC, ClassIdentSet, MqContextC_ClassIdentSet )
3058OT_METH_O ( MqContextC, ClassOriginalIdentGet, MqContextC_ClassOriginalIdentGet )
3059
3060// doc-key: MqContextC,MqConfig,oco
3061OT_METH_O ( MqContextC, ConfigGetIoTcpL, MqContextC_ConfigGetIoTcpL )
3062
3063// doc-key: MqContextC,MqConfig,om_
3064OT_METH_O ( MqContextC, ConfigCheckStartAs, MqContextC_ConfigCheckStartAs )
3065OT_METH_O ( MqContextC, ConfigGetBuffersize, MqContextC_ConfigGetBuffersize )
3066OT_METH_O ( MqContextC, ConfigGetIdentFrom, MqContextC_ConfigGetIdentFrom )
3067OT_METH_O ( MqContextC, ConfigGetIoPipe, MqContextC_ConfigGetIoPipe )
3068OT_METH_O ( MqContextC, ConfigGetIoUds, MqContextC_ConfigGetIoUds )
3069OT_METH_O ( MqContextC, ConfigGetIsParent, MqContextC_ConfigGetIsParent )
3070OT_METH_O ( MqContextC, ConfigGetIsServer, MqContextC_ConfigGetIsServer )
3071OT_METH_O ( MqContextC, ConfigGetIsString, MqContextC_ConfigGetIsString )
3072OT_METH_O ( MqContextC, ConfigGetName, MqContextC_ConfigGetName )
3073OT_METH_O ( MqContextC, ConfigGetPkgsize, MqContextC_ConfigGetPkgsize )
3074OT_METH_O ( MqContextC, ConfigGetPostfix, MqContextC_ConfigGetPostfix )
3075OT_METH_O ( MqContextC, ConfigGetPrefix, MqContextC_ConfigGetPrefix )
3076OT_METH_O ( MqContextC, ConfigGetStartAs, MqContextC_ConfigGetStartAs )
3077OT_METH_O ( MqContextC, ConfigGetStatusIs, MqContextC_ConfigGetStatusIs )
3078OT_METH_O ( MqContextC, ConfigGetStorage, MqContextC_ConfigGetStorage )
3079OT_METH_O ( MqContextC, ConfigGetTimeout, MqContextC_ConfigGetTimeout )
3080OT_METH_O ( MqContextC, ConfigReset, MqContextC_ConfigReset )
3081OT_METH_O ( MqContextC, ConfigSetAllDebug, MqContextC_ConfigSetAllDebug )
3082OT_METH_O ( MqContextC, ConfigSetBgError, MqContextC_ConfigSetBgError )
3083OT_METH_O ( MqContextC, ConfigSetBuffersize, MqContextC_ConfigSetBuffersize )
3084OT_METH_O ( MqContextC, ConfigSetConfigFile, MqContextC_ConfigSetConfigFile )
3085OT_METH_O ( MqContextC, ConfigSetDaemon, MqContextC_ConfigSetDaemon )
3086OT_METH_O ( MqContextC, ConfigSetEvent, MqContextC_ConfigSetEvent )
3087OT_METH_O ( MqContextC, ConfigSetIdentFrom, MqContextC_ConfigSetIdentFrom )
3088OT_METH_O ( MqContextC, ConfigSetIgnoreExit, MqContextC_ConfigSetIgnoreExit )
3089OT_METH_O ( MqContextC, ConfigSetIoPipe, MqContextC_ConfigSetIoPipe )
3090OT_METH_O ( MqContextC, ConfigSetIoTcp, MqContextC_ConfigSetIoTcp )
3091OT_METH_O ( MqContextC, ConfigSetIoTcpL, MqContextC_ConfigSetIoTcpL )
3092OT_METH_O ( MqContextC, ConfigSetIoUds, MqContextC_ConfigSetIoUds )
3093OT_METH_O ( MqContextC, ConfigSetIsServer, MqContextC_ConfigSetIsServer )
3094OT_METH_O ( MqContextC, ConfigSetIsString, MqContextC_ConfigSetIsString )
3095OT_METH_O ( MqContextC, ConfigSetName, MqContextC_ConfigSetName )
3096OT_METH_O ( MqContextC, ConfigSetPkgsize, MqContextC_ConfigSetPkgsize )
3097OT_METH_O ( MqContextC, ConfigSetPostfix, MqContextC_ConfigSetPostfix )
3098OT_METH_O ( MqContextC, ConfigSetPrefix, MqContextC_ConfigSetPrefix )
3099OT_METH_O ( MqContextC, ConfigSetServerCleanup, MqContextC_ConfigSetServerCleanup )
3100OT_METH_O ( MqContextC, ConfigSetServerSetup, MqContextC_ConfigSetServerSetup )
3101OT_METH_O ( MqContextC, ConfigSetStartAs, MqContextC_ConfigSetStartAs )
3102OT_METH_O ( MqContextC, ConfigSetStartAsString, MqContextC_ConfigSetStartAsString )
3103OT_METH_O ( MqContextC, ConfigSetStorage, MqContextC_ConfigSetStorage )
3104OT_METH_O ( MqContextC, ConfigSetTimeout, MqContextC_ConfigSetTimeout )
3105
3106// doc-key: MqContextC,MqConfig,omo
3107OT_METH_O ( MqContextC, ConfigGetIoTcp, MqContextC_ConfigGetIoTcp )
3108
3109// doc-key: MqContextC,MqContext,oc_
3110OT_METH_O ( MqContextC, ErrorFORMAT, MqContextC_ErrorFORMAT )
3111OT_METH_O ( MqContextC, GetBuffer, MqContextC_GetBuffer )
3112OT_METH_O ( MqContextC, Next, MqContextC_Next )
3113OT_METH_O ( MqContextC, Prev, MqContextC_Prev )
3114
3115// doc-key: MqContextC,MqContext,om_
3116OT_METH_O ( MqContextC, ErrorCopy, MqContextC_ErrorCopy )
3117OT_METH_O ( MqContextC, ErrorMove, MqContextC_ErrorMove )
3118// skip class-overload: MqContextHandleGet → HandleGet, MqContextC_HandleGet
3119// skip class-overload: MqContextLog → Log, MqContextC_Log
3120OT_METH_O ( MqContextC, LogConfig, MqContextC_LogConfig )
3121OT_METH_O ( MqContextC, LogEnv, MqContextC_LogEnv )
3122OT_METH_O ( MqContextC, LogLink, MqContextC_LogLink )
3123OT_METH_O ( MqContextC, LogSetup, MqContextC_LogSetup )
3124OT_METH_O ( MqContextC, LogShort, MqContextC_LogShort )
3125OT_METH_O ( MqContextC, LogType, MqContextC_LogType )
3126// skip class-overload: MqContextToString → ToString, MqContextC_ToString
3127
3128// doc-key: MqContextC,MqEnv,om_
3129OT_METH_O ( MqContextC, EnvProtect, MqContextC_EnvProtect )
3130OT_METH_O ( MqContextC, EnvRestore, MqContextC_EnvRestore )
3131
3132// doc-key: MqContextC,MqExit,om_
3133OT_METH_O ( MqContextC, Exit, MqContextC_Exit )
3134
3135// doc-key: MqContextC,MqGet,oc_
3136OT_METH_O ( MqContextC, GetRoot, MqContextC_GetRoot )
3137
3138// doc-key: MqContextC,MqLink,oc_
3139OT_METH_O ( MqContextC, LinkGetParent, MqContextC_LinkGetParent )
3140
3141// doc-key: MqContextC,MqLink,om_
3142OT_METH_O ( MqContextC, LinkConnect, MqContextC_LinkConnect )
3143OT_METH_O ( MqContextC, LinkCreate, MqContextC_LinkCreate )
3144OT_METH_O ( MqContextC, LinkCreateChild, MqContextC_LinkCreateChild )
3145OT_METH_O ( MqContextC, LinkDelete, MqContextC_LinkDelete )
3146OT_METH_O ( MqContextC, LinkGetCtxId, MqContextC_LinkGetCtxId )
3147OT_METH_O ( MqContextC, LinkGetTargetIdent, MqContextC_LinkGetTargetIdent )
3148OT_METH_O ( MqContextC, LinkIsConnected, MqContextC_LinkIsConnected )
3149OT_METH_O ( MqContextC, LinkIsParent, MqContextC_LinkIsParent )
3150OT_METH_O ( MqContextC, LinkShutdown, MqContextC_LinkShutdown )
3151
3152// doc-key: MqContextC,MqLog,om_
3153OT_METH_O ( MqContextC, LogParentOrChild, MqContextC_LogParentOrChild )
3154OT_METH_O ( MqContextC, LogServerOrClient, MqContextC_LogServerOrClient )
3155
3156// doc-key: MqContextC,MqProcess,om_
3157OT_METH_O ( MqContextC, ProcessEvent, MqContextC_ProcessEvent )
3158
3159// doc-key: MqContextC,MqProxy,om_
3160OT_METH_O ( MqContextC, ProxyForward, MqContextC_ProxyForward )
3161OT_METH_O ( MqContextC, ProxyItem, MqContextC_ProxyItem )
3162
3163// doc-key: MqContextC,MqRead,oci
3164OT_METH_O ( MqContextC, ReadALL, MqContextC_ReadALL )
3165
3166// doc-key: MqContextC,MqRead,oco
3167OT_METH_O ( MqContextC, ReadBFL, MqContextC_ReadBFL )
3168OT_METH_O ( MqContextC, ReadBUF, MqContextC_ReadBUF )
3169
3170// doc-key: MqContextC,MqRead,om_
3171OT_METH_O ( MqContextC, ReadDbg, MqContextC_ReadDbg )
3172OT_METH_O ( MqContextC, ReadGetNextType, MqContextC_ReadGetNextType )
3173OT_METH_O ( MqContextC, ReadGetNumItems, MqContextC_ReadGetNumItems )
3174OT_METH_O ( MqContextC, ReadItemExists, MqContextC_ReadItemExists )
3175OT_METH_O ( MqContextC, ReadL_END, MqContextC_ReadL_END )
3176OT_METH_O ( MqContextC, ReadL_START, MqContextC_ReadL_START )
3177OT_METH_O ( MqContextC, ReadT_END, MqContextC_ReadT_END )
3178OT_METH_O ( MqContextC, ReadT_START, MqContextC_ReadT_START )
3179OT_METH_O ( MqContextC, ReadUndo, MqContextC_ReadUndo )
3180
3181// doc-key: MqContextC,MqRead,omo
3182OT_METH_O ( MqContextC, ReadBIN, MqContextC_ReadBIN )
3183OT_METH_O ( MqContextC, ReadBOL, MqContextC_ReadBOL )
3184OT_METH_O ( MqContextC, ReadBinaryR, MqContextC_ReadBinaryR )
3185OT_METH_O ( MqContextC, ReadDBL, MqContextC_ReadDBL )
3186OT_METH_O ( MqContextC, ReadFLT, MqContextC_ReadFLT )
3187OT_METH_O ( MqContextC, ReadHDL, MqContextC_ReadHDL )
3188OT_METH_O ( MqContextC, ReadI16, MqContextC_ReadI16 )
3189OT_METH_O ( MqContextC, ReadI32, MqContextC_ReadI32 )
3190OT_METH_O ( MqContextC, ReadI64, MqContextC_ReadI64 )
3191OT_METH_O ( MqContextC, ReadI8, MqContextC_ReadI8 )
3192OT_METH_O ( MqContextC, ReadLIST, MqContextC_ReadLIST )
3193OT_METH_O ( MqContextC, ReadLONG, MqContextC_ReadLONG )
3194OT_METH_O ( MqContextC, ReadNEXT, MqContextC_ReadNEXT )
3195OT_METH_O ( MqContextC, ReadSTR, MqContextC_ReadSTR )
3196OT_METH_O ( MqContextC, ReadStringR, MqContextC_ReadStringR )
3197
3198// doc-key: MqContextC,MqRoute,oco
3199OT_METH_O ( MqContextC, RouteGetTree, MqContextC_RouteGetTree )
3200
3201// doc-key: MqContextC,MqRoute,om_
3202OT_METH_O ( MqContextC, RouteCreate, MqContextC_RouteCreate )
3203OT_METH_O ( MqContextC, RouteDelete, MqContextC_RouteDelete )
3204OT_METH_O ( MqContextC, RouteResolve, MqContextC_RouteResolve )
3205OT_METH_O ( MqContextC, RouteTraverse, MqContextC_RouteTraverse )
3206
3207// doc-key: MqContextC,MqRoute,omo
3208OT_METH_O ( MqContextC, RouteGetPath, MqContextC_RouteGetPath )
3209
3210// doc-key: MqContextC,MqSend,om_
3211OT_METH_O ( MqContextC, Send, MqContextC_Send )
3212OT_METH_O ( MqContextC, SendBFL, MqContextC_SendBFL )
3213OT_METH_O ( MqContextC, SendBIN, MqContextC_SendBIN )
3214OT_METH_O ( MqContextC, SendBOL, MqContextC_SendBOL )
3215OT_METH_O ( MqContextC, SendBUF, MqContextC_SendBUF )
3216OT_METH_O ( MqContextC, SendBUS_FLAT, MqContextC_SendBUS_FLAT )
3217OT_METH_O ( MqContextC, SendBinaryR, MqContextC_SendBinaryR )
3218OT_METH_O ( MqContextC, SendDBL, MqContextC_SendDBL )
3219OT_METH_O ( MqContextC, SendEND, MqContextC_SendEND )
3220OT_METH_O ( MqContextC, SendEND_AND_CALLBACK, MqContextC_SendEND_AND_CALLBACK )
3221OT_METH_O ( MqContextC, SendEND_AND_SUB, MqContextC_SendEND_AND_SUB )
3222OT_METH_O ( MqContextC, SendEND_AND_TRANSACTION, MqContextC_SendEND_AND_TRANSACTION )
3223OT_METH_O ( MqContextC, SendEND_AND_WAIT, MqContextC_SendEND_AND_WAIT )
3224OT_METH_O ( MqContextC, SendERROR, MqContextC_SendERROR )
3225OT_METH_O ( MqContextC, SendFLT, MqContextC_SendFLT )
3226OT_METH_O ( MqContextC, SendHDL, MqContextC_SendHDL )
3227OT_METH_O ( MqContextC, SendI16, MqContextC_SendI16 )
3228OT_METH_O ( MqContextC, SendI32, MqContextC_SendI32 )
3229OT_METH_O ( MqContextC, SendI64, MqContextC_SendI64 )
3230OT_METH_O ( MqContextC, SendI8, MqContextC_SendI8 )
3231OT_METH_O ( MqContextC, SendLONG, MqContextC_SendLONG )
3232OT_METH_O ( MqContextC, SendLTR, MqContextC_SendLTR )
3233OT_METH_O ( MqContextC, SendL_END, MqContextC_SendL_END )
3234OT_METH_O ( MqContextC, SendL_FLAT, MqContextC_SendL_FLAT )
3235OT_METH_O ( MqContextC, SendL_START, MqContextC_SendL_START )
3236OT_METH_O ( MqContextC, SendRETURN, MqContextC_SendRETURN )
3237OT_METH_O ( MqContextC, SendRETURN_SUB, MqContextC_SendRETURN_SUB )
3238OT_METH_O ( MqContextC, SendSTART, MqContextC_SendSTART )
3239OT_METH_O ( MqContextC, SendSTR, MqContextC_SendSTR )
3240OT_METH_O ( MqContextC, SendSYNC, MqContextC_SendSYNC )
3241OT_METH_O ( MqContextC, SendStringR, MqContextC_SendStringR )
3242OT_METH_O ( MqContextC, SendT_END, MqContextC_SendT_END )
3243OT_METH_O ( MqContextC, SendT_START, MqContextC_SendT_START )
3244
3245// doc-key: MqContextC,MqService,om_
3246OT_METH_O ( MqContextC, ServiceCreate, MqContextC_ServiceCreate )
3247OT_METH_O ( MqContextC, ServiceDelete, MqContextC_ServiceDelete )
3248OT_METH_O ( MqContextC, ServiceIsTransaction, MqContextC_ServiceIsTransaction )
3249OT_METH_O ( MqContextC, ServiceProxy, MqContextC_ServiceProxy )
3250OT_METH_O ( MqContextC, ServiceProxyCtx, MqContextC_ServiceProxyCtx )
3251OT_METH_O ( MqContextC, ServiceProxyCtxExists, MqContextC_ServiceProxyCtxExists )
3252OT_METH_O ( MqContextC, ServiceProxyRoundRobin, MqContextC_ServiceProxyRoundRobin )
3253OT_METH_O ( MqContextC, ServiceStorage, MqContextC_ServiceStorage )
3254OT_METH_O ( MqContextC, ServiceTokenCheck, MqContextC_ServiceTokenCheck )
3255OT_METH_O ( MqContextC, ServiceTokenExists, MqContextC_ServiceTokenExists )
3256OT_METH_O ( MqContextC, ServiceTokenGet, MqContextC_ServiceTokenGet )
3257
3258// doc-key: MqContextC,MqSlave,oc_
3259OT_METH_O ( MqContextC, SlaveGetMaster, MqContextC_SlaveGetMaster )
3260
3261// doc-key: MqContextC,MqSlave,oco
3262OT_METH_O ( MqContextC, SlaveGet, MqContextC_SlaveGet )
3263OT_METH_O ( MqContextC, SlaveGetFilter, MqContextC_SlaveGetFilter )
3264OT_METH_O ( MqContextC, SlaveGetProxy, MqContextC_SlaveGetProxy )
3265
3266// doc-key: MqContextC,MqSlave,om_
3267OT_METH_O ( MqContextC, SlaveCheck, MqContextC_SlaveCheck )
3268OT_METH_O ( MqContextC, SlaveCreate, MqContextC_SlaveCreate )
3269OT_METH_O ( MqContextC, SlaveDelete, MqContextC_SlaveDelete )
3270OT_METH_O ( MqContextC, SlaveIs, MqContextC_SlaveIs )
3271OT_METH_O ( MqContextC, SlaveWorker, MqContextC_SlaveWorker )
3272
3273// doc-key: MqContextC,MqStorage,oci
3274OT_METH_O ( MqContextC, StorageDelete, MqContextC_StorageDelete )
3275OT_METH_O ( MqContextC, StorageImport, MqContextC_StorageImport )
3276
3277// doc-key: MqContextC,MqStorage,om_
3278OT_METH_O ( MqContextC, StorageClose, MqContextC_StorageClose )
3279OT_METH_O ( MqContextC, StorageDecrRef, MqContextC_StorageDecrRef )
3280OT_METH_O ( MqContextC, StorageIncrRef, MqContextC_StorageIncrRef )
3281OT_METH_O ( MqContextC, StorageLog, MqContextC_StorageLog )
3282OT_METH_O ( MqContextC, StorageOpen, MqContextC_StorageOpen )
3283
3284// doc-key: MqContextC,MqStorage,omo
3285OT_METH_O ( MqContextC, StorageCount, MqContextC_StorageCount )
3286OT_METH_O ( MqContextC, StorageErrCnt, MqContextC_StorageErrCnt )
3287OT_METH_O ( MqContextC, StorageExport, MqContextC_StorageExport )
3288OT_METH_O ( MqContextC, StorageResolve, MqContextC_StorageResolve )
3289
3290// END-OBJ - created by 'rb_MqS.tcl -i NHI1_HOME/theLink/c/gen/c_mqmsgque.meta' - DO NOT change
3291}
OT_METH_S
#define OT_METH_S(c, s, f)
Definition LibMkKernel_rb.h:387
OT_METH_O
#define OT_METH_O(c, s, f)
Definition LibMkKernel_rb.h:388
OT_METH_C
#define OT_METH_C(c, s, f)
Definition LibMkKernel_rb.h:386
MqContextCTT
static MK_TYP MqContextCTT
Definition MqContextC_rb.c:22
S_INIT
#define S_INIT
Definition MqContextC_rb.c:69
MkTypeDup2
#define MkTypeDup2(...)
MqContextCT
#define MqContextCT
class as MqTypeCtxS-class-type for MqContextC in the Target-Programming-Language (TPL) …
Definition LibMqMsgque_mq.h:4187
MqContextC_TT
#define MqContextC_TT
class as MkTypeS-class-type, useable in a class-macro as: class##_TT …
Definition LibMqMsgque_mq.h:4169

◆ rbmqmsgque_MqContextC_selfCreate()

static MK_PTR rbmqmsgque_MqContextC_selfCreate ( MK_RT mkrt,
MK_OBJ obj,
MK_PTR envP )
static

Definition at line 55 of file MqContextC_rb.c.

55 {
56 OT_OBJ_T self = NS(LNG_CONSTR) (OT_CLASS, obj, 0, NULL);
57 return VAL2PTR(self);
58}
VAL2PTR
#define VAL2PTR(val)
Definition LibMkKernel_rb.h:730
OT_CLASS
#define OT_CLASS
Definition MqContextC_rb.c:14
obj
MK_OBJ const obj
Definition high_lng.h:136

◆ rbmqmsgque_MqContextC_selfDelete()

static void rbmqmsgque_MqContextC_selfDelete ( MK_RT mkrt,
MK_PTR ptr,
MK_PTR envP )
static

Definition at line 60 of file MqContextC_rb.c.

60 {
61 OT_OBJECT_DELETE_HARD(PTR2VAL(ptr));
62}
PTR2VAL
#define PTR2VAL(nat)
Definition LibMkKernel_rb.h:735
OT_OBJECT_DELETE_HARD
#define OT_OBJECT_DELETE_HARD(obj)
Definition LibMkKernel_rb.h:158
ptr
MK_STRN ptr
Definition high_lng.h:130

◆ rbmqmsgque_MqContextC_selfUnlink()

static void rbmqmsgque_MqContextC_selfUnlink ( MK_RT mkrt,
MK_PTR ptr,
MK_PTR envP )
static

Definition at line 64 of file MqContextC_rb.c.

64 {
65 OT_OBJ_T self = PTR2VAL(ptr);
66 RDATA(self)->data = NULL;
67}

◆ rbmqmsgque_sInit()

static void rbmqmsgque_sInit ( MK_RT mkrt)
static

Definition at line 70 of file MqContextC_rb.c.

70 {
71
72 // add "selfCreate" and "selfDelete" feature to the MQ-MqContextC-Type
73 MqContextCTT->selfCreate = NS(MqContextC_selfCreate);
74 MqContextCTT->selfDelete = NS(MqContextC_selfDelete);
75 MqContextCTT->selfUnlink = NS(MqContextC_selfUnlink);
76
77 // create the RUBY class
78 OT_CLASS = rb_define_class_under(OT_PKG, "MqContextC", MK_BASE_CLASS);
79 rb_undef_alloc_func(OT_CLASS);
80
81 /* define the "NULL" object */
82 VALUE nullO = TypedData_Wrap_Struct (OT_CLASS, &NS(MqContextC_T), MK_NULL);
83 NS(MqContextC_MK_NULL) = nullO;
84 INCR_REF(&NS(MqContextC_MK_NULL));
85}
MK_BASE_CLASS
#define MK_BASE_CLASS
Definition LibMkKernel_rb.h:163
INCR_REF
#define INCR_REF(valP)
Definition LibMkKernel_rb.h:709
MqContextC_MK_NULL
#define MqContextC_MK_NULL
Definition LibMqMsgque_rb.h:105
OT_PKG
#define OT_PKG
Definition LibMqMsgque_rb.h:81
MK_NULL
#define MK_NULL
MkTypeS::selfUnlink
MkSelfUnlinkF selfUnlink
MkTypeS::selfDelete
MkSelfDeleteF selfDelete
MkTypeS::selfCreate
MkSelfCreateF selfCreate

◆ rbmqmsgque_sMark()

static void rbmqmsgque_sMark ( MK_PTR mng)
static

Definition at line 3006 of file MqContextC_rb.c.

3007{
3008 MQ_CTX mqctx = MqCtx(mng);
3009 MkRtSetup_X(mqctx);
3010 if (mqctx) MqContextMark(mqctx);
3011}
mqctx
#define mqctx
MkRtSetup_X
#define MkRtSetup_X(x)
MqContextMark
#define MqContextMark(...)
Definition msgque_overload_mq.h:310
MqContextS
PUBLIC data structure for the rbmqmsgque-specific-data
Definition LibMqMsgque_mq.h:4110

Variable Documentation

◆ MqContextCTT

MK_TYP MqContextCTT = NULL
static

Definition at line 22 of file MqContextC_rb.c.

◆ OT_CLASS

OT_CLS_T OT_CLASS

Definition at line 19 of file MqContextC_rb.c.

◆ rbmqmsgque_MqContextC_MK_NULL

OT_OBJ_T rbmqmsgque_MqContextC_MK_NULL = 0

Definition at line 23 of file MqContextC_rb.c.

◆ rbmqmsgque_MqContextC_T

rb_data_type_t rbmqmsgque_MqContextC_T
static
Initial value:
= {
"MqContextC",
{
rbmqmsgque_sMark ,
rbmkkernel_AtomDeleteSoft ,
0,
0,
},
NULL,
NULL,
RUBY_TYPED_FREE_IMMEDIATELY
}
rbmkkernel_AtomDeleteSoft
static void rbmkkernel_AtomDeleteSoft(MK_MNG)
Definition LibMkKernel_rb.h:891
rbmqmsgque_sMark
static void rbmqmsgque_sMark(MK_PTR)
Definition MqContextC_rb.c:3006

Definition at line 29 of file MqContextC_rb.c.

29 {
30 "MqContextC",
31 {
32 NS(sMark),
33 MK(AtomDeleteSoft),
34 0, /* dsize */
35 0, /* reserved[1] */
36 },
37 NULL, /* parent */
38 NULL, /* data */
39 RUBY_TYPED_FREE_IMMEDIATELY
40};
Generated on Thu May 29 2025 13:13:59 for theLink by doxygen 1.12.0