久久久久久久999_99精品久久精品一区二区爱城_成人欧美一区二区三区在线播放_国产精品日本一区二区不卡视频_国产午夜视频_欧美精品在线观看免费

 找回密碼
 立即注冊

QQ登錄

只需一步，快速開始

搜索
查看: 3434|回復: 1
收起左側

環形緩存區ring_buffer源程序

[復制鏈接]
ID:423034 發表于 2018-11-13 17:07 | 顯示全部樓層 |閱讀模式
串口數據接收 及發送處理 節省空間 高效率

單片機源程序如下:
  1. #include <stdlib.h>
  2. #include <string.h>
  3. #include "ring_buffer.h"

  5. /*****************************************************************************
  6. * Private types/enumerations/variables
  7. ****************************************************************************/

  9. #define RB_INDH(rb)                ((rb)->head & ((rb)->count - 1))
  10. #define RB_INDT(rb)                ((rb)->tail & ((rb)->count - 1))

  12. #if !defined(MAX)
  13. #define MAX(a, b) (((a) > (b)) ? (a) : (b))
  14. #endif
  15. #if !defined(MIN)
  16. #define MIN(a, b) (((a) < (b)) ? (a) : (b))
  17. #endif
  18. /*****************************************************************************
  19. * Public types/enumerations/variables
  20. ****************************************************************************/

  22. /*****************************************************************************
  23. * Private functions
  24. ****************************************************************************/

  26. /*****************************************************************************
  27. * Public functions
  28. ****************************************************************************/

  30. /**
  31. * @brief        Resets the ring buffer to empty
  32. * @param        RingBuff        : Pointer to ring buffer
  33. * @return        Nothing
  34. */
  35. void RingBuffer_Flush(RINGBUFF_T *RingBuff)
  36. {
  37.     RingBuff->head = RingBuff->tail = 0;
  38. }

  40. /**
  41. * @brief        Return size the ring buffer
  42. * @param        RingBuff        : Pointer to ring buffer
  43. * @return        Size of the ring buffer in bytes
  44. */
  45. int RingBuffer_GetSize(RINGBUFF_T *RingBuff)
  46. {
  47.     return RingBuff->count;
  48. }

  50. /**
  51. * @brief        Return number of items in the ring buffer
  52. * @param        RingBuff        : Pointer to ring buffer
  53. * @return        Number of items in the ring buffer
  54. */
  55. static int RingBuffer_GetCount(RINGBUFF_T *RingBuff)
  56. {
  57.     return RB_VHEAD(RingBuff) - RB_VTAIL(RingBuff);
  58. }

  60. /**
  61. * @brief        Return number of free items in the ring buffer
  62. * @param        RingBuff        : Pointer to ring buffer
  63. * @return        Number of free items in the ring buffer
  64. */
  65. static int RingBuffer_GetFree(RINGBUFF_T *RingBuff)
  66. {
  67.     return RingBuff->count - RingBuffer_GetCount(RingBuff);
  68. }

  70. /**
  71. * @brief        Return number of items in the ring buffer
  72. * @param        RingBuff        : Pointer to ring buffer
  73. * @return        1 if the ring buffer is full, otherwise 0
  74. */
  75. int RingBuffer_IsFull(RINGBUFF_T *RingBuff)
  76. {
  77.     return (RingBuffer_GetCount(RingBuff) >= RingBuff->count);
  78. }

  80. /**
  81. * @brief        Return empty status of ring buffer
  82. * @param        RingBuff        : Pointer to ring buffer
  83. * @return        1 if the ring buffer is empty, otherwise 0
  84. */
  85. int RingBuffer_IsEmpty(RINGBUFF_T *RingBuff)
  86. {
  87.     return RB_VHEAD(RingBuff) == RB_VTAIL(RingBuff);
  88. }
  89. /* Initialize ring buffer */
  90. int RingBuffer_Init(RINGBUFF_T *RingBuff, void *buffer, int itemSize, int count)
  91. {
  92.     RingBuff->data = buffer;
  93.     RingBuff->count = count;
  94.     RingBuff->itemSz = itemSize;
  95.     RingBuff->head = RingBuff->tail = 0;

  97.     return 1;
  98. }

  100. /* Insert a single item into Ring Buffer */
  101. int RingBuffer_Insert(RINGBUFF_T *RingBuff, const void *data)
  102. {
  103.     u8 *ptr = RingBuff->data;

  105.     /* We cannot insert when queue is full */
  106.     if (RingBuffer_IsFull(RingBuff))
  107.         return 0;
  108.     ptr += RB_INDH(RingBuff) * RingBuff->itemSz;
  109.     memcpy(ptr, data, RingBuff->itemSz);
  110.     RingBuff->head++;
  111.     return 1;
  112. }

  114. /* Insert multiple items into Ring Buffer */
  115. int RingBuffer_InsertMult(RINGBUFF_T *RingBuff, const void *data, int num)
  116. {
  117.     u8 *ptr = RingBuff->data;
  118.     int cnt1, cnt2;

  120.     /* We cannot insert when queue is full */
  121.     if (RingBuffer_IsFull(RingBuff))
  122.         return 0;

  124.     /* Calculate the segment lengths */
  125.     cnt1 = cnt2 = RingBuffer_GetFree(RingBuff);
  126.     if (RB_INDH(RingBuff) + cnt1 >= RingBuff->count)
  127.         cnt1 = RingBuff->count - RB_INDH(RingBuff);
  128.     cnt2 -= cnt1;

  130.     cnt1 = MIN(cnt1, num);
  131.     num -= cnt1;

  133.     cnt2 = MIN(cnt2, num);
  134.     num -= cnt2;

  136.     /* Write segment 1 */
  137.     ptr += RB_INDH(RingBuff) * RingBuff->itemSz;
  138.     memcpy(ptr, data, cnt1 * RingBuff->itemSz);
  139.     RingBuff->head += cnt1;

  141.     /* Write segment 2 */
  142.     ptr = (u8 *) RingBuff->data + RB_INDH(RingBuff) * RingBuff->itemSz;
  143.     data = (const u8 *) data + cnt1 * RingBuff->itemSz;
  144.     memcpy(ptr, data, cnt2 * RingBuff->itemSz);
  145.     RingBuff->head += cnt2;

  147.     return cnt1 + cnt2;
  148. }

  150. /* Pop single item from Ring Buffer */
  151. int RingBuffer_Pop(RINGBUFF_T *RingBuff, void *data)
  152. {
  153.     u8 *ptr = RingBuff->data;

  155.     /* We cannot pop when queue is empty */
  156.     if (RingBuffer_IsEmpty(RingBuff))
  157.         return 0;

  159.     ptr += RB_INDT(RingBuff) * RingBuff->itemSz;
  160.     memcpy(data, ptr, RingBuff->itemSz);
  161.     RingBuff->tail++;

  163.     return 1;
  164. }

  166. /* Pop multiple items from Ring buffer */
  167. int RingBuffer_PopMult(RINGBUFF_T *RingBuff, void *data, int num)
  168. {
  169.     u8 *ptr = RingBuff->data;
  170.     int cnt1, cnt2;

  172.     /* We cannot insert when queue is empty */
  173.     if (RingBuffer_IsEmpty(RingBuff))
  174.         return 0;

  176.     /* Calculate the segment lengths */
  177.     cnt1 = cnt2 = RingBuffer_GetCount(RingBuff);
  178.     if (RB_INDT(RingBuff) + cnt1 >= RingBuff->count)
  179.         cnt1 = RingBuff->count - RB_INDT(RingBuff);
  180.     cnt2 -= cnt1;

  182.     cnt1 = MIN(cnt1, num);
  183.     num -= cnt1;

  185.     cnt2 = MIN(cnt2, num);
  186.     num -= cnt2;

  188.     /* Write segment 1 */
  189.     ptr += RB_INDT(RingBuff) * RingBuff->itemSz;
  190.     memcpy(data, ptr, cnt1 * RingBuff->itemSz);
  191.     RingBuff->tail += cnt1;

  193.     /* Write segment 2 */
  194.     ptr = (u8 *) RingBuff->data + RB_INDT(RingBuff) * RingBuff->itemSz;
  195.     data = (u8 *) data + cnt1 * RingBuff->itemSz;
  196.     memcpy(data, ptr, cnt2 * RingBuff->itemSz);
  197.     RingBuff->tail += cnt2;

  199.     return cnt1 + cnt2;
  200. }
復制代碼

所有資料51hei提供下載:
ring_buffer.zip (3.77 KB, 下載次數: 31)


評分

參與人數 1黑幣 +50 收起 理由
admin + 50 共享資料的黑幣獎勵！

查看全部評分

回復

使用道具 舉報

ID:92520 發表于 2020-1-18 10:56 | 顯示全部樓層
正是需要的，感謝分享！
回復

使用道具 舉報

您需要登錄后才可以回帖 登錄 | 立即注冊

本版積分規則

小黑屋|51黑電子論壇 |51黑電子論壇6群 QQ 管理員QQ:125739409;技術交流QQ群281945664

Powered by 單片機教程網

快速回復 返回頂部 返回列表
主站蜘蛛池模板： 婷婷色国产偷v国产偷v小说 | 在线视频成人 | 久久毛片| av性色全交蜜桃成熟时 | 日本精品一区二区三区四区 | 亚洲午夜精品 | 日日躁狠狠躁aaaaxxxx | 国产福利在线 | 午夜视频在线免费观看 | 99精品欧美一区二区蜜桃免费 | www.天天操| 亚洲狠狠爱 | 国产欧美日韩视频 | 99r在线 | 在线免费观看毛片 | 成年人网站免费视频 | 亚洲乱码一区二区三区在线观看 | 黄色a视频| 亚洲欧美一区二区三区国产精品 | 超碰免费在线观看 | 一起操网站 | 农夫在线精品视频免费观看 | 欧美视频二区 | 亚洲精品99 | 日本亚洲一区二区 | 亚洲精品在线播放 | 亚洲一区二区三区免费视频 | 国产成人免费视频网站视频社区 | 国产jizz女人多喷水99 | 日日干日日色 | 久综合| 亚洲精品一区二区三区在线观看 | 亚洲不卡在线观看 | 一级毛片视频 | 中文字幕一区二区三区精彩视频 | 99欧美精品 | 日韩一区二区三区在线观看 | 日日操日日干 | 网站黄色在线 | 盗摄精品av一区二区三区 | 亚洲a一区二区 |