Параллельный сервер на С

/* ...server`s set up was there ... */
listen(server_sockfd, 1);
        FD_ZERO(&readfds);
        FD_SET(server_sockfd, &readfds);
        FD_SET(0, &readfds);  /* Add keyboard to file descriptor set */
       
        char * testDir;
        size = pathconf(".", _PC_PATH_MAX);
        if ((testDir = (char *) malloc((size_t)size)) != NULL)//set server`s directory
            testDir = (char *) getcwd(testDir, (size_t)size);
        /*  Now wait for clients and requests */
        while (1) {
            testfds = readfds;
            select(FD_SETSIZE, &testfds, NULL, NULL, NULL);
                   
            /* If there is activity, find which descriptor it's on using FD_ISSET */
            for (fd = 0; fd < FD_SETSIZE; fd++) {
                if (FD_ISSET(fd, &testfds)) {
               
       
                    if (fd == server_sockfd) { /* Accept a new connection request */
                        client_sockfd = accept(server_sockfd, NULL, NULL);
                                             
                        if (num_clients < MAX_CLIENTS) {
                            FD_SET(client_sockfd, &readfds);
                            fd_array[num_clients] = client_sockfd;
                            clientInfo = malloc(sizeof(struct info));
                            clientInfo[num_clients]->clientFd = client_sockfd;
                            //strcpy(clientInfo[num_clients]->currentDir,testDir);
                            printf("Client %d joined\n In directory %s", num_clients++, clientInfo[num_clients]->currentDir);
                            fflush(stdout);
                        } else {
                            sprintf(msg, "XSorry, too many clients.  Try again later.\n");
                            write(client_sockfd, msg, strlen(msg));
                            close(client_sockfd);
                        }
                    } else if (fd) {  /*Process Client specific activity*/
В этой части идет чтение и обработка команд клиента, составление и отсылака запроса. Принятие и отсылака фаилов и т.д.
                    }

while (1) {
            client_sockfd = accept(server_sockfd, (struct sockaddr *)&client_addr,
                                                    &client_addr_len );
             if( (pid = fork()) < 0 ) {
                perror("fork");
                exit(EXIT_FAILURE);
            } else if(!pid) {
                char * testDir;
                size = pathconf(".", _PC_PATH_MAX);
                if ((testDir = (char *) malloc((size_t)size)) != NULL)//set server`s directory
                    testDir = (char *) getcwd(testDir, (size_t)size);
                mes = (char *) malloc(sizeof(char) * MSG_SIZE);
                result = read(client_sockfd, mes, MSG_SIZE);
                if (result == -1) {
                    perror("read");
                    exit(EXIT_FAILURE);
                }
                mes[result] = '\0';
                if (mes[0] == 'X') {
                    exitClient(client_sockfd, &readfds, fd_array, &num_clients);
                }
                printf("Message from client %d: %s\n", client_sockfd, mes);
                if (!strncmp(mes, "FBEGIN",6)) {
                    file = fopen ("SERVERblabla.txt", "w");  
                    char fileBuf[1];
                    recv(client_sockfd, buf, 4, 0) ;
                    while(buf[0] != -1) {
                        putc(buf[0], file);
                        recv(client_sockfd, buf, 4, 0) ;
                    }
                fclose(file);
                } else {
                    error = parseCommand(mes, responce, testDir);
                    if (error != -1)
                        if (error == 10) {
                            printf("doing get. Arg: %s\n", argument);
                            file = fopen(argument, "r");
                            if (!file) {
                                sprintf(responce, "Error while getting file <%s>. Check file name.\n", argument);
                                write(client_sockfd, responce, strlen(responce));
                            } else {
                                long fileSize;
                                fseek(file, 0, SEEK_END);  
                                fileSize = ftell(file);  
                                rewind(file);    
                                sprintf(responce, "FBEGIN:%s:%d\r\n", argument, fileSize);  
                                send(client_sockfd, responce, sizeof(responce), 0);
                                while ((i = getc(file)) != EOF){    
                                    buf[0] = i;    
                                    send(client_sockfd, buf, sizeof(int) / sizeof(char), 0);  
                                }    
                                buf[0] = -1;
                                send(client_sockfd, buf, sizeof(int) / sizeof(char), 0);
                                fclose(file);
                            }
                    } else {
                        write(client_sockfd, responce, error);    
                    }
                }

while (1) {
   newsockfd = accept(sockfd, (struct sockaddr *) &cli_addr, &clilent);
   if (newsockfd < 0)
      error("ERROR on accept");
   pid = fork();
   if (pid < 0)
      error("ERROR on fork");
   if (pid == 0)  {
      close(sockfd);
      somefunction(newsockfd);
      exit(0);
   }
   else
   close(newsockfd);
}

if (strncmp(kb_msg, "quit", 4) == 0) {
                            sprintf(msg, "XClient is shutting down.\n");
                            write(sockfd, msg, strlen(msg));
                            close(sockfd); //close the current client
                            exit(0); //end program
                        }