From 8072bda4c1c7c5c9dd3027c40e69bf1dc9aa9bc5 Mon Sep 17 00:00:00 2001
From: bdemsky <bdemsky>
Date: Wed, 6 Aug 2008 05:42:03 +0000
Subject: [PATCH] make sure the other thread doesn't just fall asleep

---
 Robust/src/Runtime/DSTM/interface/queue.c | 12 +++++++++---
 1 file changed, 9 insertions(+), 3 deletions(-)

diff --git a/Robust/src/Runtime/DSTM/interface/queue.c b/Robust/src/Runtime/DSTM/interface/queue.c
index 9ff96430..507cf658 100644
--- a/Robust/src/Runtime/DSTM/interface/queue.c
+++ b/Robust/src/Runtime/DSTM/interface/queue.c
@@ -25,17 +25,23 @@ void * getmemory(int size) {
   if (tmpoffset>QSIZE) {
     //Wait for tail to go past end
     tmpoffset=size+sizeof(int);
-    if (headoffset<tailoffset)
+    if (headoffset<tailoffset) {
+      pthread_cond_signal(&qcond);//wake the other thread up
       return NULL;
+    }
     //Wait for tail to go past new start
-    if (tailoffset<=tmpoffset)
+    if (tailoffset<=tmpoffset) {
+      pthread_cond_signal(&qcond);//wake the other thread up
       return NULL;
+    }
     *((int *)(memory+headoffset))=-1;//safe because we left space
     *((int*)memory)=size+sizeof(int);
     return memory+sizeof(int);
   } else {
-    if (headoffset<tailoffset&&tailoffset<=tmpoffset)
+    if (headoffset<tailoffset&&tailoffset<=tmpoffset) {
+      pthread_cond_signal(&qcond);//wake the other thread up
       return NULL;
+    }
     *((int*)(memory+headoffset))=size+sizeof(int);
     return memory+headoffset+sizeof(int);
   }
-- 
2.34.1