Lines Matching refs:heap_entry
258 heap_entry = heapq.heappop(self._dispatcher_minheap)
264 dispatcher_uri = heap_entry[DISPATCHER_URI]
266 heap_entry[RPM_COUNT] = heap_entry[RPM_COUNT] + 1
267 heapq.heappush(self._dispatcher_minheap, heap_entry)
285 heap_entry = [DEFAULT_RPM_COUNT, dispatcher_uri]
286 heapq.heappush(self._dispatcher_minheap, heap_entry)
287 self._entry_dict[dispatcher_uri] = heap_entry
307 heap_entry = self._entry_dict.get(uri_to_unregister)
308 if not heap_entry:
312 heap_entry[RPM_COUNT] = TERMINATED
