feat: improve incoming data processing performance (#1194) · python-zeroconf/python-zeroconf@a56c776

4 files changed

lines changed

Original file line number	Diff line number	Diff line change
`@@ -151,6 +151,18 @@ def _make_wrapped_transport(transport: asyncio.DatagramTransport) -> _WrappedTra`
`151`	`151`	`class AsyncEngine:`
`152`	`152`	`"""An engine wraps sockets in the event loop."""`
`153`	`153`
	`154`	`+__slots__ = (`
	`155`	`+'loop',`
	`156`	`+'zc',`
	`157`	`+'protocols',`
	`158`	`+'readers',`
	`159`	`+'senders',`
	`160`	`+'running_event',`
	`161`	`+'_listen_socket',`
	`162`	`+'_respond_sockets',`
	`163`	`+'_cleanup_timer',`
	`164`	`+ )`
	`165`	`+`
`154`	`166`	`def __init__(`
`155`	`167`	`self,`
`156`	`168`	`zeroconf: 'Zeroconf',`

Original file line number	Diff line number	Diff line change
`@@ -46,6 +46,9 @@ def update_service(self, zc: 'Zeroconf', type_: str, name: str) -> None:`
`46`	`46`
`47`	`47`
`48`	`48`	`class Signal:`
	`49`	`+`
	`50`	`+__slots__ = ('_handlers',)`
	`51`	`+`
`49`	`52`	`def __init__(self) -> None:`
`50`	`53`	`self._handlers: List[Callable[..., None]] = []`
`51`	`54`
`@@ -59,6 +62,9 @@ def registration_interface(self) -> 'SignalRegistrationInterface':`
`59`	`62`
`60`	`63`
`61`	`64`	`class SignalRegistrationInterface:`
	`65`	`+`
	`66`	`+__slots__ = ('_handlers',)`
	`67`	`+`
`62`	`68`	`def __init__(self, handlers: List[Callable[..., None]]) -> None:`
`63`	`69`	`self._handlers = handlers`
`64`	`70`

Original file line number	Diff line number	Diff line change
`@@ -85,6 +85,8 @@`
`85`	`85`	`class _DNSPointerOutgoingBucket:`
`86`	`86`	`"""A DNSOutgoing bucket."""`
`87`	`87`
	`88`	`+__slots__ = ('now', 'out', 'bytes')`
	`89`	`+`
`88`	`90`	`def __init__(self, now: float, multicast: bool) -> None:`
`89`	`91`	`"""Create a bucke to wrap a DNSOutgoing."""`
`90`	`92`	`self.now = now`
`@@ -196,12 +198,14 @@ class QueryScheduler:`
`196`	`198`
`197`	`199`	`"""`
`198`	`200`
	`201`	`+__slots__ = ('_schedule_changed_event', '_types', '_next_time', '_first_random_delay_interval', '_delay')`
	`202`	`+`
`199`	`203`	`def __init__(`
`200`	`204`	`self,`
`201`	`205`	`types: Set[str],`
`202`	`206`	`delay: int,`
`203`	`207`	`first_random_delay_interval: Tuple[int, int],`
`204`		`- ):`
	`208`	`+ ) -> None:`
`205`	`209`	`self._schedule_changed_event: Optional[asyncio.Event] = None`
`206`	`210`	`self._types = types`
`207`	`211`	`self._next_time: Dict[str, float] = {}`
`@@ -261,6 +265,22 @@ def process_ready_types(self, now: float) -> List[str]:`
`261`	`265`	`class _ServiceBrowserBase(RecordUpdateListener):`
`262`	`266`	`"""Base class for ServiceBrowser."""`
`263`	`267`
	`268`	`+__slots__ = (`
	`269`	`+'types',`
	`270`	`+'zc',`
	`271`	`+'addr',`
	`272`	`+'port',`
	`273`	`+'multicast',`
	`274`	`+'question_type',`
	`275`	`+'_pending_handlers',`
	`276`	`+'_service_state_changed',`
	`277`	`+'query_scheduler',`
	`278`	`+'done',`
	`279`	`+'_first_request',`
	`280`	`+'_next_send_timer',`
	`281`	`+'_query_sender_task',`
	`282`	`+ )`
	`283`	`+`
`264`	`284`	`def __init__(`
`265`	`285`	`self,`
`266`	`286`	`zc: 'Zeroconf',`

Original file line number	Diff line number	Diff line change
`@@ -33,6 +33,8 @@ class ServiceRegistry:`
`33`	`33`	`the event loop as it is not thread safe.`
`34`	`34`	`"""`
`35`	`35`
	`36`	`+__slots__ = ("_services", "types", "servers")`
	`37`	`+`
`36`	`38`	`def __init__(`
`37`	`39`	`self,`
`38`	`40`	`) -> None:`