[telepathy-gabble/master] wait_bytestream_open: fix initiator/receiver
Guillaume Desmottes
guillaume.desmottes at collabora.co.uk
Fri Apr 3 09:26:00 PDT 2009
---
.../twisted/file-transfer/file_transfer_helper.py | 16 +++++++++-------
1 files changed, 9 insertions(+), 7 deletions(-)
diff --git a/tests/twisted/file-transfer/file_transfer_helper.py b/tests/twisted/file-transfer/file_transfer_helper.py
index 0181d64..46cb376 100644
--- a/tests/twisted/file-transfer/file_transfer_helper.py
+++ b/tests/twisted/file-transfer/file_transfer_helper.py
@@ -387,7 +387,8 @@ class SendFileTest(FileTransferTest):
self.bytestream.get_ns())
self.stream.send(result)
- self.bytestream.wait_bytestream_open(self.contact_name, 'test at localhost/Resource')
+ self.bytestream.wait_bytestream_open('test at localhost/Resource',
+ self.contact_full_jid)
def send_file(self):
s = socket.socket(socket.AF_UNIX, socket.SOCK_STREAM)
@@ -445,7 +446,7 @@ class Bytestream(object):
def get_ns(self):
raise NotImplemented
- def wait_bytestream_open(self, from_, to):
+ def wait_bytestream_open(self, initiator, receiver):
raise NotImplemented
def get_data(self):
@@ -480,7 +481,7 @@ class BytestreamIBB(Bytestream):
self.seq += 1
- def wait_bytestream_open(self, from_, to):
+ def wait_bytestream_open(self, initiator, receiver):
# Wait IBB open iq
event = self.q.expect('stream-iq', iq_type='set')
sid = parse_ibb_open(event.stanza)
@@ -524,19 +525,20 @@ class BytestreamS5B(Bytestream):
def send_data(self, from_, to, data):
self.transport.write(data)
- def wait_bytestream_open(self, from_, to):
+ def wait_bytestream_open(self, initiator, receiver):
id, mode, sid, hosts = expect_socks5_init(self.q)
for jid, host, port in hosts:
- assert jid == to, jid
+ assert jid == initiator, jid
assert mode == 'tcp'
assert sid == self.stream_id
jid, host, port = hosts[0]
- self.transport = socks5_connect(self.q, host, port, sid, from_, to)
+ self.transport = socks5_connect(self.q, host, port, sid, initiator,
+ receiver)
- send_socks5_reply(self.stream, from_, to, id, jid)
+ send_socks5_reply(self.stream, receiver, initiator, id, jid)
def get_data(self):
e = self.q.expect('s5b-data-received', transport=self.transport)
--
1.5.6.5
More information about the telepathy-commits
mailing list