mongodb/mongo-python-driver
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

indentation fix

Browse Source
This commit is contained in:
Sophia Yang 2026-05-15 11:24:29 -04:00
parent 8ed0d3577d
commit b29d615f24
2 changed files with 22 additions and 22 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

22
pymongo/asynchronous/pool.py
View File

@ -863,18 +863,18 @@ class Pool:
async with self._conns_lock:
self.conns = keep
if close:
async with self.lock:
self.state = PoolState.CLOSED
# Clear the wait queue
async with self._max_connecting_cond:
self._max_connecting_cond.notify_all()
async with self.size_cond:
self.size_cond.notify_all()
if close:
async with self.lock:
self.state = PoolState.CLOSED
# Clear the wait queue
async with self._max_connecting_cond:
self._max_connecting_cond.notify_all()
async with self.size_cond:
self.size_cond.notify_all()
if interrupt_connections:
for context in self.active_contexts.copy():
context.cancel()
if interrupt_connections:
for context in self.active_contexts.copy():
context.cancel()
listeners = self.opts._event_listeners
# CMAP spec says that close() MUST close sockets before publishing the

22
pymongo/synchronous/pool.py
View File

@ -861,18 +861,18 @@ class Pool:
with self._conns_lock:
self.conns = keep
if close:
with self.lock:
self.state = PoolState.CLOSED
# Clear the wait queue
with self._max_connecting_cond:
self._max_connecting_cond.notify_all()
with self.size_cond:
self.size_cond.notify_all()
if close:
with self.lock:
self.state = PoolState.CLOSED
# Clear the wait queue
with self._max_connecting_cond:
self._max_connecting_cond.notify_all()
with self.size_cond:
self.size_cond.notify_all()
if interrupt_connections:
for context in self.active_contexts.copy():
context.cancel()
if interrupt_connections:
for context in self.active_contexts.copy():
context.cancel()
listeners = self.opts._event_listeners
# CMAP spec says that close() MUST close sockets before publishing the