Sq3Call.cs

Go to the documentation of this file.

 
/* LABEL-NO */
 
/*****************************************************************************/
/*                                                                           */
/*                                   misc                                    */
/*                                                                           */
/*****************************************************************************/
 
using System;
using System.Runtime.InteropServices;
using csmkkernel;
 
namespace cssq3lite {
 
  public interface Sq3LiteExecIF {
    void Sq3LiteExec( string[] vals, string[] cols );
  }
 
  public interface Sq3LiteExecV2IF {
    void Sq3LiteExecV2( MkBufferListC vals, MkBufferListC cols );
  }
 
  public partial class Sq3LiteC
  {
 
    public delegate void Sq3LiteExecCCB   ( string[] vals, string[] cols );
    public delegate void Sq3LiteExecV2CCB ( MkBufferListC vals, MkBufferListC cols );
 
    internal struct Sq3Call {
      public IntPtr           mkrt  ;
      public Sq3LiteExecCCB   call1 ;
      public Sq3LiteExecV2CCB call2 ;
      public Sq3LiteExecIF    if1   ;
      public Sq3LiteExecV2IF  if2   ;
 
      public Sq3Call(IntPtr rt, Sq3LiteExecCCB val) {
        mkrt  = rt;
        call1 = val;
        call2 = null;
        if1   = null;
        if2   = null;
      }
 
      public Sq3Call(IntPtr rt, Sq3LiteExecV2CCB val) {
        mkrt  = rt;
        call2 = val;
        call1 = null;
        if1   = null;
        if2   = null;
      }
 
      public Sq3Call(IntPtr rt, Sq3LiteExecIF val) {
        mkrt  = rt;
        if1   = val;
        call1 = null;
        call2 = null;
        if2   = null;
      }
 
      public Sq3Call(IntPtr rt, Sq3LiteExecV2IF val) {
        mkrt  = rt;
        if2   = val;
        call1 = null;
        call2 = null;
        if1   = null;
      }
    }
 
    private static Int32 Sq3LiteExecCall (IntPtr callV1, Int32 num, IntPtr vals, IntPtr cols)
    {
      Sq3Call data = (Sq3Call)GCHandle.FromIntPtr(callV1).Target;
 
//printBool(MqS.MqObjCheck(hdl),"check:hdl");
 
      var valsO = new String[num];
      var colsO = new String[num];
 
      IntPtr[] valsP = new IntPtr[num];
      Marshal.Copy(vals,valsP,0,num);
      IntPtr[] colsP = new IntPtr[num];
      Marshal.Copy(cols,colsP,0,num);
 
      for (int i=0; i<num; i++) {
        valsO[i] = Marshal.PtrToStringAnsi(valsP[i]);
        colsO[i] = Marshal.PtrToStringAnsi(colsP[i]);
      }
 
      // call the function
      try {
        if (data.call1 != null) {
          data.call1(valsO,colsO);
        } else if (data.if1 != null) {
          data.if1.Sq3LiteExec(valsO,colsO);
        } else {
          return 0;
        }
      } catch (Exception ex) {
        IntPtr cstr = Marshal.StringToHGlobalAnsi("Sq3LiteExecCall");
        MkExceptionC.Catch(data.mkrt,IntPtr.Zero,ex,cstr);
        Marshal.FreeHGlobal(cstr);
        return 1;
      }
 
      // everything is OK
      return 0;
    }
 
    private static MkErrorE Sq3LiteExecV2Call(IntPtr mkrt, IntPtr callV2, IntPtr vals, IntPtr cols)
    {
      Sq3Call data = (Sq3Call)GCHandle.FromIntPtr(callV2).Target;
 
      var valsO = MkBufferListC.MkBufferListC_ObjNew(vals);
      var colsO = MkBufferListC.MkBufferListC_ObjNew(cols);
 
      // call the function
      try {
        if (data.call2 != null) {
          data.call2(valsO,colsO);
        } else if (data.if2 != null) {
          data.if2.Sq3LiteExecV2(valsO,colsO);
        } else {
          return MkErrorE.OK;
        }
      } catch (Exception ex) {
        IntPtr cstr = Marshal.StringToHGlobalAnsi("Sq3LiteExecV2Call");
        MkExceptionC.Catch(data.mkrt,IntPtr.Zero,ex,cstr);
        Marshal.FreeHGlobal(cstr);
        return MkErrorE.ERROR;
      }
 
      // everything is OK
      return Mk.CsRuntimeErrorGetCode(mkrt);
    }
 
  } // END - class "Sq3LiteC"
} // END - namespace "cssq3lite"