add up2k mutex ping

This commit is contained in:
ed
2026-09-02 20:23:54 +00:00
parent 4e318d5165
commit f792a9529c
2 changed files with 10 additions and 1 deletions
+7 -1
View File
@@ -6896,11 +6896,17 @@ class HttpCli(object):
return True
def handle_fs_abrt(self):
rk = self.uparam["fs_abrt"]
if rk == "ping":
self.conn.hsrv.broker.ask("up2k.handle_fs_abrt", rk)
self.reply(b"pong")
return True
if self.args.no_fs_abrt:
t = "aborting an ongoing copy/move is disabled in server config"
raise Pebkac(403, t)
self.conn.hsrv.broker.say("up2k.handle_fs_abrt", self.uparam["fs_abrt"])
self.conn.hsrv.broker.say("up2k.handle_fs_abrt", rk)
self.loud_reply("aborting", status=200)
return True
+3
View File
@@ -4133,6 +4133,9 @@ class Up2k(object):
pass
def handle_fs_abrt(self, akey: str) -> None:
if akey == "ping":
with self.mutex, self.reg_mutex:
return
self.abrt_key = akey
def handle_rm(