MqCall_rb.c File Reference

tag: nhi1-release-250425 More...

#include "LibMqMsgque_private_rb.h"
#include "misc_check_rb.h"
#include "tmpl/mq_misc_check_lng.h"

Include dependency graph for MqCall_rb.c:

Go to the source code of this file.

Functions
static VALUE	rbmqmsgque_sRescue (MK_RT mkrt, MK_MNG const mng, VALUE(*proc)(ANYARGS), VALUE data)
static VALUE	rbmqmsgque_sCallMethodWithoutSelf (VALUE method)
static VALUE	rbmqmsgque_sCallMethodWithSelf (VALUE array)
static VALUE	rbmqmsgque_sCallProcWithSelf (VALUE array)
enum MkErrorE	rbmqmsgque_ServiceCall (MQ_SERVICE_CALL_ARGS)
void	rbmqmsgque_ServiceFree (MQ_SERVICE_FREE_ARGS)
VALUE	rbmqmsgque_sCopyWithSelf (MQ_CTX const mqctx, VALUE meth)
VALUE	rbmqmsgque_sCopyWithoutSelf (MQ_CTX const mqctx, VALUE proc)
void	rbmqmsgque_ServiceCopy (MQ_SERVICE_COPY_ARGS)
void	rbmqmsgque_ProcMark (MK_RT mkrt, MK_PTR data)
enum MkErrorE	rbmqmsgque_CheckConstructor (OT_Check_ARGS, MK_CCP *retP)

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 MqCall_rb.c.

Function Documentation

rbmqmsgque_CheckConstructor()

enum MkErrorE rbmqmsgque_CheckConstructor	(	OT_Check_ARGS	,
		MK_CCP *	retP )

Definition at line 182 of file MqCall_rb.c.

{
  if ((*skipP) >= objc) {
    WrongNumArgs(hdl, (*skipP), objc, -999, +999, arg);
    goto error;
  }
  OT_OBJ_T objV = OT_LNG_OBJV((*skipP)++);
  if (rb_class_inherited_p(objV,MQ(MqContextC)) != Qnil) {
    *retP = (MK_CCP) objV;
  } else if (rb_class_inherited_p(objV,MK(MkObjectC)) != Qnil) {
    WrongTypeOfArgError(OT_LNG_NAME_FROM_CLASS(NS(MqContextC)), OT_LNG_NAME_FROM_CLASS(objV));
  } else {
    WrongTypeOfArgError(OT_LNG_NAME_FROM_CLASS(NS(MqContextC)), OT_OBJ_TYPE_STRING(objV));
  }
  return MK_OK;
error:
  return OT_ERROR_STACK;
}

rbmqmsgque_ProcMark()

void rbmqmsgque_ProcMark	(	MK_RT	mkrt,
		MK_PTR	data )

Definition at line 171 of file MqCall_rb.c.

                                           {
  struct MkCallS *call = (struct MkCallS*) data;
//printV("call=%p, data=%p\n", call, call->procCallback)
  rb_gc_mark(call->procCallback);
}

rbmqmsgque_sCallMethodWithoutSelf()

static VALUE rbmqmsgque_sCallMethodWithoutSelf ( VALUE method )

static

Definition at line 33 of file MqCall_rb.c.

                                                       {
  return rb_method_call(0, NULL, method);
}

rbmqmsgque_sCallMethodWithSelf()

static VALUE rbmqmsgque_sCallMethodWithSelf ( VALUE array )

static

Definition at line 38 of file MqCall_rb.c.

                                                   {
  const VALUE *valP = rb_array_const_ptr(array);
  return rb_method_call(1, &valP[0], valP[1]);
}

rbmqmsgque_sCallProcWithSelf()

static VALUE rbmqmsgque_sCallProcWithSelf ( VALUE array )

static

Definition at line 44 of file MqCall_rb.c.

                                                 {
  const VALUE *valP = rb_array_const_ptr(array);
  return rb_proc_call_with_block(valP[1], 1, &valP[0], Qnil);
}

rbmqmsgque_sCopyWithoutSelf()

VALUE rbmqmsgque_sCopyWithoutSelf	(	MQ_CTX const	mqctx,
		VALUE	proc )

Definition at line 156 of file MqCall_rb.c.

                                                            {
  return rb_funcallv(proc,MK(id_clone),0,NULL);
}

rbmqmsgque_sCopyWithSelf()

VALUE rbmqmsgque_sCopyWithSelf	(	MQ_CTX const	mqctx,
		VALUE	meth )

Definition at line 147 of file MqCall_rb.c.

                                                         {
  MkRtSetup_X(mqctx);
  OT_SETUP_self;
  meth = rb_funcallv(meth,MK(id_clone),0,NULL);
  meth = rb_funcallv(meth,MK(id_unbind),0,NULL);
  meth = rb_funcall(meth,MK(id_bind),1,self);
  return meth;
}

rbmqmsgque_ServiceCall()

enum MkErrorE rbmqmsgque_ServiceCall

(

MQ_SERVICE_CALL_ARGS

)

Definition at line 64 of file MqCall_rb.c.

{ 
  MQ_SERVICE_CALL_CHECK;
 
  struct MkCallS *call = __data__;
  int argNum = 1;
 
  if (!MqCtxCheck(mqctx)) {
    mk_dbg_color_ln(MK_COLOR_RED, "%s", "mqctx invalid");
  }
  if (!MqCtxCheck(call->hdl)) {
    mk_dbg_color_ln(MK_COLOR_RED, "%s", "call->hdl invalid");
  }
 
  // 1. check environment
  if (OT_LNG_NULL_IS(call->procCallback)) return MK_OK;
 
//MkDbgDeepX_3(mqctx, "AAA", "cmd=%s", VAL2STRN(rb_inspect(call->procCallback)));
 
  // 2. if not already done initialize
  if (call->procCall == NULL) {
    assert(!OT_LNG_NULL_IS(call->procArgs));
    switch (call->procType) {
      case MkCallS_own_method: {
        OT_SETUP_self
        argNum = rb_equal(rb_funcallv(call->procCallback,MK(id_receiver),0,NULL),self) ? 0 : 1;
        if (argNum > call->procArity) goto methode_arg_error;
        if (call->procArity == 0) {
          call->procNeedSelf = false;
          call->procCall = NS(sCallMethodWithoutSelf);
        } else {
          call->procNeedSelf = true;
          call->procCall = NS(sCallMethodWithSelf);
        }
      }
      break;
      case MkCallS_proc:
        call->procNeedSelf = true;
        call->procCall = NS(sCallProcWithSelf);
        if (argNum != call->procArity) goto methode_arg_error;
      break;
      default:
        MkErrorSetV_3M(mqctx, "WrongInitError", "found invalid procType for callback '%s'", VAL2STRN(call->procCallback));
        goto error;
      break;
    }
  }
 
  // 3. call callback
  if (call->procNeedSelf == false) {
    // without "self"
    if (rb_obj_is_kind_of(call->procCallback, rb_cMethod) != Qtrue) {
      mk_dbg_color_ln(MK_COLOR_RED, "%s", "call->procCallback invalid");
    }
    NS(sRescue)(MK_RT_CALL mqctx,call->procCall,call->procCallback);
  } else {
    // with "self"
    OT_SETUP_self;
    VALUE ary = rb_ary_resize(call->procArgs,2);
    rb_ary_store(ary,0,self);
    rb_ary_store(ary,1,call->procCallback);
    NS(sRescue)(MK_RT_CALL mqctx,call->procCall,ary);
  }
  MkErrorCheck_0E();
 
MkDbgDeepX_3(mqctx, "BBB", "cmd=%s", VAL2STRN(rb_inspect(call->procCallback)));
  return MkErrorGetCode_0E();
 
methode_arg_error:
  MkErrorSetV_3M(mqctx, "WrongNumberOfArgError", "for callback '%s' exactly '%d' argument is required, but '%d' was received", 
    VAL2STRN(call->procCallback), argNum, call->procArity);
  goto error;
 
error:
MkDbgDeepX_3(mqctx, "EEE", "cmd=%s", VAL2STRN(rb_inspect(call->procCallback)));
//printSTACK_1(mqctx)
  return MkErrorStack_0E();
}

rbmqmsgque_ServiceCopy()

void rbmqmsgque_ServiceCopy

(

MQ_SERVICE_COPY_ARGS

)

Definition at line 160 of file MqCall_rb.c.

                                              {
  struct MkCallS *call = *dataP = MkSysMemDup(MK_ERROR_PANIC, *dataP, sizeof(struct MkCallS));
 
  if (call->procNeedSelf) {
    call->procCallback = NS(sRescue)(MK_RT_CALL mqctx, NS(sCopyWithSelf), call->procCallback);
  } else {
    call->procCallback = NS(sRescue)(MK_RT_CALL mqctx, NS(sCopyWithoutSelf), call->procCallback);
  }
  INCR_REF(&call->procCallback);
}

rbmqmsgque_ServiceFree()

void rbmqmsgque_ServiceFree

(

MQ_SERVICE_FREE_ARGS

)

Definition at line 143 of file MqCall_rb.c.

                                              {
  MK(CallFree)(dataP);
}

rbmqmsgque_sRescue()

static VALUE rbmqmsgque_sRescue ( MK_RT mkrt, MK_MNG const mng, VALUE(* proc )(ANYARGS), VALUE data )

inlinestatic

Definition at line 16 of file MqCall_rb.c.

  {
  int state;
  VALUE ret = rb_protect(proc, data, &state);
  if (state) {
    OT_ERROR_LNG_2_META_2(mng,"ProcessEvent");
  }
  return ret;
}