theLink 10.0
Loading...
Searching...
No Matches
Macros | Functions
LibMqMsgque_private_rb.h File Reference

tag: nhi1-release-250425 More...

#include "LibMqMsgque_rb.h"
+ Include dependency graph for LibMqMsgque_private_rb.h:
+ This graph shows which files directly or indirectly include this file:

Go to the source code of this file.

Macros

#define OT_SETUP_self   OT_OBJ_T self = CTX2VAL(mqctx);
 
#define CTX2VAL(nat)
 

Functions

void rbmqmsgque_MqContextC_Init (MK_RT mkrt, MQ_RT mqrt)
 
void rbmqmsgque_MqDumpC_Init (MK_RT mkrt, MQ_RT mqrt)
 
void rbmqmsgque_MqFactoryC_Init (MK_RT mkrt, MQ_RT mqrt)
 
void rbmqmsgque_ServiceFree (MQ_SERVICE_FREE_ARGS)
 
void rbmqmsgque_ServiceCopy (MQ_SERVICE_COPY_ARGS)
 
enum MkErrorE rbmqmsgque_ServiceCall (MQ_SERVICE_CALL_ARGS)
 
void rbmqmsgque_ProcMark (MK_RT mkrt, MK_PTR)
 
OT_ProcRet rbmqmsgque_MqContextC_ReadLIST (MqContextC_ARGS)
  Ruby: [list...] ctx.ReadLIST() → C-API
get all arguments as native list …
 
OT_ProcRet rbmqmsgque_MqContextC_ReadNEXT (MqContextC_ARGS)
  Ruby: obj ctx.ReadNEXT() → C-API
get the next argument as native object …
 
static OT_OBJ_T rbmqmsgque__CTX2VAL (MK_RT mkrt, MQ_CTX nat)
 

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 LibMqMsgque_private_rb.h.

Macro Definition Documentation

◆ CTX2VAL

#define CTX2VAL ( nat)
Value:
MQ(_CTX2VAL)(MK_RT_CALL nat)
MQ
#define MQ(n)
Definition LibMqMsgque_rb.h:74
MK_RT_CALL
#define MK_RT_CALL

Definition at line 33 of file LibMqMsgque_private_rb.h.

◆ OT_SETUP_self

#define OT_SETUP_self   OT_OBJ_T self = CTX2VAL(mqctx);

Definition at line 31 of file LibMqMsgque_private_rb.h.

Function Documentation

◆ rbmqmsgque__CTX2VAL()

static OT_OBJ_T rbmqmsgque__CTX2VAL ( MK_RT mkrt,
MQ_CTX nat )
inlinestatic

Definition at line 35 of file LibMqMsgque_private_rb.h.

35 {
36 return (nat == NULL ? Qnil : (MkOBJ_R(nat).self) == NULL ? OT_TMP_CTX_OBJ(nat) : (OT_OBJ_T) MkOBJ_R(nat).self);
37}
OT_OBJ_T
#define OT_OBJ_T
Definition LibMkKernel_rb.h:91
OT_TMP_CTX_OBJ
#define OT_TMP_CTX_OBJ(val)
Definition LibMqMsgque_rb.h:115
MkOBJ_R
#define MkOBJ_R(x)

◆ 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
NS
#define NS(n)
Definition LibMqMsgque_rb.h:76
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_MqDumpC_Init()

void rbmqmsgque_MqDumpC_Init ( MK_RT mkrt,
MQ_RT mqrt )

Definition at line 380 of file MqDumpC_rb.c.

380 {
381
382 // init type
383 MqDumpCTT = MqDumpC_TT;
384 S_INIT;
385
386// BEGIN-CLASS - created by 'rb_MqS.tcl -i NHI1_HOME/theLink/c/gen/c_mqmsgque.meta' - DO NOT change
387
388// doc-key: MqDumpC,MqDump,sCi
389OT_METH_S ( MqDumpC, Error, MqDumpC_Error )
390OT_METH_S ( MqDumpC, Export, MqDumpC_Export )
391OT_METH_C ( MqDumpC, new, MqDumpC_new )
392
393// doc-key: MqDumpC,MqDump,sCo
394OT_METH_S ( MqDumpC, BinSet, MqDumpC_BinSet )
395
396// doc-key: MqDumpC,MqDump,sc_
397OT_METH_O ( MqDumpC, GetNull, MqDumpC_GetNull )
398OT_METH_S ( MqDumpC, GetNull, MqDumpC_GetNull )
399OT_METH_O ( MqDumpC, HandleResolve, MqDumpC_HandleResolve )
400OT_METH_S ( MqDumpC, HandleResolve, MqDumpC_HandleResolve )
401OT_METH_O ( MqDumpC, Instances, MqDumpC_Instances )
402OT_METH_S ( MqDumpC, Instances, MqDumpC_Instances )
403
404// END-CLASS - created by 'rb_MqS.tcl -i NHI1_HOME/theLink/c/gen/c_mqmsgque.meta' - DO NOT change
405
406// BEGIN-OBJ - created by 'rb_MqS.tcl -i NHI1_HOME/theLink/c/gen/c_mqmsgque.meta' - DO NOT change
407
408// doc-key: MqDumpC,MqDump,oc_
409OT_METH_O ( MqDumpC, Next, MqDumpC_Next )
410OT_METH_O ( MqDumpC, Prev, MqDumpC_Prev )
411
412// doc-key: MqDumpC,MqDump,om_
413OT_METH_O ( MqDumpC, BinGet, MqDumpC_BinGet )
414// skip class-overload: MqDumpHandleGet → HandleGet, MqDumpC_HandleGet
415OT_METH_O ( MqDumpC, Import, MqDumpC_Import )
416// skip class-overload: MqDumpLog → Log, MqDumpC_Log
417OT_METH_O ( MqDumpC, SizeGet, MqDumpC_SizeGet )
418OT_METH_O ( MqDumpC, TokenGet, MqDumpC_TokenGet )
419
420// END-OBJ - created by 'rb_MqS.tcl -i NHI1_HOME/theLink/c/gen/c_mqmsgque.meta' - DO NOT change
421}
MqDumpCTT
static MK_TYP MqDumpCTT
Definition MqDumpC_rb.c:22
S_INIT
#define S_INIT
Definition MqDumpC_rb.c:69
MqDumpC_TT
#define MqDumpC_TT
class as MkTypeS-class-type, useable in a class-macro as: class##_TT …
Definition LibMqMsgque_mq.h:8712

◆ rbmqmsgque_MqFactoryC_Init()

void rbmqmsgque_MqFactoryC_Init ( MK_RT mkrt,
MQ_RT mqrt )

Definition at line 592 of file MqFactoryC_rb.c.

592 {
593
594 // init type
595 MqFactoryCTT = MqFactoryC_TT;
596 S_INIT;
597
598 // BEGIN-CLASS - created by 'rb_MqS.tcl -i NHI1_HOME/theLink/c/gen/c_mqmsgque.meta' - DO NOT change
599
600 // doc-key: MqFactoryC,MqFactory,sCc
601 OT_METH_S ( MqFactoryC, Add, MqFactoryC_Add )
602 OT_METH_C ( MqFactoryC, new, MqFactoryC_new )
603
604 // doc-key: MqFactoryC,MqFactory,sc_
605 OT_METH_O ( MqFactoryC, Get, MqFactoryC_Get )
606 OT_METH_S ( MqFactoryC, Get, MqFactoryC_Get )
607 OT_METH_O ( MqFactoryC, GetCalled, MqFactoryC_GetCalled )
608 OT_METH_S ( MqFactoryC, GetCalled, MqFactoryC_GetCalled )
609 OT_METH_O ( MqFactoryC, GetCalledL, MqFactoryC_GetCalledL )
610 OT_METH_S ( MqFactoryC, GetCalledL, MqFactoryC_GetCalledL )
611 OT_METH_O ( MqFactoryC, GetNull, MqFactoryC_GetNull )
612 OT_METH_S ( MqFactoryC, GetNull, MqFactoryC_GetNull )
613 OT_METH_O ( MqFactoryC, HandleResolve, MqFactoryC_HandleResolve )
614 OT_METH_S ( MqFactoryC, HandleResolve, MqFactoryC_HandleResolve )
615 OT_METH_O ( MqFactoryC, Instances, MqFactoryC_Instances )
616 OT_METH_S ( MqFactoryC, Instances, MqFactoryC_Instances )
617
618 // doc-key: MqFactoryC,MqFactory,sm_
619 OT_METH_O ( MqFactoryC, DefaultIdent, MqFactoryC_DefaultIdent )
620 OT_METH_S ( MqFactoryC, DefaultIdent, MqFactoryC_DefaultIdent )
621 OT_METH_O ( MqFactoryC, InitialIdent, MqFactoryC_InitialIdent )
622 OT_METH_S ( MqFactoryC, InitialIdent, MqFactoryC_InitialIdent )
623 OT_METH_O ( MqFactoryC, LogAll, MqFactoryC_LogAll )
624 OT_METH_S ( MqFactoryC, LogAll, MqFactoryC_LogAll )
625
626 // END-CLASS - created by 'rb_MqS.tcl -i NHI1_HOME/theLink/c/gen/c_mqmsgque.meta' - DO NOT change
627
628 // BEGIN-OBJ - created by 'rb_MqS.tcl -i NHI1_HOME/theLink/c/gen/c_mqmsgque.meta' - DO NOT change
629
630 // doc-key: MqFactoryC,MqFactory,oCx
631 OT_METH_O ( MqFactoryC, Dup2, MqFactoryC_Dup2 )
632
633 // doc-key: MqFactoryC,MqFactory,oc_
634 OT_METH_O ( MqFactoryC, Default, MqFactoryC_Default )
635 OT_METH_O ( MqFactoryC, Initial, MqFactoryC_Initial )
636 OT_METH_O ( MqFactoryC, Next, MqFactoryC_Next )
637 OT_METH_O ( MqFactoryC, Prev, MqFactoryC_Prev )
638
639 // doc-key: MqFactoryC,MqFactory,oco
640 OT_METH_O ( MqFactoryC, New, MqFactoryC_New )
641
642 // doc-key: MqFactoryC,MqFactory,om_
643 OT_METH_O ( MqFactoryC, GetOriginalIdent, MqFactoryC_GetOriginalIdent )
644 // skip class-overload: MqFactoryHandleGet → HandleGet, MqFactoryC_HandleGet
645 // skip class-overload: MqFactoryLog → Log, MqFactoryC_Log
646
647 // END-OBJ - created by 'rb_MqS.tcl -i NHI1_HOME/theLink/c/gen/c_mqmsgque.meta' - DO NOT change
648
649 // setup default factory… required for objects created WITHOUT factory
650 // example: Filter3.rb
651 if (!strcmp(MqFactoryDefaultIdent(), "libmqmsgque")) {
652
653 if ( MqFactoryDefault(
654 MqFactoryInitial(
655 MqFactoryAdd (NULL,
656 NS(sFactoryCTor), (MK_PTR)NS(MqContextC), NULL, NULL,
657 NS(sFactoryDTor), NULL, NULL, NULL,
658 "rbmsgque"
659 )
660 )
661 ) == NULL
662 )
663 {
664 OT_ERROR_RUNTIME("MqFactoryC", "create default factory failed")
665 }
666 }
667
668 NS(id_new) = rb_intern("new");
669}
OT_ERROR_RUNTIME
#define OT_ERROR_RUNTIME(clazz, str)
Definition LibMkKernel_rb.h:505
S_INIT
#define S_INIT
Definition MqFactoryC_rb.c:73
MqFactoryCTT
static MK_TYP MqFactoryCTT
Definition MqFactoryC_rb.c:26
MK_PTR
MK_PTRB * MK_PTR
MqFactoryC_TT
#define MqFactoryC_TT
class as MkTypeS-class-type, useable in a class-macro as: class##_TT …
Definition LibMqMsgque_mq.h:3223
MqFactoryInitial
#define MqFactoryInitial(...)
Definition msgque_overload_mq.h:1014
MqFactoryDefaultIdent
#define MqFactoryDefaultIdent()
Definition msgque_overload_mq.h:1034
MqFactoryDefault
#define MqFactoryDefault(...)
Definition msgque_overload_mq.h:1012
MqFactoryAdd
#define MqFactoryAdd(...)
Definition msgque_overload_mq.h:1054

◆ rbmqmsgque_ProcMark()

void rbmqmsgque_ProcMark ( MK_RT mkrt,
MK_PTR data )

Definition at line 171 of file MqCall_rb.c.

171 {
172 struct MkCallS *call = (struct MkCallS*) data;
173//printV("call=%p, data=%p\n", call, call->procCallback)
174 rb_gc_mark(call->procCallback);
175}
call
enum MqCallE call

◆ rbmqmsgque_ServiceCall()

enum MkErrorE rbmqmsgque_ServiceCall ( MQ_SERVICE_CALL_ARGS )

Definition at line 64 of file MqCall_rb.c.

65{
66 MQ_SERVICE_CALL_CHECK;
67
68 struct MkCallS *call = __data__;
69 int argNum = 1;
70
71 if (!MqCtxCheck(mqctx)) {
72 mk_dbg_color_ln(MK_COLOR_RED, "%s", "mqctx invalid");
73 }
74 if (!MqCtxCheck(call->hdl)) {
75 mk_dbg_color_ln(MK_COLOR_RED, "%s", "call->hdl invalid");
76 }
77
78 // 1. check environment
79 if (OT_LNG_NULL_IS(call->procCallback)) return MK_OK;
80
81//MkDbgDeepX_3(mqctx, "AAA", "cmd=%s", VAL2STRN(rb_inspect(call->procCallback)));
82
83 // 2. if not already done initialize
84 if (call->procCall == NULL) {
85 assert(!OT_LNG_NULL_IS(call->procArgs));
86 switch (call->procType) {
87 case MkCallS_own_method: {
88 OT_SETUP_self
89 argNum = rb_equal(rb_funcallv(call->procCallback,MK(id_receiver),0,NULL),self) ? 0 : 1;
90 if (argNum > call->procArity) goto methode_arg_error;
91 if (call->procArity == 0) {
92 call->procNeedSelf = false;
93 call->procCall = NS(sCallMethodWithoutSelf);
94 } else {
95 call->procNeedSelf = true;
96 call->procCall = NS(sCallMethodWithSelf);
97 }
98 }
99 break;
100 case MkCallS_proc:
101 call->procNeedSelf = true;
102 call->procCall = NS(sCallProcWithSelf);
103 if (argNum != call->procArity) goto methode_arg_error;
104 break;
105 default:
106 MkErrorSetV_3M(mqctx, "WrongInitError", "found invalid procType for callback '%s'", VAL2STRN(call->procCallback));
107 goto error;
108 break;
109 }
110 }
111
112 // 3. call callback
113 if (call->procNeedSelf == false) {
114 // without "self"
115 if (rb_obj_is_kind_of(call->procCallback, rb_cMethod) != Qtrue) {
116 mk_dbg_color_ln(MK_COLOR_RED, "%s", "call->procCallback invalid");
117 }
118 NS(sRescue)(MK_RT_CALL mqctx,call->procCall,call->procCallback);
119 } else {
120 // with "self"
121 OT_SETUP_self;
122 VALUE ary = rb_ary_resize(call->procArgs,2);
123 rb_ary_store(ary,0,self);
124 rb_ary_store(ary,1,call->procCallback);
125 NS(sRescue)(MK_RT_CALL mqctx,call->procCall,ary);
126 }
127 MkErrorCheck_0E();
128
129MkDbgDeepX_3(mqctx, "BBB", "cmd=%s", VAL2STRN(rb_inspect(call->procCallback)));
130 return MkErrorGetCode_0E();
131
132methode_arg_error:
133 MkErrorSetV_3M(mqctx, "WrongNumberOfArgError", "for callback '%s' exactly '%d' argument is required, but '%d' was received",
134 VAL2STRN(call->procCallback), argNum, call->procArity);
135 goto error;
136
137error:
138MkDbgDeepX_3(mqctx, "EEE", "cmd=%s", VAL2STRN(rb_inspect(call->procCallback)));
139//printSTACK_1(mqctx)
140 return MkErrorStack_0E();
141}
MK
#define MK(n)
Definition LibMkKernel_rb.h:80
OT_LNG_NULL_IS
#define OT_LNG_NULL_IS(obj)
Definition LibMkKernel_rb.h:122
VAL2STRN
#define VAL2STRN(val)
Definition LibMkKernel_rb.h:728
OT_SETUP_self
#define OT_SETUP_self
Definition LibMqMsgque_private_rb.h:31
mqctx
#define mqctx
MkErrorGetCode_0E
#define MkErrorGetCode_0E()
MkErrorStack_0E
#define MkErrorStack_0E()
MkErrorSetV_3M
#define MkErrorSetV_3M(err, callfunc, printfmt,...)
MK_OK
MK_OK
MkDbgDeepX_3
#define MkDbgDeepX_3(m, ident, fmt,...)
MqCtxCheck
static bool MqCtxCheck(MK_MNGN mng)
check MqContextS -> MkObjectS::signature …
Definition LibMqMsgque_mq.h:4202
MQ_SERVICE_CALL_CHECK
#define MQ_SERVICE_CALL_CHECK
Definition LibMqMsgque_mq.h:929
error
goto error
Definition high_lng.h:251

◆ rbmqmsgque_ServiceCopy()

void rbmqmsgque_ServiceCopy ( MQ_SERVICE_COPY_ARGS )

Definition at line 160 of file MqCall_rb.c.

160 {
161 struct MkCallS *call = *dataP = MkSysMemDup(MK_ERROR_PANIC, *dataP, sizeof(struct MkCallS));
162
163 if (call->procNeedSelf) {
164 call->procCallback = NS(sRescue)(MK_RT_CALL mqctx, NS(sCopyWithSelf), call->procCallback);
165 } else {
166 call->procCallback = NS(sRescue)(MK_RT_CALL mqctx, NS(sCopyWithoutSelf), call->procCallback);
167 }
168 INCR_REF(&call->procCallback);
169}
INCR_REF
#define INCR_REF(valP)
Definition LibMkKernel_rb.h:709
MK_ERROR_PANIC
#define MK_ERROR_PANIC
MkSysMemDup
MK_PTR MkSysMemDup(MK_OBJN fmtobj, MK_PTRN const blck, size_t const size)

◆ rbmqmsgque_ServiceFree()

void rbmqmsgque_ServiceFree ( MQ_SERVICE_FREE_ARGS )

Definition at line 143 of file MqCall_rb.c.

143 {
144 MK(CallFree)(dataP);
145}
Generated on Thu May 29 2025 13:13:59 for theLink by doxygen 1.12.0