mirrors/copyparty
1
0
Fork 0
mirror of https://github.com/9001/copyparty.git synced 2025-08-17 09:02:15 -06:00
Code Issues Actions Packages Projects Releases Wiki Activity

async lsof w/ timeout

Browse source
This commit is contained in:
ed 2022-07-26 22:38:13 +02:00
parent 76adac7c72
commit b3e35bb494
1 changed files with 13 additions and 7 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

20
copyparty/util.py
View file

@ -1202,20 +1202,26 @@ def s3dec(rd: str, fn: str) -> tuple[str, str]:
)
def db_ex_chk(log: "NamedLogger", ex: Exception, db_path: str) -> None:
def db_ex_chk(log: "NamedLogger", ex: Exception, db_path: str) -> bool:
if str(ex) != "database is locked":
return False
try:
rc, so, se = runcmd([b"lsof", fsenc(db_path)])
zs = (so.strip() + "\n" + se.strip()).strip()
log("lsof {} = {}\n{}".format(db_path, rc, zs), 3)
except:
pass
thr = threading.Thread(target=lsof, args=(log, db_path))
thr.daemon = True
thr.start()
return True
def lsof(log: "NamedLogger", abspath: str) -> None:
try:
rc, so, se = runcmd([b"lsof", b"-R", fsenc(abspath)], timeout=5)
zs = (so.strip() + "\n" + se.strip()).strip()
log("lsof {} = {}\n{}".format(abspath, rc, zs), 3)
except:
log("lsof failed; " + min_ex(), 3)
def atomic_move(usrc: str, udst: str) -> None:
src = fsenc(usrc)
dst = fsenc(udst)