GmManagedRingBuffer.hpp

/*
 * GmRingBuffer.hpp
 *
 *  Created on: Jul 23, 2016
 *      Author: rcram
 */
 
#ifndef GMMANAGEDRINGBUFFER_HPP_
#define GMMANAGEDRINGBUFFER_HPP_
 
#ifdef acs
#include <ti/sysbios/knl/Semaphore.h>
#endif
 
#include "GmRingBuffer.hpp"
#ifdef linux
#include <pthread.h>
#endif
 
namespace Geometrics
{
 
   // This is just a buffer with some synchronization.
   class CManagedRingBuffer : public CRingBuffer
   {
   public:
      // Statically defined buffer...
      CManagedRingBuffer     (Semaphore_Handle  hasItemsSemaphore,
                              int               iMaxItems,
                              int               iItemSize,
                              Bool              bOkToOverrun,
                              Bool              bNotices,
                              UInt8            *puiBuffer,
                              UInt32            uiBufferSize);
 
      // Buffer will be allocated on heap.
      CManagedRingBuffer     (Semaphore_Handle  hasItemsSemaphore,
                              int               iMaxItems,
                              int               iItemSize,
                              Bool              bOkToOverrun,
                              Bool              bNotices);
      ~CManagedRingBuffer    ();
      int  WriteRecord       (UInt8            *pcSource,
                              int               iSize);
      int ReadRecord         (UInt8            *pcDestination,
                              int               iSize);
 
   #ifdef linux
   private:
     pthread_mutex_t m_mutex;
   #endif
 
   private:
     Semaphore_Handle mHasItemsSemaphore;
   };
 
}
#endif /* GMRINGBUFFER_HPP_ */