meshx_control_task.h

Go to the documentation of this file.

 
#ifndef __MESHX_CONTROL_TASK__
#define __MESHX_CONTROL_TASK__
 
#include "stdio.h"
#include "string.h"
#include "meshx_common.h"
#include "interface/rtos/meshx_task.h"
#include "interface/rtos/meshx_msg_q.h"
#include "interface/rtos/meshx_rtos_utils.h"

#define CONFIG_CONTROL_TASK_NAME        "meshx_control_task"

#ifndef CONFIG_CONTROL_TASK_PRIO
#define CONFIG_CONTROL_TASK_PRIO        configTIMER_TASK_PRIORITY + 1
#endif

#ifndef CONFIG_CONTROL_TASK_STACK_SIZE
#define CONFIG_CONTROL_TASK_STACK_SIZE  4096
#endif

#ifndef CONFIG_CONTROL_TASK_QUEUE_LEN
#define CONFIG_CONTROL_TASK_QUEUE_LEN   10
#endif

typedef enum control_task_msg_code
{
    CONTROL_TASK_MSG_CODE_EL_STATE_CH,  
    CONTROL_TASK_MSG_CODE_SYSTEM,       
    CONTROL_TASK_MSG_CODE_TO_BLE,       
    CONTROL_TASK_MSG_CODE_FRM_BLE,      
    CONTROL_TASK_MSG_CODE_CONFIG,       
    CONTROL_TASK_MSG_CODE_PROVISION,    
    CONTROL_TASK_MSG_CODE_TO_APP,       
    CONTROL_TASK_MSG_CODE_TO_MESHX,     
    CONTROL_TASK_MSG_CODE_TXCM,         
    CONTROL_TASK_MSG_CODE_MAX,          
} control_task_msg_code_t;

typedef uint32_t control_task_msg_evt_t;

typedef enum __packed control_task_msg_evt_to_app_meshx
{
    CONTROL_TASK_MSG_EVT_DATA = MESHX_BIT(0),   
    CONTROL_TASK_MSG_EVT_CTRL = MESHX_BIT(1),   
    CONTROL_TASK_MSG_EVT_MAX,           
} control_task_msg_evt_to_app_meshx_t;

typedef enum __packed control_task_msg_evt_el_state_ch
{
    CONTROL_TASK_MSG_EVT_EL_STATE_CH_SET_ON_OFF      = MESHX_BIT(0), 
    CONTROL_TASK_MSG_EVT_EL_STATE_CH_SET_CTL         = MESHX_BIT(1), 
    CONTROL_TASK_MSG_EVT_EL_STATE_CH_MAX,                    
} control_task_msg_evt_el_state_ch_t;

typedef enum __packed control_task_msg_evt_to_ble
{
    /* To Client related events */
    CONTROL_TASK_MSG_EVT_TO_BLE_SET_ON_OFF      = MESHX_BIT(0), 
    CONTROL_TASK_MSG_EVT_TO_BLE_SET_CTL         = MESHX_BIT(1), 
    CONTROL_TASK_MSG_EVT_TO_BLE_SET_LIGHTNESS   = MESHX_BIT(2), 
 
    /* To server events */
    CONTROL_TASK_MSG_EVT_TO_BLE_SET_ON_OFF_SRV  = MESHX_BIT(16),
    CONTROL_TASK_MSG_EVT_TO_BLE_SET_CTL_SRV     = MESHX_BIT(17),
    CONTROL_TASK_MSG_EVT_TO_BLE_MAX                     
} control_task_msg_evt_to_ble_t;

typedef enum __packed control_task_msg_evt_system
{
    CONTROL_TASK_MSG_EVT_SYSTEM_RESTART      = MESHX_BIT(0),    
    CONTROL_TASK_MSG_EVT_SYSTEM_TIMER_ARM    = MESHX_BIT(1),    
    CONTROL_TASK_MSG_EVT_SYSTEM_TIMER_REARM  = MESHX_BIT(2),    
    CONTROL_TASK_MSG_EVT_SYSTEM_TIMER_DISARM = MESHX_BIT(3),    
    CONTROL_TASK_MSG_EVT_SYSTEM_TIMER_FIRE   = MESHX_BIT(4),    
    CONTROL_TASK_MSG_EVT_SYSTEM_TIMER_PERIOD = MESHX_BIT(5),    
    CONTROL_TASK_MSG_EVT_SYSTEM_MAX,                    
} control_task_msg_evt_system_t;

typedef enum __packed control_task_msg_evt_config
{
    CONTROL_TASK_MSG_EVT_APP_KEY_ADD        = MESHX_BIT(0), 
    CONTROL_TASK_MSG_EVT_APP_KEY_DEL        = MESHX_BIT(1), 
    CONTROL_TASK_MSG_EVT_APP_KEY_BIND       = MESHX_BIT(2), 
    CONTROL_TASK_MSG_EVT_APP_KEY_UNBIND     = MESHX_BIT(3), 
    CONTROL_TASK_MSG_EVT_SUB_ADD            = MESHX_BIT(4), 
    CONTROL_TASK_MSG_EVT_SUB_DEL            = MESHX_BIT(5), 
    CONTROL_TASK_MSG_EVT_PUB_ADD            = MESHX_BIT(6), 
    CONTROL_TASK_MSG_EVT_PUB_DEL            = MESHX_BIT(7), 
    CONTROL_TASK_MSG_EVT_NET_KEY_ADD        = MESHX_BIT(8), 
    CONTROL_TASK_MSG_EVT_NET_KEY_DEL        = MESHX_BIT(9), 
    CONTROL_TASK_MSG_EVT_CONFIG_ALL         = 0xFF, 
} control_task_msg_evt_config_t;

typedef enum __packed control_task_msg_evt_provision
{
    CONTROL_TASK_MSG_EVT_PROVISION_STOP         = MESHX_BIT(1), 
    CONTROL_TASK_MSG_EVT_IDENTIFY_START         = MESHX_BIT(2), 
    CONTROL_TASK_MSG_EVT_IDENTIFY_STOP          = MESHX_BIT(3), 
    CONTROL_TASK_MSG_EVT_NODE_RESET             = MESHX_BIT(4), 
    CONTROL_TASK_MSG_EVT_PROXY_CONNECT          = MESHX_BIT(5), 
    CONTROL_TASK_MSG_EVT_PROXY_DISCONN          = MESHX_BIT(6), 
    CONTROL_TASK_MSG_EVT_EN_NODE_PROV           = MESHX_BIT(7), 
    CONTROL_TASK_MSG_EVT_SYSTEM_FRESH_BOOT      = MESHX_BIT(8), 
    CONTROL_TASK_MSG_EVT_PROVISION_ALL          = 0xFFFF, 
} control_task_msg_evt_provision_t;

typedef enum __packed control_task_msg_evt_txcm
{
    CONTROL_TASK_MSG_EVT_TXCM_MSG_TIMEOUT   = MESHX_BIT(1), 
    CONTROL_TASK_MSG_EVT_TXCM_MAX
}control_task_msg_evt_txcm_t;

typedef meshx_err_t (*control_task_msg_handle_t)(dev_struct_t *pdev, control_task_msg_evt_t evt, void *params);

typedef struct control_task_msg
{
    control_task_msg_code_t msg_code; 
    control_task_msg_evt_t msg_evt;   
    void *msg_evt_params;             
} control_task_msg_t;

typedef struct control_task_evt_cb_reg
{
    uint32_t msg_evt_bmap;                     
    control_task_msg_handle_t cb;              
    struct control_task_evt_cb_reg * next;     
} control_task_evt_cb_reg_t;

meshx_err_t create_control_task(dev_struct_t * pdev);

meshx_err_t control_task_msg_subscribe(control_task_msg_code_t msg_code, control_task_msg_evt_t evt_bmap, control_task_msg_handle_t callback);

meshx_err_t control_task_msg_unsubscribe(control_task_msg_code_t msg_code, control_task_msg_evt_t evt_bmap, control_task_msg_handle_t callback);

meshx_err_t control_task_msg_publish(control_task_msg_code_t msg_code, control_task_msg_evt_t msg_evt, const void *msg_evt_params, size_t sizeof_msg_evt_params);
 
#endif /* __MESHX_CONTROL_TASK__ */