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