安信可（云知声蜂鸟US516P6）SDK开发学习--databuf封装管理

业界资讯 2023-06-19 06:13:40 阅读次数: 0

安信可（云知声蜂鸟US516P6）SDK开发学习–databuf封装管理

在实际应用中，部分内存区域需要不断使用，但每次去申请释放容易产生碎片。故申请一次，后续使用常规内存管理的方式对该malloc出来的区域进行管理，无需要重新申请释放。称之为buff

如音频播放需要的buf

static void _databuf_create(void) {
    
    
  uni_s32 size = g_audio_player.pcm_frame_size * PCM_BUF_FRAMES;
  g_audio_player.databuf_handle = DataBufferCreate(size);
}

具体实现uni_databuf.c

/**************************************************************************
 * Copyright (C) 2017-2017  Unisound
 *
 * This program is free software; you can redistribute it and/or modify
 * it under the terms of the GNU General Public License as published by
 * the Free Software Foundation; either version 2 of the License, or
 * any later version.
 *
 * This program is distributed in the hope that it will be useful,
 * but WITHOUT ANY WARRANTY; without even the implied warranty of
 * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
 * GNU General Public License for more details.
 *
 * You should have received a copy of the GNU General Public License along
 * with this program; if not, write to the Free Software Foundation, Inc.,
 * 51 Franklin Street, Fifth Floor, Boston, MA 02110-1301 USA.
 **************************************************************************
 *
 * Description : uni_databuf.c
 * Author      : shangjinlong.unisound.com
 * Date        : 2018.06.19
 *
 **************************************************************************/
#include "uni_databuf.h"
#include "uni_iot.h"
#include "uni_log.h"

#define DATABUF_FILL_BYTE_SIZE   (1)
#define DATA_BUF_ATTR_READ       (1 << 0)
#define DATA_BUF_ATTR_SYNC       (1 << 1)
#define DATA_BUF_ATTR_WRITE      (1 << 2)

#define DATABUF_TAG "data_buf"

typedef int DataBufferAttr;

typedef struct {
    
    
  int  size;
  char *buf;
  int  head, tail;
} DataBuf;

static DataBuf *_create_data_buf(void) {
    
    
  DataBuf *data_buf = (DataBuf *)uni_malloc(sizeof(DataBuf));
  if (NULL == data_buf) {
    
    
    LOGE(DATABUF_TAG, "malloc failed !");
    return NULL;
  }
  data_buf->head = data_buf->tail = 0;
  return data_buf;
}

static int _get_data_size(DataBuf *data_buf) {
    
    
  return (data_buf->head + data_buf->size - data_buf->tail) % data_buf->size;
}

static int _get_free_size(DataBuf *data_buf) {
    
    
  return data_buf->size - _get_data_size(data_buf) - DATABUF_FILL_BYTE_SIZE;
}

static int _init_data_buf(void *data_buf, int size) {
    
    
  DataBuf *buf = (DataBuf *)data_buf;
  buf->size = size + DATABUF_FILL_BYTE_SIZE;
  buf->buf = (char *)uni_malloc(size + DATABUF_FILL_BYTE_SIZE);
  if (NULL == buf->buf) {
    
    
    LOGE(DATABUF_TAG, "malloc failed !");
    return -1;
  }
  buf->head = buf->tail = 0;
  return 0;
}

static inline int _read_attr_setted(DataBufferAttr attr) {
    
    
  return ((attr & DATA_BUF_ATTR_READ) == 0 ? 0 : 1);
}

static inline int _write_attr_setted(DataBufferAttr attr) {
    
    
  return ((attr & DATA_BUF_ATTR_WRITE) == 0 ? 0 : 1);
}

static inline int _sync_attr_setted(DataBufferAttr attr) {
    
    
  return ((attr & DATA_BUF_ATTR_SYNC) == 0 ? 0 : 1);
}

static inline int _read_length_overflow(DataBuf *data_buf, int readlen) {
    
    
  return _get_data_size(data_buf) < readlen;
}

static inline int _write_length_overflow(DataBuf *data_buf, int writelen) {
    
    
  return _get_free_size(data_buf) < writelen;
}

static int _read_internal(DataBufHandle handle, char *buf, int size,
                          DataBufferAttr attr) {
    
    
  DataBuf *data_buf = (DataBuf *)handle;
  int pos;
  pos = (data_buf->tail + size) % data_buf->size;
  if (_read_attr_setted(attr)) {
    
    
    if (pos >= data_buf->tail) {
    
    
      uni_memcpy(buf, data_buf->buf + data_buf->tail, size);
    } else {
    
    
      int remain = (data_buf->size - data_buf->tail);
      uni_memcpy(buf, data_buf->buf + data_buf->tail, remain);
      uni_memcpy(buf + remain, data_buf->buf, size - remain);
    }
  }
  if (_sync_attr_setted(attr)) {
    
    
    data_buf->tail = pos;
  }
  return size;
}

static int _write_internal(DataBufHandle handle, char *buf, int size,
                           DataBufferAttr attr) {
    
    
  DataBuf *data_buf = (DataBuf *)handle;
  int pos;
  pos = (data_buf->head + size) % data_buf->size;
  if (_write_attr_setted(attr)) {
    
    
    if (pos >= data_buf->head) {
    
    
      uni_memcpy(data_buf->buf + data_buf->head, buf, size);
    } else {
    
    
      int remain = (data_buf->size - data_buf->head);
      uni_memcpy(data_buf->buf + data_buf->head, buf, remain);
      uni_memcpy(data_buf->buf, buf + remain, size - remain);
    }
  }
  if (_sync_attr_setted(attr)) {
    
    
    data_buf->head = pos;
  }
  return size;
}

DataBufHandle DataBufferCreate(int size) {
    
    
  DataBuf *data_buf;
  if (size <= 0) {
    
    
    LOGE(DATABUF_TAG, "invalid input size = %d", size);
    return (DataBufHandle)NULL;
  }
  data_buf = _create_data_buf();
  if (0 != _init_data_buf(data_buf, size)) {
    
    
    uni_free(data_buf);
    return NULL;
  }
  return (DataBufHandle)data_buf;
}

int DataBufferDestroy(DataBufHandle handle) {
    
    
  DataBuf *data_buf = (DataBuf *)handle;
  uni_free(data_buf->buf);
  uni_free(data_buf);
  return 0;
}

static int _data_buffer_read(char *dst, int readlen, DataBufHandle handle,
                             DataBufferAttr attr) {
    
    
  if (_read_length_overflow((DataBuf *)handle, readlen)) {
    
    
    return -1;
  }
  return _read_internal(handle, dst, readlen, attr);
}

static int _data_buffer_write(DataBufHandle handle, char *src, int writelen,
                              DataBufferAttr attr) {
    
    
  if (_write_length_overflow((DataBuf *)handle, writelen)) {
    
    
    return -1;
  }
  return _write_internal(handle, src, writelen, attr);
}

int DataBufferClear(DataBufHandle handle) {
    
    
  DataBuf *data_buf = (DataBuf *)handle;
  data_buf->head = data_buf->tail = 0;
  return 0;
}

int DataBufferGetFreeSize(DataBufHandle handle) {
    
    
  DataBuf *data_buf = (DataBuf *)handle;
  return _get_free_size(data_buf);
}

int DataBufferGetDataSize(DataBufHandle handle) {
    
    
  DataBuf *data_buf = (DataBuf *)handle;
  return _get_data_size(data_buf);
}

int DataBufferPeek(char *dst, int readlen, DataBufHandle handle) {
    
    
  return _data_buffer_read(dst, readlen, handle, DATA_BUF_ATTR_READ);
}

int DataBufferWrite(DataBufHandle handle, char *src, int writelen) {
    
    
  return _data_buffer_write(handle, src, writelen,
                            DATA_BUF_ATTR_WRITE | DATA_BUF_ATTR_SYNC);
}

int DataBufferRead(char *dst, int readlen, DataBufHandle handle) {
    
    
  return _data_buffer_read(dst, readlen, handle,
                           DATA_BUF_ATTR_READ | DATA_BUF_ATTR_SYNC);
}

.h

/**************************************************************************
 * Copyright (C) 2017-2017  Unisound
 *
 * This program is free software; you can redistribute it and/or modify
 * it under the terms of the GNU General Public License as published by
 * the Free Software Foundation; either version 2 of the License, or
 * any later version.
 *
 * This program is distributed in the hope that it will be useful,
 * but WITHOUT ANY WARRANTY; without even the implied warranty of
 * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
 * GNU General Public License for more details.
 *
 * You should have received a copy of the GNU General Public License along
 * with this program; if not, write to the Free Software Foundation, Inc.,
 * 51 Franklin Street, Fifth Floor, Boston, MA 02110-1301 USA.
 **************************************************************************
 *
 * Description : uni_databuf.c
 * Author      : shangjinlong.unisound.com
 * Date        : 2018.06.19
 *
 **************************************************************************/
#include "uni_databuf.h"
#include "uni_iot.h"
#include "uni_log.h"

#define DATABUF_FILL_BYTE_SIZE   (1)
#define DATA_BUF_ATTR_READ       (1 << 0)
#define DATA_BUF_ATTR_SYNC       (1 << 1)
#define DATA_BUF_ATTR_WRITE      (1 << 2)

#define DATABUF_TAG "data_buf"

typedef int DataBufferAttr;

typedef struct {
    
    
  int  size;
  char *buf;
  int  head, tail;
} DataBuf;

static DataBuf *_create_data_buf(void) {
    
    
  DataBuf *data_buf = (DataBuf *)uni_malloc(sizeof(DataBuf));
  if (NULL == data_buf) {
    
    
    LOGE(DATABUF_TAG, "malloc failed !");
    return NULL;
  }
  data_buf->head = data_buf->tail = 0;
  return data_buf;
}

static int _get_data_size(DataBuf *data_buf) {
    
    
  return (data_buf->head + data_buf->size - data_buf->tail) % data_buf->size;
}

static int _get_free_size(DataBuf *data_buf) {
    
    
  return data_buf->size - _get_data_size(data_buf) - DATABUF_FILL_BYTE_SIZE;
}

static int _init_data_buf(void *data_buf, int size) {
    
    
  DataBuf *buf = (DataBuf *)data_buf;
  buf->size = size + DATABUF_FILL_BYTE_SIZE;
  buf->buf = (char *)uni_malloc(size + DATABUF_FILL_BYTE_SIZE);
  if (NULL == buf->buf) {
    
    
    LOGE(DATABUF_TAG, "malloc failed !");
    return -1;
  }
  buf->head = buf->tail = 0;
  return 0;
}

static inline int _read_attr_setted(DataBufferAttr attr) {
    
    
  return ((attr & DATA_BUF_ATTR_READ) == 0 ? 0 : 1);
}

static inline int _write_attr_setted(DataBufferAttr attr) {
    
    
  return ((attr & DATA_BUF_ATTR_WRITE) == 0 ? 0 : 1);
}

static inline int _sync_attr_setted(DataBufferAttr attr) {
    
    
  return ((attr & DATA_BUF_ATTR_SYNC) == 0 ? 0 : 1);
}

static inline int _read_length_overflow(DataBuf *data_buf, int readlen) {
    
    
  return _get_data_size(data_buf) < readlen;
}

static inline int _write_length_overflow(DataBuf *data_buf, int writelen) {
    
    
  return _get_free_size(data_buf) < writelen;
}

static int _read_internal(DataBufHandle handle, char *buf, int size,
                          DataBufferAttr attr) {
    
    
  DataBuf *data_buf = (DataBuf *)handle;
  int pos;
  pos = (data_buf->tail + size) % data_buf->size;
  if (_read_attr_setted(attr)) {
    
    
    if (pos >= data_buf->tail) {
    
    
      uni_memcpy(buf, data_buf->buf + data_buf->tail, size);
    } else {
    
    
      int remain = (data_buf->size - data_buf->tail);
      uni_memcpy(buf, data_buf->buf + data_buf->tail, remain);
      uni_memcpy(buf + remain, data_buf->buf, size - remain);
    }
  }
  if (_sync_attr_setted(attr)) {
    
    
    data_buf->tail = pos;
  }
  return size;
}

static int _write_internal(DataBufHandle handle, char *buf, int size,
                           DataBufferAttr attr) {
    
    
  DataBuf *data_buf = (DataBuf *)handle;
  int pos;
  pos = (data_buf->head + size) % data_buf->size;
  if (_write_attr_setted(attr)) {
    
    
    if (pos >= data_buf->head) {
    
    
      uni_memcpy(data_buf->buf + data_buf->head, buf, size);
    } else {
    
    
      int remain = (data_buf->size - data_buf->head);
      uni_memcpy(data_buf->buf + data_buf->head, buf, remain);
      uni_memcpy(data_buf->buf, buf + remain, size - remain);
    }
  }
  if (_sync_attr_setted(attr)) {
    
    
    data_buf->head = pos;
  }
  return size;
}

DataBufHandle DataBufferCreate(int size) {
    
    
  DataBuf *data_buf;
  if (size <= 0) {
    
    
    LOGE(DATABUF_TAG, "invalid input size = %d", size);
    return (DataBufHandle)NULL;
  }
  data_buf = _create_data_buf();
  if (0 != _init_data_buf(data_buf, size)) {
    
    
    uni_free(data_buf);
    return NULL;
  }
  return (DataBufHandle)data_buf;
}

int DataBufferDestroy(DataBufHandle handle) {
    
    
  DataBuf *data_buf = (DataBuf *)handle;
  uni_free(data_buf->buf);
  uni_free(data_buf);
  return 0;
}

static int _data_buffer_read(char *dst, int readlen, DataBufHandle handle,
                             DataBufferAttr attr) {
    
    
  if (_read_length_overflow((DataBuf *)handle, readlen)) {
    
    
    return -1;
  }
  return _read_internal(handle, dst, readlen, attr);
}

static int _data_buffer_write(DataBufHandle handle, char *src, int writelen,
                              DataBufferAttr attr) {
    
    
  if (_write_length_overflow((DataBuf *)handle, writelen)) {
    
    
    return -1;
  }
  return _write_internal(handle, src, writelen, attr);
}

int DataBufferClear(DataBufHandle handle) {
    
    
  DataBuf *data_buf = (DataBuf *)handle;
  data_buf->head = data_buf->tail = 0;
  return 0;
}

int DataBufferGetFreeSize(DataBufHandle handle) {
    
    
  DataBuf *data_buf = (DataBuf *)handle;
  return _get_free_size(data_buf);
}

int DataBufferGetDataSize(DataBufHandle handle) {
    
    
  DataBuf *data_buf = (DataBuf *)handle;
  return _get_data_size(data_buf);
}

int DataBufferPeek(char *dst, int readlen, DataBufHandle handle) {
    
    
  return _data_buffer_read(dst, readlen, handle, DATA_BUF_ATTR_READ);
}

int DataBufferWrite(DataBufHandle handle, char *src, int writelen) {
    
    
  return _data_buffer_write(handle, src, writelen,
                            DATA_BUF_ATTR_WRITE | DATA_BUF_ATTR_SYNC);
}

int DataBufferRead(char *dst, int readlen, DataBufHandle handle) {
    
    
  return _data_buffer_read(dst, readlen, handle,
                           DATA_BUF_ATTR_READ | DATA_BUF_ATTR_SYNC);
}

猜你喜欢

转载自blog.csdn.net/xushx_bigbear/article/details/130880586
今日推荐
fl studio v20.8中文破解版(附Crack文件+图文安装教程)
AI驱动TDSQL-C Serverless 数据库技术实战营-电商可视分析
828华为云征文 | 将Vue项目部署到Flexus云服务器X实例并实现公网访问
Java毕业设计：Java江西南昌城市文化展示网站系统毕业设计源代码作品和开题报告
开源日报 | 字节计划使用华为芯片训练新的AI模型；苹果明年可能推出homeOS；加州否决AI安全法案；扎克伯格的Wi-Fi密码
“AI 教母”李飞飞最新对话：当空间智能技术成熟时，机器人革命即将开始
OpenAI 融资 66 亿美元，估值达 1570 亿美元
AI小程序有哪些？AI小程序哪个好用？微信小程序AI写作叫什么？免费的ai小程序推荐 ai写作小程序推荐
灵办AI工具(科研学术,代码编程,学习辅导,图书报告)功能介绍
Linux内核源码分析（非常详细）零基础入门到精通，收藏这一篇就够了
【C++篇】启航——初识C++（上篇）
数据飞轮崛起：数据中台真的过时了吗？
周排行
java服务too many open files
指针变量所占的字节数
Linux 入门篇一（linux基本命令简介，linux系统简介，基本知识点）
VISIO标准图-EPC
BST，BVL，二叉排序树与平衡二叉树
Zabbix 自动发现端口&监控
ubuntu18.04 sumo安装 及 traci通信
ROS UVC相机标定和图像矫正
通过 SSH 连接 VirtualBox 中的 CentOS
Nginx的平滑升级
每日归档
更多
2024-10-05(62)
2024-10-04(63)
2024-10-03(2)
2024-10-02(60)
2024-10-01(0)
2024-09-30(0)
2024-09-29(0)
2024-09-28(4)
2024-09-27(60)
2024-09-26(0)

代码天地 © 2018 codetd.com

境外服务器   最新电视剧2022