MCPcopy Index your code
hub / github.com/MagicStack/asyncpg / trigger_connectivity_loss

Method trigger_connectivity_loss

asyncpg/_testbase/fuzzer.py:126–127  ·  view source on GitHub ↗
(self)

Source from the content-addressed store, hash-verified

124 self.connections[conn] = conn_task
125
126 def trigger_connectivity_loss(self):
127 self.loop.call_soon_threadsafe(self._trigger_connectivity_loss)
128
129 def _trigger_connectivity_loss(self):
130 self.connectivity.clear()

Callers 4

test_connection_close_timeoutMethod · 0.80
test_pool_acquire_timeoutMethod · 0.80
test_pool_release_timeoutMethod · 0.80
kill_connectivityMethod · 0.80

Calls

no outgoing calls

Tested by 4

test_connection_close_timeoutMethod · 0.64
test_pool_acquire_timeoutMethod · 0.64
test_pool_release_timeoutMethod · 0.64
kill_connectivityMethod · 0.64