ayo/kitty
1
Fork 0
Code Issues Pull requests Projects Releases Packages Wiki Activity Actions

Avoid progress messages with no actual progress

Browse source
This commit is contained in:
Kovid Goyal 2021-10-03 13:06:38 +05:30
parent 37f3328147
commit 1ba9cd6138
No known key found for this signature in database
GPG key ID: 06BC317B515ACE7C
1 changed files with 7 additions and 2 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

9
kitty/file_transmission.py
View file

@ -569,6 +569,10 @@ def handle_receive_cmd(self, cmd: FileTransmissionCommand) -> None:
self.callback_after(partial(self.transmit_rsync_signature, fs, ar.id, df.file_id, deque()))
elif cmd.action in (Action.data, Action.end_data):
try:
before = 0
bf = ar.files.get(cmd.file_id)
if bf is not None:
before = bf.bytes_written
df = ar.add_data(cmd)
if df.failed:
return
@ -577,8 +581,9 @@ def handle_receive_cmd(self, cmd: FileTransmissionCommand) -> None:
self.send_status_response(
code=ErrorCode.OK, request_id=ar.id, file_id=df.file_id, name=df.name, size=df.bytes_written)
else:
self.send_status_response(
code=ErrorCode.PROGRESS, request_id=ar.id, file_id=df.file_id, size=df.bytes_written)
if df.bytes_written > before:
self.send_status_response(
code=ErrorCode.PROGRESS, request_id=ar.id, file_id=df.file_id, size=df.bytes_written)
except TransmissionError as err:
if ar.send_errors:
self.send_transmission_error(ar.id, err)