commit 6f26d6a415703f5e10a2e4affee3fc4bd4535055 Author: tianjialong Date: Fri Apr 14 20:22:50 2023 +0800 update diff --git a/README.md b/README.md new file mode 100644 index 0000000..e845566 --- /dev/null +++ b/README.md @@ -0,0 +1 @@ +README diff --git a/a.out b/a.out new file mode 100755 index 0000000..3f97040 Binary files /dev/null and b/a.out differ diff --git a/main.c b/main.c new file mode 100644 index 0000000..3f91f7f --- /dev/null +++ b/main.c @@ -0,0 +1,151 @@ +#include +#include +#include +#include +#include +#include +#include +#include +#include +#include +#include +#include +#include +typedef struct termios termios_t; + +typedef struct serial_data +{ + + char databuf[100]; // 发送/接受数据 + int serfd; // 串口文件描述符 + +} ser_Data; + +void *sersend(void *arg); +void *serrecv(void *arg); + +int main(int argc, char *argv[]) +{ + pthread_t pid1, pid2; + pthread_attr_t *pthread_arr1, *pthread_arr2; + pthread_arr1 = NULL; + pthread_arr2 = NULL; + int serport1fd; + + /* 进行串口参数设置 */ + termios_t *ter_s = malloc(sizeof(*ter_s)); + + serport1fd = open(argv[1], O_RDWR | O_NOCTTY | O_NDELAY); // 不成为控制终端程序,不受其他程序输出输出影响 + if (serport1fd < 0) + { + printf("%s open faild\r\n", argv[1]); + return -1; + } + + bzero(ter_s, sizeof(*ter_s)); + + ter_s->c_cflag |= CLOCAL | CREAD; // 激活本地连接与接受使能 + + ter_s->c_cflag &= ~CSIZE; // 失能数据位屏蔽 + ter_s->c_cflag |= CS8; // 8位数据位 + + ter_s->c_cflag &= ~CSTOPB; // 1位停止位 + + ter_s->c_cflag &= ~PARENB; // 无校验位 + + ter_s->c_cc[VTIME] = 0; + ter_s->c_cc[VMIN] = 0; + + /*1 VMIN> 0 && VTIME> 0 + VMIN为最少读取的字符数,当读取到一个字符后,会启动一个定时器,在定时器超时事前,如果已经读取到了VMIN个字符,则read返回VMIN个字符。如果在接收到VMIN个字符之前,定时器已经超时,则read返回已读取到的字符,注意这个定时器会在每次读取到一个字符后重新启用,即重新开始计时,而且是读取到第一个字节后才启用,也就是说超时的情况下,至少读取到一个字节数据。 + 2 VMIN > 0 && VTIME== 0 + 在只有读取到VMIN个字符时,read才返回,可能造成read被永久阻塞。 + 3 VMIN == 0 && VTIME> 0 + 和第一种情况稍有不同,在接收到一个字节时或者定时器超时时,read返回。如果是超时这种情况,read返回值是0。 + 4 VMIN == 0 && VTIME== 0 + 这种情况下read总是立即就返回,即不会被阻塞。----by 解释粘贴自博客园 + */ + cfsetispeed(ter_s, B115200); // 设置输入波特率 + cfsetospeed(ter_s, B115200); // 设置输出波特率 + + tcflush(serport1fd, TCIFLUSH); // 刷清未处理的输入和/或输出 + + if (tcsetattr(serport1fd, TCSANOW, ter_s) != 0) + { + printf("com set error!\r\n"); + } + + char buffer[] = {"hello my world!\r\n"}; + char recvbuf[100] = {}; + + ser_Data snd_data; + ser_Data rec_data; + + snd_data.serfd = serport1fd; + rec_data.serfd = serport1fd; + + memcpy(snd_data.databuf, buffer, strlen(buffer)); // 拷贝发送数据 + + pthread_create(&pid1, pthread_arr1, sersend, (void *)&snd_data); + pthread_create(&pid2, pthread_arr2, serrecv, (void *)&rec_data); + + ssize_t sizec; + while (1) + { + + usleep(100000); + } + + pthread_join(pid1, NULL); + pthread_join(pid2, NULL); + free(ter_s); + return 0; +} + +void *sersend(void *arg) // 串口发送线程函数 +{ + ser_Data *snd = (ser_Data *)arg; + int ret; + while (1) + { + ret = write(snd->serfd, snd->databuf, strlen(snd->databuf)); + if (ret > 0) + { + printf("send success, data is %s\r\n", snd->databuf); + } + else + { + printf("send error!\r\n"); + } + usleep(300000); + /* + if(发生中断) + break;//退出 + */ + } +} + +void *serrecv(void *arg) // 串口发送线程函数 +{ + ser_Data *rec = (ser_Data *)arg; + int ret; + while (1) + { + ret = read(rec->serfd, rec->databuf, 1024); + if (ret > 0) + { + printf("recv success,recv size is %d,data is %s\r\n", ret, rec->databuf); + } + else + { + /* + 什么也不做 + */ + } + usleep(1000); + /* + if(发生中断) + break;//退出 + */ + } +}