gaschz/ansible-qubes
1
0
Fork 0
mirror of https://github.com/Rudd-O/ansible-qubes.git synced 2025-10-31 11:38:55 +01:00
Code Issues Packages Projects Releases Wiki Activity

Another fix.

Browse Source
This commit is contained in:
Rudd-O 2020-07-14 18:27:12 +00:00
parent 88907adabb
commit 0758b872f1
2 changed files with 4 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
bin/bombshell-client
View File

@ -193,6 +193,8 @@ def write(dst, buffer, l):
while len(mv): while len(mv):
dst.write(mv) dst.write(mv)
writtenthisloop = len(mv) writtenthisloop = len(mv)
#logging.debug("write: Sent %s bytes to sink %s", writtenthisloop, dst)
#logging.debug("write: %s", mv[:writtenthisloop].tobytes())
if writtenthisloop is None or writtenthisloop < 1: if writtenthisloop is None or writtenthisloop < 1:
raise Exception("copy: Failed to write any bytes") raise Exception("copy: Failed to write any bytes")
mv = mv[writtenthisloop:] mv = mv[writtenthisloop:]
@ -238,6 +240,8 @@ class DataMultiplexer(MyThread):
self.sink.write(header) self.sink.write(header)
continue continue
l = readthisloop l = readthisloop
#logging.debug("mux: Received %s bytes from source %s", l, n)
#logging.debug("mux: %s", buffer[:l])
header = struct.pack(PACKFORMAT, n, True, l) header = struct.pack(PACKFORMAT, n, True, l)
self.sink.write(header) self.sink.write(header)
write(self.sink, buffer, l) write(self.sink, buffer, l)

1
connection_plugins/qubes.py
View File

@ -264,7 +264,6 @@ class Connection(ConnectionBase):
self.transport_cmd = kwargs['transport_cmd'] self.transport_cmd = kwargs['transport_cmd']
return return
self.transport_cmd = distutils.spawn.find_executable('qrun') self.transport_cmd = distutils.spawn.find_executable('qrun')
self.transport_cmd = None
if not self.transport_cmd: if not self.transport_cmd:
self.transport_cmd = os.path.join( self.transport_cmd = os.path.join(
os.path.dirname(__file__), os.path.dirname(__file__),