X-Git-Url: http://git.onelab.eu/?p=nepi.git;a=blobdiff_plain;f=nepi%2Futil%2Fsshfuncs.py;h=1b4d389b27e533eda55de1189ed5befcae3ee06c;hp=9ba59827030364c8db2360790cc1eee2cf1ef70b;hb=40e6d376152c072bc852117f0a58e88d9e0024af;hpb=bf9ccbdbba2900cbb241f831c81d84d16883ed0b diff --git a/nepi/util/sshfuncs.py b/nepi/util/sshfuncs.py index 9ba59827..1b4d389b 100644 --- a/nepi/util/sshfuncs.py +++ b/nepi/util/sshfuncs.py @@ -410,8 +410,8 @@ def rcopy(source, dest, log_msg = " rcopy - host {} - command {} ".format(host, " ".join(map(str, args))) return _retry_rexec(args, log_msg, env = None, retry = retry, - tmp_known_hosts = tmp_known_hosts, - blocking = True) + tmp_known_hosts = tmp_known_hosts, + blocking = True) def rspawn(command, pidfile, stdout = '/dev/null', @@ -837,7 +837,7 @@ def _communicate(proc, input, timeout=None, err_on_timeout=True): # we can write up to PIPE_BUF bytes without risk # blocking. POSIX defines PIPE_BUF >= 512 bytes_written = os.write(proc.stdin.fileno(), - buffer(input, input_offset, 512)) + buffer(input, input_offset, 512)) input_offset += bytes_written if input_offset >= len(input):