From 64731cef0b4efde4459b4e47c7803b535f7ed8cd Mon Sep 17 00:00:00 2001 From: yeom Date: Fri, 23 Jul 2010 03:56:04 +0000 Subject: [PATCH] forgot to bring previous fixes. --- Robust/src/Runtime/mlp_runtime.c | 9 +++++---- 1 file changed, 5 insertions(+), 4 deletions(-) diff --git a/Robust/src/Runtime/mlp_runtime.c b/Robust/src/Runtime/mlp_runtime.c index 0550297d..b0d2e2e1 100644 --- a/Robust/src/Runtime/mlp_runtime.c +++ b/Robust/src/Runtime/mlp_runtime.c @@ -69,7 +69,7 @@ REntry* mlpCreateREntry(int type, void* seseToIssue){ } int isParent(REntry *r) { - if (r->type==PARENTREAD || r->type==PARENTWRITE) { + if (r->type==PARENTREAD || r->type==PARENTWRITE || r->type==PARENTCOARSE) { return TRUE; } else { return FALSE; @@ -500,8 +500,8 @@ ADDVECTOR(MemoryQueue *Q, REntry *r) { void* flag=NULL; flag=(void*)LOCKXCHG((unsigned INTPTR*)&(V->array[index]), (unsigned INTPTR)flag); if (flag!=NULL) { - if (isParent(r)) { //parent's retire immediately - atomic_dec(&V->item.total); + if (isParentCoarse(r)) { //parent's retire immediately + atomic_dec(&V->item.total); } return READY; } else { @@ -723,8 +723,9 @@ RESOLVEHASHTABLE(MemoryQueue *Q, Hashtable *T) { } rptr->item.status=READY; { } - ptr=ptr->next; + } + ptr=ptr->next; }while(ptr!=NULL); } bin->head=val; // released lock; -- 2.34.1