[C/Socket]Programmer un proxy

Recherche :

Mot : Pseudo : Filtrer
Bas de page
Auteur	Sujet : [C/Socket]Programmer un proxy

psyphi

Salut all, je cherche de la doc sur comment programmez un proxy minimal sans cache ou autre fioriture.
J'ai bien une idée, ouvrir deux sockets en parallèle (multithreading) de cette façon mais je ne suis pas du tout sur:
client -> socket 1 -> serveur
client <- socket 2 <- serveur

Donc avant de me lancer dans l'inconnu je vous demande de l'aide: des sources courtes ou des tutos.
merci :jap:

Publicité

nargy

c'est un poil plus compliqué: il faut que tu lise la requête HTTP, et que tu envoye cette requête au serveur désignée dans la requête. Une fois la connexion effectuée tu lit les données reçues pour les transmettre au navigateur (socket en lecture/écriture, donc).
Le shemas ressemble plus à ça:
client <---> proxy <----> serveur

Note que certaines options dans les entêtes sont utiles (genre connexion:close), et que tu doit aussi envoyer les cookies, les formulaires et les fichiers joints.

psyphi

Pourquoi est ce qu'il est nécessaire de lire l'entête http?
Dans le cas d'utilisation d'un proxy l'adresse ip de destination est celle du proxy ou celle du site web?
L'entête est directement envoyé par le navigateur j'aurai pensé que le proxy l'envoyais directement sans traitement vers le site web.
Autre question: suivant ton schéma comment faire pour traiter en parallèle les envois et les réponses, je pense que je suis obligé d'utiliser les threads non?
Merci de ton aide (PS: si t'as des sources je suis preneur)

Zipo

Ours bipolaire

tiens j'avais fais un proxy smtp si ça peut t'aider, ya le source en C et le rapport ici :
http://kaiserzipo.free.fr/web/.dir [...] eseau&3=TP

et effectivement tu utilises plusieurs threads

Message édité par Zipo le 09-04-2006 à 18:15:50

---------------
- mon feed-back

nargy

Citation :

Au niveau TCP, le navigateur envoye la requête au proxy, et non pas au serveur. C'est au proxy de prendre en charge la requête, et donc pour contacter le serveur il devra lire l'entête. Certaines options sur les sockets peuvent être fixées par le navigateur ou le serveur: par exemple les temps d'attente maximums. Le proxy devra en tenir compte. Je ne peut pas te donner une liste exhaustive des options d'entête qu'il te faudra traiter, mais tu trouvera plein de doc sur le web.

Citation :

Autre question: suivant ton schéma comment faire pour traiter en parallèle les envois et les réponses, je pense que je suis obligé d'utiliser les threads non?

Tout à fait, la structure principale d'une proxy est la même que celle d'un serveur web!

Citation :

Merci de ton aide (PS: si t'as des sources je suis preneur)

Il y a plein de proxys en open source, une petite recherche sur le net et tu trouvera ton bonheur. Même si souvent ces proxys tournent sur Unix, tu peut les adapter pour Windows.

La meilleure source que tu puisse avoir c'est celle du serveur Apache sur apache.org!

Bon courage

(rem: c'est pas si dur, mais c'est long, j'avais fait un serveur web compatible HTTP/1.1, j'y avais intégré la plupart des gestion d'entêtes, mais il m'a fallu 6 mois)

psyphi

J'ai bien essayé de regarder des logiciels open, j'ai télécharger les sources de squid mais bon faut avoir un certain niveau, je maitrise bien le C/C++ et d'autre langage mais lire un tel projet c'est chaud.

nargy

Entraîne toi sur le forum, debugger les programmes des autres c'est pas toujours évident.

psyphi

J'ai une petite idée d'algo, qu'en pensez vous? :

Code :

Creer un nouveau thread à chaque nouvelle connexion
recevoir paquet
Analyser l'header http
sortir le host
envoyer le paquet vers host
attendre réponse
renvoyer la réponse au client

nargy

C'est un bon début.

psyphi

J'ai créer un bou de code qui fonctionne a peu près, mais il y a beaucoup de bugs que je ne comprend, les connexions foires au bout d'un moment et j'ai beaucoup de bug d'affichage à croire que tout le code des pages web n'est pas transmit.
Si des âmes charitables veulent bien le tester :jap: :
Pour configurer, dans firefox: paramètre de connexion -> proxy 127.0.0.1 port 3080
adresse pour télécharger directement: http://membres.lycos.fr/bobov/code/main.c
ou ici:

Code :

#include <stdio.h>
#include <stdlib.h>
#include <string.h>
#include <windows.h>
#include <winsock2.h>
#pragma comment(lib, "ws2_32.lib" )
/**************
* prototypes *
**************/
char * get_host(char * httpRequest);
int proxy(SOCKET socket_client);
/*************
* functions *
*************/
/*
* get_host()
* fonction qui isole le header http (Host:)
*/
char * get_host(char * httpRequest){
unsigned short i = 0, j = 0;
char * buffer = strstr(httpRequest, "Host: " );
char * host = (char *)malloc(256 * sizeof(char));
while( buffer[i] != '\n' )
i++;
for(j = 6; j < i-1; j++)
host[j - 6] = buffer[j];
host[j-6+1] = '\0';
return host;
}
/*
* proxy()
*/
int proxy(SOCKET socket_client){
SOCKET envoi;
SOCKADDR_IN server2;
struct hostent * structHost;
char buffer[1024];
char buffer2[1024*1024]; // 1 ko
memset(buffer,'\0',sizeof(buffer));
// On recoit la requete du navigateur
int size = recv(socket_client, buffer, sizeof(buffer), 0);
printf("size : %d \r\n", size);
fprintf(stdout, "----\r\n%s----\r\n", buffer);
// On récupère le header (Host:) de la requete
// pour pouvoir se connecter au serveur web
char * host = get_host(buffer);
printf("Host : [%s]\r\n", get_host(buffer));
// On envoie la requete au serveur web
// grace a un nouveau socket
if((structHost = gethostbyname(host)) == NULL){
fprintf(stderr,"Host error\n" );
}
if((envoi = socket(AF_INET, SOCK_STREAM, 0)) == -1){
printf("socket error\r\n" );
}
server2.sin_family = AF_INET;
server2.sin_port = htons(80);
server2.sin_addr = *((struct in_addr *)structHost->h_addr);
memset(&(server2.sin_zero),'\0',8);
if( connect(envoi,(struct sockaddr * )&server2,sizeof(struct sockaddr)) == -1){
printf("error connect\r\n" );
return -1;
}
send(envoi, buffer, strlen(buffer), 0);
memset(buffer2,'\0',sizeof(buffer2));
// Reception des donnees a partir du serveur
// et les renvoies au navigateur
while( (size = recv(envoi,buffer2,sizeof(buffer2),0)) != 0){
buffer2[size] = '\0';
fprintf(stdout, "%s", buffer2);
// Renvoie de la réponse au navigateur
send(socket_client, buffer2,strlen(buffer2),0);
memset(buffer2,'\0',sizeof(buffer2));
}
//Nettoyage
closesocket(socket_client);
WSACleanup();
ExitThread(0);
return 0;
}
/**********
* main() *
**********/
int main(int argc, char * argv[]){
// Initialisation
WSADATA WSAData;
WSAStartup(MAKEWORD(2,0), &WSAData);
// Variables
SOCKET socket_local;
SOCKET socket_client;
SOCKADDR_IN server;
SOCKADDR_IN client;
DWORD dwThreadID;
int sin_size = sizeof(SOCKADDR_IN);
socket_local = socket(AF_INET,SOCK_STREAM,0);
// Configuration du proxy (port 3080)
server.sin_family = AF_INET;
server.sin_port = htons(3080);
server.sin_addr.s_addr = INADDR_ANY;
memset(&(server.sin_zero),'\0',8);
bind(socket_local,(struct sockaddr * )&server,sizeof(struct sockaddr));
listen(socket_local,5);
// Attente de connexion
while(1)
{
if( (socket_client = accept(socket_local,(struct sockaddr * )&client,&sin_size)) == -1)
{
fprintf(stderr, "Accept error.Error: %d\n", WSAGetLastError());
closesocket(socket_client);
WSACleanup();
return 1;
}
else
{
fprintf(stdout,"Connection de : %s \n",inet_ntoa(client.sin_addr));
// On cree un thread par nouvelle connexion en
// appelant la fonction proxy avec comme paramètre le socket client
CreateThread( NULL,
0,
(LPTHREAD_START_ROUTINE) proxy,
socket_client,
0,
&dwThreadID);
}
}
return 0;
}
}

Edit: commentaires sur le code ajouté.

Message édité par psyphi le 14-04-2006 à 15:31:49

Publicité

Zipo

Ours bipolaire

on sent que tu aimes commenter ton code toi

Message cité 1 fois
Message édité par Zipo le 12-04-2006 à 22:40:45

---------------
- mon feed-back

psyphi

:sweat: C'est vrai que je ne l'ai pas super commenté, généralement je commente mon code quand je sais que j'aurai des problèmes en le relisant mais la le principe est connu donc j'ai pas beaucoup commenté. Mais je vais corriger ca par la suite.

Emmanuel Delahaye

C is a sharp tool

Zipo a écrit :

on sent que tu aimes commenter ton code toi

Il y a le minimum vital... Si on connait le sujet, il n'y pas trop de mystères...

---------------
Des infos sur la programmation et le langage C: http://www.bien-programmer.fr Pas de Wi-Fi à la maison : http://www.cpl-france.org/

psyphi

Voila j'ai édité mon message précédent et commenté mon code

psyphi

J'ai fait une mise à jour du code proper et commenté cette fois ci, mais mon proxy ne fonctionne pas avec les images, qqun peut il m'aider?
Lien direct vers le .c : http://membres.lycos.fr/bobov/code/main.c
(Configuration du navigateur: 127.0.0.1:8080)

Code :

#include <stdio.h>
#include <stdlib.h>
#include <string.h>
#include <windows.h>
#include <winsock2.h>
#pragma comment(lib, "ws2_32.lib" )
/**************
* prototypes *
**************/
void display_error(char * errorType);
char * get_host(char * httpRequest);
int proxy(SOCKET socket_client);
/*************
* functions *
*************/
/*
* display_error()
*/
void display_error(char * errorType){
LPVOID lpMsgBuf;
FormatMessage( FORMAT_MESSAGE_ALLOCATE_BUFFER | FORMAT_MESSAGE_FROM_SYSTEM,
NULL,
GetLastError(),
MAKELANGID(LANG_NEUTRAL, SUBLANG_DEFAULT),
(LPTSTR) &lpMsgBuf,
0,
NULL);
// Affichage du message dans une boite de dialogue
MessageBox( NULL, lpMsgBuf, errorType, MB_OK | MB_ICONERROR );
// Libération du buffer
LocalFree( lpMsgBuf );
}
/*
* get_host()
* fonction qui isole le header http (Host:)
*/
char * get_host(char * httpRequest){
unsigned short i = 0, j = 0;
char * buffer = strstr(httpRequest, "Host: " );
char * host = (char *)malloc(256 * sizeof(char));
memset(host, '\0', sizeof(host));
while( buffer[i] != '\n' )
i++;
for(j = 6; j < i-1; j++)
host[j - 6] = buffer[j];
host[j-6+1] = '\0';
return host;
}
/*
* proxy()
*/
int proxy(SOCKET socket_client){
SOCKET envoi;
SOCKADDR_IN server2;
struct hostent * structHost;
char buffer[1024*10]; // 10 ko
char buffer2[1024*50]; // 50 ko
memset(buffer,'\0', sizeof(buffer));
memset(buffer2,'\0', sizeof(buffer));
// On recoit la requete du navigateur
int size = recv(socket_client, buffer, sizeof(buffer), 0);
fprintf(stdout, "----Commande recue ----\r\n%s----\r\n", buffer);
// On récupère le header (Host:) de la requete
// pour pouvoir se connecter au serveur web
char * host = get_host(buffer);
//fprintf(stdout,"Host : [%s]\r\n", get_host(buffer));
// On envoie la requete au serveur web
// grace a un nouveau socket
if((structHost = gethostbyname(host)) == NULL){
fprintf(stderr,"Host error\r\n" );
display_error("Host error !" );
return -1;
}
if((envoi = socket(AF_INET, SOCK_STREAM, 0)) == INVALID_SOCKET){
fprintf(stderr, "Socket error. Error: %d\r\n", WSAGetLastError());
display_error("Socket error !" );
return -1;
}
server2.sin_family = AF_INET;
server2.sin_port = htons(80);
server2.sin_addr = *((struct in_addr *)structHost->h_addr);
memset(&(server2.sin_zero),'\0',8);
if( connect(envoi,(struct sockaddr * )&server2,sizeof(struct sockaddr)) == -1){
fprintf(stderr,"Error connect\r\n" );
display_error("Connect Error !" );
return -1;
}
send(envoi, buffer, strlen(buffer), 0);
// Reception des donnees a partir du serveur
// et les renvoies au navigateur
while( (size = recv(envoi,buffer2,sizeof(buffer2),0)) != 0){
buffer2[size] = '\0';
//fprintf(stdout, "%s", buffer2);
// Renvoie de la réponse au navigateur
send(socket_client, buffer2,strlen(buffer2),0);
memset(buffer2,'\0',sizeof(buffer2));
}
//Nettoyage
closesocket(socket_client);
fprintf(stdout, "Exiting Thread.\r\n" );
ExitThread(0);
return 0;
}
/**********
* main() *
**********/
int main(int argc, char * argv[]){
// Initialisation
WSADATA WSAData;
if( WSAStartup(MAKEWORD(2,0),&WSAData) != 0 )
{
fprintf(stderr, "WSAStartup error. Error: %d\r\n", WSAGetLastError());
display_error("WSAStartup error !" );
return 1;
}
// Variables
SOCKET socket_local;
SOCKET socket_client;
SOCKADDR_IN server;
SOCKADDR_IN client;
DWORD dwThreadID;
int sin_size = sizeof(SOCKADDR_IN);
if( (socket_local = socket(AF_INET,SOCK_STREAM,0) ) == INVALID_SOCKET )
{
fprintf(stderr, "Socket error. Error: %d\r\n", WSAGetLastError());
display_error("Socket error !" );
WSACleanup();
return 1;
}
// Configuration du proxy (port 8080)
server.sin_family = AF_INET;
server.sin_port = htons(8080);
server.sin_addr.s_addr = INADDR_ANY;
memset(&(server.sin_zero),'\0',8);
if( bind(socket_local,(struct sockaddr * )&server,sizeof(struct sockaddr)) == SOCKET_ERROR)
{
fprintf(stderr, "Bind error. Error: %d\r\n", WSAGetLastError());
display_error("Bind error !" );
closesocket(socket_client);
WSACleanup();
return 1;
}
listen(socket_local, SOMAXCONN);
// Attente de connexion, si erreur on quitte le programme
while(1)
{
if( (socket_client = accept(socket_local,(struct sockaddr * )&client,&sin_size)) == INVALID_SOCKET )
{
fprintf(stderr, "Accept error.Error: %d\r\n", WSAGetLastError());
display_error("Accept error !" );
closesocket(socket_client);
WSACleanup();
return 1;
}
else
{
fprintf(stdout,"Connection de : %s \n",inet_ntoa(client.sin_addr));
// On cree un thread par nouvelle connexion en
// appelant la fonction proxy avec comme paramètre le socket client
// Si erreur a la creation d un thread on quitte
if( CreateThread( NULL,
0,
(LPTHREAD_START_ROUTINE) proxy,
socket_client,
0,
&dwThreadID) == NULL )
{
fprintf(stderr, "CreateThread error.\r\n" );
display_error("CreateThread error !" );
return 1;
}
}
}
return 0;
}

Merci d'avance

nargy

oui! parceque les navigateurs moderne ne demandent pas l'image en entier. Ils en font la demande au serveur bout par bout, selon l'affichage necessaire. Par exemple, si l'internaute va directement au bas de la page, le téléchargement des images du haut de la page est interrompu après le bout courant et sera repris en dernier.

La demande partiel est, il me semble le ~~code HTTP 304~~. Tu doit le traiter spécialement.

Comme quoi, je t'avais dit, c'est pas aussi évident... Mais tu es sur la bonne voie.

Message édité par nargy le 18-04-2006 à 15:24:17

nargy

heu non, c'est pas le code 304. là je me souviens plus. tu devrais le trouver sur le web.

Message édité par nargy le 18-04-2006 à 15:24:42

psyphi

:sweat: :cry: ouin je pensais pas que c'était si dur que ça.
En tout cas heureusement que tu me dis ça car j'en pouvais de chercher sans comprendre, je pensais que ca venait de mon code.
Ou est ce que je vais trouver ce code spécifique dans les RFC ?

nargy

> Ou est ce que je vais trouver ce code spécifique dans les RFC ?
- heu je l'avais trouvé, j'ai un poil la flemme de rechercher là. pourtant je l'ai presque sous les yeux, dans mes logs c'est affiché quelquepart. si, si, je t'assure :lol:
- indice: fait un debug de l'entête totale envoyée par le navigateur au proxy (jusqu'au double \n\n)

nargy

ha tiens: 206 Partial Content

nargy

zieute un coup ici:
http://www.w3.org/Protocols/rfc2616/rfc2616-sec10.html

psyphi

C'est quand même bizarre cette histoire je viens de trouver une autre source de proxy (enfin ! lol) et il ne gère nul part le 206 Partial Content et pourtant quand j'utilise son proxy avec la dernière version de firefox les images s'affichent.
source: http://www.cppfrance.com/code.aspx?ID=10846
Est ce que cela peut venir de mes threads?

psyphi

Effectivement je reviens de faire un test, en utilisant un buffer de 1 octets (char) au lieu de 1ko (char buffer2[1024]) pour la reception des données du serveur et cette fois les images s'affiches :-|.
C'est quand même bizarre ca. Faut que je trouve une solution car des buffers de 1octets pour le transfert c'est pas cool.

Message édité par psyphi le 18-04-2006 à 17:31:18

nargy

http://www.w3.org/Protocols/rfc261 [...] l#sec14.10

psyphi

J'ai fait une grosse mise à jour du code, finis les gros plantage!
Problème restant, navigation lente sur certain site, impossible de naviger sur certain site, le logiciel freeze par moment, il reste coincé dans la boucle de download. :sweat:
Tout est ici: http://www.cppfrance.com/codes/WIN [...] 37134.aspx
la source:

Code :

#include <stdio.h>
#include <stdlib.h>
#include <string.h>
#include <windows.h>
#include <winsock2.h>
#pragma comment(lib, "ws2_32.lib" )
/**************
* prototypes *
**************/
void display_error(char * errorType);
char * get_host(char * httpRequest);
void cut_host_and_port(char * host, char * port);
char * get_port(char * port);
DWORD WINAPI proxy (LPVOID psocket);
/*************
* functions *
*************/
/*
* display_error()
* donne la raison de l'erreur sert au debugage
*/
void display_error(char * errorType){
LPVOID lpMsgBuf;
FormatMessage( FORMAT_MESSAGE_ALLOCATE_BUFFER | FORMAT_MESSAGE_FROM_SYSTEM,
NULL,
GetLastError(),
MAKELANGID(LANG_NEUTRAL, SUBLANG_DEFAULT),
(LPTSTR) &lpMsgBuf,
0,
NULL);
// Affichage du message dans une boite de dialogue
MessageBox( NULL, lpMsgBuf, errorType, MB_OK | MB_ICONERROR );
// Libération du buffer
LocalFree( lpMsgBuf );
}
/*
* get_host()
* fonction qui isole le header http host qui suit le "Host:"
*/
char * get_host(char * httpRequest){
unsigned short i = 0, j = 0;
char * buffer = (char *)malloc(2*1024 * sizeof(char));
if( !(buffer = strstr(httpRequest, "Host: " )) ){
fprintf(stderr, "Can\'t find host in this request !\r\n" );
return "error";
}
else{
char * host = (char *)malloc(256 * sizeof(char));
while( buffer[i] != '\n' )
i++;
for(j = 6; j < i-1; j++)
host[j - 6] = buffer[j];
host[j-6+1] = '\0';
return host;
}
}
/*
* cut_host_and_port
* separe le host de son port
*/
void cut_host_and_port(char * host, char * port){
unsigned short i = 0;
unsigned short y = 0;
unsigned short size = strlen(host);
while(host[i] != ':')
i++;
host[i] = '\0';
i++;
for(y = 0; y < 5, i < size; i++, y++)
port[y] = host[i];
}
/*
* proxy()
*/
DWORD WINAPI proxy (LPVOID psocket){
//Recuperation de la valeur du socket
SOCKET * ps = psocket;
SOCKET socket_client = *ps;
//On a la valeur de la socket, on peut désallouer
free(psocket);
SOCKET envoi;
SOCKADDR_IN server2;
struct hostent * structHost;
char buffer[1024*2]; // 2 ko
char buffer2[1024*4]; // 4 ko
memset(buffer,'\0', sizeof(buffer));
memset(buffer2,'\0', sizeof(buffer2));
// On recoit la requete du navigateur
int size = recv(socket_client, buffer, sizeof(buffer), 0);
fprintf(stdout, "----Commande recue ----\r\n%s----\r\n", buffer);
// On récupère le header (Host:) de la requete
// pour pouvoir se connecter au serveur web
char * host = get_host(buffer);
// Parfois host a la forme (Host: adresse:port
// donc on creer une variable port pour récupérer ce dernier
char * port = (char *)malloc(5 * sizeof(char));
if( !strncmp(host, "error", 5) ){
fprintf(stderr, "get_host return error.\r\n" );
closesocket(socket_client);
//ExitThread(0);
return 1;
}
else if( strchr(host,':')){
cut_host_and_port(host, port);
}
else{
port = "80";
}
fprintf(stdout,"Host : [%s], port : [%s]\r\n", host, port);
// On envoie la requete au serveur web
// grace a un nouveau socket
if((structHost = gethostbyname(host)) == NULL){
fprintf(stderr,"Host error. Can't find %s\r\n", host);
closesocket(socket_client);
//ExitThread(0);
return 1;
}
if((envoi = socket(AF_INET, SOCK_STREAM, 0)) == INVALID_SOCKET){
fprintf(stderr, "Socket error. Error: %d\r\n", WSAGetLastError());
closesocket(socket_client);
display_error("Socket error !" );
//ExitThread(0);
return 1;
}
server2.sin_family = AF_INET;
server2.sin_port = htons(atoi(port));
server2.sin_addr = *((struct in_addr *)structHost->h_addr);
memset(&(server2.sin_zero),'\0',8);
if( connect(envoi,(struct sockaddr * )&server2, sizeof(struct sockaddr)) == -1){
fprintf(stderr,"Error connect\r\n" );
closesocket(socket_client);
closesocket(envoi);
//display_error("Connect Error !" );
//ExitThread(0);
return 1;
}
send(envoi, buffer, strlen(buffer), 0);
// Reception des donnees a partir du serveur
// et les renvoies au navigateur
while( (size = recv(envoi, buffer2, sizeof(buffer2),0)) > 0){
//fprintf(stdout, "---buffer----\r\n%s\r\n----", buffer2);
// Renvoie de la réponse au navigateur
buffer2[size]='\0';
send(socket_client, buffer2, size, 0);
}
//Nettoyage
closesocket(socket_client);
closesocket(envoi);
fprintf(stdout, "Exiting Thread.\r\n" );
//ExitThread(0);
return 0;
}
/**********
* main() *
**********/
int main(int argc, char * argv[]){
// Initialisation
WSADATA WSAData;
if( WSAStartup(MAKEWORD(2,0),&WSAData) != 0 )
{
fprintf(stderr, "WSAStartup error. Error: %d\r\n", WSAGetLastError());
display_error("WSAStartup error !" );
return 1;
}
// Variables
SOCKET socket_local;
SOCKET socket_client;
SOCKADDR_IN server;
SOCKADDR_IN client;
DWORD dwThreadID;
int * paramThread = malloc(sizeof dwThreadID);
if(paramThread == NULL){
display_error("Thread error !" );
return EXIT_FAILURE;
}
int sin_size = sizeof(SOCKADDR_IN);
if( (socket_local = socket(AF_INET,SOCK_STREAM,0) ) == INVALID_SOCKET )
{
fprintf(stderr, "Socket error. Error: %d\r\n", WSAGetLastError());
display_error("Socket error !" );
WSACleanup();
return 1;
}
// Configuration du proxy (port 8080)
server.sin_family = AF_INET;
server.sin_port = htons(8080);
server.sin_addr.s_addr = INADDR_ANY;
memset(&(server.sin_zero), '\0', 8);
if( bind(socket_local,(struct sockaddr * )&server,sizeof(struct sockaddr)) == SOCKET_ERROR)
{
fprintf(stderr, "Bind error. Error: %d\r\n", WSAGetLastError());
display_error("Bind error !" );
closesocket(socket_client);
WSACleanup();
return 1;
}
listen(socket_local, SOMAXCONN);
// Attente de connexion, si erreur on quitte le programme
while(1)
{
if( (socket_client = accept(socket_local,(struct sockaddr * )&client,&sin_size)) == INVALID_SOCKET )
{
fprintf(stderr, "Accept error.Error: %d\r\n", WSAGetLastError());
display_error("Accept error !" );
closesocket(socket_client);
WSACleanup();
return 1;
}
else
{
fprintf(stdout,"Connection de : %s \n",inet_ntoa(client.sin_addr));
// On cree un thread par nouvelle connexion en
// appelant la fonction proxy avec comme paramètre le socket client
// Si erreur a la creation d un thread on quitte
*paramThread = socket_client;
if( CreateThread( NULL,
0,
(LPTHREAD_START_ROUTINE) proxy,
paramThread,
0,
&dwThreadID) == NULL )
{
fprintf(stderr, "CreateThread error.\r\n" );
display_error("CreateThread error !" );
return 1;
}
//proxy(paramThread );
}
}
return 0;
}

Merci de ton aide nargy

nargy

ouais le code est un peu gros, et en plus c'est du windoz. je peut pas tester là, et c'est balaise avec autant de code de compiler de tête.
je te conseillerai bien de rajouter du débug à fond, histoire de cibler le problème.

nargy

pour le freeze, tu doit avoir un problème de communication thread.

psyphi

J'ai un nouveau problème, encore un :fou: . Depuis que j'ai rajouté mes fonctions de parse de requete HTTP, le nombre de site qui fonctionne est bien meilleur qu'auparavant et je n'ai plus de freeze mais par contre le multithreading plante !!
J'ai des erreurs du type:
Citation:
0x0040155f emploie l'adresse mémoire 0x0014a0000. La mémoire ne peut pas être "read".
Quelqu'un saurait me dire de quoi cela peut provenir.

PS: si vous voulez une source fonctionnel commenté CreateThread et décommenté la ligne du dessous.

PS2: la source devenant trop longue je ne vais pas poluer le forum, elle est ici:
http://membres.lycos.fr/bobov/code/main.c

PS3: Merci nargy pour ton aide jusque ici.

tholdan

Il plante à sur l'index du forum chez moi.

----Accept: []
Cookie: []
Host: []
----
Can't find host in this request !
get_host return error.
Exiting Thread Normaly.

C:\dev\C>

Pour les dernières lignes

---------------
Ph'nglui mglw'nafh Cthulhu R'lyeh wgah'nagl fhtagn

nargy

> 0x0040155f emploie l'adresse mémoire 0x0014a0000. La mémoire ne peut pas être "read".

- indique que tu as un pointeur qui se balade dans le vide. il te faut un débuggeur, qui te dira à quelle ligne de ton programme tu accède à un pointeur qui n'a pas été initialisé, ou utilisé après avoir été libéré. Sans débuggeur, tu peut trouver mais moins facilement en ajoutant des printf de débug à chaque fonctions puis chaque ligne.

Message cité 1 fois

nargy

oui, les entêtes n'ont pas d'ordre

tholdan

nargy a écrit :

Code :

C:\\dev\\C\\proxy2.c:317: warning: 'socket_client' might be used uninitialized in this function

Si ça peut aider.

Message édité par tholdan le 23-04-2006 à 01:03:45

---------------
Ph'nglui mglw'nafh Cthulhu R'lyeh wgah'nagl fhtagn

psyphi

Le problème des erreurs de read provennait de l'espace mémoire des threads qui était mal initialisé à chaque nouveau thread.
Normalment c'est corrigé.
Tholdan t'a compilé avec quoi, j'ai pas ce warning la moi :?.
Sinon j'ai pas de plantage à l'index du forum, j'en ai pour les requetes POST par contre. C'est quoi ton navigateur?

Message cité 1 fois

tholdan

psyphi a écrit :

GCC -Wall
Et firefox 1.5 comme navigateur.

Message édité par tholdan le 23-04-2006 à 01:50:17

---------------
Ph'nglui mglw'nafh Cthulhu R'lyeh wgah'nagl fhtagn

psyphi

Pour ceux que ça interesse j'ai fait une mise à jour du code avec l'implémentation de la requete POST.
http://www.cppfrance.com/code.aspx?ID=37134
En fait maintenant j'aimerais bien avoir le retour d'utilisateur

Publicité

FORUM HardWare.fr

Programmation

[C/Socket]Programmer un proxy

Sujets relatifs
QQ1 peut il m'aider à propos de socket non bloquant je n'y connais rie	Comment programmer une interruption matérielle???
programmer logiciel en BASIC	novice en programmation doit programmer sous unix.
rmi zip socket	Forcer authentification au proxy
[C] select avec les socket	Emulation socket
quel soft utiliser pour creer un site web sans savoir programmer??	Java Socket & Crontab
Plus de sujets relatifs à : [C/Socket]Programmer un proxy

Page générée en 0.266 secondes