Search  

---

C:/temp/src/j2k/Deprecated/old_18mar_diff/nto/BoundedBuffer.cpp

Go to the documentation of this file.

#ifndef BoundedBuffer_CPP
#define BoundedBuffer_CPP

#include "BoundedBuffer.hpp"

BoundedBuffer::BoundedBuffer( size_t sz = BBSIZE ) 
   : front( 0 ), rear( 0 ), count( 0 )
  {
    size    = sz + 1;
    buffer  = new char[  size ];
    empty   = new BOOL[ size ];

    memset( buffer, 0, size );  // Clear buffers
    memset( empty,  0, size );
  }

  void BoundedBuffer::enqueue( char item )
  {
    register size_t r = ( rear + 1 ) % size;
    
    if ( r != front )
    {
      rear = r;

      if ( empty[ rear ] == FALSE )
      {
        ++count;
        buffer[ rear ] = item;

      } else {

        // Trying to overwrite
        fprintf( stderr, "\nCannot overwrite the data[%d].\n", rear );
        exit( 1 );
      }
    }
  }

  char BoundedBuffer::dequeue() {
    if ( front != rear ) {
       front = ( front+1 ) % size;
    }

    --count;
    register char value = buffer[ front ];
    
    // Delete the data
    buffer[ front ] = 0;
    empty[  front ] = FALSE;

    // Return the copied value
    return value;
  }

#endif

---