cc1101_rx.c

/*---------------------------------------------------------------
TODOs and BUGs
1. Periodically check CC1101 working status, and reset it if necessary

-----------------------------------------------------------------*/


#include <stdio.h>
#include <math.h>
#include <signal.h>
#include <sys/time.h>
#include <stdbool.h>
#include <errno.h>
#include "cc1101.h"
#include "msg_common.h"

#define RSSI_SAVE_INTERVAL 120//--seconds

//------global variables -----
struct timeval t_fstart,t_start,t_end; //us from 1970
long cost_time=0;
struct tm *tm_local; //struct of local time with tm_sec,tm_min,tm_hour,..etc. 
time_t timep; // seconds from 1970 

char* str_file="/home/cc1101.dat";
FILE *fp; //save file 

int nTotal=0;
int nDATA_rec=0; // all data number received include nDATA_err, excetp CRC error.
int nDATA_err=0;
int nCRC_err=0;
int nFAIL=0;
int nMiss=0; //missing data number,counter for unconsecutive receival

void ExitProcess()
{
	int i;
	float CRC_err_rate,Miss_rate;
	printf("-------Exit Process------\n");
	fprintf(fp,"-------Exit Process------\n");
	printf("nTotal=%d\n",nTotal);
	fprintf(fp,"nTotal=%d\n",nTotal);
	printf("nDATA_rec=%d\n",nDATA_rec);
	fprintf(fp,"nDATA_rec=%d\n",nDATA_rec);
	printf("nDATA_err=%d\n",nDATA_err);
	fprintf(fp,"nDATA_err=%d\n",nDATA_err);
	printf("nCRC_err=%d\n",nCRC_err);
	fprintf(fp,"nCRC_err=%d\n",nCRC_err);
	printf("nFAIL=%d\n",nFAIL);
	fprintf(fp,"nFAIL=%d\n",nFAIL);
	printf("nMiss=%d\n",nMiss);
	fprintf(fp,"nMiss=%d\n",nMiss);
	CRC_err_rate=(float)nCRC_err/nTotal*100.0;
	Miss_rate=(float)nMiss/(nTotal+nMiss)*100;
	printf("CRC error rate: %5.2f %%\n",CRC_err_rate);
	fprintf(fp,"CRC error rate: %5.2f %%\n",CRC_err_rate);
	printf("Missing rate: %5.2f %%\n",Miss_rate);
	fprintf(fp,"Missing rate: %5.2f %%\n",Miss_rate);
        //-----message from functions-----
	fprintf(fp,"--------Message from Functions-------\n");
	for(i=1;i<num_FuncMessg;i++) //skip i=0
		fprintf(fp,"Function Messg[%d]:%s\n",i,str_FuncMessg[i]);

	fclose(fp);
	SPI_Close();
	exit(0);
}

void SaveData(char* str)
{
	if(fp)
	{
		fputs(str,fp);
	}

}


//======================= MAIN =============================
int main(void)
{
	int len,i,j;
	int len_rec;
	int ret,ccret;
	int dbmRSSI;
	bool tok_dtmp_Init=true;
	uint8_t dtmp;
	uint8_t Txtmp,data[32];
	unsigned char TxBuf[DATA_LENGTH];
	unsigned char RxBuf[DATA_LENGTH];

	//----for messsage queue----
	int msg_id=-1;
	char strRSSI[64]={0};

 	memset(data,0,sizeof(data));
	//memset(TxBuf,0,sizeof(TxBuf));
	memset(RxBuf,0,sizeof(RxBuf));

	//TxBuf[0]=0xac;
	//TxBuf[1]=0xab;

        //-------- Exit Signal Process ---------
        signal(SIGINT,ExitProcess);
	//-------- open file for RSSI record ----------------
	fp=fopen(str_file,"a"); // append data to a file, write only
	if (fp==(FILE *)NULL)
	{
		printf("%s: %s\n",str_file,strerror(errno));
		exit(-1);
	}
	fprintf(fp,"-----RSSI------\n");
	gettimeofday(&t_fstart,NULL); //timer for data save, every 10 minutes.


	SPI_Open();

/*	//--------- register operation fucntion test  -----
        //halSpiWriteReg(0x25,0x7f);
	data[0]=data[1]=data[2]=data[3]=data[4]=0xff;
	halSpiWriteBurstReg(0x25,data,5);
	halSpiReadBurstReg(0x25,RxBuf,5);
	printf("halSpiReadBurstReg(0x25,RxBuf,5) : ");
	for(i=0;i<5;i++)
	    printf("%02x",RxBuf[i]);
	printf("\n");
	printf("halSpiReadReg(0x25)=x%02x\n",halSpiReadReg(0x25));
	printf("halSpiReadReg(0x31)=x%02x\n",halSpiReadReg(0x31));
	printf("halSpiReadStatus(0x31) Chip ID: x%02x\n",halSpiReadStatus(0x31));
*/

	//-----init CC1101-----
	//set SPI CLOCK = 5MHZ; MAX. SPI CLOCK=6.5MHz for burst access.
        usleep(200000);//Good for init?
        RESET_CC1100();
        usleep(200000);
	halRfWriteRfSettings(); //--default register set
        //----set symbol rate,deviatn,filter BW properly -------
	//setAddress(0x55); //set chip address,default 0x00. also check PKTCTRL1[1:0]
	disAddrFilt();// default addr check is enabled
	setModFmt(MODFMT_MSK); //MODFMT_ASK_OOK //set modulation format
	setFreqDeviatME(0,4); //deviation: 25.4KHz
        setKbitRateME(248,10); //rate: 50kbps
	setChanBWME(0,3); //filterBW: (3,3)58KHz (0,3)102KHz
	setChanSpcME(248,2);//channel spacing: (248,2)200KHz 
	setCarFreqMHz(433,0);//(Base freq,+channel_number)

	halSpiWriteBurstReg(CCxxx0_PATABLE,PaTabel,8);//---set Power

	printf("----------  CC1101 Configuration --------\n");
	//---- get Modulation Format  ---
	printf("Set modulation format to    %s\n",getModFmtStr());
	//----- get symbol Kbit rate ----
        printf("Set symbol rate to       %8.1f Kbit/s\n",getKbitRate());
        //------ get carrier frequency ---
        printf("Set carrier frequency to   %8.3f MHz\n",getCarFreqMHz());
	//------ get freq deviation -----
	printf("Set freq deviation to    %8.1f  KHz\n",getFreqDeviatKHz());
	//------ get  IF frequency ----
	printf("Set IF to                  %8.3f KHz\n",getIfFreqKHz());
	//------ get channel Bandwith ----
	printf("Set channel BW to          %8.3f KHz\n", getChanBWKHz());
	//------ get channel spacing  ----
	printf("Set channel spacing to     %8.3f KHz\n",getChanSpcKHz());

	printf("----------------------------------------\n");
	sleep(1);

	//-----  create message queue IPC -----
	if((msg_id=createMsgQue(MSG_KEY_OLED_TEST))<0)
	{
		printf("create massage queue fails!\n");
		exit(-1);
	}

	//----- receive data -----
	len=60; //max.DATA_LENGTH-4, packet-bytes format is 1(length)+1(addr)+len(data)+2(append)
	len_rec=len;//actually received data length
	j=0;
  	while(1) //------ !!! Wait a little time just before setting up for next  TX_MODE !!!
	{
	   j++;
	   //------ cal. interval time for packets receiving ---------
	   gettimeofday(&t_end,NULL);
	   cost_time=t_end.tv_usec-t_start.tv_usec;
	   if(cost_time < 0)
	   	cost_time=cost_time+1000000*(t_end.tv_sec-t_start.tv_sec);
           printf("Out of halRfReceivePacket() preparing time:%dus\n",cost_time);

  	   ccret=halRfReceivePacket(RxBuf,len_rec);
	   //printf("Receive Start at:%lds %ldus\n",t_start.tv_sec,t_start.tv_usec);
	   //printf("Receive End at:%lds %ldus\n",t_end.tv_sec,t_end.tv_usec);

	   //-----start timer------
	   gettimeofday(&t_start,NULL);

	   //------ save RSSI every 10 minuts 
	   if((t_end.tv_sec-t_fstart.tv_sec)>RSSI_SAVE_INTERVAL)
	   {
		tm_local=localtime(&(t_start.tv_sec));
	 	fprintf(fp,"%s",asctime(tm_local));//--convert to local time string 
		fprintf(fp,"RSSI:%ddBm\n",getRSSIdbm());
		//SaveData();
		gettimeofday(&t_fstart,NULL);
	   }

	   //--- send RSSI through message queue IPC -----
	   if(recvMsgQue(msg_id,MSG_TYPE_WAIT_CC1101)>0) //-- send RSSI MSG only if there is a WAIT_CC1101 msg.
	   {
		if(decRSSI >0) //only when decRSSI is valid
		{
	             sprintf(strRSSI,"%ddBm",getRSSIdbm());
		     decRSSI=0;//reset
	             //printf("strRSSI:%s\n",strRSSI);
	             if(sendMsgQue(msg_id,MSG_TYPE_CC1101,strRSSI) != 0)
		        printf("Send RSSI through message queue fails!\n");
		}
	   }

	   //------ check received data ----------
  	   if(ccret==1) //receive success
	   {
		nDATA_rec++;

		//-----check if data packets are consecutive 
		if(tok_dtmp_Init) //--first init 
		{
			dtmp=RxBuf[0]; //reset dtmp with lastest received data
			tok_dtmp_Init=false;
		}
		else if((dtmp+1)!=RxBuf[0])
		{
			if(dtmp>RxBuf[0])//
				nMiss+=(255+RxBuf[0]-dtmp);
			else
				nMiss+=RxBuf[0]-dtmp-1;
		}
		dtmp=RxBuf[0]; //reset dtmp with lastest received data

		printf("------ nDATA_rec=%d ------\n",nDATA_rec);
		if(1)//j%10 == 0)
		{
 			printf("%dth received data:",j);
			for(i=0;i<len;i++)
				printf("%d, ",RxBuf[i]);
			printf("\n");
			printf("--------- getRSSI from RX_FIFO : %ddBm --------\n",getRSSIdbm());
			printf("--------- readRSSI from RSSI register: %ddBm --------\n",readRSSIdbm());

		}
		//---pick error data
		if(RxBuf[0]!=RxBuf[1])
		{
 			nDATA_err++;
			printf("------ nDATA_rec=%d ------\n",nDATA_err);
 			printf("%dth received data ERROR! :",j);
			for(i=0;i<len;i++)
				printf("%d, ",RxBuf[i]);
			printf("\n");
		}
	    }

  	   else if(ccret==2) // receive CRC error
	   {
 		nCRC_err++;
		printf("------ nCRC_err=%d ------\n",nCRC_err);
	   }
	   else if(ccret==0)//fail
	   {
		nFAIL++;
		printf("------ nFAIL=%d ------\n",nFAIL);
	   }

	   nTotal++;
        }//while
/*
	//---- check status ---- 
	for(i=0;i<10;i++)
	{
	 	usleep(100);
		printf("Status Byte:0x%02x\n",halSpiGetStatus());
	}
*/
	SPI_Close();
}