[socket] un socket.receive() non bloquant ....

Recherche :

Mot : Pseudo : Filtrer
Bas de page
Auteur	Sujet : [socket] un socket.receive() non bloquant ....

pi3r

slt a tous,

voila je fais une appli en python qui reçoit des instructions de tps en tps et j'ai une restriction assez sérieuse : ne pas utiliser de thread !

Donc il faudrait que je puisse faire un receive de tps en tps pour vérifier si des instructions sont arrivées mais la méthode socket.receive() est bloquante donc mon prog arrête de tourner tant qu'il n'a rien reçu :cry:

Mon idée était de combiner le timeout et 1 boucle while mais ça ne fonctionne pas .... bon place au bout de code, ce sera + compréhensible :

Code :

def __init__(self,host=socket.gethostname(),port=10000):
self.host,self.rhost=host,host
self.port,self.rport=port,port
try:
print 'Creating Socket'
self.Socket=socket.socket(socket.AF_INET,socket.SOCK_STREAM)
self.Socket.settimeout(1.0)
except socket.error:
print 'Failed to create Socket object !'
try:
print 'Binding Socket'
self.Socket.bind((self.host,self.port))
print self
except socket.error:
print 'unable to bind '+str(self.host)+' on port '+str(self.port)
def Listen(self,msg='Accepted Connection from:'):
print 'Listening to port ',self.port
self.Socket.listen(1)
try:
self.conn,self.rhost=self.Socket.accept()
self.rhost=self.rhost[0]
except socket.timeout:
print 'no available connection, doing something else'
self.somethingElse()
return 0
if self.rhost:
print 'Got connection from',self.rhost
print msg,self.rhost
return 1
def Receive(self,size=65534):
try:
print 'Receiving data...'
received=self.conn.recv(size)
print 'received ',len(received)
return received
except socket.timeout:
print 'no data to receive, doing something else'
self.somethingElse()
return None
def main(self):
while self.Listen()!=1:
print 'main: listen one more time ...'
print 'main: ok, seemed to be connected now ;)'
while self.Receive()==None:
print 'main: receive one more time ...'

Un exemple d'exécution donnerait ça :

Citation :

Creating Socket
Binding Socket
Socket bound to Host=zsdev001,Port=10000
Listening to port 10000
no available connection, doing something else
hi! im doing something else
main: listen one more time ...
Listening to port 10000
no available connection, doing something else
hi! im doing something else
main: listen one more time ...
Listening to port 10000
Got connection from 192.168.1.130
Accepted Connection from: 192.168.1.130
main: ok, seemed to be connected now
Receiving data...
Traceback (most recent call last):
File "D:\zap-Lib\serv.py", line 69, in main
while self.Receive()==None:
File "D:\zap-Lib\serv.py", line 51, in Receive
received=self.conn.recv(size)
socket.error: (10035, 'The socket operation could not complete without blocking'
)

J'ai essayé de faire un self.Socket.setblocking(0) ms la methode receive reste bloquante ....

une idée ??
d'avance merci!

vince

Publicité

SoWhatIn22

c'est curieux, cela devrait fonctionner...
essaye peut être de voir du côté de select.select() ?

Taz

bisounours-codeur

j'ai pas testé ton exemple, mais

tu mélange timeout et blocking, je suis sur que ça foir ...

en mode non bloquant, quand y a rien à lire, ça retourne pas rien, ça lance une exception socket.error

pi3r

humm, bonne idée, je vais chercher de ce côté ...

pi3r

Taz a écrit :

oui c vrai, ce que je voudrais faire, c'est faire un receive de tps en tps or le receive n'accepte pas le timeout .... maintenant je pourrai me mettre en mode non bloquant mais comment créer une boucle pour faire ce receive à intervalle régulier ??

Taz

bisounours-codeur

tu fais des pauses et voilà

pi3r

des pauses, cad ?

Taz

bisounours-codeur

time.sleep(1.1)

pi3r

Taz a écrit :

time.sleep(1.1)

ha ok c'est tout con effectivement (désolé je débute en python), ms j'ai lu :

Citation :

sleep(secs) Suspends execution for secs seconds. secs can be a float.

et ça ve dire que mon prog va arreter de tourner pdt 'secs', non ?
or justement je veux qu'il tourne et puis qu'il fasse le receive tous les 'laps' ....

Taz

bisounours-codeur

ben ton thread reçoit et dors voilà

Publicité

pi3r

Taz a écrit :

ben ton thread reçoit et dors voilà

oui ms justement, g pas de thread et je dois pas en utiliser, ms bon je vais me débrouiller avec tout ça.

merci à vs 2 pour les réponses :jap:

++
vince

Taz

bisounours-codeur

dtc .. tu vas faire un programme sous efficace et consommateur de CPU

BenO

Profil: Chercheur

euhh, a priori , ton programme est un thread que tu le veuilles ou non.
à confirmer ^^

Taz

bisounours-codeur

...

Phod

Glouloulou ?

C'est un peu tard, mais ca sera peut etre kan meme utile a kkun...

pour eviter le thread tout en concervant une vitesse d'excution correct de ton code tu utilise un compteur + un time.sleep avec une toute petite tempo !

genre :

Code :

cpt=0
while(1):
...
time.sleep(0.01)
cpt=cpt+0.01
if cpt == 5: # pour tester ton socket toutes les 5 secondes
socket.receive(...)
cpt=0
...
suite du traitement
...

vala

Message édité par Phod le 10-06-2004 à 17:16:49

---------------
Signatures aux choix Votez: O - Le python c'est bon, mangez-en O - L'abus de forum rend dependant, postez avec modération

Taz

bisounours-codeur

n'importe quoi ...

Phod

Glouloulou ?

c'est peut etre pas tres elegant mais :

c'est ppas compliqué, y a pas de thread et ca ralenti pas 'trop' le reste du traitement.

tu aurai fait comment toi ?

---------------
Signatures aux choix Votez: O - Le python c'est bon, mangez-en O - L'abus de forum rend dependant, postez avec modération

Taz

bisounours-codeur

tu plaisantes là ?

Phod

Glouloulou ?

ben non. si tu critique mon truc (qui je le reconnais est n'est pas tres 'clean') c'est que tu pense a mieu non ?

Message édité par Phod le 10-06-2004 à 17:35:23

---------------
Signatures aux choix Votez: O - Le python c'est bon, mangez-en O - L'abus de forum rend dependant, postez avec modération

FORUM HardWare.fr

Programmation

Python

[socket] un socket.receive() non bloquant ....

Sujets relatifs
besoin d'aide pour la fonction socket probleme avec free	[resolu tout seul ^^] Probleme avec socket & printf
problème socket unix - lecture	[C++] Socket - envoyer URL
Lecture du clavier non bloquant	Socket et Packet en C
[Question] Socket (résolu)	recv non bloquant en progra socket (connected)
Plus de sujets relatifs à : [socket] un socket.receive() non bloquant ....

Page générée en 0.079 secondes