sending data from DSP to PC rate problem

/*
 * recv.c
 *
 * Receive test utility
 *
 * Copyright (C) 1999 Texas Instruments Incorporated - http://www.ti.com/ 
 * 
 * 
 *  Redistribution and use in source and binary forms, with or without 
 *  modification, are permitted provided that the following conditions 
 *  are met:
 *
 *    Redistributions of source code must retain the above copyright 
 *    notice, this list of conditions and the following disclaimer.
 *
 *    Redistributions in binary form must reproduce the above copyright
 *    notice, this list of conditions and the following disclaimer in the 
 *    documentation and/or other materials provided with the   
 *    distribution.
 *
 *    Neither the name of Texas Instruments Incorporated nor the names of
 *    its contributors may be used to endorse or promote products derived
 *    from this software without specific prior written permission.
 *
 *  THIS SOFTWARE IS PROVIDED BY THE COPYRIGHT HOLDERS AND CONTRIBUTORS 
 *  "AS IS" AND ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT 
 *  LIMITED TO, THE IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR
 *  A PARTICULAR PURPOSE ARE DISCLAIMED. IN NO EVENT SHALL THE COPYRIGHT 
 *  OWNER OR CONTRIBUTORS BE LIABLE FOR ANY DIRECT, INDIRECT, INCIDENTAL, 
 *  SPECIAL, EXEMPLARY, OR CONSEQUENTIAL DAMAGES (INCLUDING, BUT NOT 
 *  LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES; LOSS OF USE,
 *  DATA, OR PROFITS; OR BUSINESS INTERRUPTION) HOWEVER CAUSED AND ON ANY
 *  THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY, OR TORT 
 *  (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT OF THE USE 
 *  OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE.
 *
 */

#include <stdio.h>
#include <time.h>
#include <stdlib.h>

#include "sockets.h"

#define BUFSIZE    46720//46720
#define PORT       1000

/*
 *  ======== main ========
 */
int main(int argc, char *argv[])
{
    SOCKET s;
    struct sockaddr_in sin;
    struct in_addr dst;
    unsigned short port = PORT;
    char *buf = NULL;
    int bufsize = BUFSIZE;
    char *name = argv[0];
    int i;
    int nr;
    int trial;
    int skipoutput;
    int update = 1;
    time_t ts;
    time_t tn;
    int status;
    int testsize;
    int bytes;

	FILE* pFile;

	printf("\n\tWelcome to NIKSOO Ethernet TCP/IP Project\n");
	printf("\tYou can use this file for transfering data from DSP to PC\n");
	printf("\tPlease be patient\n");
	
	
    if (argc < 2) {
        //fprintf(stderr, "Usage: %s ip-addr [update]\n", name);
        exit(EXIT_FAILURE);
    }

    if (!inet_pton(AF_INET, argv[1], &dst)) {
        //fprintf(stderr, "%s: invalid ip-addr (%s)\n", name, argv[1]);
        exit(EXIT_FAILURE);
    }

    if (argc > 2) {
        update = (int)strtol(argv[2], NULL, 0);
    }

    if (argc > 3) {
        port = (unsigned short)strtoul(argv[3], NULL, 0);
    }

    socketsStartup();

    status = EXIT_FAILURE;

    s = socket(AF_INET, SOCK_STREAM, 0);
    if (s < 0) {
        //fprintf(stderr, "%s: failed socket (%d)\n", name, getError());
        goto leave;
    }

    sin.sin_family = AF_INET;
    sin.sin_addr = dst;
    sin.sin_port = htons(port);

    if (connect(s, (const struct sockaddr *)&sin, sizeof(sin)) < 0) {
        //fprintf(stderr, "%s: failed connect (%d)\n", name, getError());
        goto leave;
    }
    buf = malloc(bufsize);
    if (!buf) {
        //fprintf(stderr, "%s: failed buffer allocation\n", name);
        goto leave;
    }

    testsize = bufsize;
    trial = 0;
    bytes = 0;
    skipoutput = update;

    ts = time(0);
	
	
	
	pFile= fopen("c:\\test.txt", "wb");
	
    while (!kbhit()) {
        trial++;
        skipoutput--;

        /* Send the buffer */
        if (!skipoutput) {
            //printf("%d Requesting %d bytes ... ", trial, testsize);
        }

        *(int *)buf = testsize;
        if (send(s, buf, sizeof(int), 0) < 0) {
            //fprintf(stderr, "%s: send failed (%d)\n", name, getError());
            break;
        }

        /* Try and receive the test pattern */
        if (!skipoutput) {
            //printf("receive... ");
        }
		
        for (i = 0; i < testsize; i += nr) {//
			
			
            nr = recv(s, buf + i, bufsize - i, 0);
			fwrite (buf+i , sizeof(buf+i), 1000, pFile);
			//fprintf(pFile,"%h\n",buf[i]);
            if (nr < 0) {
                //fprintf(stderr, "%s: recv failed (%d)\n", name, getError());
                break;
            }
            if (nr == 0) {
                //fprintf(stderr, "%s: recv failed - no data\n", name);
                break;
            }
        }

        /* Verify reception size */
        if (i != testsize) {
            //fprintf(stderr, "%s: received %d (not %d) bytes\n", name, i, testsize);
            break;
        }

        if ((bytes + testsize) < bytes) {
            ts = time(0);
            bytes = 0;
            skipoutput = update;
        } else {
            bytes += testsize;

            if (!skipoutput) {
                tn = time(0) - ts;
                if (tn) {
                    //printf("passed - %lu bytes/s\n", bytes / tn);
                }
                else {
                    //printf("passed\n");
                }
                skipoutput = update;
				
            }
        }
    }
    fclose (pFile);
	status = EXIT_SUCCESS;
	

leave:
    if (buf) {
        free(buf);
    }

    if (s >= 0) {
        (void)closesocket(s);
    }

    socketsShutdown();
	printf("\n\tThanks for your attention\n\n\t\tArmin Nemati\n");
	
    return (status);
}