diff BlockingQueue.c @ 27:bd38feb38c80

Added numInPrivQ
author Some Random Person <seanhalle@yahoo.com>
date Sun, 04 Mar 2012 14:25:24 -0800
parents 59781a4c9cf1
children 7d35d7f42cd5
line diff
     1.1 --- a/BlockingQueue.c	Mon Feb 13 10:36:44 2012 -0800
     1.2 +++ b/BlockingQueue.c	Sun Mar 04 14:25:24 2012 -0800
     1.3 @@ -34,7 +34,7 @@
     1.4  CASQueueStruc* makeCASQ()
     1.5   {
     1.6     CASQueueStruc* retQ;
     1.7 -   retQ = (CASQueueStruc *) VMS_int__malloc( sizeof( CASQueueStruc ) );
     1.8 +   retQ = (CASQueueStruc *) VMS_WL__malloc( sizeof( CASQueueStruc ) );
     1.9  
    1.10     retQ->insertLock = UNLOCKED;
    1.11     retQ->extractLock= UNLOCKED;
    1.12 @@ -159,7 +159,7 @@
    1.13  SRSWQueueStruc* makeSRSWQ()
    1.14   {
    1.15     SRSWQueueStruc* retQ;
    1.16 -   retQ = (SRSWQueueStruc *) VMS_int__malloc( sizeof( SRSWQueueStruc ) );
    1.17 +   retQ = (SRSWQueueStruc *) VMS_WL__malloc( sizeof( SRSWQueueStruc ) );
    1.18     memset( retQ->startOfData, 0, 1024 * sizeof(void *) );
    1.19     
    1.20     retQ->extractPos = &(retQ->startOfData[0]); //side by side == empty
    1.21 @@ -298,11 +298,11 @@
    1.22  SRMWQueueStruc* makeSRMWQ()
    1.23   { SRMWQueueStruc* retQ;
    1.24     
    1.25 -   retQ = (SRMWQueueStruc *) VMS_int__malloc( sizeof( SRMWQueueStruc ) );
    1.26 +   retQ = (SRMWQueueStruc *) VMS_WL__malloc( sizeof( SRMWQueueStruc ) );
    1.27     
    1.28     retQ->numInternalQs = 0;
    1.29     retQ->internalQsSz  = 10;
    1.30 -   retQ->internalQs = VMS_int__malloc( retQ->internalQsSz * sizeof(SRSWQueueStruc *));
    1.31 +   retQ->internalQs = VMS_WL__malloc( retQ->internalQsSz * sizeof(SRSWQueueStruc *));
    1.32     
    1.33     retQ->lastQReadFrom = 0;
    1.34     
    1.35 @@ -328,7 +328,7 @@
    1.36        oldSz            = Q->internalQsSz;
    1.37        oldArray         = Q->internalQs;
    1.38        Q->internalQsSz *= 2;
    1.39 -      Q->internalQs    = VMS_int__malloc( Q->internalQsSz * sizeof(SRSWQueueStruc *));
    1.40 +      Q->internalQs    = VMS_WL__malloc( Q->internalQsSz * sizeof(SRSWQueueStruc *));
    1.41        for( i = 0; i < oldSz; i++ )
    1.42         { Q->internalQs[i] = oldArray[i];
    1.43         }