Diff: types/CommandQueue.h

Revision:

0:ea85c4bb5e1f

Child:

1:6ec9998427ad

--- /dev/null	Thu Jan 01 00:00:00 1970 +0000
+++ b/types/CommandQueue.h	Mon Aug 11 09:58:24 2014 +0000
@@ -0,0 +1,86 @@
+/*
+ * Copyright 2014, ACKme Networks
+ * All Rights Reserved.
+ *
+ * This is UNPUBLISHED PROPRIETARY SOURCE CODE of ACKme Networks;
+ * the contents of this file may not be disclosed to third parties, copied
+ * or duplicated in any form, in whole or in part, without the prior
+ * written permission of ACKme Networks.
+ */
+
+#pragma once
+
+
+#include "WiconnectTypes.h"
+
+
+namespace wiconnect
+{
+
+
+class CommandQueue
+{
+public:
+    /*************************************************************************************************/
+    CommandQueue()
+    {
+        head = tail = queue;
+        count = 0;
+    }
+
+    /*************************************************************************************************/
+    bool isFull()
+    {
+        return count == WICONNECT_MAX_QUEUED_COMMANDS;
+    }
+
+    /*************************************************************************************************/
+    bool isEmpty()
+    {
+        return count == 0;
+    }
+
+    /*************************************************************************************************/
+    bool push(QueuedCommand *cmd)
+    {
+        if(isFull())
+        {
+            return false;
+        }
+        ++count;
+        *tail = cmd;
+        if(++tail >= queue + WICONNECT_MAX_QUEUED_COMMANDS)
+        {
+            tail = queue;
+        }
+
+        return true;
+    }
+
+    /*************************************************************************************************/
+    QueuedCommand* pop()
+    {
+        if(isEmpty())
+            return NULL;
+
+        QueuedCommand* cmd = *head;
+        --count;
+        if(++head >= queue + WICONNECT_MAX_QUEUED_COMMANDS)
+        {
+            head = queue;
+        }
+        return cmd;
+    }
+
+protected:
+    QueuedCommand* queue[WICONNECT_MAX_QUEUED_COMMANDS];
+    QueuedCommand** head;
+    QueuedCommand** tail;
+    int count;
+};
+
+
+
+
+}
+