atsc_core_common_ring_queue.h

Go to the documentation of this file.

/*******************************************************************************
 * Copyright © 2014 The DTVKit Open Software Foundation Ltd (www.dtvkit.org)
 *
 * This file is part of a DTVKit Software Component
 * You are permitted to copy, modify or distribute this file subject to the terms
 * of the DTVKit 1.0 Licence which can be found in licence.txt or at www.dtvkit.org
 *
 * THIS CODE AND INFORMATION ARE PROVIDED "AS IS" WITHOUT WARRANTY OF ANY KIND,
 * EITHER EXPRESSED OR IMPLIED, INCLUDING BUT NOT LIMITED TO THE IMPLIED WARRANTIES
 * OF MERCHANTABILITY AND/OR FITNESS FOR A PARTICULAR PURPOSE.
 *
 * If you or your organisation is not a member of DTVKit then you have access
 * to this source code outside of the terms of the licence agreement
 * and you are expected to delete this and any associated files immediately.
 * Further information on DTVKit, membership and terms can be found at www.dtvkit.org
 *******************************************************************************/
 
#ifndef ATSC_CORE_COMMON_RING_QUEUE_H_
#define ATSC_CORE_COMMON_RING_QUEUE_H_
 
#pragma once
#include <stdlib.h>
#include <stdio.h>
#include <string.h>
#include <pthread.h>
#include <unistd.h> 
 
#include "atsc_basetype.h"
 
class CQueue
{
public:
CQueue(int32_t iSize , int32_t iWidth);
 
~CQueue(void);
 
int32_t GetFrameSize(int32_t iCount);
 
UINT_64 ReadRingQueue(uint8_t* pBuffer,uint32_t *pSize);
 
UINT_64 WriteItem2RingQueue(uint8_t * pBuffer1, uint32_t iSize1, uint8_t * pBuffer2, uint32_t iSize2);
 
UINT_64 WriteItem3RingQueue(uint8_t * pBuffer1, uint32_t iSize1, uint8_t * pBuffer2, uint32_t iSize2, uint8_t * pBuffer3, uint32_t iSize3);
 
UINT_64 WriteRingQueue(uint8_t* pBuffer,uint32_t iSize);
 
UINT_64 GetQueueLen( void );
 
void ResetQueue( void );
 
private:
    uint8_t *mpDataBuffer;                          
    uint32_t *mpDataCount;                          
    UINT_64 mRingBuffCount,mHeadCount,mTailCount;   
    UINT_64 mRingBuffSize;                          
    UINT_64 mWidth;                                 
    pthread_mutex_t mutexlock;                      
};
 
#endif /* ATSC_CORE_COMMON_RING_QUEUE_H_ */