flavien/TP3_SOCKET
1
0
Fork 0
Code Issues Pull Requests Releases Wiki Activity

cassé mais connexion ok

Browse Source
This commit is contained in:
Flavien Haas 2019-10-30 13:13:10 +01:00
parent 59186f5371
commit a32d94d037
2 changed files with 24 additions and 21 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

9
client_echo.c
View File

@ -22,8 +22,8 @@ int cree_socket(char* ip, char* port, struct addrinfo hints){
void con_serveur(int *sfd){ void con_serveur(int *sfd){
struct addrinfo *rp; // structure de l'adresse du client struct addrinfo *rp; // structure de l'adresse du client
/* getaddrinfo () retourne une liste de structures d'adresses. /* getaddrinfo () retourne une liste de structures d'adresses.
Essayez chaque adresse jusqu'à ce que nous ayons réussi à bind(2). Essayez chaque adresse jusqu'à ce que nous ayons réussi à connect(2).
Si socket() (ou bind()) échoue, nous (fermons le socket et) Si socket() (ou connect()) échoue, nous (fermons le socket et)
essayons l'adresse suivante */ essayons l'adresse suivante */
for (rp = result; rp != NULL; rp = rp->ai_next) { for (rp = result; rp != NULL; rp = rp->ai_next) {
@ -81,7 +81,8 @@ int main(int argc, char *argv[]) {
/* Obtain address(es) matching host/port */ /* Obtain address(es) matching host/port */
memset(&hints, 0, sizeof(struct addrinfo)); memset(&hints, 0, sizeof(struct addrinfo));
hints.ai_family = AF_UNSPEC; // utilisation du serveur sur IPv4/v6 (AF_INET/AF_INET6) hints.ai_family = AF_UNSPEC; // utilisation du serveur sur IPv4/v6 (AF_INET/AF_INET6)
hints.ai_socktype = SOCK_DGRAM; // socket en mode datagramme hints.ai_socktype = SOCK_STREAM; // socket en mode datagramme
hints.ai_protocol = IPPROTO_TCP; // protocol de connexion
s = cree_socket(ip, port, hints); // création du socket s = cree_socket(ip, port, hints); // création du socket
if(s == 1) { if(s == 1) {
@ -99,7 +100,5 @@ int main(int argc, char *argv[]) {
sendreceive(argv[j], len, j, sfd); sendreceive(argv[j], len, j, sfd);
} }
exit(EXIT_SUCCESS); exit(EXIT_SUCCESS);
} }

36
serveur_echo.c
View File

@ -7,8 +7,9 @@
#include <netdb.h> #include <netdb.h>
#define BUF_SIZE 500 #define BUF_SIZE 500
#define MAX_CON 5 /* nombre maximum de connexions */
struct addrinfo *result; // tableau des adresses réseaux des clients struct addrinfo *result; /* tableau des adresses réseaux des clients */
int cree_socket(struct addrinfo hints, char* port){ int cree_socket(struct addrinfo hints, char* port){
int s = getaddrinfo(NULL, port, &hints, &result); int s = getaddrinfo(NULL, port, &hints, &result);
@ -20,27 +21,28 @@ int cree_socket(struct addrinfo hints, char* port){
} }
void con_client(int *sfd){ void con_client(int *sfd){
struct addrinfo *rp; // structure de l'adresse du client struct addrinfo *rp; /* structure de l'adresse du client */
/* getaddrinfo () retourne une liste de structures d'adresses. /* getaddrinfo () retourne une liste de structures d'adresses.
Essayez chaque adresse jusqu'à ce que nous ayons réussi à bind(2). Essayez chaque adresse jusqu'à ce que nous ayons réussi à bind(2).
Si socket() (ou bind()) échoue, nous (fermons le socket et) Si socket() (ou bind()) échoue, nous (fermons le socket et)
essayons l'adresse suivante */ essayons l'adresse suivante */
for (rp = result; rp != NULL; rp = rp->ai_next) { for (rp = result; rp != NULL; rp = rp->ai_next) {
// socket crée un point de communication et renvoie un descripteur /* socket crée un point de communication et renvoie un descripteur */
*sfd = socket(rp->ai_family, rp->ai_socktype, rp->ai_protocol); *sfd = socket(rp->ai_family, rp->ai_socktype, rp->ai_protocol);
if (*sfd == -1){ if (*sfd == -1){
continue; continue;
} }
if (bind(*sfd, rp->ai_addr, rp->ai_addrlen) == 0){ if (bind(*sfd, rp->ai_addr, rp->ai_addrlen) == 0){
break; // Succès break; /* Succès */
} }
close(*sfd); close(*sfd);
} }
if (rp == NULL) { // Aucune adresse n'a pu marcher if (rp == NULL) { /* Aucune adresse n'a pu marcher */
fprintf(stderr, "Could not bind\n"); fprintf(stderr, "Could not connect\n");
exit(EXIT_FAILURE); exit(EXIT_FAILURE);
} }
listen(*sfd, MAX_CON);
} }
void traite_connexion(int sfd, int s){ void traite_connexion(int sfd, int s){
@ -48,9 +50,10 @@ void traite_connexion(int sfd, int s){
char buf[BUF_SIZE]; char buf[BUF_SIZE];
struct sockaddr_storage peer_addr; struct sockaddr_storage peer_addr;
socklen_t peer_addr_len; socklen_t peer_addr_len;
// Lit les datagrammes et les renvoi au client /* Lit les datagrammes et les renvoi au client */
for (;;) { for (;;) {
peer_addr_len = sizeof(struct sockaddr_storage); peer_addr_len = sizeof(struct sockaddr_storage);
accept(sfd, (struct sockaddr*)&peer_addr, &peer_addr_len); /* accepte la connexion */
nread = recvfrom(sfd, buf, BUF_SIZE, 0, (struct sockaddr *) &peer_addr, &peer_addr_len); nread = recvfrom(sfd, buf, BUF_SIZE, 0, (struct sockaddr *) &peer_addr, &peer_addr_len);
if (nread == -1){ if (nread == -1){
continue; continue;
@ -73,29 +76,30 @@ void traite_connexion(int sfd, int s){
int main(int argc, char *argv[]){ int main(int argc, char *argv[]){
struct addrinfo hints; struct addrinfo hints;
int s; // s code de retour de getaddrinfo int s; /* s code de retour de getaddrinfo */
int sfd; // code de retour de l'ouverture du socket int sfd; /* code de retour de l'ouverture du socket */
if (argc != 2) { // test du nombre d'arguments entrés if (argc != 2) { /* test du nombre d'arguments entrés */
fprintf(stderr, "Usage: %s port\n", argv[0]); fprintf(stderr, "Usage: %s port\n", argv[0]);
exit(EXIT_FAILURE); exit(EXIT_FAILURE);
} }
char* port = argv[1]; // récupération du port passée en paramètre du programme char* port = argv[1]; /* récupération du port passée en paramètre du programme */
// remplissage de la structure hints contenants la configuration réseau du serveur /* remplissage de la structure hints contenants la configuration réseau du serveur */
memset(&hints, 0, sizeof(struct addrinfo)); memset(&hints, 0, sizeof(struct addrinfo));
hints.ai_family = AF_UNSPEC; // utilisation du serveur sur IPv4/v6 (AF_INET/AF_INET6) hints.ai_family = AF_UNSPEC; /* utilisation du serveur sur IPv4/v6 (AF_INET/AF_INET6) */
hints.ai_socktype = SOCK_DGRAM; // socket en mode datagramme hints.ai_socktype = SOCK_STREAM; /* socket en mode datagramme */
hints.ai_protocol = IPPROTO_TCP; /* protocol de connexion */
s = cree_socket(hints, port); // création du socket s = cree_socket(hints, port); /* création du socket */
if(s == 1) { if(s == 1) {
exit(EXIT_FAILURE); exit(EXIT_FAILURE);
} }
con_client(&sfd); con_client(&sfd);
freeaddrinfo(result); // libère la structure d'adresse client freeaddrinfo(result); /* libère la structure d'adresse client */
traite_connexion(sfd, s); traite_connexion(sfd, s);