From 33794d90fd9c376b05ca62ea145924c8e1b2fe60 Mon Sep 17 00:00:00 2001 From: Michael Woods Date: Sun, 16 Feb 2025 11:45:45 -0500 Subject: [PATCH] Trying to allow a quickjob to get picked up by the server quickly. --- src/packetserver/server/__init__.py | 9 ++++++++- 1 file changed, 8 insertions(+), 1 deletion(-) diff --git a/src/packetserver/server/__init__.py b/src/packetserver/server/__init__.py index ae827c8..6484304 100644 --- a/src/packetserver/server/__init__.py +++ b/src/packetserver/server/__init__.py @@ -50,6 +50,7 @@ class Server: self.check_job_queue = True self.last_check_job_queue = datetime.datetime.now() self.job_check_interval = 60 + self.quick_job = False if data_dir: data_path = Path(data_dir) else: @@ -120,6 +121,11 @@ class Server: def ping_job_queue(self): self.check_job_queue = True self.last_check_job_queue = datetime.datetime.now() + if self.quick_job: + self.job_check_interval = 5 + self.quick_job = False + else: + self.job_check_interval = 60 def server_connection_bouncer(self, conn: PacketServerConnection): logging.debug("new connection bouncer checking user status") @@ -164,7 +170,8 @@ class Server: return req_root_path = req.path.split("/")[0] if 'quick' in req.vars: - self.job_check_interval = 10 + self.job_check_interval = 8 + self.quick_job = True if req_root_path in self.handlers: logging.debug(f"found handler for req {req}") self.handlers[req_root_path](req, conn, self.db)