MCPcopy Create free account
hub / github.com/apache/qpid-proton / timer_tick

Method timer_tick

python/proton/_reactor.py:307–318  ·  view source on GitHub ↗
(self)

Source from the content-addressed store, hash-verified

305 return task
306
307 def timer_tick(self) -> None:
308 while self._timers > 0:
309 t = self._timerheap[0]
310 if t._cancelled:
311 heapq.heappop(self._timerheap)
312 self._timers -= 1
313 elif t._deadline > self._now:
314 return
315 else:
316 heapq.heappop(self._timerheap)
317 self._timers -= 1
318 self.push_event(t, Event.TIMER_TASK)
319
320 @property
321 def timer_deadline(self) -> Optional[float]:

Callers 1

expiredMethod · 0.80

Calls 1

push_eventMethod · 0.95

Tested by

no test coverage detected