MCPcopy
hub / github.com/MagicStack/asyncpg / clear

Method clear

asyncpg/connection.py:2572–2583  ·  view source on GitHub ↗
(self)

Source from the content-addressed store, hash-verified

2570 return (e._statement for e in self._entries.values())
2571
2572 def clear(self):
2573 # Store entries for later.
2574 entries = tuple(self._entries.values())
2575
2576 # Clear the entries dict.
2577 self._entries.clear()
2578
2579 # Make sure that we cancel all scheduled callbacks
2580 # and call on_remove callback for each entry.
2581 for entry in entries:
2582 self._clear_entry_callback(entry)
2583 self._on_remove(entry._statement)
2584
2585 def _set_entry_timeout(self, entry):
2586 # Clear the existing timeout.

Callers 9

_resetMethod · 0.80
_cleanupMethod · 0.80
_clean_tasksMethod · 0.80
_mark_stmts_as_closedMethod · 0.80
_restore_connectivityMethod · 0.80

Calls 1

_clear_entry_callbackMethod · 0.95

Tested by 1