step2_serialtest.rar_Z63W_tdm_嵌入式linux操作系统串口应用程序

// Serial.cpp: implementation of the CSerial class. // ////////////////////////////////////////////////////////////////////// #include <stdio.h> #include <stdlib.h> #include <string.h> #include <sys/types.h> #include <sys/wait.h> #include <errno.h> #include <string.h> #include <unistd.h> #include <fcntl.h> #include <sys/un.h> #include <sys/time.h> #include <sys/ioctl.h> #include <pthread.h> #include <termios.h> #include "Serial.h" ////////////////////////////////////////////////////////////////////// // Construction/Destruction ////////////////////////////////////////////////////////////////////// typedef struct port_info { int baud_rate; int port_fd; char parity; char stop_bit; char flow_ctrl; char data_bits; }*pport_info; //get the baud_rate defination according to the baud rate int get_baud_rate(unsigned long int baud_rate) { switch(baud_rate) { case 0: return B0; case 50: return B50; case 75: return B75; case 110: return B110; case 134: return B134; case 150: return B150; case 200: return B200; case 300: return B300; case 600: return B600; case 1200: return B1200; case 1800: return B1800; case 2400: return B2400; case 4800: return B4800; case 9600: return B9600; case 19200: return B19200; case 38400: return B38400; case 57600: return B57600; case 115200: return B115200; case 230400: return B230400; default: return -1; } } int set_port(pport_info p_info) { struct termios new_opt; int baud_rate; int status; //get the current config -> new_opt tcgetattr(p_info->port_fd,&new_opt); bzero( &new_opt, sizeof(new_opt)); //convert baud rate -> baud_flag baud_rate=get_baud_rate(p_info->baud_rate); tcflush(p_info->port_fd, TCIOFLUSH); //setup input/output baudrate cfsetispeed(&new_opt,baud_rate); //printf("cfsetispeed::c_cflag = %x\r\n", new_opt.c_cflag); cfsetospeed(&new_opt,baud_rate); //printf("cfsetospeed::c_cflag = %x\r\n", new_opt.c_cflag); status = tcsetattr(p_info->port_fd, TCSANOW, &new_opt); if (status != 0) { perror("tcsetattr::set baud rate failed\n"); return -1; } //修改控制模式，保证程序不会占用串口？ new_opt.c_cflag |= CLOCAL; //printf("c_cflag |= CLOCAL => %x\r\n", new_opt.c_cflag); //修改控制模式，使得能够从串口读取输入数据 new_opt.c_cflag |= CREAD; //printf("c_cflag |= CREAD => %x\r\n", new_opt.c_cflag); new_opt.c_cflag |= HUPCL; //setup control flow switch(p_info->flow_ctrl) { case '0': //no control-flow new_opt.c_cflag &=~CRTSCTS; break; case '1': //hardware control-flow new_opt.c_cflag |=CRTSCTS; break; case '2': new_opt.c_iflag |= IXON | IXOFF | IXANY; break; } //printf("c_cflag(no ctl-flow) = %x\r\n", new_opt.c_cflag); //setup bit size new_opt.c_cflag &=~CSIZE; switch(p_info->data_bits) { case '5': new_opt.c_cflag |=CS5; break; case '6': new_opt.c_cflag |=CS6; break; case '7': new_opt.c_cflag |=CS7; break; case '8': new_opt.c_cflag |=CS8; break; default: new_opt.c_cflag |=CS8; } printf("c_cflag |= CS8 => %x\r\n", new_opt.c_cflag); //setup parity switch(p_info->parity) { case 'n': case 'N': new_opt.c_cflag &= ~PARENB; /* Clear parity enable */ new_opt.c_iflag &= ~INPCK; /* Enable parity checking */ break; case 'o': case 'O': new_opt.c_cflag |= (PARODD | PARENB); /* 设置为奇效验*/ new_opt.c_iflag |= INPCK; /* Disable parity checking */ break; case 'e': case 'E': new_opt.c_cflag |= PARENB; /* Enable parity */ new_opt.c_cflag &= ~PARODD; /* 转换为偶效验*/ new_opt.c_iflag |= INPCK; /* Disable parity checking */ break; case 'S': case 's': /*as no parity*/ new_opt.c_cflag &= ~PARENB; new_opt.c_cflag &= ~CSTOPB; break; default: fprintf(stderr,"Unsupported parity\n"); return -1; } //printf("c_cflag &=~PARENB => %x\r\n", new_opt.c_cflag); //setup stop-bit if(p_info->stop_bit=='2') { new_opt.c_cflag |=CSTOPB; } else { new_opt.c_cflag &=~CSTOPB; } //printf("c_cflag &=~CSTOPB => %x\r\n", new_opt.c_cflag); /* Set input parity option */ if ((p_info->parity != 'n') || (p_info->parity != 'N')) { new_opt.c_iflag |= INPCK; } //修改输出模式：原始数据输出(raw 模式) new_opt.c_lflag &= ~(ICANON | ECHO | ISIG); /*Input*/ new_opt.c_oflag &= ~OPOST; /*Output*/ //修改控制字符：读取字符的最少个数为1 ？？？ new_opt.c_cc[VMIN]=1; //修改控制字符：读取第一个字符的超时时间为1×100ms new_opt.c_cc[VTIME]=1; //试图去掉在接收时必须收到'\n'才返回的问题 //忽略输入的回车 //new_opt.c_iflag |= IGNCR; //new_opt.c_iflag &= ~(IXON|IXOFF|IXANY); //如果发生数据溢出，接收数据，但是不再读取 tcflush(p_info->port_fd,TCIFLUSH); status = tcsetattr(p_info->port_fd,TCSANOW,&new_opt); if(status != 0) { perror("Cannot set the serial port parameters"); return -1; } return status; } CSerial::CSerial() { m_DatLen = 0; m_ExitThreadFlag = 0; } CSerial::~CSerial() { } int CSerial::ReceiveThreadFunc(void* lparam) { CSerial *pSer = (CSerial*)lparam; //定义读事件集合 fd_set fdRead; int ret; struct timeval aTime; while( 1 ) { //收到退出事件，结束线程 if( pSer->m_ExitThreadFlag ) { break; } FD_ZERO(&fdRead); FD_SET(pSer->m_fd,&fdRead); aTime.tv_sec = 0; aTime.tv_usec = 300000; ret = select( pSer->m_fd+1,&fdRead,NULL,NULL,&aTime ); //printf( "select ret = %d\n", ret); if (ret < 0 ) { //关闭串口 pSer->ClosePort( ); break; } if (ret > 0) { //判断是否读事件 if (FD_ISSET(pSer->m_fd,&fdRead)) { //data available, so get it! pSer->m_DatLen = read( pSer->m_fd, pSer->DatBuf, 100 ); // 对接收的数据进行处理，这里为简单的数据回发 if( pSer->m_DatLen > 0 ) { pSer->PackagePro( pSer->DatBuf, pSer->m_DatLen); } // 处理完毕 } } } printf( "ReceiveThreadFunc finished\n"); pthread_exit( NULL ); return 0; } int CSerial::OpenPort( int PortNo, int baudrate, char databits, char stopbits, char parity ) { char portname[20]; struct port_info info; pthread_attr_t attr; int res; sprintf( portname, "/dev/ttyS%d", PortNo ); //sprintf( portname, "/dev/ttyUSB%d", PortNo ); //sprintf( portname, "/dev/ttyISA%d", PortNo ); if((m_fd = open(portname,O_RDWR | O_NOCTTY | O_NONBLOCK))==-1) //O_RDWR | O_NOCTTY | O_NDELAY | { perror("Cannot open the desired port"); return -1; } // // Fill in the device control block. // // 修改相关参数 info.baud_rate = baudrate; info.parity = parity; info.data_bits = databits; info.flow_ctrl = '0'; info.port_fd = m_fd; info.stop_bit = stopbits; if(set_port(&info)==-1 ) { printf( "set port fail\n"); return -1; } // 创建串口的接收线程 res = pthread_attr_init(&attr); if( res!=0 ) { printf("Create attribute failed\n" ); } // 设置线程绑定属性 res = pthread_attr_setscope( &attr, PTHREAD_SCOPE_SYSTEM ); // 设置线程分离属性 res += pthread_attr_setdetachstate( &attr, PTHREAD_CREATE_DETACHED ); if( res!=0 ) { printf( "Setting attribute failed\n" ); } res = pthread_create( &m_thread, &attr, (void *(*) (void *))&ReceiveThreadFunc, (void*)this ); if( res!=0 ) { close( m_fd ); return -1; } pthread_attr_destroy( &attr ); return 0; } int CSerial::WritePort( char *Buf, int len ) { int sendlen=0; sendlen=write(m_fd, Buf, len); if(sendlen==len) { return sendlen; } else { //如果出现溢出情况 tcflush( m_fd,TCOFLUSH); return -1; } } // 接收串口数据处理函数 int CSerial::PackagePro( char* Buf, int len ) { // 对接收的数据进行处理，这里为简单的数据回发 int i1; i1= WritePort(Buf, len ); for( i1=0