theLink 10.0
Loading...
Searching...
No Matches
LibMqMsgque_rb.c
Go to the documentation of this file.
1
9/* LABEL-NO */
10
11#include "LibMqMsgque_private_rb.h"
12#include "misc_check_rb.h"
13
14/* LABEL-END */
15
16#include <ruby/defines.h>
17
18#define MqSetupTmpl()
19#define MqCleanupTmpl()
20
21// MARK_D ################################################################
22// -----------------------------------------------------------------------
23// documentation order
24
35
48
72
81
90
98
107
115
116// --------------------------------------------------------------------------------
117
118VALUE MQ(MqMsgque);
119
120// BEGIN-enumD - created by 'rb_MqS.tcl -i NHI1_HOME/theLink/c/gen/c_mqmsgque.meta' - DO NOT change
121
122VALUE MQ(MqIdentE);
123VALUE MQ(MqSlaveE);
124VALUE MQ(MqStartE);
125VALUE MQ(MqStatusIsEF);
126VALUE MQ(MqWaitOnEventE);
127
128// END-enumD - created by 'rb_MqS.tcl -i NHI1_HOME/theLink/c/gen/c_mqmsgque.meta' - DO NOT change
129
130
131// BEGIN-DOC - created by 'rb_MqS.tcl -i NHI1_HOME/theLink/c/gen/c_mqmsgque.meta' - DO NOT change
132
133// doc-key: MqMsgque,EnumFunc,sco,func
134#define IdentE_FromInt_doc "MqIdentE MqMsgque.IdentE_FromInt(value:int32)"
135#define SlaveE_FromInt_doc "MqSlaveE MqMsgque.SlaveE_FromInt(value:int32)"
136#define StartE_FromInt_doc "MqStartE MqMsgque.StartE_FromInt(value:int32)"
137#define StatusIsEF_FromInt_doc "MqStatusIsEF MqMsgque.StatusIsEF_FromInt(value:int32)"
138#define WaitOnEventE_FromInt_doc "MqWaitOnEventE MqMsgque.WaitOnEventE_FromInt(value:int32)"
139
140// doc-key: MqMsgque,EnumFunc,sm_,func
141#define IdentE_ToInt_doc "int32 MqMsgque.IdentE_ToInt(value:MqIdentE)"
142#define IdentE_ToString_doc "string MqMsgque.IdentE_ToString(value:MqIdentE)"
143#define SlaveE_ToInt_doc "int32 MqMsgque.SlaveE_ToInt(value:MqSlaveE)"
144#define SlaveE_ToString_doc "string MqMsgque.SlaveE_ToString(value:MqSlaveE)"
145#define StartE_ToInt_doc "int32 MqMsgque.StartE_ToInt(value:MqStartE)"
146#define StartE_ToString_doc "string MqMsgque.StartE_ToString(value:MqStartE)"
147#define StatusIsEF_ToInt_doc "int32 MqMsgque.StatusIsEF_ToInt(value:MqStatusIsEF)"
148#define StatusIsEF_ToString_doc "string MqMsgque.StatusIsEF_ToString(value:MqStatusIsEF)"
149#define WaitOnEventE_ToInt_doc "int32 MqMsgque.WaitOnEventE_ToInt(value:MqWaitOnEventE)"
150#define WaitOnEventE_ToString_doc "string MqMsgque.WaitOnEventE_ToString(value:MqWaitOnEventE)"
151
152// doc-key: MqMsgque,MqHelp,sm_,func
153#define Help_doc "string MqMsgque.Help(tool:string)"
154#define HelpMsgque_doc "string MqMsgque.HelpMsgque()"
155
156// doc-key: MqMsgque,MqInit,sm_,func
157#define InitGetArg0_doc "MkBufferListC MqMsgque.InitGetArg0()"
158#define InitResetArg0_doc "MkBufferListC MqMsgque.InitResetArg0()"
159#define InitSetArg0_doc "MqMsgque.InitSetArg0(?bfl:MkBufferListC...=nil?)"
160
161// doc-key: MqMsgque,Setup,sm_,func
162#define Cleanup_doc "MqMsgque.Cleanup()"
163#define Setup_doc "MqMsgque.Setup()"
164
165// END-DOC - created by 'rb_MqS.tcl -i NHI1_HOME/theLink/c/gen/c_mqmsgque.meta' - DO NOT change
166
167#define OT_SETUP_hdl_static MK_RT_UNUSED MkRtSetup_NULL; \
168 __attribute__((unused)) MK_ERR hdl = &MkERROR;
169
170/*****************************************************************************/
171/* */
172/* private */
173/* */
174/*****************************************************************************/
175
176// BEGIN-MqMsgque - created by 'rb_MqC.tcl -i NHI1_HOME/theLink/c/gen/c_mqmsgque.meta' - DO NOT change
177
181
182// doc-key: MqMsgque,MqMsgque-Enum,sco
183
185static OT_ProcRet NS(MqMsgque_IdentE_FromInt) (OtClass_ARGS) {
186 OT_SETUP_hdl_static;
187 OT_SETUP_ONEARG(IdentE_FromInt_doc);
188 MK_I32 value = 0;
189 OT_CHECK_REQUIRED(OT_CHECK_NI4 (value))
190 OT_CHECK_NOARGS;
191 enum MqIdentE value_out;
192 MkErrorC_Check(MK_ERROR_FORMAT,MqIdentE_FromInt (value, &value_out));
193 OT_retObj_SET(OT_NEW_Mq_enum_OBJ(IdentE,value_out));
194 end: MK_UNUSED /* LONG JUMP on error */
195 OT_retObj_RETURN;
196}
197
199static OT_ProcRet NS(MqMsgque_SlaveE_FromInt) (OtClass_ARGS) {
200 OT_SETUP_hdl_static;
201 OT_SETUP_ONEARG(SlaveE_FromInt_doc);
202 MK_I32 value = 0;
203 OT_CHECK_REQUIRED(OT_CHECK_NI4 (value))
204 OT_CHECK_NOARGS;
205 enum MqSlaveE value_out;
206 MkErrorC_Check(MK_ERROR_FORMAT,MqSlaveE_FromInt (value, &value_out));
207 OT_retObj_SET(OT_NEW_Mq_enum_OBJ(SlaveE,value_out));
208 end: MK_UNUSED /* LONG JUMP on error */
209 OT_retObj_RETURN;
210}
211
213static OT_ProcRet NS(MqMsgque_StartE_FromInt) (OtClass_ARGS) {
214 OT_SETUP_hdl_static;
215 OT_SETUP_ONEARG(StartE_FromInt_doc);
216 MK_I32 value = 0;
217 OT_CHECK_REQUIRED(OT_CHECK_NI4 (value))
218 OT_CHECK_NOARGS;
219 enum MqStartE value_out;
220 MkErrorC_Check(MK_ERROR_FORMAT,MqStartE_FromInt (value, &value_out));
221 OT_retObj_SET(OT_NEW_Mq_enum_OBJ(StartE,value_out));
222 end: MK_UNUSED /* LONG JUMP on error */
223 OT_retObj_RETURN;
224}
225
227static OT_ProcRet NS(MqMsgque_StatusIsEF_FromInt) (OtClass_ARGS) {
228 OT_SETUP_hdl_static;
229 OT_SETUP_ONEARG(StatusIsEF_FromInt_doc);
230 MK_I32 value = 0;
231 OT_CHECK_REQUIRED(OT_CHECK_NI4 (value))
232 OT_CHECK_NOARGS;
233 enum MqStatusIsEF value_out;
234 MkErrorC_Check(MK_ERROR_FORMAT,MqStatusIsEF_FromInt (value, &value_out));
235 OT_retObj_SET(OT_NEW_Mq_enum_OBJ(StatusIsEF,value_out));
236 end: MK_UNUSED /* LONG JUMP on error */
237 OT_retObj_RETURN;
238}
239
241static OT_ProcRet NS(MqMsgque_WaitOnEventE_FromInt) (OtClass_ARGS) {
242 OT_SETUP_hdl_static;
243 OT_SETUP_ONEARG(WaitOnEventE_FromInt_doc);
244 MK_I32 value = 0;
245 OT_CHECK_REQUIRED(OT_CHECK_NI4 (value))
246 OT_CHECK_NOARGS;
247 enum MqWaitOnEventE value_out;
248 MkErrorC_Check(MK_ERROR_FORMAT,MqWaitOnEventE_FromInt (value, &value_out));
249 OT_retObj_SET(OT_NEW_Mq_enum_OBJ(WaitOnEventE,value_out));
250 end: MK_UNUSED /* LONG JUMP on error */
251 OT_retObj_RETURN;
252}
253
254// doc-key: MqMsgque,MqMsgque-Enum,sm_
255
257static OT_ProcRet NS(MqMsgque_IdentE_ToInt) (OtClass_ARGS) {
258 OT_SETUP_hdl_static;
259 OT_SETUP_ONEARG(IdentE_ToInt_doc);
260 enum MqIdentE value = 0;
261 OT_CHECK_REQUIRED(OT_CHECK_ENUM (MqIdentE,value))
262 OT_CHECK_NOARGS;
263 OT_retObj_SET_I32(MqIdentE_ToInt (value));
264 end: MK_UNUSED /* LONG JUMP on error */
265 OT_retObj_RETURN;
266}
267
269static OT_ProcRet NS(MqMsgque_IdentE_ToString) (OtClass_ARGS) {
270 OT_SETUP_hdl_static;
271 OT_SETUP_ONEARG(IdentE_ToString_doc);
272 enum MqIdentE value = 0;
273 OT_CHECK_REQUIRED(OT_CHECK_ENUM (MqIdentE,value))
274 OT_CHECK_NOARGS;
275 OT_retObj_SET_STR(MqIdentE_ToString (value));
276 end: MK_UNUSED /* LONG JUMP on error */
277 OT_retObj_RETURN;
278}
279
281static OT_ProcRet NS(MqMsgque_SlaveE_ToInt) (OtClass_ARGS) {
282 OT_SETUP_hdl_static;
283 OT_SETUP_ONEARG(SlaveE_ToInt_doc);
284 enum MqSlaveE value = 0;
285 OT_CHECK_REQUIRED(OT_CHECK_ENUM (MqSlaveE,value))
286 OT_CHECK_NOARGS;
287 OT_retObj_SET_I32(MqSlaveE_ToInt (value));
288 end: MK_UNUSED /* LONG JUMP on error */
289 OT_retObj_RETURN;
290}
291
293static OT_ProcRet NS(MqMsgque_SlaveE_ToString) (OtClass_ARGS) {
294 OT_SETUP_hdl_static;
295 OT_SETUP_ONEARG(SlaveE_ToString_doc);
296 enum MqSlaveE value = 0;
297 OT_CHECK_REQUIRED(OT_CHECK_ENUM (MqSlaveE,value))
298 OT_CHECK_NOARGS;
299 OT_retObj_SET_STR(MqSlaveE_ToString (value));
300 end: MK_UNUSED /* LONG JUMP on error */
301 OT_retObj_RETURN;
302}
303
305static OT_ProcRet NS(MqMsgque_StartE_ToInt) (OtClass_ARGS) {
306 OT_SETUP_hdl_static;
307 OT_SETUP_ONEARG(StartE_ToInt_doc);
308 enum MqStartE value = 0;
309 OT_CHECK_REQUIRED(OT_CHECK_ENUM (MqStartE,value))
310 OT_CHECK_NOARGS;
311 OT_retObj_SET_I32(MqStartE_ToInt (value));
312 end: MK_UNUSED /* LONG JUMP on error */
313 OT_retObj_RETURN;
314}
315
317static OT_ProcRet NS(MqMsgque_StartE_ToString) (OtClass_ARGS) {
318 OT_SETUP_hdl_static;
319 OT_SETUP_ONEARG(StartE_ToString_doc);
320 enum MqStartE value = 0;
321 OT_CHECK_REQUIRED(OT_CHECK_ENUM (MqStartE,value))
322 OT_CHECK_NOARGS;
323 OT_retObj_SET_STR(MqStartE_ToString (value));
324 end: MK_UNUSED /* LONG JUMP on error */
325 OT_retObj_RETURN;
326}
327
329static OT_ProcRet NS(MqMsgque_StatusIsEF_ToInt) (OtClass_ARGS) {
330 OT_SETUP_hdl_static;
331 OT_SETUP_ONEARG(StatusIsEF_ToInt_doc);
332 enum MqStatusIsEF value = 0;
333 OT_CHECK_REQUIRED(OT_CHECK_ENUM (MqStatusIsEF,value))
334 OT_CHECK_NOARGS;
335 OT_retObj_SET_I32(MqStatusIsEF_ToInt (value));
336 end: MK_UNUSED /* LONG JUMP on error */
337 OT_retObj_RETURN;
338}
339
341static OT_ProcRet NS(MqMsgque_StatusIsEF_ToString) (OtClass_ARGS) {
342 OT_SETUP_hdl_static;
343 OT_SETUP_ONEARG(StatusIsEF_ToString_doc);
344 enum MqStatusIsEF value = 0;
345 OT_CHECK_REQUIRED(OT_CHECK_ENUM (MqStatusIsEF,value))
346 OT_CHECK_NOARGS;
347 OT_retObj_SET_STR(MqStatusIsEF_ToString (value));
348 end: MK_UNUSED /* LONG JUMP on error */
349 OT_retObj_RETURN;
350}
351
353static OT_ProcRet NS(MqMsgque_WaitOnEventE_ToInt) (OtClass_ARGS) {
354 OT_SETUP_hdl_static;
355 OT_SETUP_ONEARG(WaitOnEventE_ToInt_doc);
356 enum MqWaitOnEventE value = 0;
357 OT_CHECK_REQUIRED(OT_CHECK_ENUM (MqWaitOnEventE,value))
358 OT_CHECK_NOARGS;
359 OT_retObj_SET_I32(MqWaitOnEventE_ToInt (value));
360 end: MK_UNUSED /* LONG JUMP on error */
361 OT_retObj_RETURN;
362}
363
365static OT_ProcRet NS(MqMsgque_WaitOnEventE_ToString) (OtClass_ARGS) {
366 OT_SETUP_hdl_static;
367 OT_SETUP_ONEARG(WaitOnEventE_ToString_doc);
368 enum MqWaitOnEventE value = 0;
369 OT_CHECK_REQUIRED(OT_CHECK_ENUM (MqWaitOnEventE,value))
370 OT_CHECK_NOARGS;
371 OT_retObj_SET_STR(MqWaitOnEventE_ToString (value));
372 end: MK_UNUSED /* LONG JUMP on error */
373 OT_retObj_RETURN;
374}
375
377// MqMsgque_Enum_RB_API
378
382
383// doc-key: MqMsgque,MqMsgque-Help,sm_
384
386static OT_ProcRet NS(MqMsgque_Help) (OtClass_ARGS) {
387 OT_SETUP_hdl_static;
388 OT_SETUP_ONEARG(Help_doc);
389 MK_STRN tool = 0;
390 OT_CHECK_REQUIRED(OT_CHECK_STRN (tool))
391 OT_CHECK_NOARGS;
392 OT_retObj_SET_STR(MqHelp (tool));
393 end: MK_UNUSED /* LONG JUMP on error */
394 OT_retObj_RETURN;
395}
396
398static OT_ProcRet NS(MqMsgque_HelpMsgque) (OtClass_ARGS) {
399 OT_SETUP_hdl_static;
400 OT_SETUP_NOARG(HelpMsgque_doc);
401 OT_CHECK_NOARGS;
402 OT_retObj_SET_STR(MqHelpMsgque ());
403 end: MK_UNUSED /* LONG JUMP on error */
404 OT_retObj_RETURN;
405}
406
408// MqMsgque_Help_RB_API
409
413
414// doc-key: MqMsgque,MqMsgque-Init,sm_
415
417static OT_ProcRet NS(MqMsgque_InitGetArg0) (OtClass_ARGS) {
418 OT_SETUP_hdl_static;
419 OT_SETUP_NOARG(InitGetArg0_doc);
420 OT_CHECK_NOARGS;
421 OT_retObj_SET_BFL(MqInitGetArg0 ());
422 end: MK_UNUSED /* LONG JUMP on error */
423 OT_retObj_RETURN;
424}
425
427static OT_ProcRet NS(MqMsgque_InitResetArg0) (OtClass_ARGS) {
428 OT_SETUP_hdl_static;
429 OT_SETUP_NOARG(InitResetArg0_doc);
430 OT_CHECK_NOARGS;
431 OT_retObj_SET_BFL(MqInitResetArg0 ());
432 end: MK_UNUSED /* LONG JUMP on error */
433 OT_retObj_RETURN;
434}
435
437static OT_ProcRet NS(MqMsgque_InitSetArg0) (OtClass_ARGS) {
438 OT_SETUP_hdl_static;
439 OT_SETUP_VARARGS(0,99,InitSetArg0_doc);
440 MkBufferListCreateTLS_T(bfl,10);
441 OT_CHECK_OPTIONAL(OT_CHECK_BAC (bfl))
442 OT_CHECK_NOARGS;
443 MqInitSetArg0 (bfl);
444 OT_retObj_SET_None;
445 end: MK_UNUSED /* LONG JUMP on error */
446 OT_retObj_RETURN;
447}
448
450// MqMsgque_Init_RB_API
451
455
456// doc-key: MqMsgque,MqMsgque-Setup,sm_
457
459static OT_ProcRet NS(MqMsgque_Cleanup) (OtClass_ARGS) {
460 OT_SETUP_hdl_static;
461 OT_SETUP_NOARG(Cleanup_doc);
462 OT_CHECK_NOARGS;
463 MqCleanupTmpl ();
464 OT_retObj_SET_None;
465 end: MK_UNUSED /* LONG JUMP on error */
466 OT_retObj_RETURN;
467}
468
470static OT_ProcRet NS(MqMsgque_Setup) (OtClass_ARGS) {
471 OT_SETUP_hdl_static;
472 OT_SETUP_NOARG(Setup_doc);
473 OT_CHECK_NOARGS;
474 MqSetupTmpl ();
475 OT_retObj_SET_None;
476 end: MK_UNUSED /* LONG JUMP on error */
477 OT_retObj_RETURN;
478}
479
481// MqMsgque_Setup_RB_API
482
483// END-MqMsgque - created by 'rb_MqC.tcl -i NHI1_HOME/theLink/c/gen/c_mqmsgque.meta' - DO NOT change
484
485// **************************************************************************
486
487static OT_ProcRet MQ(MqMsgque_M) (OtClass_ARGS) {
488 OT_SETUP_hdl_static
489 OT_SETUP_VARARGS(1,1,"M(repeat*10)")
490 VALUE strO = 0;
491 OT_CHECK_REQUIRED(OT_CHECK_LNG_T (strO))
492 OT_CHECK_NOARGS
493 OT_retObj_SET_None
494 OT_GET_CALL_ALL
495 strO = rb_funcall(rb_obj_as_string(strO), rb_intern("*"), 1, INT2VAL(17));
496 MkLogV_4M(MK_ERROR_PRINT,proc,0, "%s [%s:%d]\n", VAL2STRN(strO), file, line);
497 OT_retObj_RETURN
498}
499
500static OT_ProcRet MQ(MqMsgque_printObj) (OtClass_ARGS) {
501 OT_SETUP_hdl_static
502 OT_SETUP_VARARGS(1,2,"printObj object ?caller?")
503 VALUE obj = 0;
504 OT_CHECK_REQUIRED(OT_CHECK_LNG_T (obj))
505 MK_STRN caller = NULL;
506 OT_CHECK_OPTIONAL(OT_CHECK_STRN (caller))
507 OT_CHECK_NOARGS
508 OT_retObj_SET_None
509 if (caller == NULL) caller = OT_GET_CALL_PROC;
510 MK(_printObj)(MK_RT_CALL obj,caller);
511 OT_retObj_RETURN
512}
513
514/*****************************************************************************/
515/* */
516/* public */
517/* */
518/*****************************************************************************/
519
520void MQ(MqMsgque_Init) (MQ_RT_ARGS_ONLY) {
521 MQ(MqMsgque) = rb_define_module("MqMsgque");
522
523 OT_METH_S ( MqMsgque, M, MqMsgque_M )
524 OT_METH_O ( MqMsgque, M, MqMsgque_M )
525
526 OT_METH_S ( MqMsgque, printObj, MqMsgque_printObj )
527 OT_METH_O ( MqMsgque, printObj, MqMsgque_printObj )
528
529// BEGIN-CLASS - created by 'rb_MqS.tcl -i NHI1_HOME/theLink/c/gen/c_mqmsgque.meta' - DO NOT change
530
531// doc-key: MqMsgque,EnumFunc,sco
532OT_METH_O ( MqMsgque, IdentE_FromInt, MqMsgque_IdentE_FromInt )
533OT_METH_S ( MqMsgque, IdentE_FromInt, MqMsgque_IdentE_FromInt )
534OT_METH_O ( MqMsgque, SlaveE_FromInt, MqMsgque_SlaveE_FromInt )
535OT_METH_S ( MqMsgque, SlaveE_FromInt, MqMsgque_SlaveE_FromInt )
536OT_METH_O ( MqMsgque, StartE_FromInt, MqMsgque_StartE_FromInt )
537OT_METH_S ( MqMsgque, StartE_FromInt, MqMsgque_StartE_FromInt )
538OT_METH_O ( MqMsgque, StatusIsEF_FromInt, MqMsgque_StatusIsEF_FromInt )
539OT_METH_S ( MqMsgque, StatusIsEF_FromInt, MqMsgque_StatusIsEF_FromInt )
540OT_METH_O ( MqMsgque, WaitOnEventE_FromInt, MqMsgque_WaitOnEventE_FromInt )
541OT_METH_S ( MqMsgque, WaitOnEventE_FromInt, MqMsgque_WaitOnEventE_FromInt )
542
543// doc-key: MqMsgque,EnumFunc,sm_
544OT_METH_O ( MqMsgque, IdentE_ToInt, MqMsgque_IdentE_ToInt )
545OT_METH_S ( MqMsgque, IdentE_ToInt, MqMsgque_IdentE_ToInt )
546OT_METH_O ( MqMsgque, IdentE_ToString, MqMsgque_IdentE_ToString )
547OT_METH_S ( MqMsgque, IdentE_ToString, MqMsgque_IdentE_ToString )
548OT_METH_O ( MqMsgque, SlaveE_ToInt, MqMsgque_SlaveE_ToInt )
549OT_METH_S ( MqMsgque, SlaveE_ToInt, MqMsgque_SlaveE_ToInt )
550OT_METH_O ( MqMsgque, SlaveE_ToString, MqMsgque_SlaveE_ToString )
551OT_METH_S ( MqMsgque, SlaveE_ToString, MqMsgque_SlaveE_ToString )
552OT_METH_O ( MqMsgque, StartE_ToInt, MqMsgque_StartE_ToInt )
553OT_METH_S ( MqMsgque, StartE_ToInt, MqMsgque_StartE_ToInt )
554OT_METH_O ( MqMsgque, StartE_ToString, MqMsgque_StartE_ToString )
555OT_METH_S ( MqMsgque, StartE_ToString, MqMsgque_StartE_ToString )
556OT_METH_O ( MqMsgque, StatusIsEF_ToInt, MqMsgque_StatusIsEF_ToInt )
557OT_METH_S ( MqMsgque, StatusIsEF_ToInt, MqMsgque_StatusIsEF_ToInt )
558OT_METH_O ( MqMsgque, StatusIsEF_ToString, MqMsgque_StatusIsEF_ToString )
559OT_METH_S ( MqMsgque, StatusIsEF_ToString, MqMsgque_StatusIsEF_ToString )
560OT_METH_O ( MqMsgque, WaitOnEventE_ToInt, MqMsgque_WaitOnEventE_ToInt )
561OT_METH_S ( MqMsgque, WaitOnEventE_ToInt, MqMsgque_WaitOnEventE_ToInt )
562OT_METH_O ( MqMsgque, WaitOnEventE_ToString, MqMsgque_WaitOnEventE_ToString )
563OT_METH_S ( MqMsgque, WaitOnEventE_ToString, MqMsgque_WaitOnEventE_ToString )
564
565// doc-key: MqMsgque,MqHelp,sm_
566OT_METH_O ( MqMsgque, Help, MqMsgque_Help )
567OT_METH_S ( MqMsgque, Help, MqMsgque_Help )
568OT_METH_O ( MqMsgque, HelpMsgque, MqMsgque_HelpMsgque )
569OT_METH_S ( MqMsgque, HelpMsgque, MqMsgque_HelpMsgque )
570
571// doc-key: MqMsgque,MqInit,sm_
572OT_METH_O ( MqMsgque, InitGetArg0, MqMsgque_InitGetArg0 )
573OT_METH_S ( MqMsgque, InitGetArg0, MqMsgque_InitGetArg0 )
574OT_METH_O ( MqMsgque, InitResetArg0, MqMsgque_InitResetArg0 )
575OT_METH_S ( MqMsgque, InitResetArg0, MqMsgque_InitResetArg0 )
576OT_METH_O ( MqMsgque, InitSetArg0, MqMsgque_InitSetArg0 )
577OT_METH_S ( MqMsgque, InitSetArg0, MqMsgque_InitSetArg0 )
578
579// doc-key: MqMsgque,Setup,sm_
580OT_METH_O ( MqMsgque, Cleanup, MqMsgque_Cleanup )
581OT_METH_S ( MqMsgque, Cleanup, MqMsgque_Cleanup )
582OT_METH_O ( MqMsgque, Setup, MqMsgque_Setup )
583OT_METH_S ( MqMsgque, Setup, MqMsgque_Setup )
584
585// END-CLASS - created by 'rb_MqS.tcl -i NHI1_HOME/theLink/c/gen/c_mqmsgque.meta' - DO NOT change
586
587// BEGIN-OBJ - created by 'rb_MqS.tcl -i NHI1_HOME/theLink/c/gen/c_mqmsgque.meta' - DO NOT change
588
589// → no data
590
591// END-OBJ - created by 'rb_MqS.tcl -i NHI1_HOME/theLink/c/gen/c_mqmsgque.meta' - DO NOT change
592
593/*
594 rb_define_const(MQ(MqMsgque), "WAIT_FOREVER", INT2VAL(2));
595
596 // Start
597 rb_define_const(MQ(MqMsgque), "START_DEFAULT", INT2VAL(0));
598 rb_define_const(MQ(MqMsgque), "START_FORK", INT2VAL(1));
599 rb_define_const(MQ(MqMsgque), "START_THREAD", INT2VAL(2));
600 rb_define_const(MQ(MqMsgque), "START_SPAWN", INT2VAL(3));
601*/
602}
603
604/*****************************************************************************/
605/* */
606/* init */
607/* */
608/*****************************************************************************/
609
610MK_RB_EXTERN void LibMqMsgque() {
611
612 // Register system
613#ifdef HAVE_FORK
614// MkInitSysAPI(MK(fork),NULL);
615#endif
616
617 // Initialize libmqmsgque
618 MqSetup();
619 AllRtSetup_NULL;
620
621 // load "rbmkkernel" shared library
622 rb_require("rbmkkernel");
623
624 // Initialize components
625 MQ(MqMsgque_Init) (MQ_RT_CALL_ONLY) ;
626 MQ(MqContextC_Init) (MQ_RT_CALL_ONLY) ;
627 MQ(MqDumpC_Init) (MQ_RT_CALL_ONLY) ;
628 MQ(MqFactoryC_Init) (MQ_RT_CALL_ONLY) ;
629
630 // get the script name
631 VALUE a0 = rb_gv_get("$0");
632
633 // init libmqmsgque global data
634 if (MqInitGetArg0() == NULL && !NIL_P(a0)) {
635 MqInitSetArg0VA(VAL2STRN(rb_argv0), VAL2STRN(a0), NULL);
636 }
637
638 // update LAL
639 // ...
640
641 /*****************************************************************************/
642 /* */
643 /* enums */
644 /* */
645 /*****************************************************************************/
646
647 // BEGIN-enumF - created by 'rb_MqS.tcl -i NHI1_HOME/theLink/c/gen/c_mqmsgque.meta' - DO NOT change
648
649 MQ(MqIdentE) = rb_define_class_under(MQ(MqMsgque), "MqIdentE", MK(cEnum));
650 rb_funcall(MQ(MqIdentE), MK(id_enum_attr), 2, STRN2VAL("PREFIX"), INT2NUM(0));
651 rb_funcall(MQ(MqIdentE), MK(id_enum_attr), 2, STRN2VAL("FACTORY"), INT2NUM(1));
652
653 MQ(MqSlaveE) = rb_define_class_under(MQ(MqMsgque), "MqSlaveE", MK(cEnum));
654 rb_funcall(MQ(MqSlaveE), MK(id_enum_attr), 2, STRN2VAL("LOOPBACK"), INT2NUM(0));
655 rb_funcall(MQ(MqSlaveE), MK(id_enum_attr), 2, STRN2VAL("FILTER"), INT2NUM(1));
656 rb_funcall(MQ(MqSlaveE), MK(id_enum_attr), 2, STRN2VAL("MASTER"), INT2NUM(1));
657 rb_funcall(MQ(MqSlaveE), MK(id_enum_attr), 2, STRN2VAL("OTHER"), INT2NUM(1));
658 rb_funcall(MQ(MqSlaveE), MK(id_enum_attr), 2, STRN2VAL("USER"), INT2NUM(10));
659 rb_funcall(MQ(MqSlaveE), MK(id_enum_attr), 2, STRN2VAL("MAX"), INT2NUM(1024));
660
661 MQ(MqStartE) = rb_define_class_under(MQ(MqMsgque), "MqStartE", MK(cEnum));
662 rb_funcall(MQ(MqStartE), MK(id_enum_attr), 2, STRN2VAL("DEFAULT"), INT2NUM(0));
663 rb_funcall(MQ(MqStartE), MK(id_enum_attr), 2, STRN2VAL("FORK"), INT2NUM(1));
664 rb_funcall(MQ(MqStartE), MK(id_enum_attr), 2, STRN2VAL("THREAD"), INT2NUM(2));
665 rb_funcall(MQ(MqStartE), MK(id_enum_attr), 2, STRN2VAL("SPAWN"), INT2NUM(3));
666
667 MQ(MqStatusIsEF) = rb_define_class_under(MQ(MqMsgque), "MqStatusIsEF", MK(cEnum));
668 rb_funcall(MQ(MqStatusIsEF), MK(id_enum_attr), 2, STRN2VAL("INITIAL"), INT2NUM(0));
669 rb_funcall(MQ(MqStatusIsEF), MK(id_enum_attr), 2, STRN2VAL("DUP"), INT2NUM(1<<0));
670 rb_funcall(MQ(MqStatusIsEF), MK(id_enum_attr), 2, STRN2VAL("THREAD"), INT2NUM(1<<1));
671 rb_funcall(MQ(MqStatusIsEF), MK(id_enum_attr), 2, STRN2VAL("FORK"), INT2NUM(1<<2));
672 rb_funcall(MQ(MqStatusIsEF), MK(id_enum_attr), 2, STRN2VAL("SPAWN"), INT2NUM(1<<3));
673
674 MQ(MqWaitOnEventE) = rb_define_class_under(MQ(MqMsgque), "MqWaitOnEventE", MK(cEnum));
675 rb_funcall(MQ(MqWaitOnEventE), MK(id_enum_attr), 2, STRN2VAL("NO"), INT2NUM(0));
676 rb_funcall(MQ(MqWaitOnEventE), MK(id_enum_attr), 2, STRN2VAL("ONCE"), INT2NUM(1));
677 rb_funcall(MQ(MqWaitOnEventE), MK(id_enum_attr), 2, STRN2VAL("OWN"), INT2NUM(2));
678 rb_funcall(MQ(MqWaitOnEventE), MK(id_enum_attr), 2, STRN2VAL("FOREVER"), INT2NUM(3));
679
680 // END-enumF - created by 'rb_MqS.tcl -i NHI1_HOME/theLink/c/gen/c_mqmsgque.meta' - DO NOT change
681}
MK
#define MK(n)
Definition LibMkKernel_rb.h:80
OT_SETUP_VARARGS
#define OT_SETUP_VARARGS(min, max, d)
Definition LibMkKernel_rb.h:408
OT_SETUP_NOARG
#define OT_SETUP_NOARG(d)
Definition LibMkKernel_rb.h:416
OT_SETUP_ONEARG
#define OT_SETUP_ONEARG(d)
Definition LibMkKernel_rb.h:412
OT_CHECK_NI4
#define OT_CHECK_NI4(val)
Definition LibMkKernel_rb.h:655
OT_METH_S
#define OT_METH_S(c, s, f)
Definition LibMkKernel_rb.h:387
OT_CHECK_REQUIRED
#define OT_CHECK_REQUIRED(val)
Definition LibMkKernel_rb.h:558
OT_retObj_SET_None
#define OT_retObj_SET_None
Definition LibMkKernel_rb.h:453
OT_retObj_SET_I32
#define OT_retObj_SET_I32(nat)
Definition LibMkKernel_rb.h:462
OT_METH_O
#define OT_METH_O(c, s, f)
Definition LibMkKernel_rb.h:388
OT_retObj_SET_BFL
#define OT_retObj_SET_BFL(nat)
Definition LibMkKernel_rb.h:194
INT2VAL
#define INT2VAL(nat)
Definition LibMkKernel_rb.h:740
VAL2STRN
#define VAL2STRN(val)
Definition LibMkKernel_rb.h:728
OT_retObj_RETURN
#define OT_retObj_RETURN
Definition LibMkKernel_rb.h:457
OT_GET_CALL_PROC
#define OT_GET_CALL_PROC
Definition LibMkKernel_rb.h:667
OT_GET_CALL_ALL
#define OT_GET_CALL_ALL
Definition LibMkKernel_rb.h:678
OT_retObj_SET_STR
#define OT_retObj_SET_STR(nat)
Definition LibMkKernel_rb.h:467
MK_RB_EXTERN
#define MK_RB_EXTERN
static library
Definition LibMkKernel_rb.h:53
OT_CHECK_OPTIONAL
#define OT_CHECK_OPTIONAL(val)
Definition LibMkKernel_rb.h:557
OT_retObj_SET
#define OT_retObj_SET(val)
Definition LibMkKernel_rb.h:452
OT_CHECK_NOARGS
#define OT_CHECK_NOARGS
Definition LibMkKernel_rb.h:565
MkErrorC_Check
#define MkErrorC_Check(mng, PROC)
Definition LibMkKernel_rb.h:515
OT_ProcRet
#define OT_ProcRet
Definition LibMkKernel_rb.h:382
OtClass_ARGS
#define OtClass_ARGS
Definition LibMkKernel_rb.h:152
STRN2VAL
#define STRN2VAL(nat)
Definition LibMkKernel_rb.h:744
OT_CHECK_STRN
#define OT_CHECK_STRN(val)
Definition LibMkKernel_rb.h:660
AllRtSetup_NULL
#define AllRtSetup_NULL
Definition LibMqMsgque_mq.h:9397
LibMqMsgque_private_rb.h
tag: nhi1-release-250425
MqCleanupTmpl
#define MqCleanupTmpl()
Definition LibMqMsgque_rb.c:19
StartE_ToString_doc
#define StartE_ToString_doc
Definition LibMqMsgque_rb.c:146
WaitOnEventE_ToInt_doc
#define WaitOnEventE_ToInt_doc
Definition LibMqMsgque_rb.c:149
WaitOnEventE_ToString_doc
#define WaitOnEventE_ToString_doc
Definition LibMqMsgque_rb.c:150
IdentE_ToInt_doc
#define IdentE_ToInt_doc
Definition LibMqMsgque_rb.c:141
IdentE_ToString_doc
#define IdentE_ToString_doc
Definition LibMqMsgque_rb.c:142
InitGetArg0_doc
#define InitGetArg0_doc
Definition LibMqMsgque_rb.c:157
SlaveE_ToString_doc
#define SlaveE_ToString_doc
Definition LibMqMsgque_rb.c:144
StatusIsEF_FromInt_doc
#define StatusIsEF_FromInt_doc
Definition LibMqMsgque_rb.c:137
LibMqMsgque
MK_RB_EXTERN void LibMqMsgque()
Definition LibMqMsgque_rb.c:610
StatusIsEF_ToString_doc
#define StatusIsEF_ToString_doc
Definition LibMqMsgque_rb.c:148
MqSetupTmpl
#define MqSetupTmpl()
Definition LibMqMsgque_rb.c:18
StatusIsEF_ToInt_doc
#define StatusIsEF_ToInt_doc
Definition LibMqMsgque_rb.c:147
HelpMsgque_doc
#define HelpMsgque_doc
Definition LibMqMsgque_rb.c:154
Help_doc
#define Help_doc
Definition LibMqMsgque_rb.c:153
OT_SETUP_hdl_static
#define OT_SETUP_hdl_static
Definition LibMqMsgque_rb.c:167
InitSetArg0_doc
#define InitSetArg0_doc
Definition LibMqMsgque_rb.c:159
InitResetArg0_doc
#define InitResetArg0_doc
Definition LibMqMsgque_rb.c:158
StartE_ToInt_doc
#define StartE_ToInt_doc
Definition LibMqMsgque_rb.c:145
Cleanup_doc
#define Cleanup_doc
Definition LibMqMsgque_rb.c:162
IdentE_FromInt_doc
#define IdentE_FromInt_doc
Definition LibMqMsgque_rb.c:134
SlaveE_ToInt_doc
#define SlaveE_ToInt_doc
Definition LibMqMsgque_rb.c:143
SlaveE_FromInt_doc
#define SlaveE_FromInt_doc
Definition LibMqMsgque_rb.c:135
Setup_doc
#define Setup_doc
Definition LibMqMsgque_rb.c:163
WaitOnEventE_FromInt_doc
#define WaitOnEventE_FromInt_doc
Definition LibMqMsgque_rb.c:138
StartE_FromInt_doc
#define StartE_FromInt_doc
Definition LibMqMsgque_rb.c:136
MQ
#define MQ(n)
Definition LibMqMsgque_rb.h:74
NS
#define NS(n)
Definition LibMqMsgque_rb.h:76
OT_NEW_Mq_enum_OBJ
#define OT_NEW_Mq_enum_OBJ(typ, i)
Definition LibMqMsgque_rb.h:192
MkBufferListCreateTLS_T
#define MkBufferListCreateTLS_T(name, num)
MK_ERROR_PRINT
#define MK_ERROR_PRINT
MK_ERROR_FORMAT
#define MK_ERROR_FORMAT
MK_UNUSED
#define MK_UNUSED
MK_STRN
const MK_STRB * MK_STRN
MK_I32
signed int MK_I32
MkLogV_4M
#define MkLogV_4M(x, callfunc, debug, printfmt,...)
MK_RT_CALL
#define MK_RT_CALL
MqStartE_ToInt
static MK_I32 MqStartE_ToInt(enum MqStartE value)
return the MqStartE as integer …
Definition LibMqMsgque_mq.h:1443
MqIdentE_ToInt
static MK_I32 MqIdentE_ToInt(enum MqIdentE value)
return the MqIdentE as integer …
Definition LibMqMsgque_mq.h:722
MqWaitOnEventE_ToString
MK_STRN MqWaitOnEventE_ToString(enum MqWaitOnEventE value)
return the MqWaitOnEventE as string …
MqStatusIsEF_ToInt
static MK_I32 MqStatusIsEF_ToInt(enum MqStatusIsEF value)
return the MqStatusIsEF as integer …
Definition LibMqMsgque_mq.h:1486
MqStartE_FromInt
enum MkErrorE MqStartE_FromInt(MK_I32 const value, enum MqStartE *value_out)
return the MqStartE from integer …
MqIdentE_FromInt
enum MkErrorE MqIdentE_FromInt(MK_I32 const value, enum MqIdentE *value_out)
return the MqIdentE from integer …
MqWaitOnEventE
MqWaitOnEventE
wait for an event? …
Definition LibMqMsgque_mq.h:1586
MqSlaveE
MqSlaveE
predefined slave-id for well known slaves …
Definition LibMqMsgque_mq.h:1656
MqStatusIsEF_ToString
MK_STRN MqStatusIsEF_ToString(enum MqStatusIsEF value)
return the MqStatusIsEF as string …
MqSlaveE_FromInt
enum MkErrorE MqSlaveE_FromInt(MK_I32 const value, enum MqSlaveE *value_out)
return the MqSlaveE from integer …
MqIdentE
MqIdentE
identify the application using prefix (default) or factory …
Definition LibMqMsgque_mq.h:705
MqSlaveE_ToString
MK_STRN MqSlaveE_ToString(enum MqSlaveE value)
return the MqSlaveE as string …
MqStartE
MqStartE
User preferences on HOWTO start a new entity.
Definition LibMqMsgque_mq.h:1424
MqStatusIsEF
MqStatusIsEF
Information about how the context was created.
Definition LibMqMsgque_mq.h:1466
MqIdentE_ToString
MK_STRN MqIdentE_ToString(enum MqIdentE value)
return the MqIdentE as string …
MqStartE_ToString
MK_STRN MqStartE_ToString(enum MqStartE value)
return the MqStartE as string …
MqStatusIsEF_FromInt
enum MkErrorE MqStatusIsEF_FromInt(MK_I32 const value, enum MqStatusIsEF *value_out)
return the MqStatusIsEF from integer …
MqWaitOnEventE_ToInt
static MK_I32 MqWaitOnEventE_ToInt(enum MqWaitOnEventE value)
return the MqWaitOnEventE as integer …
Definition LibMqMsgque_mq.h:1631
MqSlaveE_ToInt
static MK_I32 MqSlaveE_ToInt(enum MqSlaveE value)
return the MqSlaveE as integer …
Definition LibMqMsgque_mq.h:1680
MqWaitOnEventE_FromInt
enum MkErrorE MqWaitOnEventE_FromInt(MK_I32 const value, enum MqWaitOnEventE *value_out)
return the MqWaitOnEventE from integer …
MqHelp
MK_STR MqHelp(MK_STRN tool)
write rbmqmsgque specific user-help to stderr
MqHelpMsgque
MK_STR MqHelpMsgque(void)
return a page with the usage of all rbmqmsgque specific options
MqInitGetArg0
MK_BFL MqInitGetArg0(void)
get the process startup-prefix argument
MqInitResetArg0
MK_BFL MqInitResetArg0(void)
Reset the process-startup-prefix argument to an empty list …
MqInitSetArg0VA
void MqInitSetArg0VA(MK_STRN arg0,...)
set the process startup-prefix to a args
MqInitSetArg0
void MqInitSetArg0(MK_BAC bfl)
set the process startup-prefix argument to bfl
MqSetup
void MqSetup(void)
setup rbmqmsgque internal memory …
MQ_RT_ARGS_ONLY
#define MQ_RT_ARGS_ONLY
Definition LibMqMsgque_mq.h:214
MQ_RT_CALL_ONLY
#define MQ_RT_CALL_ONLY
Definition LibMqMsgque_mq.h:216
obj
MK_OBJ const obj
Definition high_lng.h:136
OT_CHECK_ENUM
#define OT_CHECK_ENUM(ename, val)
Definition mk_misc_check_lng.h:88
OT_CHECK_LNG_T
#define OT_CHECK_LNG_T(val)
Definition mk_misc_check_lng.h:40
OT_CHECK_BAC
#define OT_CHECK_BAC(val)
Definition mk_misc_check_lng.h:77
Generated on Thu May 29 2025 13:13:59 for theLink by doxygen 1.12.0