「ZigBee模块」组网实验-信号传输质量检测

 #include "string.h"

void uartInit(void);//**************************
void uartSend(int8 *Data,int len);//**********************

 1 /****************************************************************
 2 串口初始化函数
 3 ****************************************************************/
 4 void initUART(void)
 5 { 
 6     PERCFG = 0x00;              //位置1 P0口
 7     P0SEL = 0x0c;              //P0_2,P0_3用作串口（外部设备功能）
 8     P2DIR &= ~0XC0;          //P0优先作为UART0
 9 
10     U0CSR |= 0x80;              //设置为UART方式
11     U0GCR |= 11;                       
12     U0BAUD |= 216;              //波特率设为115200
13     UTX0IF = 0;               //UART0 TX中断标志初始置位0
14 }

 1 /****************************************************************
 2 串口发送字符串函数            
 3 ****************************************************************/
 4 void uartSend(int8 *Data,int len)
 5 {
 6   int j;
 7   for(j=0;j<len;j++)
 8   {
 9     U0DBUF = *Data++;
10     while(UTX0IF == 0);
11     UTX0IF = 0;
12   }
13 }

 1 void main (void)
 2 {
 3     //变量声明
 4     uint8 appMode;         //用来选择模式（发送或接收）
 5     
 6     appState = IDLE;
 7     
 8     //配置basic RF
 9     basicRfConfig.panId = PAN_ID;
10     basicRfConfig.ackRequest = FALSE;
11 
12     //初始化外围设备
13     halBoardInit();
14 
15     //初始化hal_rf
16     if(halRfInit()==FAILED) {
17       HAL_ASSERT(FALSE);
18     }
19     
20     //点亮led1（P1.0）用以表示程序开始运行
21     halLedSet(1);
22 
23     //信道设置 11—25都可以
24     basicRfConfig.channel = 0x0B;
25 
26     //这里就是模式选择啦，选择完进入那个函数，然后main函数就不需要啦
27     //这个怎么选？？
28     //看MODE_SEND，go to definition，找到定义的地方
29     //把那行代码注释掉就是接收部分，不注释就是发送
30     #ifdef MODE_SEND
31      appMode = MODE_TX;
32     #else
33      appMode = MODE_RX;
34     #endif  
35     // Transmitter application
36     if(appMode == MODE_TX) {
37         // No return from here
38         appTransmitter();
39     }
40     // Receiver application
41     else if(appMode == MODE_RX) {
42         // No return from here
43         appReceiver();
44     }
45     // Role is undefined. This code should not be reached
46     HAL_ASSERT(FALSE);
47 }

 1 static void appTransmitter()
 2 {
 3   //声明变量
 4   uint32 burstSize=0;     //设定进行一次测试所发送的数据包数量
 5   uint32 pktsSent=0;      //指示当前已经发了多少个数据包
 6   uint8 n;
 7 
 8   //初始化Basic RF
 9   basicRfConfig.myAddr = TX_ADDR;
10   if(basicRfInit(&basicRfConfig)==FAILED) 
11   {
12     HAL_ASSERT(FALSE);
13   }
14 
15   //置输出功率
16   halRfSetTxPower(2);
17 
18   //设置进行一次测试所发送的数据包数量 
19   burstSize = 1000;
20 
21   //关闭接收模块，省电
22   basicRfReceiveOff();
23 
24   //配置定时器和IO
25   //暂时不知道有什么用...以后补上
26   appConfigTimer(0xC8);
27 
28   //初始化数据包载荷
29   //txPacket是什么？ 就是一个数据包~在per_test.h中！
30   //里面有两个变量，seqNumber和padding[6]
31   //就是说一个数据包里面有6个字节的内容和一个表示序号的seqNumber
32   //讲一下seqNumber 就是拿来当序号用，发送时按012345这样的顺序发送，所以理应012345这样接受
33   //如果这次收到3，下次收到5，那就表示丢包了
34   txPacket.seqNumber = 0;
35   for(n = 0; n < sizeof(txPacket.padding); n++)  //初始化下，数据包里面就是012345
36   {
37     txPacket.padding[n] = n;
38   }
39 
40   //主循环
41   while (TRUE) 
42   {
43     if (pktsSent < burstSize) //如果数据包还没有发送完，继续执行
44     {
45       // 改变发送序号的字节顺序
46       //我也不知道为什么要改变顺序再改回来，可能和数据发送的一些协议有关吧，以后知道再补上
47       UINT32_HTON(txPacket.seqNumber);
48       
49       //发送数据函数（发给谁， 发的内容， 数据长度） 重点就是这行代码！
50       //注意下，发送的就是txPacket这一整个数据，包括实际内容和序号，这是一个完整的数据包
51       basicRfSendPacket(RX_ADDR, (uint8*)&txPacket, PACKET_SIZE);
52 
53       //在增加序号前将字节顺序改回为主机顺序
54       UINT32_NTOH(txPacket.seqNumber);
55       txPacket.seqNumber++; //发的序号+1 
56 
57       pktsSent++;           //发送了一个数据包了 +1
58 
59       halLedToggle(1);   //改变LED1的亮灭状态
60       halMcuWaitMs(500); //延时
61     }
62       //数据包清零
63      pktsSent = 0;
64 
65   }
66 }

  1 static void appReceiver()
  2 {
  3   uint32 segNumber=0;                              // 数据包序列号 
  4   int16 perRssiBuf[RSSI_AVG_WINDOW_SIZE] = {0};    // 存储RSSI的环形缓冲区
  5   uint8 perRssiBufCounter = 0;                     // 计数器用于RSSI缓冲区统计
  6  
  7   perRxStats_t rxStats = {0,0,0,0};      
  8    int16 rssi;
  9   uint8 resetStats=FALSE;
 10   
 11   int8 Myper[5];        
 12   int8 Myrssi[2];
 13   int8 Myreceive[4];
 14   int32 temp_per;           //存放掉包率
 15   int32 temp_receive;       //存放接收的包的个数
 16   int32 temp_rssi;          //存放前32个rssi值的平均值
 17   uartInit();               // 初始化串口
 18   
 19 #ifdef INCLUDE_PA
 20   uint8 gain;
 21 
 22   // Select gain (for modules with CC2590/91 only)
 23   gain =appSelectGain();
 24   halRfSetGain(gain);
 25 #endif
 26     
 27    // Initialize BasicRF     初始化Basic RF 
 28   basicRfConfig.myAddr = RX_ADDR;
 29   if(basicRfInit(&basicRfConfig)==FAILED) 
 30   {
 31     HAL_ASSERT(FALSE);
 32   }
 33   //打开接收模块
 34   basicRfReceiveOn();
 35 
 36   /* 主循环 */
 37   uartSend("PER_test: ",strlen("PER_test: ")); //串口发送数据
 38     // Main loop
 39   while (TRUE) 
 40   {
 41     while(!basicRfPacketIsReady());  // 等待新的数据包
 42     //查看之后发行这里的rxPacket和发送里面的txPacket是同一种数据类型
 43     //basicRfReceive（指向数据缓冲区的指针，缓冲区最大数据长度，这个包的rssi值）
 44     //返回缓冲区实际数据长度
 45     if(basicRfReceive((uint8*)&rxPacket, MAX_PAYLOAD_LENGTH, &rssi)>0) {
 46          halLedSet(2);//*************P1_1 LED2点亮
 47             
 48       UINT32_NTOH(rxPacket.seqNumber);  // 改变接收序号的字节顺序
 49       segNumber = rxPacket.seqNumber;   //读取包的序号
 50             
 51       // If statistics is reset set expected sequence number to
 52       // received sequence number 
 53       //若统计被复位，设置期望收到的数据包序号为已经收到的数据包序号  
 54       //怎么样被认为统计复位？在后面~
 55       if(resetStats)
 56       {
 57         rxStats.expectedSeqNum = segNumber;
 58         
 59         resetStats=FALSE;
 60       }  
 61       
 62       //下面这几行代码是用来计算上32个包的RSSI值的
 63       //先预设一个32个长度的数组，用来存放RSSI值，一个指针，指示最旧的一个RSSI值
 64       //每次获取新的包后，把最旧的RSSI值从总和处减去，再把新的RSSI值放入，并把它的值加入总和
 65       // Subtract old RSSI value from sum
 66       rxStats.rssiSum -= perRssiBuf[perRssiBufCounter];  // 从sum中减去旧的RSSI值
 67       // Store new RSSI value in ring buffer, will add it to sum later
 68       perRssiBuf[perRssiBufCounter] =  rssi;  // 存储新的RSSI值到环形缓冲区，之后它将被加入sum
 69       rxStats.rssiSum += perRssiBuf[perRssiBufCounter];  // 增加新的RSSI值到sum
 70       //如果指针超出数组最大值，复位指针
 71       if(++perRssiBufCounter == RSSI_AVG_WINDOW_SIZE) {
 72         perRssiBufCounter = 0;      
 73       }
 74 
 75       
 76       //检查接收到的数据包是否是所期望收到的数据包
 77       // 是所期望收到的数据包
 78       if(rxStats.expectedSeqNum == segNumber)   
 79       {
 80         rxStats.expectedSeqNum++;  
 81       }
 82       
 83       // 不是所期望收到的数据包（大于期望收到的数据包的序号）
 84       // 认为丢包
 85       else if(rxStats.expectedSeqNum < segNumber)  
 86       {                                            
 87         rxStats.lostPkts += segNumber - rxStats.expectedSeqNum;
 88         rxStats.expectedSeqNum = segNumber + 1;
 89       }
 90       
 91       // (小于期望收到的数据包的序号）
 92       //认为是一个新的测试开始，复位统计变量
 93       else  
 94       {              
 95         rxStats.expectedSeqNum = segNumber + 1;
 96         rxStats.rcvdPkts = 0;
 97         rxStats.lostPkts = 0;
 98       }
 99       rxStats.rcvdPkts++;
100       
101       //以下代码都是用于串口输出计算值的
102       temp_receive=(int32)rxStats.rcvdPkts;
103        if(temp_receive>1000)
104       {
105        if(halButtonPushed()==HAL_BUTTON_1){
106        resetStats = TRUE;
107        rxStats.rcvdPkts = 1;
108        rxStats.lostPkts = 0;
109         }
110       }
111 
112       Myreceive[0]=temp_receive/100+‘0‘;
113       Myreceive[1]=temp_receive%100/10+‘0‘;
114       Myreceive[2]=temp_receive%10+‘0‘;
115       Myreceive[3]=‘\0‘;
116       uartSend("RECE:",strlen("RECE:"));
117       uartSend(Myreceive,4);
118       uartSend("    ",strlen("    "));   
119       
120       temp_per = (int32)((rxStats.lostPkts*1000)/(rxStats.lostPkts+rxStats.rcvdPkts));
121       Myper[0]=temp_per/100+‘0‘;
122       Myper[1]=temp_per%100/10+‘0‘; 
123       Myper[2]=‘.‘;
124       Myper[3]=temp_per%10+‘0‘;
125       Myper[4]=‘%‘;
126       uartSend("PER:",strlen("PER:"));
127       uartSend(Myper,5);
128       uartSend("    ",strlen("    "));
129      
130       temp_rssi=(0-(int32)rxStats.rssiSum/32);
131       Myrssi[0]=temp_rssi/10+‘0‘;
132       Myrssi[1]=temp_rssi%10+‘0‘;
133       uartSend("RSSI:-",strlen("RSSI:-"));
134       uartSend(Myrssi,2);        
135       uartSend("\n",strlen("\n"));
136 
137       halLedClear(2);
138 
139       halMcuWaitMs(300);
140     }                    
141   }
142 }