Sq3Call_rb.c

Go to the documentation of this file.

 
/* LABEL-NO */
 
#define META_FILE_NAME "Sq3Call_rb.c"
 
#include "LibSq3Lite_private_rb.h"
//#include "tmpl/lc_type_S_lng.h"
//#include "misc_check_rb.h"
 
/* LABEL-END */
 
mk_inline VALUE NS(sRescue) (
  MK_RT_ARGS
  MK_MNG const mng,
  VALUE(*proc)(ANYARGS),
  VALUE data
) {
  VALUE ret;
  int state;
  ret = rb_protect(proc, data, &state);
  if (state) {
    OT_ERROR_LNG_2_META(mng);
  }
  return ret;
}
 
// ==========================================================================
 
// method callback without self
MK_UNUSED static VALUE NS(sCallMethod) (VALUE array) {
  const VALUE *valP = rb_array_const_ptr(array);
  return rb_method_call((int)RARRAY_LEN(array)-1, &valP[1], valP[0]);
}
 
// ==========================================================================
 
/*
[LiteExecCall signature]
  callback-args := vals:List[in] , cols:List[in]
  [static]   def callback ( callback-args )
  [instance] class YYY:
               def callback ( self, callback-args )
  [class]    class ZZZ: 
               @staticmethod
               def callback ( callback-args )
[LiteExecCall signature]
*/
 
// #define Sq3Fupu_Sq3LiteExec_callback_call_args MK_CBP callV1, MK_I32 num, MK_STR *vals, MK_STR *cols
 
Sq3Fupu_Sq3LiteExec_callback_call_ret NS(LiteExecCall) ( Sq3Fupu_Sq3LiteExec_callback_call_args )
{ 
  Sq3Fupu_Sq3LiteExec_callback_call_check;
 
  // ?? if (_Py_IsFinalizing()) return 1;
 
  struct MkCallS *call = callV1;
  MkRtSetup_RT(call->mkrt);
 
  int argNum = 2;
 
  // 1. check environment
  if (OT_LNG_NULL_IS(call->procCallback)) return 1;
 
//printLngObj(call->procCallback)
 
MkDbgDeepX_3(call->hdl, "AAA", "cmd=%s", VAL2STRN(rb_inspect(call->procCallback)));
 
  // 2. if not already done initialize
  if (call->procCall == NULL) {
    switch (call->procType) {
      case MkCallS_own_method: {
        if (call->procArity != argNum) goto methode_arg_error;
        call->procCall = NS(sCallMethod);
      }
      break;
      default:
        MkErrorSetV_3M(call->hdl, "WrongInitError", "found invalid procType for callback '%s'", VAL2STRN(call->procCallback));
        goto error;
      break;
    }
  }
 
  OT_OBJ_T valsO = rb_ary_new2(num);
  OT_OBJ_T colsO = rb_ary_new2(num);
  for (long i=0; i<num; i++) {
    rb_ary_store(valsO,i,STRN2VAL(vals[i]));
  }
  for (long i=0; i<num; i++) {
    rb_ary_store(colsO,i,STRN2VAL(cols[i]));
  }
 
  VALUE ary = rb_ary_resize(call->procArgs,3);
  rb_ary_store(ary,0,call->procCallback);
  rb_ary_store(ary,1,valsO);
  rb_ary_store(ary,2,colsO);
  NS(sRescue)(MK_RT_CALL call->hdl,call->procCall,ary);
 
  MkErrorCheck_0E();
 
MkDbgDeepX_3(mqctx, "BBB", "cmd=%s", VAL2STRN(rb_inspect(call->procCallback)));
  return 0;
 
methode_arg_error:
  MkErrorSetV_3M(call->hdl, "WrongNumberOfArgError", "for callback '%s' exactly '%d' argument is required, but '%d' was received", 
    VAL2STRN(call->procCallback), argNum, call->procArity);
  goto error;
 
error:
MkDbgDeepX_3(call->hdl, "EEE", "cmd=%s", VAL2STRN(rb_inspect(call->procCallback)));
  MkErrorStack_0E();
//printSTACK_1(mqctx)
  return 1;
}
 
// ---------------------------------------------------------------------
 
/*
[LiteExecV2Call signature]
  callback-args := vals:MkBufferList[in] , cols:MkBufferList[in]
  [static]   def callback ( callback-args )
  [instance] class YYY:
               def callback ( self, callback-args )
  [class]    class ZZZ: 
               @staticmethod
               def callback ( callback-args )
[LiteExecV2Call signature]
*/
 
// #define Sq3LiteExecV2CB_ret   enum MkErrorE
// #define Sq3LiteExecV2CB_args  MK_RT_ARGS MK_CBP callback, MK_BFL vals, MK_BFL cols
 
Sq3LiteExecV2CB_ret NS(LiteExecV2Call) ( Sq3LiteExecV2CB_args )
{ 
  Sq3Fupu_Sq3LiteExecV2CB_callback_call_check;
 
  struct MkCallS *call = callV2;
 
  int argNum = 2;
 
  // 1. check environment
  if (OT_LNG_NULL_IS(call->procCallback)) return MK_ERROR;
 
//printLngObj(call->procCallback)
 
MkDbgDeepX_3(call->hdl, "AAA", "cmd=%s", VAL2STRN(rb_inspect(call->procCallback)));
 
  // 2. if not already done initialize
  if (call->procCall == NULL) {
    switch (call->procType) {
      case MkCallS_own_method: {
        if (call->procArity != argNum) goto methode_arg_error;
        call->procCall = NS(sCallMethod);
      }
      break;
      default:
        MkErrorSetV_3M(call->hdl, "WrongInitError", "found invalid procType for callback '%s'", VAL2STRN(call->procCallback));
        goto error;
      break;
    }
  }
 
  OT_OBJ_T valsO = OT_TMP_BFL_OBJ(vals);
  OT_OBJ_T colsO = OT_TMP_BFL_OBJ(cols);
 
  VALUE ary = rb_ary_resize(call->procArgs,3);
  rb_ary_store(ary,0,call->procCallback);
  rb_ary_store(ary,1,valsO);
  rb_ary_store(ary,2,colsO);
  NS(sRescue)(MK_RT_CALL call->hdl,call->procCall,ary);
 
  MkErrorCheck_0E();
 
MkDbgDeepX_3(mqctx, "BBB", "cmd=%s", VAL2STRN(rb_inspect(call->procCallback)));
  return MkErrorGetCode_0E();
 
methode_arg_error:
  MkErrorSetV_3M(call->hdl, "WrongNumberOfArgError", "for callback '%s' exactly '%d' argument is required, but '%d' was received", 
    VAL2STRN(call->procCallback), argNum, call->procArity);
  goto error;
 
error:
MkDbgDeepX_3(call->hdl, "EEE", "cmd=%s", VAL2STRN(rb_inspect(call->procCallback)));
  return MkErrorStack_0E();
}