Discussion :

[FloMo]

Bonjour,

Je suis en train de réaliser une application cliente qui se connecte à plusieurs serveurs.
Pour chaque connexion à établir ( définie dans un fichier de configuration ), je stocke toutes les informations la concernant dans une structure ( descripteurs de fichiers, buffers, paramètres, ...) . A chaque connexion correspond un thread.

L'application contient donc 2 tableaux de taille identique :
- l'un contient les threads,
- l'autre contient des pointeurs vers les structures correspondantes.

De la sorte, il me semble que les informations ne peuvent pas se croiser.

Lorsque je n'utilise qu'un serveur, ça passe. Par contre, dès que je passe à 2, les performances chutent. Les données transmises sont pourtant de taille minimale ( de l'ordre de quelques octets ).

J'aimerais donc savoir si quelqu'un a déjà rencontré un problème similaire et pourrait éventuellement m'aider ou orienter mes recherches.

Merci par avance.

[fearyourself]

Sans voir un code minimal ce sera difficile de trancher...

- Que fait vraiment l'application ?
- Quelle est la fréquence des envois ?
- Les données sont-elles communes ou est-ce que chaque thread fait des choses séparément ?
- Si c'est bien séparé, y-a-t-il un avantage à utiliser des threads ?
- Si y a des choses communes, y-a-t-il des mutex/sémaphores ?

Jc

[FloMo]

Sans voir un code minimal ce sera difficile de trancher...

Désolé, c'est confidentiel ( boulot ).

- Que fait vraiment l'application ?

Elle envoie une requête vers le serveur qui envoie par la suite une ou plusieurs réponse(s). Les réponses sont ensuite écrites sur un PTY. Les données sont de taille variable.

- Quelle est la fréquence des envois ?

Elle est variable. Les données peuvent être envoyées depuis plusieurs serveurs simultanément.

- Les données sont-elles communes ou est-ce que chaque thread fait des choses séparément ?

Les seules données communes sont les informations de débogage.

- Si c'est bien séparé, y-a-t-il un avantage à utiliser des threads ?

Avec les fork(), il y a des problèmes de portabilité.

[fearyourself]

Elle envoie une requête vers le serveur qui envoie par la suite une ou plusieurs réponse(s). Les réponses sont ensuite écrites sur un PTY. Les données sont de taille variable.

Il est simplement possible que tu satures le réseau avec tes réponses. Si tu fais deux applications séparées qui se connectent en même temps, est-ce que tu constates le même problème ?


Jc

[FloMo]

J'ai essayé en faisant un fork(). Les données sont bien séparées. J'ai des performances inférieures.

Cependant, je me suis rendu compte que lorsque j'utilise un client vers plusieurs serveurs, c'est toujours le dernier qui a les pires performances.
Par exemple, pour une lecture qui dure 2 secondes en temps normal, il faudra 6 secondes au dernier serveur ( selon l'ordre de création des threads, à partir de la lecture d'un fichier de configuration ).

J'ai bien vérifié les fuites mémoire éventuelles. Tout malloc() ou calloc() a son free(). Je n'y comprend plus rien.

[FloMo]

Pour les échanges de données, j'utilise 2 select() : un pour les lecteurs, qui remplit un buffer, l'autre pour les écriture qui écrit éventuellement le contenu du buffer.

Serait-il judicieux de créer un thread par tentative de lecture ou d'écriture et de le détacher de manière à accélérer les traitements ?
En gros, cela donnerait :

- Puis-je lire ( select() + test buffer ) ?
- Si oui, je bloque l'accès au descripteur grâce à un mutex,
- Je lis,
- Je débloque le mutex.

- Puis-je écrire (select() + test buffer ) ?
- Si oui, je bloque l'accès au descripteur grâce à un mutex,
- J'écris,
- Je débloque le mutex.

Je me demande si le laps de temps entre les traitement sera plus long ou plus court que la demande de création de thread ?

[FloMo]

Une question : est-ce que le fait d'ajouter des mutexes pour gérer mes messages sur stderr, stdout et varlog peut être bénéfique ?

[fearyourself]

Une question : est-ce que le fait d'ajouter des mutexes pour gérer mes messages sur stderr, stdout et varlog peut être bénéfique ?

Je ne sais pas si utiliser des mutex va aider mais cela se tente. Par contre, un mutex sert à limiter l'accès à une zone de code donc oui c'est possible de faire ce que tu veux.

Jc

[FloMo]

Les mutexes sont en effet inutiles. Par contre, j'ai remarqué un comportement étrange...
Quand je lance 2 instances de mon programme exécutant chacune une tâche d'écoute - transmission des données, j'ai exactement les mêmes symptômes, à savoir :
- deux connexions aux serveurs séparées : pas de problème,
- deux connexions aux serveurs avec léger différé : ça passe, mais c'est lent,
- deux connexions aux serveurs simultanés : très lent, voir plantage.

De plus, ce développement se passe sous SCO.

Merci pour vos réponses.