来自中央控制物联网MSK DA14585的DWS消息

user_connect_to_device函数：

Void user_connect_to_device(struct adv_device device){wdg_resume();arch_printf (" \ r \ nConnecting ");user_print_device_name(设备);arch_printf_flush ();app_easy_gap_start_connection_to_set(设备。adv_addr_type， (uint8_t *)&(device.adv_addr)， MS_TO_DOUBLESLOTS(30));app_easy_gap_start_connection_to ();}

user_on_connection回调:

void user_on_connection（uint8_t connection_idx，struct gapc_connection_req_ind const * param）{ARCH_PRINTF（“\ r \ ndevice连接”）;app_prf_enable（param-> conhdl）;//调用在prf_func，custs_prf_func和user_prf_func}中注册的所有函数

app.c中定义的prf_func_callbacks：

const struct prf_func_callbacks prf_funcs [] = {{task_id_dws_client，user_dws_client_create_db，user_dws_client_enable}，{task_id_invalid，null，null}，//不要移动。必须始终持续};

user_dws_client_create_db函数：

空隙user_dws_client_create_db（无效）{结构gapm_profile_task_add_cmd * REQ = KE_MSG_ALLOC_DYN（GAPM_PROFILE_TASK_ADD_CMD，TASK_GAPM，TASK_APP，gapm_profile_task_add_cmd，的sizeof（结构dws_db_cfg））;//填充消息req->操作= GAPM_PROFILE_TASK_ADD;申请- > sec_lvl = get_user_prf_srv_perm (TASK_ID_DWS_CLIENT);申请- > prf_task_id = TASK_ID_DWS_CLIENT;申请- > app_task = TASK_APP;申请- > start_hdl = 0;//设置配置参数，以供将来使用结构dws_db_cfg * db_cfg =（结构dws_db_cfg *）req-> PARAM;db_cfg->设有= 0;//发送消息ke_msg_send（REQ）;}

user_dws_client_enable功能:

void user_dws_client_enable（uint8_t conidx）{struct dws_enable_req * req = ke_msg_alloc（dws_client_enable_req，prf_get_task_from_id（task_id_dws_client），task_app，dws_enable_req）;//填写参数结构req->conidx = conidx;申请- > con_type = PRF_CON_DISCOVERY;//发送消息arch_printf（启用“\ r \ ndws客户端”）;ke_msg_send(要求的);}

default_state_handlers：

const struct ke_msg_handler dws_client_default_state [] = {{GATTC_EVENT_IND, (ke_msg_func_t) dws_client_event_ind_handler}, {GATTC_DISC_CHAR_IND, (ke_msg_func_t) dws_client_disc_char_ind_handler}, {GATTC_DISC_SVC_IND, (ke_msg_func_t) dws_client_disc_svc_ind_handler}, / / {GATTC_DISC_CHAR_DESC_IND,一旦发现服务(ke_msg_func_t)dws_client_disc_char_desc_ind_handler}， {DWS_CLIENT_ENABLE_REQ， (ke_msg_func_t)dws_client_enable_req_handler}， {GATTC_CMP_EVT， (ke_msg_func_t)dws_client_cmp_evt_handler}， //一旦命令结束{DWS_CLIENT_DATA_TX_REQ， (ke_msg_func_t)dws_client_data_tx_req_handler}};

dws_client_enable_req_handler:

静态INT dws_client_enable_req_handler（ke_msg_id_t常量MSGID，结构dws_enable_req常量* PARAM，ke_task_id_t const的DEST_ID，ke_task_id_t常量src_id）{// DWS客户端角色任务环境结构dws_client_env_tag * dws_env = PRF_ENV_GET（DWS_CLIENT，dws_client）;如果（param-> con_type == PRF_CON_DISCOVERY）{//开始发现DWS对等uint8_t dws_control_service_uuid [] = DWS_SVC_UUID; // DWS_SVC_UUID;/ / DWS_CONTROL_UUID;dws_env-> last_uuid_req = ATT_DECL_PRIMARY_SERVICE; // ATT_DECL_CHARACTERISTIC; // ATT_DECL_PRIMARY_SERVICE;memcpy（dws_env-> last_svc_req，dws_control_service_uuid，att_uuid_128_len）;volatile uint8_t conidx = ke_idx_get（dest_id）;prf_disc_svc_send_128（＆dws_env-> prf_env，conidx，dws_env-> last_svc_req）;//将状态设置为发现ke_state_set（dest_id，dws_client_discovering）;} arch_printf（ “\ r \ nDWS服务发现”）;返回(KE_MSG_CONSUMED); }

dws_client_cmp_evt_handler：

Static int dws_client_cmp_evt_handler(ke_msg_id_t const msgid, struct gattc_cmp_evt const *param, ke_task_id_t const dest_id, ke_task_id_t const src_id) {uint8_t state = ke_state_get(dest_id);uint8_t conidx = KE_IDX_GET(dest_id);//获取环境结构体的地址dws_client_env_tag *dws_client_env = PRF_ENV_GET(DWS_CLIENT, DWS_CLIENT);uint8_t状态;if(state == dws_client_discovery) {arch_printf("\r\nDWS发现处理器");if ((param->status == ATT_ERR_ATTRIBUTE_NOT_FOUND) || (param->status == ATT_ERR_NO_ERROR)){//当前发现sps_server Service uint8_t dws_service_uuid[] = DWS_SVC_UUID;/ / DWS_CONTROL_UUID;如果(!memcmp(dws_client_env->last_svc_req, dws_service_uuid, ATT_UUID_128_LEN)) {if (dws_client_env->last_uuid_req == ATT_DECL_PRIMARY_SERVICE) {if (dws_client_env-> cs.svc. len)}shdl == ATT_INVALID_HANDLE){//停止发现过程。dws_client_enable_cfm_send (dws_client_env conidx PRF_ERR_STOP_DISC_CHAR_MISSING); } // Too many services found only one such service should exist else if(dws_client_env->nb_svc > 1) { // stop discovery procedure. dws_client_enable_cfm_send(dws_client_env, conidx, PRF_ERR_MULTIPLE_SVC); } else { // Discover DWS Client Device characteristics prf_disc_char_all_send(&(dws_client_env->prf_env), conidx, &(dws_client_env->dcs.svc)); // Keep last UUID requested and for which service in env dws_client_env->last_uuid_req = ATT_DECL_CHARACTERISTIC; } } else if (dws_client_env->last_uuid_req == ATT_DECL_CHARACTERISTIC) { status = prf_check_svc_char_validity_128(DWS_CLIENT_CHAR_MAX, dws_client_env->dcs.chars, dws_client_char); // Check for characteristic properties. if (status == ATT_ERR_NO_ERROR) { dws_client_env->last_uuid_req = ATT_INVALID_HANDLE; dws_client_env->last_char_code = dws_client_char_desc[ATT_DESC_CLIENT_CHAR_CFG].char_code; //Discover characteristic descriptor prf_disc_char_desc_send(&(dws_client_env->prf_env), conidx, &(dws_client_env->dcs.chars[dws_client_env->last_char_code])); } else { // Stop discovery procedure. dws_client_enable_cfm_send(dws_client_env, conidx, status); } } else //Descriptors { //Get code of next char. having descriptors dws_client_env->last_char_code = dws_get_next_desc_char_code(dws_client_env, &dws_client_char_desc[0]); if (dws_client_env->last_char_code != DWS_CLIENT_CHAR_MAX) { prf_disc_char_desc_send(&(dws_client_env->prf_env), conidx, &(dws_client_env->dcs.chars[dws_client_env->last_char_code])); } else { status = prf_check_svc_char_desc_validity(DWS_CLIENT_DESC_MAX, dws_client_env->dcs.descs, dws_client_char_desc, dws_client_env->dcs.chars); dws_client_env->nb_svc = 0; dws_client_enable_cfm_send(dws_client_env, conidx, status); } } } } else { dws_client_enable_cfm_send(dws_client_env, conidx, param->status); } } else if (state == DWS_CLIENT_CONNECTED) { if(param->operation == GATTC_WRITE_NO_RESPONSE) { arch_printf("\r\nDWS no response"); } } return (KE_MSG_CONSUMED); }

dws_client_event_ind_handler：

静态int dws_client_event_ind_handler（ke_msg_d_t const msgs，struct gattc_event_ind const * param，ke_task_id_t const dest_id，ke_task_id_t const src_id）{struct dws_client_env_tag * dws_env = prf_env_get（dws_client，dws_client）;//特定特征的处理如果（dws_env-> dcs.chars [dws_client_control_char] .val_hdl == param->句柄）{} else if（dws_env-> dcs.chars [dws_client_control_reply_char] .val_hdl == param->句柄）{} return（ke_msg_consumed）;}

dws_client_disc_char_ind_handler:

静态int dws_client_disc_char_ind_handler（ke_msg_id_t const msgs，struct gattc_disc_char_ind const * param，ke_task_id_t const dest_id，ke_task_id_t const src_id）{//获取环境结构dws_client_env_tag * dws_env = prf_env_get的地址（dws_client，dws_client）;prf_search_chars_128（dws_env-> dcs.svc.ehdl，dws_client_char_max，＆dws_env-> dcs.chars [0]，＆dws_client_char [0]，param，＆dws_env-> last_char_code）;返回(KE_MSG_CONSUMED);}

dws_client_disc_svc_ind_handler：

static int dws_client_disc_svc_ind_handler（ke_msg_id_t const msgs，struct gattc_disc_svc_ind const * param，ke_task_id_t const dest_id，ke_task_id_t const src_id）{//获取环境结构dws_client_env_tag * dws_env = prf_g_get的地址（dws_client，dws_client）;//即使我们得到多个响应，我们只存储1个范围dws_env-> dcs.svc.shdl = param-> start_hdl;dws_env-> dcs.svc.ehdl = param-> end_hdl;dws_env-> nb_svc ++;返回(KE_MSG_CONSUMED);}

dws_client_disc_char_desc_ind_handler：

static int dws_client_disc_char_desc_ind_handler(ke_msg_id_t const msgid, struct gattc_disc_char_desc_ind const *param, ke_task_id_t const dest_id, ke_task_id_t const src_id){//获取环境结构体的地址dws_client_env_tag *dws_env = PRF_ENV_GET(DWS_CLIENT, DWS_CLIENT);//获取SPS描述符prf_search_descs(DWS_CLIENT_DESC_MAX， &dws_env-> cs.descs[0]， &dws_client_char_desc[0]， param, dws_env->last_char_code);返回(KE_MSG_CONSUMED);}

dws_client_data_tx_req_handler：

静态INT dws_client_data_tx_req_handler（ke_msg_id_t常量MSGID，结构dws_client_data_tx_req常量* PARAM，ke_task_id_t const的DEST_ID，ke_task_id_t常量src_id）{结构dws_client_env_tag * dws_client_env = PRF_ENV_GET（DWS_CLIENT，dws_client）;uint8_t conidx = KE_IDX_GET(dest_id);如果（ke_state_get（KE_BUILD_ID（dws_client_env-> prf_env.prf_task，conidx））== DWS_CLIENT_CONNECTED）{{prf_gatt_write（dws_client_env-> prf_env，conidx，dws_client_env-> dcs.chars [DWS_CLIENT_CONTROL_CHAR] .val_hdl，（uint8_t *）param->数据，的sizeof（uint8_t）* param->数据长度，GATTC_WRITE）;回报（KE_MSG_NO_FREE）;}} return (KE_MSG_CONSUMED);}

BLE数据发送例程：

Static uint8_t data = 0x17;如果(central_is_connected() == DWS_CLIENT_CONNECTED) {user_send_ble_data((uint8_t *)&data, 1);arch_printf("\r\nCMD发送%d"，数据);Data = (Data == 0x17) ?0 x18: 0 x17;}

user_send_ble_data功能:

void user_send_ble_data(const uint8_t *data, uint16_t length) {struct dws_client_data_tx_req *req = KE_MSG_ALLOC_DYN(dws_client_data_tx_req, prf_get_task_from_id(TASK_ID_DWS_CLIENT)，TASK_APP,dws_client_data_tx_req,length);申请- > data_length =长度;memcpy(请求- >[0]的数据,数据长度);ke_msg_send(要求的);}

c .特点:

常量结构prf_char_def_128 dws_client_char [DWS_CLIENT_CHAR_MAX] = {[DWS_CLIENT_ACCEL_CHAR] = {DWS_ACCEL_UUID，ATT_MANDATORY，ATT_CHAR_PROP_NTF}，[DWS_CLIENT_GYRO_CHAR] = {DWS_GYRO_UUID，ATT_MANDATORY，ATT_CHAR_PROP_NTF}，[DWS_CLIENT_MAG_CHAR] = {DWS_MAG_UUID，ATT_MANDATORY，ATT_CHAR_PROP_NTF}，[DWS_CLIENT_BARO_CHAR] = {DWS_BARO_UUID，ATT_MANDATORY，ATT_CHAR_PROP_NTF}，[DWS_CLIENT_HUM_CHAR] = {DWS_HUM_UUID，ATT_MANDATORY，ATT_CHAR_PROP_NTF}，[DWS_CLIENT_TEMP_CHAR] = {DWS_TEMP_UUID，ATT_MANDATORY，ATT_CHAR_PROP_NTF}，[DWS_CLIENT_SENSF_CHAR] = {DWS_SENSF_UUID，ATT_MANDATORY，ATT_CHAR_PROP_NTF}，[DWS_CLIENT_FEAT_CHAR] = {DWS_FEAT_UUID，ATT_MANDATORY，ATT_CHAR_PROP_RD}，[DWS_CLIENT_CONTROL_CHAR] = {DWS_CONTROL_UUID，ATT_MANDATORY，ATT_CHAR_PROP_WR}，[DWS_CLIENT_CONTROL_REPLY_CHAR] = {DWS_CONTROL_REPLY_UUID，ATT_MANDATORY，ATT_CHAR_PROP_NTF}，[DWS_CLIENT_MULTI_SENS_CHAR] = {DWS_MULTI_SENS_UUID，ATT_MANDATORY，ATT_CHAR_PROP_NTF}，};常量结构prf_char_desc_def dws_client_char_desc [DWS_CLIENT_DESC_MAX] = {/// DWS客户端配置[DWS_CLIENT_ACCEL_NTF_CFG] = {ATT_DESC_CLIENT_CHAR_CFG，ATT_MANDATORY，DWS_CLIENT_ACCEL_CHAR}，[DWS_CLIENT_GYRO_NTF_CFG] = {ATT_DESC_CLIENT_CHAR_CFG，ATT_MANDATORY，DWS_CLIENT_GYRO_CHAR}，[DWS_CLIENT_MAG_NTF_CFG] = {ATT_DESC_CLIENT_CHAR_CFG，ATT_MANDATORY，DWS_CLIENT_MAG_CHAR}[DWS_CLIENT_BARO_NTF_CFG] = {ATT_DESC_CLIENT_CHAR_CFG，ATT_MANDATORY，DWS_CLIENT_BARO_CHAR}，[DWS_CLIENT_HUM_NTF_CFG] = {ATT_DESC_CLIENT_CHAR_CFG，ATT_MANDATORY，DWS_CLIENT_HUM_CHAR}，[DWS_CLIENT_TEMP_NTF_CFG] = {ATT_DESC_CLIENT_CHAR_CFG，ATT_MANDATORY，DWS_CLIENT_TEMP_CHAR}，[DWS_CLIENT_SENSF_NTF_CFG] = {ATT_DESC_CLIENT_CHAR_CFG，ATT_MANDATORY，DWS_CLIENT_SENSF_CHAR}，[dws_client_control_reply_ntf_cfg] = {att_desc_client_char_cfg，att_mandatory，dws_client_control_reply_char}，[dws_client_multi_sens_ntf_cfg] = {att_desc_client_char_cfg，att_mandatory，dws_client_multi_sens_char}，};

D.数据结构：

结构dws_client_data_tx_req {///连接索引uint16_t conidx;///这已被写入uint16_t手柄属性的句柄;///数据长度被写入数据长度uint16_t;///要写入的数据在属性数据库uint8_t数据[1]; // [__ ARRAY_EMPTY];}；

struct dws_client_env_tag {///配置文件环境prf_env_t prf_env;///服务开始处理UINT16_T SHDL;///存储DB最大属性的uint8_t max_nb_att;///正在进行的操作struct ke_msg *操作;/// Coursor用于通知对等设备UINT8_T光标的连接;/// CCC句柄索引，在通知期间使用/指示忙状态UINT8_T CCC_IDX;///按应用程序结构co_list值设置的值列表;/// custs1任务状态ke_state_t state [dws_idx_max];///配置文件连接信息///最后请求的uuid（跟踪两个服务和char）uint16_t last_uuid_req;///被发现的东西是uint8_t last_svc_req [att_uuid_128_len]的最后一次服务; /// Last char. code requested to read. uint8_t last_char_code; /// counter used to check service uniqueness uint8_t nb_svc; /// DWS Client Service Device Service information recovered from discovery struct dws_client_content dcs; }; struct spsc_db_cfg { ///Database configuration uint16_t features; };

Struct adv_device {uint8_t index;///多个广告设备索引uint8_t evt_type;///事件类型:uint8_t adv_addr_type;///发布地址类型:public/random struct bd_addr adv_addr;///发布地址值uint8_t device_name_len;///通告报文uint8_t device_name[ADV_DATA_LEN]的数据长度;///通告报文uint8_t device_spec_len的数据;uint8_t device_spec [ADV_DATA_LEN];uint8_t flags_len;uint8_t旗帜(ADV_DATA_LEN); uint8_t services[4]; uint8_t uuid_len; uint8_t uuid[ADV_DATA_LEN]; uint8_t uuid_sol_len; uint8_t uuid_sol[ADV_DATA_LEN]; uint8_t raw_len; uint8_t raw[ADV_DATA_LEN]; int8_t rssi; ///RSSI value for advertising packet }; struct scan_configuration { /// Operation code. uint8_t code; /// Own BD address source of the device uint8_t addr_src; /// Scan interval uint16_t interval; /// Scan window size uint16_t window; /// Scanning mode uint8_t mode; /// Scan filter policy uint8_t filt_policy; /// Scan duplicate filtering policy uint8_t filter_duplic; };

枚举{///空闲状态dws_client_idle，///连接状态dws_client_connected，///发现dws_client_discovering，///定义状态。dws_client_state_max};/// DWS客户端服务特性枚举{//// DWS_CLIENT_ACCEL_CHAR = 0，DWS_CLIENT_GYRO_CHAR，DWS_CLIENT_MAG_CHAR，DWS_CLIENT_BARO_CHAR，DWS_CLIENT_HUM_CHAR，DWS_CLIENT_TEMP_CHAR，DWS_CLIENT_SENSF_CHAR，DWS_CLIENT_FEAT_CHAR，DWS_CLIENT_CONTROL_CHAR，DWS_CLIENT_CONTROL_REPLY_CHAR，DWS_CLIENT_MULTI_SENS_CHAR，//// DWS_CLIENT_CHAR_MAX};/// DWS客户端服务特性描述符枚举{/// DWS客户端配置DWS_CLIENT_ACCEL_NTF_CFG，DWS_CLIENT_GYRO_NTF_CFG，DWS_CLIENT_MAG_NTF_CFG，DWS_CLIENT_BARO_NTF_CFG，DWS_CLIENT_HUM_NTF_CFG，DWS_CLIENT_TEMP_NTF_CFG，DWS_CLIENT_SENSF_NTF_CFG，DWS_CLIENT_CONTROL_REPLY_NTF_CFG，DWS_CLIENT_MULTI_SENS_NTF_CFG，/// DWS_CLIENT_DESC_MAX，};/// DWS客户端主机API邮件枚举{/// dws客户端角色启用从应用程序的请求。dws_client_enable_req = ke_first_msg（task_id_dws_client），/// sps主机角色允许确认应用程序。dws_client_enable_cfm，///要传输数据dws_client_data_tx_req，///确认数据已被发送到dws_client_data_tx_cfm，///向app dws_client_data_rx_ind，//发送流控制状态dws_client_rx_flow_ctrl_req，///表示流控制状态dws_client_tx_flow_ctrl_ind，};///服务信息struct dws_client_content {///服务信息struct prf_svc svc;///特征信息：struct prf_char_inf chars [dws_client_char_max];///特征cfg struct prf_char_desc_inf descs [dws_client_desc_max]; };

我相信它将帮助另一个人努力实现一个非常简单的中央设备FW为DA14585。

如果你想让我联系你，请在LinkedIn上联系我https://www.linkedin.com/in/petr-dvorak-hw/