ZSO-SPNFS_server.cpp

Go to the documentation of this file.

#include <arpa/inet.h>
#include <cstdio>      /* standard I/O routines.            */
#include <cstdlib>     /* standard library definitions      */
#include <cstring>     /* C++ wrapper for string.h - string operations*/
#include <errno.h>     /* system error numbers */
#include <fcntl.h>     /* file control options */
#include <map>         /* STL -> map */
#include <netdb.h>
#include <netinet/in.h>
#include <string>      /* STL -> string */
#include <sys/socket.h> /* guess for what is that ? ;) */
#include <sys/stat.h>  /* data returned by the stat() function */
#include <sys/types.h> /* standard system data types.       */
#include <unistd.h>    /* standard symbolic constants and types */
#include "ZSO-SPNFS_hooks.hpp" /* functions that handles each hook */
#include "ZSO-SPNFS_network.hpp" /*network functions */

void service_client(int client_socket);

int main (int argc, char **argv) {
    int sock;
    int status;
    int i;
    struct sockaddr_in clientname;
    socklen_t socklen;
    size_t size;
    int portnum;

    if(argc<=1){
        printf("Server usage:\n%s port\n",
                "\n"
                "When server runs, you can use client, telnet and webbrowser as well\n",
                argv[0]);
        return 0;
    };

    //INIT

    portnum = atoi(argv[1]);
    printf("Port = %d\n", portnum);

    /* Create the socket and set it up to accept connections.  */
    sock = make_socket (portnum);
    if (listen (sock, 1) < 0) {
        perror ("listen");
        exit (EXIT_FAILURE);
    }

    set_TCP_NODELAY(sock);

    // MAIN LOOP
    while (1) {
        if ( (status = accept (sock, (struct sockaddr *) &clientname, &socklen)) < 0) {
            perror ("accept");
            exit (EXIT_FAILURE);
        }
//#ifdef DEB
        fprintf (stderr, "Server: connect from host %s, port %hd.\n", inet_ntoa (clientname.sin_addr), ntohs (clientname.sin_port));
//#endif
        if( fork()==0 ){
            service_client(status);
            return 0;
        };
        // close client socket on parent thread side. To give thread child posiibility to close it permamently.
        close(status); 
    };
    return 0; //never reached
}
    
int logining(int);

void service_client(int client_socket){
    char ch;
    hooks_container hc; 
    //init
    if(logining(client_socket)<0){
        write(client_socket,make_csv_string(-1)+make_csv_string("login failed"));
        close(client_socket);
        return;
    };
    
    init_hooks(hc);
    
    //main loop
    while(1){
        //printf("%s\n", (read_csv_string(client_socket)).c_str() );
        hc << client_socket; //**< process one command
        write(client_socket, "\n-  -  -  -  -  -  -  -  -  -  -  -  -\n"); //flushing buffer
    };
    close(client_socket); 
};

int logining(int fd){
    if(read_csv_string(fd)=="login" && 
            read_csv_string(fd)=="ala" &&
            read_csv_string(fd)=="kota" ){
        write(fd,make_csv_string(0)+make_csv_string("logged in successfully"));
        return 0;
    };
    return -1;
};

---