Thread & Serveur echo

Version imprimable

Bonjour bonjour :)

Je suis en train d'essayer de coder un petit programme qui envois des message en udp sur le reseau local.
Un espece de messenger en faite...

Mais j'ai un petit soucis, que je ne parvient pas à résoudre...
Au debut je lance l'écoute sur un port, mais seulement l'instruction est bloquante. Et ne rends pas la main... donc les ligne suivante l'appel ne s'exécute pas...

Main.py

Code:

1
2
3
4
5
6
7
8
9
10
from Lib_WifiMessenger import *
from multiprocessing import Process
 
connec = Connection()
saisie = 'Se connecte : '
p_recv = Process(connec.Start_Recevoir())
p_recv.start()
while saisie != '#exit':
    connec.Envoyer(saisie)
    saisie = raw_input()

Lib_WifiMessenger

Code:

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
import socket
import sys
class Connection(object):
    def __init__(self):
        self.port = 20462
        self.thread_continue = False
        self.sock_in = socket.socket(socket.AF_INET, socket.SOCK_DGRAM)
        self.sock_in.setsockopt(socket.SOL_SOCKET, socket.SO_REUSEADDR, 1)
        self.sock_in.setsockopt(socket.SOL_SOCKET, socket.SO_BROADCAST, 1)
 
        self.sock_out = socket.socket(socket.AF_INET, socket.SOCK_DGRAM)
        self.sock_out.setsockopt(socket.SOL_SOCKET, socket.SO_BROADCAST, 1)
 
    def Envoyer(self, message):
        self.sock_out.connect(('<broadcast>',self.port))
        self.sock_out.send(message)
 
    def Start_Recevoir(self):
        print ("Thread d\'ecoute lance sur : "+str(socket.gethostbyname(socket.gethostname())))
        self.sock_in.bind((socket.gethostbyname(socket.gethostname()), self.port))
        while 1:
            message, addr = self.sock_in.recvfrom(4096)
            sys.stdout.write(message)

Salut,
Ben connec.Start_Recevoir() demande l'évaluation de la fonction alors que Process préférerait le point d'entrée du process/thread à démarrer, i.e
connec.Start_Recevoir sans les '()'
Code:

1 2 3 4 5 6 7 connec = Connection() saisie = 'Se connecte : ' p_recv = Process(target=connec.Start_Recevoir, args=()) p_recv.start() while saisie != '#exit': connec.Envoyer(saisie) saisie = raw_input()
- W

Bonjour,
Merci pour ta réponse, mais il est impossible de lancer l'application avec ta modification

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
Traceback (most recent call last):
  File "C:\main.py", line 7, in <module>
    p_recv.start()
  File "C:\Python26\lib\multiprocessing\process.py", line 104, in start
    self._popen = Popen(self)
  File "C:\Python26\lib\multiprocessing\forking.py", line 239, in __init__
    dump(process_obj, to_child, HIGHEST_PROTOCOL)
  File "C:\Python26\lib\multiprocessing\forking.py", line 162, in dump
    ForkingPickler(file, protocol).dump(obj)
  File "C:\Python26\lib\pickle.py", line 224, in dump
    self.save(obj)
  File "C:\Python26\lib\pickle.py", line 331, in save
    self.save_reduce(obj=obj, *rv)
  File "C:\Python26\lib\pickle.py", line 419, in save_reduce
    save(state)
  File "C:\Python26\lib\pickle.py", line 286, in save
    f(self, obj) # Call unbound method with explicit self
  File "C:\Python26\lib\pickle.py", line 649, in save_dict
    self._batch_setitems(obj.iteritems())
  File "C:\Python26\lib\pickle.py", line 681, in _batch_setitems
    save(v)
  File "C:\Python26\lib\pickle.py", line 286, in save
    f(self, obj) # Call unbound method with explicit self
  File "C:\Python26\lib\multiprocessing\forking.py", line 40, in dispatcher
    self.save_reduce(obj=obj, *rv)
  File "C:\Python26\lib\pickle.py", line 401, in save_reduce
    save(args)
  File "C:\Python26\lib\pickle.py", line 286, in save
    f(self, obj) # Call unbound method with explicit self
  File "C:\Python26\lib\pickle.py", line 548, in save_tuple
    save(element)
  File "C:\Python26\lib\pickle.py", line 331, in save
    self.save_reduce(obj=obj, *rv)
  File "C:\Python26\lib\pickle.py", line 419, in save_reduce
    save(state)
  File "C:\Python26\lib\pickle.py", line 286, in save
    f(self, obj) # Call unbound method with explicit self
  File "C:\Python26\lib\pickle.py", line 649, in save_dict
    self._batch_setitems(obj.iteritems())
  File "C:\Python26\lib\pickle.py", line 681, in _batch_setitems
    save(v)
  File "C:\Python26\lib\pickle.py", line 331, in save
    self.save_reduce(obj=obj, *rv)
  File "C:\Python26\lib\pickle.py", line 419, in save_reduce
    save(state)
  File "C:\Python26\lib\pickle.py", line 286, in save
    f(self, obj) # Call unbound method with explicit self
  File "C:\Python26\lib\pickle.py", line 548, in save_tuple
    save(element)
  File "C:\Python26\lib\pickle.py", line 286, in save
    f(self, obj) # Call unbound method with explicit self
  File "C:\Python26\lib\pickle.py", line 649, in save_dict
    self._batch_setitems(obj.iteritems())
  File "C:\Python26\lib\pickle.py", line 681, in _batch_setitems
    save(v)
  File "C:\Python26\lib\pickle.py", line 286, in save
    f(self, obj) # Call unbound method with explicit self
  File "C:\Python26\lib\pickle.py", line 748, in save_global
    (obj, module, name))
PicklingError: Can't pickle <built-in method recvfrom_into of _socket.socket object at 0x01670A48>: it's not found as __main__.recvfrom_into

14/06/2010, 11h24
wiztricks

Salut,

Si vous voulez créer un process dont le point d'entrée est la méthode "truc", vous n'avez pas d'autre choix que de passer l'adresse de "truc" avec ses éventuels arguments "a part"... Aucune chance pour que l'évaluation de "truc" puisse être faite dans le contexte cible sinon.

Pour vous en convaincre, essayez avec des exemples "simples".

L'erreur dit que le "truc" que vous donnez à Process ne plait pas à "pickle" et cela dépend plus du contenu/nature du "Connection" sorti de "Lib_WifiMessenger"...

Bon courage,
- W
14/06/2010, 13h27
dogua

Hum hum...

Mais comment savoir ce qui coince pour pickle ?
Sinon il n'y a pas moyen alors de faire un thread à la place d'un process?
Mais que celui si ne bloque pas le déroulement de mon programme ensuite..

Merci
14/06/2010, 22h50
wiztricks

Citation:

Envoyé par dogua

Hum hum...

Mais comment savoir ce qui coince pour pickle ?

Il faut voir ce qu'il y a dans Lib_Wifi...

Citation:

Sinon il n'y a pas moyen alors de faire un thread à la place d'un process?

C'est la même API, voir le FAQ

Citation:

Mais que celui si ne bloque pas le déroulement de mon programme ensuite..

i[/QUOTE]
Lib_Wifi a sans doute de bonnes raisons de ne pas être 'pickable' mais peut être aussi d'autres restrictions qu'il serait bon de connaitre.

- W
16/06/2010, 11h16
dogua

Lib_WifiMessenger est affiché dans mon premier post ;)

J'ai regarder un peu, et en faite, il ne veut tous simplement pas de "socket"
19/06/2010, 14h14
wiztricks

Salut,

Désolé mais en prenant ce que vous avez fourni et la correction que je vous ai proposé, chez moi la chose se lance sans les messages d'erreurs "Pickle" que vous mentionnez.
- W