[Multi-threading] Connexion impossible ?

Version imprimable

Bonjour à tous,

J'essaye dans mon programme d'accéder à des données sur le réseau intranet de mon entreprise. J'utilise un programme multi-thread, et je me demande si c'est mon programme qui est tout pourri, ou bien si c'est le réseau car ça plante lamentablement... :aie:

Voici mon code simple de test :
Code:

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 void RequeteServeur() { std::cout << "Début du test serveur " << std::endl; std::vector<unsigned short> image(77120); unsigned short* image_ptr = &image[0]; // On lance 50 fois la boucle for (int i = 500; i != 550; i++) { int cr = IRimages(36181, 1, i, i, &image_ptr); // Appel serveur } std::cout << "Fin du test serveur " << std::endl; } int main() { boost::thread thread1 (&RequeteServeur); boost::thread thread2 (&RequeteServeur); thread1.join(); thread2.join(); std::cout << "Appuyez sur entrée pour continuer..."; std::cin.ignore( std::numeric_limits<std::streamsize>::max(), '\n' ); return 0; }
Alors? C'est moi ou le réseau ? :koi:

:merci:

EDIT : Quand je dis ça plante, c'est que le débogeur ne me donne pas vraiment d'infos utiles:
dans vector.h :
Code:

1 2 3 4 5 #endif /* _HAS_ITERATOR_DEBUGGING */ _SCL_SECURE_VALIDATE_RANGE(_Pos < size()); // plante ICI return (*(_Myfirst + _Pos)); }

29/01/2008, 14h26
Mat007

Salut,

Si ça plante c'est que c'est vraisemblablement toi !
Sans plus d'informations sur ce que fait IRimages c'est dur de savoir où est le problème, juste qu'une tentative d'accès à un élément qui n'existe pas d'un vecteur est faite...
Tu n'as pas la pile d'appels ?

MAT.
29/01/2008, 14h35
poukill

1 pièce(s) jointe(s)
IRimages c'est pas moi qui l'ai codé... ça fait parti des bibliothèques que notre service informatique nous met à disposition.
C'est une fonction qui va chercher sur le réseau une image, et la stocke dans la case mémoire appropriée...

Le code:
Code:

1 2 3 4 5 int main() { RequeteServeur(); return 0; }
fonctionne très bien en mono thread. Je récupère tout comme il faut.
Mais dès que je met deux RequeteServeur en parallèle ça plante, avec un message du style dans la console (cf pièce jointe)
29/01/2008, 14h44
Mat007

Si y'a des données statiques non protégées (en gros que c'est pas prévu pour du multi-thread) dans IRimages, ça va pas être possible de l'utiliser comme ça...

MAT.
29/01/2008, 15h18
poukill

Bon j'ai envoyé un mail à la personne concernée pour récupérer ce fameux IRImages(). Sinon je vais devoir faire comme j'ai toujours fait: sécuriser le réseau avec un mutex... :?
30/01/2008, 10h08
poukill

OK j'ai vu la personne concernée. Le code est vieux de plus de 10 ans, et utilise d'anciennes librairies de décompression JPEG codées par une entreprise sous-traitante...:roll:
Bref, je laisse tomber... :?

J'ai plus qu'à créer un singleton Mutex pour sécuriser l'accès réseau et le tour est joué !
30/01/2008, 10h16
Mat007

Un singleton c'est peut-être pas obligatoire, mais un wrapper avec un mutex, oui c'est sans doute le plus simple.
Par contre du coup ça va sérialiser les demandes d'images et si c'est le gros du boulot que réalisent tes threads ça va va pas mal diminuer l'intérêt d'en mettre plusieurs. Mais j'imagine qu'il y a des traitements (coûteux) après de réalisés sur les données de ces images récupérées ?

MAT.
30/01/2008, 10h31
poukill

Citation:

Envoyé par Mat007

Un singleton c'est peut-être pas obligatoire, mais un wrapper avec un mutex, oui c'est sans doute le plus simple.

Ah? Tu peux m'en dire plus? Qu'entends-tu par wrapper avec un mutex?
J'ai trouvé un papier intéressant ICI sur Google, mais c'est un mutex wrapper facade.

Citation:

Envoyé par Mat007

Par contre du coup ça va sérialiser les demandes d'images et si c'est le gros du boulot que réalisent tes threads ça va va pas mal diminuer l'intérêt d'en mettre plusieurs. Mais j'imagine qu'il y a des traitements (coûteux) après de réalisés sur les données de ces images récupérées ?

En fait j'ai pour simplifier des films d'images qui doivent jouer en même temps. C'est pourquoi chaque thread prend en charge de jouer le film avec les traitements appropriés. Donc aller chercher une image sur un serveur n'est qu'une partie de ce que va effectuer chaque thread, effectivement.

Citation:

Envoyé par poukill

Qu'entends-tu par wrapper avec un mutex?

Bah je pensais juste à une simple classe du style :
Code:

1 2 3 4 5 6 7 8 9 10 11 12 class ImageProvider { ... public: int LoadImage( ... ) { boost::mutex::scoped_lock locker( mutex_ ); return IRimages( ... ); } private: boost::mutex mutex_; };
Pas spécialement statique quoi...

MAT.

En fait je pensais ajouter un proxy à mon architecture déjà existante.
J' ai déjà une classe de base abstraite Camera, dont dérivent un tas de classes concrètes.
En utilisant le pattern Proxy, j'obtiens:
Code:

1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 class CameraProxy : public Camera { public: CameraProxy (Camera * camera) {m_camera = camera;} virtual ~CameraProxy(){} virtual vigra::UInt16Image importImage(int numero_image) { // On transmet l'appel en sécurisant le réseau boost::mutex::scoped_lock locker( m_mutex ); return m_camera->importImage(numero_image); } private: Camera * m_camera; boost::mutex m_mutex; };
Le problème ici c'est que le mutex n'est pas unique, c'est pour ça que je proposais de l'encapsuler dans un singleton ! ;)

30/01/2008, 11h32
Mat007

Mets juste le mutex en membre statique à ce moment-là ?

MAT.

Citation:

Envoyé par Mat007

Mets juste le mutex en membre statique à ce moment-là ?

C'est pas faux! :aie: Pourquoi se compliquer la vie ! :king:

Merci Mat, tu as de bons conseils comme d'habitude! :D

EDIT : le code qui marche

Code:

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
class Camera
{
public:
	Camera() {}
	Camera(int num_choc) : m_choc(num_choc){}
	~Camera(){};
 
	virtual vigra::UInt16Image importImage(int i) = 0;
 
protected:
	int m_choc;
};
 
class CameraIR : public Camera
{
public:
	CameraIR(int i): Camera(i) {}
	CameraIR(): Camera() {}
	virtual ~CameraIR() {}
 
 
	virtual vigra::UInt16Image importImage(int i)
	{
		std::vector<unsigned short> image(77120);
		unsigned short* image_ptr = &image[0];		
		int cr  = IRimages(36181, 1, i, i, &image_ptr); // Appel serveur
 
		return vigra::UInt16Image(320, 240, &image[0]);
	}
};
 
class CameraProxy : public Camera {
public:
	CameraProxy (Camera * camera) {m_camera = camera;}
	virtual ~CameraProxy(){ delete m_camera; }
 
	virtual vigra::UInt16Image importImage(int i)
	{
		// On transmet l'appel en sécurisant le réseau
		boost::mutex::scoped_lock locker( m_mutex );
		return m_camera->importImage(i);
	}
 
private:
	Camera * m_camera;
	static boost::mutex m_mutex;
};
 
boost::mutex CameraProxy::m_mutex;
 
void RequeteServeur()
{
	Camera * camera = new CameraProxy(new CameraIR);
	vigra::UInt16Image image = camera->importImage(500);
 
        delete camera;
}
 
int main()
{
	boost::thread thread1 (&RequeteServeur);
	boost::thread thread2 (&RequeteServeur);
 
	thread1.join();
	thread2.join();
 
	std::cout << "Appuyez sur entrée pour continuer...";
	std::cin.ignore( std::numeric_limits<std::streamsize>::max(), '\n' );
	return 0;
}