MqCall_atl.c File Reference

tag: nhi1-release-250425 More...

#include "LibMqMsgque_private_atl.h"

Include dependency graph for MqCall_atl.c:

Go to the source code of this file.

Macros
#define	mqctx   hdl
#define	dbgMsg(fmt, ...)
#define	dbgObj(obj)
#define	m   mqctx

Functions
enum MkErrorE	atlmqmsgque_ServiceCall (MQ_SERVICE_CALL_ARGS)
void	atlmqmsgque_ServiceFree (MQ_SERVICE_FREE_ARGS)
void	atlmqmsgque_ServiceCopy (MQ_SERVICE_COPY_ARGS)

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

Macro Definition Documentation

dbgMsg

#define dbgMsg	(		fmt,
			... )

Definition at line 42 of file MqCall_atl.c.

dbgObj

#define dbgObj

(

obj

)

Definition at line 43 of file MqCall_atl.c.

m

#define m   mqctx

mqctx

#define mqctx   hdl

Definition at line 13 of file MqCall_atl.c.

Function Documentation

atlmqmsgque_ServiceCall()

enum MkErrorE atlmqmsgque_ServiceCall

(

MQ_SERVICE_CALL_ARGS

)

Definition at line 46 of file MqCall_atl.c.

{
  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();
}

atlmqmsgque_ServiceCopy()

void atlmqmsgque_ServiceCopy

(

MQ_SERVICE_COPY_ARGS

)

Definition at line 131 of file MqCall_atl.c.

{
  MK(CallCopy)(MK_RT_CALL MkOBJ(mqctx), dataP);
}

atlmqmsgque_ServiceFree()

void atlmqmsgque_ServiceFree

(

MQ_SERVICE_FREE_ARGS

)

Definition at line 126 of file MqCall_atl.c.

{
  MK(CallFree) (dataP);
}