programme serveur multitâches

Marsh Posté le 15-06-2006 à 16:15:08

Bonjour,
Quelqu'un aurait il un programme pour rendre un serveur multitâches?
Merci

Reply

Marsh Posté le 15-06-2006 à 16:15:08

Reply

Marsh Posté le 15-06-2006 à 16:35:47

cette phrase ne veut rien dire, c'est normal, c'est la ...

Reply

Marsh Posté le 15-06-2006 à 16:38:01

Voici ce que je voudrais que le programme fasse par exemple:
Boucle infinie
La connexion est toujours acceptée sur le port X
On lance un nouveau programme serveur par le biais de fork()
Si lon est dans le programme serveur fils (i-e fork() a retourné 0)
Alors
On ferme le socket qui était en attente de connexion
On ouvre la connexion en direction du vrai serveur
Boucle infinie
On attend une trame du vrai client
Si erreur de lecture
On fait un exit(0) pour terminer.
On la transmet à lautre serveur
Si erreur décriture
On fait un exit(0) pour terminer.

Reply

Marsh Posté le 15-06-2006 à 20:26:18

bah tu comme tu l'as écrit toi même, tu forkes.... il est ou le probleme ?

Reply

Marsh Posté le 16-06-2006 à 10:09:24

et si je veux utiliser des threads?
Merci

Reply

Marsh Posté le 16-06-2006 à 10:19:49

ben ... essaye ?

Reply

Marsh Posté le 16-06-2006 à 11:15:47

Tu n'as pas de piste à me donner?
Merci

Reply

Marsh Posté le 16-06-2006 à 11:17:28

Ben t'as une idée de ton algo ... je vois pas ce qu'il te faut de plus, à part s'y mettre .

Message cité 1 fois

Reply

Marsh Posté le 16-06-2006 à 15:08:24

_darkalt3_ a écrit :

Ben t'as une idée de ton algo ... je vois pas ce qu'il te faut de plus, à part s'y mettre .

Voici mon algo et l'erreur à la compilation:

Code :

#include "ServerSocket.h"
#include "SocketException.h"
#include <string>
#include <mysql/mysql.h>
#include <stdio.h>
#include <stdlib.h>
#include <time.h>
#include <pthread.h>
#include <unistd.h>
#define MYSQL_HOST "localhost"
#define MYSQL_DB "cmm_produits"
#define MYSQL_LOGIN "cmmuser"
#define MYSQL_PASSWD "voltair"
#define mysql_connect(m, h, u, p) mysql_real_connect((m), (h), (u), (p), NULL, 0, NULL, 0)
class GestionServer
{
public:
MYSQL mysql; /* Vers la connexion de la base*/
int StartDataBaseConnection();
void StopDataBaseConnection();
//void Tsrv_memoireAdd(char *arg);
//void Tsrv_iaxAdd(char *arg);
};
//struct tm {
// int tm_sec; /* Secondes */
// int tm_min; /* Minutes */
// int tm_hour; /* Heures (0 - 23) */
// int tm_mday; /* Quantième du mois (1 - 31) */
// int tm_mon; /* Mois (0 - 11) */
// int tm_year; /* An (année calendaire - 1900) */
// int tm_wday; /* Jour de semaine (0 - 6 Dimanche = 0) */
// int tm_yday; /* Jour dans l'année (0 - 365) */
// int tm_isdst; /* 1 si "daylight saving time" */
//};
/* ****************************************************************
* Nom :StartDataBaseConnection *
* But :lancer une connection avec une base de donnée *
**************************************************************** */
int GestionServer::StartDataBaseConnection()
{
mysql_init(&mysql);
/* Se connecter a la base*/
if (!mysql_connect(&mysql,MYSQL_HOST,MYSQL_LOGIN,MYSQL_PASSWD))
{
printf ("Probleme de connection a la BDD\n" );
return -1;
}
if (mysql_select_db(&mysql,MYSQL_DB))
{
printf ("Ne peut pas sectionner la BASE\n" );
mysql_close(&mysql);
return -1;
}
return 0;
}
/* ****************************************************************
* Nom :StopDataBaseConnection *
* But : Arreter la connection avec la base de donnée *
**************************************************************** */
void GestionServer::StopDataBaseConnection()
{
mysql_close(&mysql);
}
/* ****************************************************************
* Nom :TableTsrv_memoireAdd *
* But :Ajouter les donnees dans la Table Tsrv_memoire *
**************************************************************** */
void* Tsrv_memoireAdd(char *arg, MYSQL mysql)
{
char *prt;
char valeur[600],valeur1[40],sqlrequest1[450];
char val1[20],val2[20], val3[20], val6[20], val5[20],val7[20],val8[20],val9[20],val10[20],val11[20],val13[20],val14[20],mac[20];
int val12, val4,val22,val32,val52,val62,val72;
static pthread_mutex_t mutex;
prt = strtok(arg, "#" );
strcpy(mac,prt);
printf("%s\n",mac);
prt = strtok(NULL, "#" );
strcpy(valeur, prt);
printf("%s\n",valeur);
if (strcmp(valeur,"memoire" )==0)
{
prt = strtok(NULL,"#" );
while (prt!=NULL)
{
pthread_mutex_lock(&mutex);
strcpy(valeur,prt);
sscanf(valeur,"%s %s %s %s %s %s", val1,val2,val3,val5,val6,val7);
val12 = atoi(val1);
val22 = atoi(val2);
val32 = atoi(val3);
val52 = atoi(val5);
val62 = atoi(val6);
val72 = atoi(val7);
sprintf(sqlrequest1,"INSERT INTO Tsrv_Memoire (Mac,MemTotal,MemLibr,MemActive,MemInactive,SwapLibr,SwapTotal,Heure) VALUES ('%s','%d','%d','%d','%d','%d','%d',now())",mac,val12,val22,val32,val52,val62,val72);
mysql_query(&mysql,sqlrequest1);
prt = strtok(NULL,"#" );
pthread_mutex_unlock(&mutex);
sleep(1);
}
pthread_exit(0);
}
}
void* Tsrv_iaxAdd(char *arg, MYSQL mysql)
{
char *prt;
char valeur[600],valeur1[40],sqlrequest1[450];
char val1[20],val2[20], val3[20], val6[20], val5[20],val7[20],val8[20],val9[20],val10[20],val11[20],val13[20],val14[20],mac[20];
int val12, val4,val22,val32,val52,val62,val72;
static pthread_mutex_t mutex;
pthread_mutex_lock(&mutex);
prt = strtok(arg, "#" );
strcpy(mac,prt);
printf("%s\n",mac);
prt = strtok(NULL, "#" );
strcpy(valeur, prt);
printf("%s\n",valeur);
if (strcmp(valeur,"iax" )==0)
{
prt = strtok(NULL,"#" );
while (prt!=NULL)
{
pthread_mutex_lock(&mutex);
strcpy(valeur,prt);
sscanf(valeur,"%s %s", val1,val2);
sprintf(sqlrequest1,"INSERT INTO Tsrv_TelEtat(ident, Mac, Etat,Heure) VALUES ('%s','%s','%s',now())", val1, mac, val2);
mysql_query(&mysql,sqlrequest1);
prt = strtok(NULL,"#" );
pthread_mutex_unlock(&mutex);
sleep(2);
}
pthread_exit(0);
}
}
int main (int argc, char *argv[])
{
pthread_t thread1, thread2;
void *retour;
static pthread_mutex_t mutex;
pthread_mutex_init (&mutex, NULL);
MYSQL mysql;
GestionServer oGestionServer;
oGestionServer.StartDataBaseConnection();
std::cout << "running....\n";
try
{
/* Create the socket*/
//int port = 10245;
int port = 22266;
ServerSocket server ( port );
while ( true )
{
ServerSocket new_sock;
server.accept ( new_sock );
try
{
while ( true )
{
std::string datast;
new_sock >> datast;
//std::cout << datast << "\n";
size_t size = datast.size() + 1;
char * data = new char[ size ];
strncpy( data, datast.c_str(), size );
//printf("%s\n", data);
//oGestionServer.Tsrv_iaxAdd(data);
if (pthread_create (&thread1, NULL, (void*()(void*)) Tsrv_memoireAdd(data, mysql), NULL) < 0)
{
fprintf (stderr, "Impossible de créer le thread 1\\n" );
exit (1);
}
if (pthread_create (&thread2, NULL, (void*()(void*)) Tsrv_iaxAdd(data, mysql), NULL) < 0)
{
fprintf (stderr, "Impossible de créer le thread 2\\n" );
exit (1);
}
(void)pthread_join (thread1, &retour);
(void)pthread_join (thread2, &retour);
new_sock << "OK";
}
}
catch ( SocketException& ) {}
}
}
catch ( SocketException& e )
{
std::cout << "Exception was caught:" << e.description() << "\nExiting.\n";
}
oGestionServer.StopDataBaseConnection();
return EXIT_SUCCESS;
}
g++ -c -o testthread.o testthread.cpp
testthread.cpp: In function `int main(int, char **)':
testthread.cpp:204: `type name' declared as function returning a function
testthread.cpp:204: casting to function type `int ()()'
testthread.cpp:210: `type name' declared as function returning a function
testthread.cpp:210: casting to function type `int ()()'
make: *** [testthread.o] Error 1

Reply

Marsh Posté le 16-06-2006 à 15:17:33

à ton avis ca vient d'où ?

Reply

Marsh Posté le 16-06-2006 à 15:17:33

Reply

Marsh Posté le 16-06-2006 à 15:20:10

Je crois que c'est au niveau de la création du thread, la déclaration du troisième paramètre. Mais je ne sais que faire

Reply

Marsh Posté le 16-06-2006 à 15:43:34

http://mapage.noos.fr/emdel/pthreads.htm ca t'aide ?

Message cité 1 fois

Reply

Marsh Posté le 16-06-2006 à 16:25:09

Non pas plus

Reply

Marsh Posté le 19-06-2006 à 09:50:56

_darkalt3_ a écrit :

http://mapage.noos.fr/emdel/pthreads.htm ca t'aide ?

Salut darkalt3,
Serait-ce ceci?

Code :

pthread_create (&thread1, NULL, (void* (Tsrv_memoireAdd(data, mysql))(void* arg)) , NULL)

Maintenant il me dit des erreurs du type parse error.
Merci de voir avec moi.

Reply

Marsh Posté le 19-06-2006 à 13:39:53

les fonctions que tu fais pointer par ton thread doivent être statics, et avoir un pointeur sur void en paramètre, donc avoir le prototype style

static void* mafonctionthreadee(void* iParam);

---------------
Töp of the plöp

Reply

Marsh Posté le 19-06-2006 à 14:07:28

Mais si je veux que ma fonction soit de ce type:
int ma_fonction(param1,parm2...)?
Que dois-je faire dans ce cas?
Merci

Reply

Marsh Posté le 19-06-2006 à 14:11:35

te renseigner, chercher des tutoriels, des exemples, lire de la doc...

éventuellement passer des pointeurs sur objet ... en faisant attention ...

Message édité par _darkalt3_ le 19-06-2006 à 14:11:57

---------------
Töp of the plöp

Reply

Marsh Posté le 19-06-2006 à 14:14:06

j'oublie le plus important: si tu es sous windows, utilises plutot les thread mfc. Les fonctions que tu utilises sont plutôt orientées C, pas C++.

---------------
Töp of the plöp

Reply

Marsh Posté le 22-06-2006 à 11:31:29

J'ai finalement trouvé la solution,
d'une part, j'ai regroupé mes deux fonctions en une seule fonction à laquelle je passe mon argument en faisant char *argu=(char *)arg, avec arg l'élélment void* arg passé à ma fonction. Ensuite j'ai enlevé la classe.
J'ai aussi supprimé le mutex car il ne me sert à rien dans ce cas.
Merci

Reply

Marsh Posté le 22-06-2006 à 12:03:33

[résolu] en titre de topic :jap:

Reply

programme serveur multitâches

Sujets relatifs:

Leave a Replay