\ Maintain the dirty arbiter process by respawning if needed.
(self)
| 929 | self.dirty_arbiter = None |
| 930 | |
| 931 | def manage_dirty_arbiter(self): |
| 932 | """\ |
| 933 | Maintain the dirty arbiter process by respawning if needed. |
| 934 | """ |
| 935 | if self.dirty_arbiter_pid: |
| 936 | return # Already running |
| 937 | |
| 938 | if self.cfg.dirty_workers > 0 and self.cfg.dirty_apps: |
| 939 | self.log.info("Spawning dirty arbiter...") |
| 940 | self.spawn_dirty_arbiter() |
| 941 | |
| 942 | # ========================================================================= |
| 943 | # Control Socket Management |
no test coverage detected