From: Vasek Sraier <git@vakabus.cz>
Date: Sat, 17 Jul 2021 08:10:45 +0000 (+0200)
Subject: formatting fix
X-Git-Tag: v6.0.0a1~133
X-Git-Url: http://git.ipfire.org/cgi-bin/gitweb.cgi?a=commitdiff_plain;h=a7eda4f207260318e9ce231fa11b867fff7efc52;p=thirdparty%2Fknot-resolver.git

formatting fix
---

diff --git a/manager/knot_resolver_manager/kres_manager.py b/manager/knot_resolver_manager/kres_manager.py
index 7b818861a..a1820a797 100644
--- a/manager/knot_resolver_manager/kres_manager.py
+++ b/manager/knot_resolver_manager/kres_manager.py
@@ -1,7 +1,7 @@
 import asyncio
 import logging
 from subprocess import SubprocessError
-from typing import List, Optional, Type
+from typing import List, Optional, Set, Type
 from uuid import uuid4
 
 from knot_resolver_manager.constants import KRESD_CONFIG_FILE
@@ -15,6 +15,16 @@ from .datamodel import KresConfig
 logger = logging.getLogger(__name__)
 
 
+class _PrettyIDAllocator:
+    def __init__(self):
+        self._used: Set[int] = set()
+
+    def free(self, n: int):
+        assert n in self._used
+        self._used.remove(n)
+
+
+
 class KresManager:
     """
     Core of the whole operation. Orchestrates individual instances under some
@@ -76,15 +86,15 @@ class KresManager:
         # spawn new children if needed
         while len(self._workers) < n:
             await self._spawn_new_worker()
-    
+
     def _is_gc_running(self) -> bool:
         return self._gc is not None
-    
+
     async def _start_gc(self):
         subprocess = await self._controller.create_subprocess(SubprocessType.GC, "gc")
         await subprocess.start()
         self._gc = subprocess
-    
+
     async def _stop_gc(self):
         assert self._gc is not None
         await self._gc.stop()