LibMqMsgque.cs

Go to the documentation of this file.

 
/* LABEL-NO */
using System;
using System.Reflection;
using System.Runtime.InteropServices;
using System.Threading;
using System.Threading.Tasks;
using System.Runtime.CompilerServices;
using csmkkernel;
using csmqmsgque;
using Mq = csmqmsgque.MqMsgque;
/* LABEL-END */
 
using System.Collections.Generic;
 
[assembly:AssemblyTitleAttribute("csmqmsgque")]
[assembly:AssemblyDescriptionAttribute("Programming-Language-Micro-Kernel for C#")]
[assembly:AssemblyConfigurationAttribute("")]
[assembly:AssemblyCompanyAttribute("IPN")]
[assembly:AssemblyProductAttribute("csmqmsgque")]
[assembly:AssemblyCopyrightAttribute("Copyright (c) Andreas Otto 2022")]
[assembly:AssemblyTrademarkAttribute("NHI1")]
[assembly:AssemblyCultureAttribute("")]
 
[assembly:AssemblyVersionAttribute("10.0.*")]
[assembly:ComVisible(false)]
[assembly:CLSCompliantAttribute(true)]
 
// MARK_D ################################################################
// -----------------------------------------------------------------------
// documentation order
 
 
 
 
 
 
 
 
 
/*
  // BEGIN-CLASS - created by 'cs_MqC.tcl -i NHI1_HOME/theLink/c/gen/c_mqmsgque.meta' - DO NOT change
 
  MqFactoryC.SetupThreadFCT(mkrt);
  MqContextC.SetupThreadCTX(mkrt);
  MqDumpC.SetupThreadDMP(mkrt);
 
  // END-CLASS - created by 'cs_MqC.tcl -i NHI1_HOME/theLink/c/gen/c_mqmsgque.meta' - DO NOT change
*/
 
// --------------------------------------------------------------------------------
 
namespace csmqmsgque {
 
  public static partial class MqMsgque {
    
 
//MkObjectC.DbgM($"Init -> {Environment.CurrentManagedThreadId}");
    static unsafe private void MqSetupTmpl() {
      Mq.MqSetup();
      Mq.MqCsInit(MqSysServerThreadCB,null);
      //Mq.MqCsInit(MqSysServerThreadCB,MkSysExitCB);
    }
    static private void MqCleanupTmpl() {
    }
 
  } // END-MqMsgque
 
 
  // BEGIN-MqMsgque - created by 'cs_MqC.tcl -i NHI1_HOME/theLink/c/gen/c_mqmsgque.meta' - DO NOT change
 
  public partial class MqMsgque {
 
 
    // doc-key: MqMsgque,MqMsgque-Enum,sco
 
    public static MqIdentE IdentE_FromInt (int value)  {
      MqIdentE value_out;
      MkErrorE errVal = Mq.MqIdentE_FromInt(value, out value_out);
      if (errVal > MkErrorE.CONTINUE) MkErrorC.Check(errVal);
      return value_out;
    }
 
    public static MqSlaveE SlaveE_FromInt (int value)  {
      MqSlaveE value_out;
      MkErrorE errVal = Mq.MqSlaveE_FromInt(value, out value_out);
      if (errVal > MkErrorE.CONTINUE) MkErrorC.Check(errVal);
      return value_out;
    }
 
    public static MqStartE StartE_FromInt (int value)  {
      MqStartE value_out;
      MkErrorE errVal = Mq.MqStartE_FromInt(value, out value_out);
      if (errVal > MkErrorE.CONTINUE) MkErrorC.Check(errVal);
      return value_out;
    }
 
    public static MqStatusIsEF StatusIsEF_FromInt (int value)  {
      MqStatusIsEF value_out;
      MkErrorE errVal = Mq.MqStatusIsEF_FromInt(value, out value_out);
      if (errVal > MkErrorE.CONTINUE) MkErrorC.Check(errVal);
      return value_out;
    }
 
    public static MqWaitOnEventE WaitOnEventE_FromInt (int value)  {
      MqWaitOnEventE value_out;
      MkErrorE errVal = Mq.MqWaitOnEventE_FromInt(value, out value_out);
      if (errVal > MkErrorE.CONTINUE) MkErrorC.Check(errVal);
      return value_out;
    }
 
    // doc-key: MqMsgque,MqMsgque-Enum,sm_
 
    public static int IdentE_ToInt (MqIdentE value)  {
      Int32 __retVal__L = Mq.MqIdentE_ToInt(value);
      return __retVal__L;
    }
 
    public static string IdentE_ToString (MqIdentE value)  {
      IntPtr __retVal__L = Mq.MqIdentE_ToString(value);
      return Marshal.PtrToStringAnsi(__retVal__L);
    }
 
    public static int SlaveE_ToInt (MqSlaveE value)  {
      Int32 __retVal__L = Mq.MqSlaveE_ToInt(value);
      return __retVal__L;
    }
 
    public static string SlaveE_ToString (MqSlaveE value)  {
      IntPtr __retVal__L = Mq.MqSlaveE_ToString(value);
      return Marshal.PtrToStringAnsi(__retVal__L);
    }
 
    public static int StartE_ToInt (MqStartE value)  {
      Int32 __retVal__L = Mq.MqStartE_ToInt(value);
      return __retVal__L;
    }
 
    public static string StartE_ToString (MqStartE value)  {
      IntPtr __retVal__L = Mq.MqStartE_ToString(value);
      return Marshal.PtrToStringAnsi(__retVal__L);
    }
 
    public static int StatusIsEF_ToInt (MqStatusIsEF value)  {
      Int32 __retVal__L = Mq.MqStatusIsEF_ToInt(value);
      return __retVal__L;
    }
 
    public static string StatusIsEF_ToString (MqStatusIsEF value)  {
      IntPtr __retVal__L = Mq.MqStatusIsEF_ToString(value);
      return Marshal.PtrToStringAnsi(__retVal__L);
    }
 
    public static int WaitOnEventE_ToInt (MqWaitOnEventE value)  {
      Int32 __retVal__L = Mq.MqWaitOnEventE_ToInt(value);
      return __retVal__L;
    }
 
    public static string WaitOnEventE_ToString (MqWaitOnEventE value)  {
      IntPtr __retVal__L = Mq.MqWaitOnEventE_ToString(value);
      return Marshal.PtrToStringAnsi(__retVal__L);
    }
 
    // MqMsgque_Enum_CS_API
  }
 
  public partial class MqMsgque {
 
 
    // doc-key: MqMsgque,MqMsgque-Help,sm_
 
    public static string Help (string tool)  {
      IntPtr tool_cstr = Marshal.StringToHGlobalAnsi(tool);
      IntPtr __retVal__L = Mq.MqHelp(tool_cstr);
      Marshal.FreeHGlobal(tool_cstr);
      return Marshal.PtrToStringAnsi(__retVal__L);
    }
 
    public static string HelpMsgque ()  {
      IntPtr __retVal__L = Mq.MqHelpMsgque();
      return Marshal.PtrToStringAnsi(__retVal__L);
    }
 
    // MqMsgque_Help_CS_API
  }
 
  public partial class MqMsgque {
 
 
    // doc-key: MqMsgque,MqMsgque-Init,sm_
 
    public static MkBufferListC InitGetArg0 ()  {
      IntPtr __retVal__L = Mq.MqInitGetArg0();
      return MkBufferListC.MkBufferListC_ObjNew(__retVal__L);
    }
 
    public static MkBufferListC InitResetArg0 ()  {
      IntPtr __retVal__L = Mq.MqInitResetArg0();
      return MkBufferListC.MkBufferListC_ObjNew(__retVal__L);
    }
 
    public static void InitSetArg0 (MkBufferListC bfl = null)  {
      IntPtr bfl_hdl = MkBufferListC.getOBJ_null_allow(bfl);
      Mq.MqInitSetArg0(bfl_hdl);
    }
 
    public static void InitSetArg0 (params string[] bfl)  {
      // OVERLOAD
      InitSetArg0 (new MkBufferListC(bfl));
    }
 
    // MqMsgque_Init_CS_API
  }
 
  public partial class MqMsgque {
 
 
    // doc-key: MqMsgque,MqMsgque-Setup,sm_
 
    public static void Cleanup ()  {
      MqCleanupTmpl();
    }
 
    public static void Setup ()  {
      MqSetupTmpl();
    }
 
    // MqMsgque_Setup_CS_API
  }
 
  // END-MqMsgque - created by 'cs_MqC.tcl -i NHI1_HOME/theLink/c/gen/c_mqmsgque.meta' - DO NOT change
 
// OVERLOAD
 
  public partial class MqMsgque {
//MkObjectC.DbgM("============================================================================");
//MkObjectC.DbgM($"Thread MAIN  -> mkrt=0x{mkrt}");
//MkObjectC.DbgM($"Thread START -> mkrt=0x{Mk.MkRuntimeGet()}, tId={System.Environment.CurrentManagedThreadId}");
//MkObjectC.DbgM($"Thread END   -> mkrt=0x{Mk.MkRuntimeGet()}, tId={System.Environment.CurrentManagedThreadId}");
//MkObjectC.DbgM($"Start Task -> idP={Convert.ToString((long)idP, 16)}, val={(*idP).val}");
//MkObjectC.DbgM($"Start Wait -> idP={Convert.ToString((long)idP, 16)}, val={(*idP).val}, type={(*idP).type}");
    private unsafe static MkErrorE MqSysServerThreadCB ( 
      IntPtr  mkrt, IntPtr  ctx, IntPtr  argP, String  name, int state, MkIdS *idP 
    ) {
      try {
        var thread = Task.Factory.StartNew( () => { 
          Mq.MqSysServerThreadMain(argP); 
        });
 
        (*idP).type = MkIdSE.THREAD;
        if ((*idP).ioIsPipe) {
          (*idP).val  = (IntPtr)GCHandle.Alloc(thread,GCHandleType.Weak);
          (*idP).setByExtern  = true;
        } else {
          (*idP).val  = (IntPtr) 0x1;
        }
      } catch (Exception ex) {
        return MkErrorC.DEFAULT().Catch(ex).GetCode();
      }
      return MkErrorE.OK;
    }
 
//MkObjectC.DbgM($"Start Exit -> isThread={isThread}, num={num}");
//MkObjectC.DbgM("End Exit");
 
/*
replaced by sThreadExit/sProcessExit and "true" return
 
    private static void MkSysExitCB ( int isThread, int num ) {
      if (isThread != 0) {
        // do nothing, end of MqSysServerThreadMain finish thread
      } else {
        Environment.Exit(num);
      }
      // FINISH
    }
*/
  }
 
} // END - namespace "csmqmsgque"