/* 向环形buffer中写入数据 */
static rt_bool_t rb_put(struct rb* rb, const rt uint8_t *ptr, rt_uint16_t length)
{
    rt_size_t size;

    /* 判断是否有足够的剩余空间 */
    //图示的第一种情况，相减即为有效存储空间，就是中间那段空白区域了
    if (rb->read_index > rb->write_index) 
        size = rb->read_index - rb->write_index;
    else  // 图示的第二种情况，两段效存储空间之和
        size = rb->buffer_size - rb->write_index + rb->read_index;

    /* 没有多余的空间，即空间不足无法完成写入，直接返回错误 */
    if (size < length) return RT_FALSE;

    /* 以下均是指有效存储空间满足，可以完成写操作 */
    //图示的第一种情况，所以直接将数据从write_index处写入到buffer_ptr中即可
    if (rb->read_index > rb->write_index)  
    {
        /* read_index - write_index 即为总的空余空间
        * 关于memcpy, 指的是将prt中长度为length的数据拷贝到第一个参数所指的地址
        * 其实每次写入都必须是从write_index（写指针）开始，
        * 因为write_index是指向环形Buffer中的第一个可写缓冲区
        */
        memcpy(&rb->buffer_ptr[rb->write_index], ptr, length); 

        rb->write_index += length; //写操作完成后需要将写指针后移相应的长度
    }
    else //图示的第二种情况，有两段可用空间
    {
        //如果后半段空闲空间足够容纳，则直接拷贝即可
        if (rb->buffer_size - rb->write_index > length) 
        {
            memcpy(&rb->buffer_ptr[rb->write_index], ptr, length);
            rb->write_index += length; //写指针后移相应的长度
        }
        else //如果后半段空间不足，则先将后半段装满，然后再将剩余的装到前半段之中
        {
            /*
            * write_index 后面剩余的空间不存在足够的长度,
            * 需要把部分数据复制到前面的剩余空间中
            */
            //先塞满后半段，注意大小不是length，而是后半段的长度
            memcpy(&rb->buffer_ptr[rb->write index], ptr, rb->buffer_size - rb->write_index); 

            //此时只能从buffer_ptr的开始处进行写入了，长度为总长减去上次已经写入的
            memcpy(&rb->buffer_ptr[0], &ptr[rb->buffer_size - rb->write_index], length - (rb->buffer_size - rb->write_index)); 

            //写指针后移相应的长度，其实就是第二次写入的长度
            rb->write_index = length - (rb->buffer_size - rb->write_index); 
        }
    }
    return RT_TRUE;
}

对于读操作：

/* 从环形buffer中读出数据 */
static rt_bool_t rb_get(struct rb* rb, rt_uint8 t *ptr, rt_uint16_t length)
{
    rt_size_t size;

    /* 判断是否有足够的数据 */
    if (rb->read_index > rb->write_index) //图示的第一种情况，有效数据为前后两段的和
        size = rb->buffer_size - rb->read_index + rb->write_index;
    else // 图示的第二种情况， 中间一段为数据，直接相减即可
        size = rb->write_index - rb->read_index;

    /* 没有足够的数据，如果剩余数据不足，这直接返回错误 */
    if (size < length) return RT_FALSE;

    /* 以下均是指剩余数据量满足，可以完成读操作 */
    if (rb->read_index > rb->write_index) //图示的第一种情况，有两段数据
    {
        //如果后半段数据足够，则直接取用
        if (rb->buffer_size - rb->read_index > length) 
        {
            //这里是将buffer_ptr里面取出长度为length的数据放到ptr之中；
            //切记总是从read_index（读指针）开始取
            memcpy(ptr, &rb->buffer_ptr[rb->read_index], length); 

            rb->read_index += length; //读指针后移相应的长度
        }
        else //如果后半段不够用，则先取完后半段，然后从前半段取剩余的部分
        {
            /* read index的数据不够,需要分段复制 */
            //注意数据长度
            memcpy(ptr, &rb->buffer_ptr[rb->read index], rb->buffer_size - rb->read_index); 

            //注意数据长度和存储的起始位置
            memcpy(&ptr[rb->buffer_size - rb->read_index], &rb->buffer_ptr[0], length - rb->buffer_size + rb->read_index); 
            rb->read_index = length - rb->buffer_size + rb->read_index;
        }
    }
    else //图示的第二种情况，仅中间一段有数据，直接取用
    {
        memcpy(ptr, &rb->buffer_ptr[rb->read_index], length);
        rb->read_index += length; //读指针后移相应的长度
    }
    return RT_TRUE;
}

赞赏

长按二维码向我转账

受苹果公司新规定影响，微信 iOS 版的赞赏功能被关闭，可通过二维码转账支持公众号。