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;
}