self._next_scheduled_for_alias.clear()

self._query_heap.clear()

def schedule_ptr_first_refresh(self, pointer: DNSPointer) -> None:

"""Schedule a query for a pointer."""

expire_time_millis = pointer.get_expiration_time(100)

refresh_time_millis = pointer.get_expiration_time(_EXPIRE_REFRESH_TIME_PERCENT)

self._schedule_ptr_refresh(pointer, expire_time_millis, refresh_time_millis)

def _schedule_ptr_refresh(

self, pointer: DNSPointer, expire_time_millis: float_, refresh_time_millis: float_

) -> None:

):

return

current.cancelled = True

del self._next_scheduled_for_alias[pointer.alias]

expire_time_millis = pointer.get_expiration_time(100)

self._schedule_ptr_refresh(pointer, expire_time_millis, refresh_time_millis)

if query.when_millis > end_time_millis:

next_scheduled = query

break

query = heappop(self._query_heap)

ready_types.add(query.name)

heappop(self._query_heap)

del self._next_scheduled_for_alias[query.alias]

# If there is still more than 10% of the TTL remaining

# schedule a query again to try to rescue the record

for type_ in self.types.intersection(cached_possible_types(pointer.name)):

if old_record is None:

self._enqueue_callback(SERVICE_STATE_CHANGE_ADDED, type_, pointer.alias)

self.query_scheduler.schedule_ptr_first_refresh(pointer)

self.query_scheduler.reschedule_ptr_first_refresh(pointer)

elif pointer.is_expired(now):

self._enqueue_callback(SERVICE_STATE_CHANGE_REMOVED, type_, pointer.alias)

self.query_scheduler.cancel_ptr_refresh(pointer)