Discussion :

[dsant]

Bonjour, avec Qt la doc propose d'utiliser readDatagram() et writeDatagram() pour recevoir et envoyer des données sur le reseau (en UDP).
http://qt.developpez.com/doc/latest/qudpsocket.html

Or readDatagram() est appelé par un signal, et peut donc etre appelé n'importe quand, y compris pendant que je manipule mes données pour writeDatagram()

Code :

Sélectionner tout - Visualiser dans une fenêtre à part

connect(udpSocket, SIGNAL(readyRead()),this, SLOT(readPendingDatagrams()));

Quelle solution élégante et portable me conseillez vous pour faire un accés exlusif, afin que les traitements de reception et d'expédition se fassent l'un après l'autre et pas en même temps ?

Dsant



Le code de l'exemple de Trolltech :

Code :

Sélectionner tout - Visualiser dans une fenêtre à part

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
void Server::initSocket()
 {
     udpSocket = new QUdpSocket(this);
     udpSocket->bind(QHostAddress::LocalHost, 7755);
 
     connect(udpSocket, SIGNAL(readyRead()),
             this, SLOT(readPendingDatagrams()));
 }
 
 void Server::readPendingDatagrams()
 {
     while (udpSocket->hasPendingDatagrams()) {
         QByteArray datagram;
         datagram.resize(udpSocket->pendingDatagramSize());
         QHostAddress sender;
         quint16 senderPort;
 
         udpSocket->readDatagram(datagram.data(), datagram.size(),
                                 &sender, &senderPort);
 
         processTheDatagram(datagram);
     }
 }

[gbdivers]

Bonjour dsant

L'exemple donné dans la doc présente uniquement la lecture de données.
La différence entre la lecture et l'écriture de données, c'est que la lecture dépend d'un signal (le socket qui dit "j'ai des données à transmettre") alors que l'écriture non : tu peux écrire quand tu veux.
Donc, pour gérer ton accès exclusif :
* tu peux utiliser des tampons de données différents pour la lecture et l'écriture.
* tu peux utiliser une classe "intelligente" qui autorisera ou non l'écriture/lecture des données (par exemple QBuffer pour lire/écrire dans un QByteArray : avant de lire/écrire, tu testes si le buffer est déjà ouvert avec la fonction isOpen(). si c'est la cas, tu attends, sinon tu ouvre le buffer en ReadOnly ou WriteOnly puis tu écris/lis)
* plus compliqué (et risqué) : si tes données sont de tailles importantes et que tu ne veux pas dupliquer (problème de taille) ou attendre en cas de signal readyRead (problème de perte de données), c'est d'écrire une classe permettant l'accès concurrent aux données, en garantissant que l'écriture et la lecture ne provoquent pas de ré-allocation mémoire et qu'ils n'accèdent pas aux mêmes blocs de données.

[yan]

Or readDatagram() est appelé par un signal, et peut donc etre appelé n'importe quand, y compris pendant que je manipule mes données pour writeDatagram()

Tu manipule ta socket par plusieurs thread??

[Gulish]

Je ne comprends pas trop ta question. Tes actions, le socket n'est utilisé que par un thread, ne se feront jamais en même temps.

Si tu veux juste désactiver la lecture automatique, tu n'as qu'à pas faire le "connect", et appeler toi même la fonction readPendingDatagrams().

G.

[dsant]

Merci beaucoup