---

yaml
---
r: 518
b: refs/heads/master
c: 6e9f0f9
h: refs/heads/master
v: v3

Author: mbebenita

[refs]

@@ -1,2 +1,2 @@
 ---
-refs/heads/master: 028702a798988a86da3f5700a9a4daea01dbe0b0
+refs/heads/master: 6e9f0f952d758bae2b530c2c9b780f2addf10207

trunk/src/rt/sync/lock_free_queue.cpp

@@ -18,17 +18,20 @@ lock_free_queue::lock_free_queue() : _tail(this) {
 
 void
 lock_free_queue::enqueue(lock_free_queue_node *item) {
+    lock.lock();
     item->next = (lock_free_queue_node *) NULL;
     lock_free_queue_node *last = _tail;
     _tail = item;
     while (last->next) {
         last = last->next;
     }
     last->next = item;
+    lock.unlock();
 }
 
 lock_free_queue_node *
 lock_free_queue::dequeue() {
+    lock.lock();
     lock_free_queue_node *item = next;
     if (item && !(next = item->next)) {
         _tail = (lock_free_queue_node *) this;
@@ -41,6 +44,7 @@ lock_free_queue::dequeue() {
             } while ((lost = help) != (lock_free_queue_node *) NULL);
         }
     }
+    lock.unlock();
     return item;
 }
 

trunk/src/rt/sync/lock_free_queue.h

@@ -1,13 +1,16 @@
 #ifndef LOCK_FREE_QUEUE_H
 #define LOCK_FREE_QUEUE_H
 
+#include "spin_lock.h"
+
 class lock_free_queue_node {
 public:
     lock_free_queue_node *next;
     lock_free_queue_node();
 };
 
 class lock_free_queue : lock_free_queue_node {
+    spin_lock lock;
     lock_free_queue_node *_tail;
 public:
     lock_free_queue();