Browse Source

update

master
tianjialong 2 years ago
parent
commit
bab227d6fa
  1. 9
      .clang-format
  2. 6
      .vscode/settings.json
  3. 210
      main.c

9
.clang-format

@ -0,0 +1,9 @@
# Defines the Chromium style for automatic reformatting.
# http://clang.llvm.org/docs/ClangFormatStyleOptions.html
Language: Cpp
BasedOnStyle: Google
ColumnLimit: 120
AlignConsecutiveMacros: true
AlignConsecutiveDeclarations: true
AlignConsecutiveAssignments: true
AlignOperands: true

6
.vscode/settings.json

@ -0,0 +1,6 @@
{
"files.associations": {
"strings.h": "c",
"stat.h": "c"
}
}

210
main.c

@ -1,151 +1,135 @@
#include <error.h>
#include <fcntl.h>
#include <malloc.h>
#include <pthread.h>
#include <stdio.h>
#include <stdlib.h>
#include <strings.h>
#include <string.h>
#include <pthread.h>
#include <unistd.h>
#include <fcntl.h>
#include <stdlib.h>
#include <error.h>
#include <termios.h>
#include <malloc.h>
#include <sys/types.h>
#include <strings.h>
#include <sys/stat.h>
#include <sys/types.h>
#include <termios.h>
#include <unistd.h>
typedef struct termios termios_t;
typedef struct serial_data
{
char databuf[100]; // /
int serfd; //
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;
}
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;
bzero(ter_s, sizeof(*ter_s));
/* 进行串口参数设置 */
termios_t *ter_s = malloc(sizeof(*ter_s));
ter_s->c_cflag |= CLOCAL | CREAD; // 使
serport1fd = open(argv[1], O_RDWR | O_NOCTTY | O_NDELAY); //
if (serport1fd < 0) {
printf("%s open faild\r\n", argv[1]);
return -1;
}
ter_s->c_cflag &= ~CSIZE; //
ter_s->c_cflag |= CS8; // 8
bzero(ter_s, sizeof(*ter_s));
ter_s->c_cflag &= ~CSTOPB; // 1
ter_s->c_cflag |= CLOCAL | CREAD; // 使
ter_s->c_cflag &= ~PARENB; //
ter_s->c_cflag &= ~CSIZE; //
ter_s->c_cflag |= CS8; // 8
ter_s->c_cc[VTIME] = 0;
ter_s->c_cc[VMIN] = 0;
ter_s->c_cflag &= ~CSTOPB; // 1
/*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); //
ter_s->c_cflag &= ~PARENB; //
tcflush(serport1fd, TCIFLUSH); // /
ter_s->c_cc[VTIME] = 0;
ter_s->c_cc[VMIN] = 0;
if (tcsetattr(serport1fd, TCSANOW, ter_s) != 0)
{
printf("com set error!\r\n");
}
/*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); //
char buffer[] = {"hello my world!\r\n"};
char recvbuf[100] = {};
tcflush(serport1fd, TCIFLUSH); // /
ser_Data snd_data;
ser_Data rec_data;
if (tcsetattr(serport1fd, TCSANOW, ter_s) != 0) {
printf("com set error!\r\n");
}
snd_data.serfd = serport1fd;
rec_data.serfd = serport1fd;
char buffer[] = {"hello my world!\r\n"};
char recvbuf[100] = {};
memcpy(snd_data.databuf, buffer, strlen(buffer)); //
ser_Data snd_data;
ser_Data rec_data;
pthread_create(&pid1, pthread_arr1, sersend, (void *)&snd_data);
pthread_create(&pid2, pthread_arr2, serrecv, (void *)&rec_data);
snd_data.serfd = serport1fd;
rec_data.serfd = serport1fd;
ssize_t sizec;
while (1)
{
memcpy(snd_data.databuf, buffer, strlen(buffer)); //
usleep(100000);
}
pthread_create(&pid1, pthread_arr1, sersend, (void *)&snd_data);
pthread_create(&pid2, pthread_arr2, serrecv, (void *)&rec_data);
pthread_join(pid1, NULL);
pthread_join(pid2, NULL);
free(ter_s);
return 0;
ssize_t sizec;
while (1) {
usleep(100000);
}
pthread_join(pid1, NULL);
pthread_join(pid2, NULL);
free(ter_s);
return 0;
}
void *sersend(void *arg) // 线
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;//退
*/
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) // 线
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;//退
*/
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;//退
*/
}
}
Loading…
Cancel
Save