Linux下串口協議控制51單片機

上位機程序

/***************************************************************************

writen by jingshui 7-17 2011 12：53
說明：這是一個linux下串口，多線程測試程序
Version 0.26
***************************************************************************/
# include <stdio.h>
# include <unistd.h>
# include <stdlib.h>
# include <termios.h>
# include <fcntl.h>
# include <string.h>
# include <sys/time.h>
# include <sys/types.h>
# include <pthread.h>

int fd;
pthread_t thread[2];
pthread_mutex_t mutex;

/****************************************************************************
結構體說明：傳送控制單片機的信息
成員1：select 選擇功能模塊
成員2：control 控制單片機相應的動作
*****************************************************************************/
struct protocal
{
unsigned char select;
unsigned char control;
};
struct protocal ptr[14]={{0xa1,0x01},{0xa1,0x02},{0xa1,0x03},{0xa1,0x04},{0xa1,0x05},
{0xa1,0x06},{0xa1,0x07},{0xa1,0x08},{0xb2,0x00},{0xb2,0x03},
{0xb2,0x06},{0xb2,0x09},{0xb2,0x0e},{0xc3,0xd4}};

/********************************************************************
功能說明：設置linux串口參數
傳入參數：
fd nspeed nbit nevent nstop
文件句柄 波特率 數據位 奇偶校驗 停止位
返回值: fd 文件句柄
********************************************************************/
int set_port(int fd ,int nspeed ,int nbits ,char nevent ,int nstop)
{
struct termios newtio,oldtio;
if (tcgetattr(fd,&oldtio)!= 0)
{
perror("setup serial");
return -1;
}
bzero(&newtio,sizeof(newtio));
newtio.c_cflag |= CLOCAL|CREAD;
newtio.c_cflag &= ~CSIZE;
switch (nbits)
{
case 7:
newtio.c_cflag |= CS7;
break;
case 8:
newtio.c_cflag |= CS8;
break;
}
switch (nevent)
{
case 'N':
newtio.c_cflag &= ~PARENB;
break;
}
switch (nspeed)
{
case 9600:
cfsetispeed(&newtio,B9600);
cfsetospeed(&newtio,B9600);
break;
}
switch (nstop)
{
case 1:
newtio.c_cflag &= ~CSTOPB;
break;
case 2:
newtio.c_cflag |= CSTOPB;
break;
}
newtio.c_cc[VTIME]= 0;
newtio.c_cc[VMIN]= 14;
tcflush(fd,TCIFLUSH);
if ((tcsetattr(fd,TCSANOW,&newtio))!= 0)
{
perror("com set");
return -1;
}
return 0;
}

int open_port(int fd,int comport)
{
if (comport == 1){
fd = open ("/dev/ttyUSB0",O_RDWR);
if ( -1 == fd ){
perror("can't open serial port");
return -1;
}
}
return fd;
}

void write_port(void)
{
int nwrite,i;
for (i=0;i<14;i++)
{
nwrite = write(fd,&ptr[i],2);
usleep(200000);/*每200ms秒發一次數據*/
}
}

void read_port(void)
{
fd_set rd;
int nread,retval;
unsigned char msg[14];
struct timeval timeout;
FD_ZERO(&rd);
FD_SET(fd,&rd);
timeout.tv_sec = 1;
timeout.tv_usec = 0;
retval = select (fd+1,&rd,NULL,NULL,&timeout);/*select 實現i/o復用*/
switch (retval)
{
case 0:
printf("no data input within 1 seconds.\n");
break;
case -1:
perror("select");
break;
default:
if((nread=read(fd,msg,14))>0)
{
printf("nread=%d,msg=%s\n",nread,msg);
}
break;
}
}

void *recv_thread(void )
{
pthread_mutex_lock(&mutex);
read_port();
pthread_mutex_unlock(&mutex);
pthread_exit(NULL);
}

void *send_thread(void )
{
pthread_mutex_lock(&mutex);
write_port();
pthread_mutex_unlock(&mutex);
pthread_exit(NULL);
}

void create_thread(void )
{
int temp;
memset(thread, 0, sizeof(thread));
if((temp = pthread_create(&thread[0], NULL,(void *)send_thread, NULL)) != 0)
printf("create send_thread failed!\n");
if((temp = pthread_create(&thread[1], NULL,(void *)recv_thread, NULL)) != 0)
printf("create recev_thread failed!\n");

}

void wait_thread(void )
{
if(thread[0] !=0)
{
pthread_join(thread[0],NULL);
printf("send_thread end\n");
}
if(thread[1] !=0)
{
pthread_join(thread[1],NULL);
printf("recev_thread end\n");
}
}

int main(void )
{
int i;
if((fd=open_port(fd,1))<0){
perror("open_port error");
}
if((i=set_port(fd,9600,8,'N',1))<0){
perror("set_opt error");
}
/*用默認屬性初始化互斥鎖*/
pthread_mutex_init(&mutex,NULL);
int num = 100;
while (num)
{
create_thread();
wait_thread();
num--;
}
pthread_mutex_destroy(&mutex);
close(fd);
return 0;
}