uni_queue.h

浏览该文件的文档.

 
#ifndef _UNI_QUEUE_H
#define _UNI_QUEUE_H
 
#ifdef __cplusplus
    extern "C" {
#endif
 
#include "tuya_error_code.h"
#include "tuya_os_adapter.h"
 
 
#define QUEUE_SAFE_FUNC
 
typedef struct{
    unsigned int queUnitSize;   // queue unit size 
    unsigned int queTolNum;     // queue total unit number
    unsigned int queCurNum;     // queue current unit number
    
    unsigned char *queData;     // queue buffer
    unsigned char *queIn;       // in queue position
    unsigned char *queOut;      // out queue position
 
    #ifdef QUEUE_SAFE_FUNC
    MUTEX_HANDLE mutex;         // safity access prevent reentry
    #endif
}QUEUE_CLASS,*P_QUEUE_CLASS;
 
P_QUEUE_CLASS CreateQueueObj(const unsigned int queTolNum, const unsigned int queUnitSize);
 
unsigned char RegisterQueueObj(P_QUEUE_CLASS pQueObj, const unsigned char *pQueData, const unsigned int queTolNum, const unsigned int queUnitSize);
 
unsigned char InQueue(P_QUEUE_CLASS pQueObj, const unsigned char *pQueUnit, const unsigned int queNum);
 
unsigned char OutQueue(P_QUEUE_CLASS pQueObj,unsigned char *pQueUnit, const unsigned int queNum);
 
unsigned char GetQueueMember(P_QUEUE_CLASS pQueObj, const unsigned int start, unsigned char *pQueUnit, const unsigned int queNum);
 
unsigned char ClearQueue(P_QUEUE_CLASS pQueObj);
 
unsigned char DelQueueMember(P_QUEUE_CLASS pQueObj,const unsigned int queNum);
 
unsigned int GetCurFreeQueNum(P_QUEUE_CLASS pQueObj);
 
unsigned int GetCurQueNum(P_QUEUE_CLASS pQueObj);
 
void ReleaseQueueObj(P_QUEUE_CLASS pQueObj);
 
 
#ifdef __cplusplus
}
#endif
#endif