1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 33 34 35 36 37 38 39 40 41 42 43 44 45 46 47 48 49 50 51 52 53 54 55 56 57 58 59 60 61 62 63 64 65 66 67 68 69 70 71 72 73 74 75 76 77 78 79 80 81 82 83 84 85 86 87 88 89 90 91 92 93 94 95 96 97 98 99 100 101 102 103 104 105 106 107 108 109 110 111 112 113 114 115 116 117 118 119 120 121 122 123 124 125 126 127 128 129 130 131 132 133 134 135 136 137 138 139 140 141 142 143 144
|
int main()
{
#if defined (_WIN32)
WSADATA wsa_data;
if ( WSAStartup(MAKEWORD(2,2),&wsa_data) != 0 )
{
perror("WSAStartup()");
return 1;
}
#endif
struct client* unClient = NULL;
int err = 0;
int max;
int s_ecoute;
/*Ensemble de socket surveillées en lecture */
fd_set fds_lecture;
FD_ZERO(&fds_lecture);
/* Création de la socket */
s_ecoute = socket(PF_INET,SOCK_STREAM,0);
max = s_ecoute;
if ( s_ecoute != SOCKET_ERROR )
{
/* "bindage" de la socket */
struct sockaddr_in myaddr;
struct sockaddr_in client_addr;
myaddr.sin_family = AF_INET;
myaddr.sin_port = htons(PORT);
myaddr.sin_addr.s_addr = (INADDR_ANY);
err = bind(s_ecoute,(struct sockaddr *) &myaddr, sizeof (myaddr));
if ( err != SOCKET_ERROR )
{
/* Ecoute sur le port */
printf("Attente de connexion sur le port %d...\n",PORT);
err = listen(s_ecoute,10);
if ( err != SOCKET_ERROR )
{
/* On met la socket d'ecoute dans l'ensemble de lecture */
FD_SET(s_ecoute,&fds_lecture);
while(1)
{
if ( select(max+1,&fds_lecture,NULL,NULL,NULL) != -1 )
{
/* On parcourt la liste des clients */
while( unClient )
{
/* Si il sait passer quelque chose dans l'emsemble de lecture avec ce client */
if ( FD_ISSET(unClient->fd,&fds_lecture))
{
/* Si c'est la socket d'ecoute ==> nouvelle connexion ! */
if ( unClient->fd == s_ecoute )
{
unsigned int size_client_addr = sizeof(client_addr);
int newClient = accept(s_ecoute,(struct sockaddr *)&client_addr,&size_client_addr);
int oct_rec;
if ( newClient != SOCKET_ERROR )
{
char login[16];
printf("Connexion d'un nouveau client : %s...\n",inet_ntoa(client_addr.sin_addr));
/* On attend la réception de son login */
oct_rec = recv(newClient,login,sizeof(login),0);
if ( oct_rec != - 1)
{
/* On procède à l'authentification du login */
int authent = authentification(login);
if ( authent == 0 )
{
/* Authentification reussie ! */
/* On met le nouveau client dans la liste */
ajouter_client(&unClient,login,"",newClient);
/* On le met aussi dans l'ensemble de lecture */
FD_SET(newClient,&fds_lecture);
}
else
{
/* Client inconnu ! */
char erreur404[] = "Désolé vous n'etes pas dans la base de donnees...\n";
int oct_env;
/* On envoie un message d'erreur au client inconnu */
oct_env = send(newClient,erreur404,sizeof(erreur404),0);
if ( oct_env == -1 )
{
perror("send() 404error");
}
}
}
else
{
perror("revc() login");
}
}
else
{
perror("accept()");
}
}
else
{
/* Le client en cours a fait une action ! */
int oct_rec;
int message[144]; /* 16 premiers octets pour le login du destinataire, le reste c'est le message */
oct_rec = recv(unClient->fd,message,sizeof(message),0);
if ( oct_rec <= 0 )
{
/* Erreur ou deconnexion client */
}
else
{
/* Le client a envoyé un message ! */
}
}
}
unClient = unClient->suivant;
} /* Fin du parcour de la liste */
}
else
{
perror("select()");
}
} /* Fin de la boucle infinie */
}
else
{
perror("listen()");
}
}
else
{
perror("bind()");
}
}
else
{
perror("socket()");
err = 1;
}
#if defined (_WIN32)
WSACleanup();
#endif
return err;
} |
Partager