1.1 --- a/BlockingQueue.h	Mon Sep 03 15:07:45 2012 -0700
     1.2 +++ b/BlockingQueue.h	Fri Mar 08 05:40:08 2013 -0800
     1.3 @@ -26,9 +26,9 @@
     1.4   { pthread_mutex_t  mutex_t;
     1.5     pthread_cond_t   cond_w_t;
     1.6     pthread_cond_t   cond_r_t;
     1.7 -   int              count;
     1.8 -   int              readPos;
     1.9 -   int              writePos;
    1.10 +   int32            count;
    1.11 +   int32            readPos;
    1.12 +   int32            writePos;
    1.13     void*            data[1024];  //an array of pointers
    1.14     int w_empty;
    1.15     int w_full;
    1.16 @@ -43,8 +43,8 @@
    1.17  //========== CAS based queue ==========
    1.18  typedef
    1.19  struct
    1.20 - { volatile int     insertLock;
    1.21 -   volatile int     extractLock;
    1.22 + { volatile int32   insertLock;
    1.23 +   volatile int32   extractLock;
    1.24     volatile void*  *insertPos;
    1.25     volatile void*  *extractPos;
    1.26     void*   startOfData[1024];  //data is pointers
    1.27 @@ -76,9 +76,9 @@
    1.28  //========= non-atomic instr S R M W queue ===========
    1.29  typedef
    1.30  struct
    1.31 - { int              lastQReadFrom;
    1.32 -   int              numInternalQs;
    1.33 -   int              internalQsSz;
    1.34 + { int32            lastQReadFrom;
    1.35 +   int32            numInternalQs;
    1.36 +   int32            internalQsSz;
    1.37     SRSWQueueStruc* *internalQs;
    1.38   }
    1.39  SRMWQueueStruc;