feat: small speed up to process incoming packets (#1309) · python-zeroconf/python-zeroconf@56ef908

3 files changed

lines changed

Original file line number	Diff line number	Diff line change
`@@ -573,7 +573,7 @@ def handle_assembled_query(`
`573`	`573`	`addr: str,`
`574`	`574`	`port: int,`
`575`	`575`	`transport: _WrappedTransport,`
`576`		`-v6_flow_scope: Union[Tuple[()], Tuple[int, int]] = (),`
	`576`	`+v6_flow_scope: Union[Tuple[()], Tuple[int, int]],`
`577`	`577`	`) -> None:`
`578`	`578`	`"""Respond to a (re)assembled query.`
`579`	`579`

Original file line number	Diff line number	Diff line change
`@@ -37,6 +37,7 @@ cdef class AsyncListener:`
`37`	`37`
`38`	`38`	`cdef _cancel_any_timers_for_addr(self, object addr)`
`39`	`39`
	`40`	`+@cython.locals(incoming=DNSIncoming, deferred=list)`
`40`	`41`	`cpdef handle_query_or_defer(`
`41`	`42`	`self,`
`42`	`43`	`DNSIncoming msg,`
`@@ -45,3 +46,12 @@ cdef class AsyncListener:`
`45`	`46`	`object transport,`
`46`	`47`	`tuple v6_flow_scope`
`47`	`48`	`)`
	`49`	`+`
	`50`	`+ cpdef _respond_query(`
	`51`	`+self,`
	`52`	`+object msg,`
	`53`	`+object addr,`
	`54`	`+object port,`
	`55`	`+object transport,`
	`56`	`+tuple v6_flow_scope`
	`57`	`+ )`

Original file line number	Diff line number	Diff line change
`@@ -220,7 +220,7 @@ def _respond_query(`
`220`	`220`	`addr: _str,`
`221`	`221`	`port: _int,`
`222`	`222`	`transport: _WrappedTransport,`
`223`		`-v6_flow_scope: Union[Tuple[()], Tuple[int, int]] = (),`
	`223`	`+v6_flow_scope: Union[Tuple[()], Tuple[int, int]],`
`224`	`224`	`) -> None:`
`225`	`225`	`"""Respond to a query and reassemble any truncated deferred packets."""`
`226`	`226`	`self._cancel_any_timers_for_addr(addr)`