嵌入式基础:环形缓冲区ringbuffer

原创 汽车电子嵌入式 2024-05-06 07:36

目录

1.概述

2. 原理

3. 使用场景


4. 实践


  4.1 Github搜索


  4.2 编写makefile


  4.3 编译运行


5.总结

1.概述

ring buffer称作环形缓冲区,也称作环形队列(circular queue),是一种用于表示一个固定尺寸、头尾相连的缓冲区的数据结构,适合缓存数据流。如下为环形缓冲区(ring buffer) 的概念示意图。


在任务间的通信、串口数据收发、log缓存、网卡处理网络数据包、音频/视频流处理中均有环形缓冲区(ring buffer) 的应用。在RT-Threadringbuffer.cringbuffer.h文件中,Linux内核文件kfifo.hkfifo.c中也有环形缓冲区(ring buffer)的代码实现。

环形缓冲区的一些使用特点如下:

  • 当一个数据元素被读取出后,其余数据元素不需要移动其存储位置;

  • 适合于事先明确了缓冲区的最大容量的情形。缓冲区的容量(长度)一般固定,可以用一个静态数组来充当缓冲区,无需重复申请内存;

  • 如果缓冲区的大小需要经常调整,就不适合用环形缓冲区,因为在扩展缓冲区大小时,需要搬移其中的数据,这种场合使用链表更加合适;

  • 因为缓冲区成头尾相连的环形,写操作可能会覆盖未及时读取的数据,有的场景允许这种情况发生,有的场景又严格限制这种情况发生。选择何种策略和具体应用场景相关。


2. 原理

站在巨人的肩膀上,有文章已经介绍的很好了,参考文章:

https://zhuanlan.zhihu.com/p/534098236


3. 使用场景

只要出现数据生产者和的可能速度快于数据消费者场景,就需要使用缓存buffer. 比如在汽车ECU控制器中(如座舱域控制器)MCU和SOC之间的通信(如MCU收到CAN数据,根据情况上传给SOC)肯定需要使用缓存buffer, 这个buffer还需要具有先进行出的特性,那么就需要ring buffer.


4. 实践

如果是学习的话,我们当然可以从0到1自己写一个,这样更加能锻炼我们的代码能力。如果是项目着急使用的话,我们首先考虑站在巨人的肩膀上看有没有开源现成的可以参考。


4.1 Github搜索

github上搜索ringbuffer, 找一个star数相对比较高的项目。

读下项目的README

项目在实际硬件平台上使用过,且有相关的测试代码,但是没有makefile,我们需要编写一个makefile来测试下。

Github链接:https://github.com/netube99/RingBuffer


4.2 编写makefile

makefile参考本公众号的系类文章:

编译链接专题第7篇-变量的高级主题(下)


#makefileCOMPILER := gccTARGET := ringbuffer.exeOBJS := ring_buffer.o ring_buffer_chapter.o main.oRM := del
$(TARGET) : $(OBJS) $(COMPILER) -o $@ $^ $(OBJS) : %.o : %.c $(COMPILER) -o $@ -c $^ .PHONY : rebuild clean all
rebuild : clean all
all : $(TARGET) clean : $(RM) *o $(TARGET)


测试代码:

//引用相关头文件#include #include #include "ring_buffer.h"
//创建一个数组作为数据存储空间#define BUFFER_SIZE 128static uint8_t buffer[BUFFER_SIZE];
//创建环形缓冲区句柄static ring_buffer rb;
int main(void){ //初始化环形缓冲区参数 RB_Init(&rb, buffer, BUFFER_SIZE);
//写入向环形缓冲区写入数据 RB_Write_String(&rb, "hello world", 11); RB_Write_Byte(&rb, '!'); RB_Write_Byte(&rb, 0x00);
//删除环形缓冲区部分数据 RB_Delete(&rb, 2);
//获取已储存的数据长度 uint32_t num = RB_Get_Length(&rb);
//读出环形缓冲区中的数据并打印 uint8_t get[16]; RB_Read_String(&rb, get, num); printf("%s", get); //控制台输出内容 //llo world! return 0;}


4.3 编译运行

编译这个开源项目,生成可执行文件ringbuffer.exe

执行ringbuffer.exe,结果符合测试代码的预期。

5.总结

本文没有详细赘述ringbuffer的原理(参考文章中有详细介绍),着重介绍了项目中需要使用ringbuffer的场景,同时介绍了实际工程中如何从github中获取开源项目并编译运行起来。

ringbuffer的源码如下:


ring_buffer.h

/** * \file ring_buffer.h * \brief 简易环形缓冲相关定义与声明 * \author netube_99\netube@163.com * \date 2022.08.20 * \version v0.4.0*/#ifndef _RING_BUFFER_H_#define _RING_BUFFER_H_
//返回值定义#define RING_BUFFER_SUCCESS 0x01#define RING_BUFFER_ERROR 0x00
//环形缓冲区结构体typedef struct{ uint32_t head ; //操作头指针 uint32_t tail ; //操作尾指针 uint32_t Length ; //已储存的数据量 uint8_t *array_addr ; //缓冲区储存数组基地址 uint32_t max_Length ; //缓冲区最大可储存数据量}ring_buffer;
uint8_t RB_Init(ring_buffer *rb_handle, uint8_t *buffer_addr ,uint32_t buffer_size); //初始化基础环形缓冲区uint8_t RB_Delete(ring_buffer *rb_handle, uint32_t Length); //从头指针开始删除指定长度的数据uint8_t RB_Write_Byte(ring_buffer *rb_handle, uint8_t data); //向缓冲区尾指针写一个字节uint8_t RB_Write_String(ring_buffer *rb_handle, uint8_t *input_addr, uint32_t write_Length); //向缓冲区尾指针写指定长度数据uint8_t RB_Read_Byte(ring_buffer *rb_handle, uint8_t *output_addr); //从缓冲区头指针读一个字节uint8_t RB_Read_String(ring_buffer *rb_handle, uint8_t *output_addr, uint32_t read_Length); //从缓冲区头指针读指定长度数据uint32_t RB_Get_Length(ring_buffer *rb_handle); //获取缓冲区里已储存的数据长度uint32_t RB_Get_FreeSize(ring_buffer *rb_handle); //获取缓冲区可用储存空间
#endif//#ifndef _RING_BUFFER_H_


ring_buffer.c

/** * \file ring_buffer.c * \brief 简易环形缓冲的实现 * \author netube_99\netube@163.com * \date 2022.08.20 * \version v0.4.0*/
#include #include #include "ring_buffer.h"
/** * \brief 初始化新缓冲区 * \param[out] rb_handle: 待初始化的缓冲区结构体句柄 * \param[in] buffer_addr: 外部定义的缓冲区数组,类型必须为 uint8_t * \param[in] buffer_size: 外部定义的缓冲区数组空间 * \return 返回缓冲区初始化的结果 * \arg RING_BUFFER_SUCCESS: 初始化成功 * \arg RING_BUFFER_ERROR: 初始化失败*/uint8_t RB_Init(ring_buffer *rb_handle, uint8_t *buffer_addr ,uint32_t buffer_size){ //缓冲区数组空间必须大于2且小于数据类型最大值 if(buffer_size < 2 || buffer_size == 0xFFFFFFFF) return RING_BUFFER_ERROR ; //初始化失败 rb_handle->head = 0 ; //复位头指针 rb_handle->tail = 0 ; //复位尾指针 rb_handle->Length = 0 ; //复位已存储数据长度 rb_handle->array_addr = buffer_addr ; //缓冲区储存数组基地址 rb_handle->max_Length = buffer_size ; //缓冲区最大可储存数据量 return RING_BUFFER_SUCCESS ; //缓冲区初始化成功}
/** * \brief 从头指针开始删除指定长度的数据 * \param[out] rb_handle: 缓冲区结构体句柄 * \param[in] Length: 要删除的长度 * \return 返回删除指定长度数据结果 * \arg RING_BUFFER_SUCCESS: 删除成功 * \arg RING_BUFFER_ERROR: 删除失败*/uint8_t RB_Delete(ring_buffer *rb_handle, uint32_t Length){ if(rb_handle->Length < Length) return RING_BUFFER_ERROR ;//已储存的数据量小于需删除的数据量 else { if((rb_handle->head + Length) >= rb_handle->max_Length) rb_handle->head = Length - (rb_handle->max_Length - rb_handle->head); else rb_handle->head += Length ; //头指针向前推进,抛弃数据 rb_handle->Length -= Length ; //重新记录有效数据长度 return RING_BUFFER_SUCCESS ;//已储存的数据量小于需删除的数据量 }}
/** * \brief 向缓冲区尾部写一个字节 * \param[out] rb_handle: 缓冲区结构体句柄 * \param[in] data: 要写入的字节 * \return 返回缓冲区写字节的结果 * \arg RING_BUFFER_SUCCESS: 写入成功 * \arg RING_BUFFER_ERROR: 写入失败*/uint8_t RB_Write_Byte(ring_buffer *rb_handle, uint8_t data){ //缓冲区数组已满,产生覆盖错误 if(rb_handle->Length == (rb_handle->max_Length)) return RING_BUFFER_ERROR ; else { *(rb_handle->array_addr + rb_handle->tail) = data;//基地址+偏移量,存放数据 rb_handle->Length ++ ;//数据量计数+1 rb_handle->tail ++ ;//尾指针后移 } //如果尾指针超越了数组末尾,尾指针指向缓冲区数组开头,形成闭环 if(rb_handle->tail > (rb_handle->max_Length - 1)) rb_handle->tail = 0 ; return RING_BUFFER_SUCCESS ;}
/** * \brief 从缓冲区头指针读取一个字节 * \param[out] rb_handle: 缓冲区结构体句柄 * \param[out] output_addr: 读取的字节保存地址 * \return 返回读取状态 * \arg RING_BUFFER_SUCCESS: 读取成功 * \arg RING_BUFFER_ERROR: 读取失败*/uint8_t RB_Read_Byte(ring_buffer *rb_handle, uint8_t *output_addr){ if (rb_handle->Length != 0)//有数据未读出 { *output_addr = *(rb_handle->array_addr + rb_handle->head);//读取数据 rb_handle->head ++ ; rb_handle->Length -- ;//数据量计数-1 //如果头指针超越了数组末尾,头指针指向数组开头,形成闭环 if(rb_handle->head > (rb_handle->max_Length - 1)) rb_handle->head = 0 ; return RING_BUFFER_SUCCESS ; } return RING_BUFFER_ERROR ;}
/** * \brief 向缓冲区尾部写指定长度的数据 * \param[out] rb_handle: 缓冲区结构体句柄 * \param[out] input_addr: 待写入数据的基地址 * \param[in] write_Length: 要写入的字节数 * \return 返回缓冲区尾部写指定长度字节的结果 * \arg RING_BUFFER_SUCCESS: 写入成功 * \arg RING_BUFFER_ERROR: 写入失败*/uint8_t RB_Write_String(ring_buffer *rb_handle, uint8_t *input_addr, uint32_t write_Length){ //如果不够存储空间存放新数据,返回错误 if((rb_handle->Length + write_Length) > (rb_handle->max_Length)) return RING_BUFFER_ERROR ; else { //设置两次写入长度 uint32_t write_size_a, write_size_b ; //如果顺序可用长度小于需写入的长度,需要将数据拆成两次分别写入 if((rb_handle->max_Length - rb_handle->tail) < write_Length) { write_size_a = rb_handle->max_Length - rb_handle->tail ;//从尾指针开始写到储存数组末尾 write_size_b = write_Length - write_size_a ;//从储存数组开头写数据 //分别拷贝a、b段数据到储存数组中 memcpy(rb_handle->array_addr + rb_handle->tail, input_addr, write_size_a); memcpy(rb_handle->array_addr, input_addr + write_size_a, write_size_b); rb_handle->Length += write_Length ;//记录新存储了多少数据量 rb_handle->tail = write_size_b ;//重新定位尾指针位置 } else//如果顺序可用长度大于或等于需写入的长度,则只需要写入一次 { write_size_a = write_Length ;//从尾指针开始写到储存数组末尾 memcpy(rb_handle->array_addr + rb_handle->tail, input_addr, write_size_a); rb_handle->Length += write_Length ;//记录新存储了多少数据量 rb_handle->tail += write_size_a ;//重新定位尾指针位置 if(rb_handle->tail == rb_handle->max_Length) rb_handle->tail = 0 ;//如果写入数据后尾指针刚好写到数组尾部,则回到开头,防止越位 } return RING_BUFFER_SUCCESS ; }}
/** * \brief 从缓冲区头部读指定长度的数据,保存到指定的地址 * \param[out] rb_handle: 缓冲区结构体句柄 * \param[out] output_addr: 读取的数据保存地址 * \param[in] read_Length: 要读取的字节数 * \return 返回缓冲区头部读指定长度字节的结果 * \arg RING_BUFFER_SUCCESS: 读取成功 * \arg RING_BUFFER_ERROR: 读取失败*/uint8_t RB_Read_String(ring_buffer *rb_handle, uint8_t *output_addr, uint32_t read_Length){ if(read_Length > rb_handle->Length) return RING_BUFFER_ERROR ; else { uint32_t Read_size_a, Read_size_b ; if(read_Length > (rb_handle->max_Length - rb_handle->head)) { Read_size_a = rb_handle->max_Length - rb_handle->head ; Read_size_b = read_Length - Read_size_a ; memcpy(output_addr, rb_handle->array_addr + rb_handle->head, Read_size_a); memcpy(output_addr + Read_size_a, rb_handle->array_addr, Read_size_b); rb_handle->Length -= read_Length ;//记录剩余数据量 rb_handle->head = Read_size_b ;//重新定位头指针位置 } else { Read_size_a = read_Length ; memcpy(output_addr, rb_handle->array_addr + rb_handle->head, Read_size_a); rb_handle->Length -= read_Length ;//记录剩余数据量 rb_handle->head += Read_size_a ;//重新定位头指针位置 if(rb_handle->head == rb_handle->max_Length) rb_handle->head = 0 ;//如果读取数据后头指针刚好写到数组尾部,则回到开头,防止越位 } return RING_BUFFER_SUCCESS ; }}
/** * \brief 获取缓冲区里已储存的数据长度 * \param[in] rb_handle: 缓冲区结构体句柄 * \return 返回缓冲区里已储存的数据长度*/uint32_t RB_Get_Length(ring_buffer *rb_handle){ return rb_handle->Length ;}
/** * \brief 获取缓冲区可用储存空间 * \param[in] rb_handle: 缓冲区结构体句柄 * \return 返回缓冲区可用储存空间*/uint32_t RB_Get_FreeSize(ring_buffer *rb_handle){ return (rb_handle->max_Length - rb_handle->Length) ;}


main.c和makefile文件见前文。



End

「汽车电子嵌入式在CSDN上同步推出AUTOSAR精进之路专栏,本专栏每个模块完全按实际项目中开发及维护过程来详细介绍。模块核心概念介绍、实际需求描述、实际工程配置、特殊需求介绍及背后原理、实际工程使用经验总结。目的是让读者看完每一个章节后能理解原理后根据需求完成一个模块的配置或者解决一个问题。」


点击文章最后左下角的阅读原文可以获取更多信息


或者复制如下链接到浏览器获取更多信息

https://blog.csdn.net/qq_36056498/article/details/132125693


文末福利




1
.如需汽车电子嵌入式收集的学习文档,
后台回复“

资料

即可免费下载;

2.为便于技术交流,创建了汽车电子嵌入式技术交流群,可尽情探讨AP,CP,DDS,SOME/IP等前沿热点话题,后台回复“加群”即可加入;



注:本文引用了一些第三方工具和文档,若有侵权,请联系作者删除!


推荐阅读

汽车电子嵌入式精彩文章汇总第一期:20210530-20230703

汽车电子嵌入式精彩文章汇总第2期

TC3xx芯片GTM模块-CMU,CCM,TBU详解

TC3xx芯片GTM模块-TOM详解

AUTOSAR架构下PWM模块配置实践

TC3xx芯片GTM模块-TIM详解

AUTOSAR架构下ICU模块配置实践

TC3xx芯片电源管理系统PMS详解

TC3xx DMA模块详解

TC3xx芯片SMU模块详解

如何监控TC3xx芯片PFlash的ECC错误

TC3xx芯片RAM的错误检测

TC3xx芯片的总线内存保护

编译链接专题第1篇-make和makefile介绍

编译链接专题第2篇-初识makefile结构

编译链接专题第3篇-初识makefile中的伪目标

编译链接专题第4篇-变量和变量的不同赋值方式

编译链接专题第5篇-预定义变量的使用

编译链接专题第6篇-变量的高级主题(上)

编译链接专题第7篇-变量的高级主题(下)

编译链接专题第8篇-条件判断语句




End


欢迎点赞,关注,转发,在看,您的每一次鼓励,都是我最大的动力!

汽车电子嵌入式

微信扫描二维码,关注我的公众号


评论 (0)
  • 政策驱动,AVAS成新能源车安全刚需随着全球碳中和目标的推进,新能源汽车产业迎来爆发式增长。据统计,2023年中国新能源汽车渗透率已突破35%,而欧盟法规明确要求2024年后新能效车型必须配备低速提示音系统(AVAS)。在此背景下,低速报警器作为车辆主动安全的核心组件,其技术性能直接关乎行人安全与法规合规性。基于WT2003H芯片开发的AVAS解决方案,以高可靠性、强定制化能力及智能场景适配特性,正成为行业技术升级的新标杆。WT2003H方案技术亮点解析全场景音效精准触发方案通过多传感器融合技术
    广州唯创电子 2025-04-10 08:53 173浏览
  • 技术原理:非扫描式全局像的革新Flash激光雷达是一种纯固态激光雷达技术,其核心原理是通过面阵激光瞬时覆盖探测区域,配合高灵敏度传感器实现全局三维成像。其工作流程可分解为以下关键环节:1. 激光发射:采用二维点阵光源(如VCSEL垂直腔面发射激光器),通过光扩散器在单次脉冲中发射覆盖整个视场的面阵激光,视场角通常可达120°×75°,部分激光雷达产品可以做到120°×90°的超大视场角。不同于传统机械扫描或MEMS微振镜方案,Flash方案无需任何移动部件,直接通过电信号控制激光发射模式。2.
    robolab 2025-04-10 15:30 79浏览
  •   海上电磁干扰训练系统:全方位解析      海上电磁干扰训练系统,作为模拟复杂海上电磁环境、锻炼人员应对电磁干扰能力的关键技术装备,在军事、科研以及民用等诸多领域广泛应用。接下来从系统构成、功能特点、技术原理及应用场景等方面展开详细解析。   应用案例   系统软件供应可以来这里,这个首肌开始是幺伍扒,中间是幺幺叁叁,最后一个是泗柒泗泗,按照数字顺序组合就可以找到。   一、系统构成   核心组件   电磁信号模拟设备:负责生成各类复杂的电磁信号,模拟海上多样
    华盛恒辉l58ll334744 2025-04-10 16:45 83浏览
  • 行业变局:从机械仪表到智能交互终端的跃迁全球两轮电动车市场正经历从“功能机”向“智能机”的转型浪潮。数据显示,2024年智能电动车仪表盘渗透率已突破42%,而传统LED仪表因交互单一、扩展性差等问题,难以满足以下核心需求:适老化需求:35%中老年用户反映仪表信息辨识困难智能化缺口:78%用户期待仪表盘支持手机互联与语音交互成本敏感度:厂商需在15元以内BOM成本实现功能升级在此背景下,集成语音播报与蓝牙互联的WT2605C-32N芯片方案,以“极简设计+智能交互”重构仪表盘技术生态链。技术破局:
    广州唯创电子 2025-04-11 08:59 104浏览
  •   天空卫星健康状况监测维护管理系统:全方位解析  在航天技术迅猛发展的当下,卫星在轨运行的安全与可靠至关重要。整合多种技术,实现对卫星的实时监测、故障诊断、健康评估以及维护决策,有力保障卫星长期稳定运转。  应用案例       系统软件供应可以来这里,这个首肌开始是幺伍扒,中间是幺幺叁叁,最后一个是泗柒泗泗,按照数字顺序组合就可以找到。  一、系统架构与功能模块  数据采集层  数据处理层  智能分析层  决策支持层  二、关键技术  故障诊断技术  
    华盛恒辉l58ll334744 2025-04-10 15:46 54浏览
  • 由西门子(Siemens)生产的SIMATIC S7 PLC在SCADA 领域发挥着至关重要的作用。在众多行业中,SCADA 应用都需要与这些 PLC 进行通信。那么,有哪些高效可行的解决方案呢?宏集为您提供多种选择。传统方案:通过OPC服务器与西门子 PLC 间接通信SIMATIC S7系列的PLC是工业可编程控制器,能够实现对生产流程的实时SCADA监控,提供关于设备和流程状态的准确、最新数据。S7Comm(全称S7 Communication),也被称为工业以太网或Profinet,是西门
    宏集科技 2025-04-10 13:44 64浏览
  • 行业痛点:电动车智能化催生语音交互刚需随着全球短途出行市场爆发式增长,中国电动自行车保有量已突破3.5亿辆。新国标实施推动行业向智能化、安全化转型,传统蜂鸣器报警方式因音效单一、缺乏场景适配性等问题,难以满足用户对智能交互体验的需求。WT2003HX系列语音芯片,以高性能处理器架构与灵活开发平台,为两轮电动车提供从基础报警到智能交互的全栈语音解决方案。WT2003HX芯片技术优势深度解读1. 高品质硬件性能,重塑语音交互标准搭载32位RISC处理器,主频高达120MHz,确保复杂算法流畅运行支持
    广州唯创电子 2025-04-10 09:12 160浏览
  •     前几天同事问我,电压到多少伏就不安全了?考虑到这位同事的非电专业背景,我做了最极端的答复——多少伏都不安全,非专业人员别摸带电的东西。    那么,是不是这么绝对呢?我查了一下标准,奇怪的知识增加了。    标准的名字值得玩味——《电流对人和家畜的效应》,GB/T 13870.5 (IEC 60749-5)。里面对人、牛、尸体分类讨论(搞硬件的牛马一时恍惚,不知道自己算哪种)。    触电是电流造成的生理效应
    电子知识打边炉 2025-04-09 22:35 170浏览
  • 背景近年来,随着国家对资源、能源有效利用率的要求越来越高,对环境保护和水处理的要求也越来越严格,因此有大量的固液分离问题需要解决。真空过滤器是是由负压形成真空过滤的固液分离机械。用过滤介质把容器分为上、下两层,利用负压,悬浮液加入上腔,在压力作用下通过过滤介质进入下腔成为滤液,悬浮液中的固体颗粒吸附在过滤介质表面形成滤饼,滤液穿过过滤介质经中心轴内部排出,达到固液分离的目的。目前市面上的过滤器多分为间歇操作和连续操作两种。间歇操作的真空过滤机可过滤各种浓度的悬浮液,连续操作的真空过滤机适于过滤含
    宏集科技 2025-04-10 13:45 60浏览
  • 文/Leon编辑/侯煜‍关税大战一触即发,当地时间4月9日起,美国开始对中国进口商品征收总计104%的关税。对此,中国外交部回应道:中方绝不接受美方极限施压霸道霸凌,将继续采取坚决有力措施,维护自身正当权益。同时,中国对原产于美国的进口商品加征关税税率,由34%提高至84%。随后,美国总统特朗普在社交媒体宣布,对中国关税立刻提高至125%,并暂缓其他75个国家对等关税90天,在此期间适用于10%的税率。特朗普政府挑起关税大战的目的,实际上是寻求制造业回流至美国。据悉,特朗普政府此次宣布对全球18
    华尔街科技眼 2025-04-10 16:39 69浏览
  • 什么是车用高效能运算(Automotive HPC)?高温条件为何是潜在威胁?作为电动车内的关键核心组件,由于Automotive HPC(CPU)具备高频高效能运算电子组件、高速传输接口以及复杂运算处理、资源分配等诸多特性,再加上各种车辆的复杂应用情境等等条件,不难发见Automotive HPC对整个平台讯号传输实时处理、系统稳定度、耐久度、兼容性与安全性将造成多大的考验。而在各种汽车使用者情境之中,「高温条件」就是你我在日常生活中必然会面临到的一种潜在威胁。不论是长时间将车辆停放在室外的高
    百佳泰测试实验室 2025-04-10 15:09 65浏览
我要评论
0
0
点击右上角,分享到朋友圈 我知道啦
请使用浏览器分享功能 我知道啦