使用循环缓冲区,可以避免重复的分配内存,释放内存,也可以解决多个进场同时读写的问题。
1、定义一个缓冲数据结构。
#define MAX_RECV_BUF_LEN 1024*512 //定义缓冲区大小
#define BUFFER_HEAD_SIZE 8
//视频数据缓存区
typedef struct{
Data pBuffer[MAX_RECV_BUF_LEN];//用来接收的
uint nReadPos;
uint nWritePos;
}T_RECV_BUFFER;
static T_RECV_BUFFER tRecvBuffer;//定义一个缓冲变量
2、写入数据
+ (int)writeRecvBuffer:(uint8_t*)recvBuffer writeLen:(int)length{
if(recvBuffer ==NULL){
return -1;
}
int tailSize = MAX_RECV_BUF_LEN -tRecvBuffer.nWritePos;
if(length <= tailSize){
memcpy(&tRecvBuffer.recvBuffer[tRecvBuffer.nWritePos], recvBuffer, length);
tMediaRecvBuffer.nWritePos += length;
}else{//写入长度+写入位置 >缓冲
//如果写入数据的位置加长度超过最大缓冲,
//则先保存 写指针位置到MAX_RECV_BUF_LEN,再保存超出长度的数据。
memcpy(&tRecvBuffer.recvBuffer[tRecvBuffer.nWritePos], recvBuffer, tailSize);
memcpy(&tRecvBuffer.recvBuffer[0], &recvBuffer[tailSize], (length - tailSize));
tRecvBuffer.nWritePos = length - tailSize;
}
return0;
}
3、读取数据
+ (int)readRecvBuffer:(uint8_t*)copyRecvBuffer readLen:(int)length{
int tailSize =MAX_RECV_BUF_LEN -tRecvBuffer.nReadPos;
if( length > tailSize){
//如果读取的长度超出 MAX_RECV_BUF_LEN-读指针位置
//则先拷贝 读指针位置到MAX_RECV_BUF_LEN,再拷贝超出长度的数据。
memcpy(copyRecvBuffer, &tRecvBuffer.recvBuffer[tRecvBuffer.nReadPos], tailSize);
memcpy(©RecvBuffer[MAX_RECV_BUF_LEN -tRecvBuffer.nReadPos], &tRecvBuffer.recvBuffer[0], length - tailSize);
tRecvBuffer.nReadPos = length - tailSize;
}else{
memcpy(copyRecvBuffer, &tRecvBuffer.recvBuffer[tRecvBuffer.nReadPos], length);
tRecvBuffer.nReadPos += length;
}
return0;
}