Mercurial > cgi-bin > hgwebdir.cgi > VMS > C_Libraries > Queue_impl
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 }
