-
La fonction de connexion au serveur en IPv4 :
int connexionServeur(char *hote,int port)
{
int s;
struct sockaddr_in adresse;
socklen_t taille=sizeof adresse;
int statut;
/* Creation d'une socket */
s=socket(PF_INET,SOCK_STREAM,0);
if(s<0){
perror("connexionServeur.socket");
exit(-1);
}
/* Connection de la socket a l'hote */
adresse.sin_family=AF_INET;
if(nomVersAdresse(hote,(void *)&adresse)<0) return -1;
adresse.sin_port=htons(port);
if(connect(s,(struct sockaddr *)&adresse,taille)<0) return -1;
else return s;
}
- La fonction de connexion au serveur en IPv6 :
int connexionServeur(char *hote,int port)
{
int s;
struct sockaddr_in6 adresse;
socklen_t taille=sizeof adresse;
int statut;
/* Creation d'une socket */
s=socket(PF_INET6,SOCK_STREAM,0);
if(s<0){
perror("connexionServeur.socket");
exit(-1);
}
/* Connection de la socket a l'hote */
adresse.sin6_family=AF_INET6;
if(nomVersAdresse(hote,(void *)&adresse)<0) return -1;
adresse.sin6_port=htons(port);
adresse.sin6_flowinfo=0;
adresse.sin6_scope_id=0;
if(connect(s,(struct sockaddr *)&adresse,taille)<0) return -1;
else return s;
}
- Une fonction de connexion générique :
int connexionServeur(char *hote,char *service){
struct addrinfo precisions,*resultat,*origine;
int statut;
int s;
/* Creation de l'adresse de socket */
memset(&precisions,0,sizeof precisions);
precisions.ai_family=AF_UNSPEC;
precisions.ai_socktype=SOCK_STREAM;
statut=getaddrinfo(hote,service,&precisions,&origine);
if(statut<0){ perror("connexionServeur.getaddrinfo"); exit(EXIT_FAILURE); }
struct addrinfo *p;
for(p=origine,resultat=origine;p!=NULL;p=p->ai_next)
if(p->ai_family==AF_INET6){ resultat=p; break; }
/* Creation d'une socket */
s=socket(resultat->ai_family,resultat->ai_socktype,resultat->ai_protocol);
if(s<0){ perror("connexionServeur.socket"); exit(EXIT_FAILURE); }
/* Connection de la socket a l'hote */
if(connect(s,resultat->ai_addr,resultat->ai_addrlen)<0)
{ freeaddrinfo(origine); shutdown(s,SHUT_RDWR); return -1; }
/* Liberation de la structure d'informations */
freeaddrinfo(origine);
return s;
}
- La fonction principale :
int main(int argc,char *argv[])
{
int s;
/* Lecture des arguments de la commande */
analyseArguments(argc,argv);
/* Connection au serveur */
s=connexionServeur(machine,port);
if(s<0){ fprintf(stderr,"Erreur de connexion au serveur\n"); exit(EXIT_FAILURE); }
/* Boucle de communication avec le serveur */
struct pollfd descripteurs[2];
descripteurs[0].fd=s;
descripteurs[0].events=POLLIN;
descripteurs[1].fd=0;
descripteurs[1].events=POLLIN;
while(1){
char tampon[MAX_TAMPON];
int nb=poll(descripteurs,2,-1);
if(nb<0){ perror("main.poll"); exit(EXIT_FAILURE); }
if((descripteurs[0].revents&POLLIN)!=0){
int taille=read(s,tampon,MAX_TAMPON);
if(taille<=0) break;
write(1,tampon,taille);
}
if((descripteurs[1].revents&POLLIN)!=0){
int taille=read(0,tampon,MAX_TAMPON);
if(taille<=0) break;
write(s,tampon,taille);
}
}
/* On termine la connexion */
shutdown(s,SHUT_RDWR);
return 0;
}