From 6ee7921d066396da13da7744fc0e0591a516453f Mon Sep 17 00:00:00 2001 From: Robey Pointer Date: Tue, 28 Jun 2005 07:23:41 +0000 Subject: [PATCH] [project @ Arch-1:robey@lag.net--2005-master-shake%paramiko--dev--1--patch-18] tweak random stuff in transport that i forgot what it does --- paramiko/transport.py | 8 ++++---- 1 file changed, 4 insertions(+), 4 deletions(-) diff --git a/paramiko/transport.py b/paramiko/transport.py index dc0632a..21bc7ed 100644 --- a/paramiko/transport.py +++ b/paramiko/transport.py @@ -643,11 +643,11 @@ class BaseTransport (threading.Thread): self._log(DEBUG, 'Sending global request "%s"' % kind) self._send_user_message(m) if not wait: - return True + return None while True: self.completion_event.wait(0.1) if not self.active: - return False + return None if self.completion_event.isSet(): break return self.global_response @@ -1224,7 +1224,7 @@ class BaseTransport (threading.Thread): self._activate_inbound() # can also free a bunch of stuff here self.local_kex_init = self.remote_kex_init = None - self.e = self.f = self.K = self.x = None + self.K = None if not self.initial_kex_done: # this was the first key exchange self.initial_kex_done = True @@ -1281,8 +1281,8 @@ class BaseTransport (threading.Thread): if not self.channels.has_key(chanid): self._log(WARNING, 'Success for unrequested channel! [??]') return + self.lock.acquire() try: - self.lock.acquire() chan = self.channels[chanid] chan._set_remote_channel(server_chanid, server_window_size, server_max_packet_size) self._log(INFO, 'Secsh channel %d opened.' % chanid)