MqCall.cs

Go to the documentation of this file.

 
/* LABEL-NO */
 
/*****************************************************************************/
/*                                                                           */
/*                                   misc                                    */
/*                                                                           */
/*****************************************************************************/
 
using System;
using System.Runtime.InteropServices;
using csmkkernel;
//using Mk = csmkkernel.MkKernel;
 
namespace csmqmsgque {
 
  public interface MqServerSetupIF {
    void ServerSetup();
  }
 
  public interface MqServerCleanupIF {
    void ServerCleanup();
  }
 
  public interface MqBgErrorIF {
    void BgError();
  }
 
  public interface MqEventIF {
    void Event();
  }
 
  public interface MqServiceIF {
    void Service(MqContextC ctx);
  }
 
  public partial class MqContextC
  {
 
    public delegate void MqServiceICB();
 
    public delegate void MqServiceCCB(MqContextC ctx);
 
    // callback struc
    internal struct MqCall {
      public MqServiceICB   callICB;
      public MqServiceCCB   callCCB;
      public MqServiceIF    callIF;
 
      public MqCall(IntPtr rt, MqServiceICB val) {
        callICB = val;
        callCCB = null;
        callIF = null;
      }
 
      public MqCall(IntPtr rt, MqServiceIF val) {
        callICB = null;
        callCCB = null;
        callIF = val;
      }
 
      public MqCall(IntPtr rt, MqServiceCCB val) {
        callICB = null;
        callCCB = val;
        callIF = null;
      }
    }
 
    private static MkErrorE ServiceCall (IntPtr mkrt, IntPtr hdl, IntPtr data)
    {
//printBool(MqS.MqObjCheck(hdl),"check:hdl");
      if (data == IntPtr.Zero) return MkErrorE.OK;
      MqCall dataC = (MqCall)GCHandle.FromIntPtr(data).Target;
 
      // call the function
      try {
        if (dataC.callICB != null) {
          dataC.callICB();
        } else {
          MqContextC self = MqContextC_ObjNewOrNull(hdl);
          if (self == null) return MkErrorE.OK;
 
          if (dataC.callCCB != null) {
            dataC.callCCB(self);
          } else {
            dataC.callIF.Service(self);
          }
        }
      } catch (Exception ex) {
        MkErrorC.DEFAULT().ErrorCatch (ex);
      }
 
      // everything is OK
      return Mk.CsRuntimeErrorGetCode(mkrt);
/*
      var code = Mk.CsRuntimeErrorGetCode(mkrt);
      printVal(code,"code");
      return code;
*/
    }
 
    private static void ServiceFree (IntPtr mkrt, IntPtr hdl, ref IntPtr data) {
      GCHandle.FromIntPtr(data).Free();
      data = IntPtr.Zero;
    }
 
  } // END - class "MqContextC"
} // END - namespace "csmqmsgque"