/* p2p_m.c */
/* 雙機點對點通信的主機部分 */
#ifndef __P2P_M_C__
#define __P2P_M_C__

#include <AT89X51.H>
#include <STRING.H>

#define __MAX_LEN_ 64    // 數(shù)據(jù)最大長度
#define _MHZ_ 11    // 設(shè)置單片機使用的晶振頻率(11.0592MHz)

/* 以下為程序協(xié)議中使用的握手信號 */
#define __RDY_ 0x06    // 主機開始通信時發(fā)送的呼叫信號
#define __BUSY_ 0x15    // 從機忙應(yīng)答
#define __OK_ 0x00    // 從機準(zhǔn)備好
#define __SUCC_ 0x0f    // 數(shù)據(jù)傳送成功
#define __ERR_ 0xf0    // 數(shù)據(jù)傳送錯誤

void init_serial();    // 串口初始化
void send_data(unsigned char *buf);    // 發(fā)送數(shù)據(jù)
void delay10ms(unsigned int count);    // 延時子程序(10ms)

void main()
{
	char buf[__MAX_LEN_];
	unsigned char i = 0;
	unsigned char tmp = __BUSY_;

	/* 為緩沖區(qū)賦初值 */
	P0 = 0xff;
	while(P1 != 0)    // 每隔100ms從P0口讀取，若讀取到0則表明數(shù)據(jù)采集結(jié)束
	{
		*(buf+i) = P0;
		delay10ms(10);    // 延時100ms
		P0 = 0xff;
		i++;
	}
	*(buf+i) = 0;    // 緩沖區(qū)最后一個字節(jié)為0表示數(shù)據(jù)結(jié)束

	/* 串口初始化 */
	init_serial();    // 初始化串口
	EA = 0;    // 關(guān)閉所有中斷

	/* 發(fā)送握手信號06H */
	TI = 0;
	SBUF = __RDY_;
	while(!TI);
	TI = 0;
	/* 接收應(yīng)答信息，如果接收的信號為00H，表示從機允許接收 */
	while(tmp != __OK_)
	{
		RI = 0;
		while(!RI);
		tmp = SBUF;
		RI = 0;
	}
	/* 發(fā)送數(shù)據(jù)并接收校驗信息，如果接收的信號為0FH，表示從機接收成功，否則將重新發(fā)送該組數(shù)據(jù) */
	tmp = __ERR_;
	while(tmp != __SUCC_)
	{
		send_data(buf);    // 發(fā)送數(shù)據(jù)
		RI = 0;
		while(!RI);
		tmp = SBUF;
		RI = 0;
	}
	while(1);    // 程序結(jié)束，進入死循環(huán)
}

/* 初始化串口 */
void init_serial()
{
	TMOD = 0x20;	//定時器T1使用工作方式2
	TH1 = 250;    // 設(shè)置初值
	TL1 = 250;
	TR1 = 1;    // 開始計時
	PCON = 0x80;    // SMOD = 1
	SCON = 0x50;	//工作方式1，波特率9600bps，允許接收
}

/* 發(fā)送數(shù)據(jù) */
void send_data(unsigned char *buf)
{
	unsigned char len;    // 保存數(shù)據(jù)長度
	unsigned char ecc;    // 保存校驗字節(jié)
	
	len = strlen(buf);    // 計算要發(fā)送數(shù)據(jù)的長度
	ecc = len;    // 開始進行校驗字節(jié)計算
	/* 發(fā)送數(shù)據(jù)長度 */
	TI = 0;    
	SBUF = len;    // 發(fā)送長度
	while(!TI);
	TI = 0;
	/* 發(fā)送數(shù)據(jù) */
	for(i=0; i<len; i++)
	{
		ecc = ecc^(*buf);    // 計算校驗字節(jié)
		SBUF = *buf;    // 發(fā)送數(shù)據(jù)
		buf++;
		while(!TI);
		TI = 0;
	}
	/* 發(fā)送校驗字節(jié) */
	SBUF = ecc;    // 發(fā)送校驗字節(jié)
	while(!TI);
	TI = 0;
}

/* 延時10ms，精度較低，參數(shù)count為延時時間 */
void delay10ms(unsigned int count)
{
	unsigned int i, k;
	unsigned char j;
	unsigned int tmp;
	tmp = (int)((100*_MHZ_)/12);

	for(i=0; i<count; i++)
		for(j=0; j<100; j++)
			for(k=0; k<tmp; k++);
}

#endif