feat: small cleanups to cache cleanup interval (#1146)

bdraco · web-flow · commit b434b60f14eb · 2023-04-01T20:05:48.000-10:00
diff --git a/src/zeroconf/_core.py b/src/zeroconf/_core.py
@@ -175,9 +175,7 @@ def setup(self, loop: asyncio.AbstractEventLoop, loop_thread_ready: Optional[thr
     async def _async_setup(self, loop_thread_ready: Optional[threading.Event]) -> None:
         """Set up the instance."""
         assert self.loop is not None
-        self._cleanup_timer = self.loop.call_later(
-            millis_to_seconds(_CACHE_CLEANUP_INTERVAL), self._async_cache_cleanup
-        )
+        self._cleanup_timer = self.loop.call_later(_CACHE_CLEANUP_INTERVAL, self._async_cache_cleanup)
         await self._async_create_endpoints()
         assert self.running_event is not None
         self.running_event.set()
@@ -213,9 +211,7 @@ def _async_cache_cleanup(self) -> None:
         )
         self.zc.record_manager.async_updates_complete(False)
         assert self.loop is not None
-        self._cleanup_timer = self.loop.call_later(
-            millis_to_seconds(_CACHE_CLEANUP_INTERVAL), self._async_cache_cleanup
-        )
+        self._cleanup_timer = self.loop.call_later(_CACHE_CLEANUP_INTERVAL, self._async_cache_cleanup)
 
     async def _async_close(self) -> None:
         """Cancel and wait for the cleanup task to finish."""
diff --git a/src/zeroconf/const.py b/src/zeroconf/const.py
@@ -32,7 +32,7 @@
 _BROWSER_TIME = 1000  # ms
 _DUPLICATE_QUESTION_INTERVAL = _BROWSER_TIME - 1  # ms
 _BROWSER_BACKOFF_LIMIT = 3600  # s
-_CACHE_CLEANUP_INTERVAL = 10000  # ms
+_CACHE_CLEANUP_INTERVAL = 10  # s
 _LOADED_SYSTEM_TIMEOUT = 10  # s
 _STARTUP_TIMEOUT = 9  # s must be lower than _LOADED_SYSTEM_TIMEOUT
 _ONE_SECOND = 1000  # ms
diff --git a/tests/services/test_browser.py b/tests/services/test_browser.py
@@ -1120,7 +1120,7 @@ def mock_incoming_msg(records: Iterable[r.DNSRecord]) -> r.DNSIncoming:
 
 
 @patch.object(_handlers, '_DNS_PTR_MIN_TTL', 1)
-@patch.object(_core, "_CACHE_CLEANUP_INTERVAL", 10)
+@patch.object(_core, "_CACHE_CLEANUP_INTERVAL", 0.01)
 def test_service_browser_expire_callbacks():
     """Test that the ServiceBrowser matching does not match partial names."""
     # instantiate a zeroconf instance
diff --git a/tests/test_core.py b/tests/test_core.py
@@ -51,8 +51,7 @@ async def make_query():
 # which is not threadsafe
 @pytest.mark.asyncio
 async def test_reaper():
-    with patch.object(_core, "_CACHE_CLEANUP_INTERVAL", 10):
-        assert _core._CACHE_CLEANUP_INTERVAL == 10
+    with patch.object(_core, "_CACHE_CLEANUP_INTERVAL", 0.01):
         aiozc = AsyncZeroconf(interfaces=['127.0.0.1'])
         zeroconf = aiozc.zeroconf
         cache = zeroconf.cache
@@ -88,8 +87,7 @@ async def test_reaper():
 @pytest.mark.asyncio
 async def test_reaper_aborts_when_done():
     """Ensure cache cleanup stops when zeroconf is done."""
-    with patch.object(_core, "_CACHE_CLEANUP_INTERVAL", 10):
-        assert _core._CACHE_CLEANUP_INTERVAL == 10
+    with patch.object(_core, "_CACHE_CLEANUP_INTERVAL", 0.01):
         aiozc = AsyncZeroconf(interfaces=['127.0.0.1'])
         zeroconf = aiozc.zeroconf
         record_with_10s_ttl = r.DNSAddress('a', const._TYPE_SOA, const._CLASS_IN, 10, b'a')
