14.FreeRTOS 流媒体缓存 Stream Buffer

FreeRTOS 中的 Stream Buffer（流媒体缓存）

在实时操作系统（RTOS）中，处理流媒体数据是一项非常关键的任务。FreeRTOS 提供了一种名为 Stream Buffer（流媒体缓存）的机制，用于高效地管理和传输流式数据，如音频、视频等。

什么是 Stream Buffer？

Stream Buffer 是 FreeRTOS 提供的一种数据结构，专门用于在任务之间传递和处理流式数据。与队列不同，Stream Buffer 适用于大数据块的流式传输，而不是单个数据项的传输。这使得它非常适合用于音频、视频和其他连续数据流的场景。

Stream Buffer 的工作原理

Stream Buffer 的基本操作包括创建、发送和接收数据。它通过一个环形缓冲区来存储数据，使得数据可以连续地写入和读取。以下是其主要操作：

  1. 创建 Stream Buffer：使用 xStreamBufferCreate 函数创建一个新的 Stream Buffer。
  2. 发送数据到 Stream Buffer：任务使用 xStreamBufferSend 将数据发送到缓冲区。
  3. 从 Stream Buffer 接收数据：任务使用 xStreamBufferReceive 从缓冲区接收数据。

流媒体传输任务处理的示例

下面是一个示例，展示了如何使用 Stream Buffer 实现流水线式任务处理：

#include <Arduino.h>
#include <FreeRTOS.h>
#include <stream_buffer.h>#define BUFFER_SIZE 1024
#define TRIGGER_LEVEL 1StreamBufferHandle_t xStreamBuffer;// Task1: 发送数据到 Stream Buffer
void Task1(void *pvParameters) {const char *data = "Task 1 data";for (;;) {// 模拟 Task1 的工作delay(1000);Serial.println("Task 1 is sending data");xStreamBufferSend(xStreamBuffer, data, strlen(data), portMAX_DELAY);}
}// Task2: 从 Stream Buffer 接收数据并处理
void Task2(void *pvParameters) {char buffer[50];for (;;) {// 从 Stream Buffer 接收数据size_t bytesReceived = xStreamBufferReceive(xStreamBuffer, buffer, sizeof(buffer), portMAX_DELAY);if (bytesReceived > 0) {buffer[bytesReceived] = '\0'; // 确保字符串以 NULL 结尾Serial.print("Task 2 received data: ");Serial.println(buffer);// 模拟 Task2 的工作delay(1000);}}
}void setup() {Serial.begin(115200);// 创建 Stream BufferxStreamBuffer = xStreamBufferCreate(BUFFER_SIZE, TRIGGER_LEVEL);if (xStreamBuffer == NULL) {// 创建失败，处理错误while (1);}// 创建任务xTaskCreate(Task1, "Task 1", 10000, NULL, 1, NULL);xTaskCreate(Task2, "Task 2", 10000, NULL, 1, NULL);// 启动任务调度器vTaskStartScheduler();
}void loop() {// loop 函数为空，不需要额外的代码
}

API

使用 Stream Buffer 的步骤

1. 创建 Stream Buffer

要创建一个 Stream Buffer，使用 xStreamBufferCreate 函数：

StreamBufferHandle_t xStreamBufferCreate(size_t xBufferSizeBytes, size_t xTriggerLevelBytes);

参数：

  • xBufferSizeBytes：缓冲区的大小（字节数）。
  • xTriggerLevelBytes：触发接收任务的最小字节数。

返回值：

  • 成功时返回 Stream Buffer 的句柄（非 NULL）；失败时返回 NULL。

示例：

StreamBufferHandle_t xStreamBuffer = xStreamBufferCreate(1024, 1);
if (xStreamBuffer == NULL) {// 创建失败，处理错误
}
2. 发送数据到 Stream Buffer

使用 xStreamBufferSend 将数据发送到缓冲区：

size_t xStreamBufferSend(StreamBufferHandle_t xStreamBuffer, const void *pvTxData, size_t xDataLengthBytes, TickType_t xTicksToWait);

参数：

  • xStreamBuffer：Stream Buffer 的句柄。
  • pvTxData：要发送的数据指针。
  • xDataLengthBytes：发送的数据长度（字节数）。
  • xTicksToWait：等待时间（滴答数）。

返回值：

  • 成功发送的数据字节数。如果返回值小于 xDataLengthBytes，则表示在 xTicksToWait 时间内没有足够的空间发送所有数据。

示例：

const char *data = "Hello, FreeRTOS!";
size_t bytesSent = xStreamBufferSend(xStreamBuffer, data, strlen(data), portMAX_DELAY);
if (bytesSent < strlen(data)) {// 发送的数据不完整，处理错误
}
3. 从 Stream Buffer 接收数据

使用 xStreamBufferReceive 从缓冲区接收数据：

size_t xStreamBufferReceive(StreamBufferHandle_t xStreamBuffer, void *pvRxData, size_t xBufferLengthBytes, TickType_t xTicksToWait);

参数：

  • xStreamBuffer：Stream Buffer 的句柄。
  • pvRxData：接收数据的缓冲区指针。
  • xBufferLengthBytes：接收缓冲区的大小（字节数）。
  • xTicksToWait：等待时间（滴答数）。

返回值：

  • 成功接收的数据字节数。如果返回值小于 xBufferLengthBytes，则表示在 xTicksToWait 时间内没有接收到足够的数据。

示例：

char buffer[50];
size_t bytesReceived = xStreamBufferReceive(xStreamBuffer, buffer, sizeof(buffer), portMAX_DELAY);
if (bytesReceived > 0) {buffer[bytesReceived] = '\0'; // 确保字符串以 NULL 结尾Serial.println(buffer);
} else {// 接收失败，处理错误
}

其他 Stream Buffer API

1. xStreamBufferCreateStatic

创建一个静态分配的 Stream Buffer。

StreamBufferHandle_t xStreamBufferCreateStatic(size_t xBufferSizeBytes, size_t xTriggerLevelBytes, uint8_t *pucStreamBufferStorageArea, StaticStreamBuffer_t *pxStaticStreamBuffer);

参数：

  • xBufferSizeBytes：缓冲区的大小（字节数）。
  • xTriggerLevelBytes：触发接收任务的最小字节数。
  • pucStreamBufferStorageArea：指向预先分配的缓冲区存储区。
  • pxStaticStreamBuffer：指向预先分配的 StaticStreamBuffer_t 结构。

返回值：

  • 成功时返回 Stream Buffer 的句柄（非 NULL）；失败时返回 NULL。
2. xStreamBufferReset

重置 Stream Buffer，使其变为空。

BaseType_t xStreamBufferReset(StreamBufferHandle_t xStreamBuffer);

参数：

  • xStreamBuffer：Stream Buffer 的句柄。

返回值：

  • 如果成功重置 Stream Buffer，则返回 pdPASS；如果在 Stream Buffer 上有任务阻塞，则返回 pdFAIL。

示例：

if (xStreamBufferReset(xStreamBuffer) == pdPASS) {// 重置成功
} else {// 重置失败，处理错误
}
3. xStreamBufferSpacesAvailable

获取 Stream Buffer 中可用的空闲空间（字节数）。

size_t xStreamBufferSpacesAvailable(StreamBufferHandle_t xStreamBuffer);

参数：

  • xStreamBuffer：Stream Buffer 的句柄。

返回值：

  • Stream Buffer 中当前可用的空闲空间，以字节为单位。

示例：

size_t spaceAvailable = xStreamBufferSpacesAvailable(xStreamBuffer);
Serial.print("Space available: ");
Serial.println(spaceAvailable);
4. xStreamBufferBytesAvailable

获取 Stream Buffer 中可读取的字节数。

size_t xStreamBufferBytesAvailable(StreamBufferHandle_t xStreamBuffer);

参数：

  • xStreamBuffer：Stream Buffer 的句柄。

返回值：

  • Stream Buffer 中当前可读取的字节数。

示例：

size_t bytesAvailable = xStreamBufferBytesAvailable(xStreamBuffer);
Serial.print("Bytes available: ");
Serial.println(bytesAvailable);
5. xStreamBufferSetTriggerLevel

设置触发接收任务的最小字节数。

BaseType_t xStreamBufferSetTriggerLevel(StreamBufferHandle_t xStreamBuffer, size_t xTriggerLevel);

参数：

  • xStreamBuffer：Stream Buffer 的句柄。
  • xTriggerLevel：触发级别（字节数）。

返回值：

  • 如果成功设置触发级别，则返回 pdPASS；如果提供的 xTriggerLevel 超过缓冲区大小，则返回 pdFAIL。

示例：

if (xStreamBufferSetTriggerLevel(xStreamBuffer, 10) == pdPASS) {// 设置成功
} else {// 设置失败，处理错误
}
6. vStreamBufferDelete

删除 Stream Buffer，释放分配的内存。

void vStreamBufferDelete(StreamBufferHandle_t xStreamBuffer);

参数：

  • xStreamBuffer：Stream Buffer 的句柄。

返回值：

  • 无返回值。

示例：

vStreamBufferDelete(xStreamBuffer);

结论

FreeRTOS 的 Stream Buffer 提供了一种高效的机制来处理和传输流媒体数据。通过合理使用 Stream Buffer，可以在嵌入式系统中实现稳定可靠的流媒体数据处理。在实际应用中，我们应根据具体需求调整缓冲区大小和触发级别，并优化数据处理流程，以实现最佳性能。

本文来自互联网用户投稿，该文观点仅代表作者本人，不代表本站立场。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如若转载，请注明出处：http://www.mzph.cn/web/20958.shtml

如若内容造成侵权/违法违规/事实不符，请联系多彩编程网进行投诉反馈email:809451989@qq.com，一经查实，立即删除！

相关文章

面试官问：Redis 为什么这么快？只会说一个内存...

面试官问：Redis 为什么这么快？只会说一个内存...

本文将围绕 Redis 为什么这么快这一主题，从多个角度进行深入分析。我们将探讨 Redis 的数据结构、网络模型、持久化机制、内存管理等关键因素，并分析它们如何共同作用，使 Redis 成为高性能的内存数据库。 一、引言 在当今大数据时代，高性能的数据库系统对于处理海量数据至…
阅读更多...
插入排序详解及Java代码实现

插入排序详解及Java代码实现

在计算机科学中&#xff0c;排序是一种基本的操作&#xff0c;它广泛应用于各种数据处理场景。插入排序&#xff08;Insertion Sort&#xff09;是一种简单直观的排序算法&#xff0c;它的工作原理是通过构建有序序列&#xff0c;对于未排序数据&#xff0c;在已排序序列中从后…
阅读更多...
牛客BM85 验证IP地址【中等 字符串 Java/Go/PHP】

牛客BM85 验证IP地址【中等 字符串 Java/Go/PHP】

题目 题目链接&#xff1a; https://www.nowcoder.com/practice/55fb3c68d08d46119f76ae2df7566880 https://www.lintcode.com/problem/1222/description 思路 直接模拟&#xff0c;注意IPv4,ipv6的条件Java代码 import java.util.*;public class Solution {/*** 验证IP地址…
阅读更多...
关于IDEA创建Maven一直爆红无法下载的问题

关于IDEA创建Maven一直爆红无法下载的问题

你能看到这我就知道你肯定已经试过了网上的很多方法了&#xff0c;我之前也是&#xff0c;试过了很多一直无法正常下载&#xff0c;我也是找人给 线下看了看解决了&#xff0c;我总结一下从头到尾排除问题&#xff0c;试到最后要是还解决不了你直接私信我&#xff0c;我给你看看…
阅读更多...
【TB作品】msp430g2553，读取ADXL345+读取DS18B20

【TB作品】msp430g2553，读取ADXL345+读取DS18B20

硬件 OLED ADXL345 msp430g2553 ds18b20 功能 //OLED 接线 /* NEW P2.0 CSP2.1 DCP2.2 RESP2.3 D1 SDAP2.4 D0 */ //ADXL345 接线 //只需要接五根线&#xff0c;其余乱七八糟的不用接 //P1.4接SCL //P1.5接SDA //3.3接3.3V //CS接3.3V //GND接GND // //执行到while1之后&a…
阅读更多...
路由策略实验1

路由策略实验1

先把地址全部配通 对R1 对R2 对R4 对R3 对R5 对R6 对R7 然后起路由协议 对R1 对R2 对R3 对R4 对R5 对R6 对R7
阅读更多...
C++17之std::void_t

C++17之std::void_t

目录 1.std::void_t 的原理 2.std::void_t 的应用 2.1.判断成员存在性 2.1.1.判断嵌套类型定义 2.1.2 判断成员是否存在 2.2 判断表达式是否合法 2.2.1 判断是否支持前置运算符 2.2.3 判断两个类型是否可做加法运算 3.std::void_t 与 std::enable_if 1.std::void_t 的…
阅读更多...
NAS的外网访问设置

NAS的外网访问设置

1.公网IP 2.备案域名 3.DDNS解析 4.光猫桥接路由器拨号上网 5.nginx证书accesskey 我使用在阿里云注册备案的域名&#xff0c;使用阿里云的DNS解析服务&#xff0c;使用阿里云提供的api实现DDNS解析。 在NAS中需要安装DNSSERVER插件并创建解析空间和解析域名。 在阿里云…
阅读更多...
猫头虎分享已解决Bug || **Eslint插件安装问题Unable to resolve eslint-plugin-猫头虎

猫头虎分享已解决Bug || **Eslint插件安装问题Unable to resolve eslint-plugin-猫头虎

猫头虎分享已解决Bug || **Eslint插件安装问题Unable to resolve eslint-plugin-猫头虎 博主猫头虎的技术世界 &#x1f31f; 欢迎来到猫头虎的博客 — 探索技术的无限可能&#xff01; 专栏链接&#xff1a; &#x1f517; 精选专栏&#xff1a; 《面试题大全》 — 面试准备的…
阅读更多...
将 py 文件编译成 pyd 文件

将 py 文件编译成 pyd 文件

文章目录 一、简介1.1、Python中的文件类型&#xff1a;.py .pyc .pyd1.2、基本原理1.2.1、函数详解&#xff1a;Extension() —— 用于定义扩展模块&#xff08;C/C 扩展&#xff09;的类1.2.2、函数详解&#xff1a;setup() —— 用于配置和构建包的函数 二、构建过程2.0、…
阅读更多...
百度文心一言API批量多线程写文章软件-key免费无限写

百度文心一言API批量多线程写文章软件-key免费无限写

百度文心大模型的两款主力模型ENIRE Speed、ENIRE Lite全面免费&#xff0c;即刻生效。 百度文心大模型的两款主力模型 这意味着&#xff0c;大模型已进入免费时代&#xff01; 据了解&#xff0c;这两款大模型发布于今年 3 月&#xff0c;支持 8K 和 128k 上下文长度。 ER…
阅读更多...
Java集合面试题（概述，list，Map）

Java集合面试题（概述，list，Map）

一个常见的"fail-safe"集合例子是CopyOnWriteArrayList。这个集合在每次修改时都会复制当前的数组&#xff0c;修改操作在新数组上进行&#xff0c;而遍历操作则在旧数组上进行。这样&#xff0c;即使在遍历过程中进行了修改&#xff0c;也不会影响遍历的进行。 插入…
阅读更多...
小程序的数据驱动和vue的双向绑定有何异同

小程序的数据驱动和vue的双向绑定有何异同

小程序的数据驱动和Vue的双向绑定在概念和应用上既有相似之处&#xff0c;也存在明显的差异。以下是它们之间的异同点&#xff1a; 相同点 数据驱动&#xff1a; 小程序和Vue都采用了数据驱动的方式&#xff0c;即将数据作为中心&#xff0c;通过更新数据来驱动视图的渲染。当…
阅读更多...
车载诊断内容汇总（培训＋视频）

车载诊断内容汇总（培训＋视频）

车载诊断内容汇总 我是穿拖鞋的汉子&#xff0c;魔都中坚持长期主义的汽车电子工程师。 老规矩&#xff0c;分享一段喜欢的文字&#xff0c;避免自己成为高知识低文化的工程师&#xff1a; 屏蔽力是信息过载时代一个人的特殊竞争力&#xff0c;任何消耗你的人和事&#xff0c…
阅读更多...
搭建USRP收发系统（1）

搭建USRP收发系统（1）

之前浅浅搭过一次&#xff0c;但是因为uhd、Ubuntu、gnuradio版本的问题&#xff0c;导致usrp断断续续地连接不上。于是打算重新弄一次。实验室里很多小伙伴都在做实验&#xff0c;所以我本次是在windowsUbuntu的双系统的基础上&#xff0c;再加一个Ubuntu系统。 参考安装Ubunt…
阅读更多...
pyopengl 立方体 正投影，透视投影

pyopengl 立方体 正投影，透视投影

目录 顶点和线的方式 划线的方式实现： 顶点和线的方式 import numpy as np from PyQt5 import QtWidgets from PyQt5.QtCore import Qt from PyQt5.QtWidgets import QApplication, QMainWindow, QPushButton from OpenGL.GL import * from OpenGL.GLU import * import sys…
阅读更多...
Java大文件上传、分片上传、多文件上传、断点续传、上传文件minio、分片上传minio等解决方案

Java大文件上传、分片上传、多文件上传、断点续传、上传文件minio、分片上传minio等解决方案

一、上传说明 文件上传花样百出&#xff0c;根据不同场景使用不同方案进行实现尤为必要。通常开发过程中&#xff0c;文件较小&#xff0c;直接将文件转化为字节流上传到服务器&#xff0c;但是文件较大时&#xff0c;用普通的方法上传&#xff0c;显然效果不是很好&#xff0c…
阅读更多...
【Unity脚本】修改游戏对象的活动状态

【Unity脚本】修改游戏对象的活动状态

【知识链】Unity -> Unity脚本 -> 游戏对象 -> 活动状态【摘要】本文介绍了如何通过编辑器和脚本来访问游戏对象的活动状态&#xff0c;并给出具体的场景示例。 文章目录 第一章 引言第二章 在编辑器中设置活动状态2.1. 在编辑器中设置活动状态2.1.1. 停用游戏对象2.…
阅读更多...
文件IO（三）

文件IO（三）

文件IO&#xff08;三&#xff09; 左移右移Linux的man 手册文件IO打开文件操作文件关闭文件 caps lock开灯关灯读取按键文件IO操作目录文件打开目录文件操作目录文件 库动态库和静态库的优缺点创建静态库创建动态库 按下右ctrl键 亮灭灯 左移右移 Linux的man 手册 文件IO 打开…
阅读更多...
FJSP：常春藤算法（Ivy algorithm，LVYA）求解柔性作业车间调度问题（FJSP），提供MATLAB代码

FJSP：常春藤算法（Ivy algorithm，LVYA）求解柔性作业车间调度问题（FJSP），提供MATLAB代码

详细介绍 FJSP&#xff1a;常春藤算法&#xff08;Ivy algorithm&#xff0c;LVYA&#xff09;求解柔性作业车间调度问题&#xff08;FJSP&#xff09;&#xff0c;提供MATLAB代码-CSDN博客 完整MATLAB代码 FJSP&#xff1a;常春藤算法&#xff08;Ivy algorithm&#xff0c;…
阅读更多...
最新文章

Copyright @ 2022~2023