// File: prg6_9.c
    #include <stdio.h>          /* These are the usual header files */
    #include <strings.h>          /* for bzero() */
    #include <unistd.h>         /* for close() */
    #include <sys/types.h>
    #include <sys/socket.h>
    #include <netinet/in.h>
    #include <arpa/inet.h>
    #include <sys/time.h>
    #include <stdlib.h>

    #define PORT 1234   /* Port that will be opened */
    #define BACKLOG 5   /* Number of allowed connections */
    #define MAXDATASIZE 1000
    typedef struct CLIENT{
       int     fd;
       char*  name;
       struct sockaddr_in addr; /* client's address information */
       char* data;                        
    };  
    void process_cli(CLIENT *client, char* recvbuf, int len);
    void savedata(char* recvbuf, int len, char* data);

    main()
    {
    int    i, maxi, maxfd,sockfd;
    int    nready;
    ssize_t    n;
    fd_set    rset, allset;
    int listenfd, connectfd; /* socket descriptors */     
    struct sockaddr_in server; /* server's address information */
    /* client's information */
    CLIENT client[FD_SETSIZE];
    char recvbuf[MAXDATASIZE];
    int sin_size;

    /* Create TCP socket  */
    if ((listenfd = socket(AF_INET, SOCK_STREAM, 0)) == -1) {
       /* handle exception */
       perror("Creating socket failed.");
       exit(1);
       }

    int opt = SO_REUSEADDR;
    setsockopt(listenfd, SOL_SOCKET, SO_REUSEADDR, &opt, sizeof(opt));

    bzero(&server,sizeof(server));
    server.sin_family=AF_INET;
    server.sin_port=htons(PORT);
    server.sin_addr.s_addr = htonl (INADDR_ANY);
    if (bind(listenfd, (struct sockaddr *)&server, sizeof(struct sockaddr)) == -1) {
       /* handle exception */
       perror("Bind error.");
       exit(1);
       }    

    if(listen(listenfd,BACKLOG) == -1){  /* calls listen() */
       perror("listen() error\n");
       exit(1);
       }

    sin_size=sizeof(struct sockaddr_in);
    /*initialize for select */
    maxfd = listenfd;    
    maxi = -1;            
    for (i = 0; i < FD_SETSIZE; i++) {
       client[i].fd = -1;    
       }
    FD_ZERO(&allset);
    FD_SET(listenfd, &allset);

    while(1)
    {
    struct sockaddr_in addr;
    rset = allset;        
    nready = select(maxfd+1, &rset, NULL, NULL, NULL);

    if (FD_ISSET(listenfd, &rset)) {    /* new client connection */
       /* Accept connection */
       if ((connectfd = accept(listenfd,(struct sockaddr *)&addr,&sin_size))==-1) {
          perror("accept() error\n");
          continue;
          }
       /* Put new fd to client */
       for (i = 0; i < FD_SETSIZE; i++)
          if (client[i].fd < 0) {
             client[i].fd = connectfd;    /* save descriptor */
             client[i].name = new char[MAXDATASIZE];
             client[i].addr = addr;
             client[i].data = new char[MAXDATASIZE];
             client[i].name[0] = '\0';
             client[i].data[0] = '\0';
             printf("You got a connection from %s.  ",inet_ntoa(client[i].addr.sin_addr) );
             break;
             }
          if (i == FD_SETSIZE)        printf("too many clients\n");
          FD_SET(connectfd, &allset);    /* add new descriptor to set */
          if (connectfd > maxfd)  maxfd = connectfd;    
          if (i > maxi)    maxi = i;        
          if (--nready <= 0) continue;    /* no more readable descriptors */
          }

       for (i = 0; i <= maxi; i++) {    /* check all clients for data */
          if ( (sockfd = client[i].fd) < 0)    continue;
          if (FD_ISSET(sockfd, &rset)) {
             if ( (n = recv(sockfd, recvbuf, MAXDATASIZE,0)) == 0) {
                /*connection closed by client */
                close(sockfd);
                printf("Client( %s ) closed connection. User's data: %s\n",client[i].name,client[i].data);
                FD_CLR(sockfd, &allset);
                client[i].fd = -1;
                delete client[i].name;
                delete client[i].data;
                } else
                process_cli(&client[i], recvbuf, n);
             if (--nready <= 0)    break;    /* no more readable descriptors */
             }
       }
    }
    close(listenfd);   /* close listenfd */         
    }

    void process_cli(CLIENT *client, char* recvbuf, int len)
    {
    char sendbuf[MAXDATASIZE];

    recvbuf[len-1] = '\0';
    if (strlen(client->name) == 0) {
       /* Got client's name from client */
       memcpy(client->name,recvbuf, len);
       printf("Client's name is %s.\n",client->name);
       return;
       }

    /* save client's data */
    printf("Received client( %s ) message: %s\n",client->name, recvbuf);
    /* save user's data */
    savedata(recvbuf,len, client->data);
    /* reverse usr's data */
    for (int i1 = 0; i1 < len - 1; i1++) {
       sendbuf[i1] = recvbuf[len - i1 -2];
    }
    sendbuf[len - 1] = '\0';

    send(client->fd,sendbuf,strlen(sendbuf),0);
    }

    void savedata(char* recvbuf, int len, char* data)
    {
    int start = strlen(data);
    for (int i = 0; i < len; i++) {
       data[start + i] = recvbuf[i];
    }         
    }