首页 / 缓存 / nordic mesh中的消息缓存实现

nordic mesh中的消息缓存实现

内容导读

互联网集市收集整理的这篇技术教程文章主要介绍了nordic mesh中的消息缓存实现，小编现在分享给大家，供广大互联网技能从业者学习和参考。文章包含2412字，纯文字阅读大概需要4分钟。

内容图文

nordic mesh中的消息缓存实现

代码文件msg_cache.h、msg_cache.c。

接口定义

头文件中定义了四个接口，供mesh协议栈调用，四个接口如下所示，接口的实现代码在msg_cache.c文件中。

            @file：msg_cache.h

// 消息缓存初始化void msg_cache_init(void);

// 检查消息是否存在
bool msg_cache_entry_exists(uint16_t src_addr, uint32_t sequence_number);

// 添加消息到缓存void msg_cache_entry_add(uint16_t src, uint32_t seq);

// 消息缓存清空void msg_cache_clear(void);

实现代码

消息缓存用静态全局变量的一个数组m_msg_cache[]实现，该数组长度为32，数组每个元素表示消息。m_msg_cache_head表示新消息加入的位置，通过对m_msg_cache_head的控制实现一个环形的消息缓存。

其结构定义如下：

            
                typedef
                struct
{
    bool allocated;  /**< Whether the entry is in use. */uint16_t src;    /**< Source address from packet header. */uint32_t seq;    /**< Sequence number from the packet header. */
} msg_cache_entry_t;

/** Message cache buffer */static msg_cache_entry_t m_msg_cache[MSG_CACHE_ENTRY_COUNT];

/** Message cache head index  *  新消息的加入位置 */staticuint32_t m_msg_cache_head = 0;

由缓存结构可知，消息缓存结构只是保存了消息的源地址及其序列号。收到消息时，先在消息缓存中检查是否已有该消息，若不存在则添加进去，否则忽略消息。

由于蓝牙mesh是基于泛洪管理网络的，所以某个节点会收到多条相同的消息（每个节点会中继转发消息），消息缓存主要用判断是否已收到该消息，用来避免消息拥塞。

msg_cache_init()

消息缓存初始化代码如下，就是将消息缓存数组的各元素设置为可用状态。

            
                void msg_cache_init(void)
{
    for (uint32_t i = 0; i < MSG_CACHE_ENTRY_COUNT; ++i)
    {
        m_msg_cache[i].src = NRF_MESH_ADDR_UNASSIGNED;
        m_msg_cache[i].seq = 0;
        m_msg_cache[i].allocated = 0;
    }

    m_msg_cache_head = 0;
}

msg_cache_entry_exists()

判断消息是否已经存在，从m_msg_cache_head的位置开始逆序遍历整个消息缓存数组，逐个对比源地址及序列号

            
bool msg_cache_entry_exists(uint16_t src_addr, uint32_t sequence_number)
{
    /* Search backwards from head */uint32_t entry_index = m_msg_cache_head;
    for (uint32_t i = 0; i < MSG_CACHE_ENTRY_COUNT; ++i)
    {
        if (entry_index-- == 0) /* compare before subtraction */
        {
            entry_index = MSG_CACHE_ENTRY_COUNT - 1;
        }

        if (!m_msg_cache[entry_index].allocated)
        {
            return false; /* Gone past the last valid entry. */
        }

        if (m_msg_cache[entry_index].src == src_addr &&
            m_msg_cache[entry_index].seq == sequence_number)
        {
            return true;
        }
    }

    return false;
}

msg_cache_entry_add()

消息添加到缓存

            
                void msg_cache_entry_add(uint16_t src, uint32_t seq)
{
    m_msg_cache[m_msg_cache_head].src = src;
    m_msg_cache[m_msg_cache_head].seq = seq;
    m_msg_cache[m_msg_cache_head].allocated = true;

    if ((++m_msg_cache_head) == MSG_CACHE_ENTRY_COUNT)
    {
        m_msg_cache_head = 0;
    }
}

msg_cache_clear()

清空消息缓存

            
                void msg_cache_clear(void)
{
    for (uint32_t i = 0; i < MSG_CACHE_ENTRY_COUNT; ++i)
    {
        m_msg_cache[i].allocated = 0;
    }
}

原文：https://www.cnblogs.com/gexin/p/9070979.html

内容总结

以上是互联网集市为您收集整理的nordic mesh中的消息缓存实现全部内容，希望文章能够帮你解决nordic mesh中的消息缓存实现所遇到的程序开发问题。 如果觉得互联网集市技术教程内容还不错，欢迎将互联网集市网站推荐给程序员好友。

内容备注

版权声明：本文内容由互联网用户自发贡献，该文观点与技术仅代表作者本人。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容， 请发送邮件至 gblab@vip.qq.com 举报，一经查实，本站将立刻删除。

内容手机端

扫描二维码推送至手机访问。

本文链接：https://qyyshop.com/info/1174958.html

来源：【匿名】