LibMqMsgque_cs.c

Go to the documentation of this file.

 
/* LABEL-START */
 
#define META_FILE_NAME "LibMqMsgque_cs.c"
 
/* LABEL-END */
 
#include "LibMqMsgque_cs.h"
 
bool MqRuntimeThreadPoolUse = true;
 
MK_PTR
MqCsContextTypeCreate_RT (
  MK_RT_ARGS
  MK_STRN         ident,
  MqCreateF       fChildCreate,
  MqDeleteF       fChildDelete,
  MqCreateF       fParentCreate,
  MqDeleteF       fParentDelete,
  MqExitF         MqProcessExitCB,
  MqExitF         MqThreadExitCB,
  MqWaitForPipeF  MqWaitForPipeCB
) {
  assert(ident != NULL);
  MqRtSetup_NULL_RT;
  MK_TYP MqContextCTT = MkTypeDup2(MqContextC_TT,ident);
  MqContextCT->argvFix = true;
  MqContextCT->ignoreFork = true;
  MqContextCT->ignoreDisasterSetup = true ;
  MqContextCT->Child.fCreate = fChildCreate;
  MqContextCT->Child.fDelete = fChildDelete;
  MqContextCT->Parent.fCreate = fParentCreate;
  MqContextCT->Parent.fDelete = fParentDelete;
  MqContextCT->MqProcessExitCB = MqProcessExitCB;
  MqContextCT->MqThreadExitCB = MqThreadExitCB;
  MqContextCT->MqWaitForPipeCB = MqWaitForPipeCB;
  return MqContextCTT;
}
 
void MqCsTypeUpdate_RT (
  MK_RT_ARGS
  MqCsTypeLookupE const typeL, 
  MkSelfCreateF const   selfCTOR, 
  MkSelfUnlinkF const   selfUnlink
) {
  MqRtSetup_NULL_RT;
  MK_TYP type = NULL;
  switch (typeL) {
    // BEGIN-CLS - created by 'cs_PreMeta.tcl -i NHI1_HOME/theLink/c/gen/c_mqmsgque.meta' - DO NOT change
 
    case MQ_CS_TYPE_LOOKUP_FCT   :  type = MqFactoryC_TT ; break;
    case MQ_CS_TYPE_LOOKUP_CTX   :  type = MqContextC_TT ; break;
    case MQ_CS_TYPE_LOOKUP_DMP   :  type = MqDumpC_TT    ; break;
 
    // END-CLS - created by 'cs_PreMeta.tcl -i NHI1_HOME/theLink/c/gen/c_mqmsgque.meta' - DO NOT change
    default:  MkPanicC_1("get invalid type enum '%d' not part of 'MqCsTypeLookupE'");
  }
  assert(type != NULL);
  type->selfCreate = selfCTOR;
  type->selfUnlink = selfUnlink;
}
 
void MqCsInit ( 
  MqSysServerThreadF  SysServerThread,
  MkSysExitF          SysExit
) {
  if (SysServerThread)  MqLal.MqSysServerThreadCB = SysServerThread;
  if (SysExit)          MkLal.MkSysExitCB         = SysExit;
}
 
// vim: tabstop=8