serialthread.cpp

qtopia的串口通信程序

#include <sys/types.h>      
#include <sys/stat.h>      
#include <fcntl.h>
#include <termios.h>
#include <stdio.h>
#include <unistd.h>

#include "my_define.h" 
#include "serialthread.h" 
#include "mainwindow.h" 

int set_nc_mode(int fd)
{ 
    struct termios options; //terminal io ?
    if  ( tcgetattr(fd,&options)  !=  0){ //get char from terminal
		perror("SetupSerial Error"); 
		return(FALSE); 
	} /* get current port settings */ 
	
    bzero(&options, sizeof(options)); //operation struct set zero
    options.c_cflag |= BAUDRATE | CS8 | CLOCAL | CREAD;  
    options.c_cflag &= ~CRTSCTS; 
    options.c_iflag = IGNPAR;  
    options.c_oflag &=~OPOST;            
	// 
	options.c_lflag = 0;            
	options.c_cc[VTIME] = WAIT_TIME; 
    options.c_cc[VMIN] = BLOCK_SIZE;    /* blocking read until 5 chars received */ 
    
    tcflush(fd, TCIFLUSH);
    tcsetattr(fd,TCSANOW,&options);
    return(TRUE); 
} 

int set_c_mode(int fd) 
{ 
    struct termios options; 
    if  ( tcgetattr( fd,&options)  !=  0){ 
		perror("SetupSerial Error"); 
		return(FALSE); 
	} 
    bzero(&options, sizeof(options));
    tcflush(fd, TCIOFLUSH); 
    cfsetispeed(&options, BAUDRATE); 
	cfsetospeed(&options, BAUDRATE); 
	
    options.c_cflag |=(CLOCAL|CREAD); 
	
    options.c_cflag &= ~CRTSCTS; 
	
    options.c_cflag &= ~CSIZE; 
    options.c_cflag |= CS8; 
	
    options.c_cflag &= ~PARENB;  /* Clear parity enable,clear control mode flag */ 
    options.c_iflag &= ~INPCK;    /* Disable parity checking ,*/ 
    options.c_cflag &= ~CSTOPB; 
	
    options.c_iflag |= IGNBRK; 
	
    options.c_lflag |= ICANON;        
    options.c_lflag &= ~(ECHO | ECHOE | ISIG); 
    options.c_oflag &= ~(OPOST); 
	
    tcflush(fd, TCIOFLUSH); 
	if (tcsetattr(fd,TCSANOW,&options) != 0){ 
		perror("SetupSerial 3"); 
        return (FALSE); 
    } 
    return(TRUE);
}

void send_ack(int fd)
{ 
    char buf[]={'A','C','K',CHANGE_LINE};
    write(fd,buf,sizeof(buf)); 
}

void resend(int fd)
{ 
    char buf[]={'R','S','D',CHANGE_LINE}; 
    write(fd,buf,sizeof(buf)); 
}

void delay(int i) 
{ 
    int j; 
    for (;i>0;i--) 
        for(j=0;j<65535;j++); 
} 


//////////////////////////////////////////////////////////////////////////////////////////// 

SerialThread::SerialThread(MainWindow *parent)
{
    this->parent = parent;
} 


void SerialThread::run() //use a new thread to do
{ 
    int fd,c, res;    
    int block_num,last_block; 
    int i;    
    char buf[BLOCK_SIZE];        
    char file_name[32]; 
    FILE *fp; 
    struct termios oldtio; 
	
    block_num=last_block=0; 
    fd = open(DEVICE, O_RDWR | O_NOCTTY );  
    
    parent->setCounter(fd); 
    parent->setMsgText("opend device fd::::::");    
    
    
    if (fd <0){ 
        perror(DEVICE);  
        parent->setMsgText("open device failed");    
		//    exit(-1);  
    }    
	
    tcgetattr(fd,&oldtio); 
    set_nc_mode(fd); 
    printf("Changed to nc mode\n"); 
    /* 
    res=read(fd,( char *)file_name,32); 
    parent->setCounter(res); 
    parent->setMsgText("res is ::::::");    
    */ 
	
	/* 
    
	  
		if(res>0){ 
        file_name[res-1]='\0'; 
        printf("Received the file name:%s\n",file_name); 
        } 
		else 
        printf("The received file name is error.\n"); 
		
		  fp=fopen(file_name,"wb"); 
		  if(fp==NULL){ 
		  printf("Can not creat file %s!\n",file_name); 
		  return; 
		  //    exit(-1); 
		  } 
		  else 
		  { 
		  send_ack(fd); 
		  printf("The file %s is created.\nWaitting for the block num and last block size\n",file_name); 
		  } 
		  
			//set_nc_mode(fd); 
			//printf("Changed to nc mode\n"); 
			
			  res=read(fd,buf,4); 
			  printf("res=%d\n",res); 
			  printf("Received the block num \n"); 
			  
				for(i=0,block_num=0;i<4;i++){ 
				block_num=block_num*10+buf; 
				printf("buf[%d]=%x\n",i,buf); 
				} 
				printf("The number of blocks is %d\n",block_num); 
				send_ack(fd); 
				
				  res=read(fd,buf,3); 
				  printf("res=%d\n",res); 
				  printf("Received the last block size \n"); 
				  for(i=0,last_block=0;i<3;i++){ 
				  last_block=last_block*10+buf; 
				  printf("buf[%d]=%x\n",i,buf); 
				  }    
				  printf("The last block size is %d\n",last_block); 
				  send_ack(fd);    
				  
					printf("Starting receive blocks\n"); 
					
					  for(i=0;i<block_num;i++){ 
					  res=read(fd,buf,BLOCK_SIZE); 
					  if(res!=BLOCK_SIZE){ 
					  printf("res=%d,\t Request resend the %d block\n",res,i); 
					  i--; 
					  tcflush(fd, TCIOFLUSH); 
					  resend(fd); 
					  } 
					  else{            
					  fwrite(buf,1,BLOCK_SIZE,fp); 
					  printf("Received the %d block,    res=%d\n",i,res); 
					  printf("Send ack signal complete,waiting to read\n"); 
					  send_ack(fd); 
					  } 
					  } 
					  printf("start transporting the last block\n"); 
					  
						if(last_block>0){ 
						send_ack(fd); 
						res=read(fd,buf,last_block); 
						printf("res=%d\n",res); 
						if(res!=last_block){ 
						printf("Request resend the last block\n"); 
						tcflush(fd, TCIOFLUSH); 
                        resend(fd); 
                        } 
						else 
						fwrite(buf,1,last_block,fp); 
						} 
						send_ack(fd); 
						printf("The file transports end\n"); 
						
						  fclose(fp); 
						  printf("close the file\n"); 
						  tcsetattr(fd,TCSANOW,&oldtio); 
						  close(fd); 
						  printf("close the serial port\n"); 
    */      
}