Inter-Process Communication (IPC) with Autodesk Map3d

Author: Jonio, Dennis

Prospective and Environment
Everything that follows was done on and with Windows XP SP2, Visual Studio 2005 Professional SP1, Oracle XE 10.2, Oracle ODP.NET 11g(2.111.6.20), Autodesk Map3d 2008 SP1, Autodesk ObjectARX 2008 and lots of reading and lots of research. Since I have not done it myself I cannot attest as to the viability of this solution in a vanilla AutoCAD 200x environment. I am however inclined to believe that it will work just fine. I make neither guarantees nor claims of fitness for any purpose. It is “as-is” so proceed at your own risk.

Overview
Simply stated, this was the problem, I wished to have a generic way in which to communicate with a DWG. All I wished to do was PUT an SDO_GEOMETRY and GET a selected entity back as an SDO_GEOMETRY. This seemed to me to be a not unreasonable request. Just think about this a second: AutoCAD as a COLUMN editor? I could build whatever user interface I wished, using whatever tools I wished. Include all the business logic needed and then just “plumb” this stand-alone application. I didn’t have to solve the world’s problems either. Points, lines and surfaces were all I was interested in. Well good luck! First off there was no .NET DWG to SDO_GEOMETRY translator that I could get my hands on. Second, this just is not how Autodesk has written their applications. Don’t misunderstand me here. This is not a flame against Autodesk. Their applications do what they were designed to do and do this very well. So this series is then about getting one of two major things accomplished: 1) A 2-dimensional, SDO_GEOMETRY translator that supported arcs and 2) A communications interface.

This is about the communications piece. In my mind this would be the most technically challenging and if I was going to fail it would be on this.

Of course the issue of multithreading arose numerous times but it always seemed, by its nature, to be somewhat limiting. Inter-process communication (IPC) was the answer but I found no ready made solution. I had to piece this together myself. I did a fair amount of investigating and found named pipes to be the most generic and robust approach to take.

This is not really a story about pipes but you must look at this article: “Inter-Process Communication in .NET Using Named Pipes” by Ivan Latunov.
link to article The author explains it all much better than I ever could and his implementation is the backbone of this implementation. By the way, I believe that Microsoft has now included Named Pipe support in the 3.5 .NET framework. Since MS pipes are a Client/Server architecture and I was totally intimidated by “overlapping” ,“bidirectional” and the other more complex implementations I decided to really simplify and incorporate, in each executable or dll, a pipe Server and a pipe Client. Thank you Ivan. The significant change that I incorporated was the use of Events on the Server side( the “owner” side if you will ). When you compare Ivan’s code to mine you will see some other minor changes. A simple piccy to illustrate the idea.

Since experience has taught me that the Autodesk API’s are not trivial especially when it comes to the MDI interface structure I really needed to isolate this application as much as possible. The solution was a simple data exchange mechanism, a data “bridge”, if you will. Let the bridge become the generic between the other executables! My NETLOADed module and the “bridge” will communicate with simple Events and Queue objects! The Autodesk API’s understands Forms, Forms are, by nature, multi-threaded! The bridge will then communicate to whatever is at the other end of the pipe. BINGO! We have it all!

Below is a clip where these ideas are put together. Very simple and straightforward but it should give you some "food for thought":

Full-size video clip is available for download at:

• http://tf-net.googlecode.com/files/ipc_acad_sdo.rar

The Communications Data Definition

OK… so now we have settled on the communications “plumbing”, a full blown IO channel no less, what is it that we wish to communicate?
Well in reading Ivan’s work and the work of some others I became aware that pipes can move megabytes of data in sub-second times. Thusly then, the amount was not the issue the format was. Whatever that format was it had to be serializable and it had to be generic. I had to accomplish two(2) things: 1) construct a request that I wished my NETLOADed module to perform 2) provide for data interchange. The solution here is a plain’ol .NET dataset. In fact, all I really had to do was encapsulate a dataset inside a field in a “control” dataset. I could then pass one(1) serializabe object that had both a request/task and corresponding data. In my mind at least, very clean, very straightforward, and very generic.

The following is the structure I decided upon for my environment:

+ expand sourceview plainprint?

1. public static DataSet MaterializeNPControlDataSet()  
2.     {  
3.     DataSet _ds = new DataSet("NPCONTROLDATASET");  
4.     _ds.RemotingFormat = SerializationFormat.Binary;  
5.     _ds.SchemaSerializationMode = SchemaSerializationMode.IncludeSchema;  
6.   
7.     _ds.Tables.Add("NPCONTROLTABLE");  
8.     DataColumn dc1 = new DataColumn("ID", typeof(Int32));  
9.     DataColumn dc2 = new DataColumn("TEXT", typeof(string));  
10.     DataColumn dc3 = new DataColumn("PAYLOADTEXT", typeof(string));  
11.     DataColumn dc4 = new DataColumn("PAYLOAD", typeof(object));  
12.     _ds.Tables[0].Columns.Add(dc1);  
13.     _ds.Tables[0].Columns.Add(dc2);  
14.     _ds.Tables[0].Columns.Add(dc3);  
15.     _ds.Tables[0].Columns.Add(dc4);  
16.     return _ds;  
17.     }  

public static DataSet MaterializeNPControlDataSet()
    {
    DataSet _ds = new DataSet("NPCONTROLDATASET");
    _ds.RemotingFormat = SerializationFormat.Binary;
    _ds.SchemaSerializationMode = SchemaSerializationMode.IncludeSchema;

    _ds.Tables.Add("NPCONTROLTABLE");
    DataColumn dc1 = new DataColumn("ID", typeof(Int32));
    DataColumn dc2 = new DataColumn("TEXT", typeof(string));
    DataColumn dc3 = new DataColumn("PAYLOADTEXT", typeof(string));
    DataColumn dc4 = new DataColumn("PAYLOAD", typeof(object));
    _ds.Tables[0].Columns.Add(dc1);
    _ds.Tables[0].Columns.Add(dc2);
    _ds.Tables[0].Columns.Add(dc3);
    _ds.Tables[0].Columns.Add(dc4);
    return _ds;
    }

To support the manipulation of this structure there is one(1) class. All of the serialization/de-seriaization and encapsulations are done with this class. Below are the “putter” and “getter” methods for the dataset that is encapsulated within the “PAYLOAD” field. In addition there are numerous other helper methods within the class.
”putter”

+ expand sourceview plainprint?

1. public static void SetNPControlTablePayLoad(ref DataSet _NPds, ref DataSet _payload)  
2.     {  
3.         byte[] ba = SerializeDataSet(ref _payload);  
4.         _NPds.Tables["NPCONTROLTABLE"].Rows[0]["PAYLOAD"] = (object)ba;  
5.     }  

public static void SetNPControlTablePayLoad(ref DataSet _NPds, ref DataSet _payload)
    {
        byte[] ba = SerializeDataSet(ref _payload);
        _NPds.Tables["NPCONTROLTABLE"].Rows[0]["PAYLOAD"] = (object)ba;
    }

“getter”

+ expand sourceview plainprint?

1. public static DataSet ExtractNPCTablePayLoad(ref DataSet _NPds)  
2.     {  
3.         DataSet ads = null;  
4.         object o = (object)_NPds.Tables["NPCONTROLTABLE"].Rows[0]["PAYLOAD"];  
5.         if (o != System.DBNull.Value)  
6.         {  
7.             ads = ExtractSerializedDataSet((byte[])o);  
8.             if (ads != null)  
9.                 return ads;  
10.             else  
11.                 return null;  
12.         }  
13.             else  
14.                 return null;  
15.     }  

public static DataSet ExtractNPCTablePayLoad(ref DataSet _NPds)
    {
        DataSet ads = null;
        object o = (object)_NPds.Tables["NPCONTROLTABLE"].Rows[0]["PAYLOAD"];
        if (o != System.DBNull.Value)
        {
            ads = ExtractSerializedDataSet((byte[])o);
            if (ads != null)
                return ads;
            else
                return null;
        }
            else
                return null;
    }

No, I did not implement any compression of the datasets, just the BinaryFormatter.

+ expand sourceview plainprint?

1. public static byte[] SerializeDataSet(ref DataSet _ds)  
2.  {  
3.      _ds.RemotingFormat = SerializationFormat.Binary;  
4.      _ds.SchemaSerializationMode = SchemaSerializationMode.IncludeSchema;  
5.      MemoryStream ms = new MemoryStream();  
6.      BinaryFormatter bf = new BinaryFormatter();  
7.      bf.Serialize(ms, _ds);  
8.      if (ms.Length > 0)  
9.          return ms.ToArray();  
10.      else  
11.          return null;  
12.  }  

       public static byte[] SerializeDataSet(ref DataSet _ds)
        {
            _ds.RemotingFormat = SerializationFormat.Binary;
            _ds.SchemaSerializationMode = SchemaSerializationMode.IncludeSchema;
            MemoryStream ms = new MemoryStream();
            BinaryFormatter bf = new BinaryFormatter();
            bf.Serialize(ms, _ds);
            if (ms.Length > 0)
                return ms.ToArray();
            else
                return null;
        }

The Named Pipes
Ivan’s implementation is a work of art. I really hated to touch it. (Not only because it was well put together but I really did not fully comprehend his threading architecture). However, I really needed event hooks because this wasn’t going to be a “classic” Client/Server application. The applications that were going to be incorporating this were going to be operating in and supporting the user interface world. Since Ivan had architected this with interfaces I went about some touch up. (four lines of code with some big ideas ...)
Source code (C#):

+ expand sourceview plainprint?

1. using System;  
2. namespace AppModule.InterProcessComm {  
3.     // Delegates for events that your component will use to communicate  
4.     // values to the form  
5.      public delegate void ReceiveCompleteHandler(byte[] ba);  
6.      public delegate void StatusActivityHandler(string info);  
7.   
8. public interface IChannelManager {  
9.         // events that this (class)component will use to communicate with the app  
10.         event ReceiveCompleteHandler OnReceiveComplete;  
11.         event StatusActivityHandler OnStatusActivity;  
12.   
13.   void Initialize();  
14.   void Stop();  
15.   string HandleRequest(string request);  
16.   bool Listen {get; set;}  
17.   void WakeUp();  
18.         void RemoveServerChannel(object param);  
19.     }  
20. }  

using System;
namespace AppModule.InterProcessComm {
    // Delegates for events that your component will use to communicate
    // values to the form
     public delegate void ReceiveCompleteHandler(byte[] ba);
     public delegate void StatusActivityHandler(string info);

public interface IChannelManager {
        // events that this (class)component will use to communicate with the app
        event ReceiveCompleteHandler OnReceiveComplete;
        event StatusActivityHandler OnStatusActivity;

  void Initialize();
  void Stop();
  string HandleRequest(string request);
  bool Listen {get; set;}
  void WakeUp();
        void RemoveServerChannel(object param);
    }
}

Since I had decided to have both a Client and a Server incorporated within each app I made it easier on myself and just constructed an “A” and “B” dispatcher (I wanted to get rid of this Client/Server label). One would be owned by the “bridge” the other would be owned by the “other” application.
They are really nothing more than containers for Ivan’s public static IChannelManager PipeManager; I just added a few constants to make life easier and to set the “ReadOn” pipe and the “SendOn” pipe. I really didn’t want any confusion later on.

PipeManager’s most significant modifications had to do with the Events hooks:
Source code (C#):

+ expand sourceview plainprint?

1. if (numChannels <= NumberPipes) // =>  
2. {  
3.  ServerNamedPipe pipe = new ServerNamedPipe(PipeName, OutBuffer, InBuffer, MAX_READ_BYTES, false);  
4.  // subscribe to the events raised when data has been gotten  
5.  pipe.GotNewByteArray += new OnNewByteArrayHandler(pipe_GotNewByteArray);  
6.  pipe.GotActivity += new OnActivityToReportHandler(pipe_GotActivity);  
7.  try  
8.  {  
9.   pipe.Connect();  
10.   pipe.LastAction = DateTime.Now;  
11.   System.Threading.Interlocked.Increment(ref numChannels);  
12.   pipe.Start();  
13.   Pipes.Add(pipe.PipeConnection.NativeHandle, pipe);  
14.  }  
15.  catch (InterProcessIOException ex) {  
16.   RemoveServerChannel(pipe.PipeConnection.NativeHandle);  
17.   // unsubscribe to the events raised when data has been gotten  
18.   pipe.GotNewByteArray -= new OnNewByteArrayHandler(pipe_GotNewByteArray);  
19.   pipe.GotActivity -= new OnActivityToReportHandler(pipe_GotActivity);  
20.   pipe.Dispose();  
21.  }  
22. }  
23. else {  
24.  Mre.Reset();  
25.  Mre.WaitOne(1000, false);  
26. }  

if (numChannels <= NumberPipes) // =>
{
 ServerNamedPipe pipe = new ServerNamedPipe(PipeName, OutBuffer, InBuffer, MAX_READ_BYTES, false);
 // subscribe to the events raised when data has been gotten
 pipe.GotNewByteArray += new OnNewByteArrayHandler(pipe_GotNewByteArray);
 pipe.GotActivity += new OnActivityToReportHandler(pipe_GotActivity);
 try
 {
  pipe.Connect();
  pipe.LastAction = DateTime.Now;
  System.Threading.Interlocked.Increment(ref numChannels);
  pipe.Start();
  Pipes.Add(pipe.PipeConnection.NativeHandle, pipe);
 }
 catch (InterProcessIOException ex) {
  RemoveServerChannel(pipe.PipeConnection.NativeHandle);
  // unsubscribe to the events raised when data has been gotten
  pipe.GotNewByteArray -= new OnNewByteArrayHandler(pipe_GotNewByteArray);
  pipe.GotActivity -= new OnActivityToReportHandler(pipe_GotActivity);
  pipe.Dispose();
 }
}
else {
 Mre.Reset();
 Mre.WaitOne(1000, false);
}

Now, I just pass it on up the chain to “whatever” has hooked up.
Source code (C#):

+ expand sourceview plainprint?

1. void pipe_GotActivity(object sender, string activity)  
2. {  
3.  if (OnStatusActivity.Target is System.Windows.Forms.Control)  
4.     {  
5.        // make sure execution is done on the UI thread  
6.        System.Windows.Forms.Control t = OnStatusActivity.Target as System.Windows.Forms.Control;  
7.              t.BeginInvoke(OnStatusActivity, new Object[] { activity });  
8.     }  
9.     else  
10.         // object from the invocation list isn't a UI thread.  
11.         OnStatusActivity(activity);  
12.        }  
13. }  
14. void pipe_GotNewByteArray(object sender, byte[] ba)  
15. {  
16.  string rcvszdttm = string.Format("Received: {0} bytes at {1}", ba.Length.ToString(), DateTime.Now);  
17.     // tell whoever that a worker has just sent us a byte array  
18.     pipe_GotActivity(this, rcvszdttm);  
19.     //  
20.     // determine if the object on which this delegate was invoked is a UI thread  
21.     // if the object is a control, then the object is a UI thread  
22.     //  
23.     if (OnReceiveComplete.Target is System.Windows.Forms.Control)  
24.     {  
25.      // make sure execution is done on the UI thread  
26.         System.Windows.Forms.Control t = OnReceiveComplete.Target as System.Windows.Forms.Control;  
27.         t.BeginInvoke(OnReceiveComplete, new Object[] { ba });  
28.     }  
29.     else // object from the invocation list isn't a UI thread.  
30.         OnReceiveComplete(ba);          
31. }  

void pipe_GotActivity(object sender, string activity)
{
 if (OnStatusActivity.Target is System.Windows.Forms.Control)
    {
       // make sure execution is done on the UI thread
       System.Windows.Forms.Control t = OnStatusActivity.Target as System.Windows.Forms.Control;
             t.BeginInvoke(OnStatusActivity, new Object[] { activity });
    }
    else
        // object from the invocation list isn't a UI thread.
        OnStatusActivity(activity);
       }
}
void pipe_GotNewByteArray(object sender, byte[] ba)
{
 string rcvszdttm = string.Format("Received: {0} bytes at {1}", ba.Length.ToString(), DateTime.Now);
    // tell whoever that a worker has just sent us a byte array
    pipe_GotActivity(this, rcvszdttm);
    //
    // determine if the object on which this delegate was invoked is a UI thread
    // if the object is a control, then the object is a UI thread
    //
    if (OnReceiveComplete.Target is System.Windows.Forms.Control)
    {
     // make sure execution is done on the UI thread
        System.Windows.Forms.Control t = OnReceiveComplete.Target as System.Windows.Forms.Control;
        t.BeginInvoke(OnReceiveComplete, new Object[] { ba });
    }
    else // object from the invocation list isn't a UI thread.
        OnReceiveComplete(ba);        
}

Finally public sealed class ServerNamedPipe had to be tweaked. In this implementation I always send an acknowledgment string after a receipt. It is client/server after all. So it is a receive binary / send a string.
Source code (C#):

+ expand sourceview plainprint?

1. public event OnNewByteArrayHandler GotNewByteArray;  
2. public event OnActivityToReportHandler GotActivity;  
3.  private void PipeListener() {  
4.   CheckIfDisposed();  
5.   try {  
6.    Listen = DspchrHandlerA.PipeManager.Listen;  
7.    string myName = "Pipe_" + this.PipeConnection.NativeHandle.ToString();  
8.    GotActivity(new object(), myName + " :new pipe started");  
9.    while (Listen)  
10.    {  
11.     LastAction = DateTime.Now;  
12.     byte[] request = PipeConnection.ReadBytes();  
13.     LastAction = DateTime.Now;  
14.       
15.      // pipe manager gets the data  
16.      GotNewByteArray(this, request);  
17.      // this goes to the sender's listener to signal OK  
18.      PipeConnection.Write("ACKNOWLEDGEMENT " + request.Length.ToString() + " bytes");  
19.      //pipe manager get more info  
20.      GotActivity(new object(), myName + " acknowledgement sent for receipt of " + request.Length.ToString() + " bytes");  
21.   
22.     LastAction = DateTime.Now;  
23.     PipeConnection.Disconnect();  
24.     if (Listen) {  
25.      GotActivity(new object(), myName + " :listening");                          
26.      Connect();  
27.     }  
28.     //  
29.     DspchrHandlerA.PipeManager.WakeUp();  
30.    }  
31.   }   
32.   catch (System.Threading.ThreadAbortException ex) { }  
33.   catch (System.Threading.ThreadStateException ex) { }  
34.   catch (Exception ex) {   
35.    // Log exception  
36.   }  
37.   finally {  
38.    this.Close();  
39.   }  
40.  }  

public event OnNewByteArrayHandler GotNewByteArray;
public event OnActivityToReportHandler GotActivity;
 private void PipeListener() {
  CheckIfDisposed();
  try {
   Listen = DspchrHandlerA.PipeManager.Listen;
   string myName = "Pipe_" + this.PipeConnection.NativeHandle.ToString();
   GotActivity(new object(), myName + " :new pipe started");
   while (Listen)
   {
    LastAction = DateTime.Now;
    byte[] request = PipeConnection.ReadBytes();
    LastAction = DateTime.Now;
    
     // pipe manager gets the data
     GotNewByteArray(this, request);
     // this goes to the sender's listener to signal OK
     PipeConnection.Write("ACKNOWLEDGEMENT " + request.Length.ToString() + " bytes");
     //pipe manager get more info
     GotActivity(new object(), myName + " acknowledgement sent for receipt of " + request.Length.ToString() + " bytes");

    LastAction = DateTime.Now;
    PipeConnection.Disconnect();
    if (Listen) {
     GotActivity(new object(), myName + " :listening");                        
     Connect();
    }
    //
    DspchrHandlerA.PipeManager.WakeUp();
   }
  } 
  catch (System.Threading.ThreadAbortException ex) { }
  catch (System.Threading.ThreadStateException ex) { }
  catch (Exception ex) { 
   // Log exception
  }
  finally {
   this.Close();
  }
 }

Believe me named pipes and threads are NOT my specialty. I just had to know and do just enough to make it work for me. Yes, I am sure there are different and probably better ways. But I am a pragmatist and was not doing this for fun.

So we now have our pipes and we have an A and a B configuration. It matters not who is who but obviously partners cannot have the same configuration. As a final note these configurations are coded to operate on one workstation. You can of course run across different machines but that is a whole different topic.

The Data Bridge
This is the Form that will be instantiated from our NETLOADed module. As I mentioned before I wanted this to be as simple and generic as possible. Just a couple public Queue objects and a few events. I did add some UI Controls to play with during debug and never took them out.

How it works:

1. Receive an entry on “my” pipe
2. EnQueue the entry into the Suspense Queue
3. Fire off an OnReceivedQueueEntry event

OR

1. Receive an OnCompletedTask event
2. DeQueue the entry from the Process queue
3. Send it on to the other “Server’

If there is a simpler approach I could not think of it. Since a picture is worth so many words…



And the entire source sans the UI controls for the bridge:

+ expand sourceview plainprint?

1. using System;  
2. using System.Data;  
3. using System.Drawing;  
4. using System.ComponentModel;  
5. using System.Windows.Forms;  
6. using System.Collections;  
7.   
8. using DspchrHandlers;  
9. using Dspchr;  
10.   
11. namespace DataBridge  
12. {  
13.     public partial class DataBridge : Form  
14.     {  
15.         public delegate void ReceivedQueueEntryHandler(object sender);  
16.         public event ReceivedQueueEntryHandler OnReceivedQueueEntry;  
17.   
18.         public Queue SuspenseQ;  
19.         public Queue ProcessQ;  
20.   
21.         public SendVia SendViaX;  
22.         IDataBridge iDataBridgeClient;  
23.   
24.         public DataBridge(IDataBridge parent)  
25.         {  
26.             InitializeComponent();  
27.             iDataBridgeClient = parent;   
28.             DspchrHandlerA.StartServer();  
29.             SuspenseQ = new Queue();  
30.             ProcessQ = new Queue();  
31.             SendViaX = new SendVia();  
32.             DspchrHandlerA.PipeManager.OnReceiveComplete += new AppModule.InterProcessComm.ReceiveCompleteHandler(PipeManager_OnReceiveComplete);  
33.             DspchrHandlerA.PipeManager.OnStatusActivity += new AppModule.InterProcessComm.StatusActivityHandler(PipeManager_OnStatusActivity);  
34.             iDataBridgeClient.OnCompletedTask += new CompletedTaskHandler(iDataBridgeClient_OnCompletedTask);  
35.         }  
36.   
37.         void iDataBridgeClient_OnCompletedTask(object sender)  
38.         {  
39.             lblPQCnt.Text = ProcessQ.Count.ToString();  
40.             string rtn_result = null;  
41.             if (ProcessQ.Count > 0)  
42.             {  
43.                 rtn_result = SendViaX.WriteBytes(DspchrHandlerA.SendOnPipeName, DspchrHandlerA.ServerName, (byte[])ProcessQ.Dequeue());  
44.                 txtActivity.AppendText(rtn_result + Environment.NewLine);  
45.             }  
46.             lblPQCnt.Text = ProcessQ.Count.ToString();  
47.             lblSQCnt.Text = SuspenseQ.Count.ToString();  
48.         }         
49.         //  
50.         void PipeManager_OnStatusActivity(string info)  
51.         {  
52.             txtActivity.AppendText(info + Environment.NewLine);  
53.         }  
54.         void PipeManager_OnReceiveComplete(byte[] ba)  
55.         {  
56.             SuspenseQ.Enqueue(ba);  
57.             lblSQCnt.Text = SuspenseQ.Count.ToString();  
58.             Application.DoEvents();  
59.             OnReceivedQueueEntry(this);  
60.         }   
61.         private void DataBridge_FormClosing(object sender, FormClosingEventArgs e)  
62.         {  
63.             DspchrHandlerA.StopServer();  
64.         }  
65.         //  
66.         // Some form relate stuff to mess around with  
67.         //  
68.         private void btnRmvSQE_Click(object sender, EventArgs e)  
69.         {  
70.             if (SuspenseQ.Count > 0) SuspenseQ.Dequeue();  
71.             lblSQCnt.Text = SuspenseQ.Count.ToString();  
72.         }  
73.         private void btnRmvPQE_Click(object sender, EventArgs e)  
74.         {  
75.             if (ProcessQ.Count > 0) ProcessQ.Dequeue();  
76.             lblPQCnt.Text = ProcessQ.Count.ToString();  
77.         }  
78.         private void btnReturnSQE_Click(object sender, EventArgs e)  
79.         {  
80.             string rtn_result = null;  
81.             if (SuspenseQ.Count > 0)  
82.             {  
83.                 rtn_result = SendViaX.WriteBytes(DspchrHandlerA.SendOnPipeName, DspchrHandlerA.ServerName, (byte[])SuspenseQ.Dequeue());  
84.                 lblSQCnt.Text = SuspenseQ.Count.ToString();  
85.                 txtActivity.AppendText(rtn_result + Environment.NewLine);  
86.             }  
87.         }  
88.         private void btnCLEARLOG_Click(object sender, EventArgs e)  
89.         {  
90.             txtActivity.Clear();  
91.         }  
92.     }  
93. }  

using System;
using System.Data;
using System.Drawing;
using System.ComponentModel;
using System.Windows.Forms;
using System.Collections;

using DspchrHandlers;
using Dspchr;

namespace DataBridge
{
    public partial class DataBridge : Form
    {
        public delegate void ReceivedQueueEntryHandler(object sender);
        public event ReceivedQueueEntryHandler OnReceivedQueueEntry;

        public Queue SuspenseQ;
        public Queue ProcessQ;

        public SendVia SendViaX;
        IDataBridge iDataBridgeClient;

        public DataBridge(IDataBridge parent)
        {
            InitializeComponent();
            iDataBridgeClient = parent; 
            DspchrHandlerA.StartServer();
            SuspenseQ = new Queue();
            ProcessQ = new Queue();
            SendViaX = new SendVia();
            DspchrHandlerA.PipeManager.OnReceiveComplete += new AppModule.InterProcessComm.ReceiveCompleteHandler(PipeManager_OnReceiveComplete);
            DspchrHandlerA.PipeManager.OnStatusActivity += new AppModule.InterProcessComm.StatusActivityHandler(PipeManager_OnStatusActivity);
            iDataBridgeClient.OnCompletedTask += new CompletedTaskHandler(iDataBridgeClient_OnCompletedTask);
        }

        void iDataBridgeClient_OnCompletedTask(object sender)
        {
            lblPQCnt.Text = ProcessQ.Count.ToString();
            string rtn_result = null;
            if (ProcessQ.Count > 0)
            {
                rtn_result = SendViaX.WriteBytes(DspchrHandlerA.SendOnPipeName, DspchrHandlerA.ServerName, (byte[])ProcessQ.Dequeue());
                txtActivity.AppendText(rtn_result + Environment.NewLine);
            }
            lblPQCnt.Text = ProcessQ.Count.ToString();
            lblSQCnt.Text = SuspenseQ.Count.ToString();
        }       
        //
        void PipeManager_OnStatusActivity(string info)
        {
            txtActivity.AppendText(info + Environment.NewLine);
        }
        void PipeManager_OnReceiveComplete(byte[] ba)
        {
            SuspenseQ.Enqueue(ba);
            lblSQCnt.Text = SuspenseQ.Count.ToString();
            Application.DoEvents();
            OnReceivedQueueEntry(this);
        } 
        private void DataBridge_FormClosing(object sender, FormClosingEventArgs e)
        {
            DspchrHandlerA.StopServer();
        }
        //
        // Some form relate stuff to mess around with
        //
        private void btnRmvSQE_Click(object sender, EventArgs e)
        {
            if (SuspenseQ.Count > 0) SuspenseQ.Dequeue();
            lblSQCnt.Text = SuspenseQ.Count.ToString();
        }
        private void btnRmvPQE_Click(object sender, EventArgs e)
        {
            if (ProcessQ.Count > 0) ProcessQ.Dequeue();
            lblPQCnt.Text = ProcessQ.Count.ToString();
        }
        private void btnReturnSQE_Click(object sender, EventArgs e)
        {
            string rtn_result = null;
            if (SuspenseQ.Count > 0)
            {
                rtn_result = SendViaX.WriteBytes(DspchrHandlerA.SendOnPipeName, DspchrHandlerA.ServerName, (byte[])SuspenseQ.Dequeue());
                lblSQCnt.Text = SuspenseQ.Count.ToString();
                txtActivity.AppendText(rtn_result + Environment.NewLine);
            }
        }
        private void btnCLEARLOG_Click(object sender, EventArgs e)
        {
            txtActivity.Clear();
        }
    }
}

The last piece of the puzzle is this interface object for the DataBridge so it knows that there was something to be done.

+ expand sourceview plainprint?

1. using System;  
2. using System.Collections.Generic;  
3. using System.Text;  
4.   
5. public delegate void CompletedTaskHandler(object sender);  
6. public interface IDataBridge  
7. {  
8.     event CompletedTaskHandler OnCompletedTask;  
9. }  

using System;
using System.Collections.Generic;
using System.Text;

public delegate void CompletedTaskHandler(object sender);
public interface IDataBridge
{
    event CompletedTaskHandler OnCompletedTask;
}

And a skeleton of a NETLOADable dll:

+ expand sourceview plainprint?

1. namespace ADSKDATABRIDGE  
2. {  
3.     public class WRKR : IDataBridge  
4.     {  
5.         public event CompletedTaskHandler OnCompletedTask;  
6.         public DataBridge.DataBridge DataBridgeForm;  
7.   
8.         private static object TestForDuplication = null;  
9.         public WRKR() { }  
10.           
11.         [CommandMethod("DOPUTGET")]  
12.         public void dome()   
13.         {  
14.             if (TestForDuplication == null)  
15.             {  
16.                 DataBridgeForm = new DataBridge.DataBridge(this);  
17.                 TestForDuplication = DataBridgeForm;  
18.                 DataBridgeForm.FormClosing += new FormClosingEventHandler(DataBridgeForm_FormClosing);  
19.                 DataBridgeForm.OnReceivedQueueEntry += new DataBridge.DataBridge.ReceivedQueueEntryHandler(DataBridgeForm_OnReceivedQueueEntry);  
20.                 DataBridgeForm.Show();  
21.             }  
22.         }  
23.         void DataBridgeForm_FormClosing(object sender, FormClosingEventArgs e)  
24.         {  
25.             DataBridgeForm.OnReceivedQueueEntry -= new DataBridge.DataBridge.ReceivedQueueEntryHandler(DataBridgeForm_OnReceivedQueueEntry);  
26.             TestForDuplication = null;  
27.         }  

namespace ADSKDATABRIDGE
{
    public class WRKR : IDataBridge
    {
        public event CompletedTaskHandler OnCompletedTask;
        public DataBridge.DataBridge DataBridgeForm;

        private static object TestForDuplication = null;
        public WRKR() { }
        
        [CommandMethod("DOPUTGET")]
        public void dome() 
        {
            if (TestForDuplication == null)
            {
                DataBridgeForm = new DataBridge.DataBridge(this);
                TestForDuplication = DataBridgeForm;
                DataBridgeForm.FormClosing += new FormClosingEventHandler(DataBridgeForm_FormClosing);
                DataBridgeForm.OnReceivedQueueEntry += new DataBridge.DataBridge.ReceivedQueueEntryHandler(DataBridgeForm_OnReceivedQueueEntry);
                DataBridgeForm.Show();
            }
        }
        void DataBridgeForm_FormClosing(object sender, FormClosingEventArgs e)
        {
            DataBridgeForm.OnReceivedQueueEntry -= new DataBridge.DataBridge.ReceivedQueueEntryHandler(DataBridgeForm_OnReceivedQueueEntry);
            TestForDuplication = null;
        }

Finally … we receive our task and do it

+ expand sourceview plainprint?

1.         void DataBridgeForm_OnReceivedQueueEntry(object sender)  
2.         {  
3.             Document doc = Autodesk.AutoCAD.ApplicationServices.Application.DocumentManager.MdiActiveDocument;  
4.             Editor ed = doc.Editor;  
5.             bool GONOGO = true;  
6.             DataSet CntrlDS;  
7.             DataSet ToDoDS;  
8.             byte[] RtnVal = null;  
9.             if (this.DataBridgeForm.SuspenseQ.Count > 0)  
10.             {  
11.                 while (GONOGO && this.DataBridgeForm.SuspenseQ.Count > 0)  
12.                 {  
13.                     object o = DataBridgeForm.SuspenseQ.Dequeue();  
14.                     try  
15.                     {  
16.                         CntrlDS = NPC.ExtractSerializedDataSet((byte[])o);  
17.                         if (CntrlDS != null)  
18.                         {  
19.                             if (NPC.HasPayLoad(ref CntrlDS))  
20.                             {  
21.                                 ToDoDS = NPC.ExtractNPCTablePayLoad(ref CntrlDS);  
22.                                 if (ToDoDS != null)  
23.                                 {  
24.                                     RtnVal = ProcessRequest(ref CntrlDS, ref ToDoDS);  
25.                                 }  
26.                             }  
27.                         }  
28.                         if (RtnVal != null)  
29.                             DataBridgeForm.ProcessQ.Enqueue(RtnVal);  
30.                         OnCompletedTask(this);  
31.                         RtnVal = null;  
32.                     }  
33.                     catch (System.Exception _Ex)  
34.                     {  
35.                         ed.WriteMessage("ERROR: " + _Ex.Message + "\r\n");  
36.                     }  
37.                 } // end while GONOGO  
38.             }// if count in queue  
39.         }// OnReceivedQueueEntry  
40. }//eoc WRKR  
41. } // eons   

        void DataBridgeForm_OnReceivedQueueEntry(object sender)
        {
            Document doc = Autodesk.AutoCAD.ApplicationServices.Application.DocumentManager.MdiActiveDocument;
            Editor ed = doc.Editor;
            bool GONOGO = true;
            DataSet CntrlDS;
            DataSet ToDoDS;
            byte[] RtnVal = null;
            if (this.DataBridgeForm.SuspenseQ.Count > 0)
            {
                while (GONOGO && this.DataBridgeForm.SuspenseQ.Count > 0)
                {
                    object o = DataBridgeForm.SuspenseQ.Dequeue();
                    try
                    {
                        CntrlDS = NPC.ExtractSerializedDataSet((byte[])o);
                        if (CntrlDS != null)
                        {
                            if (NPC.HasPayLoad(ref CntrlDS))
                            {
                                ToDoDS = NPC.ExtractNPCTablePayLoad(ref CntrlDS);
                                if (ToDoDS != null)
                                {
                                    RtnVal = ProcessRequest(ref CntrlDS, ref ToDoDS);
                                }
                            }
                        }
                        if (RtnVal != null)
                            DataBridgeForm.ProcessQ.Enqueue(RtnVal);
                        OnCompletedTask(this);
                        RtnVal = null;
                    }
                    catch (System.Exception _Ex)
                    {
                        ed.WriteMessage("ERROR: " + _Ex.Message + "\r\n");
                    }
                } // end while GONOGO
            }// if count in queue
        }// OnReceivedQueueEntry
}//eoc WRKR
} // eons 

Harvesting Autodesk DWG Entities

Author: Jonio, Dennis

This kicks off a series of articles on building SDO_GEOMETRY types from DWG entities. By series end you should have at least one working NETLOADable module for a template. I do not pretend that this is THE solution. Since this was completed, I have, of course, realized better ways to do some things and I am sure you will be able to find more. I strongly recommend that you look over the Oracle OTN forums in particular .NET and Spatial. The heart and soul of these UDT’s came from there. Another indispensable forum is the Autodesk Discussion Groups. Their .NET forum is also indispensable.

Oracle SDO_GEOMETRY and a few others as User Defined Types (UDT’s)

Included below are a couple projects NetSdoGeometry and NetSdoDimArray. These are the fundamental classes and I have posted these in the past. However since that time I have added an AsText property and the ToString() method. It became necessary to actually visualize the objects during development. I must also point out that SDO_GEOMETRY is now marked as [Serializable]. You will see later on that this allows for the inclusion of this type into a native .NET serializable dataset. I have included a fair number of non-essential members and methods. They are for convenience so the purist may wish to strip them.

• http://tf-net.googlecode.com/files/NetSdoGeometry.zip
• http://tf-net.googlecode.com/files/NetSdoDimArray.zip

Triplets and Triplet Management

In order to make any sense of this article you will have to have a copy of Oracle’s SDO_GEOMETRY specification and my implementation of the class NetSdoGeometry.sdogeometry.

Let me clarify, in general terms, what this implementation does and does not do in regards the specification

1. Is Limited to two(2) dimensional geometries. Points, lines, surfaces(polygons)
2. Does not include “compound-type” geometries
3. Does include support for curves/arcs

After reviewing the spec you will realize it is all about “triplets”. The SDO_DIM_ELEM_ARRAY is of course a 1-> n series of 3 element integers groups. OFFSET - ETYPE -INTERPRETATION as the named components.

The manipulation of the ordinates array I found to be rather trivial both in terms of composition and decomposition. It is nothing more than that a left to right series of numbers.

“Triple Management” becomes the focus. Since I was learning the spec and writing code to it as I went along, the first class I created was, of course, “Triplet”. This class helped me visualize and understand the key elements of the specification. It is nothing more than codifying the obvious. The only oddity is my use of a GUID to track external or internal rings. The idea here will be explained later. In most cases a triplet acts as a kind’a sort’a header. A header that explains the ordinate array that is part of the SDO_GEOMETRY class. It would be just that simple if all one wished to do was work with linestrings. It is the support for curves/arcs that really adds a level of complexity by using a series of triplets to denote the transitions from line to arc, arc to line, etc.

Class “Pts” is a simple container for holding the ordinates. Of note here is the BulgeValue member. This acts as the placeholder for the arc information gotten from, in my case Map3d.

Finally class “TripletMgr” or Triplet Manager if you will. Before I discuss this class I will give you a chance to see how it is used. I do not use it for points and simple lines. Really unnecessary in those cases. This code decomposes as MPolygon into an sdogeometry. Frankly if you understand this one the rest is easy.

Here is the basic idea:

+ expand sourceview plainprint?

1. public static sdogeometry PolygonGeometryFromMPolygon(MPolygon mpoly)  
2. {  
3.     sdogeometry sdo = null;  
4.     Point2dCollection p2dColl = new Point2dCollection();  
5.     int hasBulgesCount;  
6.     int totalOrdinatesWritten = 0;                  // The total ordinates in the array  
7.     int totalSubElementCount = 0;                   // Just the total of sub-elements  
8.     int OWNERSHIP = 1;                              // Manage the OFFSET for a triplet   
9.     LoopDirection loopdirection;  
10.   
11.     TripletMgr MasterTripletMgr = new TripletMgr();  
12.     int loops = mpoly.NumMPolygonLoops;  
13.     for (int i = 0; i < loops; i++)  
14.     {  
15.         // Gather up points and bulges for this loop  
16.         MPolygonLoop mPolygonLoop = mpoly.GetMPolygonLoopAt(i);  
17.         loopdirection = mpoly.GetLoopDirection(i);  
18.         hasBulgesCount = 0;  
19.         // Remove duplicate verticies  
20.         for (int d = 1; d < mPolygonLoop.Count - 1; d++)  
21.         {  
22.             if (mPolygonLoop[d].Vertex.IsEqualTo(mPolygonLoop[d + 1].Vertex))  
23.             {  
24.                 mPolygonLoop.RemoveAt(d + 1);  
25.             }  
26.         }  
27.         //  
28.         Point2d[] pts = new Point2d[mPolygonLoop.Count];  
29.         double[] blgs = new double[mPolygonLoop.Count];  
30.         for (int z = 0; z < mPolygonLoop.Count; z++)  
31.         {  
32.             if (z == mPolygonLoop.Count - 1)  
33.             {  
34.                 pts[z] = pts[0];  
35.             }  
36.             else  
37.             {  
38.                 double X = Math.Round(mPolygonLoop[z].Vertex.X, 10, MidpointRounding.AwayFromZero);  
39.                 double Y = Math.Round(mPolygonLoop[z].Vertex.Y, 10, MidpointRounding.AwayFromZero);  
40.                 pts[z] = new Point2d(X, Y);  
41.             }  
42.             blgs[z] = mPolygonLoop[z].Bulge;  
43.             if (blgs[z] != 0.0)  
44.                 hasBulgesCount = hasBulgesCount + 1;  
45.         }  
46.         // dej 2008/12/17  
47.         // Some fixup for starting and/or ending with an arc in that the bulges get duplicated  
48.         // along with the vertices. This also seems to be a bigger issue with "Inner" vs "Outer"  
49.         // loops. Obviously if we have a series of arcs they won't have dup values anyway.  
50.         // We must not decrement hasBulgesCount!!!  
51.         if (blgs[0] == blgs[mPolygonLoop.Count - 1])  
52.             blgs[mPolygonLoop.Count - 1] = 0.0;  
53.   
54.         //  
55.         // Finished getting all the ordinates and bulges for this loop  
56.         //  
57.         // Just a dummy triplet to work with and begin the process of formulation  
58.         // Each loop needs its own header triplet.  
59.         // Establish the ETYPE and the OWNERSHIP(OFFSET) marker for this header  
60.         // and its INTERPRETATION  
61.         int headerOffset = (i == 0) ? 1 : OWNERSHIP;  
62.         Triplet dummy_headerTriplet = new Triplet(new int[] { headerOffset, 0, 0 });  
63.         if (hasBulgesCount == 0)  
64.             dummy_headerTriplet.INTERPRETATION = 1; // all "lines"  
65.         else if (hasBulgesCount == pts.Length)  
66.             dummy_headerTriplet.INTERPRETATION = 2; // all "arcs"  
67.         // if it is not a 1 or 2 we have to fill the INTERPRETATION value in later  
68.         // because it contains the number of subelements  
69.         if (loopdirection == LoopDirection.Exterior)  
70.         {  
71.             // It is an exterior  
72.             if (dummy_headerTriplet.INTERPRETATION == 1 || dummy_headerTriplet.INTERPRETATION == 2)  
73.             {  
74.                 dummy_headerTriplet.ETYPE = 1003;  
75.             }  
76.         }  
77.         else  
78.         {  
79.             // It is an interior  
80.             if (dummy_headerTriplet.INTERPRETATION == 1 || dummy_headerTriplet.INTERPRETATION == 2)  
81.             {  
82.                 dummy_headerTriplet.ETYPE = 2003;  
83.             }  
84.         }  
85.         // We have not set the etype yet so it must be a 1005 0R 2005 - compound polygon  
86.         // dej 2008/12/17 if (dummy_headerTriplet.ETYPE == 0)  
87.         if (dummy_headerTriplet.ETYPE == 0 || hasBulgesCount > 0)  
88.         {  
89.             if (loopdirection == LoopDirection.Exterior)  
90.                 dummy_headerTriplet.ETYPE = 1005;  
91.             else  
92.                 dummy_headerTriplet.ETYPE = 2005;  
93.         }  
94.         //  
95.         // Every time we make a transition from/to a curve/line we will make up a triplet  
96.         //  
97.         // We new-up a triplet mgr for these subelements within this loop  
98.         // We do know that the etype MUST be a 2 - line or arc  
99.         //  
100.         TripletMgr tmgr = new TripletMgr();  
101.         Triplet nxtTriplet = null;  
102.         int currentINTERPRETATION = 0;  
103.         int lastwrittenINTERPRETATION = 0;  
104.         Point2d somePointOnArc;  
105.         Point2d arc_endpoint;  
106.         for (int j = 0; j < mPolygonLoop.Count; j++)  
107.         {  
108.             double theBulge = blgs[j];  
109.             //Test the bulge  
110.             if (theBulge != 0.0)  
111.             {  
112.                 // Look ahead to get the endpoint for the arc  
113.                 if (j == (mPolygonLoop.Count - 1))  
114.                     arc_endpoint = pts[0];  
115.                 else  
116.                     arc_endpoint = pts[j + 1];  
117.   
118.                 CircularArc2d ca2d = new CircularArc2d(pts[j], arc_endpoint, theBulge, false);  
119.                 //  
120.                 // Get the center point on the arc ....  
121.                 // As an alternative:/ Point2d[] somePointSOnArc = ca2d.GetSamplePoints(3);  
122.                 // The somePointSOnArc[1] element will have the centerpoint on the arc  
123.                 //  
124.                 Interval interval_of_arc = ca2d.GetInterval();  
125.                 somePointOnArc = ca2d.EvaluatePoint(interval_of_arc.Element / 2);  
126.                 currentINTERPRETATION = 2;  
127.             }  
128.             else  
129.             {  
130.                 currentINTERPRETATION = 1;  
131.             }  
132.             // This only happens once per loop/ring because nxtTriplet is no longer null  
133.             // We use this to start off the tracking transitions from-to curves/lines  
134.             if (nxtTriplet == null)  
135.             {  
136.                 int elementOffset = (i == 0) ? 1 : OWNERSHIP;  
137.                 nxtTriplet = new Triplet(new int[] { elementOffset, 2, currentINTERPRETATION });  
138.                 lastwrittenINTERPRETATION = currentINTERPRETATION;  
139.             }  
140.             // Now collect the points and if we have a bulge add the midpoint only   
141.             // and not the endpoint that will be next  
142.             p2dColl.Add(pts[j]);  
143.             totalOrdinatesWritten = totalOrdinatesWritten + 2;  
144.             OWNERSHIP = OWNERSHIP + 2;  
145.             if (theBulge != 0.0)  
146.             {  
147.                 p2dColl.Add(new Point2d(somePointOnArc.ToArray()));  
148.                 totalOrdinatesWritten = totalOrdinatesWritten + 2;  
149.                 OWNERSHIP = OWNERSHIP + 2;  
150.                 // Oracle must be made happy.  
151.                 // OK this is really tricky ... the next item may or may not have a bulge  
152.                 // if the next item is at the end and it has a bulge this is a circle!  
153.                 // If it does not it is a line and we must loop back up so we make the proper  
154.                 // switch on interp and get the OWNERSHIP value correct. Otherwise  
155.                 // our OWNERSHIP value will be off by 2  
156.                 //   
157.                 if ((j + 1) == (mPolygonLoop.Count - 1))  
158.                 {  
159.                     if (blgs[j + 1] != 0.0)  
160.                     {  
161.                         p2dColl.Add(pts[j + 1]);  
162.                         totalOrdinatesWritten = totalOrdinatesWritten + 2;  
163.                         OWNERSHIP = OWNERSHIP + 2;  
164.                         j = j + 1;  
165.                     }  
166.                 }  
167.             }  
168.             //  
169.             // Now we construct an additional triplet in the event we have changed INTERPRETATION  
170.             //  
171.             if (currentINTERPRETATION != lastwrittenINTERPRETATION)  
172.             {  
173.                 tmgr.TripletList.Add(nxtTriplet);  
174.                 totalSubElementCount++;  
175.                 //   
176.                 // If I am transitioning to an arc/curve my ownership actually started  
177.                 // 4 ordinates ago or 2 ordinates ago in the case of a line  
178.                 //  
179.                 int elementOffset = (currentINTERPRETATION == 2) ? (OWNERSHIP - 4) : OWNERSHIP - 2;  
180.                 nxtTriplet = new Triplet(new int[] { elementOffset, 2, currentINTERPRETATION });  
181.                 lastwrittenINTERPRETATION = currentINTERPRETATION;  
182.             }  
183.         }   // end of for-loop on vertex count ... finished with one of the rings.  
184.         //  
185.         // Add this last triplet no matter what  
186.         //  
187.         tmgr.TripletList.Add(nxtTriplet);  
188.         totalSubElementCount++;  
189.         //  
190.         // If we are a 1005 or a 2005 we must fix-up the header triplet to reflect  
191.         // the total number of triplets(subelements) that are present. In this case it  
192.         // gets stuffed into the INTERP position.  
193.         // In the end the Master will hold the entire polygon  
194.         //  
195.         if (tmgr.TripletCount > 1)  
196.         {  
197.             dummy_headerTriplet.INTERPRETATION = totalSubElementCount;  
198.             MasterTripletMgr.TripletList.Add(dummy_headerTriplet);  
199.             for (int x = 0; x < tmgr.TripletCount; x++)  
200.             {  
201.                 MasterTripletMgr.TripletList.Add(tmgr.TripletList[x]);  
202.             }  
203.         }  
204.         //  
205.         // If we are a 1003 or a 2003  
206.         //  
207.         if (tmgr.TripletCount == 1)  
208.         {  
209.             MasterTripletMgr.TripletList.Add(dummy_headerTriplet);  
210.         }  
211.         // Set for next ring ...  
212.         totalSubElementCount = 0;  
213.     }// for each loop in the mpolygon  
214.     //  
215.     // We should have the geometry for the entire MPolygon described  
216.     // Construct the sdo_geometry object  
217.     //  
218.     sdo = new sdogeometry();  
219.     sdo.Dimensionality = (int)sdogeometryTypes.DIMENSION.DIM2D;  
220.     sdo.ElemArrayOfInts = MasterTripletMgr.ElementInfoToArray;  
221.     double[] rtnval = new double[p2dColl.Count * 2];  
222.     for (int w = 0, cnt = 0; w < p2dColl.Count; w++)  
223.     {  
224.         rtnval[cnt++] = p2dColl[w].X; rtnval[cnt++] = p2dColl[w].Y;  
225.     }  
226.     sdo.OrdinatesArrayOfDoubles = rtnval;  
227.     sdo.GeometryType = (int)sdogeometryTypes.GTYPE.POLYGON;  
228.     sdo.PropertiesToGTYPE();  
229.     return sdo;  
230. }  

  
        public static sdogeometry PolygonGeometryFromMPolygon(MPolygon mpoly)
        {
            sdogeometry sdo = null;
            Point2dCollection p2dColl = new Point2dCollection();
            int hasBulgesCount;
            int totalOrdinatesWritten = 0;                  // The total ordinates in the array
            int totalSubElementCount = 0;                   // Just the total of sub-elements
            int OWNERSHIP = 1;                              // Manage the OFFSET for a triplet 
            LoopDirection loopdirection;

            TripletMgr MasterTripletMgr = new TripletMgr();
            int loops = mpoly.NumMPolygonLoops;
            for (int i = 0; i < loops; i++)
            {
                // Gather up points and bulges for this loop
                MPolygonLoop mPolygonLoop = mpoly.GetMPolygonLoopAt(i);
                loopdirection = mpoly.GetLoopDirection(i);
                hasBulgesCount = 0;
                // Remove duplicate verticies
                for (int d = 1; d < mPolygonLoop.Count - 1; d++)
                {
                    if (mPolygonLoop[d].Vertex.IsEqualTo(mPolygonLoop[d + 1].Vertex))
                    {
                        mPolygonLoop.RemoveAt(d + 1);
                    }
                }
                //
                Point2d[] pts = new Point2d[mPolygonLoop.Count];
                double[] blgs = new double[mPolygonLoop.Count];
                for (int z = 0; z < mPolygonLoop.Count; z++)
                {
                    if (z == mPolygonLoop.Count - 1)
                    {
                        pts[z] = pts[0];
                    }
                    else
                    {
                        double X = Math.Round(mPolygonLoop[z].Vertex.X, 10, MidpointRounding.AwayFromZero);
                        double Y = Math.Round(mPolygonLoop[z].Vertex.Y, 10, MidpointRounding.AwayFromZero);
                        pts[z] = new Point2d(X, Y);
                    }
                    blgs[z] = mPolygonLoop[z].Bulge;
                    if (blgs[z] != 0.0)
                        hasBulgesCount = hasBulgesCount + 1;
                }
                // dej 2008/12/17
                // Some fixup for starting and/or ending with an arc in that the bulges get duplicated
                // along with the vertices. This also seems to be a bigger issue with "Inner" vs "Outer"
                // loops. Obviously if we have a series of arcs they won't have dup values anyway.
                // We must not decrement hasBulgesCount!!!
                if (blgs[0] == blgs[mPolygonLoop.Count - 1])
                    blgs[mPolygonLoop.Count - 1] = 0.0;

                //
                // Finished getting all the ordinates and bulges for this loop
                //
                // Just a dummy triplet to work with and begin the process of formulation
                // Each loop needs its own header triplet.
                // Establish the ETYPE and the OWNERSHIP(OFFSET) marker for this header
                // and its INTERPRETATION
                int headerOffset = (i == 0) ? 1 : OWNERSHIP;
                Triplet dummy_headerTriplet = new Triplet(new int[] { headerOffset, 0, 0 });
                if (hasBulgesCount == 0)
                    dummy_headerTriplet.INTERPRETATION = 1; // all "lines"
                else if (hasBulgesCount == pts.Length)
                    dummy_headerTriplet.INTERPRETATION = 2; // all "arcs"
                // if it is not a 1 or 2 we have to fill the INTERPRETATION value in later
                // because it contains the number of subelements
                if (loopdirection == LoopDirection.Exterior)
                {
                    // It is an exterior
                    if (dummy_headerTriplet.INTERPRETATION == 1 || dummy_headerTriplet.INTERPRETATION == 2)
                    {
                        dummy_headerTriplet.ETYPE = 1003;
                    }
                }
                else
                {
                    // It is an interior
                    if (dummy_headerTriplet.INTERPRETATION == 1 || dummy_headerTriplet.INTERPRETATION == 2)
                    {
                        dummy_headerTriplet.ETYPE = 2003;
                    }
                }
                // We have not set the etype yet so it must be a 1005 0R 2005 - compound polygon
                // dej 2008/12/17 if (dummy_headerTriplet.ETYPE == 0)
                if (dummy_headerTriplet.ETYPE == 0 || hasBulgesCount > 0)
                {
                    if (loopdirection == LoopDirection.Exterior)
                        dummy_headerTriplet.ETYPE = 1005;
                    else
                        dummy_headerTriplet.ETYPE = 2005;
                }
                //
                // Every time we make a transition from/to a curve/line we will make up a triplet
                //
                // We new-up a triplet mgr for these subelements within this loop
                // We do know that the etype MUST be a 2 - line or arc
                //
                TripletMgr tmgr = new TripletMgr();
                Triplet nxtTriplet = null;
                int currentINTERPRETATION = 0;
                int lastwrittenINTERPRETATION = 0;
                Point2d somePointOnArc;
                Point2d arc_endpoint;
                for (int j = 0; j < mPolygonLoop.Count; j++)
                {
                    double theBulge = blgs[j];
                    //Test the bulge
                    if (theBulge != 0.0)
                    {
                        // Look ahead to get the endpoint for the arc
                        if (j == (mPolygonLoop.Count - 1))
                            arc_endpoint = pts[0];
                        else
                            arc_endpoint = pts[j + 1];

                        CircularArc2d ca2d = new CircularArc2d(pts[j], arc_endpoint, theBulge, false);
                        //
                        // Get the center point on the arc ....
                        // As an alternative:/ Point2d[] somePointSOnArc = ca2d.GetSamplePoints(3);
                        // The somePointSOnArc[1] element will have the centerpoint on the arc
                        //
                        Interval interval_of_arc = ca2d.GetInterval();
                        somePointOnArc = ca2d.EvaluatePoint(interval_of_arc.Element / 2);
                        currentINTERPRETATION = 2;
                    }
                    else
                    {
                        currentINTERPRETATION = 1;
                    }
                    // This only happens once per loop/ring because nxtTriplet is no longer null
                    // We use this to start off the tracking transitions from-to curves/lines
                    if (nxtTriplet == null)
                    {
                        int elementOffset = (i == 0) ? 1 : OWNERSHIP;
                        nxtTriplet = new Triplet(new int[] { elementOffset, 2, currentINTERPRETATION });
                        lastwrittenINTERPRETATION = currentINTERPRETATION;
                    }
                    // Now collect the points and if we have a bulge add the midpoint only 
                    // and not the endpoint that will be next
                    p2dColl.Add(pts[j]);
                    totalOrdinatesWritten = totalOrdinatesWritten + 2;
                    OWNERSHIP = OWNERSHIP + 2;
                    if (theBulge != 0.0)
                    {
                        p2dColl.Add(new Point2d(somePointOnArc.ToArray()));
                        totalOrdinatesWritten = totalOrdinatesWritten + 2;
                        OWNERSHIP = OWNERSHIP + 2;
                        // Oracle must be made happy.
                        // OK this is really tricky ... the next item may or may not have a bulge
                        // if the next item is at the end and it has a bulge this is a circle!
                        // If it does not it is a line and we must loop back up so we make the proper
                        // switch on interp and get the OWNERSHIP value correct. Otherwise
                        // our OWNERSHIP value will be off by 2
                        // 
                        if ((j + 1) == (mPolygonLoop.Count - 1))
                        {
                            if (blgs[j + 1] != 0.0)
                            {
                                p2dColl.Add(pts[j + 1]);
                                totalOrdinatesWritten = totalOrdinatesWritten + 2;
                                OWNERSHIP = OWNERSHIP + 2;
                                j = j + 1;
                            }
                        }
                    }
                    //
                    // Now we construct an additional triplet in the event we have changed INTERPRETATION
                    //
                    if (currentINTERPRETATION != lastwrittenINTERPRETATION)
                    {
                        tmgr.TripletList.Add(nxtTriplet);
                        totalSubElementCount++;
                        // 
                        // If I am transitioning to an arc/curve my ownership actually started
                        // 4 ordinates ago or 2 ordinates ago in the case of a line
                        //
                        int elementOffset = (currentINTERPRETATION == 2) ? (OWNERSHIP - 4) : OWNERSHIP - 2;
                        nxtTriplet = new Triplet(new int[] { elementOffset, 2, currentINTERPRETATION });
                        lastwrittenINTERPRETATION = currentINTERPRETATION;
                    }
                }   // end of for-loop on vertex count ... finished with one of the rings.
                //
                // Add this last triplet no matter what
                //
                tmgr.TripletList.Add(nxtTriplet);
                totalSubElementCount++;
                //
                // If we are a 1005 or a 2005 we must fix-up the header triplet to reflect
                // the total number of triplets(subelements) that are present. In this case it
                // gets stuffed into the INTERP position.
                // In the end the Master will hold the entire polygon
                //
                if (tmgr.TripletCount > 1)
                {
                    dummy_headerTriplet.INTERPRETATION = totalSubElementCount;
                    MasterTripletMgr.TripletList.Add(dummy_headerTriplet);
                    for (int x = 0; x < tmgr.TripletCount; x++)
                    {
                        MasterTripletMgr.TripletList.Add(tmgr.TripletList[x]);
                    }
                }
                //
                // If we are a 1003 or a 2003
                //
                if (tmgr.TripletCount == 1)
                {
                    MasterTripletMgr.TripletList.Add(dummy_headerTriplet);
                }
                // Set for next ring ...
                totalSubElementCount = 0;
            }// for each loop in the mpolygon
            //
            // We should have the geometry for the entire MPolygon described
            // Construct the sdo_geometry object
            //
            sdo = new sdogeometry();
            sdo.Dimensionality = (int)sdogeometryTypes.DIMENSION.DIM2D;
            sdo.ElemArrayOfInts = MasterTripletMgr.ElementInfoToArray;
            double[] rtnval = new double[p2dColl.Count * 2];
            for (int w = 0, cnt = 0; w < p2dColl.Count; w++)
            {
                rtnval[cnt++] = p2dColl[w].X; rtnval[cnt++] = p2dColl[w].Y;
            }
            sdo.OrdinatesArrayOfDoubles = rtnval;
            sdo.GeometryType = (int)sdogeometryTypes.GTYPE.POLYGON;
            sdo.PropertiesToGTYPE();
            return sdo;
        }
 

The method SetPts is the workhorse. Once again it is the management of the triplets. The concept of “ownership” can from Pro Oracle Spatial for Oracle Database 11g, by Kothuri, Godfrind, Beinat. This really helped me put some of the pieces together. I recommend it highly.

Source code (C#) available for download at:

• http://tf-net.googlecode.com/files/Triplet_Pts_TripletMgr.zip