dorian
/
paramiko
1
0
Fork 0
Code Issues Pull Requests Projects Releases Wiki Activity

[project @ robey@lag.net-20061008002032-d6803b57bac4f62c] 

i think the compression needs to be inside this lock in order to preserve order
This commit is contained in:
Robey Pointer 2006-10-07 17:20:32 -07:00
parent 93ab477408
commit 4d090c71a6
1 changed files with 6 additions and 6 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

12
paramiko/packet.py
View File

@ -261,14 +261,14 @@ class Packetizer (object):
else: else:
cmd_name = '$%x' % cmd cmd_name = '$%x' % cmd
orig_len = len(data) orig_len = len(data)
if self.__compress_engine_out is not None:
data = self.__compress_engine_out(data)
packet = self._build_packet(data)
if self.__dump_packets:
self._log(DEBUG, 'Write packet <%s>, length %d' % (cmd_name, orig_len))
self._log(DEBUG, util.format_binary(packet, 'OUT: '))
self.__write_lock.acquire() self.__write_lock.acquire()
try: try:
if self.__compress_engine_out is not None:
data = self.__compress_engine_out(data)
packet = self._build_packet(data)
if self.__dump_packets:
self._log(DEBUG, 'Write packet <%s>, length %d' % (cmd_name, orig_len))
self._log(DEBUG, util.format_binary(packet, 'OUT: '))
if self.__block_engine_out != None: if self.__block_engine_out != None:
out = self.__block_engine_out.encrypt(packet) out = self.__block_engine_out.encrypt(packet)
else: else: