diff --git a/APP_Framework/Applications/app_test/test_lora_net_final/lora_driver/e220.c b/APP_Framework/Applications/app_test/test_lora_net_final/lora_driver/e220.c index cff76d97a..db094a145 100755 --- a/APP_Framework/Applications/app_test/test_lora_net_final/lora_driver/e220.c +++ b/APP_Framework/Applications/app_test/test_lora_net_final/lora_driver/e220.c @@ -1,3 +1,24 @@ +/* +* Copyright (c) 2020 AIIT XUOS Lab +* XiUOS is licensed under Mulan PSL v2. +* You can use this software according to the terms and conditions of the Mulan PSL v2. +* You may obtain a copy of Mulan PSL v2 at: +* http://license.coscl.org.cn/MulanPSL2 +* THIS SOFTWARE IS PROVIDED ON AN "AS IS" BASIS, WITHOUT WARRANTIES OF ANY KIND, +* EITHER EXPRESS OR IMPLIED, INCLUDING BUT NOT LIMITED TO NON-INFRINGEMENT, +* MERCHANTABILITY OR FIT FOR A PARTICULAR PURPOSE. +* See the Mulan PSL v2 for more details. +*/ + +/** +* @file: e220.c +* @brief: E220 module underlying related configuration driver functions implement +* @version: 0.1 +* @author: YUNFEI CHU +* @date: 2023/10/01 +* +*/ + #include "e220.h" struct RegisterCfg // 寄存器结构 @@ -32,7 +53,7 @@ static struct RegisterCfg register_cfg = */ static struct SerialDataCfg serial_cfg = { - .serial_baud_rate = E220_DEFAULT_CONFIG_BAUD_RATE, // 串口波特率 + .serial_baud_rate = E220_DEFAULT_CONFIG_BAUD_RATE,// 串口波特率 .serial_data_bits = DATA_BITS_8, .serial_stop_bits = STOP_BITS_1, .serial_parity_mode = PARITY_NONE, diff --git a/APP_Framework/Applications/app_test/test_lora_net_final/lora_driver/e220.h b/APP_Framework/Applications/app_test/test_lora_net_final/lora_driver/e220.h index 87ef4d0e8..b69d1a75d 100755 --- a/APP_Framework/Applications/app_test/test_lora_net_final/lora_driver/e220.h +++ b/APP_Framework/Applications/app_test/test_lora_net_final/lora_driver/e220.h @@ -1,10 +1,31 @@ +/* +* Copyright (c) 2020 AIIT XUOS Lab +* XiUOS is licensed under Mulan PSL v2. +* You can use this software according to the terms and conditions of the Mulan PSL v2. +* You may obtain a copy of Mulan PSL v2 at: +* http://license.coscl.org.cn/MulanPSL2 +* THIS SOFTWARE IS PROVIDED ON AN "AS IS" BASIS, WITHOUT WARRANTIES OF ANY KIND, +* EITHER EXPRESS OR IMPLIED, INCLUDING BUT NOT LIMITED TO NON-INFRINGEMENT, +* MERCHANTABILITY OR FIT FOR A PARTICULAR PURPOSE. +* See the Mulan PSL v2 for more details. +*/ + +/** +* @file: e220.h +* @brief: E220 module underlying related configuration driver functions declarations +* @version: 0.1 +* @author: YUNFEI CHU +* @date: 2023/10/01 +* +*/ + #include #include #ifndef __E220_H__ #define __E220_H__ -// #define __DRIVER_DEBUG__ // 驱动调试信息输出开关 +// #define __DRIVER_DEBUG__ // 驱动调试信息输出开关 #ifdef __DRIVER_DEBUG__ #define DDBG(format,...) printf(format, ##__VA_ARGS__) #else diff --git a/APP_Framework/Applications/app_test/test_lora_net_final/lora_mac/lora_mac.c b/APP_Framework/Applications/app_test/test_lora_net_final/lora_mac/lora_mac.c index f4fe29621..bf0700679 100755 --- a/APP_Framework/Applications/app_test/test_lora_net_final/lora_mac/lora_mac.c +++ b/APP_Framework/Applications/app_test/test_lora_net_final/lora_mac/lora_mac.c @@ -1,3 +1,24 @@ +/* +* Copyright (c) 2020 AIIT XUOS Lab +* XiUOS is licensed under Mulan PSL v2. +* You can use this software according to the terms and conditions of the Mulan PSL v2. +* You may obtain a copy of Mulan PSL v2 at: +* http://license.coscl.org.cn/MulanPSL2 +* THIS SOFTWARE IS PROVIDED ON AN "AS IS" BASIS, WITHOUT WARRANTIES OF ANY KIND, +* EITHER EXPRESS OR IMPLIED, INCLUDING BUT NOT LIMITED TO NON-INFRINGEMENT, +* MERCHANTABILITY OR FIT FOR A PARTICULAR PURPOSE. +* See the Mulan PSL v2 for more details. +*/ + +/** +* @file: lora_mac.c +* @brief: Lora private network protocol related data structure implementation +* @version: 0.1 +* @author: YUNFEI CHU +* @date: 2023/10/01 +* +*/ + #include "lora_mac.h" static const uint8 crc_hi_table[] = diff --git a/APP_Framework/Applications/app_test/test_lora_net_final/lora_mac/lora_mac.h b/APP_Framework/Applications/app_test/test_lora_net_final/lora_mac/lora_mac.h index 38a9b5e15..1d6bd6627 100755 --- a/APP_Framework/Applications/app_test/test_lora_net_final/lora_mac/lora_mac.h +++ b/APP_Framework/Applications/app_test/test_lora_net_final/lora_mac/lora_mac.h @@ -1,3 +1,24 @@ +/* +* Copyright (c) 2020 AIIT XUOS Lab +* XiUOS is licensed under Mulan PSL v2. +* You can use this software according to the terms and conditions of the Mulan PSL v2. +* You may obtain a copy of Mulan PSL v2 at: +* http://license.coscl.org.cn/MulanPSL2 +* THIS SOFTWARE IS PROVIDED ON AN "AS IS" BASIS, WITHOUT WARRANTIES OF ANY KIND, +* EITHER EXPRESS OR IMPLIED, INCLUDING BUT NOT LIMITED TO NON-INFRINGEMENT, +* MERCHANTABILITY OR FIT FOR A PARTICULAR PURPOSE. +* See the Mulan PSL v2 for more details. +*/ + +/** +* @file: lora_mac.h +* @brief: Definition of data structures related to the Lora private protocol +* @version: 0.1 +* @author: YUNFEI CHU +* @date: 2023/10/01 +* +*/ + #include #include #include "../lora_driver/e220.h" @@ -19,12 +40,12 @@ #define FRAME_FOOT_LENGTH 4 // 额外数据以下至帧尾的数据长度 #define FRAME_MARK_LENGTH 2 // 帧头帧尾的数据长度 -enum FrameType // 数据帧类型枚举 +enum FrameType // 数据帧类型枚举 { - E_G_JOIN = 0, // 客户端入网请求，需回复 - E_G_QUIT, // 客户端退网请求，不需回复 - E_G_DATA, // 客户端上传数据，需回复 - G_E_ANS, // 网关响应客户端请求 + E_G_JOIN = 0, // 客户端入网请求，需回复 + E_G_QUIT, // 客户端退网请求，不需回复 + E_G_DATA, // 客户端上传数据，需回复 + G_E_ANS, // 网关响应客户端请求 }; struct LoraFrame // 数据帧消息类型 @@ -75,29 +96,29 @@ uint8 CheckCrcLoraFrame(struct LoraFrame* frame); /*数据帧**************************************************************************/ /*基础操作************************************************************************/ -#define LORA_ADAPTER_NAME "e220" -#define LORA_OK 0XFF -#define LORA_NO 0X00 -#define LORA_TIME_ON_AIR 2 -#define LORA_AIR_RATE 0 -#define LORA_FRAME_RETRY 5 -#define LORA_GATEWAY_MAX_CMD 20 -#define LORA_GATEWAY_MAX_NODE 20 -#define LORA_GATEWAY_ADDRESS 0XFFFF +#define LORA_ADAPTER_NAME "e220" // Lora适配器名称 +#define LORA_OK 0XFF // 标识成功、确认等 +#define LORA_NO 0X00 // 标识失败、丢失等 +#define LORA_TIME_ON_AIR 2 // 估计的空中时间 +#define LORA_AIR_RATE 0 // 模块的空中速率 +#define LORA_FRAME_RETRY 5 // 数据帧重传次数，超过这个次数判定断网 +#define LORA_GATEWAY_MAX_NODE 20 // 每个网关支持的最大客户端个数，防止上行通道过于拥挤 +#define LORA_GATEWAY_ADDRESS 0XFFFF // 网关地址，单信道网关的监听地址 #ifdef AS_LORA_GATEWAY -#define LORA_RECV_TIME 10 -#define LORA_GATEWAY_CHANNEL 0XA +#define LORA_RECV_TIME 10 // 串口超时时间 +#define LORA_GATEWAY_CHANNEL 0XA // 网关默认信道 #else -#define LORA_ADDRESS 0X9 -#define LORA_RECV_TIME 5 -#define LORA_DOWN_CHANNEL 0X9 -#define LORA_UP_CHANNEL 0XA -#define LORA_ADR_ENABLE LORA_NO -#define LORA_RECONNECT_ENABLE LORA_OK +#define LORA_ADDRESS 0X9 // 节点默认地址 +#define LORA_RECV_TIME 5 // 节点默认串口超时时间 +#define LORA_DOWN_CHANNEL 0X9 // 节点默认下行信道 +#define LORA_UP_CHANNEL 0XA // 节点默认上行通道 +#define LORA_ADR_ENABLE LORA_NO // 节点是否开启网关自动搜索 +#define LORA_RECONNECT_ENABLE LORA_OK // 节点是否开启断网自动重联 + #endif /** @@ -234,20 +255,20 @@ enum GatewayState // 网关的状态枚举 GATEWAY_BROKEN // 模块损坏 }; -struct GatewayParam // 网关参数 +struct GatewayParam // 网关参数 { - uint16 dev_addr; // 设备ID - uint8 channel; // 网络编号 + uint16 dev_addr; // 设备ID + uint8 channel; // 网络编号 - int recv_time; // 串口超时时间 - enum LoraAirRate air_rate; // 网关空中速率 - uint8 frame_retry; // 重传次数 - enum GatewayState gateway_state; // 网关状态 - struct EndNodeInfo *node_infos[LORA_GATEWAY_MAX_NODE]; // 客户端信息 - uint16 node_count; // 已链接客户端数量 + int recv_time; // 串口超时时间 + enum LoraAirRate air_rate; // 网关空中速率 + uint8 frame_retry; // 重传次数 + enum GatewayState gateway_state; // 网关状态 + struct EndNodeInfo *node_infos[LORA_GATEWAY_MAX_NODE]; // 客户端信息 + uint16 node_count; // 已链接客户端数量 }; -extern struct GatewayParam gateway_param; // 网关参数 +extern struct GatewayParam gateway_param; // 网关参数 extern int (*gateway_handlers[])(struct Adapter*,struct LoraFrame*); // 处理程序 /** diff --git a/APP_Framework/Applications/app_test/test_lora_net_final/test_lora_net_final.c b/APP_Framework/Applications/app_test/test_lora_net_final/test_lora_net_final.c index e7bc5325f..5d8e279f0 100755 --- a/APP_Framework/Applications/app_test/test_lora_net_final/test_lora_net_final.c +++ b/APP_Framework/Applications/app_test/test_lora_net_final/test_lora_net_final.c @@ -1,3 +1,24 @@ +/* +* Copyright (c) 2020 AIIT XUOS Lab +* XiUOS is licensed under Mulan PSL v2. +* You can use this software according to the terms and conditions of the Mulan PSL v2. +* You may obtain a copy of Mulan PSL v2 at: +* http://license.coscl.org.cn/MulanPSL2 +* THIS SOFTWARE IS PROVIDED ON AN "AS IS" BASIS, WITHOUT WARRANTIES OF ANY KIND, +* EITHER EXPRESS OR IMPLIED, INCLUDING BUT NOT LIMITED TO NON-INFRINGEMENT, +* MERCHANTABILITY OR FIT FOR A PARTICULAR PURPOSE. +* See the Mulan PSL v2 for more details. +*/ + +/** +* @file: test_lora_net_final.c +* @brief: Private protocol test functions +* @version: 0.1 +* @author: YUNFEI CHU +* @date: 2023/10/01 +* +*/ + #include "test_lora_net_final.h" #ifdef AS_LORA_GATEWAY diff --git a/APP_Framework/Applications/app_test/test_lora_net_final/test_lora_net_final.h b/APP_Framework/Applications/app_test/test_lora_net_final/test_lora_net_final.h index 1ab38fe96..b80a83d03 100755 --- a/APP_Framework/Applications/app_test/test_lora_net_final/test_lora_net_final.h +++ b/APP_Framework/Applications/app_test/test_lora_net_final/test_lora_net_final.h @@ -1,3 +1,24 @@ +/* +* Copyright (c) 2020 AIIT XUOS Lab +* XiUOS is licensed under Mulan PSL v2. +* You can use this software according to the terms and conditions of the Mulan PSL v2. +* You may obtain a copy of Mulan PSL v2 at: +* http://license.coscl.org.cn/MulanPSL2 +* THIS SOFTWARE IS PROVIDED ON AN "AS IS" BASIS, WITHOUT WARRANTIES OF ANY KIND, +* EITHER EXPRESS OR IMPLIED, INCLUDING BUT NOT LIMITED TO NON-INFRINGEMENT, +* MERCHANTABILITY OR FIT FOR A PARTICULAR PURPOSE. +* See the Mulan PSL v2 for more details. +*/ + +/** +* @file: test_lora_net_final.h +* @brief: Private protocol test function definition +* @version: 0.1 +* @author: YUNFEI CHU +* @date: 2023/10/01 +* +*/ + #include #include diff --git a/APP_Framework/Applications/app_test/test_lora_p2p/README.md b/APP_Framework/Applications/app_test/test_lora_p2p/README.md deleted file mode 100755 index 3bc748a9b..000000000 --- a/APP_Framework/Applications/app_test/test_lora_p2p/README.md +++ /dev/null @@ -1,154 +0,0 @@ -# 基于RISC-V终端，实现LoRa节点和LoRa网关通信私有协议 - -## 一、简介 -在RISC-V终端上实现LoRa节点和LoRa网关私有协议通信功能,客户端可以通过SHELL终端连接\断开网关,并可以向网关发送数据. - -## 二、数据结构设计说明 -### 1、Lora工作模式枚举 -```c -enum LoraMode -{ - LORA_SLEEP = 0, // 切换至休眠模式 - LORA_WORK = 1 // 切换至工作模式 -}; -``` -在客户端需要传输数据时，Lora会工作在普通模式进行数据传输，在客户端数据传输完毕后，Lora会切换到休眠模式以屏蔽数据。 - -### 2、客户端/网关状态信息 -```c -enum ClientState -{ - CLIENT_DISCONNECT = 0, // 开启但断网 - CLIENT_CONNECT, // 开启且联网 - CLIENT_BROKEN, // 硬件损坏 - CLIENT_CLOSED // 硬件关闭 -}; -enum GatewayState -{ - GATEWAY_ORIGINAL= 0, // 关闭且未开始工作 - GATEWAY_WORKING, // 开启且已经开始工作 - GATEWAY_BROKEN // 模块损坏 -}; -``` -### 3、客户端/网关参数信息 -```c -struct ClientParam -{ - uint8_t client_id; - uint8_t panid; - uint8_t gateway_id; - enum ClientState client_state; - pthread_mutex_t client_mutex; // 互斥量 -}; -struct GatewayParam -{ - uint8_t gateway_id; - uint8_t panid; - uint8_t client_infos[GATEWAY_MAX_CLIENT_NUM]; - uint8_t client_num; - enum GatewayState gateway_state; - pthread_mutex_t gateway_mutex; // 互斥量 -}; -``` -### 4、数据帧类型枚举 -```c -enum FrameType -{ - /*C ---> G*/ - CG_NET_JOIN = 0, // 入网请求 - CG_NET_QUIT, // 退网请求 - CG_DATA_SEND, // 数据传输请求 - /*G ---> C*/ - GC_REPLY_EXPECTED, // 上行请求执行成功 - GC_REPLY_UNEXPECTED, // 上行请求执行失败 -}; -``` -### 5、数据帧结构设计 -```c -struct DataFrameFormat -{ - uint8_t begin_mark_1; // 0XFF - uint8_t begin_mark_2; // 0XAA - uint8_t client_id; // 0 - 127 - uint8_t panid; // 0 - 127 - uint8_t gateway_id; // 0 - 127 - uint8_t frame_type; // 0 - 127 - uint8_t attach_data; // 0 - 127 可以是数据长度，该值的意义视数据帧类型而定 - uint8_t* user_data; // 在有数据携带时才会发送该指针所指缓冲区数据 - uint8_t crc_hi; // 这个字节没有0XFF - uint8_t crc_lo; // 这个字节会出现 0XFF，但是他的下一个字节不可能是00，必然是0XFF - uint8_t end_mark_1; // 0XFF - uint8_t end_mark_2; // 0X00 -}; -``` -## 三、包含以下功能 -### 1、客户端联网/退网/数据传输操作 -> (1)、获取使用权后将其配置为传输模式。
-> (2)、构建数据帧并设置好数据帧类型。
-> (3)、监听信道直到信道空闲。
-> (4)、发送数据帧（若是数据传输需要带上数据一起传输），若失败回到第三步。
-> (5)、接收数据帧并对数据帧进行数据过滤，若失败回到第三步。
-> (6)、解析数据帧并得到结果
-### 2、网关后台任务操作 -> (1)、获取使用权后开启数据接收。
-> (2)、根据数据帧结构，监听信道，过滤掉杂乱的信号，在接收到一个完整的数据帧并完整性校验通过后返回继续第三步，否则循环执行第二步。
-> (3)、根据得到的数据帧类型将其交付给对应的处理器处理，处理完毕后返回第二步。
- -## 四、测试程序说明 -在进行测试时，最好先启动网关并开启网关程序，当然后启动网关也一样。 -### 1、客户端测试程序 -> (1)、`TestLoraConnectState`命令可以进行网络连接或者断开，`0-CLIENT_DISCONNECT 1-CLIENT_CONNECT`。 -> (2)、`TestLoraSendData`命令可以发送数据（联网状态下），请使用字符串（`void TestLoraSendData(char* data)`）。 -> (3)、`TestLoraClient`命令可以整体测试，先进行联网，再发送数据，再断开连接，最后再联网。 -### 2、网关测试程序 -> (1)、`TestLoraGateway`命令可以启动网关程序。 - -## 五、运行结果（##需结合运行测试截图按步骤说明##） -### 1、修改必要的框架和驱动代码 - -#### 修改文件： `xiuos/APP_Framework/Framework/framework_init.c` -1. 在第`28`行添加代码: `extern int UsrAdapterLoraInit(void);`; -2. 将第`170`行代码的`AdapterLoraInit`修改为`UsrAdapterLoraInit`，更换Lora的初始化函数; - -#### 修改文件：`xiuos/APP_Framework/Framework/connection/lora/e220/e220.c` -1. 将第`429`行代码修改为`cfg.serial_timeout = 5000;`,更改客户端超时时间; -2. 为第`478`行的`E220Ioctl`添加函数体： -```c -static int E220Ioctl(struct Adapter *adapter, int cmd, void *args) -{ - switch (cmd) - { - case 0: // LORA_SLEEP - E220LoraModeConfig(CONFIGURE_MODE_MODE); // 切换至休眠模式 - break; - case 1: // LORA_WORK - E220LoraModeConfig(DATA_TRANSFER_MODE); // 切换至传输模式 - break; - default: - break; - } - - return 0; -} -``` -### 2、修改Makefile - -#### 修改文件： `xiuos/APP_Framework/Applications/app_test/Makefile` 第 `137` 行为 `SRC_FILES += test_lora_p2p/test_lora_p2p.c` -### 3、menuconfig配置 -1. `APP_Framework > Applications > test app` 开启 `Enable application test function` ,然后进入其中，开启 `Config test lora p2p (NEW)` ; -![image](images/5-3-1.png) -2. `APP_Framework > Framework` 开启 `support connection framework (NEW)` ,然后进入其中，开启 `Using lora adapter device (NEW)` ，然后进入其中， 客户端将其配置如下图所示，网关将其配置为下下图所示; -![image](images/5-3-2-1.png) -![image](images/5-3-2-2.png) -3. 将客户端和网关分别编译、烧录到不同的板子并启动后用串口进行连接; -![image](images/5-3-3.png) -4. 启动网关程序； -![image](images/5-3-4.png) -5. 整体测试客户端； -![image](images/5-3-5.png) -6. 测试断网 -![image](images/5-3-6.png) -7. 测试联网 -![image](images/5-3-7.png) -8. 测试数据发送 -![image](images/5-3-8.png) \ No newline at end of file diff --git a/APP_Framework/Applications/app_test/test_lora_p2p/images/5-3-1.png b/APP_Framework/Applications/app_test/test_lora_p2p/images/5-3-1.png deleted file mode 100755 index cd4f859f9..000000000 Binary files a/APP_Framework/Applications/app_test/test_lora_p2p/images/5-3-1.png and /dev/null differ diff --git a/APP_Framework/Applications/app_test/test_lora_p2p/images/5-3-2-1.png b/APP_Framework/Applications/app_test/test_lora_p2p/images/5-3-2-1.png deleted file mode 100755 index aedf8eaf2..000000000 Binary files a/APP_Framework/Applications/app_test/test_lora_p2p/images/5-3-2-1.png and /dev/null differ diff --git a/APP_Framework/Applications/app_test/test_lora_p2p/images/5-3-2-2.png b/APP_Framework/Applications/app_test/test_lora_p2p/images/5-3-2-2.png deleted file mode 100755 index 18cd03d99..000000000 Binary files a/APP_Framework/Applications/app_test/test_lora_p2p/images/5-3-2-2.png and /dev/null differ diff --git a/APP_Framework/Applications/app_test/test_lora_p2p/images/5-3-3.png b/APP_Framework/Applications/app_test/test_lora_p2p/images/5-3-3.png deleted file mode 100755 index 181d471c0..000000000 Binary files a/APP_Framework/Applications/app_test/test_lora_p2p/images/5-3-3.png and /dev/null differ diff --git a/APP_Framework/Applications/app_test/test_lora_p2p/images/5-3-4.png b/APP_Framework/Applications/app_test/test_lora_p2p/images/5-3-4.png deleted file mode 100755 index 71673186c..000000000 Binary files a/APP_Framework/Applications/app_test/test_lora_p2p/images/5-3-4.png and /dev/null differ diff --git a/APP_Framework/Applications/app_test/test_lora_p2p/images/5-3-5.png b/APP_Framework/Applications/app_test/test_lora_p2p/images/5-3-5.png deleted file mode 100755 index 8a73cc1eb..000000000 Binary files a/APP_Framework/Applications/app_test/test_lora_p2p/images/5-3-5.png and /dev/null differ diff --git a/APP_Framework/Applications/app_test/test_lora_p2p/images/5-3-6.png b/APP_Framework/Applications/app_test/test_lora_p2p/images/5-3-6.png deleted file mode 100755 index 29ccfa34d..000000000 Binary files a/APP_Framework/Applications/app_test/test_lora_p2p/images/5-3-6.png and /dev/null differ diff --git a/APP_Framework/Applications/app_test/test_lora_p2p/images/5-3-7.png b/APP_Framework/Applications/app_test/test_lora_p2p/images/5-3-7.png deleted file mode 100755 index 2605a964e..000000000 Binary files a/APP_Framework/Applications/app_test/test_lora_p2p/images/5-3-7.png and /dev/null differ diff --git a/APP_Framework/Applications/app_test/test_lora_p2p/images/5-3-8.png b/APP_Framework/Applications/app_test/test_lora_p2p/images/5-3-8.png deleted file mode 100755 index 1aa130aa5..000000000 Binary files a/APP_Framework/Applications/app_test/test_lora_p2p/images/5-3-8.png and /dev/null differ diff --git a/APP_Framework/Applications/app_test/test_lora_p2p/test_lora_p2p.c b/APP_Framework/Applications/app_test/test_lora_p2p/test_lora_p2p.c deleted file mode 100644 index 9e9ac72f1..000000000 --- a/APP_Framework/Applications/app_test/test_lora_p2p/test_lora_p2p.c +++ /dev/null @@ -1,826 +0,0 @@ -#include "test_lora_p2p.h" - -/******************************public_operate*********************************/ -static const uint8_t table_crc_hi[] = - { - 0x00, 0xC1, 0x81, 0x40, 0x01, 0xC0, 0x80, 0x41, 0x01, 0xC0, 0x80, 0x41, 0x00, 0xC1, 0x81, 0x40, 0x01, 0xC0, 0x80, 0x41, 0x00, 0xC1, 0x81, 0x40, 0x00, 0xC1, 0x81, 0x40, 0x01, 0xC0, 0x80, 0x41, 0x01, 0xC0, 0x80, 0x41, 0x00, 0xC1, 0x81, 0x40, - 0x00, 0xC1, 0x81, 0x40, 0x01, 0xC0, 0x80, 0x41, 0x00, 0xC1, 0x81, 0x40, 0x01, 0xC0, 0x80, 0x41, 0x01, 0xC0, 0x80, 0x41, 0x00, 0xC1, 0x81, 0x40, 0x01, 0xC0, 0x80, 0x41, 0x00, 0xC1, 0x81, 0x40, 0x00, 0xC1, 0x81, 0x40, 0x01, 0xC0, 0x80, 0x41, - 0x00, 0xC1, 0x81, 0x40, 0x01, 0xC0, 0x80, 0x41, 0x01, 0xC0, 0x80, 0x41, 0x00, 0xC1, 0x81, 0x40, 0x00, 0xC1, 0x81, 0x40, 0x01, 0xC0, 0x80, 0x41, 0x01, 0xC0, 0x80, 0x41, 0x00, 0xC1, 0x81, 0x40, 0x01, 0xC0, 0x80, 0x41, 0x00, 0xC1, 0x81, 0x40, - 0x00, 0xC1, 0x81, 0x40, 0x01, 0xC0, 0x80, 0x41, 0x01, 0xC0, 0x80, 0x41, 0x00, 0xC1, 0x81, 0x40, 0x00, 0xC1, 0x81, 0x40, 0x01, 0xC0, 0x80, 0x41, 0x00, 0xC1, 0x81, 0x40, 0x01, 0xC0, 0x80, 0x41, 0x01, 0xC0, 0x80, 0x41, 0x00, 0xC1, 0x81, 0x40, - 0x00, 0xC1, 0x81, 0x40, 0x01, 0xC0, 0x80, 0x41, 0x01, 0xC0, 0x80, 0x41, 0x00, 0xC1, 0x81, 0x40, 0x01, 0xC0, 0x80, 0x41, 0x00, 0xC1, 0x81, 0x40, 0x00, 0xC1, 0x81, 0x40, 0x01, 0xC0, 0x80, 0x41, 0x00, 0xC1, 0x81, 0x40, 0x01, 0xC0, 0x80, 0x41, - 0x01, 0xC0, 0x80, 0x41, 0x00, 0xC1, 0x81, 0x40, 0x01, 0xC0, 0x80, 0x41, 0x00, 0xC1, 0x81, 0x40, 0x00, 0xC1, 0x81, 0x40, 0x01, 0xC0, 0x80, 0x41, 0x01, 0xC0, 0x80, 0x41, 0x00, 0xC1, 0x81, 0x40, 0x00, 0xC1, 0x81, 0x40, 0x01, 0xC0, 0x80, 0x41, - 0x00, 0xC1, 0x81, 0x40, 0x01, 0xC0, 0x80, 0x41, 0x01, 0xC0, 0x80, 0x41, 0x00, 0xC1, 0x81, 0x40}; - -static const uint8_t table_crc_lo[] = - { - 0x00, 0xC0, 0xC1, 0x01, 0xC3, 0x03, 0x02, 0xC2, 0xC6, 0x06, 0x07, 0xC7, 0x05, 0xC5, 0xC4, 0x04, 0xCC, 0x0C, 0x0D, 0xCD, 0x0F, 0xCF, 0xCE, 0x0E, 0x0A, 0xCA, 0xCB, 0x0B, 0xC9, 0x09, 0x08, 0xC8, 0xD8, 0x18, 0x19, 0xD9, 0x1B, 0xDB, 0xDA, 0x1A, - 0x1E, 0xDE, 0xDF, 0x1F, 0xDD, 0x1D, 0x1C, 0xDC, 0x14, 0xD4, 0xD5, 0x15, 0xD7, 0x17, 0x16, 0xD6, 0xD2, 0x12, 0x13, 0xD3, 0x11, 0xD1, 0xD0, 0x10, 0xF0, 0x30, 0x31, 0xF1, 0x33, 0xF3, 0xF2, 0x32, 0x36, 0xF6, 0xF7, 0x37, 0xF5, 0x35, 0x34, 0xF4, - 0x3C, 0xFC, 0xFD, 0x3D, 0xFF, 0x3F, 0x3E, 0xFE, 0xFA, 0x3A, 0x3B, 0xFB, 0x39, 0xF9, 0xF8, 0x38, 0x28, 0xE8, 0xE9, 0x29, 0xEB, 0x2B, 0x2A, 0xEA, 0xEE, 0x2E, 0x2F, 0xEF, 0x2D, 0xED, 0xEC, 0x2C, 0xE4, 0x24, 0x25, 0xE5, 0x27, 0xE7, 0xE6, 0x26, - 0x22, 0xE2, 0xE3, 0x23, 0xE1, 0x21, 0x20, 0xE0, 0xA0, 0x60, 0x61, 0xA1, 0x63, 0xA3, 0xA2, 0x62, 0x66, 0xA6, 0xA7, 0x67, 0xA5, 0x65, 0x64, 0xA4, 0x6C, 0xAC, 0xAD, 0x6D, 0xAF, 0x6F, 0x6E, 0xAE, 0xAA, 0x6A, 0x6B, 0xAB, 0x69, 0xA9, 0xA8, 0x68, - 0x78, 0xB8, 0xB9, 0x79, 0xBB, 0x7B, 0x7A, 0xBA, 0xBE, 0x7E, 0x7F, 0xBF, 0x7D, 0xBD, 0xBC, 0x7C, 0xB4, 0x74, 0x75, 0xB5, 0x77, 0xB7, 0xB6, 0x76, 0x72, 0xB2, 0xB3, 0x73, 0xB1, 0x71, 0x70, 0xB0, 0x50, 0x90, 0x91, 0x51, 0x93, 0x53, 0x52, 0x92, - 0x96, 0x56, 0x57, 0x97, 0x55, 0x95, 0x94, 0x54, 0x9C, 0x5C, 0x5D, 0x9D, 0x5F, 0x9F, 0x9E, 0x5E, 0x5A, 0x9A, 0x9B, 0x5B, 0x99, 0x59, 0x58, 0x98, 0x88, 0x48, 0x49, 0x89, 0x4B, 0x8B, 0x8A, 0x4A, 0x4E, 0x8E, 0x8F, 0x4F, 0x8D, 0x4D, 0x4C, 0x8C, - 0x44, 0x84, 0x85, 0x45, 0x87, 0x47, 0x46, 0x86, 0x82, 0x42, 0x43, 0x83, 0x41, 0x81, 0x80, 0x40}; - -struct DataFrameFormat frame_send_buffer; // 消息发送缓冲区 -struct DataFrameFormat frame_recv_buffer; // 消息接收缓冲区 -uint8_t data_buffer[LORA_FRAME_USER_MAX_LENGTH]; // 数据发送/接收缓冲区 - -// 按照要求计算出数据帧的校验值 -static uint8_t CalCrcDataFrameFormat(struct DataFrameFormat *frame) -{ - uint8_t crc_hi = 0xFF; - uint8_t crc_lo = 0xFF; - unsigned int temp; - uint8_t *bit_arr = (uint8_t *)frame; // 转化为字节的方式进行数据访问 - - uint8_t *temp_begin = bit_arr + 2; // 指向第二个数据段 - for (int i = 0; i < 5; i++) // 计算第二个字段到第六个字段，计算完毕该指针失效 - { - temp = crc_hi ^ *temp_begin++; - crc_hi = crc_lo ^ table_crc_hi[temp]; - crc_lo = table_crc_lo[temp]; - } - - if (CG_DATA_SEND == frame->frame_type) // 是否携带了上传数据 - { - if (NULL == frame->user_data) - { - printf("CalCrcDataFrameFormat: User data is null\n"); - return -1; - } - uint8_t data_length = frame->attach_data; - temp_begin = frame->user_data; - for (int i = 0; i < data_length; i++) // 计算上传数据的校验值 - { - temp = crc_hi ^ *temp_begin++; - crc_hi = crc_lo ^ table_crc_hi[temp]; - crc_lo = table_crc_lo[temp]; - } - } - - frame->crc_lo = crc_lo; - frame->crc_hi = crc_hi; - - return 0; -} - -// 按照要求计算出数据帧的校验值 -static uint8_t CheckCrcDataFrameFormat(struct DataFrameFormat *frame) -{ - uint8_t crc_hi = 0xFF; - uint8_t crc_lo = 0xFF; - unsigned int temp; - uint8_t *bit_arr = (uint8_t *)frame; // 转化为字节的方式进行数据访问 - - uint8_t *temp_begin = bit_arr + 2; // 指向第二个数据段 - for (int i = 0; i < 5; i++) // 计算第二个字段到第六个字段，计算完毕该指针失效 - { - temp = crc_hi ^ *temp_begin++; - crc_hi = crc_lo ^ table_crc_hi[temp]; - crc_lo = table_crc_lo[temp]; - } - - if (CG_DATA_SEND == frame->frame_type) // 是否携带了上传数据 - { - if (NULL == frame->user_data) - { - printf("CheckCrcDataFrameFormat: User data is null\n"); - return -1; - } - uint8_t data_length = frame->attach_data; - temp_begin = frame->user_data; - for (int i = 0; i < data_length; i++) // 计算上传数据的校验值 - { - temp = crc_hi ^ *temp_begin++; - crc_hi = crc_lo ^ table_crc_hi[temp]; - crc_lo = table_crc_lo[temp]; - } - } - - frame->crc_lo = crc_lo; - frame->crc_hi = crc_hi; - - return (frame->crc_hi == crc_hi && frame->crc_lo == crc_lo) ? 0 : -1; -} - -// 初始化数据帧的头部标识和尾部标识 -static void InitFrame(struct DataFrameFormat *frame) -{ - memset(frame, 0, sizeof(struct DataFrameFormat)); - frame->begin_mark_1 = LORA_FRAME_BEGIN_MARK_1; - frame->begin_mark_2 = LORA_FRAME_BEGIN_MARK_2; - frame->end_mark_1 = LORA_FRAME_END_MARK_1; - frame->end_mark_2 = LORA_FRAME_END_MARK_2; -} - -// 空中信号探测器，用于简易的信道碰撞检测，当一个周期未能收到数据时判定为信道空闲 -static uint8_t SignalDetector(struct Adapter *adapter) -{ - uint8_t temp_dst; - while (1 == AdapterDeviceRecv(adapter, &temp_dst, 1)) // 当读取数据超时时假定为信道空闲 - { - printf("SignalDetector: Channel Occupied\n"); - } - printf("SignalDetector: Channel Idle\n"); - return 0; -} - -// 打印消息头数据 -static void PrintFrame(struct DataFrameFormat *frame, char *prefix) -{ - printf("%s: ", prefix); - printf("client: %X, pan: %X, gateway: %X, frame_type: ", frame->client_id, frame->panid, frame->gateway_id); - switch (frame->frame_type) - { - case CG_NET_JOIN: - printf(" - CG_NET_JOIN- "); - break; - case CG_NET_QUIT: - printf(" - CG_NET_QUIT- "); - break; - case CG_DATA_SEND: - printf(" - CG_DATA_SEND- "); - break; - case GC_REPLY_EXPECTED: - printf(" - GC_REPLY_EXPECTED- "); - break; - case GC_REPLY_UNEXPECTED: - printf(" - GC_REPLY_UNEXPECTED- "); - break; - default: - break; - } - printf("attach_data: %X, crc: %X %X ", frame->attach_data, frame->crc_hi, frame->crc_lo); - if (frame->frame_type == CG_DATA_SEND) - { - frame->user_data[frame->attach_data] = '\0'; - printf("user_data: %s \n", frame->user_data); - } - else - { - printf("\n"); - } -} - -// 接收直到一个完整的数据帧并校验其完整性，不完整的数据会被丢弃 -static uint8_t RecvFrame(struct Adapter *adapter, struct DataFrameFormat *frame) -{ - memset(frame, 0, sizeof(struct DataFrameFormat)); // 缓冲区数据初始化 - uint8_t header_temp[2] = {0, 0}; // 头部数据查找缓冲区，一个用于接收数据，一个用于存储上一次接收到的数据 - - while (1 == AdapterDeviceRecv(adapter, &header_temp[1], 1)) // 查找开始标志 - { - if (LORA_FRAME_BEGIN_MARK_2 == header_temp[1]) // 查找到了第二个标志 - { - if (LORA_FRAME_BEGIN_MARK_1 == header_temp[0]) // 查看上一次的数据是不是第一个标识 - { - frame->begin_mark_1 = header_temp[0]; - frame->begin_mark_2 = header_temp[1]; - // 开始按照结构读取数据 - if (LORA_FRAME_NECK_LENGTH == AdapterDeviceRecv(adapter, &frame->client_id, LORA_FRAME_NECK_LENGTH)) // 接收除可能的用户数据以外的数据 - { - // 判断是否有用户数据 - if (CG_DATA_SEND == frame->frame_type) // 存在用户数据 - { - frame->user_data = data_buffer; // 关联数据缓冲区用于接收数据 - if (frame->attach_data != AdapterDeviceRecv(adapter, data_buffer, frame->attach_data)) // 接收数据 - { - printf("RecvFrame: Timeout or Failed 5\n"); - break; // 接收用户数据失败或者超时 - } - } - // 继续接收接下来的数据 - if (LORA_FRAME_CRC_LENGTH + LORA_FRAME_MARK_LENGTH == AdapterDeviceRecv(adapter, &frame->crc_hi, LORA_FRAME_CRC_LENGTH + LORA_FRAME_MARK_LENGTH)) - { - // 判断数据帧的完善性，看是否有尾巴 - if (LORA_FRAME_END_MARK_1 == frame->end_mark_1 && LORA_FRAME_END_MARK_2 == frame->end_mark_2) - { - // 进行数据完整性校验 - if (0 == CheckCrcDataFrameFormat(frame)) - { - return 0; // 成功接收了一帧数据 - } - printf("RecvFrame: CRC ERROR!\n"); - break; - } - printf("RecvFrame: End ERROR!\n"); - break; - } - printf("RecvFrame: Timeout or Failed 4\n"); - break; - } - printf("RecvFrame: Timeout or Failed 3\n"); - break; // 找到了头数据，却没能收到完整数据的全部失败 - } - else - { - header_temp[0] = header_temp[1]; // 记录这一次的数据 - } - } - else - { - header_temp[0] = header_temp[1]; // 记录这一次的数据 - } - } - - return -1; -} - -// 计算消息头校验并发送出去 -static uint8_t SendFrame(struct Adapter *adapter, struct DataFrameFormat *frame) -{ - // 校验数据 - if (0 == CalCrcDataFrameFormat(frame)) - { - // 发送公共信息 - if (LORA_FRAME_MARK_LENGTH + LORA_FRAME_NECK_LENGTH == AdapterDeviceSend(adapter, frame, LORA_FRAME_MARK_LENGTH + LORA_FRAME_NECK_LENGTH)) - { - // 判断是否有需要发送的用户数据 - if (CG_DATA_SEND == frame->frame_type) - { - if (frame->attach_data != AdapterDeviceSend(adapter, frame->user_data, frame->attach_data)) - { - return -1; - } - } - // 发送剩下的数据 - if (LORA_FRAME_MARK_LENGTH + LORA_FRAME_CRC_LENGTH == AdapterDeviceSend(adapter, &frame->crc_hi, LORA_FRAME_MARK_LENGTH + LORA_FRAME_CRC_LENGTH)) - { - return 0; - } - } - } - return -1; -} - -// 切换Lora的工作模式 -static void LoraModeConfig(struct Adapter *adapter, enum LoraMode mode) -{ - if (adapter->net_protocol == PRIVATE_PROTOCOL) - { - struct PrivProtocolDone *done = (struct PrivProtocolDone *)adapter->done; - done->ioctl(adapter, mode, NULL); - - printf("LoraModeConfig: Config Lora %s\n", mode == LORA_WORK ? "Working" : "Sleeping"); - } - else - { - printf("LoraModeConfig: Config Lora Fail\n"); - } -} - -// 客户端数据帧过滤器 -static uint8_t LoraClientFrameFilter(struct ClientParam *client_param, struct DataFrameFormat *frame) -{ - if (client_param->panid != frame->panid) // 是否是同一个网络 - { - printf("LoraFrameFilter: Different Networks\n"); - return -1; - } - - if (client_param->gateway_id != 0 && client_param->gateway_id != frame->gateway_id) // 不是该客户端所连接的网关 - { - printf("LoraFrameFilter: Different Gateway\n"); - return -1; - } - - if (client_param->client_id != frame->client_id) // 不是该客户端所连接的网关 - { - printf("LoraFrameFilter: Not For This Client\n"); - return -1; - } - - return 0; -} - -// 网关数据帧过滤器 -static uint8_t LoraGatewayFrameFilter(struct GatewayParam *gateway_param, struct DataFrameFormat *frame) -{ - if (gateway_param->panid != frame->panid) // 是否是同一个网络 - { - printf("LoraFrameFilter: Different Networks\n"); - return -1; - } - - if (frame->gateway_id == 0 && frame->frame_type == CG_NET_JOIN) // 入网请求 - { - return 0; - } - - if (frame->gateway_id != gateway_param->gateway_id) // 不是该网关所连接的客户端 - { - printf("LoraFrameFilter: Different Gateway\n"); - return -1; - } - - return 0; -} - -/******************************client_operate*********************************/ -static uint8_t LoraClientConnectState(struct Adapter *adapter, enum ClientState aim_state) -{ - if (aim_state == CLIENT_CONNECT || aim_state == CLIENT_DISCONNECT) // 只支持联网和退网 - { - struct ClientParam *client_param = (struct ClientParam *)adapter->adapter_param; - - if (client_param->client_state == aim_state) // 已经处于目标状态 - { - printf("LoraClientConnectState: Client %s Before\n", aim_state == CLIENT_CONNECT ? "Connect" : "Disconnect"); - return 0; - } - - PrivMutexObtain(&client_param->client_mutex); // 获取lora的使用权 - LoraModeConfig(adapter, LORA_WORK); // 切换Lora到普通接收模式 - - InitFrame(&frame_send_buffer); // 准备数据帧 - frame_send_buffer.client_id = client_param->client_id; - frame_send_buffer.panid = client_param->panid; - frame_send_buffer.gateway_id = client_param->gateway_id; - frame_send_buffer.frame_type = aim_state == CLIENT_CONNECT ? CG_NET_JOIN : CG_NET_QUIT; - - while (1) // 不停的发送信息直到收到正确的响应 - { - SignalDetector(adapter); // 监听信道直到信道空闲 - - if (0 == SendFrame(adapter, &frame_send_buffer)) - { - printf("LoraClientConnectState: Send Frame Success\n"); - PrintFrame(&frame_send_buffer, "LoraClientConnectState Send"); - if (0 == RecvFrame(adapter, &frame_recv_buffer)) // 成功接收到了一个数据帧 - { - printf("LoraClientConnectState: Recv Frame Success\n"); - PrintFrame(&frame_recv_buffer, "LoraClientConnectState Recv"); - if (0 == LoraClientFrameFilter(client_param, &frame_recv_buffer)) // 判断这个数据帧是不是自己 - { - if (frame_recv_buffer.frame_type == GC_REPLY_EXPECTED) // 请求成功 - { - client_param->gateway_id = aim_state == CLIENT_CONNECT ? frame_recv_buffer.gateway_id : 0; - client_param->client_state = aim_state; - - printf("LoraClientConnectState: Success - > Client(%X) Gateway(%X) %s\n", client_param->client_id, client_param->gateway_id, aim_state == CLIENT_CONNECT ? "Connect" : "Disconnect"); - break; - } - else - { - printf("LoraClientConnectState: Fail And Try Again\n"); - } - } - } - else - { - printf("LoraClientConnectState: Recv Frame Failed\n"); - } - } - else - { - printf("LoraClientConnectState: Send Frame Failed\n"); - } - } - - LoraModeConfig(adapter, LORA_SLEEP); // 切换Lora到休眠状态 - PrivMutexAbandon(&client_param->client_mutex); // 释放Lora - - return 0; - } - else - { - printf("LoraClientConnectState: Not Supported!\n"); - return -1; - } -} - -static uint8_t LoraClientSendData(struct Adapter *adapter, uint8_t *data_buffer, uint8_t data_length) -{ - struct ClientParam *client_param = (struct ClientParam *)adapter->adapter_param; - - if (client_param->client_state == CLIENT_CONNECT) // 只有处于联网状态的客户端才可以进行数据传输任务 - { - PrivMutexObtain(&client_param->client_mutex); // 拿到控制权 - LoraModeConfig(adapter, LORA_WORK); // 切换Lora为工作模式 - - InitFrame(&frame_send_buffer); // 准备消息头 - frame_send_buffer.client_id = client_param->client_id; - frame_send_buffer.panid = client_param->panid; - frame_send_buffer.gateway_id = client_param->gateway_id; - frame_send_buffer.frame_type = CG_DATA_SEND; - frame_send_buffer.user_data = data_buffer; // 关联数据缓冲区 - frame_send_buffer.attach_data = data_length; // 数据长度 - - while (1) // 不停的发送信息直到收到正确的响应 - { - SignalDetector(adapter); // 监听信道直到信道空闲 - - if (0 == SendFrame(adapter, &frame_send_buffer)) - { - printf("LoraClientSendData: Send Frame Success\n"); - PrintFrame(&frame_send_buffer, "LoraClientSendData Send"); - if (0 == RecvFrame(adapter, &frame_recv_buffer)) // 成功接收到了一个数据帧 - { - printf("LoraClientSendData: Recv Frame Success\n"); - PrintFrame(&frame_recv_buffer, "LoraClientSendData Recv"); - if (0 == LoraClientFrameFilter(client_param, &frame_recv_buffer)) // 判断这个数据帧是不是自己 - { - if (frame_recv_buffer.frame_type == GC_REPLY_EXPECTED) // 发送成功 - { - printf("LoraClientSendData: Send Data Success\n"); - break; - } - else - { - printf("LoraClientSendData: Fail And Try Again\n"); - } - } - } - else - { - printf("LoraClientSendData: Recv Frame Failed\n"); - } - } - else - { - printf("LoraClientSendData: Send Frame Failed\n"); - } - } - - LoraModeConfig(adapter, LORA_SLEEP); // 切换Lora到睡眠模式 - PrivMutexAbandon(&client_param->client_mutex); // 释放Lora - - return 0; - } - else - { - printf("LoraClientSendData: Client Is Disconnect\n"); - return -1; - } -} - -/**************************gateway_handlers*********************************/ - -// 网关处理客户端入网请求 -static uint8_t GatewayJoinNetHandler(struct Adapter *adapter, struct DataFrameFormat *frame) -{ - PrintFrame(frame, "GatewayJoinNetHandler Recv"); - - struct GatewayParam *gateway_param = (struct GatewayParam *)adapter->adapter_param; - - frame->gateway_id = gateway_param->gateway_id; // 确保网关设备参数正确传递 - - if (gateway_param->client_num == GATEWAY_MAX_CLIENT_NUM) // 判断网关连接的客户端是否达到上限 - { - printf("GatewayJoinNetHandler: Too much client\n"); - frame->frame_type = GC_REPLY_UNEXPECTED; - if (0 != SendFrame(adapter, frame)) - { - printf("GatewayJoinNetHandler: Client(%X) Join Gateway(%X) Failed 1 !\n", frame->client_id, gateway_param->gateway_id); - return -1; - } - PrintFrame(frame, "GatewayJoinNetHandler Send"); - printf("GatewayJoinNetHandler: Client(%X) Join Gateway(%X) Failed (MAX)!\n", frame->client_id, gateway_param->gateway_id); - return -1; - } - - for (int i = 0; i < gateway_param->client_num; i++) // 判断该客户端是否已经连接过了 - { - if (gateway_param->client_infos[i] == frame->client_id) - { - printf("GatewayJoinNetHandler: Joined before\n"); - frame->frame_type = GC_REPLY_EXPECTED; - if (0 != SendFrame(adapter, frame)) - { - printf("GatewayJoinNetHandler: Client(%X) Join Gateway(%X) Failed 2 !\n", frame->client_id, gateway_param->gateway_id); - return -1; - } - PrintFrame(frame, "GatewayJoinNetHandler Send"); - printf("GatewayJoinNetHandler: Client(%X) Join Gateway(%X) Success!\n", frame->client_id, gateway_param->gateway_id); - return 0; - } - } - - gateway_param->client_infos[gateway_param->client_num] = frame->client_id; - gateway_param->client_num++; - frame->frame_type = GC_REPLY_EXPECTED; // 成功连接到网关 - frame->gateway_id = gateway_param->gateway_id; - if (0 != SendFrame(adapter, frame)) - { - printf("GatewayJoinNetHandler: Client(%X) Join Gateway(%X) Failed 3 !\n", frame->client_id, gateway_param->gateway_id); - return -1; - } - PrintFrame(frame, "GatewayJoinNetHandler Send"); - printf("GatewayJoinNetHandler: Client(%X) Join Gateway(%X) Success!\n", frame->client_id, gateway_param->gateway_id); - return 0; -} - -// 网关处理客户端退网请求 -static uint8_t GatewayQuitNetHandler(struct Adapter *adapter, struct DataFrameFormat *frame) -{ - PrintFrame(frame, "GatewayQuitNetHandler Recv"); - - struct GatewayParam *gateway_param = (struct GatewayParam *)adapter->adapter_param; - - for (int i = 0; i < gateway_param->client_num; i++) - { - // 移除这个客户端的信息 - if (gateway_param->client_infos[i] == frame->client_id) - { - for (int j = i; j < gateway_param->client_num - 1; j++) - { - gateway_param->client_infos[j] = gateway_param->client_infos[j + 1]; - } - gateway_param->client_num--; - break; - } - } - - frame->frame_type = GC_REPLY_EXPECTED; - if (0 != SendFrame(adapter, frame)) - { - printf("GatewayQuitNetHandler: Client(%X) Quit Gateway(%X) Failed!\n", frame->client_id, gateway_param->gateway_id); - return -1; - } - PrintFrame(frame, "GatewayQuitNetHandler Send"); - printf("GatewayQuitNetHandler: Client(%X) Quit Gateway(%X) Success!\n", frame->client_id, gateway_param->gateway_id); - return 0; -} - -// 网关处理客户端的数据传输请求 -static uint8_t GatewayDataSendHandler(struct Adapter *adapter, struct DataFrameFormat *frame) -{ - PrintFrame(frame, "GatewayDataSendHandler Recv"); - - frame->frame_type = GC_REPLY_EXPECTED; - - if (0 != SendFrame(adapter, frame)) - { - printf("GatewayDataSendHandler: Client(%X) Send Data To Gateway(%X) Failed!\n", frame->client_id, frame->gateway_id); - return -1; - } - PrintFrame(frame, "GatewayDataSendHandler Send"); - printf("GatewayDataSendHandler: Client(%X) Send Data To Gateway(%X) Success!\n", frame->client_id, frame->gateway_id); - return 0; -} - -// 网关自动程序 -static void *GatewayDaemonTask(void *param) -{ - struct Adapter *gateway_adapter = (struct Adapter *)param; - if (gateway_adapter == NULL) // 判断参数合法性 - { - return NULL; - } - - struct GatewayParam *gateway_param = (struct GatewayParam *)gateway_adapter->adapter_param; - if (gateway_param->gateway_state != GATEWAY_WORKING) - { - if (0 != AdapterDeviceOpen(gateway_adapter)) // 开启Lora模块以接收消息 - { - return NULL; - } - gateway_param->gateway_state = GATEWAY_WORKING; - } - - PrivMutexObtain(&gateway_param->gateway_mutex); // 获取Lora控制权 - - while (1) // 内部业务大循环 - { - if (0 == RecvFrame(gateway_adapter, &frame_recv_buffer) && 0 == LoraGatewayFrameFilter(gateway_param, &frame_recv_buffer)) // 是否接收成功且是发给自己的 - { - gateway_handlers[frame_recv_buffer.frame_type](gateway_adapter, &frame_recv_buffer); // 根据消息类型，调用指定处理函数 - } - else - { - printf("GatewayDaemonTask: Recv No Frame\n"); - } - } - - PrivMutexAbandon(&gateway_param->gateway_mutex); // 释放Lora - - printf("GatewayDaemonTask: Exit!\n"); - return NULL; -} - -/**************************test_funcations*********************************/ -#ifdef AS_LORA_GATEWAY_ROLE - -void TestLoraGateway(void) -{ - struct Adapter *gateway_adapter = (struct Adapter *)AdapterDeviceFindByName(ADAPTER_LORA_NAME); - - UtaskType gateway_task; - gateway_task.prio = 24; - gateway_task.stack_size = 2048; - gateway_task.func_param = gateway_adapter; - gateway_task.func_entry = GatewayDaemonTask; - strncpy(gateway_task.name, "lora_gateway_task", strlen("lora_gateway_task")); - - int32_t gateway_task_id = UserTaskCreate(gateway_task); - - if (gateway_task_id > 0) - { - printf("TestLoraGateway: Create Gateway Task Success\n"); - if (0 == UserTaskStartup(gateway_task_id)) - { - printf("TestLoraGateway: Start Gateway Task Success\n"); - } - else - { - printf("TestLoraGateway: Start Gateway Task Failed\n"); - } - } - else - { - printf("TestLoraGateway: Create Gateway Task Failed\n"); - } -} -PRIV_SHELL_CMD_FUNCTION(TestLoraGateway, TestLoraGateway No Param, PRIV_SHELL_CMD_MAIN_ATTR); - -#else -void TestLoraConnectState(int user_state) -{ - enum ClientState state; - if (user_state == 0) - { - state = CLIENT_DISCONNECT; - printf("TestLoraConnectState: Config Lora Disconnect\n"); - } - else if (user_state == 1) - { - state = CLIENT_CONNECT; - printf("TestLoraConnectState: Config Lora Connect\n"); - } - else - { - printf("TestLoraConnectState: Not Suport 0-CLIENT_DISCONNECT 1-CLIENT_CONNECT\n"); - } - - struct Adapter *client_adapter = (struct Adapter *)AdapterDeviceFindByName(ADAPTER_LORA_NAME); - if (0 == AdapterDeviceOpen(client_adapter)) - { - if (0 == LoraClientConnectState(client_adapter, state)) - { - printf("TestLoraConnectState: Config Lora Connect State Success\n"); - } - else - { - printf("TestLoraConnectState: Config Lora Connect State Failed\n"); - } - } - else - { - printf("TestLoraConnectState: Lora Open Failed\n"); - } -} -PRIV_SHELL_CMD_FUNCTION(TestLoraConnectState, Only Suport 0-CLIENT_DISCONNECT 1-CLIENT_CONNECT, PRIV_SHELL_CMD_FUNC_ATTR); - -void TestLoraSendData(char* data) -{ - struct Adapter *client_adapter = (struct Adapter *)AdapterDeviceFindByName(ADAPTER_LORA_NAME); - if (0 == AdapterDeviceOpen(client_adapter)) - { - if (0 == LoraClientSendData(client_adapter, data,strlen(data))) - { - printf("TestLoraSendData: Send Data Success\n"); - } - else - { - printf("TestLoraSendData: Send Data Failed\n"); - } - } - else - { - printf("TestLoraSendData: Lora Open Failed\n"); - } -} -PRIV_SHELL_CMD_FUNCTION(TestLoraSendData, char* data param, PRIV_SHELL_CMD_FUNC_ATTR); - -void TestLoraClient(void) -{ - struct Adapter *client_adapter = (struct Adapter *)AdapterDeviceFindByName(ADAPTER_LORA_NAME); - if (0 == AdapterDeviceOpen(client_adapter)) - { - printf("TestLoraClient: Open Lora Success!\n"); - if (0 == LoraClientConnectState(client_adapter, CLIENT_CONNECT)) - { - printf("TestLoraClient: Client Join Net Success!\n"); - if (0 == LoraClientSendData(client_adapter, "Hello,Gateway!", strlen("Hello,Gateway!"))) - { - printf("TestLoraClient: Client Send Data Success!\n"); - if (0 == LoraClientConnectState(client_adapter, CLIENT_DISCONNECT)) - { - printf("TestLoraClient: Client Quit Net Success!\n"); - if (0 == LoraClientConnectState(client_adapter, CLIENT_CONNECT)) - { - printf("TestLoraClient: Client Join Net Success!\n"); - } - else - { - printf("TestLoraClient: Client Join Net Failed!\n"); - } - } - else - { - printf("TestLoraClient: Client Quit Net Failed!\n"); - } - } - else - { - printf("TestLoraClient: Client Send Data Fail!\n"); - } - } - else - { - printf("TestLoraClient: Client Join Net Fail!\n"); - } - } - else - { - printf("TestLoraClient: Open Lora Failed!\n"); - } -} -PRIV_SHELL_CMD_FUNCTION(TestLoraClient, TestLoraClient No Param, PRIV_SHELL_CMD_MAIN_ATTR); - -#endif -/*******************LORA ADAPTER FUNCTION********************/ -static int UsrAdapterLoraRegister(struct Adapter *adapter) -{ - int ret = 0; - struct GatewayParam *gateway_param; - struct ClientParam *client_param; - strncpy(adapter->name, ADAPTER_LORA_NAME, NAME_NUM_MAX); - adapter->net_protocol = PRIVATE_PROTOCOL; -#ifdef AS_LORA_GATEWAY_ROLE - gateway_param = PrivMalloc(sizeof(struct GatewayParam)); - if (!gateway_param) - { - PrivFree(gateway_param); - return -1; - } - memset(gateway_param, 0, sizeof(struct GatewayParam)); - gateway_param->gateway_id = DEAFULT_GATEWAY_ID; - gateway_param->panid = DEAFULT_PANID; - gateway_param->gateway_state = GATEWAY_ORIGINAL; - PrivMutexCreate(&gateway_param->gateway_mutex, 0); - adapter->net_role = GATEWAY; - adapter->net_role_id = DEAFULT_GATEWAY_ID; - adapter->adapter_param = (void *)gateway_param; -#else // AS_LORA_CLIENT_ROLE - client_param = PrivMalloc(sizeof(struct ClientParam)); - if (!client_param) - { - PrivFree(client_param); - return -1; - } - memset(client_param, 0, sizeof(struct ClientParam)); - client_param->client_id = DEAFULT_CLIENT_ID; - client_param->panid = DEAFULT_PANID; - client_param->gateway_id = 0; - client_param->client_state = CLIENT_DISCONNECT; - PrivMutexCreate(&client_param->client_mutex, 0); - adapter->net_role = CLIENT; - adapter->net_role_id = DEAFULT_CLIENT_ID; - adapter->adapter_param = (void *)client_param; -#endif - adapter->adapter_status = UNREGISTERED; - ret = AdapterDeviceRegister(adapter); - if (ret < 0) - { - printf("Adapter lora register error\n"); - if (gateway_param) - PrivFree(gateway_param); - if (client_param) - PrivFree(client_param); - return -1; - } - return ret; -} - -int UsrAdapterLoraInit(void) -{ - int ret = 0; - struct Adapter *adapter = PrivMalloc(sizeof(struct Adapter)); - if (!adapter) - { - PrivFree(adapter); - return -1; - } - memset(adapter, 0, sizeof(struct Adapter)); - ret = UsrAdapterLoraRegister(adapter); - if (ret < 0) - { - printf("AdapterLoraInit register lora adapter error\n"); - PrivFree(adapter); - return -1; - } - AdapterProductInfoType product_info = E220Attach(adapter); - if (!product_info) - { - printf("AdapterLoraInit e220 attach error\n"); - PrivFree(adapter); - return -1; - } - adapter->product_info_flag = 1; - adapter->info = product_info; - adapter->done = product_info->model_done; - PrivSemaphoreCreate(&adapter->sem, 0, 0); - PrivMutexCreate(&adapter->lock, 0); - return ret; -} diff --git a/APP_Framework/Applications/app_test/test_lora_p2p/test_lora_p2p.h b/APP_Framework/Applications/app_test/test_lora_p2p/test_lora_p2p.h deleted file mode 100644 index 7e4d690aa..000000000 --- a/APP_Framework/Applications/app_test/test_lora_p2p/test_lora_p2p.h +++ /dev/null @@ -1,157 +0,0 @@ -/* -* Copyright (c) 2023 AIIT XUOS Lab -* XiUOS is licensed under Mulan PSL v2. -* You can use this software according to the terms and conditions of the Mulan PSL v2. -* You may obtain a copy of Mulan PSL v2 at: -* http://license.coscl.org.cn/MulanPSL2 -* THIS SOFTWARE IS PROVIDED ON AN "AS IS" BASIS, WITHOUT WARRANTIES OF ANY KIND, -* EITHER EXPRESS OR IMPLIED, INCLUDING BUT NOT LIMITED TO NON-INFRINGEMENT, -* MERCHANTABILITY OR FIT FOR A PARTICULAR PURPOSE. -* See the Mulan PSL v2 for more details. -*/ - -/** -* @file: test_lora_p2p.h -* @brief: a head file of lora structure -* @version: 1.0 -* @author: Chu yunfei -* @date: 2023/8/30 -*/ - -#include -#include - -#define LORA_FRAME_MAX_LENGTH 128 -#define LORA_FRAME_USER_MAX_LENGTH LORA_FRAME_MAX_LENGTH - 11 -#define LORA_FRAME_BEGIN_MARK_1 0XFF -#define LORA_FRAME_BEGIN_MARK_2 0XAA -#define LORA_FRAME_END_MARK_1 0XFF -#define LORA_FRAME_END_MARK_2 0X00 -#define LORA_FRAME_MARK_LENGTH 2 -#define LORA_FRAME_NECK_LENGTH 5 -#define LORA_FRAME_CRC_LENGTH 2 -#define LORA_FRAME_SEND_INTERVAL 500 - -#define GATEWAY_MAX_CLIENT_NUM 20 - -#define DEFAULT_ID_MAX 125 -#define DEFAULT_ID_MIN 1 -#define DEAFULT_PANID 0XA -#define DEAFULT_CLIENT_ID 0XB -#define DEAFULT_GATEWAY_ID 0XC - -extern AdapterProductInfoType E220Attach(struct Adapter *adapter); - -// Lora工作模式枚举 -enum LoraMode -{ - LORA_SLEEP = 0, // 切换至休眠模式 - LORA_WORK = 1 // 切换至工作模式 -}; - -// 客户端状态 -enum ClientState -{ - CLIENT_DISCONNECT = 0, // 开启但断网 - CLIENT_CONNECT, // 开启且联网 - CLIENT_BROKEN, // 硬件损坏 - CLIENT_CLOSED // 硬件关闭 -}; - -// 客户端参数 -struct ClientParam -{ - uint8_t client_id; - uint8_t panid; - uint8_t gateway_id; - enum ClientState client_state; - pthread_mutex_t client_mutex; // 互斥量 -}; - -// 网关状态 -enum GatewayState -{ - GATEWAY_ORIGINAL= 0, // 关闭且未开始工作 - GATEWAY_WORKING, // 开启且已经开始工作 - GATEWAY_BROKEN // 模块损坏 -}; - -// 网关参数 -struct GatewayParam -{ - uint8_t gateway_id; - uint8_t panid; - uint8_t client_infos[GATEWAY_MAX_CLIENT_NUM]; - uint8_t client_num; - enum GatewayState gateway_state; - pthread_mutex_t gateway_mutex; // 互斥量 -}; - -// 消息类型 -enum FrameType -{ - /*C ---> G*/ - CG_NET_JOIN = 0, // 入网请求 - CG_NET_QUIT, // 退网请求 - CG_DATA_SEND, // 数据传输请求 - /*G ---> C*/ - GC_REPLY_EXPECTED, // 上行请求执行成功 - GC_REPLY_UNEXPECTED, // 上行请求执行失败 -}; -// 消息数据帧格式 -struct DataFrameFormat -{ - uint8_t begin_mark_1; // 0XFF - uint8_t begin_mark_2; // 0XAA - uint8_t client_id; // 0 - 127 - uint8_t panid; // 0 - 127 - uint8_t gateway_id; // 0 - 127 - uint8_t frame_type; // 0 - 127 - uint8_t attach_data; // 0 - 127 - uint8_t* user_data; // 在有数据携带时才会发送该指针所指缓冲区数据 - uint8_t crc_hi; // 这个字节没有0XFF - uint8_t crc_lo; // 这个字节会出现 0XFF，但是他的下一个字节不可能是00，必然是0XFF - uint8_t end_mark_1; // 0XFF - uint8_t end_mark_2; // 0X00 -}; -/******************************client_operate*********************************/ -/** - * @description: 将客户端网络状态切换为联网状态或者离线状态 - * @param adapter - 需要是一个已经打开的设备 - * @param aim_state - 需要转换的状态： CLIENT_CONNECT OR CLIENT_DISCONNECT - * @return success: 0, failure: -1 - */ -static uint8_t LoraClientConnectState(struct Adapter *adapter, enum ClientState aim_state); - -/** - * @description: 在联网状态下向网关发送数据 - * @param adapter - 需要是一个已经打开的设备 - * @param data_buffer - 数据缓冲区地址 - * @param data_length - 数据长度 - * @return success: 0, failure: -1 - */ -static uint8_t LoraClientSendData(struct Adapter *adapter, uint8_t *data_buffer, uint8_t data_length); - -/*****************************gateway_handlers*********************************/ -// 网关处理客户端入网请求 -static uint8_t GatewayJoinNetHandler(struct Adapter* adapter,struct DataFrameFormat* frame); -// 网关处理客户端退网请求 -static uint8_t GatewayQuitNetHandler(struct Adapter* adapter,struct DataFrameFormat* frame); -// 网关处理客户端的数据传输请求 -static uint8_t GatewayDataSendHandler(struct Adapter* adapter,struct DataFrameFormat* frame); -// 网关自动化处理程序任务，需要启动 -static void *GatewayDaemonTask(void *param); - -// 网关处理程序与消息类型的对照表 -static uint8_t (*gateway_handlers[])(struct Adapter*,struct DataFrameFormat*) = -{ - [CG_NET_JOIN] = GatewayJoinNetHandler, - [CG_NET_QUIT] = GatewayQuitNetHandler, - [CG_DATA_SEND] = GatewayDataSendHandler -}; - -/************************lora adapter function*********************************/ -// 自定义注册函数 -static int UserAdapterLoraRegister(struct Adapter *adapter); -// 自定义初始化函数 -int UserAdapterLoraInit(void); \ No newline at end of file