Comment vider les sockets ?

Recherche :

Mot : Pseudo : Filtrer
Bas de page
Auteur	Sujet : Comment vider les sockets ?

alex2423

j'aimerais bien faire 2 dialoguer un client serveur avec les sockets normal bloquantes. J'arrive a envoyer des données mais au bout d'un moment le fonction send bloque.

Malheuresement j'ai vu dans l'aide de send :

Citation :

Si la socket ne dispose pas de la place suffisante pour le message,
alors send va bloquer, à moins que la socket ait été configurée en mode
d'entrées/sorties non-bloquantes auquel cas elle renverra EAGAIN. On
peut utiliser l'appel système select(2) pour vérifier s'il est possible
d'émettre des données.

qu'une sockete dispose d'une quantité de placé limité. Comment faire avec des sockete bloquante car je n'ai pas envie de me lancer dans des socket non bloquante.

le client en voie un message
le serveur repond
le client repond
le serveur repond
.....
et ainsi de suite, je n'ai pas besoin de sockete non bloquantes
CLIENT

Code :

#define MAXDATASIZE 200 /* Tampon d'entrée */
int main(int argc, char *argv[])
{
int sockfd, numbytes;
//char buf[MAXDATASIZE];
struct hostent *he;
struct sockaddr_in their_addr; /* Adresse de celui qui se connecte */
char *buf=NULL;
rcv.pile = malloc (MAX_PILE_RECEPTION);
if (argc != 2)
{
fprintf(stderr,"usage: client hostname\n" );
exit(1);
}
printf("\n Etabilssement de la connexion sur le serveur %s\n",argv[1]);
if ((he=gethostbyname(argv[1])) == NULL)
{ /* Info de l'hôte */
herror("gethostbyname" );
exit(1);
}
if ((sockfd = socket(AF_INET, SOCK_STREAM, 0)) == -1)
{
perror("socket" );
exit(1);
}
their_addr.sin_family = AF_INET; /* host byte order */
their_addr.sin_port = htons(PORT); /* short, network byte order */
their_addr.sin_addr = *((struct in_addr *)he->h_addr);
bzero(&(their_addr.sin_zero), 8); /* zero pour le reste de struct */
if (connect(sockfd, (struct sockaddr *)&their_addr, sizeof(struct sockaddr)) == -1)
{
perror("connect" );
exit(1);
}
while (j < 4)
{
j++; printf("\n\n\n j == %d\n, strlen(buf) = %d", j, strlen(buf));
printf("\n buf : \n %s\n",buf);
printf("\n<<---------------------------- envoi ------------------------------->>\n" );
if (send(sockfd, buf, strlen(buf), 0) == -1)
{
perror("send" );
}
if (buf != NULL) free(buf);
buf = malloc (MAXDATASIZE);
if ((numbytes=recv(sockfd, buf, MAXDATASIZE, 0)) == -1)
{
perror("recv" );
exit(1);
}
buf[numbytes] = '\0';
printf("\n\n\n<<---------------------- Reception ------------------------------->>\n" );
if (seg.c_ack == 1 && seg.syn == 1)
{
printf("\n Connexion reussi avec le serveur (ack=1 & syn=1)\n" );
}
}
close(sockfd);
return 0;
}

SERVEUR

Code :

//serveur
#define MAXDATASIZE 200 /* Tampon d'entrée */
main()
{
int sockfd, new_fd, numbytes; /* Ecouter sock_fd, nouvelle connection sur new_fd */
struct sockaddr_in my_addr; /* Adresse */
struct sockaddr_in their_addr; /* Adresse du connecté */
int sin_size;
//char buf[MAXDATASIZE];
int j=0;
rcv.pile = malloc (MAX_PILE_RECEPTION);
//buffer pour la reception et emmsion des données
//allocation faites avec affectation_envoi
char *buf = NULL;
int bits=32;
//char *entete = malloc ( bits * sizeof (int)+1);
affectation_position_entete ();
if ((sockfd = socket(AF_INET, SOCK_STREAM, 0)) == -1)
{
perror("\nsocket\n" );
exit(1);
}
my_addr.sin_family = AF_INET; /* host byte order */
my_addr.sin_port = htons(MYPORT); /* short, network byte order */
my_addr.sin_addr.s_addr = INADDR_ANY; /* auto-remplissage avec mon IP */
bzero(&(my_addr.sin_zero), 8); /* zero pour le reste de struct */
if (bind(sockfd, (struct sockaddr *)&my_addr, sizeof(struct sockaddr)) == -1)
{
perror("\nbind\n" );
exit(1);
}
/*
if( getpeername (sockfd, (struct sockaddr *)&my_addr, sizeof(struct sockaddr) ) == -1)
{
perror("\ngetpeername\n" );
exit(1);
}*/
if (listen(sockfd, BACKLOG) == -1)
{
perror("\nlisten\n" );
exit(1);
}
fflush(stdout);
printf("\n <---------------------accept---------------------------->\n" );
sin_size = sizeof(struct sockaddr_in);
if ((new_fd = accept(sockfd, (struct sockaddr *)&their_addr, &sin_size)) == -1)
{
perror("\naccept\n" );
}
else
{
printf("\n connexion accept\n" );
}
while(j<5)
{
j++; printf("\n\n\n j == %d\n",j);
/* main accept() loop */
if (buf != NULL) printf("\nfree de buf\n" );
buf = malloc (MAXDATASIZE);
;
printf("\n<<---------------------------- reception ------------------------------->>\n" );
if ((numbytes=recv(new_fd, buf, MAXDATASIZE, 0)) == -1)
{
perror("\nrecv_serveur\n" );
exit(1);
}
buf[numbytes] = '\0';
affectation_seg(buf);
if (seg.c_ack == 0 && seg.syn == 1)
{
printf("\n\n\n\n<----Debut de connexion---->\n" );
printf("\n<<---------------------------- envoi ------------------------------->>\n" );
if (send(new_fd, buf, strlen(buf), 0) == -1)
{
perror("send" );
}
}
else
{
if ( !(snd.una.valeur < seg.ack && seg.ack <= snd.nxt) )
{
printf("\n reception du numero d'acquitement incorrect\n envoie d'un ack = 0\n" );
snd.c_ack = 0;
}
else if ( !(rcv.una.valeur < seg.seq && seg.seq <=rcv.nxt) )
{
printf("\n reception du numero de sequence incorrect\n envoie d'un ack = 0\n" );
snd.c_ack = 0;
}
}
fflush(stdout);
}
close(new_fd);
}
}

Message édité par alex2423 le 23-06-2004 à 22:30:22

Publicité

schnapsmann

Zaford Beeblefect

t'inquiete pas coco, en envoi la socket va bloquer seulement si son buffer interne est plein et ne permet pas de stoquer le nombre d'octets que tu veux envoyer.

Si elle bloque pour cause de buffer plein, la pile tcp/ip de ton système va bien finir par réussir à envoyer les données contenues dans le buffer tcp/ip. Et donc send va débloquer quand la socket se sera vidée suffisament pour "envoyer" tes octets.

Message édité par schnapsmann le 23-06-2004 à 22:01:54

---------------
From now on, you will speak only when spoken to, and the first and last words out of your filthy sewers will be "Sir!"

alex2423

en plus j'ai l'impression que tu as raison

c'est vraiment bizzare cette histoire
aupravant quand je voyais a mon dernier send 30 caracteres ca passait et lorsque j'essayé 31, ca passait plus

enfin bon la j'ai l'impression que ca fonctionne

alex2423

et au fait tu m'as plus que rassurer quand tu m'as dis ca

merci a toi

schnapsmann

Zaford Beeblefect

non, a mon avis tu as un bug mais j'ai pas envie de lire le gros paté que tu as posté.

passer de 30 à 31 octets, ça ne represente rien.

---------------
From now on, you will speak only when spoken to, and the first and last words out of your filthy sewers will be "Sir!"

alex2423

schnapsmann a écrit :

non, a mon avis tu as un bug mais j'ai pas envie de lire le gros paté que tu as posté.

passer de 30 à 31 octets, ça ne represente rien.

lol je te comprends a moitié

mon gros paté comme tu le dis, je ne l'ai pas assez commenyé pour que ce soit plus lisible
mais maintenant ca fonctionne

je sais pas pourquoi ....

jagstang

Pa Capona ಠ_ಠ

ça serait une bonne idée de faire des fonctions, ou mieux, une classe.

---------------
What if I were smiling and running into your arms? Would you see then what I see now?

alex2423

oui la je sais que c'est pas tres propre ce que j'ai fais de mettre les sends et les rcv, y a tellement de calcule a faire autour des recv et des send que j'ai decidé de faire les fonctions apres ...

En ce qui concerne les classes, j'avais de mal à visulaiser les objets dans ce que je veux faire ... Et comme je n'aime pas faire du C dans du C++ c'est a dire en faisant presque pas de POO, mon choix c'est fais sur le C

FORUM HardWare.fr

Programmation

Comment vider les sockets ?

Sujets relatifs
[VBA Excel] - Vider toutes les TextBox d'un UserForm	Cours sur les sockets ICMP
Problème de sockets	[C] Sockets et appel système "select()"
[Delphi] Vider un StringGrid ?	vider 1 tableau
[java]Régler le timeout de déconnexion des sockets	Sockets haut niveau
Vider un buffer cin
Plus de sujets relatifs à : Comment vider les sockets ?

Page générée en 0.123 secondes