ahamilton/eris
1
0
Fork 0
Code Releases Activity

Cope with worker processes being terminated.

Browse source
This commit is contained in:
Andrew Hamilton 2020-10-15 12:57:37 +10:00
parent 0cdb5c3a37
commit f1902a4d1b
1 changed files with 9 additions and 4 deletions
Download patch file Download diff file Expand all files Collapse all files

7
eris/worker.py
View file

@ -33,17 +33,22 @@ class Worker:
pid_line = await self.process.stdout.readline() pid_line = await self.process.stdout.readline()
self.child_pgid = int(pid_line.strip()) self.child_pgid = int(pid_line.strip())
os.setpriority(os.PRIO_PGRP, self.child_pgid, 19) os.setpriority(os.PRIO_PGRP, self.child_pgid, 19)
self.process.stdin.write(f"{self.compression}\n".encode("utf-8"))
async def run_tool(self, path, tool): async def run_tool(self, path, tool):
while True:
self.process.stdin.write( self.process.stdin.write(
f"{tool.__qualname__}\n{path}\n".encode("utf-8")) f"{tool.__qualname__}\n{path}\n".encode("utf-8"))
data = await self.process.stdout.readline() data = await self.process.stdout.readline()
if data == b"":
await self.create_process()
else:
break
return tools.Status(int(data)) return tools.Status(int(data))
async def job_runner(self, screen, summary, log, jobs_added_event, async def job_runner(self, screen, summary, log, jobs_added_event,
appearance_changed_event): appearance_changed_event):
await self.create_process() await self.create_process()
self.process.stdin.write(f"{self.compression}\n".encode("utf-8"))
while True: while True:
await jobs_added_event.wait() await jobs_added_event.wait()
while True: while True: