LibMqMsgque_tcl.h File Reference

tag: nhi1-release-250425 More...

#include "LibMkKernel_tcl.h"
#include "LibMqMsgque_mq.h"
#include "tmpl/mq_type_S_lng.h"
#include "tmpl/mq_misc_check_lng.h"

Include dependency graph for LibMqMsgque_tcl.h:

This graph shows which files directly or indirectly include this file:

Go to the source code of this file.

Data Structures
struct	TclContextS

Macros
#define	HEADER
#define	MQ_TCL_EXTERN
	static library
#define	MQ_TCL_EXTERN_DATA   extern
#define	MQ(n)
#define	NS(n)
#define	MqContextC_ARGS   OBJECT_ARGS
#define	MqContextC_ARGS_CALL   OBJECT_ARGS_CALL
#define	MqDumpC_ARGS   OBJECT_ARGS
#define	MqDumpC_ARGS_CALL   OBJECT_ARGS_CALL
#define	MqFactoryC_ARGS   OBJECT_ARGS
#define	MqFactoryC_ARGS_CALL   OBJECT_ARGS_CALL
#define	MqContextC_lngO   MQ(MqContextC)
#define	OT_retObj_SET_CTX(nat)
#define	OT_TMP_CTX_OBJ(val)
#define	MqDumpC_lngO   MQ(MqDumpC)
#define	OT_retObj_SET_DMP(nat)
#define	OT_TMP_DMP_OBJ(val)
#define	MqFactoryC_lngO   MQ(MqFactoryC)
#define	OT_retObj_SET_FCT(nat)
#define	OT_TMP_FCT_OBJ(val)
#define	Get_MqIdentE_FromObj_path   MQ(Get_MqIdentE_FromObj)
#define	Get_MqSlaveE_FromObj_path   MQ(Get_MqSlaveE_FromObj)
#define	Get_MqStartE_FromObj_path   MQ(Get_MqStartE_FromObj)
#define	Get_MqStatusIsEF_FromObj_path   MQ(Get_MqStatusIsEF_FromObj)
#define	Get_MqWaitOnEventE_FromObj_path   MQ(Get_MqWaitOnEventE_FromObj)
#define	OT_NEW_Mq_enum_OBJ(typ, val)

Functions
int	tclmqmsgque_pMqContextC_Init (MK_RT mkrt, OT_ENV_T, OT_NS_T)
static MK_ARTIFICIAL OT_OBJ_T	tclmqmsgque_MqContextC_ObjNew (MK_RT mkrt, OT_ENV_T interp, MqContextC_type hdl)
int	tclmqmsgque_pMqDumpC_Init (MK_RT mkrt, OT_ENV_T, OT_NS_T)
static MK_ARTIFICIAL OT_OBJ_T	tclmqmsgque_MqDumpC_ObjNew (MK_RT mkrt, OT_ENV_T interp, MqDumpC_type hdl)
int	tclmqmsgque_pMqFactoryC_Init (MK_RT mkrt, OT_ENV_T, OT_NS_T)
static MK_ARTIFICIAL OT_OBJ_T	tclmqmsgque_MqFactoryC_ObjNew (MK_RT mkrt, OT_ENV_T interp, MqFactoryC_type hdl)
int	tclmqmsgque_MqContextC_ReadLIST (MqContextC_ARGS)
int	tclmqmsgque_MqContextC_ReadNEXT (MqContextC_ARGS)
void	tclmqmsgque_ServiceFree (MQ_SERVICE_FREE_ARGS)
void	tclmqmsgque_ServiceCopy (MQ_SERVICE_COPY_ARGS)
enum MkErrorE	tclmqmsgque_ServiceCall (MQ_SERVICE_CALL_ARGS)
int	tclmqmsgque_MqFactoryC_Setup (MK_RT mkrt, OT_ENV_T)
MQ_TCL_EXTERN int	tclmqmsgque_Get_MqIdentE_FromObj (MK_RT mkrt, OT_ENV_T interp, OT_OBJ_T enumE, enum MqIdentE *ret)
MQ_TCL_EXTERN int	tclmqmsgque_Get_MqSlaveE_FromObj (MK_RT mkrt, OT_ENV_T interp, OT_OBJ_T enumE, enum MqSlaveE *ret)
MQ_TCL_EXTERN int	tclmqmsgque_Get_MqStartE_FromObj (MK_RT mkrt, OT_ENV_T interp, OT_OBJ_T enumE, enum MqStartE *ret)
MQ_TCL_EXTERN int	tclmqmsgque_Get_MqStatusIsEF_FromObj (MK_RT mkrt, OT_ENV_T interp, OT_OBJ_T enumE, enum MqStatusIsEF *ret)
MQ_TCL_EXTERN int	tclmqmsgque_Get_MqWaitOnEventE_FromObj (MK_RT mkrt, OT_ENV_T interp, OT_OBJ_T enumE, enum MqWaitOnEventE *ret)
MQ_TCL_EXTERN OT_OBJ_T	tclmqmsgque_MqIdentE_ToString (const enum MqIdentE)
MQ_TCL_EXTERN OT_OBJ_T	tclmqmsgque_MqSlaveE_ToString (const enum MqSlaveE)
MQ_TCL_EXTERN OT_OBJ_T	tclmqmsgque_MqStartE_ToString (const enum MqStartE)
MQ_TCL_EXTERN OT_OBJ_T	tclmqmsgque_MqStatusIsEF_ToString (const enum MqStatusIsEF)
MQ_TCL_EXTERN OT_OBJ_T	tclmqmsgque_MqWaitOnEventE_ToString (const enum MqWaitOnEventE)

Variables
MQ_TCL_EXTERN_DATA __thread OT_CLS_T	tclmqmsgque_MqContextC
MQ_TCL_EXTERN_DATA __thread OT_OBJ_T	tclmqmsgque_MqContextC_MK_NULL
MQ_TCL_EXTERN_DATA __thread OT_CLS_T	tclmqmsgque_MqDumpC
MQ_TCL_EXTERN_DATA __thread OT_OBJ_T	tclmqmsgque_MqDumpC_MK_NULL
MQ_TCL_EXTERN_DATA __thread OT_CLS_T	tclmqmsgque_MqFactoryC
MQ_TCL_EXTERN_DATA __thread OT_OBJ_T	tclmqmsgque_MqFactoryC_MK_NULL

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 LibMqMsgque_tcl.h.

Macro Definition Documentation

Get_MqIdentE_FromObj_path

#define Get_MqIdentE_FromObj_path   MQ(Get_MqIdentE_FromObj)

Definition at line 207 of file LibMqMsgque_tcl.h.

Get_MqSlaveE_FromObj_path

#define Get_MqSlaveE_FromObj_path   MQ(Get_MqSlaveE_FromObj)

Definition at line 210 of file LibMqMsgque_tcl.h.

Get_MqStartE_FromObj_path

#define Get_MqStartE_FromObj_path   MQ(Get_MqStartE_FromObj)

Definition at line 213 of file LibMqMsgque_tcl.h.

Get_MqStatusIsEF_FromObj_path

#define Get_MqStatusIsEF_FromObj_path   MQ(Get_MqStatusIsEF_FromObj)

Definition at line 216 of file LibMqMsgque_tcl.h.

Get_MqWaitOnEventE_FromObj_path

#define Get_MqWaitOnEventE_FromObj_path   MQ(Get_MqWaitOnEventE_FromObj)

Definition at line 219 of file LibMqMsgque_tcl.h.

HEADER

#define HEADER

Definition at line 24 of file LibMqMsgque_tcl.h.

MQ

#define MQ

(

n

)

Value:

tclmqmsgque_ ## n

Definition at line 75 of file LibMqMsgque_tcl.h.

MQ_TCL_EXTERN

#define MQ_TCL_EXTERN

static library

Definition at line 48 of file LibMqMsgque_tcl.h.

MQ_TCL_EXTERN_DATA

#define MQ_TCL_EXTERN_DATA   extern

Definition at line 71 of file LibMqMsgque_tcl.h.

MqContextC_ARGS

#define MqContextC_ARGS   OBJECT_ARGS

Definition at line 83 of file LibMqMsgque_tcl.h.

MqContextC_ARGS_CALL

#define MqContextC_ARGS_CALL   OBJECT_ARGS_CALL

Definition at line 84 of file LibMqMsgque_tcl.h.

MqContextC_lngO

#define MqContextC_lngO   MQ(MqContextC)

Definition at line 111 of file LibMqMsgque_tcl.h.

MqDumpC_ARGS

#define MqDumpC_ARGS   OBJECT_ARGS

Definition at line 85 of file LibMqMsgque_tcl.h.

MqDumpC_ARGS_CALL

#define MqDumpC_ARGS_CALL   OBJECT_ARGS_CALL

Definition at line 86 of file LibMqMsgque_tcl.h.

MqDumpC_lngO

#define MqDumpC_lngO   MQ(MqDumpC)

Definition at line 129 of file LibMqMsgque_tcl.h.

MqFactoryC_ARGS

#define MqFactoryC_ARGS   OBJECT_ARGS

Definition at line 87 of file LibMqMsgque_tcl.h.

MqFactoryC_ARGS_CALL

#define MqFactoryC_ARGS_CALL   OBJECT_ARGS_CALL

Definition at line 88 of file LibMqMsgque_tcl.h.

MqFactoryC_lngO

#define MqFactoryC_lngO   MQ(MqFactoryC)

Definition at line 147 of file LibMqMsgque_tcl.h.

NS

#define NS

(

n

)

Value:

tclmqmsgque_ ## n

Definition at line 77 of file LibMqMsgque_tcl.h.

OT_NEW_Mq_enum_OBJ

#define OT_NEW_Mq_enum_OBJ	(		typ,
			val )

Value:

MQ(Mq ## typ ## _ToString(val))

Definition at line 225 of file LibMqMsgque_tcl.h.

OT_retObj_SET_CTX

#define OT_retObj_SET_CTX

(

nat

)

Value:

retObj = MQ(MqContextC_ObjNew) (MK_RT_CALL interp,nat)

Definition at line 117 of file LibMqMsgque_tcl.h.

OT_retObj_SET_DMP

#define OT_retObj_SET_DMP

(

nat

)

Value:

retObj = MQ(MqDumpC_ObjNew) (MK_RT_CALL interp,nat)

Definition at line 135 of file LibMqMsgque_tcl.h.

OT_retObj_SET_FCT

#define OT_retObj_SET_FCT

(

nat

)

Value:

retObj = MQ(MqFactoryC_ObjNew) (MK_RT_CALL interp,nat)

Definition at line 153 of file LibMqMsgque_tcl.h.

OT_TMP_CTX_OBJ

#define OT_TMP_CTX_OBJ

(

val

)

Value:

MQ(MqContextC_ObjNew) (MK_RT_CALL interp,val)

Definition at line 119 of file LibMqMsgque_tcl.h.

OT_TMP_DMP_OBJ

#define OT_TMP_DMP_OBJ

(

val

)

Value:

MQ(MqDumpC_ObjNew) (MK_RT_CALL interp,val)

Definition at line 137 of file LibMqMsgque_tcl.h.

OT_TMP_FCT_OBJ

#define OT_TMP_FCT_OBJ

(

val

)

Value:

MQ(MqFactoryC_ObjNew) (MK_RT_CALL interp,val)

Definition at line 155 of file LibMqMsgque_tcl.h.

Function Documentation

tclmqmsgque_MqContextC_ObjNew()

static MK_ARTIFICIAL OT_OBJ_T tclmqmsgque_MqContextC_ObjNew ( MK_RT mkrt, OT_ENV_T interp, MqContextC_type hdl )

inlinestatic

Definition at line 122 of file LibMqMsgque_tcl.h.

                                                                                             {
    return ( hdl ? MK(AtomObjNew) (MK_RT_CALL interp, MqContextC_X2obj(hdl)) : MQ(MqContextC_MK_NULL) );
  }

tclmqmsgque_MqContextC_ReadLIST()

int tclmqmsgque_MqContextC_ReadLIST

(

MqContextC_ARGS

)

tclmqmsgque_MqContextC_ReadNEXT()

int tclmqmsgque_MqContextC_ReadNEXT

(

MqContextC_ARGS

)

tclmqmsgque_MqDumpC_ObjNew()

static MK_ARTIFICIAL OT_OBJ_T tclmqmsgque_MqDumpC_ObjNew ( MK_RT mkrt, OT_ENV_T interp, MqDumpC_type hdl )

inlinestatic

Definition at line 140 of file LibMqMsgque_tcl.h.

                                                                                       {
    return ( hdl ? MK(AtomObjNew) (MK_RT_CALL interp, MqDumpC_X2obj(hdl)) : MQ(MqDumpC_MK_NULL) );
  }

tclmqmsgque_MqFactoryC_ObjNew()

static MK_ARTIFICIAL OT_OBJ_T tclmqmsgque_MqFactoryC_ObjNew ( MK_RT mkrt, OT_ENV_T interp, MqFactoryC_type hdl )

inlinestatic

Definition at line 158 of file LibMqMsgque_tcl.h.

                                                                                             {
    return ( hdl ? MK(AtomObjNew) (MK_RT_CALL interp, MqFactoryC_X2obj(hdl)) : MQ(MqFactoryC_MK_NULL) );
  }

tclmqmsgque_MqFactoryC_Setup()

int tclmqmsgque_MqFactoryC_Setup	(	MK_RT	mkrt,
		OT_ENV_T	interp )

Public API

Definition at line 839 of file MqFactoryC_tcl.c.

{
  if (!strcmp(MqFactoryDefaultIdent(), "libmqmsgque")) {
    if  ( MqFactoryDefault(
            MqFactoryInitial(
              MqFactoryAdd (MK_ERROR_FORMAT,
                NS(sFactoryCTor), NULL, NULL, NULL, NULL, NULL, NULL, NULL, "tclmqmsgque"
              )
            )
          ) == NULL
        )
    { 
      Tcl_SetResult(interp,"MqFactoryS exception",TCL_STATIC);
      return TCL_ERROR;
    }
  }
  return TCL_OK;
}

tclmqmsgque_pMqContextC_Init()

int tclmqmsgque_pMqContextC_Init	(	MK_RT	mkrt,
		OT_ENV_T	interp,
		OT_NS_T	ns )

Definition at line 3966 of file MqContextC_tcl.c.

{
  MQ_STATIC_RT;
 
  if (MqContextCTT == NULL) {
 
    // register a new type
    MkRuntimeCallbackAdd( MK_RT_CALL &sTclMqRuntimeCallback, NS(sMqContextC_Type) , "TclMqContextC" );
 
    // tcl does !not! support fork for a threaded interpreter
    if (Tcl_GetVar2Ex(interp,"tcl_platform","threaded",TCL_GLOBAL_ONLY) != NULL) {
      MqContextCT->ignoreFork = true;
    }
  }
 
  ClassInit
 
  return TCL_OK;
error:
  return TCL_ERROR;
}

tclmqmsgque_pMqDumpC_Init()

int tclmqmsgque_pMqDumpC_Init	(	MK_RT	mkrt,
		OT_ENV_T	interp,
		OT_NS_T	ns )

Public API

Definition at line 463 of file MqDumpC_tcl.c.

{
  MQ_STATIC_RT;
  ClassInit
  
  return TCL_OK;
error:
  return TCL_ERROR;
}

tclmqmsgque_pMqFactoryC_Init()

int tclmqmsgque_pMqFactoryC_Init	(	MK_RT	mkrt,
		OT_ENV_T	interp,
		OT_NS_T	ns )

Definition at line 858 of file MqFactoryC_tcl.c.

{
  MQ_STATIC_RT;
  ClassInit
  
  return TCL_OK;
error:
  return TCL_ERROR;
}

tclmqmsgque_ServiceCall()

enum MkErrorE tclmqmsgque_ServiceCall

(

MQ_SERVICE_CALL_ARGS

)

Definition at line 72 of file MqCall_tcl.c.

{
  MQ_SERVICE_CALL_CHECK;
 
  // 1. setup environment
  SETUP_interp
  if (interp==NULL || Tcl_InterpDeleted(interp) ) return MK_OK;
 
  // 2. setup arguments
  struct MkCallS *call = __data__;
  OT_OBJ_T objv[5+MkProcResolve_maxArgsLen] = {0};
  int objc = 0;
 
//colorBLUE("call<%p>, type<%d>, nsO<%p>",call,call->type,call->nsO);
 
  // 3. setup my
rescan:
  switch (call->type) {
    case MkCallS_own_method: {
//printLTxt("MkCallS_own_method");
      // this is a instance->method
      SETUP_selfO
      SETUP_my
      objv[objc++] = tclctx->my;
      break;
    }
    case MkCallS_other_method:
    case MkCallS_static:
//printLTxt("MkCallS_other_method OR MkCallS_static");
      objv[objc++] = call->my;
      break;
    case MkCallS_proc:
//printLTxt("MkCallS_proc");
      break;
    case MkCallS_init: {
      check_META(MK(ProcResolve)(MK_RT_CALL interp, MkOBJ(mqctx), call)) goto error_mq;
      goto rescan;
    }
    case MkCallS_error:
//printLTxt("MkCallS_error");
      goto error;
    case MkCallS_null:
//printLTxt("MkCallS_null");
      return MK_OK;
  }
 
  // 4. setup methode
  if (call->mth)  objv[objc++] = call->mth;
 
  // 5. setup CTX arg
  switch (call->type) {
    case MkCallS_own_method:
      break;
    case MkCallS_other_method:
    case MkCallS_static:
    case MkCallS_proc:
      objv[objc++] = META2VAL_X(mqctx);
      break;
    case MkCallS_init:
      break;
    case MkCallS_error:
      goto error;
    case MkCallS_null:
      return MK_OK;
  }
 
  if (call->args) MK(ProcResolveAppendArgs)(call,&objc,objv);
 
//printAryL("__data__", objc, objv);
 
  // 3. call the callback
  //int ret = Tcl_EvalObjv (interp, objc, objv, TCL_EVAL_GLOBAL);
  int ret = MK(EvalObjv) (interp, objc, objv, TCL_EVAL_GLOBAL);
 
//printV("ret=%i, code=%s\n", ret, MkLogErrorE(MkErrorGetCode_0E()))
 
  if (ret == TCL_OK) {
    Tcl_ResetResult(interp);
    return MkErrorGetCode_0E();
  }
 
error:
//ME
  OT_ERROR_LNG_2_META(mqctx);
//MkErrorLog_0E();
 
error_mq:
  return MkErrorStack_0E();
}

tclmqmsgque_ServiceCopy()

void tclmqmsgque_ServiceCopy

(

MQ_SERVICE_COPY_ARGS

)

Definition at line 170 of file MqCall_tcl.c.

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

tclmqmsgque_ServiceFree()

void tclmqmsgque_ServiceFree

(

MQ_SERVICE_FREE_ARGS

)

Definition at line 162 of file MqCall_tcl.c.

{
  SETUP_interp;
  if ( interp == NULL || Tcl_InterpDeleted(interp)) return;
 
  MK(CallFree) (dataP);
}

Variable Documentation

tclmqmsgque_MqContextC

MQ_TCL_EXTERN_DATA __thread OT_CLS_T tclmqmsgque_MqContextC

Definition at line 112 of file LibMqMsgque_tcl.h.

tclmqmsgque_MqContextC_MK_NULL

MQ_TCL_EXTERN_DATA __thread OT_OBJ_T tclmqmsgque_MqContextC_MK_NULL

Definition at line 113 of file LibMqMsgque_tcl.h.

tclmqmsgque_MqDumpC

MQ_TCL_EXTERN_DATA __thread OT_CLS_T tclmqmsgque_MqDumpC

Definition at line 130 of file LibMqMsgque_tcl.h.

tclmqmsgque_MqDumpC_MK_NULL

MQ_TCL_EXTERN_DATA __thread OT_OBJ_T tclmqmsgque_MqDumpC_MK_NULL

Definition at line 131 of file LibMqMsgque_tcl.h.

tclmqmsgque_MqFactoryC

MQ_TCL_EXTERN_DATA __thread OT_CLS_T tclmqmsgque_MqFactoryC

Definition at line 148 of file LibMqMsgque_tcl.h.

tclmqmsgque_MqFactoryC_MK_NULL

MQ_TCL_EXTERN_DATA __thread OT_OBJ_T tclmqmsgque_MqFactoryC_MK_NULL

Definition at line 149 of file LibMqMsgque_tcl.h.