1 files changed, 114 insertions, 0 deletions
diff --git a/led/complex1/MessageQueueT_BASE.h b/led/complex1/MessageQueueT_BASE.h
new file mode 100644
index 0000000..a9ac3f7
--- /dev/null
+++ b/led/complex1/MessageQueueT_BASE.h
@@ -0,0 +1,114 @@
+//
+//  MessageQueue Template Base
+//
+//  $Id$
+//
+
+#ifndef __MessageQueueT_OE3_h
+#define __MessageQueueT_OE3_h
+
+#include <iostream>
+#include <string>
+
+namespace OSWrapper {
+
+  template<
+    typename QueueType
+  >
+  class MessageQueueTemplate {
+    public:
+
+    typedef void (*Converter_t)( const QueueType *src, QueueType *dest );
+
+    private:
+
+    std::string                 mName;
+    Converter_t                 mHTON;
+    Converter_t                 mNTOH;
+    void                       *mQueue;
+
+    public:
+
+    MessageQueueTemplate::MessageQueueTemplate(
+      const char      *name,
+      unsigned int     depth,
+      Converter_t      hton_f,
+      Converter_t      ntoh_f
+    )
+    {
+      mName = name;
+      this->mHTON = hton_f;
+      this->mNTOH = ntoh_f;
+
+      // create the message queue
+      mQueue = NULL;
+    }
+
+    MessageQueueTemplate::~MessageQueueTemplate()
+    {
+      // destroy the message queue object
+      // delete mQueue;
+      // destroy anything else
+    }
+
+    bool MessageQueueTemplate::Read(
+      QueueType *buffer
+    )
+    {
+      int       status = 0;
+      QueueType tbuffer; 
+
+      // Get the message
+      try {
+        if ( mNTOH ) {
+          status = 1;  // read into tbuffer
+        } else {
+          status = 1;  // read into buffer
+        }
+ 
+        // read the message queue
+        if ( status ) {
+          std::cerr << mName << " Queue not Read: " << status << std::endl;
+          return false;
+        }
+      } catch (...) {
+        std::cerr << mName << " Queue not Read: Exception" << std::endl;
+        return false;
+      }
+
+      // convert from network neutral
+      if ( mNTOH )
+        (*mNTOH)( &tbuffer, buffer );
+
+      return true;
+    }
+
+    bool MessageQueueTemplate::Write(
+      QueueType *buffer
+    )
+    {
+      int status = 0;
+      QueueType tbuffer; 
+      QueueType *b = buffer; 
+
+      // convert to network neutral
+      if ( mHTON ) {
+        (*mHTON)( buffer, &tbuffer );
+        b = &tbuffer;
+      }
+        
+
+      // write the message
+      status = 1; // write( b );
+      if ( status ) {
+        std::cerr << mName << " Queue not Written: " << status << std::endl;
+        return false;
+      }
+      return true;
+    }
+  };
+
+};
+
+
+#endif