asyncmemoryblock.h

Go to the documentation of this file.

 
#ifndef __ASYNC_MEMORY_BLOCK_HEADER
#define __ASYNC_MEMORY_BLOCK_HEADER
 
#include <mutex>
#include <condition_variable>
 
namespace A_UTILS_NS
{
 
class cAsyncMemoryBlock
{
    A_UTILS_D(cAsyncMemoryBlock)
 
    public:
        cAsyncMemoryBlock();
 
        virtual ~cAsyncMemoryBlock();
 
        tResult Alloc(tInt nSize);
 
        tResult Assign(void* pMem, tInt nSize);
 
        tResult Free();
 
        tResult ReadLock(void** ppMem, const tBool bWait=tTrue);
 
        tResult WriteLock(void** ppMem, const tBool bWait=tTrue);
 
        tResult Unlock(void);
 
        tResult Copy(cAsyncMemoryBlock& oSrc);
 
        tInt    Compare(cAsyncMemoryBlock& oSrc);
 
        tInt    GetSize();
 
        tResult WaitNewData(tInt nTimeout=-1);
 
    private:
        void*                       m_pMem;                 
        tBool                       m_bMemAssigned;         
        tInt                        m_nSize;                
 
        tInt                        m_nReaderCount;         
        tBool                       m_bWriteAccess;         
        tInt                        m_nWriterWaitCount;     
 
        std::recursive_mutex        m_oMutexChangeState;    
 
        std::mutex                  m_mutexLock;            
        std::mutex                  m_mutexNoReader;        
        std::mutex                  m_mutexNewData;         
        std::condition_variable     m_CondEventNoReader;    
        std::condition_variable     m_CondNewData;          
        std::condition_variable     m_CondMutexLock;        
};
 
} // namespace A_UTILS_NS
 
#endif // __ASYNC_MEMORY_BLOCK_HEADER