(self)
| 27 | return used_mem |
| 28 | |
| 29 | def run(self): |
| 30 | while True: |
| 31 | for (pid, worker) in list(self.server.WORKERS.items()): |
| 32 | if self.memory_usage(pid) > self.max_mem: |
| 33 | self.server.log.info("Pid %s killed (memory usage > %s)", |
| 34 | pid, self.max_mem) |
| 35 | self.server.kill_worker(pid, signal.SIGTERM) |
| 36 | time.sleep(self.timeout) |
| 37 | |
| 38 | |
| 39 | def when_ready(server): |