Skip to content

feat: small speed up to processing incoming records #1345

New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Merged
bdraco merged 1 commit into from
Dec 15, 2023
Merged

feat: small speed up to processing incoming records #1345

Show file tree
Hide file tree
Changes from all commits
Commits
Show all changes
1 commit
Select commit
File filter

Filter by extension

Filter by extension
Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
6 changes: 3 additions & 3 deletions src/zeroconf/_services/browser.pxd
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -70,10 +70,10 @@ cdef class _ServiceBrowserBase(RecordUpdateListener):

cpdef _generate_ready_queries(self, object first_request, object now)

cpdef _enqueue_callback(self, object state_change, object type_, object name)
cpdef void _enqueue_callback(self, object state_change, object type_, object name)

@cython.locals(record_update=RecordUpdate, record=DNSRecord, cache=DNSCache, service=DNSRecord, pointer=DNSPointer)
cpdef async_update_records(self, object zc, double now, cython.list records)
cpdef void async_update_records(self, object zc, double now, cython.list records)

cpdef cython.list _names_matching_types(self, object types)

Expand All @@ -89,4 +89,4 @@ cdef class _ServiceBrowserBase(RecordUpdateListener):

cpdef _cancel_send_timer(self)

cpdef async_update_records_complete(self)
cpdef void async_update_records_complete(self)
2 changes: 1 addition & 1 deletion src/zeroconf/_services/info.pxd
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -65,7 +65,7 @@ cdef class ServiceInfo(RecordUpdateListener):
cdef public cython.set _get_address_and_nsec_records_cache

@cython.locals(record_update=RecordUpdate, update=bint, cache=DNSCache)
cpdef async_update_records(self, object zc, double now, cython.list records)
cpdef void async_update_records(self, object zc, double now, cython.list records)

@cython.locals(cache=DNSCache)
cpdef bint _load_from_cache(self, object zc, double now)
Expand Down
4 changes: 2 additions & 2 deletions src/zeroconf/_updates.pxd
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -4,6 +4,6 @@ import cython

cdef class RecordUpdateListener:

cpdef async_update_records(self, object zc, double now, cython.list records)
cpdef void async_update_records(self, object zc, double now, cython.list records)

cpdef async_update_records_complete(self)
cpdef void async_update_records_complete(self)