alienhunter/packetserver
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

Trying to allow a quickjob to get picked up by the server quickly.

Browse Source
This commit is contained in:
Michael Woods
2025-02-16 11:45:45 -05:00
parent 747d2aff7d
commit 33794d90fd
1 changed files with 8 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

9
src/packetserver/server/__init__.py
View File

@@ -50,6 +50,7 @@ class Server:
self.check_job_queue = True self.check_job_queue = True
self.last_check_job_queue = datetime.datetime.now() self.last_check_job_queue = datetime.datetime.now()
self.job_check_interval = 60 self.job_check_interval = 60
self.quick_job = False
if data_dir: if data_dir:
data_path = Path(data_dir) data_path = Path(data_dir)
else: else:
@@ -120,6 +121,11 @@ class Server:
def ping_job_queue(self): def ping_job_queue(self):
self.check_job_queue = True self.check_job_queue = True
self.last_check_job_queue = datetime.datetime.now() 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): def server_connection_bouncer(self, conn: PacketServerConnection):
logging.debug("new connection bouncer checking user status") logging.debug("new connection bouncer checking user status")
@@ -164,7 +170,8 @@ class Server:
return return
req_root_path = req.path.split("/")[0] req_root_path = req.path.split("/")[0]
if 'quick' in req.vars: 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: if req_root_path in self.handlers:
logging.debug(f"found handler for req {req}") logging.debug(f"found handler for req {req}")
self.handlers[req_root_path](req, conn, self.db) self.handlers[req_root_path](req, conn, self.db)