1 files changed, 160 insertions, 0 deletions
diff --git a/node_modules/webworker-threads/src/queues_a_gogo.cc b/node_modules/webworker-threads/src/queues_a_gogo.cc
new file mode 100644
index 0000000..d675bb1
--- /dev/null
+++ b/node_modules/webworker-threads/src/queues_a_gogo.cc
@@ -0,0 +1,160 @@
+//2011-11 Proyectos Equis Ka, s.l., jorge@jorgechamorro.com
+//queues_a_gogo.cc
+
+#include <string.h>
+#include <stdio.h>
+#include <uv.h>
+#include <stdlib.h>
+#if defined(__unix__) || defined(__POSIX__) || defined(__APPLE__) || defined(_AIX)
+#include <unistd.h>
+#endif
+
+enum types {
+  kItemTypeNONE,
+  kItemTypeNumber,
+  kItemTypePointer,
+  kItemTypeQUIT
+};
+
+struct typeQueueItem {
+  int itemType;
+  typeQueueItem* next;
+  union {
+    void* asPtr;
+    double asNumber;
+  };
+};
+typedef struct typeQueueItem typeQueueItem;
+
+typedef struct {
+  typeQueueItem* first;
+  typeQueueItem* last;
+  uv_mutex_t queueLock;
+  long int id;
+  volatile long int length;
+} typeQueue;
+
+static typeQueue* queuesPool= NULL;
+static typeQueue* freeItemsQueue= NULL;
+
+
+
+
+static void queue_push (typeQueueItem* qitem, typeQueue* queue) {
+  qitem->next= NULL;
+  
+  uv_mutex_lock(&queue->queueLock);
+  if (queue->last) {
+    queue->last->next= qitem;
+  }
+  else {
+    queue->first= qitem;
+  }
+  queue->last= qitem;
+  queue->length++;
+  uv_mutex_unlock(&queue->queueLock);
+}
+
+
+
+
+static typeQueueItem* queue_pull (typeQueue* queue) {
+  typeQueueItem* qitem;
+  
+  uv_mutex_lock(&queue->queueLock);
+  if ((qitem= queue->first)) {
+    if (queue->last == qitem) {
+      queue->first= queue->last= NULL;
+    }
+    else {
+      queue->first= qitem->next;
+    }
+    queue->length--;
+    qitem->next= NULL;
+  }
+  uv_mutex_unlock(&queue->queueLock);
+  
+  return qitem;
+}
+
+
+
+
+static typeQueueItem* nuItem (int itemType, void* item) {
+  
+  typeQueueItem* qitem= queue_pull(freeItemsQueue);
+  if (!qitem) {
+    qitem= (typeQueueItem*) calloc(1, sizeof(typeQueueItem));
+  }
+  
+  qitem->next= NULL;
+  qitem->itemType= itemType;
+  if (itemType == kItemTypeNumber) {
+    qitem->asNumber= *((double*) item);
+  }
+  else if (itemType == kItemTypePointer) {
+    qitem->asPtr= item;
+  }
+  
+  return qitem;
+}
+
+
+
+
+static void destroyItem (typeQueueItem* qitem) {
+  
+  if (freeItemsQueue) {
+    queue_push(qitem, freeItemsQueue);
+  }
+  else {
+    free(qitem);
+  }
+}
+
+
+
+
+static typeQueue* nuQueue (long int id) {
+  
+  typeQueue* queue= NULL;
+  typeQueueItem* qitem= NULL;
+  if (queuesPool && queuesPool->first) qitem= queue_pull(queuesPool);
+  if (qitem) {
+    queue= (typeQueue*) qitem->asPtr;
+    destroyItem(qitem);
+  }
+  else {
+    queue= (typeQueue*) calloc(1, sizeof(typeQueue));
+    uv_mutex_init(&queue->queueLock);
+  }
+  
+  queue->id= id;
+  queue->length= 0;
+  queue->first= queue->last= NULL;
+  return queue;
+}
+
+
+/*
+
+static void destroyQueue (typeQueue* queue) {
+  if (queuesPool) {
+    queue_push(nuItem(kItemTypePointer, queue), queuesPool);
+  }
+  else {
+    free(queue);
+  }
+}
+
+*/
+
+
+static void initQueues (void) {
+  freeItemsQueue= nuQueue(-2);  //MUST be created before queuesPool
+  //queuesPool= nuQueue(-1);
+}
+
+
+
+