Web   ·   Wiki   ·   Activities   ·   Blog   ·   Lists   ·   Chat   ·   Meeting   ·   Bugs   ·   Git   ·   Translate   ·   Archive   ·   People   ·   Donate
summaryrefslogtreecommitdiffstats
path: root/sugar/p2p
diff options
context:
space:
mode:
authorMarco 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)
commit51ea9eedba1891abdc004433bfe29a4ae3cc50b1 (patch)
treef969b23b049a3188a52a10c8f2dc9ee0f8938116 /sugar/p2p
parentbc43e25e107f8737342db295d165ba30b0b2c46d (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.py6
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