cs_MeshModelUnicast.h

Go to the documentation of this file.

/*
 * Author: Crownstone Team
 * Copyright: Crownstone (https://crownstone.rocks)
 * Date: Mar 10, 2020
 * License: LGPLv3+, Apache License 2.0, and/or MIT (triple-licensed)
 */
 
#pragma once
 
#include <cfg/cs_Config.h>
#include <mesh/cs_MeshCommon.h>
#include <protocol/mesh/cs_MeshModelPackets.h>
#include <third/std/function.h>
 
extern "C" {
#include <access_reliable.h>
}
 
class MeshModelUnicast {
public:
    typedef function<void(MeshMsgEvent& msg)> callback_msg_t;
 
    void registerMsgHandler(const callback_msg_t& closure);
 
    void init(uint16_t modelId);
 
    void configureSelf(dsm_handle_t appkeyHandle);
 
    cs_ret_code_t addToQueue(MeshUtil::cs_mesh_queue_item_t& item);
 
    cs_ret_code_t remFromQueue(cs_mesh_model_msg_type_t type, uint16_t id);
 
    void tick(uint32_t tickCount);
 
    void handleMsg(const access_message_rx_t* accessMsg);
 
    void handleReliableStatus(access_reliable_status_t status);
 
private:
    const static uint8_t QUEUE_SIZE       = 5;
 
    const static uint8_t QUEUE_INDEX_NONE = 255;
 
    struct __attribute__((__packed__)) cs_unicast_queue_item_t {
        MeshUtil::cs_mesh_queue_item_meta_data_t metaData;
        stone_id_t targetId;
        cs_control_cmd_t controlCommand;
        uint8_t msgSize;
        uint8_t* msgPtr = nullptr;
    };
 
    access_model_handle_t _accessModelHandle = ACCESS_HANDLE_INVALID;
 
    dsm_handle_t _publishAddressHandle       = DSM_HANDLE_INVALID;
 
    callback_msg_t _msgCallback              = nullptr;
 
    access_reliable_t _accessReliableMsg;
 
#if MESH_MODEL_TEST_MSG == 2
    uint32_t _acked    = 0;
    uint32_t _timedout = 0;
    uint32_t _canceled = 0;
#endif
 
    cs_unicast_queue_item_t _queue[QUEUE_SIZE];
 
    uint8_t _queueIndexInProgress = QUEUE_INDEX_NONE;
 
    uint8_t _queueIndexNext       = 0;
 
    uint8_t _reliableStatus       = 255;
 
    bool _replyReceived           = false;
 
    uint8_t _ttl                  = CS_MESH_DEFAULT_TTL;
 
    void cancelQueueItem(uint8_t index);
 
    void remQueueItem(uint8_t index);
 
    void processQueue();
 
    int getNextItemInQueue(bool priority);
 
    bool sendMsgFromQueue();
 
    void checkDone();
 
    cs_ret_code_t sendMsg(const uint8_t* msg, uint16_t msgSize, uint32_t timeoutUs);
 
    cs_ret_code_t sendReply(const access_message_rx_t* accessMsg, const uint8_t* msg, uint16_t msgSize);
 
    cs_ret_code_t setPublishAddress(stone_id_t id);
 
    cs_ret_code_t setTtl(uint8_t ttl, bool temp = false);
 
    void sendFailedResultToUart(cs_unicast_queue_item_t& item, cs_ret_code_t retCode);
};