Thread: sending binaries files between server and client

I wrote this 2 funcions in order to send and receive files using a file descriptors
******SOME COMMENTS ARE IN JAPANESE***

Code:

/*myFunc.h*/

#ifndef BUFSIZE
	#define BUFISIZE 256
#endif

	
void receive_file_from(int fd, char *fileName)
{ 
	/*fd ：ファイル記述子*/
    char		buf[BUFSIZE];		/* ファイルの内容を格納するバッファ */ 
   	FILE		*fp;				/* 受信ファイルポインター */
	ssize_t		br;					/* read()で読み込んだバイト数 (bites readの略)*/
	
	/* 書き込みモードでファイルを開く */
	printf("\nopening file '%d'\n", fileName); 
	if( (fp = fopen(fileName, "w"))==NULL){ 
		perror("fopen");
		exit(1); 
	} 
	
	/* ファイルデータの受信とコーカルファイルへの書き込み */ 
	printf("writing file received from the %d\n", fd);
	while( ( br = read(fd, buf, BUFSIZE) )>0){ 
		//printf("%s\n", buf);  //ファイル内容を表示
		fwrite(buf,sizeof(char),br,fp);
	}
	
	/*ファイルデータの受信の終了*/
	printf("file was successfully received and saved as %s\n", fileName);

	fclose(fp); //corrected

}

void send_file_to(int fd, char* fileName){
	
	char		*buf[BUFSIZE];		/* ファイルの内容を格納するバッファ */
	FILE		*fp;				/* 送信ファイルポインタ */
	size_t		br;					/* read()で読み込んだバイト数 (bites readの略)*/
	
	/* 読み込みモードでファイルを開く */
	printf("\nopening file '%d'\n", fileName); 
	if( (fp = fopen(fileName, "r") )== NULL ){
		perror("fopen");
		exit(1);
	}
	/* ローカルファイルデータの読み込みと送信 */
	printf("reading local file and sending to %d\n", fd);
	while( ( br = fread(buf,sizeof(char),BUFSIZE,fp) )>0){
		write(fd, buf, br); 
		//printf("%s\n", buf);	//ファイル内容を表示
	}
	
	/*ファイルデータの送信の終了*/
	printf("file was successfully read and sent\n");
	fclose(fp); //corrected
}

I call them from the server and client program in order to receive a file (lets say the file is image.txt and is in the same place as client program )from the client to the server and everything goes great. But my problem is when i try to send back the same file (with a different file name) to the client from the server. It seems that write() system call is not completely correct. I mean, when i try to do the 2 operations the file is not even correctly received (from the client to the server). I suspect there is a problem of synchronization... maybe? I cannot think of another think, but still if is synchronization, i don't know how to do it.
Can any one help me?

my server program is as follows.:

Code:

/* システムプログラミング　並行サーバの実現　(concurrent_server.c)  */ 
#include    <stdio.h> 
#include    <sys/types.h> 
#include    <sys/socket.h> 
#include    <netinet/in.h> 
#include    <sys/stat.h> 
#include    <fcntl.h> 
#include	<stdlib.h>
#include	<strings.h>

#define     BUFSIZE 256 /* バッファサイズ */ 

#include	"../myFuncs.h"

#define     ERR -1 /* システムコールのエラー */ 
#define     SERVER_PORT 50000 /* サーバのソケットの名前（ポート番号） */ 

main(int argc, char *argv[]) 
{ 
    int                 sockfd;		/* socket()の返すファイル記述子 */ 
    int                 ns;			/* accept()の返すファイル記述子 */ 
    struct  sockaddr_in server;		/* サーバプロセスのソケットアドレス情報 */ 
    struct  sockaddr_in client;		/* クライアントプロセスのソケットアドレス 情報 */ 
    socklen_t           fromlen;	/* クライアントプロセスのソケットアドレス 情報の長さ */ 
    int                 pid;		/* プロセスID */ 
	FILE				*fp;
	char				*tempFileName; /* 一時的なファイルの名前 */
	
    if(argc != 1){ /* コマンドの引数が正しく与えられなかった場合 */ 
		printf("Usage: concurrent_server\n"); 
	} 
	
	if( (sockfd = socket(PF_INET, SOCK_STREAM, 0)) == ERR) {/* ソケットの作成 */ 
        perror("server: socket"); 
        exit(1); 
    } 
   
    bzero((char *)&server, sizeof(server)); /* アドレス情報構造体 の初期化 */ 
    server.sin_family      = PF_INET; /* プロトコルファミリの設定 */ 
    server.sin_port        = htons(SERVER_PORT); /* ソケットの名前（ポート番号）の設定 */ 
    server.sin_addr.s_addr = htonl(INADDR_ANY); /* IPアドレスの設定 */
	
	printf("\tINADDR_ANY: %X\n\tserver.sinaddr.s_addr: %X\n",INADDR_ANY, server.sin_addr.s_addr);

    if( bind(sockfd, (struct sockaddr *)&server, sizeof(server)) == ERR) { 
		perror("server: bind"); 
        exit(1); 
    } 
	
	if( listen(sockfd, 5) == ERR) { /* 接続要求の受け入れ準備 */ 
        perror("server: listen"); 
        exit(1); 
    } 
	
    while(1) { /* 永久ループ */ 
		
		fromlen = sizeof(client); 
        if( (ns = accept(sockfd, (struct sockaddr *)&client, &fromlen)) == ERR ) { /* 接続要求の許可 */ 
            perror("server: accept"); 
            exit(1); 
        } 
		
		printf("\nconnect request from: %s   port: %d\n", 
			   inet_ntoa(client.sin_addr), ntohs(client.sin_port)); 
        if( (pid = fork()) == 0 ) { /* fork process */ 
            /* child process */ 
			strcpy(tempFileName,"temporal.txt");
                        receive_file_from(ns, tempFileName); /* receiving file from client as tempFileName */ 
			sleep(3);
                         //execute(tempFileName, option);	/* not implemented yet*/
			//send_file_to(ns, tempFileName);	/* sends back file to the client  THIS IS THE PROBLEM*/
			
			close(ns); /* accept()で返されたファイル記述子のクローズ */ 
            close(sockfd); /* socket()で返されたファイル記述子のクローズ */ 
            exit(0); /* 正常終了 */ 
        } 
        else if( pid >= 1 ) 
		/* parent process */ 
            close(ns); /* accept()で返されたファイル記述子のクローズ */ 
        else { 
			perror("server: fork"); 
			exit(1); 
        } 
    } 
    close(sockfd);  
    exit(0); 
}

and the client program is as follows :

Code:

#include    <stdio.h> 
#include    <sys/types.h> 
#include    <sys/socket.h> 
#include    <netinet/in.h> 
#include    <netdb.h> 
#include	<strings.h>
#include	<stdlib.h>


#define     BUFSIZE     256 /* バッファサイズ */ 

#include	"../myFuncs.h"

#define     ERR         -1 /* システムコールのエラー */ 
#define     SERVER_PORT 50000 /* サーバのソケットの名前（ポート番号） */ 
void        usage(void); /* Usageメッセージの出力 */ 
char        *command_name; /* コマンド名 */ 

main(int argc, char *argv[]) 
{ 
    int                 sockfd; /* socket()の返すファイル記述子 */ 
    struct  sockaddr_in server; /* サーバプロセスのソケットアドレス情報 */ 
    struct  hostent     *hp; /* ホスト情報 */ 
    char                buf[BUFSIZE]; /* メッセージを格納するバッファ */ 
    int                 n; /* 受信バイト数 */ 
    int                 fnamelen; /* メッセージ長 */ 
    char				*rindex(const char *s, int c); /* 末尾から文字列検索 */ 
	char				*hostname;
	int status;
	
    if((command_name = rindex(argv[0], '/')) != NULL) /* コマンド名の獲得 */ 
        command_name++; 
    else 
        command_name = argv[0]; 
    
	/*
	*	argv[0] = client_kadai_func
	*	argv[1] = hostname (get the hostname by typing hostname in the UNIX command line )
	*/
	
	if(argc != 2) {/*  check arguments */ 
        fprintf(stderr,"Usage: %s server-hostname\n", command_name); 
		exit(1); 
	}
	
	hostname = argv[1];
	if(	strcmp(argv[1],"local") == 0)
		if(gethostname(hostname, sizeof(hostname)+1)==ERR){
			perror("client: gethostname");
			exit(1);
		}
	printf("connection (hostname): %s\n",hostname);
	
	if( (sockfd = socket(PF_INET, SOCK_STREAM, 0)) == ERR) {/* ソケットの作成 */ 
        perror("client: socket"); 
        exit(1); 
    } 
    
	bzero((char *)&server, sizeof(server));		/* アドレス情報構造体の初期化 */ 
    server.sin_family = PF_INET;				/* プロトコルファミリの設定 */ 
    server.sin_port   = htons(SERVER_PORT);		/* ソケットの名前（ポート番号）の設定 */ 
    
	if( (hp = gethostbyname(argv[1])) == NULL) { /* ホスト情報の獲得 */ 
        herror("client: gethostbyname");
        exit(1); 
    }
		 
    bcopy(hp->h_addr, (char *)&server.sin_addr, hp->h_length); 
    
	if( connect(sockfd, (struct sockaddr *)&server, sizeof(server)) == ERR){ 
		perror("client: connect"); 
        exit(1); 
    } 
	
	send_file_to(sockfd, "image.txt");
	sleep(3);
	//receive_file_from(sockfd, "receivedFromServer.txt"); /*THIS IS THE PROBLEM!!*/
	
	close(sockfd);  
    exit(0); 
	
}