| | |
| | | |
| | | extern bool IrqFired; |
| | | |
| | | bool RadioEnableMaster=true;//主从选择 |
| | | uchar nRadioChannel = 0; |
| | | uchar nRadioAddr = 1; |
| | | //bool RadioEnableMaster=true;//主从选择 |
| | | //uchar nRadioChannel = 0; |
| | | //uchar nRadioAddr = 1; |
| | | uint16_t crc_value; |
| | | |
| | | #define MixAddr(x,y) ((x<<4)|(y)) |
| | | /*! |
| | | * Radio events function pointer |
| | | */ |
| | | #define MASTER_RX_TIMEOUT_VALUE 80 //mS |
| | | #define SLAVE_RX_TIMEOUT_VALUE 400 //mS |
| | | #define CYCLE_TIME 120 //mS |
| | | |
| | | const stWLConfig defaultWLConfig = |
| | | { |
| | | .RF_T_Freq = 430620000, // uint32_t Hz |
| | | .RF_R_Freq = 430620000, //uint32_t //Hz |
| | | .RF_R_Freq = 430620000, // uint32_t //Hz |
| | | .nChnSpacing = 530, // uint16_t ChannelSpacing; //kHz |
| | | .nCycleTime = CYCLE_TIME, // CyCleTime |
| | | .workMode = 1, // uchar workMode; //0: FSK, 1: LoRa |
| | | .Tx_Power = 22, // uchar Tx_Power; |
| | | .LoraBandWidth = 0, // uchar LoraBandWidth; // [0: 125 kHz, 1: 250 kHz, 2: 500 kHz, 3: Reserved ] |
| | | .nChannel = 0, |
| | | .bMaster = 0, |
| | | .nRadioAddr =1 , |
| | | .bEnableMulti = 0, |
| | | |
| | | .Tx_Power = 20, // uchar Tx_Power; |
| | | .LoraBandWidth = 1, // uchar LoraBandWidth; // [0: 125 kHz, 1: 250 kHz, 2: 500 kHz, 3: Reserved ] |
| | | .LoRaFactor = 5, // uchar LoRaFactor; // [SF5 .. SF 12] |
| | | .LoRaCodingRate = 1, // uchar LoRaCodingRate; // [1 : 4/5, 2: 4/6, 3: 4/7, 4: 4/8 |
| | | .NetWorkAddr = 0x00, // uint8_t NetWorkAddr; |
| | |
| | | .bEnableEncrypt = 0, // uchar bEnableEncrypt; |
| | | .bEnableRelay = 0, // uchar bEnableRelay; |
| | | .LoRaPreambleLen = 4, // uchar LoRaPreamble_Len; // 2 - 12 |
| | | .bAutoPower = 1, |
| | | .bAutoReSend = 1, // 自动重发 |
| | | }; |
| | | |
| | |
| | | TX_TIMEOUT, |
| | | }States_t; |
| | | |
| | | #define MASTER_RX_TIMEOUT_VALUE 80 //mS |
| | | #define SLAVE_RX_TIMEOUT_VALUE 400 //mS |
| | | #define CYCLE_TIME 160 //mS |
| | | |
| | | |
| | | #define WL_RX_BUFFER_SIZE 256 // Define the payload size here |
| | | #define WL_TX_BUFFER_SIZE 128 // Define the payload size here |
| | |
| | | int KWireLessInit(bool bRadioEnableMaster, uint32_t nChn) |
| | | { |
| | | stWLConfig * pWLCfg = & WLCfg; |
| | | RadioEnableMaster = bRadioEnableMaster; |
| | | pWLCfg->bMaster = bRadioEnableMaster; |
| | | // Radio initialization |
| | | RadioEvents.TxDone = OnTxDone; |
| | | RadioEvents.RxDone = OnRxDone; |
| | |
| | | RadioEvents.CadDone = OnCadDone; |
| | | |
| | | Radio.Init( &RadioEvents ); |
| | | nRadioChannel = nChn; |
| | | KwRunStat.RF_Freq = pWLCfg->RF_T_Freq + nRadioChannel * pWLCfg->nChnSpacing*1000; |
| | | pWLCfg->nChannel = nChn; |
| | | KwRunStat.RF_Freq = pWLCfg->RF_T_Freq + pWLCfg->nChannel * pWLCfg->nChnSpacing*1000; |
| | | |
| | | Radio.SetChannel( pWLCfg->RF_T_Freq + nRadioChannel * pWLCfg->nChnSpacing*1000 ); |
| | | Radio.SetChannel( KwRunStat.RF_Freq ); |
| | | |
| | | // Radio.WriteBuffer(0x06C0,data,2); |
| | | // Radio.ReadBuffer(0x06C0,test,2); |
| | |
| | | #endif |
| | | SX126xSetRxTxFallbackMode(0x40); // 0x40-> FS 0x30 -> SD_XOSC 0x20 -> SD_RC |
| | | |
| | | SX126xSetCadParams(LORA_CAD_04_SYMBOL,0,1,LORA_CAD_ONLY,1); |
| | | SX126xSetCadParams(LORA_CAD_02_SYMBOL,22,10,LORA_CAD_ONLY,1); |
| | | |
| | | nTimeOnAir = Radio.TimeOnAir(MODEM_LORA,14); |
| | | KwRunStat.nTimeOnAir = nTimeOnAir; |
| | | KMem.WDT[38]=nTimeOnAir; |
| | | KwRunStat.runStep=RS_IDEL; |
| | | // KMem.WDT[38]=nTimeOnAir; |
| | | KwRunStat.runStep=RS_IDLE; |
| | | KMem.WDT[0]++; |
| | | KwRunStat.Tx_Power = WLCfg.Tx_Power; |
| | | KwRunStat.LoraBandWidth = WLCfg.LoraBandWidth; |
| | | KwRunStat.LoRaFactor = WLCfg.LoRaFactor; |
| | | KwRunStat.LoRaCodingRate = WLCfg.LoRaCodingRate; |
| | | KwRunStat.LoRaPreambleLen = WLCfg.LoRaPreambleLen; |
| | | |
| | | return 0; |
| | | } |
| | | |
| | | int KWireLessStart(void) |
| | | int KwResetRf() |
| | | { |
| | | if(RadioEnableMaster) |
| | | { |
| | | KWLMasterSendReqPkt(1); |
| | | } |
| | | else |
| | | { |
| | | // LoadKwConfig(); |
| | | // KWireLessInit(RadioEnableMaster,nRadioChannel); |
| | | Radio.Standby(); |
| | | KwRunStat.runStep=RS_IDLE; |
| | | return 0; |
| | | } |
| | | |
| | | int KwStartRecv(int nChnd) |
| | | { |
| | | Radio.Standby(); |
| | | Radio.SetChannel( KwRunStat.RF_Freq ); |
| | | Radio.SetRxConfig( MODEM_LORA, WLCfg.LoraBandWidth, WLCfg.LoRaFactor, |
| | | WLCfg.LoRaCodingRate, 0, WLCfg.LoRaPreambleLen, |
| | | LORA_SYMBOL_TIMEOUT, LORA_FIX_LENGTH_PAYLOAD_ON, |
| | | 0, true, 0, 0, LORA_IQ_INVERSION_ON, false ); |
| | | |
| | | Radio.SetMaxPayloadLength(MODEM_LORA,32); |
| | | |
| | | Radio.Rx( SLAVE_RX_TIMEOUT_VALUE ); |
| | | KwRunStat.runStep=RS_RECVING; |
| | | |
| | | KwRunStat.lastActTime = GetTick(); |
| | | KwRunStat.lastRecvtime = GetTick(); |
| | | return 0; |
| | | } |
| | | |
| | | int KWireLessStart(void) |
| | | { |
| | | if(WLCfg.bMaster) |
| | | { |
| | | KWLMasterSendReqPkt(1); |
| | | } |
| | | else |
| | | { |
| | | KwStartRecv(1); |
| | | } |
| | | |
| | | // while( 1 ) |
| | |
| | | return 0; |
| | | } |
| | | |
| | | |
| | | void OnTxDone( void ) |
| | | { |
| | | KwRunStat.bMasterSent = 1; |
| | | KwRunStat.bMasterRecved = 0; |
| | | KwRunStat.runStep=RS_IDEL; |
| | | KwRunStat.runStep=RS_IDLE; |
| | | KMem.WDT[42]++; |
| | | KwRunStat.lastSenttime = GetTick(); |
| | | KwRunStat.lastAckTime = GetTick(); |
| | | Radio.Standby(); |
| | | if (RadioEnableMaster) { |
| | | if (WLCfg.bMaster) { |
| | | Radio.Rx( MASTER_RX_TIMEOUT_VALUE ); //进入接收 |
| | | } else { |
| | | Radio.Rx( SLAVE_RX_TIMEOUT_VALUE ); //进入接收 |
| | | KwStartRecv(1); |
| | | //Radio.Rx( SLAVE_RX_TIMEOUT_VALUE ); //进入接收 |
| | | } |
| | | KwRunStat.runStep=RS_RECVING; |
| | | |
| | | KwRunStat.lastActTime = GetTick(); |
| | | KwRunStat.lastRecvtime = GetTick(); |
| | | LL_GPIO_TogglePin(GPIOC,LL_GPIO_PIN_14); |
| | | int us2=GetTick(); |
| | | KMem.ScanTimeuS=us2-KMem.LastScanTime; |
| | | KMem.LastScanTime = us2; |
| | | if (KMem.ScanTimeuS < KMem.MinScanTimeuS) {KMem.MinScanTimeuS = KMem.ScanTimeuS;} |
| | | if (KMem.ScanTimeuS > KMem.MaxScanTimeuS) {KMem.MaxScanTimeuS = KMem.ScanTimeuS;} |
| | | // int us2=GetTick(); |
| | | // KMem.ScanTimeuS=us2-KMem.LastScanTime; |
| | | // KMem.LastScanTime = us2; |
| | | // if (KMem.ScanTimeuS < KMem.MinScanTimeuS) {KMem.MinScanTimeuS = KMem.ScanTimeuS;} |
| | | // if (KMem.ScanTimeuS > KMem.MaxScanTimeuS) {KMem.MaxScanTimeuS = KMem.ScanTimeuS;} |
| | | |
| | | } |
| | | |
| | | void OnTxTimeout( void ) |
| | | { |
| | | KwRunStat.runStep=RS_IDEL; |
| | | KwRunStat.runStep=RS_IDLE; |
| | | KwRunStat.lastAckTime = GetTick(); |
| | | KwRunStat.TXErr++; |
| | | Radio.Standby(); |
| | |
| | | void OnRxDone( uint8_t *payload, uint16_t size, int16_t rssi, int8_t snr ) |
| | | { |
| | | KMem.WDT[44] = size; |
| | | memcpy( RX_Buffer, payload, size ); |
| | | memcpy(&KMem.WDT[64],payload,size); |
| | | Radio.Standby(); |
| | | |
| | | if (bThisRxError) { |
| | | bThisRxError=0; |
| | | return; |
| | | if (size <= 120) { |
| | | memcpy( RX_Buffer, payload, size ); |
| | | memcpy(&KMem.WDT[64],payload,size); |
| | | }else |
| | | { |
| | | |
| | | } |
| | | Radio.Standby(); |
| | | KwRunStat.runStep = RS_IDLE; |
| | | |
| | | |
| | | KwRunStat.curStat = 0; |
| | | KwRunStat.latancy = GetTick() - KwRunStat.lastSendtime; |
| | |
| | | KwRunStat.recvCount++; |
| | | // KwRunStat.CtnLstPkts=0; |
| | | |
| | | if(RadioEnableMaster) |
| | | if(WLCfg.bMaster) |
| | | { |
| | | KWLMasterParsePkt(nRadioChannel,size); |
| | | KWLMasterParsePkt(WLCfg.nChannel,size); |
| | | //KWLMasterSendReqPkt(1); |
| | | } |
| | | else //slave |
| | | { |
| | | KWLSlaveParsePkt(nRadioChannel,size); |
| | | KWLSlaveParsePkt(WLCfg.nChannel,size); |
| | | } |
| | | if (bThisRxError) { |
| | | bThisRxError=0; |
| | | // return; |
| | | } |
| | | } |
| | | |
| | | void OnRxTimeout( void ) |
| | | { |
| | | KwRunStat.runStep=RS_IDEL; |
| | | KwRunStat.runStep=RS_IDLE; |
| | | |
| | | Radio.Standby(); |
| | | KwRunStat.lastErrTime = GetTick() - KwRunStat.lastAckTime; |
| | | KwRunStat.lastAckTime = GetTick(); |
| | | |
| | | KwRunStat.Tx_Power+=6; //丢包, 增加发射功率 |
| | | if (KwRunStat.Tx_Power > WLCfg.Tx_Power) {KwRunStat.Tx_Power= WLCfg.Tx_Power; } |
| | | SX126xSetRfTxPower(KwRunStat.Tx_Power); |
| | | |
| | | |
| | | KMem.WDT[45]++; |
| | | KwRunStat.LostPackets++; |
| | |
| | | if (KwRunStat.CtnLstPkts == 10) {KwRunStat.Err3Count++;} |
| | | if ((KwRunStat.CtnLstPkts &0x0f) == 0x0f) { |
| | | KMem.WDT[51]++; |
| | | LoadKwConfig(); |
| | | KWireLessInit(RadioEnableMaster,nRadioChannel); |
| | | KwResetRf(); |
| | | Radio.Standby(); |
| | | // KWireLessStart(); |
| | | } |
| | | if(RadioEnableMaster) |
| | | if(WLCfg.bMaster) |
| | | { |
| | | //KWLMasterSendReqPkt(1); |
| | | } |
| | | else |
| | | { |
| | | Radio.Standby(); |
| | | Radio.Rx( SLAVE_RX_TIMEOUT_VALUE ); |
| | | KwRunStat.runStep=RS_RECVING; |
| | | KwRunStat.lastActTime = GetTick(); |
| | | KwRunStat.lastRecvtime = GetTick(); |
| | | KwStartRecv(1); |
| | | // Radio.Standby(); |
| | | // Radio.Rx( SLAVE_RX_TIMEOUT_VALUE ); |
| | | // KwRunStat.runStep=RS_RECVING; |
| | | // KwRunStat.lastActTime = GetTick(); |
| | | // KwRunStat.lastRecvtime = GetTick(); |
| | | } |
| | | } |
| | | |
| | | |
| | | void OnRxError( void ) |
| | | { |
| | | Radio.Standby(); |
| | | Radio.Rx( SLAVE_RX_TIMEOUT_VALUE ); |
| | | KwRunStat.runStep=RS_RECVING; |
| | | KwRunStat.lastActTime = GetTick(); |
| | | KwRunStat.lastRecvtime = GetTick(); |
| | | KwStartRecv(1); |
| | | // Radio.Standby(); |
| | | // Radio.Rx( SLAVE_RX_TIMEOUT_VALUE ); |
| | | // KwRunStat.runStep=RS_RECVING; |
| | | // KwRunStat.lastActTime = GetTick(); |
| | | // KwRunStat.lastRecvtime = GetTick(); |
| | | |
| | | KwRunStat.RXErr++; |
| | | KMem.WDT[46]++; |
| | | bThisRxError=1; |
| | | KwRunStat.lastErrTime = GetTick() - KwRunStat.lastAckTime; |
| | | |
| | | if(RadioEnableMaster) |
| | | if(WLCfg.bMaster) |
| | | { |
| | | // SendPingMsg(); |
| | | } |
| | | else |
| | | { |
| | | /* |
| | | // Radio.Rx( RX_TIMEOUT_VALUE ); |
| | | //KwRunStat.lastActTime = GetTick(); |
| | | KwRunStat.LostPackets++; |
| | |
| | | if (KwRunStat.CtnLstPkts == 4) {KwRunStat.Err2Count++;} |
| | | if (KwRunStat.CtnLstPkts > 6) { KwRunStat.ErrStat=5000; KMem.WFX[1]=0; } |
| | | if (KwRunStat.CtnLstPkts == 7) {KwRunStat.Err3Count++;} |
| | | |
| | | */ |
| | | } |
| | | // Radio.Standby(); |
| | | } |
| | | |
| | | void OnCadDone( bool channelActivityDetected) |
| | | { |
| | | KMem.WDT[60]++; |
| | | KwRunStat.CADDoneCount++; |
| | | KwRunStat.lastAckTime = GetTick(); |
| | | KMem.WDT[16] = KwRunStat.lastAckTime - KwRunStat.lastActTime; |
| | | if (channelActivityDetected) { |
| | | KwRunStat.CADNgCount++; |
| | | KMem.WDT[61]++; |
| | | Radio.StartCad(); |
| | | KwRunStat.lastActTime = GetTick(); |
| | | } |
| | | else { |
| | | KwRunStat.CADOkCount++; |
| | | KMem.WDT[62]++; |
| | | if (WLCfg.bMaster) { |
| | | if (KwRunStat.curStat == 0 ){ //&& stat == RF_IDLE ) //200mS |
| | | // Radio.Standby(); |
| | | KWireLessStart(); |
| | | }else { |
| | | Radio.Standby(); |
| | | KWireLessStart(); |
| | | } |
| | | }else { |
| | | KWLSlaveSendRplyPkt(1); |
| | | } |
| | | } |
| | | return; |
| | | } |
| | | int KWLMasterParsePkt(int nChn,int size) |
| | |
| | | pstKLPacket p1 = (pstKLPacket) RX_Buffer; |
| | | if(CRC_OK && p1->STSign == enRplySign ) //memcmp(RX_Buffer,PongMsg,4)==0 |
| | | { |
| | | if (p1->DstAddr == MixAddr(nRadioChannel,nRadioAddr)) |
| | | if (p1->DstAddr == MixAddr(WLCfg.nChannel,WLCfg.nRadioAddr)) |
| | | { |
| | | KwRunStat.bMasterRecved = 1; |
| | | LedToggle();//LED闪烁 |
| | |
| | | if (p1->Stat==0) { |
| | | KwRunStat.tRSSI = RX_Buffer[10]; |
| | | KwRunStat.tSNR = RX_Buffer[11]; |
| | | if (KwRunStat.tRSSI > -50) { |
| | | if (KwRunStat.Tx_Power > 0) {KwRunStat.Tx_Power--; SX126xSetRfTxPower(KwRunStat.Tx_Power);} |
| | | }else if (KwRunStat.tRSSI < -60) { |
| | | KwRunStat.Tx_Power+=6; |
| | | if (KwRunStat.Tx_Power > WLCfg.Tx_Power) {KwRunStat.Tx_Power= WLCfg.Tx_Power; } |
| | | SX126xSetRfTxPower(KwRunStat.Tx_Power); |
| | | } |
| | | |
| | | }else if (p1->Stat==1){ |
| | | KwRunStat.targetSentCount = RX_Buffer[8] + (RX_Buffer[9]<<8) + (RX_Buffer[10]<<16) + (RX_Buffer[11]<<24); |
| | | }else if (p1->Stat==2) { |
| | |
| | | if (RX_Buffer[size-2] != (crc_value&0xff) && RX_Buffer[size-1] != (crc_value >> 8)) |
| | | { |
| | | KwRunStat.CRCErr++; |
| | | KwRunStat.ErrStat=500; |
| | | // KwRunStat.ErrStat=500; |
| | | CRC_OK = 0; |
| | | }else { |
| | | CRC_OK = 1; |
| | | if (p1->STSign != enReqSign) { |
| | | KwRunStat.PktErr++; |
| | | }else { |
| | | if (p1->DstAddr != MixAddr(nRadioChannel,nRadioAddr)) { |
| | | KwRunStat.ChnErr++; |
| | | } |
| | | if (p1->DstAddr != MixAddr(WLCfg.nChannel,WLCfg.nRadioAddr)) { |
| | | KwRunStat.ChnErr++; |
| | | KwRunStat.nErrChn = p1->DstAddr; |
| | | } |
| | | } |
| | | } |
| | | //*/ |
| | | |
| | | if(CRC_OK && p1->STSign == enReqSign && p1->DstAddr == MixAddr(nRadioChannel,nRadioAddr))// memcmp(RX_Buffer,PingMsg,4)==0 && ) |
| | | if(CRC_OK && p1->STSign == enReqSign && p1->DstAddr == MixAddr(WLCfg.nChannel,WLCfg.nRadioAddr))// memcmp(RX_Buffer,PingMsg,4)==0 && ) |
| | | { |
| | | |
| | | LedToggle();//LED闪烁 |
| | |
| | | if (p1->Stat==0) { |
| | | KwRunStat.tRSSI = RX_Buffer[10]; |
| | | KwRunStat.tSNR = RX_Buffer[11]; |
| | | if (KwRunStat.tRSSI > -50) { |
| | | if (KwRunStat.Tx_Power > 0) {KwRunStat.Tx_Power--; SX126xSetRfTxPower(KwRunStat.Tx_Power);} |
| | | }else if (KwRunStat.tRSSI < -60) { |
| | | KwRunStat.Tx_Power+=6; |
| | | if (KwRunStat.Tx_Power > WLCfg.Tx_Power) {KwRunStat.Tx_Power= WLCfg.Tx_Power; } |
| | | SX126xSetRfTxPower(KwRunStat.Tx_Power); |
| | | } |
| | | }else if (p1->Stat==1){ |
| | | KwRunStat.targetSentCount = RX_Buffer[8] + (RX_Buffer[9]<<8) + (RX_Buffer[10]<<16) + (RX_Buffer[11]<<24); |
| | | }else if (p1->Stat==2) { |
| | |
| | | KMem.WFX[2]=(RX_Buffer[6]) + (RX_Buffer[7]<<8); |
| | | |
| | | KWLSlaveSendRplyPkt(1); |
| | | // Radio.StartCad(); |
| | | // KMem.WFY[0]=(RX_Buffer[4]<<8) + RX_Buffer[5]; |
| | | // KMem.WFY[1]=(RX_Buffer[6]<<8) + RX_Buffer[7]; |
| | | } |
| | | else |
| | | { |
| | | Radio.Rx( SLAVE_RX_TIMEOUT_VALUE ); |
| | | KwRunStat.runStep=RS_RECVING; |
| | | KwRunStat.lastActTime = GetTick(); |
| | | KwRunStat.lastRecvtime = GetTick(); |
| | | KwStartRecv(1); |
| | | // Radio.Rx( SLAVE_RX_TIMEOUT_VALUE ); |
| | | // KwRunStat.runStep=RS_RECVING; |
| | | // KwRunStat.lastActTime = GetTick(); |
| | | // KwRunStat.lastRecvtime = GetTick(); |
| | | |
| | | } |
| | | return 0; |
| | |
| | | int len1=12; |
| | | pstKLPacket p1 = (pstKLPacket) TX_Buffer; |
| | | p1->STSign = enReqSign; |
| | | p1->DstAddr = MixAddr(nRadioChannel,nRadioAddr); |
| | | p1->DstAddr = MixAddr(WLCfg.nChannel,WLCfg.nRadioAddr); |
| | | p1->Func = 0x3; |
| | | p1->Stat = (p1->Stat + 1) &0x03; //0x00; |
| | | p1->Data[0]=KMem.WFY[1]; |
| | |
| | | int len1=12; |
| | | pstKLPacket p1 = (pstKLPacket) TX_Buffer; |
| | | p1->STSign = enRplySign; |
| | | p1->DstAddr = MixAddr(nRadioChannel,nRadioAddr); |
| | | p1->DstAddr = MixAddr(WLCfg.nChannel,WLCfg.nRadioAddr); |
| | | p1->Func = 0x3; |
| | | p1->Stat = (p1->Stat + 1) &0x03; //0x00; |
| | | p1->Data[0]=KMem.WFY[1]; |
| | |
| | | } |
| | | |
| | | |
| | | int KWL_Process(int nChn) |
| | | { |
| | | RadioStatus_t rs = SX126xGetStatus(); |
| | | KMem.WDT[1] = rs.Value; |
| | | |
| | | RadioError_t er = SX126xGetDeviceErrors(); |
| | | KMem.WDT[2] = er.Value; |
| | | |
| | | KMem.WDT[3] = SX126xGetIrqStatus(); |
| | | |
| | | KMem.WDT[4] = SX126xGetRssiInst(); |
| | | |
| | | KMem.WDT[5] = GetRadioBusyPin(); |
| | | |
| | | RadioState_t stat = Radio.GetStatus(); |
| | | |
| | | KMem.WDT[32]=stat; |
| | | // KMem.WDT[38]=Radio.Rssi(MODEM_FSK); |
| | | if (WLCfg.bMaster){ |
| | | |
| | | KWLMasterProc(nChn); |
| | | }else //slave |
| | | { |
| | | KWLSlaveProc(nChn); |
| | | } |
| | | if (KwRunStat.RunStat) KwRunStat.RunStat--; |
| | | if (KwRunStat.ErrStat) KwRunStat.ErrStat--; |
| | | |
| | | |
| | | return 0; |
| | | } |
| | | |
| | | int KWLMasterProc(int nChn) |
| | | { |
| | | RadioState_t stat = Radio.GetStatus(); |
| | | |
| | | switch (KwRunStat.runStep){ |
| | | case RS_IDLE: |
| | | if (GetTick() - KwRunStat.lastSendtime > (WLCfg.nCycleTime) *10){ |
| | | Radio.StartCad(); |
| | | KwRunStat.runStep = RS_MASTER_CAD; |
| | | KwRunStat.lastActTime = GetTick(); |
| | | } |
| | | break; |
| | | case RS_MASTER_CAD: |
| | | if (GetTick() - KwRunStat.lastActTime > 15) { |
| | | KwRunStat.CADTimeOut++; |
| | | KwRunStat.runStep = RS_IDLE; |
| | | Radio.Standby(); |
| | | KMem.WDT[17]++; |
| | | KwResetRf(); |
| | | } |
| | | break; |
| | | case RS_SENDING: |
| | | break; |
| | | case RS_SENT: |
| | | break; |
| | | case RS_RECVING: |
| | | if (GetTick() - KwRunStat.lastSendtime > (WLCfg.nCycleTime) *10){ |
| | | KwRunStat.ErrStat=5000; |
| | | KwRunStat.LostPackets++; |
| | | KwRunStat.CtnLstPkts++; |
| | | |
| | | KwRunStat.Tx_Power+=6; //丢包, 增加发射功率 |
| | | if (KwRunStat.Tx_Power > WLCfg.Tx_Power) {KwRunStat.Tx_Power= WLCfg.Tx_Power; } |
| | | SX126xSetRfTxPower(KwRunStat.Tx_Power); |
| | | |
| | | if (KwRunStat.CtnLstPkts > KwRunStat.MaxCtnLstPkts) {KwRunStat.MaxCtnLstPkts = KwRunStat.CtnLstPkts;} |
| | | // KwRunStat.ErrStat=500; |
| | | if (KwRunStat.CtnLstPkts > 1) { KwRunStat.ErrStat=2000;} |
| | | if (KwRunStat.CtnLstPkts == 2) {KwRunStat.Err1Count++;} |
| | | if (KwRunStat.CtnLstPkts > 3) { KwRunStat.ErrStat=5000;} |
| | | if (KwRunStat.CtnLstPkts == 4) {KwRunStat.Err2Count++;} |
| | | if (KwRunStat.CtnLstPkts > 6) { KwRunStat.ErrStat=5000; KMem.WFX[1]=0; } |
| | | if (KwRunStat.CtnLstPkts == 7) {KwRunStat.Err3Count++;} |
| | | if ((KwRunStat.CtnLstPkts &0x0f) == 0x0f) { |
| | | KMem.WDT[51]++; |
| | | |
| | | KwResetRf(); |
| | | // LoadKwConfig(); |
| | | // KWireLessInit(RadioEnableMaster,nRadioChannel); |
| | | // Radio.Standby(); |
| | | // KWireLessStart(); |
| | | } |
| | | |
| | | |
| | | KwRunStat.runStep = RS_IDLE; |
| | | } |
| | | break; |
| | | case RS_RECVED: |
| | | KwRunStat.runStep = RS_IDLE; |
| | | break; |
| | | |
| | | default: |
| | | break; |
| | | |
| | | } |
| | | /* |
| | | if (GetTick() - KwRunStat.lastSendtime > (WLCfg.nCycleTime) *10){ |
| | | if (!KwRunStat.bMasterRecved) { |
| | | KwRunStat.ErrStat=5000; |
| | | KwRunStat.LostPackets++; |
| | | KwRunStat.CtnLstPkts++; |
| | | if (KwRunStat.CtnLstPkts > KwRunStat.MaxCtnLstPkts) {KwRunStat.MaxCtnLstPkts = KwRunStat.CtnLstPkts;} |
| | | // KwRunStat.ErrStat=500; |
| | | if (KwRunStat.CtnLstPkts > 1) { KwRunStat.ErrStat=2000;} |
| | | if (KwRunStat.CtnLstPkts == 2) {KwRunStat.Err1Count++;} |
| | | if (KwRunStat.CtnLstPkts > 3) { KwRunStat.ErrStat=5000;} |
| | | if (KwRunStat.CtnLstPkts == 4) {KwRunStat.Err2Count++;} |
| | | if (KwRunStat.CtnLstPkts > 6) { KwRunStat.ErrStat=5000; KMem.WFX[1]=0; } |
| | | if (KwRunStat.CtnLstPkts == 7) {KwRunStat.Err3Count++;} |
| | | if ((KwRunStat.CtnLstPkts &0x0f) == 0x0f) { |
| | | KMem.WDT[51]++; |
| | | // LoadKwConfig(); |
| | | // KWireLessInit(RadioEnableMaster,nRadioChannel); |
| | | // Radio.Standby(); |
| | | // KWireLessStart(); |
| | | } |
| | | } |
| | | } |
| | | */ |
| | | /* |
| | | if (KwRunStat.curStat == 0 ){ //&& stat == RF_IDLE ) //200mS |
| | | // Radio.Standby(); |
| | | KWireLessStart(); |
| | | }else { |
| | | Radio.Standby(); |
| | | KWireLessStart(); |
| | | } |
| | | */ |
| | | return 0; |
| | | } |
| | | |
| | |
| | | KWireLessStart(); |
| | | } |
| | | } |
| | | if (stat == RF_CAD && GetTick() - KwRunStat.lastRecvtime > ((1 )*10)){ |
| | | if (stat == RF_CAD && GetTick() - KwRunStat.lastRecvtime > ((2 )*10)){ |
| | | KwRunStat.StepErr2++; |
| | | KwRunStat.CADTimeOut++; |
| | | KMem.WDT[50]++; |
| | | Radio.Standby(); |
| | | KWireLessStart(); |
| | |
| | | } |
| | | if (GetTick() - KwRunStat.lastRecvtime > 16000){ |
| | | KMem.WDT[52]++; |
| | | LoadKwConfig(); |
| | | KWireLessInit(RadioEnableMaster,nRadioChannel); |
| | | KwResetRf(); |
| | | Radio.Standby(); |
| | | KWireLessStart(); |
| | | KwRunStat.lastRecvtime = GetTick(); |
| | |
| | | return 0; |
| | | } |
| | | |
| | | int KWL_Process(int nChn) |
| | | { |
| | | RadioState_t stat = Radio.GetStatus(); |
| | | KMem.WDT[32]=stat; |
| | | // KMem.WDT[38]=Radio.Rssi(MODEM_FSK); |
| | | if (RadioEnableMaster){ |
| | | if (GetTick() - KwRunStat.lastSendtime > CYCLE_TIME *10 && Radio.IsChannelFree(MODEM_LORA,KwRunStat.RF_Freq,-60,1)){ |
| | | if (!KwRunStat.bMasterRecved) { |
| | | KwRunStat.ErrStat=5000; |
| | | KwRunStat.LostPackets++; |
| | | KwRunStat.CtnLstPkts++; |
| | | if (KwRunStat.CtnLstPkts > KwRunStat.MaxCtnLstPkts) {KwRunStat.MaxCtnLstPkts = KwRunStat.CtnLstPkts;} |
| | | // KwRunStat.ErrStat=500; |
| | | if (KwRunStat.CtnLstPkts > 1) { KwRunStat.ErrStat=2000;} |
| | | if (KwRunStat.CtnLstPkts == 2) {KwRunStat.Err1Count++;} |
| | | if (KwRunStat.CtnLstPkts > 3) { KwRunStat.ErrStat=5000;} |
| | | if (KwRunStat.CtnLstPkts == 4) {KwRunStat.Err2Count++;} |
| | | if (KwRunStat.CtnLstPkts > 6) { KwRunStat.ErrStat=5000; KMem.WFX[1]=0; } |
| | | if (KwRunStat.CtnLstPkts == 7) {KwRunStat.Err3Count++;} |
| | | if ((KwRunStat.CtnLstPkts &0x0f) == 0x0f) { |
| | | KMem.WDT[51]++; |
| | | LoadKwConfig(); |
| | | KWireLessInit(RadioEnableMaster,nRadioChannel); |
| | | Radio.Standby(); |
| | | // KWireLessStart(); |
| | | } |
| | | } |
| | | if (KwRunStat.curStat == 0 ){ //&& stat == RF_IDLE ) //200mS |
| | | // Radio.Standby(); |
| | | KWireLessStart(); |
| | | }else { |
| | | Radio.Standby(); |
| | | KWireLessStart(); |
| | | } |
| | | } |
| | | }else //slave |
| | | { |
| | | KWLSlaveProc(nChn); |
| | | } |
| | | if (KwRunStat.RunStat) KwRunStat.RunStat--; |
| | | if (KwRunStat.ErrStat) KwRunStat.ErrStat--; |
| | | |
| | | KwRunStat.Tx_Power = WLCfg.Tx_Power; |
| | | KwRunStat.LoraBandWidth = WLCfg.LoraBandWidth; |
| | | KwRunStat.LoRaFactor = WLCfg.LoRaFactor; |
| | | KwRunStat.LoRaCodingRate = WLCfg.LoRaCodingRate; |
| | | KwRunStat.LoRaPreambleLen = WLCfg.LoRaPreambleLen; |
| | | |
| | | |
| | | return 0; |
| | | } |
| | | |
| | | |
| | | |