MqCall_atl.c

Go to the documentation of this file.

 
/* LABEL-NO */
 
#include  "LibMqMsgque_private_atl.h"
 
#define mqctx hdl
 
/*****************************************************************************/
/*                                                                           */
/*                                Proc-Call                                  */
/*                                                                           */
/*****************************************************************************/
 
/*
[ServiceCall signature]
  1. The *service-ctx* is the *context* for which the service was defined.
  2. If the *callback* is **not** an instance of the calling *context*, the *service-ctx* is added as an argument.
 
  callback-args := service-ctx:MqContextC[in]
  [static]   proc callback { callback-args ?additional-args...? } ...
  [own]      myooX::ClassN ::XXX {
               SuperI MqContextC
               proc callback { ?additional-args...? } ...
  [instance] myooX::ClassN ::YYY {
               proc callback { myNs callback-args ?additional-args...? } ...
  [class]    myooX::ClassN ::ZZZ {
               proc callback { callback-args ?additional-args...? } ...
[ServiceCall signature]
*/
 
#if 0
  #define dbgMsg(fmt,...) printV(fmt,__VA_ARGS__)
  #define dbgObj(obj)     printLngObj(obj)
#else
  #define dbgMsg(fmt,...)
  #define dbgObj(obj)
#endif
 
enum MkErrorE NS(ServiceCall) ( MQ_SERVICE_CALL_ARGS )
{
  MQ_SERVICE_CALL_CHECK;
 
  // 1. setup environment
  MkCallS *call = __data__;
    assert(call->signature == MkCallS_SIG);
 
//MkCallLog(call);
 
  // 2. prolog
#if 0
  CallProlog(mqctx);
#else
# define m mqctx
  /* 1. setup runtime */
  OT_MK_RT_T const amkrt = call->amkrt;
    assert (amkrt->signature == OT_MK_RT_SIG);
  OT_ENV_T const interp = amkrt->interp;
    assert (!Tcl_InterpDeleted(interp));
  Tcl_ResetResult(interp);
 
  /* 2. setup arguments */
  Tcl_Obj *objv[5+MkProcResolve_maxArgsLen];
 
  rescan:
    int objc = 1;
 
    /* 1. setup methode */
    objv[0] = call->mth;
 
    /* 2. setup my */
    switch (call->type) {
      case MkCallS_own_method:
        dbgMsg("%s","MkCallS_own_method");
        break;
      case MkCallS_static:
        dbgMsg("%s","MkCallS_static");
        break;
      case MkCallS_proc:
        dbgMsg("%s","MkCallS_proc");
        break;
      case MkCallS_other_method:
        dbgMsg("%s","MkCallS_other_method");
        objv[objc++] = call->my;
        break;
      case MkCallS_init: {
        dbgMsg("%s","MkCallS_init");
        check_META(MK(ProcResolve)(OT_MK_CALL (m), call)) goto error_mq;
        goto rescan;
      }
      case MkCallS_null:
        dbgMsg("%s","MkCallS_null");
        return MK_OK;
      case MkCallS_error:
        dbgMsg("%s","MkCallS_error");
        goto error;
    }
# undef m
#endif
 
  // 3. setup CTX arg
  objv[objc++] = META2VAL_X(mqctx);
 
  // 4. setup user arg(s)
  if (call->args) MK(ProcResolveAppendArgs)(call,&objc,objv);
 
  // 3. call the callback
  int ret = Atl_EvalObjv (interp, objc, objv, 0); /* "MK(EvalObjv)" IS NOT required !! */
    if (ret != TCL_OK) goto error;
 
  return MkErrorGetCodeI(&MkERROR);   /* MkErrorGetCode_0E() */
 
error:
  OT_ERROR_LNG_2_META(mqctx);
 
error_mq:
  return MkErrorStack_0E();
}
 
void NS(ServiceFree) ( MQ_SERVICE_FREE_ARGS )
{
  MK(CallFree) (dataP);
}
 
void NS(ServiceCopy) ( MQ_SERVICE_COPY_ARGS )
{
  MK(CallCopy)(MK_RT_CALL MkOBJ(mqctx), dataP);
}