linux串口传输文件

需要从FPGA上通过串口把文件传输到PC上面,下面是代码。可以测试下串口的buffer大小,我电脑上的是4k多。

write.c

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

#define BUFFER_SIZE 32               //这里可以优化,一次读取文件可以大点,分次写入串口buffer。
#define FALSE -1
#define TRUE 1

int speed_arr[] = { B38400, B19200, B9600, B4800, B2400, B1200, B300,
	    B38400, B19200, B9600, B4800, B2400, B1200, B300, };
int name_arr[] = {38400,  19200,  9600,  4800,  2400,  1200,  300,
	    38400,  19200,  9600, 4800, 2400, 1200,  300, };

void set_speed(int fd, int speed);
int set_Parity(int fd,int databits,int stopbits,int parity);

int main(int argc,char *argv[])
{
	char *interface = NULL,*filename = NULL;

	if (argc < 2)
	{
		interface = "/dev/ttyUSB0";
		filename = "hello.txt"	;
	}
	else 
	{
		interface = argv[1];
		filename = argv[2];	
	}

	int fd=open(interface,O_RDWR|O_NOCTTY|O_NDELAY);   
	if(fd == -1)   
	{   
	    printf("%s Open   Error!\n",interface);   
	    return -1;   
	} 
	printf("open %s successfully !",interface);
	
	set_speed(fd,19200);
		if (set_Parity(fd,8,1,'N')== FALSE)
	{
		printf("Set Parity Error\n");
		exit(1);
	}


	int fp = open(filename,O_RDWR);
	if ( fp == -1 )
	{
		printf("open %s failured\n",filename);
		return -1;
	}
	int nread = 1;
	char buffer[BUFFER_SIZE] = {'\0'};
	int sum = 0;

	while(nread > 0)
	{
		int nwrite = 0;
		int tmp = 0,pos=0;	
		nread = read(fp,buffer,BUFFER_SIZE);	//一次要写进去的字节数
		printf("读取字节数 : %d bytes \n",nread);
		int size_write = nread;			//size_write是要本次要写入的总字节数	
		while (size_write > 0)
		{	
	//		int pos = 0>=nwrite?0:nwrite ;			//偏移
//			printf("pos = %d\n",pos);
			tmp = (nwrite > tmp)? nwrite : tmp;			//
			pos = tmp ;
			//printf("tmp = %d,pos %d \n",tmp,pos);
		        nwrite = write(fd,buffer + pos,size_write);	//nwrite一次写进去的字节数		
			if (nwrite == -1)
			{
				sleep (2);
				continue;
			}
			sum = sum + nwrite;			//nwrite 8
			printf("写入字节数 : %d,剩余字节数 : %d \n",sum,size_write);	
			size_write = size_write-nwrite;		//剩下要写进去的字节数				
		}
	}
	printf("sussfully  write %s\n",filename);
	close(fp);
	close(fd);
	return 0; 
}  

void set_speed(int fd, int speed)
{
	int   i;
	int   status;
	struct termios   Opt;
	tcgetattr(fd, &Opt);
	for ( i= 0;  i < sizeof(speed_arr) / sizeof(int);  i++)
	{
		if  (speed == name_arr[i])
		{
			tcflush(fd, TCIOFLUSH);
			cfsetispeed(&Opt, speed_arr[i]);
			cfsetospeed(&Opt, speed_arr[i]);
			status = tcsetattr(fd, TCSANOW, &Opt);
			if (status != 0)
			{
				perror("tcsetattr fd1");
				return;
			}
		}
		tcflush(fd,TCIOFLUSH);
	}
}

int set_Parity(int fd,int databits,int stopbits,int parity)
{
	struct termios options;
	if (tcgetattr( fd,&options)  !=  0)
	{
		perror("SetupSerial 1");
		return(FALSE);
	}
	options.c_cflag &= ~CSIZE;
	switch (databits) /*设置数据位数*/
	{
		case 7:
			options.c_cflag |= CS7;
			break;
		case 8:
			options.c_cflag |= CS8;
			break;
		default:
			fprintf(stderr,"Unsupported data size\n");
			return (FALSE);
	}
	switch (parity)
	{
		case 'n':
		case 'N':
			options.c_cflag &= ~PARENB;   /* Clear parity enable */
			options.c_iflag &= ~INPCK;     /* Enable parity checking */
			break;
		case 'o':
		case 'O':
			options.c_cflag |= (PARODD | PARENB);  /* 设置为奇效验*/ 
			options.c_iflag |= INPCK;             /* Disnable parity checking */
			break;
		case 'e':
		case 'E':
			options.c_cflag |= PARENB;     /* Enable parity */
			options.c_cflag &= ~PARODD;   /* 转换为偶效验*/  
			options.c_iflag |= INPCK;       /* Disnable parity checking */
			break;
		case 'S':
		case 's':  /*as no parity*/
			options.c_cflag &= ~PARENB;
			options.c_cflag &= ~CSTOPB;
			break;
		default:
			fprintf(stderr,"Unsupported parity\n");
			return (FALSE);
	}
	/* 设置停止位*/   
	switch (stopbits)
	{
		case 1:
			options.c_cflag &= ~CSTOPB;
			break;
		case 2:
			options.c_cflag |= CSTOPB;
			break;
		default:
			fprintf(stderr,"Unsupported stop bits\n");
			return (FALSE);
	}
	/* Set input parity option */
	if (parity != 'n')
		options.c_iflag |= INPCK;
	options.c_cc[VTIME] = 150; // 15 seconds
	options.c_cc[VMIN] = 0;

	tcflush(fd,TCIFLUSH); /* Update the options and do it NOW */
	if (tcsetattr(fd,TCSANOW,&options) != 0)
	{
		perror("SetupSerial 3");
		return (FALSE);
	}
	return (TRUE);
 }

read.c


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

#define BUFFER_SIZE 32
#define MAX 1024
#define FALSE -1
#define TRUE 1

int speed_arr[] = { B38400, B19200, B9600, B4800, B2400, B1200, B300,
	    B38400, B19200, B9600, B4800, B2400, B1200, B300, };
int name_arr[] = {38400,  19200,  9600,  4800,  2400,  1200,  300,
	    38400,  19200,  9600, 4800, 2400, 1200,  300, };

void set_speed(int fd, int speed);
int set_Parity(int fd,int databits,int stopbits,int parity);

int main(int argc,char *argv[])
{
	char *interface = NULL,*filename = NULL;

	if (argc < 2)
	{
		interface = "/dev/ttyACM0";
		filename = "hello.txt"	;
	}
	else 
	{
		interface = argv[1];
		filename = argv[2];	
	}
 
	int fd=open(interface,O_RDWR|O_NOCTTY|O_NDELAY);   
	if(fd == -1)   
	{   
	    printf("%s Open   Error!\n",interface);   
	    return -1;   
	} 
	printf("open %s successfully !",interface);
	
	set_speed(fd,19200);
	if (set_Parity(fd,8,1,'N')== FALSE)
	{
		printf("Set Parity Error\n");
		exit(1);
	}

	int fp = open(filename,O_RDWR|O_CREAT);
	if ( fp == -1 )
	{
		printf("open %s failured\n",filename);
		return -1;
	}

	int nread = 1,nwrite = 0;
	char buffer[BUFFER_SIZE] = {'\0'};
	while(1)
	{
		nread = read(fd,buffer,BUFFER_SIZE);   
		if (nread > 0)
		{
//			printf("读取 %d bytes \n",nread);
			nwrite = write(fp,buffer,nread);	
//			printf("写入 %d bytes \n",nwrite);
			if (nwrite <= 0)
			{		
				printf("write into file finished n");
				break;
			}
		}
	}

	printf("sussfully get %s\n",filename);
	return 0; 
}  

void set_speed(int fd, int speed)
{
	int   i;
	int   status;
	struct termios   Opt;
	tcgetattr(fd, &Opt);
	for ( i= 0;  i < sizeof(speed_arr) / sizeof(int);  i++)
	{
		if  (speed == name_arr[i])
		{
			tcflush(fd, TCIOFLUSH);
			cfsetispeed(&Opt, speed_arr[i]);
			cfsetospeed(&Opt, speed_arr[i]);
			status = tcsetattr(fd, TCSANOW, &Opt);
			if (status != 0)
			{
				perror("tcsetattr fd1");
				return;
			}
		}
		tcflush(fd,TCIOFLUSH);
	}
}

int set_Parity(int fd,int databits,int stopbits,int parity)
{
	struct termios options;
	if (tcgetattr( fd,&options)  !=  0)
	{
		perror("SetupSerial 1");
		return(FALSE);
	}
	options.c_cflag &= ~CSIZE;
	switch (databits) /*设置数据位数*/
	{
		case 7:
			options.c_cflag |= CS7;
			break;
		case 8:
			options.c_cflag |= CS8;
			break;
		default:
			fprintf(stderr,"Unsupported data size\n");
			return (FALSE);
	}
	switch (parity)
	{
		case 'n':
		case 'N':
			options.c_cflag &= ~PARENB;   /* Clear parity enable */
			options.c_iflag &= ~INPCK;     /* Enable parity checking */
			break;
		case 'o':
		case 'O':
			options.c_cflag |= (PARODD | PARENB);  /* 设置为奇效验*/ 
			options.c_iflag |= INPCK;             /* Disnable parity checking */
			break;
		case 'e':
		case 'E':
			options.c_cflag |= PARENB;     /* Enable parity */
			options.c_cflag &= ~PARODD;   /* 转换为偶效验*/  
			options.c_iflag |= INPCK;       /* Disnable parity checking */
			break;
		case 'S':
		case 's':  /*as no parity*/
			options.c_cflag &= ~PARENB;
			options.c_cflag &= ~CSTOPB;
			break;
		default:
			fprintf(stderr,"Unsupported parity\n");
			return (FALSE);
	}
	/* 设置停止位*/   
	switch (stopbits)
	{
		case 1:
			options.c_cflag &= ~CSTOPB;
			break;
		case 2:
			options.c_cflag |= CSTOPB;
			break;
		default:
			fprintf(stderr,"Unsupported stop bits\n");
			return (FALSE);
	}
	/* Set input parity option */
	if (parity != 'n')
		options.c_iflag |= INPCK;
	options.c_cc[VTIME] = 150; // 15 seconds
	options.c_cc[VMIN] = 0;

	tcflush(fd,TCIFLUSH); /* Update the options and do it NOW */
	if (tcsetattr(fd,TCSANOW,&options) != 0)
	{
		perror("SetupSerial 3");
		return (FALSE);
	}
	return (TRUE);
 }

标签:C/C++, Linux, FPGA