mirror of
https://github.com/facebook/zstd.git
synced 2025-08-10 04:43:07 +03:00
remove error message for Ctrl+C
This commit is contained in:
@@ -23,20 +23,26 @@ rate *= 1.4 # compensation for excluding i/o time (experimentally determined)
|
|||||||
start = time.time()
|
start = time.time()
|
||||||
total_read = 0
|
total_read = 0
|
||||||
|
|
||||||
buf = " "
|
sys.stderr.close() # remove error message, for Ctrl+C
|
||||||
while len(buf):
|
|
||||||
now = time.time()
|
|
||||||
to_read = max(int(rate * (now - start) - total_read), 1)
|
|
||||||
max_buf_size = 1 * MB
|
|
||||||
to_read = min(to_read, max_buf_size)
|
|
||||||
|
|
||||||
read_start = time.time()
|
try:
|
||||||
buf = sys.stdin.buffer.read(to_read)
|
buf = " "
|
||||||
|
while len(buf):
|
||||||
|
now = time.time()
|
||||||
|
to_read = max(int(rate * (now - start) - total_read), 1)
|
||||||
|
max_buf_size = 1 * MB
|
||||||
|
to_read = min(to_read, max_buf_size)
|
||||||
|
|
||||||
write_start = read_end = time.time()
|
read_start = time.time()
|
||||||
sys.stdout.buffer.write(buf)
|
buf = sys.stdin.buffer.read(to_read)
|
||||||
write_end = time.time()
|
|
||||||
|
|
||||||
wait_time = max(read_end - read_start, write_end - write_start)
|
write_start = read_end = time.time()
|
||||||
start += wait_time # exclude delay of the slowest
|
sys.stdout.buffer.write(buf)
|
||||||
total_read += len(buf)
|
write_end = time.time()
|
||||||
|
|
||||||
|
wait_time = max(read_end - read_start, write_end - write_start)
|
||||||
|
start += wait_time # exclude delay of the slowest
|
||||||
|
total_read += len(buf)
|
||||||
|
|
||||||
|
except (KeyboardInterrupt, BrokenPipeError) as e:
|
||||||
|
pass
|
||||||
|
Reference in New Issue
Block a user