Fixed : crashing due to pile creation

[IRC.git] / Robust / src / Runtime / DSTM / interface / mcpileq.c

diff --git a/Robust/src/Runtime/DSTM/interface/mcpileq.c b/Robust/src/Runtime/DSTM/interface/mcpileq.c
index 38941ef5289dd3b9ea317bd5d3405844df4e098a..d6da34f318683f5487512b62bdc243b9d73fdd6a 100644 (file)
--- a/Robust/src/Runtime/DSTM/interface/mcpileq.c
+++ b/Robust/src/Runtime/DSTM/interface/mcpileq.c
@@ -5,23 +5,14 @@ mcpileq_t mcqueue;
 void mcpileqInit(void) {
        /* Initialize machine queue that containing prefetch oids and offset values  sorted by remote machineid */  
        mcqueue.front = mcqueue.rear = NULL;
-       pthread_mutex_init(&mcqueue.qlock, NULL); 
+       //Intiliaze and set machile pile queue's mutex attribute
+       pthread_mutexattr_init(&mcqueue.qlockattr);
+       pthread_mutexattr_settype(&mcqueue.qlockattr, PTHREAD_MUTEX_RECURSIVE_NP);
+       //pthread_mutex_init(&mcqueue.qlock, NULL); 
+       pthread_mutex_init(&mcqueue.qlock,&mcqueue.qlockattr); 
        pthread_cond_init(&mcqueue.qcond, NULL); 
 }
 
-/* Insert to the rear of machine pile queue */
-/*
-void mcpileenqueue(prefetchpile_t *node) {
-       if(mcqueue.front == NULL && mcqueue.rear == NULL) {
-               mcqueue.front = mcqueue.rear = node;
-       } else {
-               node->next = NULL;
-               mcqueue.rear->next = node;
-               mcqueue.rear = node;
-       }
-}
-*/
-
 /* Insert to the rear of machine pile queue */
 void mcpileenqueue(prefetchpile_t *node) {
        prefetchpile_t *tmp, *prev;