diff options
author | Marco Pesenti Gritti <mpg@redhat.com> | 2006-06-18 07:00:23 (GMT) |
---|---|---|
committer | Marco Pesenti Gritti <mpg@redhat.com> | 2006-06-18 07:00:23 (GMT) |
commit | 51ea9eedba1891abdc004433bfe29a4ae3cc50b1 (patch) | |
tree | f969b23b049a3188a52a10c8f2dc9ee0f8938116 /sugar/p2p | |
parent | bc43e25e107f8737342db295d165ba30b0b2c46d (diff) |
Get chat back to work. Well except it get very confused
if users have the same ip address.
Dan I commented out the service deserialization in BrowserShell
because it was not really working (also there was a few typos in
that code)
Diffstat (limited to 'sugar/p2p')
-rw-r--r-- | sugar/p2p/Stream.py | 6 |
1 files changed, 4 insertions, 2 deletions
diff --git a/sugar/p2p/Stream.py b/sugar/p2p/Stream.py index af770a2..4d0705e 100644 --- a/sugar/p2p/Stream.py +++ b/sugar/p2p/Stream.py @@ -2,6 +2,7 @@ import xmlrpclib import socket import traceback import random +import logging import network from MostlyReliablePipe import MostlyReliablePipe @@ -33,7 +34,7 @@ class Stream(object): def _recv(self, address, data): if self._callback: - self._callback(data) + self._callback(address, data) class UnicastStreamWriter(object): @@ -133,6 +134,7 @@ class MulticastStream(Stream): return self._reader_port def _internal_start_reader(self): + logging.debug('Start multicast stream, address %s, port %d' % (self._address, self._reader_port)) if not self._service.get_address(): raise ValueError("service must have a valid address.") self._pipe = MostlyReliablePipe('', self._address, self._reader_port, @@ -143,7 +145,7 @@ class MulticastStream(Stream): self._pipe.send(data) def _recv_data_cb(self, address, data, user_data=None): - self._recv(address, data) + self._recv(address[0], data) def new_writer(self, service=None): return self |