源码公开

<div class="blockcode"><blockquote>/*

**#############################################################################

**      SVN Information

**

**      Checked In          : 2017-12-27

**

**      Author              : Fan

**

**      Revision            : V1.1

**

**      Release Information : Loop queue (.c)

**#############################################################################

*/



#include "Loop_queue.h"



/*

**#############################################################################

** Loop queue initialzation

**#############################################################################

*/

void LoopQueueInit(LoopQueue *queue)

{

    unsigned int i = 0;

    queue->getIndex = 0;

    queue->putIndex = 0;

    queue->dataNumber = 0;

    for(i = 0; i<QUEUE_MAX_LENGTH; i++)

    {

        queue->queueFIFO[i] = 0;   // Clear all fifo

    }

}



/*

**#############################################################################

** Loop queue clear

**#############################################################################

*/

void LoopQueueClear(LoopQueue *queue)

{

    unsigned int clearIndex;



    queue->getIndex = 0;

    queue->putIndex = 0;

    for(clearIndex = 0; clearIndex < QUEUE_MAX_LENGTH ; clearIndex ++)

    {

        queue->queueFIFO[clearIndex] = 0;

    }

    queue->dataNumber = 0;

}



/*

**#############################################################################

** Loop queue write data by pointer 

**#############################################################################

*/

LoopQueueStateType LoopQueueWrite(LoopQueue *queue, unsigned char *data, unsigned int length)

{

    unsigned int i = 0;

    if(length > (QUEUE_MAX_LENGTH - queue->dataNumber))   

    {

        return UNDONE;

    }

    for(i = 0; i<length ; i++)

    {

        if((QUEUE_MAX_LENGTH - queue->dataNumber) == 0)

        {

            return FULL;

        }

        queue->queueFIFO[queue->putIndex] = *(data++);

        queue->dataNumber ++;

        if(queue->putIndex == QUEUE_MAX_LENGTH-1)

        {

           queue->putIndex = 0;

        }

        else

        {

           queue->putIndex ++;

        }

    }

    return DONE;

}



/*

**#############################################################################

** Loop queue read data from queue and put its into somewhere with pointer

**#############################################################################

*/

LoopQueueStateType LoopQueueRead(LoopQueue *queue, unsigned char *addr ,unsigned int length)

{

    unsigned int i = 0;



    if(queue->dataNumber == 0)

    {

        return EMPTY;

    }

    for(i = 0; i<length; i++)

    {

        if(queue->dataNumber == 0)

        {

            return UNDONE;

        }

        *addr++ = queue->queueFIFO[queue->getIndex];

        queue->dataNumber --;

        if(queue->getIndex == QUEUE_MAX_LENGTH-1)

        {

           queue->getIndex = 0;

        }

        else

        {

           queue->getIndex ++;

        }

    }

    return DONE;

}



/*

**#############################################################################

** Loop queue write one data

**#############################################################################

*/

LoopQueueStateType LoopQueueWriteOne(LoopQueue *queue, unsigned char data)

{

    if((QUEUE_MAX_LENGTH - queue->dataNumber) == 0)

    {

        return FULL;

    }

    queue->queueFIFO[queue->putIndex] = data;

    queue->dataNumber ++;

    if(queue->putIndex == QUEUE_MAX_LENGTH-1)

    {

         queue->putIndex = 0;

    }

    else

    {

         queue->putIndex ++;

    }



    return DONE;

}



/*

**#############################################################################

** Loop queue read one data

**#############################################################################

*/

LoopQueueStateType LoopQueueReadOne(LoopQueue *queue, unsigned char *addr)

{

    if(queue->dataNumber == 0)

    {

        return EMPTY;

    }

    *addr = queue->queueFIFO[queue->getIndex];

    queue->dataNumber --;

    if(queue->getIndex == QUEUE_MAX_LENGTH-1)

    {

         queue->getIndex = 0;

    }

    else

    {

         queue->getIndex ++;

    }

    return DONE;

}



/*

**#############################################################################

** Loop queue get data length

**#############################################################################

*/

unsigned int LoopQueueGetLength(LoopQueue *queue)

{

    return queue->dataNumber;

}

/*

**#############################################################################

**      SVN Information

**

**      Checked In          : 2017-12-27

**

**      Author              : Fan

**

**      Revision            : V1.1

**

**      Release Information : Loop queue head file(.h)

**#############################################################################

*/



#ifndef _RING_QUEUE_H_

#define _RING_QUEUE_H_



#define QUEUE_MAX_LENGTH  256                   // The max length of queue



//---------------- Loop queue states

typedef enum _LoopQueueStateType

{

    EMPTY = 0x50000000,                         // Queue is empty

    FULL,                                       // Queue is full

    DONE,                                       // Queue operating is done

    UNDONE,                                     // Queue operating is not done

}LoopQueueStateType;



//---------------- Loop queue struct

typedef struct _LoopQueue

{

    unsigned char putIndex;                     // Put data index

    unsigned char getIndex;                     // Get data index

    unsigned int dataNumber;                    // Current data number

    unsigned char queueFIFO[QUEUE_MAX_LENGTH];  // Loop queue FIFO

}LoopQueue;



//---------------- Loop queue initialization

extern void LoopQueueInit(LoopQueue *queue);



//---------------- Loop queue clear

extern void LoopQueueClear(LoopQueue *queue);



//---------------- Loop queue write data by pointer and length of data

extern LoopQueueStateType LoopQueueWrite(LoopQueue *queue, unsigned char *data, unsigned int length);



//---------------- Loop queue read data and put data by it's pointer

extern LoopQueueStateType LoopQueueRead(LoopQueue *queue, unsigned char *addr ,unsigned int length);



//---------------- Loop queue write one data

extern LoopQueueStateType LoopQueueWriteOne(LoopQueue *queue, unsigned char data);



//---------------- Loop read once

extern LoopQueueStateType LoopQueueReadOne(LoopQueue *queue, unsigned char *addr);



//---------------- Get the data length with queue pointer

extern unsigned int LoopQueueGetLength(LoopQueue *queue);



#endif