/* serv_6_1ou0.c */ #include #include #include #include #include #include #include #include #include #include #include #include #define PORT_NUMBER "60000" #define REQUETES 1 /* Empêche plus d'une connexion à la fois */ #define TAMPON 4000 enum liste_des_etats { ETAT0_initialisation, ETAT1_attente_connexion, ETAT2_attente_donnee_entrante } etat_serveur=ETAT0_initialisation; const char *err400="HTTP/1.0 400 Invalid\x0d\x0a\ Content-Type: text/html\x0d\x0a\ Content-Length: 34\x0d\x0a\ \x0d\x0a\ Mauvaise requete"; const char *LED_On="HTTP/1.0 200 OK\x0d\x0a\ Content-Type: text/html\x0d\x0a\ Content-Length: 42\x0d\x0a\ \x0d\x0a\ LED allumée"; const char *LED_Off="HTTP/1.0 200 OK\x0d\x0a\ Content-Type: text/html\x0d\x0a\ Content-Length: 42\x0d\x0a\ \x0d\x0a\ LED éteinte"; /* sortie avec un message d'erreur contextualisé */ void erreur(char *msg) { perror(msg); exit(EXIT_FAILURE); } /* variable persistentes du serveur */ int sock_serveur, sock_client; const int one = 1, zero=0; /* pour setsockopt() */ struct sockaddr_storage sockaddr_serveur, sockaddr_client; socklen_t taille_client = sizeof(sockaddr_client); char buffer[TAMPON]; void serveur() { /* variables locales du serveur, non persistantes */ struct addrinfo hints, *liste_adresses, *p_adresse, *aiv4, *aiv6, *choix_ai; int len, flags, sockV4, sockV6, recv_len; char *env_port, *b; switch(etat_serveur) { /********************************************************/ case ETAT0_initialisation : /* gestion du numéro du port */ env_port = getenv("GHDL_TCPPORT"); if (env_port == NULL) env_port=PORT_NUMBER; printf("Port : %s, ",env_port); /* décrit le type de socket que nous voulons ouvrir */ memset(&hints, 0, sizeof(hints)); /* vidange préliminaire */ hints.ai_family = AF_UNSPEC; /* IPv4 ou 6, comme ça lui chante */ hints.ai_socktype = SOCK_STREAM; /* TCP */ hints.ai_flags = AI_PASSIVE; /* mode serveur */ if ((flags=getaddrinfo(NULL, env_port, &hints, &liste_adresses)) < 0) { printf("getaddrinfo: %s\n", gai_strerror(flags)); exit(EXIT_FAILURE); } sockV4=-1; sockV6=-1; p_adresse = liste_adresses; /* Balaie la liste d'adresses et tente de créer des sockets */ while (p_adresse) { if (p_adresse->ai_family == AF_INET6) { /* IPV6 */ if (sockV6 < 0) { if ((sockV6 = socket(p_adresse->ai_family, p_adresse->ai_socktype, p_adresse->ai_protocol)) >= 0) { aiv6 = p_adresse; printf("IPv6 found, "); } } } else { if (p_adresse->ai_family == AF_INET) { /* IPv4 */ if (sockV4 < 0) { if ((sockV4 = socket(p_adresse->ai_family, p_adresse->ai_socktype, p_adresse->ai_protocol)) >= 0) { aiv4 = p_adresse; printf("IPv4 found, "); } } } /* else : protocole inconnu, on essaie le suivant */ } p_adresse=p_adresse->ai_next; /* avance dans la liste chaînée */ } /* sélection de la socket : */ if (sockV6 >= 0) { choix_ai = aiv6; sock_serveur = sockV6; /* Tente d'activer la traduction IPv6->IPv4 */ if (setsockopt(sockV6, IPPROTO_IPV6, IPV6_V6ONLY, &zero, sizeof(zero)) < 0) { perror("notice : setsockopt(IPV6_V6ONLY)"); /* Si la traduction n'est pas possible, on essaie de passer en IPv4 */ if (sockV4 >= 0) { printf("close(V6)"); close(sockV6); } } else { /* traduction possible : on ferme l'IPv4*/ if (sockV4 >= 0) { printf("v4 over v6 => close(v4)"); close(sockV4); sockV4=-1; } } } /* pas d'IPv6 ou pas de traduction IPv6 */ if (sockV4 >= 0) { choix_ai = aiv4; sock_serveur = sockV4; } else if (sockV6 < 0) erreur("Aucune socket convenable choisie"); printf("\n"); #ifdef SO_REUSEADDR if (setsockopt(sock_serveur, SOL_SOCKET, SO_REUSEADDR, &one, sizeof(one)) < 0) perror("setsockopt(SO_REUSEADDR)"); #endif #ifdef SO_REUSEPORT if (setsockopt(sock_serveur, SOL_SOCKET, SO_REUSEPORT, &one, sizeof(one)) < 0) perror("setsockopt(SO_REUSEPORT)"); #endif /* Branche la socket */ if (bind(sock_serveur, choix_ai->ai_addr, choix_ai->ai_addrlen) < 0) erreur("Echec de bind() du serveur"); /* Ecoute la socket */ if (listen(sock_serveur, REQUETES) < 0) erreur("Echec de listen() du serveur"); /* Débloque la socket */ flags = fcntl(sock_serveur, F_GETFL); fcntl(sock_serveur, F_SETFL, flags | O_NONBLOCK); /* libère la mémoire occupée par la liste */ freeaddrinfo(liste_adresses); etat_serveur=ETAT1_attente_connexion; /********************************************************/ case ETAT1_attente_connexion: /* Attente d'une connexion */ if ((sock_client = accept(sock_serveur, (struct sockaddr *) &sockaddr_client, &taille_client)) < 0) { if ((errno == EWOULDBLOCK) || (errno == EAGAIN)) return; else erreur("accept() : Echec d'attente de connexion"); } /* Désactive Nagle */ if (setsockopt(sock_client, IPPROTO_TCP, TCP_NODELAY, &one, sizeof(one)) < 0) erreur("setsockopt(TCP_NODELAY)"); getnameinfo((struct sockaddr *) &sockaddr_client, taille_client, buffer, sizeof(buffer), NULL, 0, NI_NUMERICHOST); b=buffer; if (memcmp("::ffff:",buffer,7)==0) b+=7; // saute le préfixe IPv6 printf("Client connecté de %s\n",b); etat_serveur= ETAT2_attente_donnee_entrante; /********************************************************/ case ETAT2_attente_donnee_entrante : /* attend quelque chose */ if ( (recv_len=recv(sock_client, buffer, TAMPON, MSG_DONTWAIT)) < 0) { if ((errno == EWOULDBLOCK) || (errno == EAGAIN)) return; else erreur("Echec de réception du message du client"); } /* analyse de la requête */ if ((recv_len >= 7) && (strncmp("GET /1 ", buffer, 7) == 0)) { printf("Allumage de la LED\n"); b=LED_On; } else { if ((recv_len >= 7) && (strncmp("GET /0 ", buffer, 7) == 0)) { printf("Extinction de la LED\n"); b=LED_Off; } else { printf("Requête invalide\n"); b=err400; } } /* Réponse : */ len=strlen(b); if (send(sock_client, b, len, 0) != len) erreur("Echec d'envoi du message"); close(sock_client); printf("Fermeture de la connexion\n"); etat_serveur=ETAT1_attente_connexion; return; /********************************************************/ default: erreur("état interdit !"); } } /* fonction principale qui appelle le serveur périodiquement */ int main(int argc, char *argv[]) { while (1) { usleep(100*1000); /* attente de 100ms */ serveur(); } }