Mercurial > cgi-bin > hgwebdir.cgi > VMS > C_Libraries > Queue_impl
diff BlockingQueue.c @ 44:67c7f5a0308b
Renamed VMS to PR, in new branch
| author | Sean Halle <seanhalle@yahoo.com> |
|---|---|
| date | Fri, 08 Mar 2013 05:40:08 -0800 |
| parents | d01d48b023ca |
| children | 1ea30ca7093c |
line diff
1.1 --- a/BlockingQueue.c Mon Sep 03 15:07:45 2012 -0700 1.2 +++ b/BlockingQueue.c Fri Mar 08 05:40:08 2013 -0800 1.3 @@ -1,5 +1,5 @@ 1.4 /* 1.5 - * Copyright 2009 OpenSourceStewardshipFoundation.org 1.6 + * Copyright 2009 OpenSourceResearchInstitute.org 1.7 * Licensed under GNU General Public License version 2 1.8 * 1.9 * Author: seanhalle@yahoo.com 1.10 @@ -50,11 +50,11 @@ 1.11 1.12 void* readCASQ( CASQueueStruc* Q ) 1.13 { void *out = 0; 1.14 - int tries = 0; 1.15 + int32 tries = 0; 1.16 void **startOfData = Q->startOfData; 1.17 void **endOfData = Q->endOfData; 1.18 1.19 - int gotLock = FALSE; 1.20 + int32 gotLock = FALSE; 1.21 1.22 while( TRUE ) 1.23 { //this intrinsic returns true if the lock held "UNLOCKED", in which 1.24 @@ -94,13 +94,13 @@ 1.25 1.26 void writeCASQ( void * in, CASQueueStruc* Q ) 1.27 { 1.28 - int tries = 0; 1.29 + int32 tries = 0; 1.30 //TODO: need to make Q volatile? Want to do this Q in assembly! 1.31 //Have no idea what GCC's going to do to this code 1.32 void **startOfData = Q->startOfData; 1.33 void **endOfData = Q->endOfData; 1.34 1.35 - int gotLock = FALSE; 1.36 + int32 gotLock = FALSE; 1.37 1.38 while( TRUE ) 1.39 { //this intrinsic returns true if the lock held "UNLOCKED", in which 1.40 @@ -178,7 +178,7 @@ 1.41 1.42 void* readSRSWQ( SRSWQueueStruc* Q ) 1.43 { void *out = 0; 1.44 - int tries = 0; 1.45 + int32 tries = 0; 1.46 1.47 while( TRUE ) 1.48 { 1.49 @@ -198,7 +198,7 @@ 1.50 1.51 void* readSRSWQ_NonBlocking( SRSWQueueStruc* Q ) 1.52 { void *out = 0; 1.53 - int tries = 0; 1.54 + int32 tries = 0; 1.55 1.56 while( TRUE ) 1.57 { 1.58 @@ -218,7 +218,7 @@ 1.59 1.60 void writeSRSWQ( void * in, SRSWQueueStruc* Q ) 1.61 { 1.62 - int tries = 0; 1.63 + int32 tries = 0; 1.64 1.65 while( TRUE ) 1.66 { 1.67 @@ -350,8 +350,8 @@ 1.68 void* readSRMWQ( SRMWQueueStruc* Q ) 1.69 { SRSWQueueStruc *readQ; 1.70 void *readValue = 0; 1.71 - int tries = 0; 1.72 - int QToReadFrom = 0; 1.73 + int32 tries = 0; 1.74 + int32 QToReadFrom = 0; 1.75 1.76 QToReadFrom = Q->lastQReadFrom; 1.77
