Discussion :

[jacquesh]

Bonjour à tous.

je débute avec les socket en C++ et j'ai un problème dans la reception quand il y a beaucoup de données (en tous cas bcp plus que le buffer peut absorbé)

voila des extraits du code :

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
 
...
    char buf[PACKET_SIZE];
 
    string message[] = {
        "authinfo user XXXX@free.fr\n",
        "authinfo pass YYYY\n"
    } ;
 
    for (int i=0;i<sizeof(message)/sizeof *message;++i){
 
    buf[0] = 0x00 ;
    ReadBuff(GetSocketId(),buf,(PACKET_SIZE)) ;
 
        // WRITE SOCKET
        if (int j = (write(GetSocketId(),message[i].c_str(),message[i].length()))<0){        
            cerr << "Impossible d'ecrire dans le socket !" << endl;
        } else {            
            if (DEBUG)
                cout << "Envoi de la commande : code("<< j << ")  " << message[i] << endl;
        }
 
    }
 
int Nntp::ReadBuff(int socket_id,char *buffer, unsigned int length) {
 
	int nl, nr ;
	nl = length ;
 
	while (nl > 0){
		memset(buffer, 0x0, PACKET_SIZE) ;
		nr = read(socket_id,buffer,nl) ;
		if (nr < 0) return nr ;
		else if (nr == 0) {
			cout << buffer ;
			break ;
		} else {
			cout << buffer ;
		}
		nl -= nr ;
		buffer += nr ;
		if ( *(buffer-1)=='\n' && *(buffer-2) == '\r'){
			break ;
		}
		break ;
	}
	*buffer = 0x00; 
	return (0); 
 
}

quelqu'un connait il un moyen de pouvoir gerer les buffers des sockets quelque soit la taille des données à obtenir et le type (Binaire ou Texte).

j'ai trouvé beaucoup de tuto mais a chaque fois c'est juste pour envoyer 'Hello World' mais pas une grande masse de données.

si quelqu'un peut m'expliquer l'algorithme a utilisé pour pouvoir tout récupérer..

merci d'avance.

[hansaplast]

perso, j'ai fait comme ca :

paquet 1 => envoie la taille du buffer

paquet 2 a n => envoi le buffer...

et ainsi de suite.

[jacquesh]

bijour,

ok mais si les données retourné dépasse le PACKET_SIZE défini au début du code ?

dans mon exemple quand je faut l'authentification au près du serveur pas de problème ; les données sont petites ; par contre quand je demande un grand nombre de données mon packet s'arrete à 1090 bytes et stop il s'arrete là (données vérifié avec Ethereal)

pourquoi ??

[niglo]

pourquoi ??

C'est normal, il atteint la limite maximale d'un paquet ! Ton message va être transféré en plusieurs paquets IP. Pour toi, ca va être transparent : l'émetteur fait un "write" sur un socket et de l'autre côté, tu fais un read pour attendre les données ! C'est write qui va se charger d'envoyer plusieurs paquets et read va les capter et les assembler !

[hansaplast]

et donc, il faut boucler, opour recomposer ta donnée initiale.

d'où ma proposition d'envoyer en premier la taille de la donnée, ainsi, tu sait quand sortir de ta boucle,e t tout recomposer

[jacquesh]

et donc, il faut boucler, opour recomposer ta donnée initiale.

d'où ma proposition d'envoyer en premier la taille de la donnée, ainsi, tu sait quand sortir de ta boucle,e t tout recomposer

c'est pas ce que je fait dans l'exemple fourni dans mon post ? le while dans la methode
Nntp::ReadBuff

[jacquesh]

ca c'est ce que dit le protocole TCP/IP je suis d'accord ; mon problème doit être la facon de l'implementé en C++ la bufferisation je pense...

quand je fait strace ./monprog voila ce que j'obtiens :

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
 
...
socket(PF_INET, SOCK_STREAM, IPPROTO_IP) = 4
connect(4, {sa_family=AF_INET, sin_port=htons(53), sin_addr=inet_addr("164.1.152.1")}, 28) = 0
writev(4, [{"\0\36", 2}, {"\240\243\1\0\0\1\0\0\0\0\0\0\4news\4free\2fr\0\0\1\0\1"..., 30}], 2) = 32
read(4, "\0022", 2)                     = 2
read(4, "\240\243\201\200\0\1\0\34\0\2\0\2\4news\4free\2fr\0\0\1"..., 562) = 562
close(4)                                = 0
read(3, 0xbfd2ad20, 1024)               = -1 ENOTCONN (Transport endpoint is not connected)
connect(3, {sa_family=AF_INET, sin_port=htons(119), sin_addr=inet_addr("212.27.42.138")}, 16) = 0
read(3, "200 nnrp10-1.free.fr NNRP Servic"..., 1024) = 79
write(1, "200 nnrp10-1.free.fr NNRP Servic"..., 79200 nnrp10-1.free.fr NNRP Service Ready - newsmaster@proxad.net (posting ok).
) = 79
write(3, "authinfo user XXXXXXXXX@free"..., 37) = 37
write(1, "Envoi de la commande : code(0)  "..., 69Envoi de la commande : code(0)  authinfo user XXXXXXXXXX@free.fr
) = 69
write(1, "\n", 1
)                       = 1
read(3, "381 PASS required\r\n", 1024)  = 19
write(1, "381 PASS required\r\n", 19381 PASS required
)   = 19
write(3, "authinfo pass YYYYYYYYY\r\n", 24) = 24
write(1, "Envoi de la commande : code(0)  "..., 56Envoi de la commande : code(0)  authinfo pass YYYYYYYYY
) = 56
write(1, "\n", 1
)                       = 1
read(3, "281 Ok\r\n", 1024)             = 8
write(1, "281 Ok\r\n", 8281 Ok
)               = 8
write(3, "list\r\n", 6)                 = 6
write(1, "Envoi de la commande : code(0)  "..., 38Envoi de la commande : code(0)  list
) = 38
write(1, "\n", 1
)                       = 1
shutdown(3, 2 /* send and receive */)   = 0
close(3)                                = 0
write(1, "Fermeture du socket :: id=3\n", 28Fermeture du socket :: id=3
) = 28
munmap(0xb7f19000, 4096)                = 0
exit_group(0)                           = ?

et quand j'envoi la commande 'list', je regarde dans ethereal et je n'est que les 1090 premier bytes pas la suite ???