#include	"../basic.h"
#include	<time.h>

void sigchldaction (int signal){

	int status, pid;
     
   for (pid = waitpid(-1,&status,WNOHANG);pid > 0;pid = waitpid(-1,&status,WNOHANG)){
   	// server: child terminated
   }  


}

void sigpipeaction (int signal){
    
    //fprintf(stderr, "Sigpipe catturato\n");
    
}

typedef struct message {
	char data[100];
}t_message;


int main(int argc, char **argv) {
	int			listenfd, connfd, n;
	struct sockaddr_in	servaddr;
	

//////////////////////////////////////////////////////////// SIGNALS
///////SIGCHLD
struct sigaction sigchldstructure;
       sigchldstructure.sa_handler = sigchldaction;
       sigchldstructure.sa_flags = 0;
          
sigaction (SIGCHLD, &sigchldstructure, NULL);

///////SIGPIPE
struct sigaction sigpipestructure;
    sigpipestructure.sa_handler = sigpipeaction;
    sigpipestructure.sa_flags = 0;
    
sigaction (SIGPIPE, &sigpipestructure, NULL);
//////////////////////////////////////////////////////////// END SIGNALS
	


	if (argc != 2 ){
		printf("usage: daytimesrv <porta>\n");
		exit(0);
}
	if( (listenfd = socket(AF_INET, SOCK_STREAM, 0)) < 0){
		printf("socket error\n");
		exit(0);
}
	bzero(&servaddr, sizeof(servaddr));
	servaddr.sin_family      = AF_INET;
	servaddr.sin_addr.s_addr = htonl(INADDR_ANY);   /* wildcard address */
	servaddr.sin_port        = htons(atoi(argv[1])); /* server port */

	if( (bind(listenfd, (struct sockaddr *) &servaddr, sizeof(servaddr))) < 0){
		printf("bind error\n"); exit(0);
}
	if( listen(listenfd, 5) < 0 )
		{ printf("listen error\n");
		  exit(0);
		}
		
	
	
	fd_set  fd_set_1;
	FD_ZERO(&fd_set_1);
	/*
	void FD_CLR(int fd, fd_set *set);
       int  FD_ISSET(int fd, fd_set *set);
       void FD_SET(int fd, fd_set *set);
       void FD_ZERO(fd_set *set);
       */
	
	struct timeval timer;
		timer.tv_sec = 99999999;
		timer.tv_usec = 0;


	
	for ( ; ; ) {
		
		
		if( (connfd = accept(listenfd, (struct sockaddr *) &client_address_struct, &client_address_struct_size)) < 0)
		{
			if(errno == EINTR || errno==ECONNABORTED)
				continue;
			printf("accept error\n");
			exit(1);
		}
		
		int split = fork();
			
		if ( split < 0) {
			printf("fork for iterative server failed\n");
			exit(-1);
		}
		
		if (split == 0){
			close(listenfd);
		

			t_message m;
			int ready_fds_to_read = 0;
			
			FD_set(connfd,&fd_set_1);
			
			for (ready_fds_to_read = select( connfd + 1, fd_set_1, NULL,NULL,&timer);
			     ready_fds_to_read <= 0 ;
			     ready_fds_to_read = select( connfd + 1, fd_set_1, NULL,NULL,&timer)){
				
				if (ready_fds_to_read == -1 && errno == EINTR ){ continue;}
				if (ready_fds_to_read ==  0) {timer.tv_sec = 99999999;continue;}
				// write code to inform client that server has an internal error
				exit(0);
				
			}// wait for nonblocking fd in read set
			
			 int ridden;
			 if( FD_ISSET(connfd, fd_set_1) ){
				for (ridden = read (connfd,&m,sizeof(m)); ridden <= 0;ridden = read (connfd,&m,sizeof(m))){
					if (errno == EINTR){continue;} else {exit(0);}
				}
				
				fprint(stdout,%s,m.data);
				
				
			 }
			 
			 exit(0);
		
		
		}else {
			close(connfd);
		}
	}
}