C++

problème taille de buffer /socket

Recherche :

Mot : Pseudo : Filtrer
Bas de page
Auteur	Sujet : problème taille de buffer /socket

Nico5779

bonjour,
Je voudrait faire un programme qui fait un genre de tunnel, pour rediriger les connexions entrantes sur le port XX vers le port port YY de la machine A.B.C.D

g taper le code suivant

Code :

#ifdef unix
#define closesocket close
#include <sys/types.h>
#include <sys/socket.h>
#include <netinet/in.h>
#include <arpa/inet.h>
#include <netdb.h>
#else
#define WIN32
#include <windows.h>
#include <winsock.h>
#endif
#include <stdio.h>
#include <string.h>
#include <iostream.h>
#define WEBPORT 2000
#define LOCALPORT 80
#define BUFFER 100000
#define QLEN 6
int visits = 0;
extern int errno;
char localhost[] = "192.168.0.81";
int sizeString(char buf[BUFFER]);
int main ()
{
struct hostent *ptrh_cli;
struct protoent *ptr_serveur,*ptrp_client;
struct sockaddr_in serveur,sad_cli,sad_serv;
int port_cli,sd_cli,n_cli,alen,port,sd,sd2,n,i = 0;;
char *host_cli;
char buffer[BUFFER],buf_cli[BUFFER];
while (i < BUFFER)
{
buffer[i] = '*';
buffer2[i] = '*';
buf_cli[i] = '*';
i++;
}
#ifdef WIN32
WSADATA wsaData;
WSAStartup(0x0101 , &wsaData);
#endif
memset((char *)&sad_serv,0,sizeof(sad_serv));
sad_serv.sin_family = AF_INET;
sad_serv.sin_addr.s_addr = INADDR_ANY;
port = WEBPORT;
sad_serv.sin_port = htons((u_short) port);
if (((int)(ptr_serveur = getprotobyname("tcp" ))) ==0)
{
cerr<<"failed to get prtocol by name"<<endl;
exit(1);
}
sd = socket(PF_INET, SOCK_STREAM , ptr_serveur->p_proto);
if (sd < 0)
{
cerr<<"erreur while initializing socket"<<endl;
exit(1);
}
if (bind(sd,(struct sockaddr *)&sad_serv, sizeof(sad_serv))<0)
{
cerr<<"error while binding socket"<<endl;
exit(1);
}
if (listen(sd ,QLEN) >= 0)
{
cout<<"Listening port "<<port<<"..."<<endl;
}
else
{
cerr<<"failed to listen port "<<port<<" ..."<<endl;
exit(1);
}
memset((char *) &sad_cli,0,sizeof(sad_cli));
sad_cli.sin_family = AF_INET;
port_cli = LOCALPORT;
sad_cli.sin_port = htons ((u_short)port_cli);
host_cli = localhost;
ptrh_cli = gethostbyname(host_cli);
if (((char *)ptrh_cli) == NULL)
{
cerr<<"host unknown"<<host_cli<<endl;
exit(1);
}else
{
cout<<"attempting to reach "<<(char *)ptrh_cli->h_name<<" ..."<<endl;
}
memcpy(&sad_cli.sin_addr , ptrh_cli->h_addr,ptrh_cli->h_length);
if (((int)(ptrp_client = getprotobyname("tcp" ))) == 0)
{
cerr<<"failed to get prtocol by name"<<endl;
exit(1);
}
//listen(sd,QLEN);
while(true)
{
alen = sizeof(serveur);
if ((sd2=accept(sd,(struct sockaddr *)&serveur ,&alen))<0)
{
cerr<<"unable to accept remote user\n"<<endl;
exit(1);
}else
{
visits++;
cout<<endl<<"connection id: "<<visits<<endl;
}
sd_cli = socket(PF_INET, SOCK_STREAM, ptrp_client->p_proto);
if(sd_cli < 0)
{
cerr<<"erreur while initializing socket"<<endl;
exit(1);
}
if (connect(sd_cli,(struct sockaddr *)& sad_cli,sizeof(sad_cli)) >= 0)
{
cout<<"*** connected to "<<localhost<<" ***"<<endl;
}else
{
cerr<<"attempt to connect "<<localhost<<" failed ... aborting"<<endl;
exit(1);
}
n = recv(sd2,buffer,sizeof(buffer),0);
send (sd_cli,buffer,strlen(buffer),0);
n_cli = recv(sd_cli,buf_cli,sizeof(buf_cli),0);
send (sd2,buf_cli,sizeString(buf_cli)-1,0);
closesocket(sd_cli);
closesocket(sd2);
}
return 0;
}
int sizeString(char buf[BUFFER])
{
int i = 0;
bool b = true;
while (i < BUFFER && b == true)
{
int j = i,c=0;
while (j<i+15)
{
if(buf[j] == '*')
c++;
j++;
}
if (c >= 14)
b = false;
i++;
}
return i;
}

a priori ca fonctionne mais lorsque que j'essaye de transferer un buffer suprérieur a 10220 bytes ca foire
Je vois pas trop comment m'y prendre ...si vous pouvez me guider sur le principe pour gerer les transferts en paquets...
Merci d'avance :jap:

Publicité

kenshiro182

Euh il aime peut-etre pas les variables globales trop grosses ?
Decris exactement ce qui se passe... Utilise un debugger...

Nico5779

Ben concrètement je teste le prog avec un serveur web sur la machine A.B.C.D , et si la page (ou image) est supérieur a 10ko elle s'affiche pas ou mal dans le navigateur, alors que je crée un buffer de 100ko pour stocker les données transferées.
Lorsque j'affiche la taille du buffer en cours elle vaut tj 10220 maximum (ou moins lorsque chaque objet de la page est < 10ko)

Nico5779

un bon vieux up :bounce:

western

AJMM

un buffer de 100000 octets ... :pt1cable:
vous etes les meilleurs!
Petite question: pourquoi un buffer aussi gros? 2048 est une taille raisonnable ...

Nico5779

ben c présicément mon prob...
d'abord je n arrive pas remplir les 100000 bytes du buffer,
Et ensuite c justement ske je voulais savoir comment gerer des transfert de gros fichiers en ptit paquet avec un ptit buffer.

western

AJMM

les paquets TCP ou UDP a une taille maximal qui n'est pas très grande ... tout est découpé en morceaux et reassemblé par le destinataire donc un gros buffer n'a pas d'intérêt ...
Comment lire un gros fichier? Comme les petits:

Code :

FILE * peripherique = fopen(fichier_in, "r" );
if(peripherique == NULL)
{
//on arrete tout!
}
FILE * fichier_iso = fopen(fichier_out, "w" );
if(fichier_iso == NULL)
{
fclose(peripherique);
//on arrete tout!
}
int taille_lu = 1;
while(taille_lu >= 0)
{
taille_lu = read(fileno(peripherique), buffer, taille);
progression = progression + ((double)taille_lu * 100)/(double)taille_cd;
printf("progression = '%f'\n", progression);
if(taille_lu == 0)
{
//fini
resultat = 0;
break;
}
if(taille_lu < 0)
{
//un error a eu lieu!
fprintf(stderr, "L'erreur '%s' a eu lieu pendant l'extraction du iso\n", strerror(errno));
unlink(nom_iso.val());
progression=0.0;
break;
}
write(fileno(fichier_iso), buffer, taille_lu);
}
fclose(fichier_iso);
fclose(peripherique);

Cet extrait de code permet de copier un fichier de taille quelconque ... il suffit que tu remplace fichier_iso par ta socket!

EDIT: pas terrible, la rendue ...

Message édité par western le 27-02-2003 à 16:26:10

Nico5779

merci :jap:
J'en ai pour l'aprem avec ca , mais tant mieux y fait bo , (et moi j aime la pluie )
Je voudrait juste etre sur d'avoir compris la méthode,
Donc peripherique c le fichier qui contient ce que je veux transferer?
Et lorsque tu fait write fichier_iso je doit faire un send ?
ca bien ca?
Et est que la méthode peut s appliquer pour recevoir un fichier (en inversant les fonctions)?
Encore merci pour ton aide

western

AJMM

bingo! cela doit être ça! (cela fait au moins deux ans que j'ai pas touché aux sockets en C)

Nico5779

oki nikel ,encore merci :jap:
une dernière question ( je pousse la )
Vous me conseillez quoi comme sentinelle mieux 15 '*'.
Le char 4 (EOT) sert a ca ?

Publicité

Nico5779

heu voila je vien de taper ca

Code :

#ifndef unix
#define WIN32
#include <windows.h>
#include <winsock.h>
#else
#define closesocket close
#include <sys/types.h>
#include <sys/socket.h>
#include <netinet/in.h>
#include <netdb.h>
#endif
#include <stdio.h>
#include <string.h>
#include <iostream.h>
#include <fstream.h>
#define PROTOPORT 2000
#define QLEN 6
#define SIZEOFBUFFER 5000
int visits = 0;
char * filename ="d:/mod/test/Debug/q3iscr.jpg";
void main ()
{
int i = 0;
int size=0;int j = 0;
struct hostent *ptrh;
struct protoent *ptrp;
struct sockaddr_in cad;
struct sockaddr_in sad;
int sd,sd2;
int port;
int alen;
int n;
char buffer[SIZEOFBUFFER];
#ifdef WIN32
WSADATA wsaData;
WSAStartup(0x0101 , &wsaData);
#endif
memset((char *)&sad,0,sizeof(sad));
sad.sin_family = AF_INET;
sad.sin_addr.s_addr = INADDR_ANY;
port = PROTOPORT;
if (port > 0)
sad.sin_port = htons((u_short) port);
else
{
fprintf(stderr,"numero de port invalide" );
exit(1);
}
if (((int)(ptrp = getprotobyname("tcp" ))) ==0)
{
fprintf (stderr,"conversion de \"tcp\" impossible" );
exit(1);
}
sd = socket(PF_INET, SOCK_STREAM , ptrp->p_proto);
if (sd < 0)
{
fprintf(stderr,"erreur (socket)\n" );
exit(1);
}
if (bind(sd,(struct sockaddr *)&sad, sizeof(sad))<0)
{
fprintf(stderr,"erreur (bind)\n" );
exit(1);
}
if (listen(sd ,QLEN < 0))
{
fprintf(stderr,"erreur (listen)\n" );
exit(1);
}
cout<<"Listening port "<<port<<"..."<<endl;
while (1)
{
alen = sizeof(cad);
if ((sd2=accept(sd,(struct sockaddr *)&cad ,&alen))<0)
{
fprintf(stderr,"accept failed\n" );
exit(1);
}else
{
cout<<endl<<"conection id: "<<visits<<endl;
}
visits++;
ifstream file (filename, ios::in|ios::binary|ios::ate);
size = file.tellg();
file.seekg (0, ios::beg);
i = 0;
while(j < size/SIZEOFBUFFER)
{
j++;
}
int lastbuf = size - (j*SIZEOFBUFFER);
while(i <= size/SIZEOFBUFFER)
{
file.read(buffer, SIZEOFBUFFER);
cout<<"lecture buffer:"<<i<<endl;
if(i == j )
{
send (sd2,buffer,lastbuf,0);
cout<<lastbuf<<" bytes sended"<<endl;
}else
{
send (sd2,buffer,SIZEOFBUFFER,0);
cout<<SIZEOFBUFFER<<" bytes sended"<<endl;
}
i++;
}
file.close();
cout<<endl<<"******************************"<<endl;
closesocket(sd2);
}
}

La y as plus qu'un socket , c juste pour tester.
La ca marche , en fait je peut transferer par exemple une image (qui pour l'instant est sur le disque local),
Mais le prob dans ie elle s'affiche très bien mais sous d'autre nav comme mozilla ou konqueror ca foire.
Qd ca sera le contenu renvoyer par le apache de l'autre machine (qd j aurais mis l'autre socket) ca marchera la?

Nico5779

bon voila g capter comment ca marchait ,c t pas nécessaire d'utiliser un fichier en fait , mais c qd meme ca qui ma mis sur la voie
Et les deux problèmes ci dessus se sont bien résolu d eux meme comme j esperait
c t tout con en fait...

Code :

#ifndef unix
#define WIN32
#include <windows.h>
#include <winsock.h>
#else
#define closesocket close
#include <sys/types.h>
#include <sys/socket.h>
#include <netinet/in.h>
#include <netdb.h>
#endif
#include <stdio.h>
#include <string.h>
#include <iostream.h>
#include <fstream.h>
#define SIZEOFBUFFER 2000
#define WEBPORT 2000
#define LOCALPORT 80
#define QLEN 6
extern int errno;
char localhost[] = "192.168.0.81";
char * filename ="d:/mod/test/Debug/tmp.dat";
int visits = 0;
void main ()
{
ofstream file (filename, ios::in|ios::binary|ios::ate);
int size=0;int j = 0;
struct hostent *ptrh_cli;
struct protoent *ptr_serveur,*ptrp_client;
struct sockaddr_in serveur,sad_cli,sad_serv;
int port_cli,sd_cli,n_cli,alen,port,sd,sd2,n,i = 0;
char buffer[SIZEOFBUFFER],buf_cli[SIZEOFBUFFER];
char *host_cli;
while (i < SIZEOFBUFFER)
{
buffer[i] = '*';
buf_cli[i] = '*';
i++;
}
#ifdef WIN32
WSADATA wsaData;
WSAStartup(0x0101 , &wsaData);
#endif
memset((char *)&sad_serv,0,sizeof(sad_serv));
sad_serv.sin_family = AF_INET;
sad_serv.sin_addr.s_addr = INADDR_ANY;
port = WEBPORT;
sad_serv.sin_port = htons((u_short) port);
if (((int)(ptr_serveur = getprotobyname("tcp" ))) ==0)
{
cerr<<"failed to get prtocol by name"<<endl;
exit(1);
}
sd = socket(PF_INET, SOCK_STREAM , ptr_serveur->p_proto);
if (sd < 0)
{
cerr<<"erreur while initializing socket"<<endl;
exit(1);
}
if (bind(sd,(struct sockaddr *)&sad_serv, sizeof(sad_serv))<0)
{
cerr<<"error while binding socket"<<endl;
exit(1);
}
if (listen(sd ,QLEN) >= 0)
{
cout<<"Listening port "<<port<<"..."<<endl;
}
else
{
cerr<<"failed to listen port "<<port<<" ..."<<endl;
exit(1);
}
memset((char *) &sad_cli,0,sizeof(sad_cli));
sad_cli.sin_family = AF_INET;
port_cli = LOCALPORT;
sad_cli.sin_port = htons ((u_short)port_cli);
host_cli = localhost;
ptrh_cli = gethostbyname(host_cli);
if (((char *)ptrh_cli) == NULL)
{
cerr<<"host unknown"<<host_cli<<endl;
exit(1);
}else
{
cout<<"attempting to reach "<<(char *)ptrh_cli->h_name<<" ..."<<endl;
}
memcpy(&sad_cli.sin_addr , ptrh_cli->h_addr,ptrh_cli->h_length);
if (((int)(ptrp_client = getprotobyname("tcp" ))) == 0)
{
cerr<<"failed to get prtocol by name"<<endl;
exit(1);
}
//listen(sd,QLEN);
while (1)
{
alen = sizeof(serveur);
if ((sd2=accept(sd,(struct sockaddr *)&serveur ,&alen))<0)
{
fprintf(stderr,"accept failed\n" );
exit(1);
}else
{
cout<<endl<<"conection id: "<<visits<<endl;
}
visits++;
i = 0;
sd_cli = socket(PF_INET, SOCK_STREAM, ptrp_client->p_proto);
if(sd_cli < 0)
{
cerr<<"erreur while initializing socket"<<endl;
exit(1);
}
if (connect(sd_cli,(struct sockaddr *)& sad_cli,sizeof(sad_cli)) >= 0)
{
cout<<"*** connected to "<<localhost<<" ***"<<endl;
}else
{
cerr<<"attempt to connect "<<localhost<<" failed ... aborting"<<endl;
exit(1);
}
n = recv(sd2,buffer,sizeof(buffer),0);
send (sd_cli,buffer,n,0);
n_cli=5000;
while (n_cli != 0 && n_cli != -1)//c t juste cette boucle ki fallait faire
{
n_cli = recv(sd_cli,buf_cli,sizeof(buf_cli),0);
//file.write(buf_cli,n_cli);
if (n_cli != 0)
send (sd2,buf_cli,n_cli,0);
cout<<n_cli<<"bytes transfered"<<endl;
}
closesocket(sd_cli);
//file.close();
cout<<endl<<"******************************"<<endl;
}
closesocket(sd2);
}

Mais y reste encore un prob c que c très (trop) lent...
Entre chaque requete transmise puis retransmise y as des long moment ou y fout rien ...Et je vois pas ou est le prob
Si par exemple j'arriverait a faire le meme algo mais en me connectant qu'une seule fois a l autre machine (192.168.0.81)
j'y gagnerait bcp?
Si qqn peut encore m'aider ca serait super :jap:

Message édité par Nico5779 le 27-02-2003 à 23:59:19

western

AJMM

Amigo, soit tu fais du C (memcpy) soit du C++(cout) ... Il ne faut pas melanger les choses car cela est une très mauvaise pratique (pas de troll, svp)
Pour tes problèmes, plutard peut-être car là
1) je ne suis pas reveillé (une mauvaise nuit);
2) j'ai très mal à la gorge, à la tête (une mauvaise nuit) et pour courronner le tout un nez qui n'arrete pas de couler ...

Nico5779

je suis d'accord avec toi en ce qui concerne les normes , mais c le genre de detail que je regle qd ca marche.
Or la ... :sweat:
Sinon jte souhaite un bon retablissement
Les autres, si vous avez des remarques qui pourrait m'aider ne vous genez pas

Nico5779

bon je crois que j'ai trouver ,le prob venait quand y recevait le dernier paquet de taille zero,
Mais g encore des probs
Je voulait utiliser le flag MSG_EOR
Mais visual me sort qu'il le connait pas.

edit: le prob avec gcc est resolu mais pas l'autre...
redit: nan en fait c MSG_WAITALL le bon flag mais c pareil visual me sort tj qu'il le connait pas...

Message édité par Nico5779 le 02-03-2003 à 18:51:10

FORUM HardWare.fr

Programmation

C++

problème taille de buffer /socket

Sujets relatifs
[SQL ACCESS] problème de syntaxe avec les JOIN	Problème SQL sous Oracle
XSL + Javascript -> probleme :(	Problème en VBA pour remplir une case ! ! ! !
[CSS/HTML] Ya moyen de changer la taille de la scrollbar ???	[NASM] problème pour utiliser le port 378h (parallele) sous XP ...
[DBGrid] Taille du déplacement horizontal ?	Apache et Tomcat : problème de session ?
[C++] tronquer un fichier à une certaine taille	Problème de Parse Error que j'arrive pas a résoudre...
Plus de sujets relatifs à : problème taille de buffer /socket

Page générée en 0.107 secondes