📄 s2onenddevice.c
字号:
/*********************************************************************
*
* End Device 数据发送接收和验证统计
*
*********************************************************************
* FileName: S2OnEndDevice.c
* Dependencies:
* Processor: PIC18F
* Complier: MCC18 v2.30 or higher
*~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~
* Nilesh Rajbharti 7/12/04 Rel 0.9
********************************************************************/
// Uncommnt ENABLE_DEBUG line to enable debug mode for this file.
// Or you may also globally enable debug by defining this macro
// in zigbee.def file or from compiler command-line.
#ifndef ENABLE_DEBUG
//#define ENABLE_DEBUG
#endif
#include "zigbee.h"
#include "S2OnEndDevice.h"
#include "Console.h"
#include "Debug.h"
#include "zMAC.h"
#include "Tick.h"
void writeLED(unsigned char data);
#define MAX_SW_RETRY_COUNT (3)
#define D1 LATA0
#define D2 LATA1
typedef enum _SM_STATE
{
SM_IDLE = 0,
SM_UPDATE,
SM_WAIT
} SM_STATE;
SM_STATE s2State;
BYTE s2Value;
BYTE s2RetryCount;
long s2LeaveToSend;
long sendCount,receiveOkCount;
SUB_MAC_FRAME submacCurrentFrame;
//static ROM char * const S2RetryMsg = "S2: Retrying switch update...\r\n";
static ROM char * const S2UpdateMsg = "S2: Sending switch update...\r\n";
static ROM char * const S2ConfirmMsg = "S2: Confirmed switch update.\r\n";
static ROM char * const S2RetriesExhaustedMsg = "S2: Exhausted switch update retries; removing it...\r\n";
static ROM char * const sendCountMsg = "Total message send : ";
static ROM char * const receiveOkCountMsg = "Total message receive ok: ";
static ROM char * const sendTaskFinshedMsg = "Send Task Finshed. \r\n";
void S2Init(void)
{
s2Value = 0;
s2LeaveToSend = 0;
sendCount = receiveOkCount = 0;
writeLED(0);
macState.bits.bIsAssociated = TRUE;
}
void SendTaskStart(long maxtosend)
{
if( s2LeaveToSend == 0 )
{
ConsolePutROMString("Task start.\r\n");
s2LeaveToSend = maxtosend;
s2Value = 0;
sendCount = receiveOkCount = 0;
//NWKStartDiscovery();
}
}
BYTE hMyFrame; // Handle to last sent frame.
NODE_INFO dest;
void SendBeaconMy1(void);
void BroadcastUniteReq(void);
BOOL S2Task(void)
{
if( s2LeaveToSend > 0 && MACIsPutReady() )
{s2LeaveToSend --;
sendCount ++;
D1 ^= 1;
MACStartScan(TRUE) ;
BroadcastUniteReq();}
//SEND(MEMBER_ALERT);
return TRUE;
}
// Private copy of handle to lamp endpoint.
// Lamp states
typedef enum _SM_STATE
{
SM_IDLE = 0,
SM_WAIT,
SM_UPDATE_WAIT,
SM_REQ_UPDATE,
SM_REQ_UPDATE_WAIT
} SM_STATE;
// Lamp state
static SM_STATE smD1;
// To keep track of time.
static TICK lastTick;
// Once we request data from coordinator, we must receive response within this time.
//#define MAX_UPDATE_WAIT (TICK_SECOND*1/20)
#define MAX_UPDATE_WAIT (TICK_SECOND*1)
//extern BYTE Destination[2];
void D1Init(void)
{
}
BOOL D1Task(void)
{ // BYTE a;
//add by zhangfen
// a=submacCurrentFrame.sub_type.Val;
// submacCurrentFrame.sub_type.Val=0xff;
if(submacCurrentFrame.sub_dest_addr.v[0]==thisnode.NODEID[0]&&submacCurrentFrame.sub_dest_addr.v[1]==thisnode.NODEID[1])
{D2=1;
return TRUE;}
if(submacCurrentFrame.sub_dest_addr.v[0]==0xff&&submacCurrentFrame.sub_dest_addr.v[0]==0xff)
{D2=1;
return TRUE;}
if(submacCurrentFrame.sub_type.Val==0xff)
{D2=1;
return TRUE;}
return FALSE;
}
//a=0xff;
// return a;
//}
void ConsolePutData(long longval)
{
char i;
BYTE dig;
long divider;
divider=100000;
for(i=6; divider>longval && i>1 ;i--)
{
divider/=10;
ConsolePut(' ');
}
for(;i>0;i--)
{
dig = (longval/divider);
longval = (longval%divider);
ConsolePut(dig+0x30);
divider/=10;
}
ConsolePut('\r');
ConsolePut('\n');
}
/********************************************************************************/
/* by zwcai -- This routine outputs an integer value in decimal TO LEDs */
/********************************************************************************/
#define MC14094_load LATA3
#define MC14094_data LATA4
#define MC14094_clk LATA5
const char table[20]={0x3F,0x06,0x5B,0x4F,0x66,0x6D,0x7D,0x27,0x7F,0x6F, // 0-9
0x77,0x7C,0x39,0x5E,0x79,0x71,0x80,0x40,0x76,0x00}; // A-F,.,-,H
void writeLED(unsigned char data)
{
unsigned char i,j;
unsigned char command;
MC14094_load = 0; //命令开始
data&=0x7F;
command = table[data%10];
for(j=0;j<2;j++)
{
for(i=0;i<8;i++){ //送入8位数据，高位在前
if(command < 0x80)
MC14094_data = 0;
else MC14094_data = 1;
MC14094_clk = 0;
command <<= 1;
MC14094_clk = 1; //上升沿有效
}
data = data/10;
if(data>0)
command = table[data];
else command = table[19];
}
MC14094_load=1; //加载数据
}
/*********************************************************************
* Function: static void SendBeaconMy1(void)
*
* PreCondition: MACIsPutready() = TRUE
*
* Input: None
*
* Output: None
*
* Side Effects: None
*
* Overview: Sends out beacon request
*
* Note: add by zwcai
********************************************************************/
void SendBeaconMy1(void)
{
BYTE mydata[10];
// Now that we are trying to associate, forget previous PAN ID
macInfo.addrMode = MAC_SRC_NO_ADDR;
// Coordinator info will be same as what was received in beacon.
// But for time being use hardcoded value to test out...
dest.addrMode = MAC_DST_SHORT_ADDR;
dest.shortAddr.Val = 0xffff;
dest.panID.Val = 0xffff;
MACPutHeader(&dest, // Dest
MAC_FRAME_CMD | // Frame Control LSB
MAC_SECURITY |
MAC_FRAME_PENDING_NO |
MAC_ACK_NO |
MAC_INTRA_PAN_NO);
// Load beacon req specific bytes in payload area.
mydata[0] = MAC_CMD_BEACON_REQ;
mydata[1] = 0x55;
mydata[2] = 0xAA;
MACPutArray(mydata,3);
// Mark it as ready to transmit
MACFlush();
}
/*********************************************************************
* Function: static void BroadcastUniteReq(void)
*
* PreCondition: MACIsPutready() = TRUE
*
* Input: None
*
* Output: None
*
* Side Effects: None
*
* Overview: Sends out beacon request
*
* Note: add by zhangfen
********************************************************************/
void BroadcastUniteReq(void)
{
BYTE mydata[10];
// Now that we are trying to associate, forget previous PAN ID
macInfo.addrMode = MAC_SRC_NO_ADDR;
// Coordinator info will be same as what was received in beacon.
// But for time being use hardcoded value to test out...
dest.addrMode = MAC_DST_SHORT_ADDR;
dest.shortAddr.Val = 0xffff;
dest.panID.Val = 0xffff;
MACPutHeader(&dest, // Dest
MAC_FRAME_DATA | // Frame Control LSB
MAC_SECURITY |
MAC_FRAME_PENDING_NO |
MAC_ACK_NO |
MAC_INTRA_PAN_NO);
mydata[0]=UNITE_REQ;
mydata[1]=0xff;
mydata[2]=0xff;
mydata[3]=macInfo.longAddr.v[0] ;
mydata[4]=macInfo.longAddr.v[1] ;
MACPutArray(mydata,5);
// Mark it as ready to transmit
MACFlush();
}
/*********************************************************************
* Function: static void SendResponseUniteReq(void)
*
* PreCondition: MACIsPutready() = TRUE
*
* Input: None
*
* Output: None
*
* Side Effects: None
*
* Overview: Sends out beacon request
*
* Note: add by zhangfen
********************************************************************/
void SendResponseUniteReq(void)
{
BYTE mydata[10];
// Now that we are trying to associate, forget previous PAN ID
macInfo.addrMode = MAC_SRC_NO_ADDR;
// Coordinator info will be same as what was received in beacon.
// But for time being use hardcoded value to test out...
dest.addrMode = MAC_DST_SHORT_ADDR;
dest.shortAddr.Val = 0xffff;
dest.panID.Val = 0xffff;
MACPutHeader(&dest, // Dest
MAC_FRAME_DATA | // Frame Control LSB
MAC_SECURITY |
MAC_FRAME_PENDING_NO |
MAC_ACK_NO |
MAC_INTRA_PAN_NO);
mydata[0]=RESPONSE_UNITE_REQ;
mydata[1]=0xff;
mydata[2]=0xff;
mydata[3]=macInfo.longAddr.v[0] ;
mydata[4]=macInfo.longAddr.v[1] ;
MACPutArray(mydata,5);
// Mark it as ready to transmit
MACFlush();
}
extern BYTE Newcaptain[2];
void SEND(BYTE n)
{BYTE mydata[MAX_NUM*2+7];
BYTE frame=n;
BYTE i;
BYTE j;
while(! MACIsPutReady() );
D1=1;
// Now that we are trying to associate, forget previous PAN ID
macInfo.addrMode = MAC_SRC_NO_ADDR;
// Coordinator info will be same as what was received in beacon.
// But for time being use hardcoded value to test out...
dest.addrMode = MAC_DST_SHORT_ADDR;
dest.shortAddr.Val = 0xffff;
dest.panID.Val = 0xffff;
MACPutHeader(&dest, // Dest
MAC_FRAME_DATA | // Frame Control LSB
MAC_SECURITY |
MAC_FRAME_PENDING_NO |
MAC_ACK_NO|
MAC_INTRA_PAN_NO);
mydata[0]=frame;
switch(frame)
{
case UNITE_REQ:
mydata[1]=0xff;
mydata[2]=0xff;
mydata[3]=macInfo.longAddr.v[0] ;
mydata[4]=macInfo.longAddr.v[1] ;
mydata[5]=1;
mydata[6]=thisnode.MEMBERNUM;
MACPutArray(mydata,7);
MACFlush();
ConsolePutROMString("Broadcast a unite req frame!\r\n");
break;
case RESPONSE_UNITE_REQ:
mydata[1]=submacCurrentFrame.sub_source_addr.v[0];
mydata[2]=submacCurrentFrame.sub_source_addr.v[1];
mydata[3]=macInfo.longAddr.v[0] ;
mydata[4]=macInfo.longAddr.v[1] ;
mydata[5]=thisnode.MEMBERNUM*2+1;
mydata[6]=thisnode.MEMBERNUM;
j=7;
for(i=0;i<thisnode.MEMBERNUM*2;i++)
{
mydata[j]=thisnode.MEMBER_OR_CAPTAIN[i];
j++;
}
MACPutArray(mydata,7+thisnode.MEMBERNUM*2);
MACFlush();
ConsolePutROMString("Receive a unite req frame and send a response frame \r\n");
break;
case ACK_UNITE:
mydata[1]=submacCurrentFrame.sub_source_addr.v[0];
mydata[2]=submacCurrentFrame.sub_source_addr.v[1];
mydata[3]=macInfo.longAddr.v[0] ;
mydata[4]=macInfo.longAddr.v[1] ;
mydata[5]=thisnode.MEMBERNUM*2+3;
mydata[6]=thisnode.MEMBERNUM;
j=7;
for(i=0;i<thisnode.MEMBERNUM*2;i++)
{
mydata[j]=thisnode.MEMBER_OR_CAPTAIN[i];
j++;
}
mydata[j]=Newcaptain[0];
mydata[j+1]=Newcaptain[1];
MACPutArray(mydata,9+thisnode.MEMBERNUM*2);
MACFlush();
ConsolePutROMString("Receive a response unite req frame and send a ack frame \r\n");
break;
case CAPTAIN_INF:
mydata[1]=0xff;
mydata[2]=0xff;
mydata[3]=macInfo.longAddr.v[0] ;
mydata[4]=macInfo.longAddr.v[1] ;
mydata[5]=2;
mydata[6]=submacCurrentFrame.sub_source_addr.v[0];
mydata[7]=submacCurrentFrame.sub_source_addr.v[1];
MACPutArray(mydata,8);
MACFlush();
ConsolePutROMString("This node is changed to be a member!");
break;
case QUERY_MEMBER:
mydata[1]=0xff;
mydata[2]=0xff;
mydata[3]=macInfo.longAddr.v[0] ;
mydata[4]=macInfo.longAddr.v[1] ;
mydata[5]=0;
MACPutArray(mydata,6);
MACFlush();
ConsolePutROMString("Send a member query frame!\r\n ");
break;
case ACK_QUER:
mydata[1]=submacCurrentFrame.sub_source_addr.v[0];
mydata[2]=submacCurrentFrame.sub_source_addr.v[1];
mydata[3]=macInfo.longAddr.v[0] ;
mydata[4]=macInfo.longAddr.v[1] ;
mydata[5]=0;
MACPutArray(mydata,6);
MACFlush();
ConsolePutROMString("Recevie a query frame and send a ack!\r\n ");
break;
case MEMBER_ALERT:
mydata[1]=thisnode.MEMBER_OR_CAPTAIN[0];
mydata[2]=thisnode.MEMBER_OR_CAPTAIN[1];
mydata[3]=macInfo.longAddr.v[0] ;
mydata[4]=macInfo.longAddr.v[1] ;
mydata[5]=0;
MACPutArray(mydata,6);
MACFlush();
ConsolePutROMString("This node is in danger!Send a alert to its captain!\r\n ");
break;
}
// Mark it as ready to transmit
D1=0;
}
void Send1(void)
{
BYTE mydata[10];
// Now that we are trying to associate, forget previous PAN ID
macInfo.addrMode = MAC_SRC_NO_ADDR;
// Coordinator info will be same as what was received in beacon.
// But for time being use hardcoded value to test out...
dest.addrMode = MAC_DST_SHORT_ADDR;
dest.shortAddr.Val = 0x00;
dest.panID.Val = 0xffff;
MACPutHeader(&dest, // Dest
MAC_FRAME_CMD | // Frame Control LSB
MAC_SECURITY |
MAC_FRAME_PENDING_NO |
MAC_ACK_NO |
MAC_INTRA_PAN_NO);
// Load beacon req specific bytes in payload area.
mydata[0] = MAC_CMD_BEACON_REQ;
mydata[1] = 0x55;
mydata[2] = 0xAA;
MACPutArray(mydata,3);
// Mark it as ready to transmit
MACFlush();
}
⌨️ 快捷键说明
复制代码
Ctrl + C
搜索代码
Ctrl + F
全屏模式
F11
切换主题
Ctrl + Shift + D
显示快捷键
?
增大字号
Ctrl + =
减小字号
Ctrl + -