moBuckets.h

Go to the documentation of this file.

/*******************************************************************************

                                moBuckets.h

  ****************************************************************************
  *                                                                          *
  *   This source is free software; you can redistribute it and/or modify    *
  *   it under the terms of the GNU General Public License as published by   *
  *   the Free Software Foundation; either version 2 of the License, or      *
  *  (at your option) any later version.                                    *
  *                                                                          *
  *   This code is distributed in the hope that it will be useful, but       *
  *   WITHOUT ANY WARRANTY; without even the implied warranty of             *
  *   MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the GNU      *
  *   General Public License for more details.                               *
  *                                                                          *
  *   A copy of the GNU General Public License is available on the World     *
  *   Wide Web at <http://www.gnu.org/copyleft/gpl.html>. You can also       *
  *   obtain it by writing to the Free Software Foundation,                  *
  *   Inc., 59 Temple Place - Suite 330, Boston, MA 02111-1307, USA.         *
  *                                                                          *
  ****************************************************************************

  Copyright(C) 2006 Fabricio Costa

  Authors:
  Fabricio Costa

  Class:
    moBuckets

  Description:
    Bucket's class, accumulation buffer


*******************************************************************************/

#ifndef __MO_BUCKETS_H
#define __MO_BUCKETS_H

#include "moTypes.h"
#include "moLock.h"

#define MAX_BUCKETS 2


class LIBMOLDEO_API moBucket {

    public:
        moBucket();
        virtual ~moBucket();


        bool Lock();


        bool Unlock();


        MOubyte *GetBuffer();//gets the bucket's buffer pointer


        MOlong  GetSize();


        void SetBuffer( MOlong size , MOubyte *pbuf);


        void Copy( MOlong size , MOubyte *pbuf );//copy size bytes from the bucket's buffer to pbuf


        void AttachBucket( moBucket* pbucket );


        moBucket* GetAttachedBucket();//get the bucket's linked bucked


        void EmptyBucket();//free the bucket's buffer


        void BuildBucket( MOlong size , int setvalue );


    protected:
        MOlong  m_lBufferSize;

        bool m_bAlligned;
        bool m_bEmpty;

        moLock  m_Lock;
        MOubyte *m_pBuffer;
        moBucket*   m_pAttachedBucket;

        moBucket*   m_pAttachedBucketUp;
        moBucket*   m_pAttachedBucketDown;

};

//SPECIAL FOR NO LOOSING DATA.....



class LIBMOLDEO_API moBucketsPool {//Last In Last Out

    public:
        moBucketsPool();
        virtual ~moBucketsPool();

        bool        AddBucket( moBucket *pBucket );//add a created bucket to the pool
        bool        AddBucket( MOlong size , MOubyte *pbuf );//take an empty created bucket and fill it with pbuf
        moBucket*   GetEmptyBucket();//get an empty bucket to fill it
        moBucket*   RetreiveBucket();//retreive from the pool the filled bucket to go
        moBucket*   GetActualBucket();//gets from the pool the pointer to the filled bucket to go, but do not retreive it!!! so beware
        moBucket*   RetreivedBucket();//get the pointer to the retreived bucket
        bool        DestroyRetreivedBucket();//deletes the retreivedbucket...
        bool IsEmpty();
        bool IsFull();

    MOlong m_nBuckets;

    protected:
        moBucket*   m_pRetreivedBucket;


        MOlong m_lMaxBuckets;//60MB = 60 buckets
        moLock  m_PoolLock;//lock access to pool
        moBucket *m_pFirstBucketToGo;
        moBucket *m_pLastBucketToGo;

        moBucket *m_pFirstEmptyBucket;
        moBucket *m_pLastEmptyBucket;
        MOlong m_nEmptyBuckets;

};

/*
//SPECIAL FOR LIVE DATA.....
class LIBMOLDEO_API moBucketsStack {//Last In First Out

    public:
        moBucketsStack();
        ~moBucketsStack();

        void AddBucket( moBucket *pBucket );
        moBucket *RetreiveBucket();

    protected:
        moBucket *m_pFirstBucketToGo;
        moBucket *m_pLastBucketToGo;

};

//SPECIAL FOR SCRATCH VIDEOS OR STREAMING.....
class LIBMOLDEO_API moBucketsBuffer {//arbitrary access

    public:
        moBucketsBuffer();
        ~moBucketsBuffer();

        Cyclic();

        void AddBucket( moBucket *pBucket );
        moBucket *RetreiveBucket();

    protected:
        moBucket *m_pFirstBucketToGo;
        moBucket *m_pLastBucketToGo;

};
*/

#endif