1.00 uart server and client - JohnHau/mis GitHub Wiki

#include <stdio.h>
#include <stdlib.h>
#include <string.h>
#include <unistd.h>
#include <sys/types.h>
#include <sys/stat.h>
#include <fcntl.h>
#include <termios.h>
#include <errno.h>
#include <getopt.h>
#include <time.h>
#include <sys/select.h>
#include "uart_os.h"

int setOpt(int fd, int nSpeed, int nBits, int nParity, int nStop) { struct termios newtio, oldtio;

// 保存测试现有串口参数设置，在这里如果串口号等出错，会有相关的出错信息
if (tcgetattr(fd, &oldtio) != 0)
{
    perror("SetupSerial 1");
    return -1;
}

bzero(&newtio, sizeof(newtio));   //新termios参数清零
newtio.c_cflag |= CLOCAL | CREAD; //CLOCAL--忽略 modem 控制线,本地连线, 不具数据机控制功能, CREAD--使能接收标志
// 设置数据位数
newtio.c_cflag &= ~CSIZE;    //清数据位标志
			 
switch (nBits)
{
    case 7:
        newtio.c_cflag |= CS7;
    break;
    case 8:
        newtio.c_cflag |= CS8;
    break;
    default:
        fprintf(stderr, "Unsupported data size\n");
        return -1;
}
// 设置校验位
switch (nParity)
{
    case 'o':
    case 'O':                     //奇校验
        newtio.c_cflag |= PARENB;
        newtio.c_cflag |= PARODD;
        newtio.c_iflag |= (INPCK | ISTRIP);
        break;
    case 'e':
    case 'E':                     //偶校验
        newtio.c_iflag |= (INPCK | ISTRIP);
        newtio.c_cflag |= PARENB;
        newtio.c_cflag &= ~PARODD;
        break;
    case 'n':
    case 'N':                    //无校验
        newtio.c_cflag &= ~PARENB;
        break;
    default:
        fprintf(stderr, "Unsupported parity\n");
        return -1;
}
// 设置停止位
switch (nStop)
{
    case 1:
        newtio.c_cflag &= ~CSTOPB;
    break;
    case 2:
        newtio.c_cflag |= CSTOPB;
    break;
    default:
        fprintf(stderr,"Unsupported stop bits\n");
        return -1;
}
// 设置波特率 2400/4800/9600/19200/38400/57600/115200/230400
switch (nSpeed)
{
    case 2400:
        cfsetispeed(&newtio, B2400);
        cfsetospeed(&newtio, B2400);
        break;
    case 4800:
        cfsetispeed(&newtio, B4800);
        cfsetospeed(&newtio, B4800);
        break;
    case 9600:
        cfsetispeed(&newtio, B9600);
        cfsetospeed(&newtio, B9600);
        break;
    case 19200:
        cfsetispeed(&newtio, B19200);
        cfsetospeed(&newtio, B19200);
        break;
    case 38400:
        cfsetispeed(&newtio, B38400);
        cfsetospeed(&newtio, B38400);
        break;
    case 57600:
        cfsetispeed(&newtio, B57600);
        cfsetospeed(&newtio, B57600);
        break;
    case 115200:
        cfsetispeed(&newtio, B115200);
        cfsetospeed(&newtio, B115200);
        break;
    case 230400:
        cfsetispeed(&newtio, B230400);
        cfsetospeed(&newtio, B230400);
        break;
    default:
        printf("\tSorry, Unsupported baud rate, set default 9600!\n\n");
        cfsetispeed(&newtio, B9600);
        cfsetospeed(&newtio, B9600);
        break;
}
// 设置read读取最小字节数和超时时间
newtio.c_cc[VTIME] = 1; // 读取一个字符等待1*(1/10)s
newtio.c_cc[VMIN] = 1;  // 读取字符的最少个数为1

  tcflush(fd,TCIFLUSH); //清空缓冲区
  if (tcsetattr(fd, TCSANOW, &newtio) != 0)    //激活新设置
  {
    perror("SetupSerial 3");
      return -1;
 }
  printf("Serial set done!\n");
return 0;

}

int uart_read(int fd, char *rcv_buf, int data_len, int timeout) { int len, fs_sel; fd_set fs_read; struct timeval time;

if(timeout >=0)
{
    time.tv_sec = timeout / 1000;              //set the rcv wait time
    time.tv_usec = timeout % 1000 * 1000;    //100000us = 0.1s
}


FD_ZERO(&fs_read);        //每次循环都要清空集合，否则不能检测描述符变化
FD_SET(fd, &fs_read);    //添加描述符

// 超时等待读变化，>0：就绪描述字的正数目， -1：出错， 0 ：超时
if(timeout >=0)
{
    fs_sel = select(fd + 1, &fs_read, NULL, NULL, &time);
}
else
{

    fs_sel = select(fd + 1, &fs_read, NULL, NULL, NULL);

}
//    printf("fs_sel = %d\n", fs_sel);
if(fs_sel)
{
    len = read(fd, rcv_buf, data_len);
    return len;
}
else
{
    printf("Sorry,I am wrong!");
    return -1;
}

}

int uart_write(int fd, char *send_buf, int data_len) { ssize_t ret = 0;

ret = write(fd, send_buf, data_len);
if (ret == data_len)
{
	//printf("send data is %s\n", send_buf);
	return ret;
}
else
{
	printf("write device error\n");
	tcflush(fd,TCOFLUSH);
	return -1;
}

}

int32_t init_com_port(char* dev_uart,uint32_t baudrate) { int fdSerial;

// 打开串口设备
fdSerial = open(dev_uart, O_RDWR | O_NOCTTY | O_NDELAY);
if(fdSerial < 0)
{
	perror(dev_uart);
	return -1;
}

// 设置串口阻塞， 0：阻塞， FNDELAY：非阻塞
if (fcntl(fdSerial, F_SETFL, 0) < 0)    //阻塞，即使前面在open串口设备时设置的是非阻塞的
{
	printf("fcntl failed!\n");
}
else
{
	printf("fcntl=%d\n", fcntl(fdSerial, F_SETFL, 0));
}

if (isatty(fdSerial) == 0)
{
	printf("standard input is not a terminal device\n");
	close(fdSerial);
	return -1;
}
else
{
	printf("is a tty success!\n");
}
printf("fd-open=%d\n", fdSerial);

// 设置串口参数
//if (setOpt(fdSerial, 115200, 8, 'N', 1)== -1)    //设置8位数据位、1位停止位、无校验
if (setOpt(fdSerial, baudrate, 8, 'N', 1)== -1)    //设置8位数据位、1位停止位、无校验
{
	fprintf(stderr, "Set opt Error\n");
	close(fdSerial);
	exit(1);
}

tcflush(fdSerial, TCIOFLUSH);    //清掉串口缓存
fcntl(fdSerial, F_SETFL, 0);    //串口阻塞


return fdSerial;
;

}

uint8_t buf[128]={0}; int main (int argc, char *argv[]) {

if(argc < 3)
{
	fprintf(stderr,"usage: %s dev baudrate\n",argv[0]);
	exit(EXIT_FAILURE);
}

int fdSerial = init_com_port(argv[1],atoi(argv[2]));

uint8_t rcv_buf[128]={0};
uint8_t send_buf[128]={0x31,0x32,0x33,0x34,0x35,0x36,0x37,0x38,0x00};
int len;
uint32_t ch_cnt =0;

while(1) 
{
	//uart_write(fdSerial, send_buf, 16);
	//sleep(3);
	memset(rcv_buf,0,sizeof(rcv_buf));
	//uart_read(fdSerial, rcv_buf, 16, 1000);

	uart_read(fdSerial, rcv_buf, 16, -1);
	printf("rcv:%s\n",rcv_buf);

}


close(fdSerial);



return 0;

}

⚠️ **GitHub.com Fallback** ⚠️