Discussion :

[Synn]

Bonjour à tous.

J'ai un pb dans une fonction qui ne fait qu'écrire un message socket et lire la réponse (voir code ci-dessous). L'initialisation se passe bien. La fonction write me retourne bien le nombre d'octets transmis mais, le serveur à qui je transmets le message ne reçoit rien. Ensuite je passe dans ma boucle de lecture, où je ne reçois rien bien entendu. J'arrive alors au niveau de la fonction close et là, le serveur reçoit mon message. Est-ce que quelqu'un pourrait m'expliquer pourquoi j'ai ce phénomène (et comment le régler si possible) ?

Code :

Sélectionner tout - Visualiser dans une fenêtre à part

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
145
146
147
148
149
150
151
152
153
154
155
int SendToServergeo (char* host_distant, char* szBeginSend, 
char* szEndSend, char* message, int mode, char *reponse_serveur, 
FILE *ftrace_geo)
{
  int sock;
  struct sockaddr_in servername;

  unsigned short int port = 2580;

  char hostname[256];

  strcpy(hostname, host_distant);

  sock = socket (PF_INET, SOCK_STREAM, 0);

  if (sock < 0)
    {
      perror ("socket (client)");
      return -1;
    }
    
  fcntl(sock,F_SETFL,O_NONBLOCK);

  int iAlive = 1;
  int iAliveLen = sizeof(iAlive);
  int iRetCode = setsockopt( sock, SOL_SOCKET, 
                      SO_KEEPALIVE, &iAlive, iAliveLen);

  if( iRetCode < 0 )
    {
    perror("setsockopt(SO_REUSEADDR)" );
    return EXIT_FAILURE;
    }

  /* Connect to the server.  */
  struct hostent *hostinfo;

  servername.sin_family = AF_INET;
  servername.sin_port = htons (port);
  hostinfo = gethostbyname (hostname);

  if (hostinfo == NULL) 
    {

      fprintf (stdout, "Unknown host %s : 
erreur %d\n", hostname,h_errno);

      return EXIT_FAILURE;
    }

  servername.sin_addr = *(struct in_addr *) hostinfo->h_addr;

  if (connect (sock,
           (struct sockaddr *) &servername,
           sizeof (servername))<0)
    {
      if(errno !=EINPROGRESS)
    {
      perror ("connect (client)");
      return EXIT_FAILURE;
    }
    }
  
  // on attend maintenant que la socket soit prete 
  struct timeval timeout;
  timeout.tv_sec = 1000;
  timeout.tv_usec =0;
  fd_set fds;
  FD_ZERO(&fds);
  FD_SET(sock,&fds);
  int rc=0;
  rc = select(sizeof(fds)*8,NULL,&fds,NULL,&timeout);
  if(rc <=0)
    {
      fprintf(stdout,"Erreur, impossible d'ouvrir 
               le port socket : %s\n",strerror(errno));
      return -1;
    }
  fcntl(sock,F_SETFL,!O_NONBLOCK);
  char buffer[320000];

  strcpy(buffer, message);
  int lmess = strlen(buffer);

  char *pmessage=buffer;

  do
    {
      int lwri = 4096;
      if(lmess < lwri)
    lwri=lmess;
      
      int nbw=write(sock, pmessage, lwri);
      if(nbw <0)
    {
      fprintf(stdout,"Erreur, impossible d'Ècrire
               le message : %s\n",strerror(errno));
       return -1;
    }
      else
    {
      lmess-=nbw;
      pmessage+=nbw;
    }
    }
  while(lmess > 0);

  int nbc=0;
  fcntl(sock,F_SETFL,O_NONBLOCK);
  int nbessais=10;

  do
    {
      nbc=read(sock,buffer,320000);    
      if(nbc>0)
    {
      buffer[nbc]='\0';
      fprintf(stdout,"%s",buffer);
      fflush(stdout);
    }
      else if(nbc <0)
    {
      if(errno == EAGAIN)
      {
        nbessais--;
        //sleep(1);
      }
      else if(errno !=54)
      {
        fprintf(stdout,"Erreur, impossible de lire 
                  la rÈponse : %d %s\n",errno,strerror(errno));
        return -1;
      }
      else
        {
          close (sock);
          return EXIT_SUCCESS;
        }
    }
      // quand le retour vaut 0, c'est la fin de fichier
    }
  while((nbc !=0) && (nbessais>0));

  close (sock);

  if(nbessais == 0)
    { //on n'a rien lu, on sort avec un code retour ‡ -1

      return -1;

    }

  return 0;

}

Cordialement,

Tony

[pier*]

Salut tu peux utiliser les balises de code stp, c'est plus lisible, j'ai pas lu ton code du coup (c'est chiant).

En plus je ne crois pas qu'il existe de fonction flush comme en java pour les sockets. Je viens de voir que le fflush() n'est la valable que pour les write dans les fichiers.

Mets des balises, ton code est trop long. Bisous.

[Synn]

Bonjour Pier.

Bon, je n'ai pas trop pigé le coup des balises code mais j'ai fait en sorte que le code soit + lisible en faisant des retours à la ligne sur les lignes trop longues.

Pour le fflush, il est fait sur le stdout, pas sur le port socket.

Donc, si quelqu'un a une idée sur le pourquoi du comment ce n'est qu'au moment du close que le serveur reçoit la réponse du client, je suis preneur !!

Synn

[zul]

Je ne sais pas trop d'ou vient le problème mais ton utilisation de fcntl est incorrecte.
Il faut faire quelquechose comme ca.

Code :

Sélectionner tout - Visualiser dans une fenêtre à part

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
int val;
val = fcntl(fd,F_GETFL);
if ( val < 0 ) {
   /* traiter erreur */
}

/* rajouter un flag */
val |= flag;
if ( fcntl(fd,F_SETFL,val) < 0 ){
    /* gestion error */
}

/* supprimer un flag */
val &= ~flag;
if ( fcntl(fd,F_SETFL,val) < 0 ){
    /* gestion error */
}

Essaye de voir si ca améliore ton probleme.

[je®ome]

Code :

Sélectionner tout - Visualiser dans une fenêtre à part

1
2
3
4
5
6
7
8
9
struct timeval timeout;
  timeout.tv_sec = 1000;
  timeout.tv_usec =0;
  fd_set fds;
  FD_ZERO(&fds);
  FD_SET(sock,&fds);
  int rc=0;
  rc = select(sizeof(fds)*8,NULL,&fds,NULL,&timeout);

Pourquoi utilises tu la fonction select, tu n'as qu'un seul descripteur , non ????
Pourqoui met tu l'intervalle à timeout et pas à NULL ??
le premier argument de select est le plus grand des descripteurs,
ici le plus grand des descripteur est sock, tu n'en a qu'un, donc ici le premier argument de select est:
sock +1.


Peut-être je n'ai pas compris ce que tu veux faire, mais la fonction select n'ouvre pas un port,
elle ne fait que vérifier s'il y a un chgnt sur une des socket appartenant à fds.

[Synn]

Bonjour.

Maintenant cela fonctionne. Il a juste fallu ajouter un "\n" à la fin des messages pour qu'ils soient lus par le client dès la fonction d'écriture du serveur.

J'aurai juste une question, est-ce que quelqu'un sait si les "\n" sont obligatoires lors de l'envois de messages via socket svp ?

Merci d'avance,

Synn

[Aramis]

Bonjour,

dans ma maigre experience d'ecrire des applications qui utilisent des sockets (principalement JAVA/C#) pour echanger du texte je dirais que oui le "\n" est obligatoire.

A.