环形字符源缓存代码

环形字符流缓存代码
对于频繁读写的字节流缓存，环形字节流可以重复使用空闲的内存，原理类似于环形队列。代码参考speex，代码已经经过测试使用。
/**  * @filecircular_buffer.cpp * @brief *  *  *  * @authoryswang * @version1.0 * @date2012年6月18日 *  * @see *  * @par 版本记录： * &lt;table border=1&gt; *  &lt;tr&gt; &lt;th&gt;版本&lt;th&gt;日期&lt;th&gt;作者&lt;th&gt;备注 &lt;/tr&gt; *  &lt;tr&gt; &lt;td&gt;1.0&lt;td&gt;2012年6月18日&lt;td&gt;yswang&lt;td&gt;创建 &lt;/tr&gt; * &lt;/table&gt; */#include &lt;stdlib.h&gt;#include "circular_buffer.h"#define dsound_alloc(size)\calloc(size, 1);\#define dsound_realloc(ptr, size)\realloc(ptr, size);\#define dsound_free(ptr)\free(ptr);\#define DSOUND_COPY(dst, src, n) (memcpy((dst), (src), (n)*sizeof(*(dst)) + 0*((dst)-(src)) ))#define DSOUND_MOVE(dst, src, n) (memmove((dst), (src), (n)*sizeof(*(dst)) + 0*((dst)-(src)) ))#define DSOUND_MEMSET(dst, c, n) (memset((dst), (c), (n)*sizeof(*(dst))))//////////////////////////////////////////////////////////////////////////struct circular_buffer_{char *data;int   size;       // 内存大小int   read_ptr; // 读指针int   write_ptr;  // 写指针int   available;  // 可读字节数(实际字节 write_ptr - read_ptr )};//////////////////////////////////////////////////////////////////////////circular_buffer * circular_buffer_init(int size){circular_buffer * st = dsound_alloc(sizeof(circular_buffer)); st-&gt;data = dsound_alloc(size);st-&gt;size = size;st-&gt;read_ptr = 0;st-&gt;write_ptr = 0;st-&gt;available = 0;return st;}void circular_buffer_destroy(circular_buffer *st){dsound_free(st-&gt;data);dsound_free(st);}int circular_buffer_write(circular_buffer *st, void * _data, int len){int end, end1; // 写后的位置int newlen;char * data = _data;if (len &gt; st-&gt;size - st-&gt;available)   // 大于剩余的空间（剩余空间不足，重新分配）{newlen = st-&gt;available + len;newlen *= 2; // 2倍空间，预留circular_buffer_resize(st, newlen);}end = st-&gt;write_ptr + len;end1 = end;if (end1 &gt; st-&gt;size)end1 = st-&gt;size;DSOUND_COPY(st-&gt;data + st-&gt;write_ptr, data, end1 - st-&gt;write_ptr);if (end &gt; st-&gt;size){end -= st-&gt;size;DSOUND_COPY(st-&gt;data, data + end1 - st-&gt;write_ptr, end);}st-&gt;available += len;st-&gt;write_ptr += len;if (st-&gt;write_ptr &gt; st-&gt;size)  // 保证指针在有效范围内st-&gt;write_ptr -= st-&gt;size;return len;}int circular_buffer_read(circular_buffer *st, void * _data, int len){int end, end1;   // 读取后的位置char * data = _data;if (len &gt; st-&gt;available)  // 读取有效的直接{//DSOUND_MEMSET(data + st-&gt;available, 0, st-&gt;size - st-&gt;available);len = st-&gt;available;}end = st-&gt;read_ptr + len;end1 = end;/* *||-------------|----------------------|| *               &######################& *   read_ptr  end1 *####&#####& *end  write_ptr **/if (end1 &gt; st-&gt;size)end1 = st-&gt;size;DSOUND_COPY(data, st-&gt;data + st-&gt;read_ptr, end1 - st-&gt;read_ptr);if (end &gt; st-&gt;size){end -= st-&gt;size;DSOUND_COPY(data + end1 - st-&gt;read_ptr, st-&gt;data, end);}st-&gt;available -= len;st-&gt;read_ptr += len;if (st-&gt;read_ptr &gt; st-&gt;size)    // 保证指针在有效范围内st-&gt;read_ptr -= st-&gt;size;return len;}int circular_buffer_get_available(circular_buffer *st){return st-&gt;available;}int circular_buffer_resize(circular_buffer *st, int len){int end, end1; char * data;int oldlen = st-&gt;size;data = dsound_alloc(len);if (!data)return -1;// 拷贝内存end = st-&gt;read_ptr + st-&gt;available;end1 = end;if (end1 &gt; st-&gt;size)end1 = st-&gt;size;DSOUND_COPY(data, st-&gt;data + st-&gt;read_ptr, end1 - st-&gt;read_ptr);if (end &gt; st-&gt;size){end -= st-&gt;size;DSOUND_COPY(data + end1 - st-&gt;read_ptr, st-&gt;data, end);}// 更新状态free(st-&gt;data);st-&gt;data = data;st-&gt;size = len;st-&gt;read_ptr = 0;st-&gt;write_ptr = st-&gt;available; return 0;}
环形字符源缓存代码

热点推荐
