techwire/copyparty
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

race-the-beam: improve phrasing

Browse Source
This commit is contained in:
ed 2025-04-13 18:51:45 +00:00
parent 98dcaee210
commit 2bd955ba9f
1 changed files with 6 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

7
copyparty/httpcli.py
View File

@ -4246,6 +4246,7 @@ class HttpCli(object):
self.log(t % (data_end / M, lower / M, upper / M), 6) self.log(t % (data_end / M, lower / M, upper / M), 6)
with self.u2mutex: with self.u2mutex:
if data_end > self.u2fh.aps.get(ap_data, data_end): if data_end > self.u2fh.aps.get(ap_data, data_end):
fhs: Optional[set[typing.BinaryIO]] = None
try: try:
fhs = self.u2fh.cache[ap_data].all_fhs fhs = self.u2fh.cache[ap_data].all_fhs
for fh in fhs: for fh in fhs:
@ -4253,7 +4254,11 @@ class HttpCli(object):
self.u2fh.aps[ap_data] = data_end self.u2fh.aps[ap_data] = data_end
self.log("pipe: flushed %d up2k-FDs" % (len(fhs),)) self.log("pipe: flushed %d up2k-FDs" % (len(fhs),))
except Exception as ex: except Exception as ex:
self.log("pipe: u2fh flush failed: %r" % (ex,)) if fhs is None:
err = "file is not being written to right now"
else:
err = repr(ex)
self.log("pipe: u2fh flush failed: " + err)
if lower >= data_end: if lower >= data_end:
if data_end: if data_end: